Function withQueueSpan

apps/api/src/lib/tracing/withQueueSpan.ts:26–68

(
  queueName: string,
  /*
   * Only the fields the span attributes read — keeps full BullMQ jobs
   * assignable while letting tests pass a structural stub without casts.
   */
  job: Pick<Job, "id" | "name" | "attemptsMade">,
  handler: () => Promise<T>
)

 * sees the failure exactly as it did before.
 */
export const withQueueSpan = async <T>(
  queueName: string,
  /*
   * Only the fields the span attributes read — keeps full BullMQ jobs
   * assignable while letting tests pass a structural stub without casts.
   */
  job: Pick<Job, "id" | "name" | "attemptsMade">,
  handler: () => Promise<T>
): Promise<T> =>
  tracer.startActiveSpan(
    `queue.${queueName}.process`,
    {
      attributes: {
        "messaging.system": "bullmq",
        "messaging.destination.name": queueName,
        "messaging.message.id": job.id ?? "",
        "messaging.bullmq.job.name": job.name,
        "messaging.bullmq.job.attempt": job.attemptsMade + 1,
      },
    },
    async (span) => {
      try {
        const result = await handler();

        span.setStatus({ code: SpanStatusCode.OK });

        return result;
      } catch (error) {
        span.setStatus({
          code: SpanStatusCode.ERROR,
          message: getErrorMessage(error),
        });

        if (error instanceof Error) {
          span.recordException(error);
        }

        throw error;
      } finally {
        span.end();
      }
    }
  );