repo.js

import WBEdit from 'wikibase-edit'
import { WBK } from 'wikibase-sdk'

export default class WikibaseRepository {
  constructor (origin, opts = {}) {
    this.origin = origin

    this.read = new WBK({
      instance: origin
    })

    if (opts.oauth) {
      this.edit = new WBEdit({
        instance: origin,
        credentials: {
          oauth: opts.oauth
        }
      })
    }
  }

  getContentLanguages () {
    return fetch(`${this.origin}/w/api.php?action=query&meta=wbcontentlanguages&format=json`)
      .then(r => r.json())
      .then(body => Object.keys(body.query.wbcontentlanguages))
  }

  createEntities (...entities) {
    if (!this.edit) {
      return Promise.reject(new Error('Cannot edit a read only instance.'))
    }
    return Promise.allSettled(entities.map(async entity => {
      return this.edit.entity.create(entity)
    }))
      .then((results) => {
        for (const result of results) {
          if (result.status === 'rejected') {
            throw new Error(result.reason)
          }
        }
        return results.map(v => v.value)
      })
  }

  getEntities (...identifiers) {
    return Promise.all(identifiers.map(async identifier => {
      const [entityId, revision] = identifier.split('@')
      const url = revision
        ? await this.read.getEntityRevision({
          id: entityId,
          revision
        })
        : await this.read.getEntities({
          ids: [entityId]
        })
      const { entities } = await fetch(url).then(res => res.json())
      return entities[entityId]
    }))
  }
}