28 replies

Tying resources like DB connection to actor lifecycle

❓type: question

How might you recommend tying a resource like a DB connection to the actor lifecycle? The below is what I was thinking, but there are a couple of issues with the approach:

1. db conn not available in createState. not critical, but would be nice to be able to lookup and initialize some state based on the input or actor key
2. not sure how to cleanup the connection. in cloudflare's example they are tying the connection to each request's lifecycle, and using

ctx.waitUntil

ctx.waitUntil

(https://developers.cloudflare.com/workers/databases/third-party-integrations/planetscale/#3-use-hyperdrive-from-your-worker), but that doesn't quite map 1-1 w actor lifecycle. There isn't a way to hook into actor destruction/cleanup is there? Might not be possible - haven't looked deep but I'm not sure if there is even a way with raw CF durable objects

import { env } from 'cloudflare:workers';

export const myActor = actor({
  onCreate: (c, opts) => {
    console.log('onCreate');
  },

  createState: (c, opts) => {
    // Won't have access to DB here as far as I can tell, right?
    // throws error if try to access vars
    const db = c.vars.db;

    return {};
  },

  createVars: async (c) => {
    const db = createConnection({ uri: env.HYPERDRIVE.connectionString, applicationName: `agent-${this.key.join(':')}` });

    return { db };
  },

  actions: {
    myAction: async (c) => {
      const foo = await c.vars.db.query('xyz');
      // ...etc
    },
  },
});

import { env } from 'cloudflare:workers';

export const myActor = actor({
  onCreate: (c, opts) => {
    console.log('onCreate');
  },

  createState: (c, opts) => {
    // Won't have access to DB here as far as I can tell, right?
    // throws error if try to access vars
    const db = c.vars.db;

    return {};
  },

  createVars: async (c) => {
    const db = createConnection({ uri: env.HYPERDRIVE.connectionString, applicationName: `agent-${this.key.join(':')}` });

    return { db };
  },

  actions: {
    myAction: async (c) => {
      const foo = await c.vars.db.query('xyz');
      // ...etc
    },
  },
});

Cloudflare Docs

PlanetScale

PlanetScale is a MySQL-compatible platform that makes databases infinitely scalable, easier and safer to manage.

RDN

Rivet Developer Network•7mo ago•

28 replies

marbemac

Tying resources like DB connection to actor lifecycle

❓type: question

ctx.waitUntil

ctx.waitUntil

import { env } from 'cloudflare:workers';

export const myActor = actor({
  onCreate: (c, opts) => {
    console.log('onCreate');
  },

  createState: (c, opts) => {
    // Won't have access to DB here as far as I can tell, right?
    // throws error if try to access vars
    const db = c.vars.db;

    return {};
  },

  createVars: async (c) => {
    const db = createConnection({ uri: env.HYPERDRIVE.connectionString, applicationName: `agent-${this.key.join(':')}` });

    return { db };
  },

  actions: {
    myAction: async (c) => {
      const foo = await c.vars.db.query('xyz');
      // ...etc
    },
  },
});

import { env } from 'cloudflare:workers';

export const myActor = actor({
  onCreate: (c, opts) => {
    console.log('onCreate');
  },

  createState: (c, opts) => {
    // Won't have access to DB here as far as I can tell, right?
    // throws error if try to access vars
    const db = c.vars.db;

    return {};
  },

  createVars: async (c) => {
    const db = createConnection({ uri: env.HYPERDRIVE.connectionString, applicationName: `agent-${this.key.join(':')}` });

    return { db };
  },

  actions: {
    myAction: async (c) => {
      const foo = await c.vars.db.query('xyz');
      // ...etc
    },
  },
});

Cloudflare Docs

PlanetScale

PlanetScale is a MySQL-compatible platform that makes databases infinitely scalable, easier and safer to manage.

Tying resources like DB connection to actor lifecycle

Tying resources like DB connection to actor lifecycle

Similar Threads

Similar Threads

Similar Threads