Function createDaemonHttpServer

src/daemon/server/http-server.ts:513–746

(options: {
  handleRequest: DaemonInvokeFn;
  token?: string;
  retainArtifacts?: boolean;
})

}

export async function createDaemonHttpServer(options: {
  handleRequest: DaemonInvokeFn;
  token?: string;
  retainArtifacts?: boolean;
}): Promise<http.Server> {
  const authHook = await loadHttpAuthHook();
  const { handleRequest, token, retainArtifacts = false } = options;
  return http.createServer((req, res) => {
    if (req.method === 'GET' && req.url === '/health') {
      res.statusCode = 200;
      res.setHeader('content-type', 'application/json');
      res.end(JSON.stringify(buildDaemonHealthPayload('agent-device-daemon')));
      return;
    }

    if (
      tryHandleUploadHttpRoute({
        req,
        res,
        token: resolveToken({}, req.headers),
        authorize: async (request) =>
          await authorizeAuxiliaryHttpRequest({
            req: request.req,
            res: request.res,
            authHook,
            expectedToken: token,
            daemonRequest: request.daemonRequest,
          }),
      })
    ) {
      return;
    }

    if (
      tryHandleDownloadableArtifactHttpRoute({
        req,
        res,
        retainArtifacts,
        authorize: async (request) =>
          await authorizeAuxiliaryHttpRequest({
            req: request.req,
            res: request.res,
            authHook,
            expectedToken: token,
            daemonRequest: request.daemonRequest,
          }),
      })
    ) {
      return;
    }

    if (req.method !== 'POST' || req.url !== '/rpc') {
      res.statusCode = 404;
      res.end('Not found');
      return;
    }

    let body = '';