Add s3 actor storage (#6)

* Add s3 actor storage

* fix issues with hmac key

* update bucket name env var

.github/workflows/publish.yaml

@@ -13,8 +13,8 @@ jobs:
  runs-on: ubuntu-latest
 
  permissions:
-  contents: read
-  id-token: write
+ contents: read
+ id-token: write
 
  steps:
  - uses: actions/checkout@v4

.github/workflows/releaser.yaml

@@ -9,9 +9,9 @@ on:
  - main
 
 permissions:
- contents: write  # Necessary for accessing and modifying repository content
- pull-requests: write  # Necessary for interacting with pull requests
- actions: write  # Necessary for triggering other workflows
+ contents: write # Necessary for accessing and modifying repository content
+ pull-requests: write # Necessary for interacting with pull requests
+ actions: write # Necessary for triggering other workflows
 
 jobs:
  tag-discussion:
@@ -21,8 +21,8 @@ jobs:
  - name: Checkout Code
  uses: actions/checkout@v3
  with:
- ref: ${{ github.event.pull_request.base.ref }}  # Checkout the base branch (target repository)
- repository: ${{ github.event.pull_request.base.repo.full_name }}  # Checkout from the target repo
+ ref: ${{ github.event.pull_request.base.ref }} # Checkout the base branch (target repository)
+ repository: ${{ github.event.pull_request.base.repo.full_name }} # Checkout from the target repo
 
  - name: Calculate new versions
  id: calculate_versions
@@ -165,15 +165,15 @@ jobs:
  git push origin ${{ steps.determine_version.outputs.new_version }}
  - name: Trigger Release Workflow
  run: |
-  curl -X POST \
-  -H "Authorization: token ${{ secrets.GITHUB_TOKEN }}" \
-  -H "Accept: application/vnd.github.everest-preview+json" \
-  https://api.github.com/repos/${{ github.repository }}/actions/workflows/release.yaml/dispatches \
-  -d '{"ref":"main", "inputs":{"tag_name":"${{ steps.determine_version.outputs.new_version }}"}}'
+ curl -X POST \
+ -H "Authorization: token ${{ secrets.GITHUB_TOKEN }}" \
+ -H "Accept: application/vnd.github.everest-preview+json" \
+ https://api.github.com/repos/${{ github.repository }}/actions/workflows/release.yaml/dispatches \
+ -d '{"ref":"main", "inputs":{"tag_name":"${{ steps.determine_version.outputs.new_version }}"}}'
  - name: Trigger Publish Workflow
  run: |
-  curl -X POST \
-  -H "Authorization: token ${{ secrets.GITHUB_TOKEN }}" \
-  -H "Accept: application/vnd.github.everest-preview+json" \
-  https://api.github.com/repos/${{ github.repository }}/actions/workflows/publish.yaml/dispatches \
-  -d '{"ref":"main", "inputs":{"tag_name":"${{ steps.determine_version.outputs.new_version }}"}}'
+ curl -X POST \
+ -H "Authorization: token ${{ secrets.GITHUB_TOKEN }}" \
+ -H "Accept: application/vnd.github.everest-preview+json" \
+ https://api.github.com/repos/${{ github.repository }}/actions/workflows/publish.yaml/dispatches \
+ -d '{"ref":"main", "inputs":{"tag_name":"${{ steps.determine_version.outputs.new_version }}"}}'

deno.json

@@ -31,7 +31,7 @@
  },
  "tasks": {
  "check": "deno fmt && deno lint --fix && deno check ./src/actors/mod.ts ./src/actors/hono/middleware.ts",
- "test": "rm kv;deno test -A --unstable-kv .",
+ "test": "rm kv;deno test -A --unstable-kv --env .",
  "release": "deno run -A jsr:@deco/scripts/release"
  },
  "lock": false,

src/actors/runtime.ts

@@ -4,6 +4,8 @@ import { ActorState } from "./state.ts";
 import { DenoKvActorStorage } from "./storage/denoKv.ts";
 import { EVENT_STREAM_RESPONSE_HEADER } from "./stream.ts";
 import { isUpgrade, makeWebSocket } from "./util/channels/channel.ts";
+import { S3ActorStorage } from "./storage/s3.ts";
+import type { ActorStorage } from "./storage.ts";
 
 /**
  * Represents an actor.
@@ -81,6 +83,22 @@ export class ActorRuntime {
  ) {
  }
 
+ getActorStorage(actorId: string, actorName: string): ActorStorage {
+ const storage = Deno.env.get("DECO_ACTORS_STORAGE");
+
+ if (storage === "s3") {
+ return new S3ActorStorage({
+ actorId,
+ actorName,
+ });
+ }
+
+ return new DenoKvActorStorage({
+ actorId,
+ actorName,
+ });
+ }
+
  /**
  * Ensures that the actors are initialized for the given actor ID.
  * @param actorId - The ID of the actor.
@@ -91,10 +109,7 @@ export class ActorRuntime {
  }
  this.actorsConstructors.forEach((Actor) => {
  const initialization = Promise.withResolvers<void>();
- const storage = new DenoKvActorStorage({
- actorId,
- actorName: Actor.name,
- });
+ const storage = this.getActorStorage(actorId, Actor.name);
  const state = new ActorState({
  initialization,
  storage,