• "Cigna

CREATE TABLE marketplace_clusters (
  id UUID PRIMARY KEY,
  
  -- Cluster Identity (deterministic grouping)
  cluster_id TEXT NOT NULL UNIQUE,  -- "Payer 

contribution_scores

CREATE TABLE contribution_scores (
  id UUID PRIMARY KEY,
  
  -- Who & Where
  tenant_id UUID NOT NULL REFERENCES tenants(id),
  cluster_id TEXT NOT NULL REFERENCES marketplace_clusters(cluster_id),
  
  -- Contribution Metrics
  ipo_count INTEGER DEFAULT 0,           -- How many precedents this tenant added
  gap_score DECIMAL(8, 2) DEFAULT 0,     -- Gap coverage in cluster (0–100)
  outcome_bonus DECIMAL(8, 2) DEFAULT 0, -- +X for high-quality outcomes
  
  -- Total Score (for ranking contributors)
  total_score DECIMAL(10, 2) GENERATED ALWAYS AS (ipo_count  10 + gap_score + outcome_bonus) STORED,
  
  -- Metadata
  updated_at TIMESTAMPTZ DEFAULT NOW(),
  
  UNIQUE(tenant_id, cluster_id),
  INDEX idx_contribution_tenant (tenant_id, total_score DESC),
  INDEX idx_contribution_cluster (cluster_id, total_score DESC)
);

marketplace_queries

CREATE TABLE marketplace_queries (
  id UUID PRIMARY KEY,
  
  -- Access Log
  tenant_id UUID NOT NULL REFERENCES tenants(id),
  cluster_id TEXT NOT NULL,              -- cluster_id queried
  query_type TEXT,                       -- "view_cluster", "export", "search"
  
  -- Credit Ledger Integration
  credits_spent DECIMAL(10, 2),
  receipt_hash TEXT,                     -- Hash of credit_ledger entry
  
  -- Metadata
  queried_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
  
  INDEX idx_query_tenant_cluster (tenant_id, cluster_id, queried_at DESC),
  INDEX idx_query_cluster (cluster_id, queried_at DESC)
);

Cluster Lifecycle

1. Initial Contribution (Embryonic)

INSERT INTO marketplace_clusters (cluster_id, payer, denial_type, loc, contributor_count, ipo_count)
VALUES ('Cigna 

UPDATE marketplace_clusters
SET contributor_count = 2, maturity_tier = 'Emerging'
WHERE cluster_id = 'Cigna 

outcome_bonus

total_score

total_score = (ipo_count  10) + gap_score + outcome_bonus

SELECT cluster_id, payer, denial_type, loc, maturity_tier, ipo_count, win_rate
FROM marketplace_clusters
WHERE tenant_id = $1 AND maturity_tier IN ('Emerging', 'Mature', 'Canonical')
ORDER BY ipo_count DESC
LIMIT 50;

SELECT 
  c.cluster_id, c.payer, c.denial_type, c.loc,
  c.maturity_tier, c.ipo_count, c.win_rate, c.avg_resolution_days,
  c.top_evidence_types, c.narrative_patterns,
  COUNT(DISTINCT s.tenant_id) AS contributor_count
FROM marketplace_clusters c
LEFT JOIN contribution_scores s ON s.cluster_id = c.cluster_id
WHERE c.cluster_id = $1
GROUP BY c.id;

SELECT tenant_id, ipo_count, gap_score, total_score
FROM contribution_scores
WHERE cluster_id = $1
ORDER BY total_score DESC
LIMIT 10;

-- Step 1: Get tenant's credit balance
SELECT SUM(amount) AS balance
FROM credit_ledger
WHERE tenant_id = $1
GROUP BY tenant_id;

-- Step 2: Get queryable clusters (2+ contributors)
SELECT c.cluster_id, c.ipo_count, c.maturity_tier
FROM marketplace_clusters c
WHERE c.contributor_count >= 2
ORDER BY c.ipo_count DESC
LIMIT 25;

UPDATE marketplace_clusters
SET maturity_tier = CASE
  WHEN contributor_count = 1 THEN 'Embryonic'
  WHEN contributor_count <= 3 AND ipo_count < 10 THEN 'Emerging'
  WHEN contributor_count >= 4 AND ipo_count >= 10 AND win_rate > 50 THEN 'Mature'
  WHEN ipo_count >= 20 AND win_rate > 70 AND avg_resolution_days < 7 THEN 'Canonical'
  ELSE 'Emerging'
END
WHERE last_refreshed < NOW() - INTERVAL '1 day';

SELECT SUM(amount) FROM credit_ledger WHERE tenant_id = $1;

Drift Detection

{
  "outcome_trending_down": false,     // Win rate decreasing month-over-month
  "resolution_time_increasing": false, // Avg resolution time > 2x baseline
  "contributor_churn": false,         // Contributors leaving (contributor_count decreasing)
  "evidence_effectiveness_declining": false  // New precedents have lower win rate
}

-- Example: Check if win rate is declining
SELECT 
  AVG(CASE WHEN outcome='Won' THEN 1 ELSE 0 END) AS current_win_rate,
  LAG(AVG(CASE WHEN outcome='Won' THEN 1 ELSE 0 END)) 
    OVER (ORDER BY DATE(created_at)) AS prior_month_rate
FROM precedent_objects
WHERE cluster_id = $1
  AND created_at > NOW() - INTERVAL '60 days'
GROUP BY DATE(created_at);

Compliance Notes

See also

Code reference