DMleadgen
46d973904b
Next.js website for Rocky Mountain Vending company featuring: - Product catalog with Stripe integration - Service areas and parts pages - Admin dashboard with Clerk authentication - SEO optimized pages with JSON-LD structured data Co-authored-by: Cursor <cursoragent@cursor.com>
75 lines
2.6 KiB
Text
75 lines
2.6 KiB
Text
import { flush } from '../exports.js';
|
|
import { debug } from './debug-logger.js';
|
|
import { vercelWaitUntil } from './vercelWaitUntil.js';
|
|
import { GLOBAL_OBJ } from './worldwide.js';
|
|
|
|
async function flushWithTimeout(timeout) {
|
|
try {
|
|
debug.log('Flushing events...');
|
|
await flush(timeout);
|
|
debug.log('Done flushing events');
|
|
} catch (e) {
|
|
debug.log('Error while flushing events:\n', e);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Flushes the event queue with a timeout in serverless environments to ensure that events are sent to Sentry before the
|
|
* serverless function execution ends.
|
|
*
|
|
* The function is async, but in environments that support a `waitUntil` mechanism, it will run synchronously.
|
|
*
|
|
* This function is aware of the following serverless platforms:
|
|
* - Cloudflare: If a Cloudflare context is provided, it will use `ctx.waitUntil()` to flush events (keeps the `this` context of `ctx`).
|
|
* If a `cloudflareWaitUntil` function is provided, it will use that to flush events (looses the `this` context of `ctx`).
|
|
* - Vercel: It detects the Vercel environment and uses Vercel's `waitUntil` function.
|
|
* - Other Serverless (AWS Lambda, Google Cloud, etc.): It detects the environment via environment variables
|
|
* and uses a regular `await flush()`.
|
|
*
|
|
* @internal This function is supposed for internal Sentry SDK usage only.
|
|
* @hidden
|
|
*/
|
|
async function flushIfServerless(
|
|
params
|
|
|
|
= {},
|
|
) {
|
|
const { timeout = 2000 } = params;
|
|
|
|
if ('cloudflareWaitUntil' in params && typeof params?.cloudflareWaitUntil === 'function') {
|
|
params.cloudflareWaitUntil(flushWithTimeout(timeout));
|
|
return;
|
|
}
|
|
|
|
if ('cloudflareCtx' in params && typeof params.cloudflareCtx?.waitUntil === 'function') {
|
|
params.cloudflareCtx.waitUntil(flushWithTimeout(timeout));
|
|
return;
|
|
}
|
|
|
|
// @ts-expect-error This is not typed
|
|
if (GLOBAL_OBJ[Symbol.for('@vercel/request-context')]) {
|
|
// Vercel has a waitUntil equivalent that works without execution context
|
|
vercelWaitUntil(flushWithTimeout(timeout));
|
|
return;
|
|
}
|
|
|
|
if (typeof process === 'undefined') {
|
|
return;
|
|
}
|
|
|
|
const isServerless =
|
|
!!process.env.FUNCTIONS_WORKER_RUNTIME || // Azure Functions
|
|
!!process.env.LAMBDA_TASK_ROOT || // AWS Lambda
|
|
!!process.env.K_SERVICE || // Google Cloud Run
|
|
!!process.env.CF_PAGES || // Cloudflare Pages
|
|
!!process.env.VERCEL ||
|
|
!!process.env.NETLIFY;
|
|
|
|
if (isServerless) {
|
|
// Use regular flush for environments without a generic waitUntil mechanism
|
|
await flushWithTimeout(timeout);
|
|
}
|
|
}
|
|
|
|
export { flushIfServerless };
|
|
//# sourceMappingURL=flushIfServerless.js.map
|