Grow With AI Economics

import { createClient } from '@supabase/supabase-js';

// 1. Initialize deterministic connection to persistence layer
const supabaseUrl = process.env.NEXT_PUBLIC_SUPABASE_URL!;
const supabaseAnonKey = process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY!;

export const auditDb = createClient(supabaseUrl, supabaseAnonKey, {
  auth: {
    persistSession: true,
    autoRefreshToken: true,
  },
  db: {
    schema: 'public',
  },
});

// 2. Telemetry Ingestion Contract
export interface AuditTelemetryPayload {
  tenantId: string;
  repositoryId: string;
  commitHash: string;
  productDebtIndex: number;
  revenuePerEngineer: number;
  vectorEmbeddings?: number[];
  timestamp: string;
}

// 3. Dispatch R&D Capital Audit event to sovereign ledger
export async function recordAuditTelemetry(payload: AuditTelemetryPayload) {
  const { data, error } = await auditDb
    .from('rd_audit_events')
    .insert([
      {
        tenant_id: payload.tenantId,
        repo_id: payload.repositoryId,
        commit_sha: payload.commitHash,
        pdi_score: payload.productDebtIndex,
        aper_value: payload.revenuePerEngineer,
        metadata: {
          runtime: 'edge-runtime-v3',
          governance_tier: 'enterprise-sovereign',
        },
        recorded_at: payload.timestamp || new Date().toISOString(),
      },
    ])
    .select();

  if (error) {
    throw new Error(`Telemetry ingestion failed: ${error.message}`);
  }

  return data;
}

Mechanism: Connects directly to the PostgreSQL database layer (e.g. Supabase) with authenticated client credentials, enforcing typed telemetry ingestion into the sovereign audit ledger.