export const handleMessage = async ({
message,
env,
}) => {
const { items, nextPageToken } =
await api.listByStatus({
limit: 100,
nextPageToken: message.nextPageToken,
status: 'approved',
});
if (nextPageToken) {
await sendQueueMessage({
message: {
type: '<REDACTED>',
nextPageToken,
},
env,
});
}
const toBeProcessed = items
.filter((f) => !f.processed)
await sendBatchQueueMessage({
batch: toBeProcessed.map((transaction) => ({
message: {
transaction,
type: '<OTHERMESSAGE>',
},
})),
env,
});
};
export const handleMessage = async ({
message,
env,
}) => {
const { items, nextPageToken } =
await api.listByStatus({
limit: 100,
nextPageToken: message.nextPageToken,
status: 'approved',
});
if (nextPageToken) {
await sendQueueMessage({
message: {
type: '<REDACTED>',
nextPageToken,
},
env,
});
}
const toBeProcessed = items
.filter((f) => !f.processed)
await sendBatchQueueMessage({
batch: toBeProcessed.map((transaction) => ({
message: {
transaction,
type: '<OTHERMESSAGE>',
},
})),
env,
});
};