baseline.prisma

// This is your Prisma schema file

generator client {
  provider      = "prisma-client-js"
  // native=local dev; linux-musl-*=Alpine Docker (Cloud Run). Alpine 3.17+ needs openssl-3.
  binaryTargets = ["native", "linux-musl-openssl-3.0.x", "linux-musl-arm64-openssl-3.0.x"]
}

datasource db {
  provider = "postgresql"
  url      = env("DATABASE_URL")
}

model Audit {
  id                 String      @id @default(uuid())
  businessName       String
  businessCity       String?
  businessUrl        String?
  businessIndustry   String?
  verticalPlaybookId String? // e.g., 'dentist', 'law-firm' — from playbook detection
  status             AuditStatus @default(QUEUED)
  modulesCompleted   String[]    @default([])
  modulesFailed      Json        @default("[]")
  overallScore       Int?
  apiCostCents       Int         @default(0)
  startedAt          DateTime    @default(now())
  completedAt        DateTime?
  createdAt          DateTime    @default(now())
  batchId            String?

  // Multi-Tenancy
  tenantId String
  tenant   Tenant @relation(fields: [tenantId], references: [id])

  findings       Finding[]
  proposals      Proposal[]
  evidence       EvidenceSnapshot[]
  FindingStatus  FindingStatus[]
  ClientMessage  ClientMessage[]
  ReviewSnapshot ReviewSnapshot[]

  @@index([status])
  @@index([createdAt])
  @@index([tenantId])
  @@index([batchId])
}

model Finding {
  id              String       @id @default(uuid())
  auditId         String
  module          String
  category        String
  type            FindingType
  title           String
  description     String?
  evidence        Json         @default("[]")
  metrics         Json         @default("{}")
  impactScore     Int
  confidenceScore Int
  effortEstimate  EffortLevel?
  recommendedFix  Json         @default("[]")
  manuallyEdited  Boolean      @default(false)
  excluded        Boolean      @default(false)
  confidenceLevel String?      // 'HIGH', 'MEDIUM', 'LOW' — set by Confidence Scorer
  createdAt       DateTime     @default(now())

  // Multi-Tenancy (Denormalized)
  tenantId String? // Optional for migration, enforce in app logic

  audit         Audit           @relation(fields: [auditId], references: [id], onDelete: Cascade)
  FindingStatus FindingStatus[]

  @@index([auditId])
  @@index([type])
  @@index([tenantId])
}

model Proposal {
  id               String         @id @default(uuid())
  auditId          String
  version          Int            @default(1)
  status           ProposalStatus @default(DRAFT)
  prospectEmail    String? // Added for follow-ups
  executiveSummary String?
  painClusters     Json           @default("[]")
  tierEssentials   Json           @default("{}")
  tierGrowth       Json           @default("{}")
  tierPremium      Json           @default("{}")
  pricing          Json           @default("{}")
  assumptions      String[]       @default([])
  disclaimers      String[]       @default([])
  nextSteps        String[]       @default([])
  comparisonReport Json? // Competitor comparison (ranking, winning/losing, quick wins)
  pdfUrl           String?
  pdfGeneratedAt   DateTime?
  webLinkToken     String         @unique @default(uuid())
  sentAt           DateTime?
  viewedAt         DateTime?
  createdAt        DateTime       @default(now())

  // Multi-Tenancy
  tenantId String?

  // Template Link
  templateId String?
  template   ProposalTemplate? @relation(fields: [templateId], references: [id])

  // QA Fields
  qaScore                Int?   @default(0)
  qaResults              Json   @default("{}")
  clientScore            Int?   @default(0)
  clientScoreResults     Json   @default("{}")
  humanCloseabilityScore Float?

  // Win/Loss Tracking (Feature #5)
  outcome         ProposalOutcome?
  closedAt        DateTime?
  dealValue       Decimal?         @db.Decimal(10, 2)
  lostReason      String?
  notes           String?
  replyReceivedAt DateTime?
  meetingBookedAt DateTime?
  tierChosen      String?

  // Viral Sharing
  shareCount Int @default(0)

  audit           Audit               @relation(fields: [auditId], references: [id], onDelete: Cascade)
  followUps       ProposalFollowUp[]
  outreach        ProposalOutreach[]
  acceptance      ProposalAcceptance? // One acceptance per proposal
  views           ProposalView[]
  contactRequests ContactRequest[]
  project         Project?

  // Sprint 9: Conversational Closing
  conversationState ConversationState?
  objectionLogs     ObjectionLog[]
  emailSequence     EmailSequence?

  @@index([auditId])
  @@index([webLinkToken])
  @@index([status])
  @@index([tenantId])
  @@index([clientScore])
  @@index([replyReceivedAt])
  @@index([meetingBookedAt])
}

model ProposalAcceptance {
  id         String @id @default(uuid())
  proposalId String @unique
  tier       String // essentials, growth, premium

  contactName  String
  contactEmail String
  contactPhone String?
  message      String?
  ipAddress    String?

  acceptedAt DateTime @default(now())

  proposal Proposal @relation(fields: [proposalId], references: [id], onDelete: Cascade)
}

model ProposalView {
  id                String   @id @default(uuid())
  proposalId        String
  sessionId         String // Random UUID per session
  viewedAt          DateTime @default(now())
  scrollDepth       Int      @default(0) // 0, 25, 50, 75, 100
  timeOnPageSeconds Int      @default(0)
  ctaClicked        Boolean  @default(false)
  expandedSections  Json     @default("[]") // Array of section IDs
  userAgent         String?  @db.Text
  referrer          String?  @db.Text
  ipHash            String? // SHA256 hash of IP for privacy

  proposal Proposal @relation(fields: [proposalId], references: [id], onDelete: Cascade)

  @@index([proposalId])
  @@index([sessionId])
}

