Dot Domino CRM — Developer Architecture

// fallback-worker.ts — BullMQ job processor async function processFallbackJob(job: Job<FallbackPayload>) { const { leadId, stepId, attemptChain } = job.data; for (const channel of attemptChain) { const result = await sendViaChannel(channel, leadId, stepId); await db.communicationLog.insert({ leadId, channel, status: result.status, sentAt: new Date(), messageId: result.messageId }); if (result.status === 'delivered') break; // stop chain on success // wait configured window before next fallback await sleep(FALLBACK_DELAY_MS[channel]); // {WA: 30min, SMS: 15min, RCS: 10min} } if (allFailed) { await taskService.createAgentTask({ leadId, reason: 'all_channels_failed' }); } }

// DB schema — key tables for drip engine CREATE TABLE sequences ( id UUID PRIMARY KEY, name TEXT, trigger_type TEXT, -- 'lead_created' | 'stage_changed' | 'no_reply' | ... trigger_config JSONB, -- {stage: 'qualified', delay_days: 2} is_active BOOLEAN, org_id UUID ); CREATE TABLE sequence_steps ( id UUID PRIMARY KEY, sequence_id UUID REFERENCES sequences, step_order INT, step_type TEXT, -- 'send_message' | 'wait' | 'condition' | 'update_stage' channel_priority TEXT[], -- ['whatsapp','sms','rcs','email'] ← fallback chain delay_ms BIGINT, -- delay before this step fires template_id UUID, condition JSONB, -- {event: 'opened', window_ms: 86400000} yes_step_id UUID, -- branch if condition true no_step_id UUID -- branch if condition false ); CREATE TABLE sequence_enrollments ( id UUID PRIMARY KEY, lead_id UUID, sequence_id UUID, current_step UUID, status TEXT, -- 'active' | 'paused' | 'completed' | 'converted' | 'unsubscribed' enrolled_at TIMESTAMPTZ, completed_at TIMESTAMPTZ ); CREATE TABLE communication_log ( id UUID PRIMARY KEY, lead_id UUID, step_id UUID, channel TEXT, -- which channel was actually used status TEXT, -- 'sent' | 'delivered' | 'opened' | 'clicked' | 'bounced' | 'failed' external_id TEXT, -- BSP message ID sent_at TIMESTAMPTZ, delivered_at TIMESTAMPTZ );

-- ORGANISATIONS (multi-tenant) organisations (id, name, plan, settings, created_at) users (id, org_id, email, role, password_hash, last_active) -- LEAD DOMAIN leads (id, org_id, first_name, last_name, email, phone, company, source, source_meta JSONB, score, status, owner_id, segment_tags TEXT[], is_duplicate, created_at, updated_at) lead_timeline (id, lead_id, event_type, payload JSONB, actor_id, created_at) lead_scores (id, lead_id, score_version, breakdown JSONB, scored_at) -- CONTACT / DEAL DOMAIN contacts (id, org_id, first_name, last_name, email, phone, company_id) companies (id, org_id, name, industry, size, website) deals (id, org_id, lead_id, contact_id, title, value, currency, stage, probability, expected_close, owner_id, created_at, won_at, lost_at, lost_reason) deal_products (id, deal_id, product_id, qty, unit_price, discount) -- COMMERCIAL products (id, org_id, name, sku, unit_price, currency, updated_at) quotations (id, deal_id, version, pdf_url, shared_at, viewed_at, status) invoices (id, deal_id, quotation_id, invoice_no, total, tax, status, paid_at, payment_ref) payment_links (id, invoice_id, gateway, external_id, url, status, created_at) -- CAMPAIGN / DRIP DOMAIN sequences (as above) sequence_steps (as above) sequence_enrollments (as above) message_templates (id, org_id, channel, name, body, variables TEXT[], created_at) ab_test_variants (id, step_id, variant_key, template_id, weight INT) communication_log (as above) -- INTEGRATION integration_sources (id, org_id, source_type, config JSONB, webhook_secret, active) chat_sync_log (id, source_id, lead_id, external_thread_id, direction, body, sent_at) -- REPORTING (TimescaleDB hypertables) metric_events (time TIMESTAMPTZ, org_id, metric_key, value FLOAT, dims JSONB)

// All source adapters implement this interface interface LeadSourceAdapter { verifySignature(headers: Headers, body: Buffer): boolean; normalise(rawPayload: unknown): LeadPayload; acknowledgeReceived(): HttpResponse; // must return 200 fast } // Normalised schema — every source adapter outputs this interface LeadPayload { source: 'indiaMart' | 'tradeIndia' | 'metaAds' | 'googleAds' | 'linkedIn' | 'website' | 'events' | 'outbound' | 'b2bDb'; externalId: string; // source's own lead ID firstName: string; lastName?: string; email?: string; phone?: string; company?: string; message?: string; // buyer's inquiry text sourceMeta: Record<string, unknown>; // raw source-specific fields receivedAt: Date; } // Example: IndiaMART adapter class IndiaMartAdapter implements LeadSourceAdapter { normalise(raw: IndiaMartPayload): LeadPayload { return { source: 'indiaMart', externalId: raw.UNIQUE_QUERY_ID, firstName: raw.SENDER_NAME.split(' ')[0], phone: raw.SENDER_MOBILE, email: raw.SENDER_EMAIL, company: raw.SENDER_COMPANY, message: raw.QUERY_MESSAGE, sourceMeta: raw, receivedAt: new Date(raw.QUERY_TIME) }; } }

# Core DATABASE_URL=postgres://user:pass@pg-host:5432/dotdomino REDIS_URL=redis://redis-host:6379 JWT_SECRET=...32-byte-random... JWT_REFRESH_SECRET=...32-byte-random... # Storage S3_BUCKET=dotdomino-files S3_REGION=ap-south-1 # Integrations INDIAMARTGLOBAL_KEY=... TRADEINDIA_WEBHOOK_SECRET=... META_APP_ID=... META_APP_SECRET=... GOOGLE_ADS_DEVELOPER_TOKEN=... LINKEDIN_CLIENT_ID=... # Communication WA_BSP_URL=https://api.gupshup.io/sm/api/v1 WA_BSP_KEY=... SMS_GATEWAY_URL=... SMS_GATEWAY_KEY=... RCS_API_KEY=... SENDGRID_API_KEY=... # Payments RAZORPAY_KEY_ID=... RAZORPAY_KEY_SECRET=... # Observability SENTRY_DSN=... OTEL_EXPORTER_ENDPOINT=http://otel-collector:4317