Skip to content

Instantly share code, notes, and snippets.

@mattlockyer

mattlockyer/do.ts

Last active December 12, 2021 05:12
Show Gist options
  • Save mattlockyer/b55d3faf466f04d5c38a6678bceb69ad to your computer and use it in GitHub Desktop.
Save mattlockyer/b55d3faf466f04d5c38a6678bceb69ad to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. mattlockyer revised this gist Dec 12, 2021. No changes.
  2. mattlockyer created this gist Dec 12, 2021.
    58 changes: 58 additions & 0 deletions do.ts
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,58 @@
    const META_KEY: string = '_M'

    export class Object {
    state: DurableObjectState
    meta: any
    data: any
    timeouts: any

    constructor(state: DurableObjectState, env: Env) {
    this.state = state;
    this.timeouts = {}
    this.data = {}
    this.state.blockConcurrencyWhile(async () => {
    this.meta = await this.state.storage?.get<any>(META_KEY);
    })
    }

    // Handle HTTP requests from clients.
    async fetch(request: Request): Promise<Response> {
    const url: URL = new URL(request.url);
    const key: string | null = url.searchParams.get('key')
    if (!key) return new Response("Not found", { status: 404 });

    let value = this.data[key]
    if (!value) {
    value = this.data[key] = await this.state.storage?.get<any>(key) || 0;
    }

    await fetch('https://example.com')

    switch (url.pathname) {
    case "/increment":
    value = ++this.data[key];
    await this.state.storage?.put(key, this.data[key]);
    break;
    case "/decrement":
    value = --this.data[key];
    await this.state.storage?.put(key, this.data[key]);
    break;
    case "/":
    // Just serve the current value. No storage calls needed!
    break;
    default:
    return new Response("Not found", { status: 404 });
    }

    if (this.timeouts[key]) {
    clearTimeout(this.timeouts[key])
    }
    this.timeouts[key] = setTimeout(() => {
    delete this.data[key]
    }, 500)

    return new Response(value.toString());
    }
    }

    interface Env { }