BullMQ queues #
Prefix: rapidstor. Config: config/default.json → scheduler.queues.
| Queue | Worker | Schedule |
|---|---|---|
| sync | workers/sync/ | unitsShort 15min; chargeBatch 6h; daily full sync |
workers/mail/ | On-demand delayed jobs | |
| webhooks | workers/webhooks/ | On-demand outbound |
| rate-push | workers/rate-push/ | On-demand SiteLink rate updates |
| indexing | workers/indexing/ | MongoDB index reconciliation per corp DB |
Index reconciliation worker #
New indexing queue (core/services/indexing/): reads desired indexes from registry.ts, reconciles against each corp DB. Populated collections use Atlas Admin API rolling index builds; empty collections get foreground indexes. Also runs inline on new corp creation. Config: config/default.json → indexing section; env vars in .env.example.
Sync collections #
unitsShort, unitsFull, unitTypeGroup, site, chargeDescription, inventory, insuranceCoverage, marketingSource, discountPlan, paymentSettings, paymentTypes, form, chargeBatch.
Mail job actions #
delayedInsuranceSms, delayedQuoteEmail, delayedReservationEmail, delayedTieredEnquiryEmail, assistanceMovingEmail (sent when external move-in reservation includes assistance-moving flag).