f305ee6e1a
- Added support for Salesforce Platform Events, specifically subscribing to `OrderProvisionRequested__e` to trigger provisioning jobs. - Introduced new environment variables for Salesforce event configuration, including SF_EVENTS_ENABLED, SF_PROVISION_EVENT_CHANNEL, and SF_PUBSUB_ENDPOINT. - Refactored order fulfillment process to utilize event-driven architecture, enhancing reliability and scalability. - Updated documentation to reflect changes in the provisioning workflow and environment variable requirements. - Removed deprecated webhook handling code to streamline the integration.
12 lines
375 B
TypeScript
12 lines
375 B
TypeScript
import { Processor, WorkerHost } from "@nestjs/bullmq";
|
|
import { Job } from "bullmq";
|
|
import { QUEUE_NAMES } from "../common/queue/queue.constants";
|
|
|
|
@Processor(QUEUE_NAMES.RECONCILE)
|
|
export class ReconcileProcessor extends WorkerHost {
|
|
async process(_job: Job) {
|
|
// TODO: Implement reconciliation logic
|
|
// Note: In production, this should use proper logging
|
|
}
|
|
}
|