Add method dropPendingUpdates

client_manager.ts

@@ -461,4 +461,21 @@ export class ClientManager {
       this.#activeWebhookLoops.delete(client);
     }
   }
+
+  async dropPendingUpdates(id: string) {
+    const client = await this.getClient(id);
+    if (!client) {
+      return;
+    }
+    const kv = this.#kvMap.get(client);
+    if (!kv) {
+      return;
+    }
+    for await (
+      const update of kv.list({ prefix: [ClientManager.#PENDING_UPDATES] })
+    ) {
+      await kv.delete(update.key);
+    }
+    this.#updates.set(client, []);
+  }
 }

main.ts

@@ -139,7 +139,14 @@ async function handleRequest(id: string, method: string, params: any[]) {
         });
       }
       return await handleDeleteWebhook(worker, id);
-
+    case "dropPendingUpdates":
+      if (params.length != 0) {
+        return Response.json("No arguments were expected.", {
+          status: 400,
+          headers: { "x-error-type": "input" },
+        });
+      }
+      return await handleDropPendingUpdates(worker, id);
     default:
       return Response.json("Invalid method", {
         status: 400,
@@ -198,3 +205,8 @@ async function handleDeleteWebhook(worker: number, id: string) {
   const result = await workers.call(worker, "deleteWebhook", id);
   return Response.json(...result);
 }
+
+async function handleDropPendingUpdates(worker: number, id: string) {
+  const result = await workers.call(worker, "dropPendingUpdates", id);
+  return Response.json(...result);
+}

worker.ts

@@ -89,6 +89,7 @@ const handlers = {
   deleteWebhook,
   startWebhookLoop,
   unload,
+  dropPendingUpdates,
 };
 export type Handler = typeof handlers;
 
@@ -233,3 +234,10 @@ async function startWebhookLoop(id: string) {
 function unload() {
   dispatchEvent(new Event("unload"));
 }
+
+async function dropPendingUpdates(
+  id: string,
+): Promise<Parameters<typeof Response["json"]>> {
+  await clientManager.dropPendingUpdates(id);
+  return [null];
+}