Function geocodePending

src/lib/sync.ts:37–90

Fire-and-forget: geocode pending markets without blocking sync

(db: ReturnType<typeof getDb>)

/** Fire-and-forget: geocode pending markets without blocking sync */
function geocodePending(db: ReturnType<typeof getDb>) {
  // Watchdog: reset stuck flag after 120s
  if (geocodeRunning && Date.now() - geocodeStartedAt > GEOCODE_WATCHDOG_MS) {
    console.warn("[sync] Geocode watchdog: resetting stuck flag");
    geocodeRunning = false;
  }
  if (geocodeRunning) return;
  const ungeo = db
    .prepare(`SELECT id, title, description, location FROM events WHERE ai_geo_done = 0 LIMIT 25`)
    .all() as Array<{ id: string; title: string; description: string | null; location: string | null }>;
  if (ungeo.length === 0) return;

  const updateGeo = db.prepare(`
    UPDATE events SET lat = @lat, lng = @lng, location = @location,
      geo_city = @city, geo_country = @country, ai_geo_done = 1
    WHERE id = @id
  `);
  const markDone = db.prepare(`UPDATE events SET ai_geo_done = 1 WHERE id = ?`);

  const writeResults = (resultMap: Map<string, { id: string; lat: number | null; lng: number | null; location: string | null; city: string | null; country: string | null; confidence: number }> | null) => {
    try {
      const txn = db.transaction(() => {
        for (const market of ungeo) {
          let result = resultMap?.get(market.id);
          if (!result || (result.lat === null && result.lng === null)) {
            const geo = geolocate(market.title, market.description ?? undefined);
            if (geo) {
              const [jLat, jLng] = addJitter(geo.coords[0], geo.coords[1], market.id);
              result = { id: market.id, lat: jLat, lng: jLng, location: geo.location, city: null, country: null, confidence: 0.3 };
            }
          }
          if (result && result.lat !== null && result.lng !== null) {
            updateGeo.run({ id: market.id, lat: result.lat, lng: result.lng, location: result.location || market.location, city: result.city, country: result.country });
          } else {
            markDone.run(market.id);
          }
        }
      });
      txn();
    } catch { /* DB busy — will retry next cycle */ }
  };

  if (isAiConfigured()) {
    geocodeRunning = true;
    geocodeStartedAt = Date.now();
    aiGeocodeBatch(ungeo.map((r) => ({ id: r.id, title: r.title, description: r.description, currentLocation: r.location })))
      .then((results) => writeResults(new Map(results.map((r) => [r.id, r]))))
      .catch((err) => { console.error("[sync] Geocode batch failed:", err); writeResults(null); })
      .finally(() => { geocodeRunning = false; console.info(`[sync] Geocoded ${ungeo.length} markets`); });
  } else {
    writeResults(null);
    console.info(`[sync] Geocoded ${ungeo.length} markets (regex)`);
  }
}

export async function runSync(): Promise<{
  eventCount: number;