From e9692501520e0ab857bc04c8e9d6924a6c537d39 Mon Sep 17 00:00:00 2001
From: Marcos Candeia <marrcooos@gmail.com>
Date: Tue, 15 Oct 2024 16:27:04 -0300
Subject: [PATCH] Gracefully failure when kv is not available

Signed-off-by: Marcos Candeia <marrcooos@gmail.com>
---
 src/actors/storage/denoKv.ts | 16 +++++++++++++++-
 1 file changed, 15 insertions(+), 1 deletion(-)

diff --git a/src/actors/storage/denoKv.ts b/src/actors/storage/denoKv.ts
index ae74ff5..a83da37 100644
--- a/src/actors/storage/denoKv.ts
+++ b/src/actors/storage/denoKv.ts
@@ -18,8 +18,21 @@ const ACTORS_DENO_KV_TOKEN = Deno.env.get("ACTORS_DENO_KV_TOKEN");
 ACTORS_DENO_KV_TOKEN &&
   Deno.env.set("DENO_KV_ACCESS_TOKEN", ACTORS_DENO_KV_TOKEN);
 
-const kv = await Deno.openKv(ACTORS_KV_DATABASE);
+let kv: Deno.Kv | null = null;
 
+try {
+  kv = await Deno.openKv(ACTORS_KV_DATABASE);
+} catch {
+  // ignore
+}
+function assertIsDefined<V>(
+  v: V | NonNullable<V>,
+): asserts v is NonNullable<V> {
+  const isDefined = v !== null && typeof v !== "undefined";
+  if (!isDefined) {
+    throw new Error(`Expected 'v' to be defined, but received ${v}`);
+  }
+}
 interface AtomicOp {
   kv: Deno.AtomicOperation;
   dirty: Deno.KvEntryMaybe<unknown>[];
@@ -31,6 +44,7 @@ export class DenoKvActorStorage implements ActorStorage {
   private kvOrTransaction: Deno.Kv | Deno.AtomicOperation;
 
   constructor(protected options: StorageOptions) {
+    assertIsDefined(kv);
     this.kv = kv;
     this.kvOrTransaction = options.atomicOp?.kv ?? kv;
     this.atomicOp = options.atomicOp;