model ContactRequest {
  id            String   @id @default(uuid())
  proposalId    String
  name          String
  email         String?
  phone         String?
  bestTime      String? // Dropdown value
  preferredTier String? // starter, growth, premium
  message       String?  @db.Text
  createdAt     DateTime @default(now())

  proposal Proposal @relation(fields: [proposalId], references: [id], onDelete: Cascade)

  @@index([proposalId])
}

model ProposalFollowUp {
  id         String @id @default(uuid())
  proposalId String
  tenantId   String

  type   String // 'email' | 'reminder'
  step   Int // 1, 2, 3
  status String // 'pending', 'sent', 'cancelled'

  emailSubject String
  emailBody    String @db.Text

  scheduledAt DateTime
  sentAt      DateTime?
  createdAt   DateTime  @default(now())
  updatedAt   DateTime  @updatedAt

  proposal Proposal @relation(fields: [proposalId], references: [id], onDelete: Cascade)

  @@index([proposalId])
  @@index([tenantId])
  @@index([status])
  @@index([scheduledAt])
}

model EvidenceSnapshot {
  id          String   @id @default(uuid())
  auditId     String
  module      String
  source      String
  rawResponse Json
  collectedAt DateTime @default(now())

  // Multi-Tenancy
  tenantId String?

  audit Audit @relation(fields: [auditId], references: [id], onDelete: Cascade)

  @@index([auditId])
  @@index([tenantId])
}

model ProposalTemplate {
  id          String  @id @default(uuid())
  name        String
  description String?
  industry    String?

  isDefault Boolean @default(false)

  // Custom Content
  headerHtml String? @db.Text
  introText  String? @db.Text
  outroText  String? @db.Text
  ctaText    String?
  ctaUrl     String?
  customCss  String? @db.Text
  footnotes  String? @db.Text

  // Toggles
  showFindings         Boolean @default(true)
  showCompetitorMatrix Boolean @default(true)
  showRoi              Boolean @default(true)

  // Standard Fields
  assumptions  String[] @default([])
  disclaimers  String[] @default([])
  nextSteps    String[] @default([])
  pricing      Json     @default("{}")
  tierSettings Json     @default("{}") // Store tier-specific customizations
  createdAt    DateTime @default(now())
  updatedAt    DateTime @updatedAt

  // Multi-Tenancy
  tenantId String? // Global templates = null, Custom = tenantId

  proposals Proposal[]

  @@index([industry])
  @@index([createdAt])
  @@index([tenantId])
}

// Feature #8: Tiered Pricing
model User {
  id            String    @id @default(uuid())
  email         String    @unique
  name          String?
  // NextAuth fields
  emailVerified DateTime?
  image         String?
  passwordHash  String?
  role          String    @default("member") // owner, admin, member, viewer

  // Legacy or Personal Subscription
  subscriptionTier SubscriptionTier @default(STARTER)
  stripeCustomerId String?          @unique
  subscriptionId   String?          @unique

  auditsThisMonth Int      @default(0)
  auditsLimit     Int      @default(10)
  tenantId        String?
  createdAt       DateTime @default(now())
  updatedAt       DateTime @updatedAt

  tenant   Tenant?   @relation(fields: [tenantId], references: [id])
  accounts Account[]
  sessions Session[]

  @@index([email])
  @@index([subscriptionTier])
  @@index([tenantId])
}

// Feature #9: Multi-Tenant
model Tenant {
  id     String  @id @default(uuid())
  name   String
  slug   String? @unique
  domain String? @unique

  // Billing
  planTier             String  @default("free") // free, starter, pro, agency
  status               String  @default("active") // active, trial, suspended
  stripeCustomerId     String?
  stripeSubscriptionId String?

  branding  Json     @default("{}")
  settings  Json     @default("{}")
  isActive  Boolean  @default(true)
  createdAt DateTime @default(now())
  updatedAt DateTime @updatedAt

  users                  User[]
  audits                 Audit[]
  brandingConfig         TenantBranding?
  apiKeys                ApiKey[]
  playbooks              Playbook[]
  auditSchedules         AuditSchedule[]
  UsageRecord            UsageRecord[]
  invitations            Invitation[]
  prospectDiscoveryJobs  ProspectDiscoveryJob[]
  prospectLeads          ProspectLead[]
  prospectEnrichmentRuns ProspectEnrichmentRun[]
  outreachSendingDomains OutreachSendingDomain[]
  outreachDomainDailyStats OutreachDomainDailyStat[]
  outreachEmails         OutreachEmail[]
  outreachEmailEvents    OutreachEmailEvent[]
  pipelineConfig         PipelineConfig?
  projects               Project[]

  @@index([domain])
  @@index([isActive])
}

model Invitation {
  id         String    @id @default(uuid())
  email      String
  role       String    @default("member")
  token      String    @unique
  tenantId   String
  invitedBy  String?
  expiresAt  DateTime
  acceptedAt DateTime?

  tenant Tenant @relation(fields: [tenantId], references: [id], onDelete: Cascade)

  @@index([tenantId])
  @@index([token])
}

model Playbook {
  id       String  @id @default(uuid())
  tenantId String? // Null = System Default
  tenant   Tenant? @relation(fields: [tenantId], references: [id], onDelete: Cascade)

  industry    String // e.g. "dental", "restaurant"
  name        String
  description String?

  // Configurations
  moduleConfig     Json @default("{}")
  pricingConfig    Json @default("{}")
  promptOverrides  Json @default("{}")
  customFindings   Json @default("[]")
  proposalLanguage Json @default("{}")

  isDefault Boolean @default(false)

  createdAt DateTime @default(now())
  updatedAt DateTime @updatedAt

  @@unique([tenantId, industry]) // One playbook per industry per tenant
  @@index([industry])
  @@index([tenantId])
}

