INTEGRITY Документация

Durable Objects

Объекты

Укажите Durable Objects, которые нужно добавить в окружение, следующим образом:

const mf = new Miniflare({
	modules: true,
	script: `
  export class Object1 {
    async fetch(request) {
      ...
    }
  }
  export default {
    fetch(request) {
      ...
    }
  }
  `,
	durableObjects: {
		// Note Object1 is exported from main (string) script
		OBJECT1: "Object1",
	},
});

Персистентность

По умолчанию данные Durable Object хранятся в памяти. Они сохраняются между перезагрузками, но не между разными Miniflare экземпляры. Чтобы включить сохранение в файловой системе, укажите параметр сохранения Durable Object:

const mf = new Miniflare({
	durableObjectsPersist: true, // Defaults to ./.mf/do
	durableObjectsPersist: "./data", // Custom path
});

Использование за пределами Workers

Для тестирования может быть полезно отправлять запросы к вашим Durable Objects извне worker. Это можно сделать с помощью getDurableObjectNamespace метод.

import { Miniflare } from "miniflare";

const mf = new Miniflare({
	modules: true,
	durableObjects: { TEST_OBJECT: "TestObject" },
	script: `
  export class TestObject {
    constructor(state) {
      this.storage = state.storage;
    }

    async fetch(request) {
      const url = new URL(request.url);
      if (url.pathname === "/put") await this.storage.put("key", 1);
      return new Response((await this.storage.get("key")).toString());
    }
  }

  export default {
    async fetch(request, env) {
      const stub = env.TEST_OBJECT.getByName("test");
      return stub.fetch(request);
    }
  }
  `,
});

const ns = await mf.getDurableObjectNamespace("TEST_OBJECT");
const stub = ns.getByName("test");
const doRes = await stub.fetch("http://localhost:8787/put");
console.log(await doRes.text()); // "1"

const res = await mf.dispatchFetch("http://localhost:8787/");
console.log(await res.text()); // "1"

Использование класса, экспортированного из другого скрипта

Miniflare поддерживает script_name параметр для доступа к Durable Objects, экспортированным другими скриптами. Для этого нужно подключить другой worker, как описано в 🔌 Несколько Workers.