Merge pull request #245 from AgentWorkforce/chore/adapter-core-0.3.60

chore(runtime): consume adapter-core writeback normalizer

Author: khaliqgant

packages/persona-kit/package.json

@@ -41,7 +41,7 @@
     "lint": "tsc -p tsconfig.json --noEmit"
   },
   "dependencies": {
-    "@relayfile/adapter-core": "^0.3.59",
+    "@relayfile/adapter-core": "^0.3.60",
     "@relayfile/local-mount": "^0.7.24"
   },
   "devDependencies": {

packages/runtime/package.json

@@ -56,7 +56,7 @@
     "@agent-assistant/proactive": "^0.4.32",
     "@agent-relay/events": "^6.3.3",
     "@agentworkforce/persona-kit": "workspace:*",
-    "@relayfile/adapter-core": "^0.3.59",
+    "@relayfile/adapter-core": "^0.3.60",
     "agent-trajectories": "^0.5.3"
   }
 }

packages/runtime/src/clients/index.ts

@@ -1,9 +1,8 @@
-import * as adapterVfsClient from '@relayfile/adapter-core/vfs-client';
 import {
   writeJsonFile as coreWriteJsonFile,
-  RelayfileWritebackError,
+  normalizeWritebackStatus,
+  WritebackError,
   type IntegrationClientOptions,
-  type WritebackReceipt,
   type WritebackResult
 } from '@relayfile/adapter-core/vfs-client';
 
@@ -25,8 +24,12 @@ export {
   readTextFile,
   resolveMountRoot,
   RelayfileWritebackError,
+  WritebackError,
+  normalizeWritebackStatus,
   type RelayfileWritebackErrorOptions,
   type IntegrationClientOptions,
+  type NormalizedWritebackState,
+  type NormalizedWritebackStatus,
   type WritebackReceipt,
   type WritebackResult
 } from '@relayfile/adapter-core/vfs-client';
@@ -37,101 +40,6 @@ export {
   SandboxNotAvailableError
 } from '../errors.js';
 
-export type NormalizedWritebackState =
-  | 'succeeded'
-  | 'no_receipt'
-  | 'validation_failed'
-  | 'readonly_rejected'
-  | 'adapter_error'
-  | 'ok';
-
-export interface NormalizedWritebackStatus {
-  state: NormalizedWritebackState;
-  path: string;
-  op?: 'create' | 'patch' | 'delete';
-  id?: string;
-  error?: string;
-  field?: string;
-  receipt?: WritebackReceipt;
-  timestamp?: string;
-  entry?: unknown;
-}
-
-type AdapterVfsClientExtensions = {
-  normalizeWritebackStatus?: (
-    result?: WritebackResult,
-    entry?: unknown
-  ) => NormalizedWritebackStatus;
-  WritebackError?: new (normalized: NormalizedWritebackStatus) => RelayfileWritebackError &
-    NormalizedWritebackStatus;
-};
-
-class FallbackWritebackError extends RelayfileWritebackError {
-  readonly state: NormalizedWritebackState;
-  readonly path: string;
-  readonly op?: 'create' | 'patch' | 'delete';
-  readonly id?: string;
-  readonly receipt?: WritebackReceipt;
-  readonly error?: string;
-  readonly field?: string;
-  readonly timestamp?: string;
-
-  constructor(normalized: NormalizedWritebackStatus) {
-    super({
-      provider: 'writeback',
-      operation: normalized.state,
-      cause: normalized.error ? new Error(normalized.error) : undefined,
-      retryable: false
-    });
-    this.name = 'WritebackError';
-    this.message = `writeback ${normalized.state} ${normalized.path}${
-      normalized.error ? `: ${normalized.error}` : ''
-    }`;
-    this.state = normalized.state;
-    this.path = normalized.path;
-    this.op = normalized.op;
-    this.id = normalized.id;
-    this.receipt = normalized.receipt;
-    this.error = normalized.error;
-    this.field = normalized.field;
-    this.timestamp = normalized.timestamp;
-  }
-}
-
-const adapterExtensions = adapterVfsClient as AdapterVfsClientExtensions;
-
-export const WritebackError = adapterExtensions.WritebackError ?? FallbackWritebackError;
-
-export function normalizeWritebackStatus(
-  result?: WritebackResult,
-  entry?: unknown
-): NormalizedWritebackStatus {
-  const normalize = adapterExtensions.normalizeWritebackStatus;
-  if (normalize) return normalize(result, entry);
-
-  if (!result?.receipt) {
-    return {
-      state: 'no_receipt',
-      path: result?.path ?? '',
-      error: 'writeback produced no receipt'
-    };
-  }
-
-  const receipt = result.receipt;
-  const id =
-    receipt.id !== undefined
-      ? String(receipt.id)
-      : receipt.created !== undefined
-        ? String(receipt.created)
-        : undefined;
-  return {
-    state: 'succeeded',
-    path: result.path,
-    ...(id ? { id } : {}),
-    receipt
-  };
-}
-
 export async function writeJsonFile(
   client: IntegrationClientOptions,
   provider: string,