model AuditSchedule {
  id       String @id @default(uuid())
  tenantId String
  tenant   Tenant @relation(fields: [tenantId], references: [id], onDelete: Cascade)

  businessName String
  businessCity String?
  businessUrl  String?
  industry     String?

  frequency   String // 'weekly', 'biweekly', 'monthly', 'quarterly'
  nextRunAt   DateTime
  lastRunAt   DateTime?
  lastAuditId String? // FK to last completed audit (optional relation/just string)

  isActive  Boolean @default(true)
  createdBy String? // User ID

  createdAt DateTime @default(now())
  updatedAt DateTime @updatedAt

  @@index([tenantId])
  @@index([nextRunAt])
  @@index([isActive])
}

// Target list for validation blitz / sales pipeline
model AuditTarget {
  id           String   @id @default(uuid())
  businessName String
  businessCity String?
  businessUrl  String
  placeId      String?
  phone        String?
  address      String?
  rating       Float?
  reviewCount  Int?
  category     String?
  vertical     String // e.g. dentist, law-firm, hvac
  source       String   @default("saskatoon-validation")
  createdAt    DateTime @default(now())

  @@index([placeId])
  @@index([vertical])
  @@index([source])
}

model ProspectDiscoveryJob {
  id       String @id @default(uuid())
  tenantId String
  tenant   Tenant @relation(fields: [tenantId], references: [id], onDelete: Cascade)

  city     String
  state    String?
  metro    String?
  vertical String

  targetLeads   Int  @default(200)
  painThreshold Int  @default(60)
  sourceConfig  Json @default("{\"googlePlaces\":true,\"yelp\":true,\"directories\":true}")

  status      ProspectDiscoveryJobStatus @default(QUEUED)
  runAttempts Int                        @default(0)

  discoveredCount Int @default(0)
  qualifiedCount  Int @default(0)
  enrichedCount   Int @default(0)

  lastError   String?
  nextRunAt   DateTime  @default(now())
  startedAt   DateTime?
  completedAt DateTime?
  createdAt   DateTime  @default(now())
  updatedAt   DateTime  @updatedAt

  leads ProspectLead[]

  @@index([tenantId, status, nextRunAt])
  @@index([city, vertical])
  @@index([createdAt])
}

model ProspectLead {
  id       String @id @default(uuid())
  tenantId String
  tenant   Tenant @relation(fields: [tenantId], references: [id], onDelete: Cascade)

  discoveryJobId String?
  discoveryJob   ProspectDiscoveryJob? @relation(fields: [discoveryJobId], references: [id], onDelete: SetNull)

  source           String
  sourceExternalId String
  sourceUrl        String?

  businessName String
  city         String
  state        String?
  vertical     String
  category     String?
  address      String?
  phone        String?
  website      String?
  rating       Float?
  reviewCount  Int?

  status        ProspectLeadStatus @default(DISCOVERED)
  painScore     Int?
  painThreshold Int                @default(60)
  painBreakdown Json               @default("{}")
  topFindings   Json               @default("[]")

  auditSummarySnippet   String?
  qualificationEvidence Json      @default("{}")
  qualifiedAt           DateTime?
  disqualifiedReason    String?

  decisionMakerName        String?
  decisionMakerTitle       String?
  decisionMakerLinkedin    String?
  decisionMakerEmail       String?
  decisionMakerEmailStatus String?
  enrichmentState          Json    @default("{}")
  estimatedCostCents       Int     @default(0)

  outreachStage            OutreachLeadStage @default(READY)
  outreachAttempts         Int               @default(0)
  outreachOpenCount        Int               @default(0)
  outreachClickCount       Int               @default(0)
  outreachReplyCount       Int               @default(0)
  outreachLastContactedAt  DateTime?
  outreachNextActionAt     DateTime?
  outreachDroppedAt        DateTime?
  outreachDropReason       String?
  scorecardToken           String?           @unique
  scorecardFirstViewedAt   DateTime?
  scorecardLastViewedAt    DateTime?
  scorecardTotalViewSeconds Int              @default(0)

  // Pipeline orchestrator fields
  pipelineStatus  String  @default("discovered")
  auditId         String?
  proposalId      String?
  engagementScore Int     @default(0)
  lastEngagementAt DateTime?

  createdAt DateTime @default(now())
  updatedAt DateTime @updatedAt

  enrichmentRuns       ProspectEnrichmentRun[]
  outreachEmails       OutreachEmail[]
  outreachEvents       OutreachEmailEvent[]
  stateTransitions     ProspectStateTransition[]
  deliveredLeads       PartnerDeliveredLead[]

  @@unique([tenantId, source, sourceExternalId])
  @@index([tenantId, status])
  @@index([city, vertical])
  @@index([painScore])
  @@index([discoveryJobId])
  @@index([createdAt])
  @@index([tenantId, outreachStage, outreachNextActionAt])
  @@index([pipelineStatus])
  @@index([engagementScore])
}

model ProspectEnrichmentRun {
  id       String @id @default(uuid())
  tenantId String
  tenant   Tenant @relation(fields: [tenantId], references: [id], onDelete: Cascade)

  leadId String
  lead   ProspectLead @relation(fields: [leadId], references: [id], onDelete: Cascade)

  provider ProspectEnrichmentProvider
  status   ProspectEnrichmentStatus   @default(PENDING)

  requestPayload  Json    @default("{}")
  responsePayload Json    @default("{}")
  costCents       Int     @default(0)
  errorMessage    String?

  startedAt   DateTime  @default(now())
  completedAt DateTime?
  createdAt   DateTime  @default(now())

  @@index([tenantId, provider, status])
  @@index([leadId, createdAt])
}

