Add reusable cryptographic parameter validation framework

components/cipher/CipherExecutionController.ts

@@ -7,8 +7,8 @@ import { useCipherWorker } from "../../hooks/useCipherWorker";
 import { clampStepIndex } from "../../lib/utils/visualizerPermalink";
 import { resolveProvenance } from "../../lib/provenance/resolve";
 import type { DataProvenanceMetadata } from "../../lib/provenance";
-import { saveConversionHistory, type ConversionHistoryEntry } from "../../lib/utils/conversionHistory";
-
+import { saveConversionHistory, type ConversionHistoryEntry } from "@/lib/utils/conversionHistory";
+import { createVirtualizedCipherResult } from "@/lib/cipher/stepVirtualization";
 interface Params {
   cipher: CipherDefinition;
   input: string;
@@ -33,10 +33,12 @@ export function buildCipherWorkerOptions(
   demoMode: boolean,
 ): CipherOptions {
   const workerOptions: CipherOptions = {
-    instrument: true,
-    signal: undefined,
-    ...options,
-  };
+  instrument: true,
+  signal: undefined,
+  traceBufferSize: 32,
+  traceBatchSize: 32,
+  ...options,
+};
   if (["des", "3des", "aes", "camellia"].includes(cipherId)) {
     workerOptions.hexInput = typeof options.hexInput === "boolean" ? options.hexInput : true;
   }
@@ -60,10 +62,10 @@ export function useCipherExecutionController({ cipher, input, key, action, autoC
   const abortRef = useRef<AbortController | null>(null);
 
   const run = useCallback(async () => {
-    abortRef.current?.abort();
-    const controller = new AbortController();
-    abortRef.current = controller;
-    onError(null);
+abortRef.current?.abort();
+
+const controller = new AbortController();
+abortRef.current = controller;    onError(null);
 
     try {
       const workerOptions = buildCipherWorkerOptions(cipher.id, options, demoMode);
@@ -76,10 +78,20 @@ export function useCipherExecutionController({ cipher, input, key, action, autoC
       const provenance = isSimulated(cipher.id, demoMode)
         ? resolveProvenance({ provenance: "simulated", source: "CryptoViz educational simulation" } as DataProvenanceMetadata)
         : resolveProvenance(result.metadata?.provenance);
-      const nextResult: CipherResult = { ...result, metadata: { ...result.metadata, provenance } };
-      onResult(nextResult);
-      onStepRestore(clampStepIndex(0, nextResult.steps?.length ?? 0));
+const nextResult: CipherResult = {
+  ...result,
+  metadata: {
+    ...result.metadata,
+    provenance,
+  },
+};
+
+const visualizedResult = createVirtualizedCipherResult(nextResult);
 
+onResult(visualizedResult);
+onStepRestore(
+  clampStepIndex(0, visualizedResult.steps?.length ?? 0),
+);
       if (nextResult.output !== undefined) {
         const entry: ConversionHistoryEntry = {
           id: `${Date.now()}-${Math.random().toString(36).slice(2, 8)}`,

components/cipher/CipherLayout.tsx

@@ -6,7 +6,6 @@ import { useRouter } from "next/navigation";
 import type { CipherDefinition } from "@/lib/cipher/registry";
 import type { CipherResult, CipherOptions } from "@/lib/cipher/types";
 import type { AnimationSpeed } from "./StepAnimator";
-import { createVirtualizedCipherResult } from "@/lib/cipher/stepVirtualization";
 import WorkspacePresetManager from "./WorkspacePresetManager";
 import ConversionHistory from "./ConversionHistory";
 import WhereIsThisUsed from "./WhereIsThisUsed";
@@ -208,11 +207,7 @@ export default function CipherLayout({ cipher }: CipherLayoutProps) {
   };
 
   const direction = cipher.id === "dh" ? "encrypt" : action;
-  const virtualizedResult = useMemo(
-    () => (result ? createVirtualizedCipherResult(result) : null),
-    [result],
-  );
-  const activeStep = result?.steps?.[currentStep];
+const virtualizedResult = result;  const activeStep = result?.steps?.[currentStep];
   const annotationScope = { cipherId: cipher.id, direction: direction as "encrypt" | "decrypt" };
   const scopeAnnotations = getScopeAnnotations(annotationStore, annotationScope);
   const activeStepId = activeStep ? createStableStepId(activeStep.label, currentStep) : null;
@@ -442,9 +437,12 @@ export default function CipherLayout({ cipher }: CipherLayoutProps) {
                     </div>
                   </div>
                   <StepAnimator
-                    steps={virtualizedResult?.steps ?? result.steps}
-                    stepMetadata={virtualizedResult?.stepMetadata}
-                    currentStep={currentStep}
+steps={result.steps}
+stepMetadata={
+  "stepMetadata" in result
+    ? result.stepMetadata
+    : undefined
+}                    currentStep={currentStep}
                     onStepChange={handleStepChange}
                     speed={animationSpeed}
                     onSpeedChange={setAnimationSpeed}

hooks/useCipherWorker.ts

@@ -2,11 +2,15 @@
 
 import { useCallback, useEffect, useRef, useState } from 'react'
 import type { CipherResult } from '@/lib/cipher/types'
-import type { WorkerRequest, WorkerResponse } from '@/types/worker'
-import type { WorkerPriority } from '@/lib/workers/pool'
+import type {
+  WorkerRequest,
+  WorkerResponse,
+  WorkerTraceBatchMessage,
+  WorkerTraceStartMessage,
+  WorkerTraceCompleteMessage,
+} from '@/types/worker'import type { WorkerPriority } from '@/lib/workers/pool'
 import type { WorkerProgressMessage } from '@/lib/workers/cipher-worker-protocol'
-import { CipherError } from '@/lib/utils/errors'
-import { decodeCipherSteps } from '@/lib/workers/stepTransfer'
+import { CipherError, type CipherErrorCode } from '@/lib/utils/errors'import { decodeCipherSteps } from '@/lib/workers/stepTransfer'
 
 const MAX_CACHE_SIZE = 200
 const WORKER_TIMEOUT_MS = 10000
@@ -34,8 +38,9 @@
   timeoutId: ReturnType<typeof setTimeout>
   cacheKey: string | null
   onProgress?: (percent: number, message: string) => void
+  traceSteps: import('@/lib/cipher/types').CipherStep[]
+  traceTotal: number
 }
-
 function sortObjectKeys(obj: unknown): unknown {
   if (obj === null || typeof obj !== 'object') return obj
   if (Array.isArray(obj)) return obj.map(sortObjectKeys)
@@ -130,12 +135,20 @@
           reject(error)
         }
       } else {
-        const errorMsg = payload?.error ?? 'Operation failed in worker'
-        const code = payload?.errorCode
-        const cipherErr = code && code !== 'INVALID_WORKER_MESSAGE'
-          ? new CipherError(code, errorMsg)
-          : new Error(errorMsg)
-        setError(errorMsg)
+const errorMsg =
+  payload?.error ??
+  payload?.errorMessage ??
+  'Operation failed in worker'
+
+const code = payload?.errorCode
+
+const cipherErr =
+  code && code !== 'INVALID_WORKER_MESSAGE'
+    ? new CipherError(code as CipherErrorCode, errorMsg, {
+        details: payload?.errorDetails,
+        remediation: payload?.remediation,
+      })
+    : new Error(errorMsg)        setError(errorMsg)
         reject(cipherErr)
       }
     }
@@ -254,16 +267,17 @@
           reject(new Error('WORKER_TIMEOUT'))
         }, WORKER_TIMEOUT_MS)
 
-        activeRequestsRef.current.set(id, {
-          resolve,
-          reject,
-          signal,
-          onAbort,
-          timeoutId,
-          cacheKey,
-          onProgress: options?.onProgress,
-        })
-        setLoading(true)
+activeRequestsRef.current.set(id, {
+  resolve,
+  reject,
+  signal,
+  onAbort,
+  timeoutId,
+  cacheKey,
+  onProgress: options?.onProgress,
+  traceSteps: [],
+  traceTotal: 0,
+})        setLoading(true)
         setError(null)
         setProgress({ percent: 0, currentMilestone: 'Queued', jobId: id })