Function parseInstallSource

src/daemon/server/http-server.ts:287–333

(params: Record<string, unknown>)

}

function parseInstallSource(params: Record<string, unknown>): DaemonInstallSource {
  const source = params.source;
  if (!source || typeof source !== 'object') {
    throw new AppError('INVALID_ARGS', 'Invalid params: source is required');
  }
  const record = source as Record<string, unknown>;
  if (record.kind === 'url') {
    const url = typeof record.url === 'string' ? record.url.trim() : '';
    if (!url) {
      throw new AppError('INVALID_ARGS', 'Invalid params: source.url is required for url sources');
    }
    const rawHeaders = record.headers;
    const headers: Record<string, string> = {};
    if (rawHeaders !== undefined) {
      if (!rawHeaders || typeof rawHeaders !== 'object' || Array.isArray(rawHeaders)) {
        throw new AppError('INVALID_ARGS', 'Invalid params: source.headers must be a string map');
      }
      for (const [key, value] of Object.entries(rawHeaders as Record<string, unknown>)) {
        if (typeof value !== 'string') {
          throw new AppError(
            'INVALID_ARGS',
            'Invalid params: source.headers values must be strings',
          );
        }
        headers[key] = value;
      }
    }
    return Object.keys(headers).length > 0 ? { kind: 'url', url, headers } : { kind: 'url', url };
  }
  if (record.kind === 'path') {
    const artifactPath = typeof record.path === 'string' ? record.path.trim() : '';
    if (!artifactPath) {
      throw new AppError(
        'INVALID_ARGS',
        'Invalid params: source.path is required for path sources',
      );
    }
    return { kind: 'path', path: artifactPath };
  }
  if (record.kind === 'github-actions-artifact') {
    return parseGitHubActionsArtifactSource(record);
  }
  throw new AppError(
    'INVALID_ARGS',
    'Invalid params: source.kind must be "url", "path", or "github-actions-artifact"',
  );
}

function toInstallFromSourceDaemonRequest(
  params: Record<string, unknown>,