model OutreachSendingDomain {
  id       String @id @default(uuid())
  tenantId String
  tenant   Tenant @relation(fields: [tenantId], references: [id], onDelete: Cascade)

  domain    String
  fromEmail String
  fromName  String?
  dailyLimit Int    @default(50)
  isActive  Boolean @default(true)

  createdAt DateTime @default(now())
  updatedAt DateTime @updatedAt

  emails     OutreachEmail[]
  dailyStats OutreachDomainDailyStat[]

  @@unique([tenantId, fromEmail])
  @@index([tenantId, isActive])
}

model OutreachDomainDailyStat {
  id       String @id @default(uuid())
  tenantId String
  tenant   Tenant @relation(fields: [tenantId], references: [id], onDelete: Cascade)

  domainId String
  domain   OutreachSendingDomain @relation(fields: [domainId], references: [id], onDelete: Cascade)

  day        DateTime
  sentCount  Int @default(0)
  openCount  Int @default(0)
  clickCount Int @default(0)
  replyCount Int @default(0)

  createdAt DateTime @default(now())
  updatedAt DateTime @updatedAt

  @@unique([domainId, day])
  @@index([tenantId, day])
}

model OutreachEmail {
  id       String @id @default(uuid())
  tenantId String
  tenant   Tenant @relation(fields: [tenantId], references: [id], onDelete: Cascade)

  leadId String
  lead   ProspectLead @relation(fields: [leadId], references: [id], onDelete: Cascade)

  domainId String?
  domain   OutreachSendingDomain? @relation(fields: [domainId], references: [id], onDelete: SetNull)

  type   OutreachEmailType   @default(INITIAL)
  status OutreachEmailStatus @default(PENDING)

  subject String
  body    String @db.Text

  qualityScore     Int   @default(0)
  readabilityGrade Float @default(0)
  wordCount        Int   @default(0)
  spamRisk         Int   @default(0)
  findingsUsed     Json  @default("[]")

  scorecardUrl      String?
  proposalUrl       String?
  trackingPixelUrl  String?
  trackingClickBaseUrl String?

  providerMessageId String?
  errorMessage      String?

  sentAt    DateTime?
  openedAt  DateTime?
  clickedAt DateTime?
  repliedAt DateTime?
  scheduledAt DateTime?
  sequencePosition Int?

  createdAt DateTime @default(now())
  updatedAt DateTime @updatedAt

  events OutreachEmailEvent[]

  @@index([tenantId, status, createdAt])
  @@index([leadId, createdAt])
  @@index([domainId, createdAt])
  @@index([type, status])
  @@index([scheduledAt, status])
}

model OutreachEmailEvent {
  id       String @id @default(uuid())
  tenantId String
  tenant   Tenant @relation(fields: [tenantId], references: [id], onDelete: Cascade)

  leadId String
  lead   ProspectLead @relation(fields: [leadId], references: [id], onDelete: Cascade)

  emailId String?
  email   OutreachEmail? @relation(fields: [emailId], references: [id], onDelete: SetNull)

  type     OutreachEventType
  metadata Json      @default("{}")
  occurredAt DateTime @default(now())
  createdAt DateTime  @default(now())

  @@index([tenantId, type, occurredAt])
  @@index([leadId, occurredAt])
  @@index([emailId, occurredAt])
}

model ApiKey {
  id       String @id @default(uuid())
  tenantId String
  tenant   Tenant @relation(fields: [tenantId], references: [id], onDelete: Cascade)

  keyHash   String   @unique
  keyPrefix String
  name      String
  scopes    String[] // e.g. ["audit:create", "audit:read"]

  isActive        Boolean   @default(true)
  rateLimitPerDay Int       @default(1000)
  usageCount      Int       @default(0) // Track usage for the day
  lastResetAt     DateTime  @default(now()) // Track when usage was last reset
  lastUsedAt      DateTime?
  expiresAt       DateTime?

  createdAt DateTime @default(now())

  @@index([tenantId])
  @@index([keyHash])
}

model TenantBranding {
  id       String @id @default(uuid())
  tenantId String @unique
  tenant   Tenant @relation(fields: [tenantId], references: [id], onDelete: Cascade)

  brandName   String?
  tagline     String?
  logoUrl     String?
  logoDarkUrl String?

  primaryColor   String @default("#8B5CF6")
  secondaryColor String @default("#38BDF8")
  accentColor    String @default("#F59E0B")

  contactEmail String?
  contactPhone String?
  websiteUrl   String?

  // Custom Domain
  customDomain           String?   @unique
  customDomainVerified   Boolean   @default(false)
  customDomainVerifiedAt DateTime?

  footerText    String?
  showPoweredBy Boolean @default(true)

  createdAt DateTime @default(now())
  updatedAt DateTime @updatedAt
}

// NextAuth Models
model Account {
  id                String  @id @default(cuid())
  userId            String
  type              String
  provider          String
  providerAccountId String
  refresh_token     String? @db.Text
  access_token      String? @db.Text
  expires_at        Int?
  token_type        String?
  scope             String?
  id_token          String? @db.Text
  session_state     String?

  user User @relation(fields: [userId], references: [id], onDelete: Cascade)

  @@unique([provider, providerAccountId])
}

