cf-workers-integration

Cloudflare Workers Project Integration

Integrating separate codebases (NAS controllers, analysis engines, LLM callers) into one coherent CF Workers project.

Trigger

• Multiple codebases need merging (NAS + working copy + external)
• Worker.ts monolithic → router + controllers refactoring
• LLM caller consolidation (duplicated DeepSeek/NVIDIA fallback)
• Data source unification (master JSON for shared constants)

Step 1 — Map structure

diff -rq src/ /source/path/src/ — find unique files on each side.

Step 2 — Find dead code

Search for orphaned files (imported 0 times), duplicated utilities, hardcoded constants.

Step 3 — Shared infra modules

1. src/data/<domain>-constants.json — master constants
2. src/utils/llm.ts — unified DeepSeek + NVIDIA callers
3. src/analysis/types.ts — analysis report types

Step 4 — Worker.ts → router pattern

import { handleX } from './src/controllers/x';
export default { async fetch(request, env, ctx) {
  if (url.pathname === '/api/x') return handleX(request, env, url, ctx);
  return env.ASSETS.fetch(request);
}};

Step 5 — LLM unification

src/utils/llm.ts provides:

• callDeepSeek(env, systemPrompt, userContent, maxTokens) — direct DeepSeek call
• callNvidiaWithFallback(env, systemPrompt, userContent, maxTokens) — 3-key NVIDIA NIM + 28s per-key timeout + AbortController
• callLLMJson(env, systemPrompt, userContent) — DeepSeek→NVIDIA fallback chain; throws on all failure
• extractJsonObject(text) — regex-based JSON extraction from LLM response

All controllers import from this single module instead of duplicating API call logic.

Step 6 — API Response Enrichment (injectAnalysisReport pattern)

Intercept an API response, add computed data, return enhanced response without breaking existing consumers:

async function injectAnalysisReport(response: Response): Promise<Response> {
  const clone = response.clone();
  const body = await clone.json();
  body.data.analysisReport = analyze(body.data);
  return new Response(JSON.stringify(body), {
    status: response.status,
    headers: response.headers, // preserve CORS/auth headers
  });
}