Function withExecutionAnalytics

packages/core/analytics/src/engine.ts:30–63

(
  engine: ExecutionEngine<E>,
  analytics: AnalyticsService,
  context: ExecutionAnalyticsContext,
)

}

export const withExecutionAnalytics = <E extends Cause.YieldableError>(
  engine: ExecutionEngine<E>,
  analytics: AnalyticsService,
  context: ExecutionAnalyticsContext,
): ExecutionEngine<E> => {
  const completed = (ok: boolean): Effect.Effect<void> =>
    analytics.record("execution_completed", {
      ok,
      plane: context.plane,
      toolkit: context.toolkit,
    });

  const recordOutcome = (result: ExecutionResult | null): Effect.Effect<void> =>
    result?.status === "completed" ? completed(!result.result.error) : Effect.void;

  return {
    ...engine,
    execute: (code, options) =>
      engine.execute(code, options).pipe(
        Effect.tap((result) => completed(!result.error)),
        Effect.tapError(() => completed(false)),
      ),
    executeWithPause: (code, options) =>
      engine.executeWithPause(code, options).pipe(
        Effect.tap(recordOutcome),
        Effect.tapError(() => completed(false)),
      ),
    resume: (executionId, response) =>
      engine.resume(executionId, response).pipe(
        Effect.tap(recordOutcome),
        Effect.tapError(() => completed(false)),
      ),
  };
};