┌─────────────────┐    ┌─────────────────┐    ┌─────────────────┐    ┌─────────────────┐
│  External APIs  │───▶│    MongoDB      │───▶│  Elasticsearch  │───▶│    Website      │
│  (DIS, K&M)     │    │   (crop_dev)    │    │  (parts_current)│    │ (Next.js SSR)   │
└─────────────────┘    └─────────────────┘    └─────────────────┘    └─────────────────┘
        │                      │                      │                      │
   Catalog Service        Raw Storage           Search Index           User Interface

DIS API ──▶ GET /parts/{vendor} ──▶ Transform ──▶ MongoDB (parts_{vendor})

K&M API ──▶ GET /Tires (paginated) ──▶ Transform ──▶ MongoDB (parts_kmt)
                                            │
                                            ▼
                                    Elasticsearch (optional)

# Parts sync (DIS collections → parts_current)
bash scripts/gcp-sync-data.sh "parts_nhl,parts_bns,..." "parts_current"

# Tires sync (K&M → tires_current)
bash scripts/gcp-sync-data.sh "parts_kmt" "tires_current"

MongoDB ──▶ Cursor (batched) ──▶ Transform ──▶ Validate ──▶ Bulk Index ──▶ Elasticsearch
   │              │                  │            │              │
   │              │                  │            │              ▼
parts_{vendor}   2000 docs/batch   IndexedPart   Skip invalid   parts_current OR tires_current

parts_current_read  ──▶ parts_v{YYYY_MM_DD} (DIS parts)
parts_current_write ──▶ parts_v{YYYY_MM_DD}

tires_current_read  ──▶ tires_v{YYYY_MM_DD} (K&M Tires)
tires_current_write ──▶ tires_v{YYYY_MM_DD}

Request ──▶ Parse Params ──▶ Build Query ──▶ Elasticsearch ──▶ Transform ──▶ Response
   │              │               │               │                │
   │              │               │               │                ▼
?q=tire      QueryFilters    bool query      Search response    PartPreview[]
&category=tires             + aggregations

{
  parts: PartPreview[],      // Search results
  pagination: {
    page: number,
    pageSize: number,
    total: number,
    totalPages: number
  },
  facets: {
    manufacturer: [...],
    category: [...],
    price: {...}
  }
}

User Request ──▶ Next.js Server ──▶ Search API ──▶ SSR ──▶ HTML Response
                      │                 │                      │
                      │                 ▼                      ▼
                 Server Component   Elasticsearch        Pre-rendered
                                                         tire catalog

ELASTICSEARCH_URL=http://10.0.0.52:9200  # VPC internal
SEARCH_INDEX_NAME=parts_current          # Alias name

# Via GitHub Actions
gh workflow run search-deploy.yml

# Via Cloud Run Job
gcloud run jobs execute sync-data-auto --region=us-east1

# Search service health
curl https://search-service-atife5uvka-ue.a.run.app/health

# Response includes:
# - elasticsearch: ok/error
# - mongodb: ok/error
# - docCount_es: number of indexed documents
# - aliasTarget: current index name

# Check index document count
curl "https://search-service-atife5uvka-ue.a.run.app/api/filters" | jq '.total'

# Check specific manufacturer
curl "https://search-service-atife5uvka-ue.a.run.app/api/search?manufacturer=kmt" | jq '.pagination.total'

# Check MongoDB collection
# Use MongoDB MCP tool: count(database: "crop_dev", collection: "parts_kmt")

interface IndexedPart {
  id: string;
  slug: string;
  sku: string;                    // CT-{MFG}-{PN}
  skuVariants: string[];
  partNumber: string;
  pnNorm: string;                 // Normalized for search
  title: string;
  description?: string;
  manufacturer: {
    name: string;
    code: string;                 // KMT, BNS, etc.
  };
  category: string;               // "Wheels & Tires", "parts"
  price?: {
    list: { value: number; currency: string; }
  };
  media?: {
    hasImages: boolean;
    imageCount: number;
    images?: Array<{ url: string; type: string; }>;
  };
  status: 'active' | 'discontinued';
  sources: string[];              // ['dis'], ['km-tire']
  createdAt: string;
  updatedAt: string;
}