cloudflare-infrastructure

Cloudflare Infrastructure Rules

🔍 Code Searchability Patterns

Find Cloudflare Infrastructure Issues with ast-grep

# Find D1 database bindings
ast-grep --pattern 'env.$DB.prepare($QUERY)' src/
ast-grep --pattern 'env.ANALYTICS.prepare' src/
ast-grep --pattern 'env.RAW_FEED_DB.prepare' src/
sg -p 'env.$DB.prepare' src/
sg -p 'env.ANALYTICS' src/
sg -p 'env.RAW_FEED_DB' src/

# Find KV namespace usage
ast-grep --pattern 'env.$KV.get($KEY)' src/
ast-grep --pattern 'env.$KV.put($KEY, $VALUE)' src/
sg -p 'env.$KV.get' src/
sg -p 'env.$KV.put' src/

# Find queue operations
ast-grep --pattern 'env.$QUEUE.send($MESSAGE)' src/
ast-grep --pattern 'env.LINE_INGRESS.send' src/
sg -p 'env.$QUEUE.send' src/
sg -p 'env.LINE_INGRESS' src/

# Find Analytics Engine usage
ast-grep --pattern 'env.ANALYTICS_ENGINE.writeDataPoint' src/
sg -p 'env.ANALYTICS_ENGINE' src/

Cloudflare Infrastructure Discovery Commands

sg search "env.ANALYTICS" src/
sg search "env.RAW_FEED_DB" src/
sg search "env.BET_TICKER_RAW" src/
sg search "env.LINE_INGRESS" src/
sg search "env.ANALYTICS_ENGINE" src/

Search Examples

# Find all D1 database operations
sg search 'env.$DB.prepare' src/
# Find KV operations
sg search 'env.$KV.get' src/
# Find queue operations
sg search 'env.$QUEUE.send' src/
# Find Analytics Engine usage
sg search 'env.ANALYTICS_ENGINE' src/

🏗️ Infrastructure Patterns

D1 Database Operations

Parameterized Queries (CRITICAL)

// ✅ CORRECT: Parameterized query
const result = await env.ANALYTICS.prepare(`
  SELECT * FROM line_movements 
  WHERE eid = ? AND ts > ?
  LIMIT ?
`).bind(eventID, timestamp, limit).all();

// ❌ WRONG: String interpolation (SQL injection risk)
const result = await env.ANALYTICS.prepare(`
  SELECT * FROM line_movements 
  WHERE eid = '${eventID}' AND ts > '${timestamp}'
  LIMIT ${limit}
`).all();

Type Safety with D1 Results

import { normalizeD1Result } from '../utils/request';

// ✅ CORRECT: Type-safe D1 results
const result = await env.ANALYTICS.prepare(`
  SELECT eid, mt, ts, old_line, new_line
  FROM line_movements
  WHERE eid = ?
  ORDER BY ts DESC
  LIMIT ?
`).bind(eventID, limit).all();

type Movement = {
  eid: string;
  mt: string;
  ts: string;
  old_line: number;
  new_line: number;
};

const movements = normalizeD1Result<Movement>(result);