diff --git a/packages/sveltekit/src/client/load.ts b/packages/sveltekit/src/client/load.ts index bbc184b6d3a0..e56d33b2e23c 100644 --- a/packages/sveltekit/src/client/load.ts +++ b/packages/sveltekit/src/client/load.ts @@ -17,6 +17,7 @@ import type { LoadEvent } from '@sveltejs/kit'; import type { SentryWrappedFlag } from '../common/utils'; import { isRedirect } from '../common/utils'; +import { isRequestCached } from './vendor/lookUpCache'; type PatchedLoadEvent = LoadEvent & Partial; @@ -153,6 +154,11 @@ function instrumentSvelteKitFetch(originalFetch: SvelteKitFetch): SvelteKitFetch return new Proxy(originalFetch, { apply: (wrappingTarget, thisArg, args: Parameters) => { const [input, init] = args; + + if (isRequestCached(input, init)) { + return wrappingTarget.apply(thisArg, args); + } + const { url: rawUrl, method } = parseFetchArgs(args); // TODO: extract this to a util function (and use it in breadcrumbs integration as well) @@ -196,6 +202,7 @@ function instrumentSvelteKitFetch(originalFetch: SvelteKitFetch): SvelteKitFetch patchedInit.headers = headers; } + let fetchPromise: Promise; const patchedFetchArgs = [input, patchedInit]; diff --git a/packages/sveltekit/src/client/vendor/buildSelector.ts b/packages/sveltekit/src/client/vendor/buildSelector.ts new file mode 100644 index 000000000000..9ff0ddebe7c7 --- /dev/null +++ b/packages/sveltekit/src/client/vendor/buildSelector.ts @@ -0,0 +1,57 @@ +/* eslint-disable @sentry-internal/sdk/no-optional-chaining */ + +// Vendored from https://github.com/sveltejs/kit/blob/1c1ddd5e34fce28e6f89299d6c59162bed087589/packages/kit/src/runtime/client/fetcher.js +// with types only changes. + +// The MIT License (MIT) + +// Copyright (c) 2020 [these people](https://github.com/sveltejs/kit/graphs/contributors) + +// Permission is hereby granted, free of charge, to any person obtaining a copy +// of this software and associated documentation files(the "Software"), to deal +// in the Software without restriction, including without limitation the rights +// to use, copy, modify, merge, publish, distribute, sublicense, and / or sell +// copies of the Software, and to permit persons to whom the Software is +// furnished to do so, subject to the following conditions: + +// The above copyright notice and this permission notice shall be included in +// all copies or substantial portions of the Software. + +// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.IN NO EVENT SHALL THE +// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN +// THE SOFTWARE. + +import { hash } from './hash'; + +/** + * Build the cache key for a given request + * @param {URL | RequestInfo} resource + * @param {RequestInit} [opts] + */ +export function build_selector(resource: URL | RequestInfo, opts: RequestInit | undefined): string { + const url = JSON.stringify(resource instanceof Request ? resource.url : resource); + + let selector = `script[data-sveltekit-fetched][data-url=${url}]`; + + if (opts?.headers || opts?.body) { + /** @type {import('types').StrictBody[]} */ + const values = []; + + if (opts.headers) { + // @ts-ignore - TS complains but this is a 1:1 copy of the original code and apparently it works + values.push([...new Headers(opts.headers)].join(',')); + } + + if (opts.body && (typeof opts.body === 'string' || ArrayBuffer.isView(opts.body))) { + values.push(opts.body); + } + + selector += `[data-hash="${hash(...values)}"]`; + } + + return selector; +} diff --git a/packages/sveltekit/src/client/vendor/hash.ts b/packages/sveltekit/src/client/vendor/hash.ts new file mode 100644 index 000000000000..1723dac703a6 --- /dev/null +++ b/packages/sveltekit/src/client/vendor/hash.ts @@ -0,0 +1,51 @@ +/* eslint-disable no-bitwise */ + +// Vendored from https://github.com/sveltejs/kit/blob/1c1ddd5e34fce28e6f89299d6c59162bed087589/packages/kit/src/runtime/hash.js +// with types only changes. + +// The MIT License (MIT) + +// Copyright (c) 2020 [these people](https://github.com/sveltejs/kit/graphs/contributors) + +// Permission is hereby granted, free of charge, to any person obtaining a copy +// of this software and associated documentation files(the "Software"), to deal +// in the Software without restriction, including without limitation the rights +// to use, copy, modify, merge, publish, distribute, sublicense, and / or sell +// copies of the Software, and to permit persons to whom the Software is +// furnished to do so, subject to the following conditions: + +// The above copyright notice and this permission notice shall be included in +// all copies or substantial portions of the Software. + +// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.IN NO EVENT SHALL THE +// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN +// THE SOFTWARE. + +import type { StrictBody } from '@sveltejs/kit/types/internal'; + +/** + * Hash using djb2 + * @param {import('types').StrictBody[]} values + */ +export function hash(...values: StrictBody[]): string { + let hash = 5381; + + for (const value of values) { + if (typeof value === 'string') { + let i = value.length; + while (i) hash = (hash * 33) ^ value.charCodeAt(--i); + } else if (ArrayBuffer.isView(value)) { + const buffer = new Uint8Array(value.buffer, value.byteOffset, value.byteLength); + let i = buffer.length; + while (i) hash = (hash * 33) ^ buffer[--i]; + } else { + throw new TypeError('value must be a string or TypedArray'); + } + } + + return (hash >>> 0).toString(36); +} diff --git a/packages/sveltekit/src/client/vendor/lookUpCache.ts b/packages/sveltekit/src/client/vendor/lookUpCache.ts new file mode 100644 index 000000000000..afcaf676b40d --- /dev/null +++ b/packages/sveltekit/src/client/vendor/lookUpCache.ts @@ -0,0 +1,79 @@ +/* eslint-disable no-bitwise */ + +// Parts of this code are taken from https://github.com/sveltejs/kit/blob/1c1ddd5e34fce28e6f89299d6c59162bed087589/packages/kit/src/runtime/client/fetcher.js +// Attribution given directly in the function code below + +// The MIT License (MIT) + +// Copyright (c) 2020 [these people](https://github.com/sveltejs/kit/graphs/contributors) + +// Permission is hereby granted, free of charge, to any person obtaining a copy +// of this software and associated documentation files(the "Software"), to deal +// in the Software without restriction, including without limitation the rights +// to use, copy, modify, merge, publish, distribute, sublicense, and / or sell +// copies of the Software, and to permit persons to whom the Software is +// furnished to do so, subject to the following conditions: + +// The above copyright notice and this permission notice shall be included in +// all copies or substantial portions of the Software. + +// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.IN NO EVENT SHALL THE +// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN +// THE SOFTWARE. + +import { WINDOW } from '@sentry/svelte'; +import { getDomElement } from '@sentry/utils'; + +import { build_selector } from './buildSelector'; + +/** + * Checks if a request is cached by looking for a script tag with the same selector as the constructed selector of the request. + * + * This function is a combination of the cache lookups in sveltekit's internal client-side fetch functions + * - initial_fetch (used during hydration) https://github.com/sveltejs/kit/blob/1c1ddd5e34fce28e6f89299d6c59162bed087589/packages/kit/src/runtime/client/fetcher.js#L76 + * - subsequent_fetch (used afterwards) https://github.com/sveltejs/kit/blob/1c1ddd5e34fce28e6f89299d6c59162bed087589/packages/kit/src/runtime/client/fetcher.js#L98 + * + * Parts of this function's logic is taken from SvelteKit source code. + * These lines are annotated with attribution in comments above them. + * + * @param input first fetch param + * @param init second fetch param + * @returns true if a cache hit was encountered, false otherwise + */ +export function isRequestCached(input: URL | RequestInfo, init: RequestInit | undefined): boolean { + // build_selector call copied from https://github.com/sveltejs/kit/blob/1c1ddd5e34fce28e6f89299d6c59162bed087589/packages/kit/src/runtime/client/fetcher.js#L77 + const selector = build_selector(input, init); + + const script = getDomElement(selector); + + if (!script) { + return false; + } + + // If the script has a data-ttl attribute, we check if we're still in the TTL window: + try { + // ttl retrieval taken from https://github.com/sveltejs/kit/blob/1c1ddd5e34fce28e6f89299d6c59162bed087589/packages/kit/src/runtime/client/fetcher.js#L83-L84 + const ttl = Number(script.getAttribute('data-ttl')) * 1000; + + if (isNaN(ttl)) { + return false; + } + + if (ttl) { + // cache hit determination taken from: https://github.com/sveltejs/kit/blob/1c1ddd5e34fce28e6f89299d6c59162bed087589/packages/kit/src/runtime/client/fetcher.js#L105-L106 + return ( + WINDOW.performance.now() < ttl && + ['default', 'force-cache', 'only-if-cached', undefined].includes(init && init.cache) + ); + } + } catch { + return false; + } + + // Otherwise, we check if the script has a content and return true in that case + return !!script.textContent; +} diff --git a/packages/sveltekit/test/client/load.test.ts b/packages/sveltekit/test/client/load.test.ts index 65b4cc1da3b1..0b74b78cefc6 100644 --- a/packages/sveltekit/test/client/load.test.ts +++ b/packages/sveltekit/test/client/load.test.ts @@ -1,5 +1,6 @@ import { addTracingExtensions, Scope } from '@sentry/svelte'; import { baggageHeaderToDynamicSamplingContext } from '@sentry/utils'; +import * as utils from '@sentry/utils'; import type { Load } from '@sveltejs/kit'; import { redirect } from '@sveltejs/kit'; import { vi } from 'vitest'; @@ -27,6 +28,12 @@ vi.mock('@sentry/svelte', async () => { }; }); +vi.spyOn(utils, 'getDomElement').mockImplementation(() => { + return { + textContent: 'test', + }; +}); + const mockTrace = vi.fn(); const mockedBrowserTracing = { diff --git a/packages/sveltekit/test/client/vendor/lookUpCache.test.ts b/packages/sveltekit/test/client/vendor/lookUpCache.test.ts new file mode 100644 index 000000000000..76c44d5cc21b --- /dev/null +++ b/packages/sveltekit/test/client/vendor/lookUpCache.test.ts @@ -0,0 +1,68 @@ +import * as utils from '@sentry/utils'; +import { vi } from 'vitest'; + +import { isRequestCached } from '../../../src/client/vendor/lookUpCache'; + +let scriptElement: { + textContent: string; + getAttribute: (name: string) => string | null; +} | null; + +vi.spyOn(utils, 'getDomElement').mockImplementation(() => { + return scriptElement; +}); + +describe('isRequestCached', () => { + it('should return true if a script tag with the same selector as the constructed request selector is found', () => { + scriptElement = { + textContent: 'test', + getAttribute: () => null, + }; + + expect(isRequestCached('/api/todos/1', undefined)).toBe(true); + }); + + it('should return false if a script with the same selector as the constructed request selector is not found', () => { + scriptElement = null; + + expect(isRequestCached('/api/todos/1', undefined)).toBe(false); + }); + + it('should return true if a script with the same selector as the constructed request selector is found and its TTL is valid', () => { + scriptElement = { + textContent: 'test', + getAttribute: () => (performance.now() / 1000 + 1).toString(), + }; + + expect(isRequestCached('/api/todos/1', undefined)).toBe(true); + }); + + it('should return false if a script with the same selector as the constructed request selector is found and its TTL is expired', () => { + scriptElement = { + textContent: 'test', + getAttribute: () => (performance.now() / 1000 - 1).toString(), + }; + + expect(isRequestCached('/api/todos/1', undefined)).toBe(false); + }); + + it("should return false if the TTL is set but can't be parsed", () => { + scriptElement = { + textContent: 'test', + getAttribute: () => 'NotANumber', + }; + + expect(isRequestCached('/api/todos/1', undefined)).toBe(false); + }); + + it('should return false if an error was thrown turing TTL evaluation', () => { + scriptElement = { + textContent: 'test', + getAttribute: () => { + throw new Error('test'); + }, + }; + + expect(isRequestCached('/api/todos/1', undefined)).toBe(false); + }); +}); diff --git a/packages/sveltekit/test/vitest.setup.ts b/packages/sveltekit/test/vitest.setup.ts index 48c9b0e33528..cafd02a8ab51 100644 --- a/packages/sveltekit/test/vitest.setup.ts +++ b/packages/sveltekit/test/vitest.setup.ts @@ -11,3 +11,9 @@ export function setup() { }; }); } + +if (!globalThis.fetch) { + // @ts-ignore dfsf + globalThis.Request = class Request {}; +} +console.log(globalThis.fetch, globalThis.Response, globalThis.Request);