Class CloudDBAdapter

lib/cloudDBAdapter.js:18–54

    return v
  })
class CloudDBAdapter {
  constructor(url, { serialize = stringify, deserialize = parse, fetchOptions = {} } = {}) {
    this.url = url
    this.serialize = serialize
    this.deserialize = deserialize
    this.fetchOptions = fetchOptions
  }

  async read() {
    try {
      let res = await got(this.url, {
        method: 'GET',
        headers: {
          Accept: 'application/json;q=0.9,text/plain',
        },
        ...this.fetchOptions,
      })
      if (res.statusCode !== 200) throw res.statusMessage
      return this.deserialize(res.body)
    } catch (e) {
      return null
    }
  }

  async write(obj) {
    let res = await got(this.url, {
      method: 'POST',
      headers: {
        'Content-Type': 'application/json',
      },
      ...this.fetchOptions,
      body: this.serialize(obj),
    })
    if (res.statusCode !== 200) throw res.statusMessage
    return res.body
  }
}

export default CloudDBAdapter