/**
 * FT.SEARCH index query [NOCONTENT] [LIMIT offset count] [TIMEOUT ms]
 */

import { parseFtSearch } from './ft/parser.ts';
import { search } from '../storage/sqlite/search.ts';
import type { CommandReply, Engine, RespValue } from '../types.ts';

export function handleFtSearch(engine: Engine, args: Buffer[]): CommandReply {
  const db = engine._db;
  if (!db) return { error: 'ERR SQLite not available' };
  const parsed = parseFtSearch(args);
  if (parsed.error) return { error: parsed.error };
  try {
    const result = search(db, parsed.indexName, parsed.query, {
      offset: parsed.offset,
      count: parsed.count,
      noContent: parsed.noContent,
      limits: engine._searchLimits,
      timeoutMs: parsed.timeoutMs,
    });
    const out: RespValue[] = [result.total];
    if (parsed.noContent) {
      out.push(...result.docIds);
    } else {
      for (const docId of result.docIds) {
        out.push(docId);
        const fields = result.fieldsByDoc![docId] ?? {};
        const flat: RespValue[] = [];
        for (const [k, v] of Object.entries(fields)) {
          flat.push(k, v);
        }
        out.push(flat);
      }
    }
    return out;
  } catch (e) {
    const msg = e instanceof Error ? e.message : String(e);
    return { error: msg === 'Unknown index name' ? msg : msg.startsWith('ERR ') ? msg : 'ERR ' + msg };
  }
}