Unified · Split
| @@ -11,7 +11,6 @@ import type { · 10 unmodified lines | |||
| 11 | TaskEventRecord, | 11 | TaskEventRecord, |
| 12 | TaskRecord, | 12 | TaskRecord, |
| 13 | TaskStatus, | 13 | TaskStatus, |
| 14 | ToolDescriptor, | ||
| 15 | ToolSourceRecord, | 14 | ToolSourceRecord, |
| 16 | } from "./types"; | 15 | } from "./types"; |
| 17 | 16 | ||
| @@ -44,7 +43,6 @@ type QueryName = · 26 unmodified lines | |||
| 44 | | "database:listCredentials" | 43 | | "database:listCredentials" |
| 45 | | "database:resolveCredential" | 44 | | "database:resolveCredential" |
| 46 | | "database:listToolSources" | 45 | | "database:listToolSources" |
| 47 | | "database:listToolSourceWorkspaceUpdates" | ||
| 48 | | "database:listTaskEvents"; | 46 | | "database:listTaskEvents"; |
| 49 | 47 | ||
| 50 | export class ExecutorDatabase { | 48 | export class ExecutorDatabase { |
| @@ -219,10 +217,6 @@ export class ExecutorDatabase { · 168 unmodified lines | |||
| 219 | return await this.query("database:listToolSources", { workspaceId }); | 217 | return await this.query("database:listToolSources", { workspaceId }); |
| 220 | } | 218 | } |
| 221 | 219 | ||
| 222 | async listToolSourceWorkspaceUpdates(): Promise<Array<{ workspaceId: string; updatedAt: number }>> { | ||
| 223 | return await this.query("database:listToolSourceWorkspaceUpdates", {}); | ||
| 224 | } | ||
| 225 | |||
| 226 | async deleteToolSource(workspaceId: string, sourceId: string): Promise<boolean> { | 220 | async deleteToolSource(workspaceId: string, sourceId: string): Promise<boolean> { |
| 227 | return await this.mutation("database:deleteToolSource", { workspaceId, sourceId }); | 221 | return await this.mutation("database:deleteToolSource", { workspaceId, sourceId }); |
| 228 | } | 222 | } |
| @@ -9,7 +9,6 @@ import type { · 8 unmodified lines | |||
| 9 | PendingApprovalRecord, | 9 | PendingApprovalRecord, |
| 10 | TaskEventRecord, | 10 | TaskEventRecord, |
| 11 | TaskRecord, | 11 | TaskRecord, |
| 12 | ToolDescriptor, | ||
| 13 | ToolSourceRecord, | 12 | ToolSourceRecord, |
| 14 | SandboxExecutionRequest, | 13 | SandboxExecutionRequest, |
| 15 | SandboxExecutionResult, | 14 | SandboxExecutionResult, |
| @@ -209,14 +208,6 @@ class TestExecutorDatabase extends ExecutorDatabase { · 193 unmodified lines | |||
| 209 | return []; | 208 | return []; |
| 210 | } | 209 | } |
| 211 | 210 | ||
| 212 | async syncWorkspaceTools(): Promise<boolean> { | ||
| 213 | return true; | ||
| 214 | } | ||
| 215 | |||
| 216 | async listWorkspaceToolsForContext(): Promise<ToolDescriptor[]> { | ||
| 217 | return []; | ||
| 218 | } | ||
| 219 | |||
| 220 | async listAccessPolicies(_workspaceId: string): Promise<AccessPolicyRecord[]> { | 211 | async listAccessPolicies(_workspaceId: string): Promise<AccessPolicyRecord[]> { |
| 221 | return [...this.policies.values()] | 212 | return [...this.policies.values()] |
| 222 | .filter((policy) => policy.workspaceId === _workspaceId) | 213 | .filter((policy) => policy.workspaceId === _workspaceId) |
| @@ -230,14 +230,6 @@ export class ExecutorService { · 229 unmodified lines | |||
| 230 | return await this.db.listToolSources(workspaceId); | 230 | return await this.db.listToolSources(workspaceId); |
| 231 | } | 231 | } |
| 232 | 232 | ||
| 233 | async listToolSourceWorkspaceUpdates(): Promise<Array<{ workspaceId: string; updatedAt: number }>> { | ||
| 234 | return await this.db.listToolSourceWorkspaceUpdates(); | ||
| 235 | } | ||
| 236 | |||
| 237 | async refreshWorkspaceTools(workspaceId: string): Promise<void> { | ||
| 238 | await this.getWorkspaceTools(workspaceId); | ||
| 239 | } | ||
| 240 | |||
| 241 | async upsertToolSource(input: { | 233 | async upsertToolSource(input: { |
| 242 | id?: string; | 234 | id?: string; |
| 243 | workspaceId: string; | 235 | workspaceId: string; |