@microlabs/otel-cf-workers/dist/esm/instrumentation/env.js

import { isProxyable, wrap } from '../wrap.js';
import { instrumentDOBinding } from './do.js';
import { instrumentKV } from './kv.js';
import { instrumentQueueSender } from './queue.js';
import { instrumentServiceBinding } from './service.js';
import { instrumentAnalyticsEngineDataset } from './analytics-engine';
const isKVNamespace = (item) => {
    return !!item?.getWithMetadata;
};
const isQueue = (item) => {
    return !!item?.sendBatch;
};
const isDurableObject = (item) => {
    return !!item?.idFromName;
};
const isServiceBinding = (item) => {
    const binding = item;
    return !!binding.connect || !!binding.fetch || binding.queue || binding.scheduled;
};
const isAnalyticsEngineDataset = (item) => {
    return !!item?.writeDataPoint;
};
const instrumentEnv = (env) => {
    const envHandler = {
        get: (target, prop, receiver) => {
            const item = Reflect.get(target, prop, receiver);
            if (!isProxyable(item)) {
                return item;
            }
            if (isKVNamespace(item)) {
                return instrumentKV(item, String(prop));
            }
            else if (isQueue(item)) {
                return instrumentQueueSender(item, String(prop));
            }
            else if (isDurableObject(item)) {
                return instrumentDOBinding(item, String(prop));
            }
            else if (isServiceBinding(item)) {
                return instrumentServiceBinding(item, String(prop));
            }
            else if (isAnalyticsEngineDataset(item)) {
                return instrumentAnalyticsEngineDataset(item, String(prop));
            }
            else {
                return item;
            }
        },
    };
    return wrap(env, envHandler);
};
export { instrumentEnv };
//# sourceMappingURL=env.js.map