Domain model

Every domain row carries subscriptionId. Production runs one: b191a905-5d19-4fa0-941b-d8eb81c0c477. The subscriptions table itself is not managed by morpheus-data-layer, which is why no ORM model declares a foreign key to it.

Maps to a HubSpot Company, not a Contact. Keyed by sellerId, the external marketplace identifier (ATVPDKIKX0DER). Carries marketplace metrics — estimateSales, numberAsins, percentFba, growth rates — plus enrichment output (website, linkedinUrl, hubspotCompanyId) and payoutPainScore.

The single source of truth shared between campaign targets and HubSpot. Optionally linked to a Seller. Carries identity, address, lifecycle and lead status, calling context (disposition, stopCalling, nextAction), HubSpot sync fields, and supplier fields (supplierKey, supplierStatus).

A contact may have several. These carry the channel state that does not belong on the person: line type and risk level for phones, opt-out flags and send spacing for emails. This is where suppression actually lives.

Its own state machine plus a cache of business-logic answers (isAmazonSeller, meetsMonthlyThreshold, interestedInDailyPayments, stopCalling, disposition) and scheduling fields (nextEarliestAttemptAt, leaseExpiresAt).

Written by both dialer paths. Holds identifiers, status and timing, cost and latency, AI analysis (sentiment, disposition, intelligence flags, extracted business logic), actionable next steps, and HubSpot correlation. providerCallId is unique when set, which is what makes the Five9 upsert idempotent.

sms, email, call, task, meeting, note, or reminder. Unique on (subscriptionId, externalId), which is how the BigQuery engagement sync upserts HubSpot engagements idempotently.

Mirrored into HubSpot and optionally Nooks. Carries escalationStage for the Slack ladder. See Follow-up tasks and escalation.

Subscription-scoped, so the same person can be a rep in several workspaces with different CRM ids. Holds hubspotOwnerId, nooksUserId, activeListId, and hubspotCallSegmentId. isActive gates every selector.

A key/value table used for watermarks, pagination cursors, round-robin position, and kill switches. key is globally unique, not unique per subscription — which is why the round-robin key embeds the subscription id. See Runtime state in configs.

resolve_hubspot_contact_id_phone_first() tries phone, then email, then mobile phone, and reports which step matched plus whether there were multiple matches. Phone first because a dialer knows a number and may not know an email.

ensure_local_contact_row() guarantees a local row exists for a HubSpot contact id, short-circuiting through: already loaded → local lookup by HubSpot id → fetch from the CRM and upsert → repair the campaign target’s foreign keys.

Hubspot.ContactResolve widens the search to every related target_phone_numbers and target_emails row, and stamps hubspotLastSyncedAt even on a miss so the batch keeps moving through fresh candidates.

new → raw_lead → enriched → in_sequence → engaged → qualified → bdr_handoff → demo_scheduled → opportunity → customer, plus disqualified. Morpheus writes only new and enriched.

subscriber → lead → marketingqualifiedlead → salesqualifiedlead → opportunity → customer → evangelist, plus other. Morpheus only ever promotes, via a rank guard. See Outbound funnel.