model Session {
  id           String   @id @default(cuid())
  sessionToken String   @unique
  userId       String
  expires      DateTime
  user         User     @relation(fields: [userId], references: [id], onDelete: Cascade)
}

model VerificationToken {
  identifier String
  token      String   @unique
  expires    DateTime

  @@unique([identifier, token])
}

// Prospect state transition history
model ProspectStateTransition {
  id         String   @id @default(uuid())
  tenantId   String
  leadId     String
  fromStatus String
  toStatus   String
  stage      String   // Pipeline stage that triggered the transition
  metadata   Json     @default("{}")
  createdAt  DateTime @default(now())

  lead ProspectLead @relation(fields: [leadId], references: [id], onDelete: Cascade)

  @@index([leadId, createdAt])
  @@index([tenantId, createdAt])
}

// Delivery tasks for fulfilled proposals
model DeliveryTask {
  id         String @id @default(uuid())
  tenantId   String
  proposalId String
  findingId  String
  agentType  String // 'speed_optimization', 'seo_fix', 'accessibility', 'security_hardening', 'content_generation'
  status     String @default("queued") // 'queued', 'in_progress', 'completed', 'verified', 'failed', 'escalated'

  estimatedCompletionDate DateTime
  completedAt             DateTime?
  verificationAuditId     String?
  beforeAfterComparison   Json?
  errorMessage            String?

  // Sprint 10: Delivery Agent fields
  artifactId      String?   // FK to GeneratedArtifact
  bundleId        String?   // FK to DeliveryBundle
  confidenceLevel String?   // 'HIGH', 'MEDIUM', 'LOW'

  createdAt DateTime @default(now())
  updatedAt DateTime @updatedAt

  @@index([tenantId, status])
  @@index([proposalId])
  @@index([estimatedCompletionDate])
}

// Pipeline stage configuration per tenant
model PipelineConfig {
  id       String @id @default(uuid())
  tenantId String @unique

  concurrencyLimit    Int     @default(10)
  batchSize           Int     @default(50)
  painScoreThreshold  Int     @default(60)
  dailyVolumeLimit    Int     @default(200)
  spendingLimitCents  Int     @default(100000) // $1000 default
  hotLeadPercentile   Int     @default(95)
  emailMinQualityScore Int    @default(90)
  maxEmailsPerDomainPerDay Int @default(50)

  // Follow-up schedule (days after initial send)
  followUpSchedule Json @default("[3, 7, 14]")

  // Stage-level pause flags
  pausedStages Json @default("[]")

  // Country/language config
  country  String @default("US")
  language String @default("en")
  currency String @default("USD")

  // Pricing multiplier
  pricingMultiplier Float @default(1.0)

  createdAt DateTime @default(now())
  updatedAt DateTime @updatedAt

  tenant Tenant @relation(fields: [tenantId], references: [id], onDelete: Cascade)

  @@index([tenantId])
}

// Pipeline error log for observability
model PipelineErrorLog {
  id         String   @id @default(uuid())
  tenantId   String
  stage      String
  prospectId String?
  errorType  String
  errorMessage String @db.Text
  stackTrace String?  @db.Text
  metadata   Json     @default("{}")
  createdAt  DateTime @default(now())

  @@index([tenantId, stage, createdAt])
  @@index([createdAt])
}

// Outreach template performance tracking
model OutreachTemplatePerformance {
  id         String @id @default(uuid())
  templateId String
  vertical   String
  city       String?

  totalSent      Int   @default(0)
  openCount      Int   @default(0)
  clickCount     Int   @default(0)
  replyCount     Int   @default(0)
  conversionCount Int  @default(0)

  openRate       Float @default(0)
  clickRate      Float @default(0)
  replyRate      Float @default(0)
  conversionRate Float @default(0)

  updatedAt DateTime @updatedAt

  @@unique([templateId, vertical, city])
  @@index([vertical])
}

// Win/loss tracking with reason codes
model WinLossRecord {
  id         String @id @default(uuid())
  tenantId   String
  proposalId String
  leadId     String
  vertical   String
  city       String?

  outcome           String  // 'won', 'lost', 'ghosted'
  tierChosen        String?
  dealValue         Decimal? @db.Decimal(10, 2)
  lostReason        String?
  objectionsRaised  Json    @default("[]")
  competitorMentioned String?

  createdAt DateTime @default(now())

  @@index([tenantId, vertical, outcome])
  @@index([createdAt])
}

// Pre-warming actions for multi-channel engagement
model PreWarmingAction {
  id       String @id @default(uuid())
  tenantId String
  leadId   String

  platform   String // 'gbp', 'facebook', 'instagram'
  actionType String // 'question', 'like', 'comment', 'follow', 'post_interaction'
  status     String @default("scheduled") // 'scheduled', 'completed', 'failed', 'skipped'

  scheduledAt DateTime
  executedAt  DateTime?
  errorMessage String?

  createdAt DateTime @default(now())

  @@index([tenantId, platform, scheduledAt])
  @@index([leadId])
}

// Detected signals for signal-based selling
model DetectedSignal {
  id       String @id @default(uuid())
  tenantId String
  leadId   String?

  signalType String // 'bad_review', 'website_change', 'competitor_upgrade', 'new_business_license', 'hiring_spike'
  priority   String @default("medium") // 'high', 'medium', 'low'
  sourceData Json   @default("{}")

  outreachTriggered Boolean @default(false)
  outreachEmailId   String?

  detectedAt DateTime @default(now())
  createdAt  DateTime @default(now())

  @@unique([tenantId, leadId, signalType, detectedAt])
  @@index([tenantId, signalType, detectedAt])
  @@index([leadId])
}

