INNER CODE UNIT · JavaScript

nextTime

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

    const nextTime = delivery.after.getTime() + Math.pow(10, delivery.attempt++)
    delivery.after = new Date(nextTime)
    const result = await this.db.collection('deliveryQueue')
      .insertOne(delivery, { forceServerObjectId: true })
    return result.acknowledged
  }

  async setup (initialUser) {
    const db = this.db
    // inbox
    await db.collection('streams').createIndex({
      id: 1
    }, {
      name: 'streams-primary',
      unique: true
    })
    await db.collection('streams').createIndex({
      '_meta.collection': 1,

View source record →