'access-content', handle errors

[github-actions[bot]]

'access-content', handle errors

https://github.com/zorko-io/zorko-platform/blob/8873ccabdeeaa3991ad718315a151ba2fe7d8c23/packages/access-content/lib/mongo/MongoRegisterAccess.mjs#L103

import {NotFoundError} from '@zorko-io/util-error'
import {toIterable} from '@zorko-io/util-lang'
import {MongoContentAccess} from './MongoContentAccess'

export class MongoRegisterAccess extends RegisterAccess {

  static name = 'register'

  static schema = {
    bsonType: "object",
    required: [ "name", "owner"],
    properties: {
      name: {
        bsonType: "string",
        description: "must be a string and is required"
      },
      owner: {
        bsonType: "string",
        description: "must be a string and is required"
      }
    }
  }

  #db = null
  #log = null
  #context = null
  #collection = null
  #deps = null

  /**
   *
   * @param {Object} context
   * @param {String} context.collection - name of collection
   * @param {Object} deps
   */

  constructor(context = {}, deps) {
    super()
    const {log, db,} = deps

    assert(context, 'should have context')
    assert(log,'should have a log')
    assert(db, 'should have a db')

    this.#deps = deps
    this.#context = context
    this.#db = db
    this.#log = deps.log
    this.#log = log.child({class:this.constructor.name})
    this.#collection = this.#db.collection(MongoRegisterAccess.name)
  }

  async add(owner, name = 'default') {
    assert(owner)
    assert(name)

    let repositoryCollectionName = MongoRepositoryAccess.toCollectionName(owner,name)

    // TODO: 'access-content', throw an exception if it already exists
    const result = await this.#collection.insertOne({
      owner,
      name: repositoryCollectionName
    })

    const doc = result.ops.pop()

    let contentCollectionName = MongoContentAccess.toCollectionName(owner, name)

    // TODO: 'access-content' creation of collections
    // - handle errors (wrap in resource access error)
    // - make a distinguish between name and location of target collection
    // - add validation schema

    await this.#db.createCollection(repositoryCollectionName)
    await this.#db.createCollection(contentCollectionName)

    return this.#createRepositoryAccess({doc})
  }

   iterate(query) {
    const cursor = this.#collection.find({
      owner: query.owner
    })

    return toIterable(
      new MongoCursorIterator({
        cursor
      },{
      wrapValue: this.#createRepositoryAccess
    }))
  }

  // TODO: 'access-content', get, error handling
  // label: tech-debt
  async get(id) {
    assert(id)

    // TODO: 'access-content', handle errors
    const doc = await this.#collection.findOne({ _id: toObjectId(id)})

    if(!doc) {
      throw new NotFoundError(`Can't find repo by #id=${id}`)
    }

    return this.#createRepositoryAccess({doc})
  }

  // TODO: 'access-content', remove, error handling
  // label: tech-debt
  async remove(id) {
    assert(id)

    const {value} =  await this.#collection.findOneAndDelete({ _id: toObjectId(id)})

    await this.#db.collection(value.name).drop()
  }

  #createRepositoryAccess = (options) => {
    return this.#deps.createRepositoryAccess(options, this.#deps)
  }
}
 No newline at end of file
ew file mode 100644
ndex 0000000..f410f16
++ b/packages/access-content/lib/mongo/MongoRepositoryAccess.mjs

bf0d160a1c54107bec74c41594bd324c1fc8f4cb

[github-actions[bot]]

Closed in 8e5dbe3835c8a3f41dd74b6dd42c30bce222c919