Skip to content

Commit

Permalink
Lint fix
Browse files Browse the repository at this point in the history
  • Loading branch information
McSick committed Mar 5, 2024
1 parent 16908aa commit f8ced07
Show file tree
Hide file tree
Showing 2 changed files with 36 additions and 16 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,6 @@ const instrumentation = registerInstrumentationTesting(
new AmqplibInstrumentation()
);


import * as amqpCallback from 'amqplib/callback_api';
import {
MessagingDestinationKindValues,
Expand Down Expand Up @@ -538,8 +537,12 @@ describe('amqplib instrumentation callback model', () => {

// link back to publish span
expect(consumeSpan.links.length).toBe(1);
expect(consumeSpan.links[0].context.traceId).toEqual(publishSpan.spanContext().traceId);
expect(consumeSpan.links[0].context.spanId).toEqual(publishSpan.spanContext().spanId);
expect(consumeSpan.links[0].context.traceId).toEqual(
publishSpan.spanContext().traceId
);
expect(consumeSpan.links[0].context.spanId).toEqual(
publishSpan.spanContext().spanId
);

done();
});
Expand Down Expand Up @@ -674,13 +677,16 @@ describe('amqplib instrumentation callback model', () => {

// link back to publish span
expect(consumeSpan.links.length).toBe(1);
expect(consumeSpan.links[0].context.traceId).toEqual(publishSpan.spanContext().traceId);
expect(consumeSpan.links[0].context.spanId).toEqual(publishSpan.spanContext().spanId);
expect(consumeSpan.links[0].context.traceId).toEqual(
publishSpan.spanContext().traceId
);
expect(consumeSpan.links[0].context.spanId).toEqual(
publishSpan.spanContext().spanId
);

done();
});
});
});

});
});
34 changes: 24 additions & 10 deletions plugins/node/instrumentation-amqplib/test/amqplib-promise.test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -1370,8 +1370,12 @@ describe('amqplib instrumentation promise model', () => {

// link back to publish span
expect(consumeSpan.links.length).toBe(1);
expect(consumeSpan.links[0].context.traceId).toEqual(publishSpan.spanContext().traceId);
expect(consumeSpan.links[0].context.spanId).toEqual(publishSpan.spanContext().spanId);
expect(consumeSpan.links[0].context.traceId).toEqual(
publishSpan.spanContext().traceId
);
expect(consumeSpan.links[0].context.spanId).toEqual(
publishSpan.spanContext().spanId
);

expectConsumeEndSpyStatus([EndOperation.AutoAck]);
});
Expand Down Expand Up @@ -1449,8 +1453,12 @@ describe('amqplib instrumentation promise model', () => {

// link back to publish span
expect(consumeSpan.links.length).toBe(1);
expect(consumeSpan.links[0].context.traceId).toEqual(publishSpan.spanContext().traceId);
expect(consumeSpan.links[0].context.spanId).toEqual(publishSpan.spanContext().spanId);
expect(consumeSpan.links[0].context.traceId).toEqual(
publishSpan.spanContext().traceId
);
expect(consumeSpan.links[0].context.spanId).toEqual(
publishSpan.spanContext().spanId
);
});
});
});
Expand All @@ -1464,7 +1472,6 @@ describe('amqplib instrumentation promise model', () => {
instrumentation.setConfig({
consumeEndHook: endHookSpy,
useLinksForConsume: true,

});

confirmChannel = await conn.createConfirmChannel();
Expand Down Expand Up @@ -1569,8 +1576,12 @@ describe('amqplib instrumentation promise model', () => {

// link back to publish span
expect(consumeSpan.links.length).toBe(1);
expect(consumeSpan.links[0].context.traceId).toEqual(publishSpan.spanContext().traceId);
expect(consumeSpan.links[0].context.spanId).toEqual(publishSpan.spanContext().spanId);
expect(consumeSpan.links[0].context.traceId).toEqual(
publishSpan.spanContext().traceId
);
expect(consumeSpan.links[0].context.spanId).toEqual(
publishSpan.spanContext().spanId
);

expectConsumeEndSpyStatus([EndOperation.AutoAck]);
});
Expand Down Expand Up @@ -1655,10 +1666,13 @@ describe('amqplib instrumentation promise model', () => {

// link back to publish span
expect(consumeSpan.links.length).toBe(1);
expect(consumeSpan.links[0].context.traceId).toEqual(publishSpan.spanContext().traceId);
expect(consumeSpan.links[0].context.spanId).toEqual(publishSpan.spanContext().spanId);
expect(consumeSpan.links[0].context.traceId).toEqual(
publishSpan.spanContext().traceId
);
expect(consumeSpan.links[0].context.spanId).toEqual(
publishSpan.spanContext().spanId
);
});
});

});
});

0 comments on commit f8ced07

Please sign in to comment.