chore(instrumentation-amqp): bump amqplib typings

Author: lucas-gregoire

package-lock.json

@@ -58,7 +58,7 @@
   "devDependencies": {
     "@opentelemetry/api": "^1.3.0",
     "@opentelemetry/contrib-test-utils": "^0.49.0",
-    "@types/amqplib": "^0.5.17",
+    "@types/amqplib": "^0.10.7",
     "@types/lodash": "4.14.199",
     "@types/mocha": "10.0.10",
     "@types/node": "18.18.14",

packages/instrumentation-amqplib/package.json

@@ -66,6 +66,7 @@ import {
   getConnectionAttributesFromServer,
   getConnectionAttributesFromUrl,
   InstrumentationConsumeChannel,
+  InstrumentationConsumeMessage,
   InstrumentationMessage,
   InstrumentationPublishChannel,
   isConfirmChannelTracing,
@@ -256,14 +257,7 @@ export class AmqplibInstrumentation extends InstrumentationBase<AmqplibInstrumen
         function (this: unknown, err, conn: Connection) {
           if (err == null) {
             const urlAttributes = getConnectionAttributesFromUrl(url);
-            // the type of conn in @types/amqplib is amqp.Connection, but in practice the library send the
-            // `serverProperties` on the `conn` and not in a property `connection`.
-            // I don't have capacity to debug it currently but it should probably be fixed in @types or
-            // in the package itself
-            // currently setting as any to calm typescript
-            const serverAttributes = getConnectionAttributesFromServer(
-              conn as any
-            );
+            const serverAttributes = getConnectionAttributesFromServer(conn);
             (conn as any)[CONNECTION_ATTRIBUTES] = {
               ...urlAttributes,
               ...serverAttributes,
@@ -402,7 +396,7 @@ export class AmqplibInstrumentation extends InstrumentationBase<AmqplibInstrumen
 
       const patchedOnMessage = function (
         this: unknown,
-        msg: InstrumentationMessage | null
+        msg: InstrumentationConsumeMessage | null
       ) {
         // msg is expected to be null for signaling consumer cancel notification
         // https://www.rabbitmq.com/consumer-cancel.html
@@ -724,7 +718,7 @@ export class AmqplibInstrumentation extends InstrumentationBase<AmqplibInstrumen
 
   private callConsumeEndHook(
     span: Span,
-    msg: ConsumeMessage,
+    msg: InstrumentationMessage,
     rejected: boolean | null,
     endOperation: EndOperation
   ) {

packages/instrumentation-amqplib/src/amqplib.ts

@@ -60,6 +60,9 @@ export type InstrumentationConsumeChannel = amqp.Channel & {
 export type InstrumentationMessage = amqp.Message & {
   [MESSAGE_STORED_SPAN]?: Span;
 };
+export type InstrumentationConsumeMessage = amqp.ConsumeMessage & {
+  [MESSAGE_STORED_SPAN]?: Span;
+};
 
 const IS_CONFIRM_CHANNEL_CONTEXT_KEY: symbol = createContextKey(
   'opentelemetry.amqplib.channel.is-confirm-channel'
@@ -117,7 +120,7 @@ const extractConnectionAttributeOrLog = (
 };
 
 export const getConnectionAttributesFromServer = (
-  conn: amqp.Connection['connection']
+  conn: amqp.Connection
 ): Attributes => {
   const product = conn.serverProperties.product?.toLowerCase?.();
   if (product) {

packages/instrumentation-amqplib/src/utils.ts

@@ -68,7 +68,7 @@ const CHANNEL_CLOSED_IN_TEST = Symbol(
 );
 
 describe('amqplib instrumentation promise model', () => {
-  let conn: amqp.Connection;
+  let conn: amqp.ChannelModel;
   before(async function () {
     if (!shouldTest) {
       this.skip();

packages/instrumentation-amqplib/test/amqplib-promise.test.ts

@@ -33,7 +33,7 @@ import { rabbitMqUrl } from './config';
 
 describe('utils', () => {
   describe('getConnectionAttributesFromServer', () => {
-    let conn: amqp.Connection;
+    let conn: amqp.ChannelModel;
     before(async function () {
       if (!shouldTest) {
         this.skip();