// AI Sales Chat conversations
model ChatConversation {
  id         String @id @default(uuid())
  tenantId   String
  proposalId String
  sessionId  String

  messages Json    @default("[]") // Array of ChatMessage
  outcome  String? // 'converted', 'escalated', 'abandoned'
  objections Json  @default("[]") // Array of objection strings

  startedAt   DateTime  @default(now())
  completedAt DateTime?

  @@index([tenantId, proposalId])
  @@index([sessionId])
}

// Agency partner accounts
model AgencyPartner {
  id       String @id @default(uuid())

  name     String
  contactEmail String
  contactName  String?

  verticals   Json @default("[]")   // Array of target verticals
  geographies Json @default("[]")   // Array of target geographies
  monthlyVolume Int @default(50)

  pricingModel     String  // 'per_lead', 'subscription'
  perLeadPriceCents Int?
  subscriptionPriceCents Int?

  isActive  Boolean  @default(true)
  createdAt DateTime @default(now())
  updatedAt DateTime @updatedAt

  deliveredLeads PartnerDeliveredLead[]

  @@index([isActive])
}

// Leads delivered to agency partners
model PartnerDeliveredLead {
  id        String @id @default(uuid())
  partnerId String
  leadId    String
  lead      ProspectLead @relation(fields: [leadId], references: [id], onDelete: Cascade)

  packagedData Json // Full lead package (audit, proposal, pain score, contact)
  status       String @default("delivered") // 'delivered', 'viewed', 'contacted', 'converted', 'rejected'

  deliveredAt DateTime @default(now())
  updatedAt   DateTime @updatedAt

  partner AgencyPartner @relation(fields: [partnerId], references: [id], onDelete: Cascade)

  @@index([partnerId, status])
  @@index([leadId])
}

// Cross-tenant anonymized intelligence model
model SharedIntelligenceModel {
  id      String @id @default(uuid())
  version String @unique

  patterns Json // Array of AnonymizedPattern
  metadata Json @default("{}")

  isActive  Boolean  @default(true)
  createdAt DateTime @default(now())

  @@index([version])
  @@index([isActive])
}

enum AuditStatus {
  QUEUED
  RUNNING
  COMPLETE
  PARTIAL
  FAILED
}

enum FindingType {
  PAINKILLER
  VITAMIN
  VISUAL_UX
  VISUAL_DESIGN
  VISUAL_COMPARISON
}

enum ProposalStatus {
  DRAFT
  READY
  SENT
  VIEWED
  ACCEPTED
  PAID
  REJECTED
}

enum ProposalOutcome {
  WON
  LOST
  PENDING
}

enum EffortLevel {
  LOW
  MEDIUM
  HIGH
}

enum SubscriptionTier {
  STARTER
  PROFESSIONAL
  ENTERPRISE
}

enum ProspectDiscoveryJobStatus {
  QUEUED
  RUNNING
  PARTIAL
  COMPLETE
  FAILED
}

enum ProspectLeadStatus {
  DISCOVERED
  QUALIFIED
  DISQUALIFIED
  ENRICH_PENDING
  ENRICHED
  ENRICH_FAILED
}

enum ProspectEnrichmentProvider {
  APOLLO
  HUNTER
  PROXYCURL
  CLEARBIT
}

enum ProspectEnrichmentStatus {
  PENDING
  SUCCESS
  FAILED
  SKIPPED
}

enum OutreachLeadStage {
  READY
  EMAIL_SENT
  OPENED
  CLICKED
  PROPOSAL_QUEUED
  PROPOSAL_SENT
  HOT
  REPLIED
  DROPPED
}

enum OutreachEmailType {
  INITIAL
  FOLLOWUP_COMPETITOR
  FOLLOWUP_PROPOSAL
  FOLLOWUP_GBP
  FOLLOWUP_RETRY
}

enum OutreachEmailStatus {
  PENDING
  SENT
  OPENED
  CLICKED
  REPLIED
  FAILED
  SUPPRESSED
}

enum OutreachEventType {
  EMAIL_SENT
  EMAIL_OPEN
  EMAIL_CLICK
  SCORECARD_VIEW
  SCORECARD_CLICK
  SCORECARD_DWELL_2M
  REPLY_RECEIVED
  PROPOSAL_SENT
  PROPOSAL_VIEW_2M
  LEAD_DROPPED
}

model ProposalOutreach {
  id             String   @id @default(uuid())
  proposalId     String
  recipientEmail String
  emailSubject   String
  emailBody      String   @db.Text
  sentAt         DateTime @default(now())

  // Engagement
  openedAt  DateTime?
  clickedAt DateTime?

  // Multi-Tenancy
  tenantId String?

  proposal Proposal @relation(fields: [proposalId], references: [id], onDelete: Cascade)

  @@index([proposalId])
  @@index([recipientEmail])
  @@index([tenantId])
}

// Follow-up email sequence (post-meeting: Day 0, Day 3, Day 7)
model FollowUpEmailSend {
  id             String   @id @default(uuid())
  auditId        String
  proposalId     String
  step           Int // 1, 2, or 3
  recipientEmail String
  recipientName  String?
  emailSubject   String
  emailBody      String   @db.Text
  sentAt         DateTime @default(now())
  tenantId       String?

  @@index([auditId])
  @@index([proposalId])
  @@index([recipientEmail])
  @@index([tenantId])
}

model EmailBlocklist {
  id        String   @id @default(uuid())
  email     String   @unique
  reason    String? // 'unsubscribe', 'bounce', 'complaint'
  createdAt DateTime @default(now())

  @@index([email])
}

