feat(deno): Add denoDataloaderIntegration

Author: logaretm

packages/deno/src/index.ts

@@ -114,6 +114,7 @@ export type { DenoRedisIntegrationOptions } from './integrations/redis';
 export { denoMysqlIntegration } from './integrations/mysql';
 export { denoPostgresIntegration } from './integrations/postgres';
 export { denoAmqplibIntegration } from './integrations/amqplib';
+export { denoDataloaderIntegration } from './integrations/dataloader';
 export { denoContextIntegration } from './integrations/context';
 export { globalHandlersIntegration } from './integrations/globalhandlers';
 export { normalizePathsIntegration } from './integrations/normalizepaths';

packages/deno/src/integrations/dataloader.ts

@@ -0,0 +1,34 @@
+import { dataloaderChannelIntegration } from '@sentry/server-utils/orchestrion';
+import type { Integration, IntegrationFn } from '@sentry/core';
+import { defineIntegration, extendIntegration } from '@sentry/core';
+import { setAsyncLocalStorageAsyncContextStrategy } from '../async';
+
+const INTEGRATION_NAME = 'DenoDataloader' as const;
+
+/**
+ * Create spans for `dataloader` load/batch operations under Deno.
+ *
+ * `dataloader` channels are injected by the orchestrion runtime hook at load time.
+ * The `@sentry/deno/import` loader must be active for this integration to
+ * record anything.
+ *
+ * The channel-subscription logic is shared with the other server runtimes in
+ * `@sentry/server-utils`. This just installs Deno's `AsyncLocalStorage` context
+ * strategy (so spans nest under the active span and survive dataloader's deferred
+ * batch dispatch) before delegating.
+ */
+const _denoDataloaderIntegration = (() => {
+  const inner = dataloaderChannelIntegration();
+
+  return extendIntegration(inner, {
+    name: INTEGRATION_NAME,
+    setupOnce() {
+      setAsyncLocalStorageAsyncContextStrategy();
+    },
+  });
+}) satisfies IntegrationFn;
+
+export const denoDataloaderIntegration = defineIntegration(_denoDataloaderIntegration) as () => Integration & {
+  name: 'DenoDataloader';
+  setupOnce: () => void;
+};