saltbo__agent-kanban/server/http/resource-server/representation.ts

import type { Board, Repository, Task, TaskAction } from "@shared";

export async function representationEtag(value: unknown): Promise<string> {
  const digest = await crypto.subtle.digest("SHA-256", new TextEncoder().encode(JSON.stringify(value)));
  const tag = Array.from(new Uint8Array(digest), (byte) => byte.toString(16).padStart(2, "0")).join("");
  return `"${tag}"`;
}

export function boardResource(board: Board & { tasks?: Task[] }, requestUrl: string) {
  return {
    id: board.id,
    name: board.name,
    description: board.description,
    type: board.type,
    labels: board.labels,
    visibility: board.visibility,
    shareSlug: board.share_slug,
    tasks: board.tasks?.map((task) => taskResource(task, requestUrl)),
    createdAt: board.created_at,
    updatedAt: board.updated_at,
    links: {
      self: absolute(requestUrl, `/api/boards/${encodeURIComponent(board.id)}`),
      tasks: absolute(requestUrl, `/api/tasks?boardId=${encodeURIComponent(board.id)}`),
    },
  };
}

export function repositoryResource(repository: Repository, requestUrl: string) {
  return {
    id: repository.id,
    name: repository.name,
    url: repository.url,
    fullName: repository.full_name,
    createdAt: repository.created_at,
    taskCount: repository.task_count ?? 0,
    appStatus: repository.app_status ?? null,
    links: {
      self: absolute(requestUrl, `/api/repositories/${encodeURIComponent(repository.id)}`),
      tasks: absolute(requestUrl, `/api/tasks?repositoryId=${encodeURIComponent(repository.id)}`),
    },
  };
}

export function taskResource(
  task: Task & {
    depends_on?: string[];
    notes?: TaskAction[];
    duration_minutes?: number | null;
    subtask_count?: number;
  },
  requestUrl: string,
) {
  return {
    id: task.id,
    seq: task.seq,
    status: task.status.replaceAll("_", "-"),
    title: task.title,
    description: task.description,
    boardId: task.board_id,
    repositoryId: task.repository_id,
    repositoryName: task.repository_name ?? null,
    labels: task.labels ?? [],
    createdBy: task.created_by,
    assignedTo: task.assigned_to,
    assigneeName: task.assignee_name ?? null,
    boardType: task.board_type ?? null,
    pullRequestUrl: task.pr_url,
    input: task.input,
    metadata: task.metadata,
    createdFrom: task.created_from,
    scheduledAt: task.scheduled_at,
    position: task.position,
    blocked: task.blocked ?? false,
    dependsOn: task.depends_on ?? [],
    durationMinutes: task.duration_minutes ?? null,
    subtaskCount: task.subtask_count ?? 0,
    sessionBinding: task.session_binding
      ? {
          agentActorId: task.session_binding.agent_actor_id,
          runtime: task.session_binding.runtime,
          runtimeSessionId: task.session_binding.runtime_session_id,
          boundAt: task.session_binding.bound_at,
        }
      : null,
    notes: task.notes?.map((note) => taskNoteResource(note, requestUrl)),
    createdAt: task.created_at,
    updatedAt: task.updated_at,
    links: {
      self: absolute(requestUrl, `/api/tasks/${encodeURIComponent(task.id)}`),
      board: absolute(requestUrl, `/api/boards/${encodeURIComponent(task.board_id)}`),
      repository: task.repository_id ? absolute(requestUrl, `/api/repositories/${encodeURIComponent(task.repository_id)}`) : null,
      notes: absolute(requestUrl, `/api/tasks/${encodeURIComponent(task.id)}/notes`),
      claims: absolute(requestUrl, `/api/tasks/${encodeURIComponent(task.id)}/claims`),
    },
  };
}

export function taskNoteResource(note: TaskAction, requestUrl: string) {
  return {
    id: note.id,
    taskId: note.task_id,
    action: note.action,
    actorType: note.actor_type,
    actorId: note.actor_id,
    actorName: note.actor_name ?? null,
    detail: note.detail,
    createdAt: note.created_at,
    links: {
      self: absolute(requestUrl, `/api/tasks/${encodeURIComponent(note.task_id)}/notes/${encodeURIComponent(note.id)}`),
      task: absolute(requestUrl, `/api/tasks/${encodeURIComponent(note.task_id)}`),
    },
  };
}

export function taskEventResource(result: { cursor: string; outcome: string; tasks: Task[]; until: string }, requestUrl: string) {
  return {
    cursor: result.cursor,
    outcome: result.outcome.replaceAll("_", "-"),
    tasks: result.tasks.map((task) => taskResource(task, requestUrl)),
    until: result.until.replaceAll("_", "-"),
  };
}

function absolute(requestUrl: string, path: string): string {
  return new URL(path, requestUrl).toString();
}