Object.defineProperty(exports, Symbol.toStringTag, { value: 'Module' });

const subscribeInjection = require('./subscribe-injection.js');

const postgresJsInstrumentationConfig = (dir) => [
  // `Query.prototype.handle` (`class Query extends Promise`) is the single
  // funnel every query passes through (`then`/`catch`/`finally`/`.execute()`/
  // `.forEach()`/cursor all call it), guarded by `this.executed`. `Async`
  // because `handle` is `async`.
  {
    channelName: "handle",
    module: { name: "postgres", versionRange: ">=3.0.0 <4", filePath: `${dir}/query.js` },
    functionQuery: { className: "Query", methodName: "handle", kind: "Async" }
  },
  // `function Connection(options, ...)` (default export of `connection.js`)
  // returns the connection object; used to build the endpoint registry that
  // resolves `server.address`/`server.port`/`db.namespace`.
  {
    channelName: "connection",
    module: { name: "postgres", versionRange: ">=3.0.0 <4", filePath: `${dir}/connection.js` },
    functionQuery: { functionName: "Connection", kind: "Sync" }
  },
  // The nested `function execute(q)` inside `Connection`; the per-connection
  // hook that attaches connection attributes to the query's span.
  {
    channelName: "execute",
    module: { name: "postgres", versionRange: ">=3.0.0 <4", filePath: `${dir}/connection.js` },
    functionQuery: { functionName: "execute", kind: "Sync" }
  },
  // The connection object's `connect(query)` method. Matched by `methodName`
  // (an object-literal method): `functionName` would hit the unrelated
  // socket-level `async function connect()` in the same file. `self` is the
  // connection object and `arguments[0]` the query, so the first query that
  // opens a connection (dispatched via a bare `execute` with no `self`) still
  // gets connection attributes in multi-endpoint apps.
  {
    channelName: "connect",
    module: { name: "postgres", versionRange: ">=3.0.0 <4", filePath: `${dir}/connection.js` },
    functionQuery: { methodName: "connect", kind: "Sync" }
  }
];
const postgresJsConfig = ["src", "cjs/src"].flatMap(postgresJsInstrumentationConfig);
const postgresJsChannels = {
  POSTGRESJS_HANDLE: "orchestrion:postgres:handle",
  POSTGRESJS_CONNECTION: "orchestrion:postgres:connection",
  POSTGRESJS_EXECUTE: "orchestrion:postgres:execute",
  POSTGRESJS_CONNECT: "orchestrion:postgres:connect"
};
const postgresJsSubscribeInjection = subscribeInjection.toSubscribeInjections(postgresJsConfig);

exports.postgresJsChannels = postgresJsChannels;
exports.postgresJsConfig = postgresJsConfig;
exports.postgresJsSubscribeInjection = postgresJsSubscribeInjection;
//# sourceMappingURL=postgres.js.map