Function createExecutionContext

packages/component-sdk/src/context.ts:53–217

(options: CreateContextOptions)

}

export function createExecutionContext(options: CreateContextOptions): ExecutionContext {
  const { runId, componentRef, metadata: metadataInput, storage, secrets, artifacts, trace, logCollector, terminalCollector, agentTracePublisher, workflowId, workflowName, organizationId } =
    options;
  const metadata = createMetadata(runId, componentRef, metadataInput);
  const scopedTrace = trace ? createScopedTrace(trace, metadata) : undefined;

  const pushLog = (
    stream: LogEventInput['stream'],
    level: LogEventInput['level'],
    args: unknown[],
  ) => {
    if (args.length === 0) {
      return;
    }
    const message = format(...args);
    if (message.length === 0) {
      return;
    }
    const entry: LogEventInput = {
      runId,
      nodeRef: componentRef,
      stream,
      level,
      message,
      timestamp: new Date().toISOString(),
      metadata,
    };

    if (logCollector) {
      logCollector(entry);
    }

    if (scopedTrace) {
      scopedTrace.record({
        type: 'NODE_PROGRESS',
        runId,
        nodeRef: componentRef,
        timestamp: entry.timestamp,
        level: level ?? 'info',
        message,
        data: { stream, origin: 'log' },
      });
    }
  };

  const logger: Logger = Object.freeze({
    debug: (...args: unknown[]) => {
      pushLog('stdout', 'debug', args);
      console.debug(`[${componentRef}]`, ...args);
    },
    info: (...args: unknown[]) => {
      pushLog('stdout', 'info', args);
      console.log(`[${componentRef}]`, ...args);
    },
    warn: (...args: unknown[]) => {
      pushLog('stdout', 'warn', args);
      console.warn(`[${componentRef}]`, ...args);
    },