model UsageRecord {
  id       String @id @default(uuid())
  tenantId String
  tenant   Tenant @relation(fields: [tenantId], references: [id], onDelete: Cascade)

  event   String // 'audit.created', 'batch.item'
  credits Int    @default(1)

  stripeUsageRecordId String? // ID from Stripe if reported

  timestamp DateTime @default(now())

  @@index([tenantId])
  @@index([timestamp])
}

model BenchmarkStats {
  id       String  @id @default(uuid())
  industry String
  city     String? // Optional: hierarchical benchmarks

  sampleSize Int @default(0)

  // Aggregate Metrics (JSON to be flexible)
  // { avgScore: 45, p90Score: 78, avgLoadTime: 2.3, ... }
  metrics Json @default("{}")

  lastUpdated DateTime @default(now())

  @@unique([industry, city]) // One benchmark per industry/city combo
}

model FindingEffectiveness {
  id          String @id @default(uuid())
  findingType String // e.g. "SLOW_MOBILE_LOAD"

  totalOccurrences Int @default(0)
  acceptedCount    Int @default(0) // How many times a proposal with this finding was accepted
  rejectedCount    Int @default(0)

  conversionPower Float @default(0.0) // Cached calculation: accepted / total

  updatedAt DateTime @updatedAt

  @@unique([findingType])
}

model PromptPerformance {
  id       String @id @default(uuid())
  promptId String // "intro-v1" or "intro-v2" (from A/B)

  uses           Int   @default(0)
  avgQaScore     Float @default(0) // Internal QA
  acceptanceRate Float @default(0) // External Success

  updatedAt DateTime @updatedAt

  @@unique([promptId])
}

// Client Portal Models
model FindingStatus {
  id        String @id @default(uuid())
  auditId   String
  findingId String

  status    String   @default("not_started") // not_started, in_progress, fixed, wont_fix
  notes     String?
  updatedBy String? // User ID (Operator)
  updatedAt DateTime @updatedAt

  audit   Audit   @relation(fields: [auditId], references: [id], onDelete: Cascade)
  finding Finding @relation(fields: [findingId], references: [id], onDelete: Cascade)

  @@unique([auditId, findingId])
  @@index([auditId])
}

model ClientMessage {
  id        String   @id @default(uuid())
  auditId   String
  sender    String // 'client' | 'operator'
  message   String   @db.Text
  read      Boolean  @default(false)
  createdAt DateTime @default(now())

  audit Audit @relation(fields: [auditId], references: [id], onDelete: Cascade)

  @@index([auditId])
}

model ReviewSnapshot {
  id      String   @id @default(uuid())
  auditId String
  audit   Audit    @relation(fields: [auditId], references: [id], onDelete: Cascade)
  date    DateTime @default(now())
  rating  Float
  count   Int
  source  String // 'google', 'facebook', etc.

  @@index([auditId])
}

model FeatureFlag {
  id        String   @id @default(uuid())
  key       String   @unique
  value     String
  updatedAt DateTime @updatedAt
  createdAt DateTime @default(now())
}

// --- Sprint 9: Conversational Closing ---

model ConversationState {
  id              String   @id @default(uuid())
  proposalId      String   @unique
  sessionId       String // Generic prospect session identifier
  history         Json     @default("[]") // Array of { role: 'user'|'agent', text: string, timestamp: string }
  objectionsRaised String[] @default([])
  questionsAsked  Int      @default(0)
  sentimentScore  Float    @default(0) // -1.0 to 1.0 trajectory
  engagementScore Int      @default(0)
  escalated       Boolean  @default(false)
  createdAt       DateTime @default(now())
  updatedAt       DateTime @updatedAt

  proposal        Proposal @relation(fields: [proposalId], references: [id], onDelete: Cascade)

  @@index([proposalId])
  @@index([sessionId])
}

model ObjectionLog {
  id              String   @id @default(uuid())
  proposalId      String
  category        String   // 'price', 'timing', 'trust', 'scope', 'competition'
  prospectText    String   @db.Text
  agentResponse   String   @db.Text
  escalated       Boolean  @default(false)
  createdAt       DateTime @default(now())

  proposal        Proposal @relation(fields: [proposalId], references: [id], onDelete: Cascade)

  @@index([proposalId])
  @@index([category])
}

// --- Sprint 9: Email Intelligence ---

model EmailSequence {
  id              String   @id @default(uuid())
  proposalId      String   @unique
  industry        String?
  role            String?
  sizeScope       String?
  emails          Json     @default("[]") // Array of { step: number, subject: string, body: string, status: 'draft'|'sent' }
  analytics       Json     @default("{}") // { openRates: {...}, clickRates: {...}, replyRates: {...} }
  createdAt       DateTime @default(now())
  updatedAt       DateTime @updatedAt

  proposal        Proposal @relation(fields: [proposalId], references: [id], onDelete: Cascade)

  @@index([proposalId])
}

// --- Sprint 10: Agentic Delivery + QA Hardening ---

model GeneratedArtifact {
  id           String   @id @default(uuid())
  tenantId     String
  proposalId   String
  findingId    String
  artifactType String   // 'json_ld', 'html_meta', 'speed_script', 'gbp_draft', 'content_brief', 'aria_fix', 'wp_plugin'
  content      String   @db.Text
  status       String   @default("pending") // 'pending', 'validated', 'failed_validation', 'packaged'
  validationResults Json @default("[]")     // ValidationCheckResult[]
  confidenceLevel   String? // 'HIGH', 'MEDIUM', 'LOW'
  estimatedImpact   String?
  installationInstructions String? @db.Text
  beforePreview    String? @db.Text
  afterPreview     String? @db.Text
  wordpressPlugin  String? @db.Text         // .php content if applicable
  humanReviewFlag  Boolean @default(false)
  createdAt    DateTime @default(now())
  updatedAt    DateTime @updatedAt

  @@index([tenantId, proposalId])
  @@index([findingId])
  @@index([status])
}

