Function getOrCreateSession

notfair-cmo/src/server/sessions/index.ts:52–92

(input: {
  project_slug: string;
  agent_id: string;
  label: string;
  harness_adapter: HarnessAdapterId;
  task_id?: string | null;
})

}

export function getOrCreateSession(input: {
  project_slug: string;
  agent_id: string;
  label: string;
  harness_adapter: HarnessAdapterId;
  task_id?: string | null;
}): Session {
  const db = getDb();
  const existing = db
    .prepare(
      "SELECT * FROM sessions WHERE project_slug = ? AND agent_id = ? AND label = ?",
    )
    .get(input.project_slug, input.agent_id, input.label) as SessionRow | undefined;
  if (existing) return rowToSession(existing);

  const session: Session = {
    id: randomUUID(),
    project_slug: input.project_slug,
    agent_id: input.agent_id,
    label: input.label,
    harness_adapter: input.harness_adapter,
    harness_session_id: null,
    task_id: input.task_id ?? null,
    created_at: new Date().toISOString(),
    updated_at: new Date().toISOString(),
  };

  db.prepare(
    "INSERT INTO sessions (id, project_slug, agent_id, label, harness_adapter, harness_session_id, task_id, created_at, updated_at) VALUES (?, ?, ?, ?, ?, NULL, ?, ?, ?)",
  ).run(
    session.id,
    session.project_slug,
    session.agent_id,
    session.label,
    session.harness_adapter,
    session.task_id,
    session.created_at,
    session.updated_at,
  );
  return session;
}

export function getSession(id: string): Session | null {
  const row = getDb()