svelte-kit-connect-cloudflare-kv

svelte-kit-connect-cloudflare-kv provides Cloudflare Workers KV session storage for svelte-kit-sessions.

Installation

svelte-kit-connect-cloudflare-kv requires svelte-kit-sessions to installed.

$ npm install svelte-kit-connect-cloudflare-kv svelte-kit-sessions

$ yarn add svelte-kit-connect-cloudflare-kv svelte-kit-sessions

$ pnpm add svelte-kit-connect-cloudflare-kv svelte-kit-sessions

Usage

svelte-kit-connect-cloudflare-kv can be used as a custom store for svelte-kit-sessions as follows.

Note For more information about svelte-kit-sessions, see https://www.npmjs.com/package/svelte-kit-sessions.

Warning You need to check that event.platform does not come out undefined. When prerendering is done at build time, event.platform is undefined because it is before bindings in Cloudflare, resulting in the following error.

> Using @sveltejs/adapter-cloudflare
TypeError: Cannot read properties of undefined (reading 'env')

// src/hooks.server.ts
import type { Handle } from '@sveltejs/kit';
import type { SessionStoreData } from 'svelte-kit-sessions';
import { sveltekitSessionHandle } from 'svelte-kit-sessions';
import KvStore from 'svelte-kit-connect-cloudflare-kv';

declare module 'svelte-kit-sessions' {
    interface SessionData {
        userId: string;
        name: string;
    }
}

export const handle: Handle = async ({ event, resolve }) => {
    let sessionHandle: Handle | null = null;

    if (event.platform && event.platform.env) {
        // https://kit.svelte.dev/docs/adapter-cloudflare#bindings
        const store = new KvStore<SessionStoreData>({ client: event.platform.env.YOUR_KV_NAMESPACE });
        sessionHandle = sveltekitSessionHandle({
            secret: 'secret',
            store
        });
    }

    return sessionHandle ? sessionHandle({ event, resolve }) : resolve(event);
};

// src/hooks.server.ts
import type { Handle } from '@sveltejs/kit';
import { sveltekitSessionHandle } from 'svelte-kit-sessions';
import KvStore from 'svelte-kit-connect-cloudflare-kv';

let sessionHandle: Handle | null = null;

const handleForSession: Handle = async ({ event, resolve }) => {
    let sessionHandle: Handle | null = null;

    if (event.platform && event.platform.env) {
        // https://kit.svelte.dev/docs/adapter-cloudflare#bindings
        const store = new KvStore({ client: event.platform.env.YOUR_KV_NAMESPACE });
        sessionHandle = sveltekitSessionHandle({
            secret: 'secret',
            store
        });
    }

    return sessionHandle ? sessionHandle({ event, resolve }) : resolve(event);
};

const yourOwnHandle: Handle = async ({ event, resolve }) => {
    // your code here
    const result = await resolve(event);
    return result;
};

export const handle: Handle = sequence(handleForSession, yourOwnHandle);

API

import KvStore from 'svelte-kit-connect-cloudflare-kv';

new KvStore(options);

new KvStore(options)

Create a Cloudflare Workers KV store for svelte-kit-sessions.

Options

A summary of the options is as follows.

client

An KVNamespace.

prefix

Key prefix in Redis (default: sess:).

serializer

Provide a custom encoder/decoder to use when storing and retrieving session data from Redis (default: JSON.parse and JSON.stringify).

Note When setting up a custom serializer, the following interface must be satisfied.

interface Serializer {
    parse(s: string): SessionStoreData | Promise<SessionStoreData>;
    stringify(data: SessionStoreData): string;
}

ttl

When svelte-kit-sessions calls a method of the store (the set function), ttl(milliseconds) is passed to it. However, if the cookie options expires and maxAge are not set, the ttl passed will be Infinity.

If the ttl passed is Infinity, the ttl to be set can be set with this option. The unit is milliseconds.

Warning Cloudflare Workers KV's expirationTtl is 60 seconds minimum. The store is implemented in such a way that an error will occur if the value is less than that.

// `svelte-kit-connect-cloudflare-kv` implementation excerpts
const ONE_DAY_IN_SECONDS = 86400;
export default class KvStore implements Store {
    constructor(options: KvStoreOptions) {
        // The number of seconds for which the key should be visible before it expires. At least 60.
        // (https://developers.cloudflare.com/api/operations/workers-kv-namespace-write-multiple-key-value-pairs#request-body)
        if (options.ttl && options.ttl < 60 * 1000)
            throw new Error(
                'ttl must be at least 60 * 1000. please refer to https://developers.cloudflare.com/workers/runtime-apis/kv#expiration-ttlhttps://developers.cloudflare.com/api/operations/workers-kv-namespace-write-multiple-key-value-pairs#request-body.'
            );

        this.ttl = options.ttl || ONE_DAY_IN_SECONDS * 1000;
    }

    ttl: number;

    async set(id: string, storeData: SessionStoreData, ttl: number): Promise<void> {
        if (ttl < 60 * 1000)
            throw new Error(
                'ttl must be at least 60 * 1000. please refer to https://developers.cloudflare.com/workers/runtime-apis/kv#expiration-ttlhttps://developers.cloudflare.com/api/operations/workers-kv-namespace-write-multiple-key-value-pairs#request-body.'
            );

        // omission ...

        // Infinite time does not support, so it is implemented separately.
        if (ttl !== Infinity) {
            // https://developers.cloudflare.com/api/operations/workers-kv-namespace-write-multiple-key-value-pairs#request-body
            await this.client.put(key, serialized, { expirationTtl: ttl / 1000 });
            return;
        }
        await this.client.put(key, serialized, { expirationTtl: this.ttl / 1000 });
    }
}

License

MIT licensed