notification-processor

notification-processor

Breaking change

• Configure API URL and Notification API URL at job processor

//2.x
require("notification-processor").JobProcessor({
    buildOpts: (message) => ({}), notificationApiUrl: "apiNotificationUrl"
})

//3.x
require("notification-processor").JobProcessor({
    apiUrl: "",
    notificationApiUrl: ""
})

New Features

• Adding request async processor

require("notification-processor").RequestAsyncProcessor({
    apiUrl: "baseAPI..."
    silentErrors: []
})

Migrating 1.x -> 2.x

Deadletter Processor

// 1.x
const buildOpts = (message) => { return ....  }
deadletterProcessor = DeadletterProcessor({
    connection: connection,
    name: "aFunctionName",
    maxDequeueCount: 1,
    rowKeyGenerator: (message) => { return ...... }
}, processor())

// 2.x
const buildOpts = (message) => { return ....  }
const sender = {
    resource: (notification) => { return ... }
    user: (notification) => { return ... }
}

deadletterProcessor = DeadletterProcessor({
    connection: connection,
    name: "aFunctionName",
    maxDequeueCount: 1,
    sender: sender
}, processor())

Job Processor

// 1.x
const buildOpts = (message) => { return ....  }
const processor = JobsProcessor(buildOpts, nonRetryable)

// 2.x
const buildOpts = ({ message }) => { return ...... }
const processor = JobsProcessor({
    buildOpts: optionsGenerator,
    maxRetries,
    nonRetryable
})

To publish

npm version [major/minor/patch]
npm publish
git push origin HEAD
git push origin HEAD --tags