Reverse Etl Sync Manager

Installation

Variants

Props

Schema

Type aliases exported from this item's source. Use these to shape the data you pass in.

interface FieldMapping {
  id: string
  sourceColumn: string
  sourceType: string
  sourceTable?: string
  destinationField: string
  destinationObject: string
  destinationType: string
  isMatchKey?: boolean
  syncMode: SyncMode
  transform: string
  sampleValue: string
  active: boolean
}

interface SyncRunRecord {
  id: string
  runNumber: string
  startedAt: string
  duration: string
  durationSec: number
  status: 'succeeded' | 'running' | 'failed' | 'warning'
  statusLabel: string
  totalRecords: number
  insertedRecords: number
  updatedRecords: number
  deletedRecords: number
  failedRecords: number
  warehouse: string
  queryId: string
  batchId: string
  syncTrigger: 'Scheduled Cron' | 'Manual Trigger' | 'dbt Cloud Webhook' | 'API Dispatch'
  errorSummary?: string
}

interface ReverseEtlMetrics {
  recordsSynced: number
  successRate: number
  duration: string
  warehouseName: string
  insertions: number
  updates: number
  deletions: number
  scheduleInterval: string
  nextRunIn: string
}

Files installed (1)

• app/components/blocks/ReverseEtlSyncManager.vue39.9 kB

  Copy

  <script setup lang="ts">
  import { computed, ref } from 'vue'
  import type { HTMLAttributes } from 'vue'
  import {
    Activity,
    ArrowRight,
    ArrowRightLeft,
    CalendarClock,
    Check,
    CheckCircle2,
    ChevronRight,
    Clock,
    Copy,
    Database,
    Download,
    Filter,
    Key,
    Layers,
    Pencil,
    RefreshCw,
    Search,
    Server,
    ShieldCheck,
    Timer,
  } from 'lucide-vue-next'
  import { cn } from '@/lib/utils'
  import { Badge } from '@/components/ui/badge'
  import { Button } from '@/components/ui/button'
  import { Card, CardContent, CardDescription, CardHeader, CardTitle } from '@/components/ui/card'
  import { Input } from '@/components/ui/input'
  import { Separator } from '@/components/ui/separator'
  import { Table, TableBody, TableCell, TableHead, TableHeader, TableRow } from '@/components/ui/table'
  
  export type SyncMode =
    'Upsert on Match Key' | 'Update if Newer' | 'Update only (Null overwrite off)' | 'Always Overwrite'
  
  export interface FieldMapping {
    id: string
    sourceColumn: string
    sourceType: string
    sourceTable?: string
    destinationField: string
    destinationObject: string
    destinationType: string
    isMatchKey?: boolean
    syncMode: SyncMode
    transform: string
    sampleValue: string
    active: boolean
  }
  
  export interface SyncRunRecord {
    id: string
    runNumber: string
    startedAt: string
    duration: string
    durationSec: number
    status: 'succeeded' | 'running' | 'failed' | 'warning'
    statusLabel: string
    totalRecords: number
    insertedRecords: number
    updatedRecords: number
    deletedRecords: number
    failedRecords: number
    warehouse: string
    queryId: string
    batchId: string
    syncTrigger: 'Scheduled Cron' | 'Manual Trigger' | 'dbt Cloud Webhook' | 'API Dispatch'
    errorSummary?: string
  }
  
  export interface ReverseEtlMetrics {
    recordsSynced: number
    successRate: number
    duration: string
    warehouseName: string
    insertions: number
    updates: number
    deletions: number
    scheduleInterval: string
    nextRunIn: string
  }
  
  interface Props {
    initialMappings?: FieldMapping[]
    initialRuns?: SyncRunRecord[]
    initialMetrics?: ReverseEtlMetrics
    class?: HTMLAttributes['class']
  }
  
  const defaultMappings: FieldMapping[] = [
    {
      id: 'map-1',
      sourceColumn: 'customer_id',
      sourceType: 'VARCHAR(64) [PK]',
      sourceTable: 'analytics.dim_high_value_customers',
      destinationField: 'External_ID__c',
      destinationObject: 'Account',
      destinationType: 'Text(64) [Unique Match Key]',
      isMatchKey: true,
      syncMode: 'Upsert on Match Key',
      transform: 'Direct Map (Primary Key)',
      sampleValue: 'CUST_9918203',
      active: true,
    },
    {
      id: 'map-2',
      sourceColumn: 'calculated_arr',
      sourceType: 'NUMBER(14,2)',
      sourceTable: 'analytics.dim_high_value_customers',
      destinationField: 'AnnualRevenue',
      destinationObject: 'Account',
      destinationType: 'Currency(16,2)',
      isMatchKey: false,
      syncMode: 'Update if Newer',
      transform: 'Currency Cast (USD)',
      sampleValue: '$14,250.00',
      active: true,
    },
    {
      id: 'map-3',
      sourceColumn: 'last_login_at',
      sourceType: 'TIMESTAMP_TZ',
      sourceTable: 'analytics.dim_high_value_customers',
      destinationField: 'Last_Active_Date__c',
      destinationObject: 'Contact',
      destinationType: 'DateTime',
      isMatchKey: false,
      syncMode: 'Update only (Null overwrite off)',
      transform: 'ISO8601 Date Parse',
      sampleValue: '2026-08-21 14:30:00',
      active: true,
    },
    {
      id: 'map-4',
      sourceColumn: 'health_score',
      sourceType: 'INTEGER',
      sourceTable: 'analytics.dim_high_value_customers',
      destinationField: 'Health_Score__c',
      destinationObject: 'Account',
      destinationType: 'Number(3,0)',
      isMatchKey: false,
      syncMode: 'Update if Newer',
      transform: 'Score Normalizer (0-100)',
      sampleValue: '94.8 / 100',
      active: true,
    },
    {
      id: 'map-5',
      sourceColumn: 'plan_tier',
      sourceType: 'VARCHAR(50)',
      sourceTable: 'analytics.dim_high_value_customers',
      destinationField: 'Plan_Tier__c',
      destinationObject: 'Account',
      destinationType: 'Picklist',
      isMatchKey: false,
      syncMode: 'Upsert on Match Key',
      transform: 'Enum Mapping (3 Tiers)',
      sampleValue: 'Tier 1 Enterprise',
      active: true,
    },
  ]
  
  const defaultRuns: SyncRunRecord[] = [
    {
      id: 'run-8821',
      runNumber: '#SYNC-8821',
      startedAt: '2026-08-21T14:00:00Z',
      duration: '01m:12s',
      durationSec: 72,
      status: 'succeeded',
      statusLabel: 'Succeeded',
      totalRecords: 14290,
      insertedRecords: 428,
      updatedRecords: 13862,
      deletedRecords: 0,
      failedRecords: 0,
      warehouse: 'SNOWFLAKE_WH_XS',
      queryId: '01b64e9a-0001-2a81-0000-00049281a8b1',
      batchId: 'sf-bulk-batch-7718902',
      syncTrigger: 'Scheduled Cron',
    },
    {
      id: 'run-8820',
      runNumber: '#SYNC-8820',
      startedAt: '2026-08-21T13:00:00Z',
      duration: '00m:58s',
      durationSec: 58,
      status: 'succeeded',
      statusLabel: 'Succeeded',
      totalRecords: 3410,
      insertedRecords: 85,
      updatedRecords: 3325,
      deletedRecords: 0,
      failedRecords: 0,
      warehouse: 'SNOWFLAKE_WH_XS',
      queryId: '01b64e9a-0001-2a80-0000-00049279b904',
      batchId: 'sf-bulk-batch-7718819',
      syncTrigger: 'Scheduled Cron',
    },
    {
      id: 'run-8819',
      runNumber: '#SYNC-8819',
      startedAt: '2026-08-21T12:00:00Z',
      duration: '01m:45s',
      durationSec: 105,
      status: 'succeeded',
      statusLabel: 'Succeeded',
      totalRecords: 12850,
      insertedRecords: 310,
      updatedRecords: 12540,
      deletedRecords: 0,
      failedRecords: 0,
      warehouse: 'SNOWFLAKE_WH_XS',
      queryId: '01b64e9a-0001-2a7f-0000-00049265f128',
      batchId: 'sf-bulk-batch-7718744',
      syncTrigger: 'dbt Cloud Webhook',
    },
    {
      id: 'run-8818',
      runNumber: '#SYNC-8818',
      startedAt: '2026-08-21T11:00:00Z',
      duration: '00m:42s',
      durationSec: 42,
      status: 'succeeded',
      statusLabel: 'Succeeded',
      totalRecords: 980,
      insertedRecords: 12,
      updatedRecords: 968,
      deletedRecords: 0,
      failedRecords: 0,
      warehouse: 'SNOWFLAKE_WH_XS',
      queryId: '01b64e9a-0001-2a7e-0000-00049251cc90',
      batchId: 'sf-bulk-batch-7718690',
      syncTrigger: 'Scheduled Cron',
    },
  ]
  
  const defaultMetrics: ReverseEtlMetrics = {
    recordsSynced: 14290,
    successRate: 100,
    duration: '01m:12s',
    warehouseName: 'Snowflake SQL Warehouse',
    insertions: 428,
    updates: 13862,
    deletions: 0,
    scheduleInterval: 'Every 1 hour',
    nextRunIn: '48m',
  }
  
  const props = defineProps<Props>()
  
  const mappings = ref<FieldMapping[]>(props.initialMappings ? [...props.initialMappings] : [...defaultMappings])
  const runs = ref<SyncRunRecord[]>(props.initialRuns ? [...props.initialRuns] : [...defaultRuns])
  const metrics = ref<ReverseEtlMetrics>(props.initialMetrics ? { ...props.initialMetrics } : { ...defaultMetrics })
  
  const isSyncing = ref(false)
  const syncNotice = ref(false)
  const isEditingMappings = ref(false)
  const mappingSearch = ref('')
  const selectedModeFilter = ref<string>('all')
  const expandedRunIds = ref<Record<string, boolean>>({ 'run-8821': true })
  const copiedQueryId = ref<string | null>(null)
  const copiedManifest = ref(false)
  
  const filteredMappings = computed(() => {
    return mappings.value.filter((m) => {
      const matchesSearch =
        mappingSearch.value.trim() === '' ||
        m.sourceColumn.toLowerCase().includes(mappingSearch.value.toLowerCase()) ||
        m.destinationField.toLowerCase().includes(mappingSearch.value.toLowerCase()) ||
        m.destinationObject.toLowerCase().includes(mappingSearch.value.toLowerCase()) ||
        m.syncMode.toLowerCase().includes(mappingSearch.value.toLowerCase()) ||
        m.sampleValue.toLowerCase().includes(mappingSearch.value.toLowerCase())
  
      const matchesMode =
        selectedModeFilter.value === 'all' ||
        (selectedModeFilter.value === 'upsert' && m.syncMode.includes('Upsert')) ||
        (selectedModeFilter.value === 'update_if_newer' && m.syncMode === 'Update if Newer') ||
        (selectedModeFilter.value === 'update_only' && m.syncMode.includes('Update only'))
  
      return matchesSearch && matchesMode
    })
  })
  
  function triggerManualSync() {
    if (isSyncing.value) return
    isSyncing.value = true
    syncNotice.value = true
  
    setTimeout(() => {
      isSyncing.value = false
      const newRunId = `run-${Date.now()}`
      runs.value.unshift({
        id: newRunId,
        runNumber: `#SYNC-${8822 + (runs.value.length - 4)}`,
        startedAt: new Date().toISOString(),
        duration: '01m:08s',
        durationSec: 68,
        status: 'succeeded',
        statusLabel: 'Succeeded',
        totalRecords: 14290,
        insertedRecords: 428,
        updatedRecords: 13862,
        deletedRecords: 0,
        failedRecords: 0,
        warehouse: 'SNOWFLAKE_WH_XS',
        queryId: `01b64e9a-0001-${Math.floor(1000 + Math.random() * 9000)}-0000-${Math.floor(100000000000 + Math.random() * 900000000000).toString(16)}`,
        batchId: `sf-bulk-batch-${Math.floor(7718900 + Math.random() * 1000)}`,
        syncTrigger: 'Manual Trigger',
      })
      expandedRunIds.value[newRunId] = true
    }, 2200)
  
    setTimeout(() => {
      syncNotice.value = false
    }, 6500)
  }
  
  function toggleEditMappings() {
    isEditingMappings.value = !isEditingMappings.value
  }
  
  function toggleRunExpand(id: string) {
    expandedRunIds.value[id] = !expandedRunIds.value[id]
  }
  
  function copyQueryId(id: string, text: string) {
    if (typeof navigator !== 'undefined' && navigator.clipboard) {
      navigator.clipboard.writeText(text)
      copiedQueryId.value = id
      setTimeout(() => {
        if (copiedQueryId.value === id) {
          copiedQueryId.value = null
        }
      }, 2000)
    }
  }
  
  function exportSyncManifest() {
    const manifestData = {
      syncName: 'Snowflake Gold Marts → Salesforce Accounts & Hubspot',
      source: 'Snowflake: analytics.dim_high_value_customers',
      destination: 'Salesforce CRM & HubSpot Marketing',
      exportTimestamp: new Date().toISOString(),
      metrics: metrics.value,
      fieldMappings: mappings.value,
      recentRuns: runs.value,
    }
  
    if (typeof document !== 'undefined') {
      const dataStr = 'data:text/json;charset=utf-8,' + encodeURIComponent(JSON.stringify(manifestData, null, 2))
      const downloadAnchor = document.createElement('a')
      downloadAnchor.setAttribute('href', dataStr)
      downloadAnchor.setAttribute(
        'download',
        `reverse-etl-sync-manifest-${new Date().toISOString().slice(0, 19).replace(/:/g, '-')}.json`,
      )
      document.body.appendChild(downloadAnchor)
      downloadAnchor.click()
      downloadAnchor.remove()
      copiedManifest.value = true
      setTimeout(() => {
        copiedManifest.value = false
      }, 2000)
    }
  }
  
  function formatNumber(num: number): string {
    return new Intl.NumberFormat('en-US').format(num)
  }
  
  function formatTimestamp(iso: string): string {
    try {
      const d = new Date(iso)
      return d.toISOString().replace('T', ' ').replace('.000Z', ' UTC').replace('Z', ' UTC')
    } catch {
      return iso
    }
  }
  </script>
  
  <template>
    <div data-slot="reverse-etl-sync-manager" :class="cn('w-full space-y-4', props.class)">
      <!-- Top Header: Sync Pipeline Name, Source, Destination & Global Triggers -->
      <div class="flex flex-col gap-4 lg:flex-row lg:items-center lg:justify-between">
        <div class="flex items-start gap-3 sm:items-center">
          <div class="bg-card flex size-10 shrink-0 items-center justify-center rounded-lg border shadow-xs">
            <ArrowRightLeft class="text-primary size-5" aria-hidden="true" />
          </div>
          <div class="space-y-1">
            <div class="flex flex-wrap items-center gap-2">
              <h2 class="text-foreground text-xl font-bold tracking-tight sm:text-2xl">
                Snowflake Gold Marts → Salesforce Accounts & Hubspot
              </h2>
  
              <!-- Real-Time Sync Status Badge -->
              <div
                v-if="isSyncing"
                class="border-info/30 bg-info/10 text-info inline-flex items-center gap-1.5 rounded-full border px-2.5 py-0.5 text-xs font-medium"
              >
                <RefreshCw class="size-3 animate-spin" aria-hidden="true" />
                <span>Syncing Warehouse Deltas...</span>
              </div>
              <div
                v-else
                class="border-success/30 bg-success/10 text-success inline-flex items-center gap-1.5 rounded-full border px-2.5 py-0.5 text-xs font-medium"
              >
                <span class="relative flex size-2 shrink-0">
                  <span class="bg-success absolute inline-flex h-full w-full rounded-full opacity-75" />
                  <span class="bg-success relative inline-flex size-2 rounded-full" />
                </span>
                <span>Sync Succeeded · {{ formatNumber(metrics.recordsSynced) }} Records Updated</span>
              </div>
            </div>
  
            <!-- Source to Destination Breadcrumb -->
            <div class="flex flex-wrap items-center gap-1.5 text-xs">
              <span class="text-foreground inline-flex items-center gap-1 font-semibold">
                <Database class="text-info size-3.5" aria-hidden="true" />
                Snowflake:
                <code class="text-foreground/90 font-mono font-medium">analytics.dim_high_value_customers</code>
              </span>
              <ArrowRight class="text-muted-foreground size-3.5" aria-hidden="true" />
              <span class="text-primary inline-flex items-center gap-1 font-semibold">
                <Layers class="text-primary size-3.5" aria-hidden="true" />
                Salesforce CRM & HubSpot Marketing
              </span>
              <span class="text-muted-foreground hidden font-mono sm:inline">Reverse ETL · Hightouch/Census Model</span>
            </div>
          </div>
        </div>
  
        <!-- Header Action Controls -->
        <div class="flex flex-wrap items-center gap-2">
          <Button
            variant="outline"
            size="sm"
            :class="isEditingMappings ? 'border-primary bg-primary/10 text-primary' : ''"
            class="gap-1.5"
            @click="toggleEditMappings"
          >
            <Pencil class="size-3.5" aria-hidden="true" />
            <span>{{ isEditingMappings ? 'Exit Mapping Mode' : 'Edit Field Mappings' }}</span>
          </Button>
  
          <Button
            aria-label="Download attachment"
            variant="outline"
            size="sm"
            class="gap-1.5"
            @click="exportSyncManifest"
          >
            <Check v-if="copiedManifest" class="text-success size-3.5" aria-hidden="true" />
            <Download v-else class="size-3.5" aria-hidden="true" />
            <span>{{ copiedManifest ? 'Exported' : 'Export Audit JSON' }}</span>
          </Button>
  
          <Button variant="default" size="sm" :disabled="isSyncing" class="gap-1.5 shadow-xs" @click="triggerManualSync">
            <RefreshCw :class="cn('size-3.5', isSyncing && 'animate-spin')" aria-hidden="true" />
            <span>{{ isSyncing ? 'Dispatching Batch...' : 'Trigger Sync Now' }}</span>
          </Button>
        </div>
      </div>
  
      <!-- Active Sync Notification Alert Banner -->
      <div
        v-if="syncNotice"
        class="text-foreground border-info/30 bg-info/10 flex items-center justify-between rounded-lg border p-3 text-xs shadow-xs"
      >
        <div class="flex items-center gap-2.5">
          <RefreshCw class="text-info size-4 shrink-0" aria-hidden="true" />
          <div>
            <span class="text-info font-semibold">Manual Reverse ETL Sync Triggered:</span>
            <span>
              Executing incremental delta reconciliation on
              <code class="font-mono font-medium">analytics.dim_high_value_customers</code>
              via Snowflake Warehouse
              <code class="font-mono font-medium">SNOWFLAKE_WH_XS</code>.
            </span>
          </div>
        </div>
        <Badge variant="outline" class="font-mono text-xs"> Salesforce Bulk API 2.0 </Badge>
      </div>
  
      <!-- 4 Reverse ETL KPI Cards -->
      <div class="grid grid-cols-1 gap-4 sm:grid-cols-2 lg:grid-cols-4">
        <!-- 1. Records Synced -->
        <Card class="border-border shadow-xs">
          <CardContent class="p-4">
            <div class="flex items-center justify-between">
              <span class="text-muted-foreground text-xs font-medium">Records Synced</span>
              <div
                class="border-success/20 bg-success/10 text-success flex size-8 items-center justify-center rounded-md border"
              >
                <CheckCircle2 class="size-4" aria-hidden="true" />
              </div>
            </div>
            <div class="mt-3 space-y-1.5">
              <div class="flex items-baseline gap-1.5">
                <span class="text-foreground font-mono text-2xl font-bold tracking-tight tabular-nums">
                  {{ formatNumber(metrics.recordsSynced) }}
                </span>
                <span class="text-muted-foreground text-xs">Records</span>
              </div>
              <div class="flex items-center gap-2">
                <Badge variant="success" class="font-mono text-xs"> {{ metrics.successRate }}% Success </Badge>
              </div>
              <div class="text-muted-foreground flex items-center justify-between pt-1 text-xs">
                <span>Failed Records</span>
                <span class="text-success font-mono font-medium">0 Errors</span>
              </div>
            </div>
          </CardContent>
        </Card>
  
        <!-- 2. Sync Duration -->
        <Card class="border-border shadow-xs">
          <CardContent class="p-4">
            <div class="flex items-center justify-between">
              <span class="text-muted-foreground text-xs font-medium">Sync Duration</span>
              <div class="border-info/20 bg-info/10 text-info flex size-8 items-center justify-center rounded-md border">
                <Timer class="size-4" aria-hidden="true" />
              </div>
            </div>
            <div class="mt-3 space-y-1.5">
              <div class="flex items-baseline gap-1.5">
                <span class="text-foreground font-mono text-2xl font-bold tracking-tight tabular-nums">
                  {{ metrics.duration }}
                </span>
                <span class="text-muted-foreground text-xs">runtime</span>
              </div>
              <div class="flex items-center gap-2">
                <Badge variant="info" class="font-mono text-xs">
                  {{ metrics.warehouseName }}
                </Badge>
              </div>
              <div class="text-muted-foreground flex items-center justify-between pt-1 text-xs">
                <span>Throughput</span>
                <span class="text-foreground font-mono font-medium">198 rows/sec</span>
              </div>
            </div>
          </CardContent>
        </Card>
  
        <!-- 3. Changes Detected -->
        <Card class="border-border shadow-xs">
          <CardContent class="p-4">
            <div class="flex items-center justify-between">
              <span class="text-muted-foreground text-xs font-medium">Changes Detected</span>
              <div
                class="border-primary/20 bg-primary/10 text-primary flex size-8 items-center justify-center rounded-md border"
              >
                <Activity class="size-4" aria-hidden="true" />
              </div>
            </div>
            <div class="mt-3 space-y-1.5">
              <div class="flex items-baseline gap-1.5">
                <span class="text-foreground font-mono text-2xl font-bold tracking-tight tabular-nums">
                  {{ formatNumber(metrics.recordsSynced) }}
                </span>
                <span class="text-muted-foreground text-xs">Total Deltas</span>
              </div>
              <div class="flex flex-wrap items-center gap-1.5 font-mono text-xs">
                <span class="bg-success/10 text-success rounded px-1.5 py-0.5 font-medium">
                  {{ metrics.insertions }} Insertions
                </span>
                <span class="bg-info/10 text-info rounded px-1.5 py-0.5 font-medium">
                  {{ formatNumber(metrics.updates) }} Updates
                </span>
                <span class="bg-muted text-muted-foreground rounded px-1.5 py-0.5 font-medium">
                  {{ metrics.deletions }} Deletions
                </span>
              </div>
              <!-- Segmented distribution progress bar -->
              <div class="bg-muted flex h-1.5 w-full overflow-hidden rounded-full border pt-0">
                <div
                  class="bg-success transition-colors duration-300"
                  :style="{ width: `${(metrics.insertions / metrics.recordsSynced) * 100}%` }"
                />
                <div
                  class="bg-info transition-colors duration-300"
                  :style="{ width: `${(metrics.updates / metrics.recordsSynced) * 100}%` }"
                />
              </div>
            </div>
          </CardContent>
        </Card>
  
        <!-- 4. Next Scheduled Run -->
        <Card class="border-border shadow-xs">
          <CardContent class="p-4">
            <div class="flex items-center justify-between">
              <span class="text-muted-foreground text-xs font-medium">Next Scheduled Run</span>
              <div
                class="border-warning/20 bg-warning/10 text-warning flex size-8 items-center justify-center rounded-md border"
              >
                <CalendarClock class="size-4" aria-hidden="true" />
              </div>
            </div>
            <div class="mt-3 space-y-1.5">
              <div class="flex items-baseline gap-1.5">
                <span class="text-foreground font-mono text-2xl font-bold tracking-tight tabular-nums">
                  in {{ metrics.nextRunIn }}
                </span>
                <span class="text-muted-foreground text-xs">remaining</span>
              </div>
              <div class="flex items-center gap-2">
                <Badge variant="outline" class="border-warning/30 text-warning font-mono text-xs">
                  {{ metrics.scheduleInterval }}
                </Badge>
              </div>
              <div class="text-muted-foreground flex items-center justify-between pt-1 text-xs">
                <span>Cron Expression</span>
                <span class="text-foreground font-mono font-medium">0 * * * *</span>
              </div>
            </div>
          </CardContent>
        </Card>
      </div>
  
      <!-- Field Mapping Configuration Table Card -->
      <Card class="border-border shadow-xs">
        <CardHeader class="pb-3">
          <div class="flex flex-col gap-2 sm:flex-row sm:items-center sm:justify-between">
            <div>
              <div class="flex items-center gap-2">
                <CardTitle class="text-base font-semibold">
                  Field Mapping Configuration ({{ mappings.length }} Mappings Active)
                </CardTitle>
                <Badge v-if="isEditingMappings" variant="default" class="text-xs"> Editing Mode Active </Badge>
              </div>
              <CardDescription class="text-xs">
                Schema transformation matrix mapping Snowflake warehouse marts to Salesforce CRM object attributes and
                match keys
              </CardDescription>
            </div>
  
            <div class="flex items-center gap-2">
              <Badge variant="outline" class="font-mono text-xs"> Primary Match: Account: External_ID__c </Badge>
            </div>
          </div>
        </CardHeader>
  
        <!-- Filter / Search Toolbar for Mappings -->
        <div class="border-b px-4 py-3">
          <div class="flex flex-col flex-wrap gap-3 sm:flex-row sm:items-center sm:justify-between">
            <div class="relative w-full sm:min-w-[12rem] sm:flex-1">
              <Search
                class="text-muted-foreground pointer-events-none absolute top-1/2 left-3 size-4 -translate-y-1/2"
                aria-hidden="true"
              />
              <Input v-model="mappingSearch" placeholder="Search mappings..." class="pl-9 text-xs" />
            </div>
  
            <div class="flex flex-wrap items-center gap-1.5">
              <span class="text-muted-foreground mr-1 flex items-center gap-1 text-xs font-medium">
                <Filter class="size-3" aria-hidden="true" />
                Mode:
              </span>
  
              <button
                type="button"
                :class="
                  cn(
                    'focus-visible:ring-ring inline-flex items-center gap-1.5 rounded-full border px-2.5 py-1 text-xs font-medium transition-colors focus-visible:ring-2 focus-visible:outline-none',
                    selectedModeFilter === 'all'
                      ? 'border-primary bg-primary text-primary-foreground shadow-xs'
                      : 'border-border bg-card text-muted-foreground hover:bg-accent hover:text-foreground',
                  )
                "
                @click="selectedModeFilter = 'all'"
              >
                All ({{ mappings.length }})
              </button>
  
              <button
                type="button"
                :class="
                  cn(
                    'focus-visible:ring-ring inline-flex items-center gap-1.5 rounded-full border px-2.5 py-1 text-xs font-medium transition-colors focus-visible:ring-2 focus-visible:outline-none',
                    selectedModeFilter === 'upsert'
                      ? 'border-primary bg-primary text-primary-foreground shadow-xs'
                      : 'border-border bg-card text-muted-foreground hover:bg-accent hover:text-foreground',
                  )
                "
                @click="selectedModeFilter = 'upsert'"
              >
                Upsert Keys (2)
              </button>
  
              <button
                type="button"
                :class="
                  cn(
                    'focus-visible:ring-ring inline-flex items-center gap-1.5 rounded-full border px-2.5 py-1 text-xs font-medium transition-colors focus-visible:ring-2 focus-visible:outline-none',
                    selectedModeFilter === 'update_if_newer'
                      ? 'border-primary bg-primary text-primary-foreground shadow-xs'
                      : 'border-border bg-card text-muted-foreground hover:bg-accent hover:text-foreground',
                  )
                "
                @click="selectedModeFilter = 'update_if_newer'"
              >
                Update if Newer (2)
              </button>
  
              <button
                type="button"
                :class="
                  cn(
                    'focus-visible:ring-ring inline-flex items-center gap-1.5 rounded-full border px-2.5 py-1 text-xs font-medium transition-colors focus-visible:ring-2 focus-visible:outline-none',
                    selectedModeFilter === 'update_only'
                      ? 'border-primary bg-primary text-primary-foreground shadow-xs'
                      : 'border-border bg-card text-muted-foreground hover:bg-accent hover:text-foreground',
                  )
                "
                @click="selectedModeFilter = 'update_only'"
              >
                Update Only (1)
              </button>
            </div>
          </div>
        </div>
  
        <CardContent class="p-0">
          <div class="overflow-x-auto">
            <Table density="cozy">
              <TableHeader>
                <TableRow>
                  <TableHead class="text-xs font-semibold">Source Column (Snowflake)</TableHead>
                  <TableHead class="w-12 text-center text-xs font-semibold" aria-label="Mapping Direction" />
                  <TableHead class="text-xs font-semibold">Destination Field (Salesforce CRM)</TableHead>
                  <TableHead class="text-xs font-semibold">Data Type & Sync Mode</TableHead>
                  <TableHead class="text-xs font-semibold">Sample Sync Value</TableHead>
                  <TableHead class="text-center text-xs font-semibold">Status</TableHead>
                </TableRow>
              </TableHeader>
              <TableBody>
                <TableRow v-for="mapping in filteredMappings" :key="mapping.id" class="group">
                  <!-- Source Column (Snowflake) -->
                  <TableCell class="py-3">
                    <div class="space-y-1">
                      <div class="flex items-center gap-1.5">
                        <span class="text-foreground font-mono text-xs font-semibold">
                          {{ mapping.sourceColumn }}
                        </span>
                        <Badge v-if="mapping.isMatchKey" variant="info" class="gap-1 font-mono text-xs">
                          <Key class="size-3" aria-hidden="true" />
                          Match Key
                        </Badge>
                      </div>
                      <div class="text-muted-foreground flex items-center gap-1.5 text-xs">
                        <span class="font-mono text-xs">{{ mapping.sourceType }}</span>
                        <span>·</span>
                        <span class="text-muted-foreground/80 truncate font-mono text-xs">
                          {{ mapping.transform }}
                        </span>
                      </div>
                    </div>
                  </TableCell>
  
                  <!-- Mapping Arrow (→) -->
                  <TableCell class="text-muted-foreground group-hover:text-primary w-12 py-3 text-center">
                    <div class="flex items-center justify-center">
                      <ArrowRight class="size-4 transition-transform group-hover:translate-x-0.5" aria-hidden="true" />
                    </div>
                  </TableCell>
  
                  <!-- Destination Field (Salesforce CRM) -->
                  <TableCell class="py-3">
                    <div class="space-y-1">
                      <div class="flex items-center gap-1.5">
                        <Badge variant="outline" class="font-mono text-xs">
                          {{ mapping.destinationObject }}
                        </Badge>
                        <span class="text-foreground font-mono text-xs font-semibold">
                          {{ mapping.destinationField }}
                        </span>
                      </div>
                      <p class="text-muted-foreground font-mono text-xs">Target Type: {{ mapping.destinationType }}</p>
                    </div>
                  </TableCell>
  
                  <!-- Data Type & Sync Mode -->
                  <TableCell class="py-3">
                    <div class="space-y-1">
                      <Badge
                        :variant="mapping.syncMode.includes('Upsert') ? 'default' : 'outline'"
                        class="font-mono text-xs"
                      >
                        {{ mapping.syncMode }}
                      </Badge>
                      <p class="text-muted-foreground text-xs">
                        {{ mapping.isMatchKey ? 'Primary deduplication index' : 'Safe incremental sync' }}
                      </p>
                    </div>
                  </TableCell>
  
                  <!-- Sample Sync Value -->
                  <TableCell class="py-3">
                    <div class="space-y-0.5">
                      <div
                        class="bg-muted/50 text-foreground inline-flex items-center gap-1.5 rounded-md border px-2 py-1 font-mono text-xs font-medium"
                      >
                        <span class="text-primary font-semibold">›</span>
                        <span>{{ mapping.sampleValue }}</span>
                      </div>
                      <p class="text-muted-foreground text-xs">Live sample preview</p>
                    </div>
                  </TableCell>
  
                  <!-- Status Badge / Toggle -->
                  <TableCell class="py-3 text-center">
                    <Badge variant="success" class="gap-1 font-mono text-xs">
                      <span class="bg-success size-1.5 rounded-full" />
                      Active
                    </Badge>
                  </TableCell>
                </TableRow>
              </TableBody>
            </Table>
          </div>
        </CardContent>
      </Card>
  
      <!-- Sync Run History & Error Queue Table Card -->
      <Card class="border-border shadow-xs">
        <CardHeader class="pb-3">
          <div class="flex flex-col gap-2 sm:flex-row sm:items-center sm:justify-between">
            <div>
              <CardTitle class="text-base font-semibold">
                Sync Run History & Execution Log (Recent {{ runs.length }} Runs)
              </CardTitle>
              <CardDescription class="text-xs">
                Audit trail of automated and manual reverse ETL execution runs, Snowflake query IDs, and Salesforce Bulk
                API ingestion
              </CardDescription>
            </div>
  
            <div class="flex items-center gap-2">
              <div
                class="bg-success/10 text-success flex items-center gap-1.5 rounded-md border px-2.5 py-1 text-xs font-medium"
              >
                <ShieldCheck class="size-3.5" aria-hidden="true" />
                <span>Error DLQ: 0 Failed Records</span>
              </div>
            </div>
          </div>
        </CardHeader>
  
        <CardContent class="p-0">
          <div class="divide-border/60 divide-y">
            <div
              v-for="run in runs"
              :key="run.id"
              :class="cn('group transition-colors', expandedRunIds[run.id] ? 'bg-muted/30' : 'hover:bg-muted/20')"
            >
              <!-- Run Summary Header Row -->
              <div
                role="button"
                tabindex="0"
                :aria-expanded="!!expandedRunIds[run.id]"
                class="focus-visible:ring-ring flex cursor-pointer flex-col gap-3 p-3.5 focus-visible:ring-2 focus-visible:outline-none focus-visible:ring-inset sm:flex-row sm:items-center sm:justify-between"
                @click="toggleRunExpand(run.id)"
                @keydown.enter.prevent="toggleRunExpand(run.id)"
                @keydown.space.prevent="toggleRunExpand(run.id)"
              >
                <!-- Left Rail: Chevron, Run ID, Status, Timestamp & Trigger -->
                <div class="flex min-w-0 items-start gap-3 sm:items-center">
                  <button
                    type="button"
                    aria-label="Toggle sync run details"
                    class="text-muted-foreground group-hover:text-foreground mt-0.5 shrink-0 transition-transform sm:mt-0"
                    :class="expandedRunIds[run.id] ? 'text-foreground rotate-90' : ''"
                  >
                    <ChevronRight class="size-4" aria-hidden="true" />
                  </button>
  
                  <div class="space-y-1 sm:space-y-0.5">
                    <div class="flex flex-wrap items-center gap-2">
                      <span class="text-foreground font-mono text-xs font-bold">
                        {{ run.runNumber }}
                      </span>
  
                      <Badge variant="success" class="gap-1 font-mono text-xs">
                        <span class="bg-success size-1.5 rounded-full" />
                        {{ run.statusLabel }}
                      </Badge>
  
                      <span class="text-muted-foreground font-mono text-xs whitespace-nowrap">
                        {{ formatTimestamp(run.startedAt) }}
                      </span>
  
                      <Badge variant="outline" class="font-mono text-xs">
                        {{ run.syncTrigger }}
                      </Badge>
                    </div>
  
                    <p class="text-muted-foreground text-xs">
                      Processed {{ formatNumber(run.totalRecords) }} records ({{
                        formatNumber(run.insertedRecords)
                      }}
                      added, {{ formatNumber(run.updatedRecords) }} updated) · 0 failed
                    </p>
                  </div>
                </div>
  
                <!-- Right Rail: Duration, Rows Affected, Warehouse -->
                <div class="flex shrink-0 flex-wrap items-center gap-3 sm:justify-end">
                  <div class="bg-muted/60 flex items-center gap-1.5 rounded-md border px-2 py-1 font-mono text-xs">
                    <Clock class="text-muted-foreground size-3" aria-hidden="true" />
                    <span class="text-muted-foreground">Duration:</span>
                    <span class="text-foreground font-medium tabular-nums">{{ run.duration }}</span>
                  </div>
  
                  <div class="text-muted-foreground flex items-center gap-1.5 font-mono text-xs">
                    <span class="text-foreground/90 font-medium">{{ run.warehouse }}</span>
                  </div>
                </div>
              </div>
  
              <!-- Expanded Run Diagnostics Details -->
              <div v-if="expandedRunIds[run.id]" class="bg-muted/15 border-t px-4 py-3.5">
                <div class="space-y-3">
                  <div class="grid grid-cols-1 gap-3 sm:grid-cols-2 lg:grid-cols-3">
                    <!-- Snowflake Query Identifier -->
                    <div class="bg-card space-y-1 rounded-md border p-3">
                      <div class="flex items-center justify-between">
                        <span class="text-muted-foreground text-xs font-medium">Snowflake Query ID</span>
                        <Button
                          variant="ghost"
                          size="xs"
                          class="h-6 gap-1 px-2 text-xs"
                          @click="copyQueryId(run.id, run.queryId)"
                        >
                          <Check v-if="copiedQueryId === run.id" class="text-success size-3" aria-hidden="true" />
                          <Copy v-else class="size-3" aria-hidden="true" />
                          <span>{{ copiedQueryId === run.id ? 'Copied' : 'Copy' }}</span>
                        </Button>
                      </div>
                      <p class="text-foreground font-mono text-xs font-semibold">
                        {{ run.queryId }}
                      </p>
                      <p class="text-muted-foreground text-xs">SQL compilation: 180ms · Warehousing tier: XS</p>
                    </div>
  
                    <!-- Salesforce Bulk API Batch ID -->
                    <div class="bg-card space-y-1 rounded-md border p-3">
                      <div class="flex items-center justify-between">
                        <span class="text-muted-foreground text-xs font-medium">Salesforce Bulk Batch ID</span>
                        <Badge variant="outline" class="font-mono text-xs"> Bulk 2.0 </Badge>
                      </div>
                      <p class="text-foreground font-mono text-xs font-semibold">
                        {{ run.batchId }}
                      </p>
                      <p class="text-muted-foreground text-xs">Chunk size: 10,000 records/batch · HTTP 200 OK</p>
                    </div>
  
                    <!-- Ingestion Breakdown -->
                    <div class="bg-card space-y-1 rounded-md border p-3 sm:col-span-2 lg:col-span-1">
                      <div class="flex items-center justify-between">
                        <span class="text-muted-foreground text-xs font-medium">Ingestion Breakdown</span>
                        <span class="text-success font-mono text-xs">100% Ingested</span>
                      </div>
                      <div class="flex items-center gap-2 pt-1 font-mono text-xs">
                        <span class="text-success font-medium"> +{{ formatNumber(run.insertedRecords) }} Ins </span>
                        <span class="text-info font-medium"> ~{{ formatNumber(run.updatedRecords) }} Upd </span>
                        <span class="text-muted-foreground"> {{ run.deletedRecords }} Del </span>
                      </div>
                      <p class="text-muted-foreground text-xs">Zero dead-letter quarantine items</p>
                    </div>
                  </div>
                </div>
              </div>
            </div>
          </div>
        </CardContent>
  
        <!-- Bottom Engine & Sync Ingestion Protocol Telemetry Bar -->
        <div
          class="bg-muted/40 flex flex-col gap-2.5 border-t px-4 py-3 text-xs sm:flex-row sm:items-center sm:justify-between"
        >
          <div class="text-muted-foreground flex flex-wrap items-center gap-4">
            <div class="text-foreground flex items-center gap-1.5 font-medium">
              <Activity class="text-success size-3.5" aria-hidden="true" />
              <span>Reverse ETL Engine:</span>
              <span class="font-mono">Census / Hightouch Protocol v4.2</span>
            </div>
  
            <Separator orientation="vertical" class="hidden h-3.5 sm:block" />
  
            <div class="flex items-center gap-1.5">
              <Database class="text-info size-3.5" aria-hidden="true" />
              <span>Source DW:</span>
              <span class="text-foreground font-mono">Snowflake (AWS us-east-1)</span>
            </div>
  
            <Separator orientation="vertical" class="hidden h-3.5 sm:block" />
  
            <div class="flex items-center gap-1.5">
              <Server class="text-primary size-3.5" aria-hidden="true" />
              <span>Target SaaS:</span>
              <span class="text-foreground font-mono">Salesforce Bulk API 2.0 + HubSpot v3</span>
            </div>
          </div>
  
          <div class="text-muted-foreground flex items-center gap-2 font-mono">
            <span class="bg-success size-1.5 rounded-full" />
            <span>Daily API Quota: 94,200 / 100,000 remaining</span>
          </div>
        </div>
      </Card>
    </div>
  </template>
  

Raw manifest:https://uipkge.dev/r/vue/reverse-etl-sync-manager.json