model DeliveryBundle {
  id           String   @id @default(uuid())
  tenantId     String
  proposalId   String   @unique
  zipUrl       String?  // GCS URL
  readmeContent String? @db.Text
  artifactCount Int     @default(0)
  status       String   @default("assembling") // 'assembling', 'ready', 'failed'
  createdAt    DateTime @default(now())
  updatedAt    DateTime @updatedAt

  @@index([tenantId])
  @@index([proposalId])
}

model AdversarialQARun {
  id           String   @id @default(uuid())
  tenantId     String
  auditId      String?
  proposalId   String?
  runType      String   // 'diagnosis', 'proposal'
  hallucinationFlags Json @default("[]")
  consistencyFlags   Json @default("[]")
  competitorFlags    Json @default("[]")
  totalClaimsChecked Int  @default(0)
  totalFlagged       Int  @default(0)
  hardenedContent    String? @db.Text
  createdAt    DateTime @default(now())

  @@index([tenantId, auditId])
  @@index([proposalId])
  @@index([createdAt])
}

model HallucinationLog {
  id           String   @id @default(uuid())
  tenantId     String
  auditId      String?
  proposalId   String?
  category     String   // 'data_fabrication', 'metric_inflation', 'false_competitor_claim', 'unsupported_recommendation'
  flaggedText  String   @db.Text
  location     String
  weekStart    DateTime // Truncated to Monday for weekly aggregation
  createdAt    DateTime @default(now())

  @@index([tenantId, weekStart])
  @@index([auditId])
  @@index([category])
}

model HumanReviewFlag {
  id           String   @id @default(uuid())
  tenantId     String
  artifactId   String
  findingId    String
  reason       String   @db.Text
  status       String   @default("pending") // 'pending', 'approved', 'rejected'
  reviewedBy   String?
  reviewedAt   DateTime?
  createdAt    DateTime @default(now())

  @@index([tenantId, status])
  @@index([artifactId])
}

enum ProjectStatus {
  KICKOFF
  IN_PROGRESS
  DELIVERED
  NEEDS_REVIEW
  COMPLETE
}

// Sprint 9: Post-Payment Auto-Onboarding
model Project {
  id             String        @id @default(uuid())
  proposalId     String       @unique
  tenantId       String
  status         ProjectStatus @default(KICKOFF)
  completedAt    DateTime?
  createdAt      DateTime      @default(now())
  updatedAt      DateTime      @updatedAt

  proposal       Proposal      @relation(fields: [proposalId], references: [id], onDelete: Cascade)
  tenant         Tenant        @relation(fields: [tenantId], references: [id], onDelete: Cascade)
  npsSurveys     NPSSurvey[]

  @@index([tenantId])
  @@index([status])
}

// Task 4: NPS Automation
model NPSSurvey {
  id           String             @id @default(uuid())
  projectId    String
  tenantId     String
  score        Int?
  feedback     String?
  surveyDay    Int                // 30 or 90
  status       NPSSurveyStatus    @default(PENDING)
  sentAt       DateTime           @default(now())
  respondedAt  DateTime?
  createdAt    DateTime           @default(now())
  updatedAt    DateTime           @updatedAt

  project      Project            @relation(fields: [projectId], references: [id], onDelete: Cascade)

  @@index([projectId])
  @@index([tenantId])
  @@index([surveyDay, status])
}

enum NPSSurveyStatus {
  PENDING
  SENT
  RESPONDED
  FLAGGED_DETRACTOR /// score <= 6 — manual outreach needed
  REFERRAL_SENT     /// score >= 9 — referral email triggered
}

// Task 3: QA Telemetry (Adversarial QA monitoring)
model QATelemetry {
  id                 String   @id @default(uuid())
  runId              String   @unique @default(uuid())
  graphName          String   // "diagnosis" | "proposal"
  inputHash          String
  qaScore            Float    // 0.0–1.0 (0 = clean, 1 = heavily flagged)
  hallucinationCount Int
  unsupportedCount   Int
  consistencyCount   Int
  hallucinations     Json     // HallucinationFlag[]
  unsupportedClaims  Json     // ConsistencyFlag[]
  retryTriggered     Boolean  @default(false)
  retryCount         Int      @default(0)
  tenantId           String?
  auditId            String?
  proposalId         String?
  createdAt          DateTime @default(now())

  @@index([graphName, createdAt])
  @@index([tenantId])
  @@index([qaScore])
}

// Task 2: Prompt auto-promotion audit trail
model PromptPromotionLog {
  id                    String   @id @default(uuid())
  promptId              String   // ExperimentName from promptAB.ts
  winnerVariantId       String   // 'control' | 'variant'
  loserVariantId        String
  winnerAvgQuality      Float
  loserAvgQuality       Float
  qualityDeltaPct       Float    // (winner - loser) / loser * 100
  winnerAvgLatencyMs    Float
  loserAvgLatencyMs     Float
  latencyIncreasePct    Float
  winnerSampleSize      Int
  loserSampleSize       Int
  promotedAt            DateTime @default(now())
  note                  String?

  @@index([promptId])
  @@index([promotedAt])
}

// Task 3: Persistent Metrics Storage (Pipeline 17)
model Metric {
  id        String   @id @default(uuid())
  name      String   // e.g. "llm_calls_total", "llm_cost_total"
  value     Float
  labels    Json     @default("{}")  // { model, node, tenantId, ... }
  timestamp DateTime @default(now())

  @@index([name, timestamp])
  @@index([name])
}