Revenue & Ops
for Nigerian
Tailors.

@Post('webhook/whatsapp') async handleInbound(@Body() payload: WaWebhookDto, @Headers() headers: Record<string, string>) { // Verify signature immediately — reject fakes this.waService.verifySignature(payload, headers['x-hub-signature-256']); const entry = payload.entry?.[0]?.changes?.[0]?.value; if (!entry?.messages?.length) return { status: 'ok' }; // status update, skip const message = entry.messages[0]; const phoneNumberId = entry.metadata.phone_number_id; // Non-blocking: queue for processing await this.waQueue.add('process-inbound', { phoneNumberId, waId: message.from, messageId: message.id, body: message.text?.body ?? '', timestamp: message.timestamp, type: message.type, }); return { status: 'ok' }; // Always return 200 fast }

@Processor('ai.parser') export class AiParserProcessor extends WorkerHost { async process(job: Job<InboundMessageJob>): Promise<void> { const { phoneNumberId, waId, body, messageId } = job.data; // 1. Resolve tenant from phone number ID const tenant = await this.tenantRepo.findByWaPhoneId(phoneNumberId); if (!tenant) return; // 2. Find or create customer let customer = await this.customerRepo.findByWaId(waId, tenant.id); if (!customer) { customer = await this.customerRepo.create({ waId, tenantId: tenant.id }); } // 3. Store raw message await this.waMessageRepo.save({ waMessageId: messageId, body, direction: 'inbound', customerId: customer.id, tenantId: tenant.id }); // 4. Call AI to extract order intent const parsed = await this.aiService.parseOrderIntent(body, customer); if (parsed.isOrder) { // 5. Create draft order const order = await this.ordersService.create({ tenantId: tenant.id, customerId: customer.id, styleName: parsed.style, deadline: parsed.deadline, notes: parsed.notes, source: 'whatsapp', waThreadId: waId, }); // 6. Send confirmation back on WhatsApp await this.waService.sendMessage(tenant, waId, `✅ Order ${order.orderRef} received!\n\nStyle: ${parsed.style}\nDeadline: ${parsed.deadlineFormatted}\n\nReply with your measurements or type MEASURES to reuse saved ones.` ); } } }