INNER CODE UNIT · JavaScript

docs

immers-space/activitypub-express · store/index.js:21

    const docs = addresses.map(address => ({
      address,
      actorId,
      signingKey,
      body,
      attempt: 0,
      after: new Date()
    }))
    await this.db.collection('deliveryQueue')
      .insertMany(docs, { ordered: false, forceServerObjectId: true })
    // TODO maybe catch errored docs and retry?
    return true
  }

  async deliveryDequeue () {
    const queryOptions = {
      sort: { after: 1, _id: 1 },
      projection: { _id: 0 }

View source record →