Function apply

packages/nuxt/src/runtime/utils/instrumentStorage.ts:149–179

(target, thisArg, args)

): (...args: unknown[]) => unknown {
  return new Proxy(original, {
    async apply(target, thisArg, args) {
      const options = createSpanStartOptions(methodName, driver, mountBase, args);

      debug.log(`[storage] Running method: "${methodName}" on driver: "${driver.name ?? 'unknown'}"`);

      return startSpan(options, async span => {
        try {
          const result = await target.apply(thisArg, args);
          span.setStatus({ code: SPAN_STATUS_OK });

          if (CACHE_HIT_METHODS.has(methodName)) {
            span.setAttribute(SEMANTIC_ATTRIBUTE_CACHE_HIT, isCacheHit(args[0], result));
          }

          return result;
        } catch (error) {
          span.setStatus({ code: SPAN_STATUS_ERROR, message: 'internal_error' });
          captureException(error, {
            mechanism: {
              handled: false,
              type: options.attributes?.[SEMANTIC_ATTRIBUTE_SENTRY_ORIGIN],
            },
          });

          // Re-throw the error to be handled by the caller
          throw error;
        } finally {
          await flushIfServerless();
        }
      });
    },
  });
}