🔌 feat: Revoke MCP OAuth Credentials (#9464)

* revocation metadata fields

* store metadata

* get client info and meta

* revoke oauth tokens

* delete flow

* uninstall oauth mcp

* revoke button

* revoke oauth refactor, add comments, test

* adjust for clarity

* test deleteFlow

* handle metadata type

* no mutation

* adjust for clarity

* styling

* restructure for clarity

* move token-specific stuff

* use mcpmanager's oauth servers

* fix typo

* fix addressing of oauth prop

* log prefix

* remove debug log

packages/api/src/flow/manager.spec.ts

@@ -149,4 +149,36 @@ describe('FlowStateManager', () => {
       await expect(flowPromise).rejects.toThrow('failure');
     }, 15000);
   });
+
+  describe('deleteFlow', () => {
+    const flowId = 'test-flow-123';
+    const type = 'test-type';
+    const flowKey = `${type}:${flowId}`;
+
+    it('deletes an existing flow', async () => {
+      await store.set(flowKey, { type, status: 'PENDING', metadata: {}, createdAt: Date.now() });
+      expect(await store.get(flowKey)).toBeDefined();
+
+      const result = await flowManager.deleteFlow(flowId, type);
+
+      expect(result).toBe(true);
+      expect(await store.get(flowKey)).toBeUndefined();
+    });
+
+    it('returns false if the deletion errors', async () => {
+      jest.spyOn(store, 'delete').mockRejectedValue(new Error('Deletion failed'));
+
+      const result = await flowManager.deleteFlow(flowId, type);
+
+      expect(result).toBe(false);
+    });
+
+    it('does nothing if the flow does not exist', async () => {
+      expect(await store.get(flowKey)).toBeUndefined();
+
+      const result = await flowManager.deleteFlow(flowId, type);
+
+      expect(result).toBe(true);
+    });
+  });
 });

packages/api/src/flow/manager.ts

@@ -241,4 +241,19 @@ export class FlowStateManager<T = unknown> {
       throw error;
     }
   }
+
+  /**
+   * Deletes a flow state
+   */
+  async deleteFlow(flowId: string, type: string): Promise<boolean> {
+    const flowKey = this.getFlowKey(flowId, type);
+    try {
+      await this.keyv.delete(flowKey);
+      logger.debug(`[${flowKey}] Flow deleted`);
+      return true;
+    } catch (error) {
+      logger.error(`[${flowKey}] Error deleting flow:`, error);
+      return false;
+    }
+  }
 }