Add Sentry spans to measure sequential queue command execution time

Track performance per command name in the sequential queue using Sentry
spans. PusherPing is excluded to avoid heartbeat noise in telemetry.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: elirangoshen

src/CONST/index.ts

@@ -1799,6 +1799,7 @@ const CONST = {
         SPAN_OPEN_SEARCH_ROUTER: 'ManualOpenSearchRouter',
         SPAN_OPEN_CREATE_EXPENSE: 'ManualOpenCreateExpense',
         SPAN_SEND_MESSAGE: 'ManualSendMessage',
+        SPAN_SEQUENTIAL_QUEUE_COMMAND: 'SequentialQueueCommand',
         SPAN_NOT_FOUND_PAGE: 'ManualNotFoundPage',
         SPAN_SKELETON: 'ManualSkeleton',
         SPAN_NAVIGATION_ROOT_READY: 'NavigationRootReady',
@@ -1835,6 +1836,7 @@ const CONST = {
         ATTRIBUTE_CANCELED: 'canceled',
         ATTRIBUTE_ROUTE_FROM: 'route_from',
         ATTRIBUTE_ROUTE_TO: 'route_to',
+        ATTRIBUTE_COMMAND_NAME: 'command_name',
         ATTRIBUTE_MIN_DURATION: 'min_duration',
         ATTRIBUTE_FINISHED_MANUALLY: 'finished_manually',
         ATTRIBUTE_SKELETON_PREFIX: 'skeleton.',

src/libs/Network/SequentialQueue.ts

@@ -1,6 +1,7 @@
 import type {OnyxKey, OnyxUpdate} from 'react-native-onyx';
 import Onyx from 'react-native-onyx';
 import {setIsOpenAppFailureModalOpen} from '@libs/actions/isOpenAppFailureModalOpen';
+import {endSpan, startSpan} from '@libs/telemetry/activeSpans';
 import {
     deleteRequestsByIndices as deletePersistedRequestsByIndices,
     endRequestAndRemoveFromQueue as endPersistedRequestAndRemoveFromQueue,
@@ -157,6 +158,19 @@ function process(): Promise<void> {
         persistWhenOngoing: requestToProcess.persistWhenOngoing ?? false,
     });
 
+    const commandSpanId = `${CONST.TELEMETRY.SPAN_SEQUENTIAL_QUEUE_COMMAND}_${requestToProcess.command}`;
+    // Skip tracking PusherPing — it fires every 30s as a heartbeat and would spam telemetry
+    const shouldTrackSpan = requestToProcess.command !== WRITE_COMMANDS.PUSHER_PING;
+    if (shouldTrackSpan) {
+        startSpan(commandSpanId, {
+            name: CONST.TELEMETRY.SPAN_SEQUENTIAL_QUEUE_COMMAND,
+            op: CONST.TELEMETRY.SPAN_SEQUENTIAL_QUEUE_COMMAND,
+            attributes: {
+                [CONST.TELEMETRY.ATTRIBUTE_COMMAND_NAME]: requestToProcess.command,
+            },
+        });
+    }
+
     // Set the current request to a promise awaiting its processing so that getCurrentRequest can be used to take some action after the current request has processed.
     currentRequestPromise = processWithMiddleware(requestToProcess, true)
         .then((response) => {
@@ -177,6 +191,7 @@ function process(): Promise<void> {
                 command: requestToProcess.command,
                 remainingRequests: getAllPersistedRequests().length,
             });
+            endSpan(commandSpanId);
             endPersistedRequestAndRemoveFromQueue(requestToProcess);
 
             if (requestToProcess.queueFlushedData) {
@@ -216,6 +231,7 @@ function process(): Promise<void> {
                     errorName: error.name,
                     errorMessage: error.message,
                 });
+                endSpan(commandSpanId);
                 endPersistedRequestAndRemoveFromQueue(requestToProcess);
                 sequentialQueueRequestThrottle.clear();
                 return process();
@@ -226,6 +242,7 @@ function process(): Promise<void> {
                     command: requestToProcess.command,
                 });
                 Onyx.update(requestToProcess.failureData ?? []);
+                endSpan(commandSpanId);
                 endPersistedRequestAndRemoveFromQueue(requestToProcess);
                 sequentialQueueRequestThrottle.clear();
                 return process();
@@ -236,6 +253,7 @@ function process(): Promise<void> {
                 errorMessage: error.message,
             });
 
+            endSpan(commandSpanId);
             rollbackOngoingPersistedRequest();
             return sequentialQueueRequestThrottle
                 .sleep(error, requestToProcess.command)