Function adapt

server/src/training-agent/framework-server.ts:229–275

* Convert a legacy `(args, TrainingContext)` handler into the framework's * `(params, HandlerContext) => Promise ` signature. * * - Enforces `VERSION_UNSUPPORTED` for `adcp_major_version !== 3` (legacy * dispatch behavior, not yet in the framework). * - Strips `context` from p

(toolName: string, handler: LegacyHandler)

 *   task type. Matches legacy dispatch behavior in `task-handlers.ts`.
 */
function adapt(toolName: string, handler: LegacyHandler) {
  return async (params: unknown, ctx: HandlerContext): Promise<AdaptedResponse> => {
    const rawParams = (params as Record<string, unknown> | undefined) ?? {};
    const { context: callerContext, ...handlerArgs } = rawParams;

    const requestedVersion = (handlerArgs as { adcp_major_version?: unknown }).adcp_major_version;
    if (
      requestedVersion !== undefined
      && !(SUPPORTED_MAJOR_VERSIONS as readonly number[]).includes(requestedVersion as number)
    ) {
      return versionUnsupported(requestedVersion, callerContext);
    }

    const trainingCtx: TrainingContext = {
      mode: 'open',
      principal: ctx.authInfo?.clientId ?? 'anonymous',
    };

    return runWithSessionContext(async () => {
      let result: unknown;
      try {
        result = await Promise.resolve(handler(handlerArgs as ToolArgs, trainingCtx));
      } catch (err) {
        logger.error({ err }, 'framework handler threw');
        return serviceUnavailable(err, callerContext);
      }
      try {
        await flushDirtySessions();
      } catch (err) {
        logger.error({ err }, 'framework flushDirtySessions threw');
        return serviceUnavailable(err, callerContext);
      }
      const response = toAdaptedResponse(result, callerContext);
      if (!response.isError) {
        const idk = (handlerArgs as { idempotency_key?: unknown }).idempotency_key;
        maybeEmitCompletionWebhook({
          toolName,
          args: handlerArgs as Record<string, unknown>,
          response: (result ?? {}) as Record<string, unknown>,
          requestIdempotencyKey: typeof idk === 'string' ? idk : undefined,
          principal: scopedWebhookPrincipal(ctx, handlerArgs as Record<string, unknown>),
        });
      }
      return response;
    });
  };
}

// ── Resolver hooks ───────────────────────────────────────────────