INNER CODE UNIT · JavaScript

ApexStore

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

class ApexStore extends IApexStore {
  constructor () {
    super()
    this.projection = { _id: 0, _meta: 0 }
    this.metaProj = { _id: 0 }
  }

  async deliveryEnqueue (actorId, body, addresses, signingKey) {
    if (!addresses || !addresses.length) return
    if (!Array.isArray(addresses)) { addresses = [addresses] }
    const docs = addresses.map(address => ({
      address,
      actorId,
      signingKey,
      body,
      attempt: 0,
      after: new Date()
    }))

View source record →