Function registerTerminalsRoutes

packages/server/src/routes/terminals.ts:51–179

(
  app: TerminalsRouteHost,
  ix: IInstantiationService,
)

const detailsSchema = z.array(z.object({ path: z.string(), message: z.string() }));

export function registerTerminalsRoutes(
  app: TerminalsRouteHost,
  ix: IInstantiationService,
): void {
  const listRoute = defineRoute(
    {
      method: 'GET',
      path: '/sessions/{session_id}/terminals',
      params: sessionIdParamSchema,
      success: { data: listTerminalsResponseSchema },
      errors: {
        [ErrorCode.VALIDATION_FAILED]: { detailsSchema },
        [ErrorCode.SESSION_NOT_FOUND]: {},
      },
      description: 'List terminals for a session',
      tags: ['terminals'],
    },
    async (req, reply) => {
      try {
        const { session_id } = req.params;
        const items = await ix.invokeFunction((a) =>
          a.get(ITerminalService).list(session_id),
        );
        reply.send(okEnvelope({ items }, req.id));
      } catch (err) {
        sendMappedError(reply, req.id, err);
      }
    },
  );
  app.get(listRoute.path, listRoute.options, listRoute.handler as Parameters<TerminalsRouteHost['get']>[2]);

  const createRoute = defineRoute(
    {
      method: 'POST',
      path: '/sessions/{session_id}/terminals',
      params: sessionIdParamSchema,
      body: createTerminalRequestSchema,
      success: { data: getTerminalResponseSchema },
      errors: {
        [ErrorCode.VALIDATION_FAILED]: { detailsSchema },
        [ErrorCode.SESSION_NOT_FOUND]: {},
        [ErrorCode.FS_PATH_ESCAPES_SESSION]: {},
      },
      description: 'Create a terminal for a session',
      tags: ['terminals'],
    },
    async (req, reply) => {
      try {
        const { session_id } = req.params;
        const terminal = await ix.invokeFunction((a) =>
          a.get(ITerminalService).create(session_id, req.body),
        );
        reply.send(okEnvelope(terminal, req.id));
      } catch (err) {
        sendMappedError(reply, req.id, err);
      }
    },
  );