refactor: remove redundant unknown casts

apps/cli/tests/dsh-badge.expected.e2e.ts

@@ -25,10 +25,10 @@ describe('dsh badge assembled snapshot', () => {
       configPath,
       tsconfigPath,
     })
-    const disabledSnapshot = JSON.parse(disabled.stdout) as unknown
-    const enabledSnapshot = JSON.parse(
+    const disabledSnapshot: unknown = JSON.parse(disabled.stdout)
+    const enabledSnapshot: unknown = JSON.parse(
       enabled.stdout.replaceAll(badgeAssetsPath, '{{badgeAssetsPath}}'),
-    ) as unknown
+    )
 
     expect(disabled.stderr).toBe('')
     expect(enabled.stderr).toBe('')

apps/cli/tests/profiles/acp/tests/goal.expected.e2e.ts

@@ -87,7 +87,7 @@ describe('same-session goal snapshot through the ACP automation driver', () => {
     const log = result.sessionLogs[0]
     if (log === undefined) throw new Error('goal snapshot did not persist its session')
     const records = parseJsonl(log.content)
-    const events = records.slice(1) as unknown as SessionEvent[]
+    const events = records.slice(1) as SessionEvent[]
     const calls = events.filter(event => event.type === 'tool/call').map(event => event.data.name)
     expect(calls).toEqual(['create_goal', 'get_goal'])
     const rounds = events.flatMap(event => event.type === 'user/message' && event.data.source.kind === 'goal'
@@ -136,7 +136,7 @@ describe('same-session goal snapshot through the ACP automation driver', () => {
     const log = result.sessionLogs[0]
     if (log === undefined) throw new Error('goal wrap-up snapshot did not persist its session')
     const records = parseJsonl(log.content)
-    const events = records.slice(1) as unknown as SessionEvent[]
+    const events = records.slice(1) as SessionEvent[]
     const calls = events.filter(event => event.type === 'tool/call').map(event => event.data.name)
     expect(calls).toEqual(['create_goal', 'update_goal'])
     expect(foldGoal(events)).toMatchObject({

apps/cli/tests/profiles/headless/tests/compaction.e2e.ts

@@ -81,7 +81,7 @@ describe.skipIf(!process.env.DEEPSEEK_API_KEY)('compaction: a long session compa
     const summaries = events.filter(e => e.type === 'compaction/summary')
     expect(summaries.length, JSON.stringify(ends.map(event => event.data.error))).toBeGreaterThan(0)
     const replaceNode = events.find((e) => {
-      const se = e as unknown as { type: string; surfaceOp?: unknown }
+      const se = e as { type: string; surfaceOp?: unknown }
       return se.type === 'user/message' && typeof se.surfaceOp === 'object' && se.surfaceOp !== null
     })
     expect(replaceNode).toBeDefined()

apps/cli/tests/web-auth.e2e.ts

@@ -182,7 +182,7 @@ describe('dsh web authentication through the real CLI', () => {
 
       const authenticated = await describeSettings(port, firstUrl.host, cookie)
       expect(authenticated.status).toBe(200)
-      const authenticatedBody = JSON.parse(authenticated.body) as unknown
+      const authenticatedBody: unknown = JSON.parse(authenticated.body)
       expect(authenticatedBody).toMatchObject({
         type: 'server-response',
         rpcId: 'web-auth-real-cli',

apps/desktop/src/runtime-tree.ts

@@ -128,7 +128,7 @@ export function writeDesktopRuntime(
   const sharedPackages = [...new Set(sharedNames)].sort().map((name) => {
     if (!PACKAGE_NAME.test(name)) throw new Error(`desktop runtime: invalid shared package ${name}`)
     const path = `node_modules/${name}`
-    const manifest = JSON.parse(readFileSync(join(runtimePath(root, path), 'package.json'), 'utf8')) as unknown
+    const manifest: unknown = JSON.parse(readFileSync(join(runtimePath(root, path), 'package.json'), 'utf8'))
     if (!record(manifest) || manifest.name !== name || typeof manifest.version !== 'string' || valid(manifest.version) === null) {
       throw new Error(`desktop runtime: invalid shared package manifest ${name}`)
     }

apps/desktop/tests/host-update-tasks.spec.ts

@@ -27,7 +27,7 @@ afterEach(async () => { await ctx.fiber.dispose() })
 function idleAgent(): AgentState { return { status: 'idle', inbox: { nextTurn: [], nextStep: [] } } }
 
 function request(next: () => Promise<void>) {
-  const incoming = Readable.from([]) as unknown as IncomingMessage
+  const incoming = Readable.from([]) as IncomingMessage
   const response = { writeHead: vi.fn(), end: vi.fn() }
   return { response, done: ctx.waterfall('connection/request', incoming, response as unknown as ServerResponse, next) }
 }

apps/desktop/tests/main-startup.spec.ts

@@ -1275,7 +1275,7 @@ describe('desktop main startup', () => {
     const window = harness.windows[0]!
     const frame = { url: 'dsh-app://app/' }
     Object.assign(window.webContents, { mainFrame: frame })
-    const handler = harness.handlers.get(DESKTOP_IPC.bootFailed)! as unknown as (event: unknown, message: unknown) => void
+    const handler = harness.handlers.get(DESKTOP_IPC.bootFailed)! as (event: unknown, message: unknown) => void
     const event = { sender: window.webContents, senderFrame: frame }
     expect(() => { handler({ ...event, senderFrame: { url: 'https://other.example/' } }, 'untrusted') }).toThrow('unowned renderer')
     expect(() => { handler({ ...event, senderFrame: { ...frame } }, 'subframe') }).toThrow('non-primary frame')

apps/desktop/tests/web-document.spec.ts

@@ -43,7 +43,7 @@ it('forwards upload bytes and cancellation with Host credentials while keeping t
     method: 'POST', body: 'upload bytes', headers: { origin: 'dsh-app://app', cookie: 'untrusted' },
   })
   const response = await forwardWebRequest(request, 'http://127.0.0.1:1234/?token=secret', 'session=owned')
-  const [target, init] = fetch.mock.calls[0] as unknown as [URL, RequestInit]
+  const [target, init] = fetch.mock.calls[0] as [URL, RequestInit]
   expect(target.href).toBe('http://127.0.0.1:1234/api/upload?name=file')
   expect(new Headers(init.headers).get('cookie')).toBe('session=owned')
   expect(new Headers(init.headers).get('origin')).toBeNull()

apps/web/tests/sidebar-right.e2e.ts

@@ -682,7 +682,7 @@ describe('web e2e: shipped right Sidebar', () => {
     }, 60_000)
 
     it('CONTROL: the host endpoint answers when called directly, bypassing the wire', async () => {
-      const files = (scaffold.ctx as unknown as {
+      const files = (scaffold.ctx as {
         get(name: string): {
           read(
             scope: { sessionId: string; workspaceRoot: string },

apps/web/tests/web-search-round.e2e.ts

@@ -84,7 +84,7 @@ async function startSearchServer(captured: CapturedSearchRequest[]): Promise<{ s
     request.setEncoding('utf8')
     request.on('data', (chunk: string) => { body += chunk })
     request.on('end', () => {
-      const parsedBody = JSON.parse(body) as unknown
+      const parsedBody: unknown = JSON.parse(body)
       captured.push({
         path: request.url ?? '',
         apiKey: typeof request.headers['x-api-key'] === 'string' ? request.headers['x-api-key'] : undefined,

packages/acp/acp/src/index.ts

@@ -476,7 +476,7 @@ function decodeSessionListCursor(value: string | null | undefined): SessionListC
   if (value === undefined || value === null) return undefined
   if (!/^[A-Za-z0-9_-]+$/.test(value)) throw new Error('session/list cursor is invalid')
   try {
-    const decoded = JSON.parse(Buffer.from(value, 'base64url').toString('utf8')) as unknown
+    const decoded: unknown = JSON.parse(Buffer.from(value, 'base64url').toString('utf8'))
     const createdAt: unknown = Array.isArray(decoded) ? decoded[0] : undefined
     const sessionId: unknown = Array.isArray(decoded) ? decoded[1] : undefined
     if (

packages/api/gateway/src/client/remote-events.ts

@@ -93,7 +93,7 @@ export class ClientRemoteEvents {
   ): () => void {
     const dispose = privateEvents(callerCtx).on(
       this.eventKey(event),
-      listener as unknown as RemoteEventListener,
+      listener as RemoteEventListener,
     )
     return () => { dispose() }
   }

packages/api/gateway/src/index.ts

@@ -276,10 +276,10 @@ export class TypertGatewayService extends Service implements TypertGateway {
     const claims = new Set<string>()
     for (const [serviceKey, definition] of Object.entries(this.ctx.reflect.props)) {
       if (definition.type !== 'service') continue
-      const receiver = this.ctx.get(serviceKey) as unknown
+      const receiver: unknown = this.ctx.get(serviceKey)
       if (!isObject(receiver)) continue
       const original = originalOf(receiver)
-      const binding = Reflect.get(original, 'typertRemote') as unknown
+      const binding: unknown = Reflect.get(original, 'typertRemote')
       if (!isObject(binding) || typeof Reflect.get(binding, 'namespace') !== 'string') continue
       const namespace = Reflect.get(binding, 'namespace') as string
       for (const candidate of remoteMethods(original)) {
@@ -483,7 +483,7 @@ export class TypertGatewayService extends Service implements TypertGateway {
       }
       const signals = new Set(projected.signal === undefined ? [] : [projected.signal])
       const abort = (): void => {
-        const reason = [...signals].find(signal => signal.aborted)?.reason as unknown
+        const reason: unknown = [...signals].find(signal => signal.aborted)?.reason
         this.cancelRemoteEvent(pending, reason instanceof Error
           ? reason
           : new Error('typert gateway: Remote event was cancelled', { cause: reason }))
@@ -599,7 +599,7 @@ export class TypertGatewayService extends Service implements TypertGateway {
     const descriptor = this.resolveDescriptor(request.namespace, request.method, endpoint)
     assertExactArguments(request.args, descriptor, endpoint)
     const receiverContext = await this.resolveReceiverContext(descriptor, request.args, endpoint)
-    const receiver = receiverContext.get(descriptor.service) as unknown
+    const receiver: unknown = receiverContext.get(descriptor.service)
     if (!isObject(receiver)) {
       throw new TypertGatewayError(
         'gateway/service-unavailable',
@@ -612,7 +612,7 @@ export class TypertGatewayService extends Service implements TypertGateway {
       this.resolveParameter(parameter, request.args, endpoint)))
     if (descriptor.cancellation !== undefined) args.push(request.signal ?? NEVER_ABORTED_SIGNAL)
     const implementation = descriptor.implementation ?? descriptor.method
-    const method = Reflect.get(receiver, implementation) as unknown
+    const method: unknown = Reflect.get(receiver, implementation)
     if (typeof method !== 'function') {
       throw new TypertGatewayError(
         'gateway/method-unavailable',
@@ -640,10 +640,10 @@ export class TypertGatewayService extends Service implements TypertGateway {
     const candidates: InvocationDescriptor[] = []
     for (const [serviceKey, definition] of Object.entries(this.ctx.reflect.props)) {
       if (definition.type !== 'service') continue
-      const receiver = this.ctx.get(serviceKey) as unknown
+      const receiver: unknown = this.ctx.get(serviceKey)
       if (!isObject(receiver)) continue
       const original = originalOf(receiver)
-      const value = Reflect.get(original, 'typertRemote') as unknown
+      const value: unknown = Reflect.get(original, 'typertRemote')
       if (value === undefined) continue
       const binding = readBinding(value, original, serviceKey, endpoint)
       if (binding.namespace !== namespace) continue
@@ -961,8 +961,8 @@ async function *cancellableStream(
   endpoint: string,
   signal: AbortSignal,
 ): AsyncGenerator {
-  const asyncFactory = Reflect.get(source, Symbol.asyncIterator) as unknown
-  const syncFactory = Reflect.get(source, Symbol.iterator) as unknown
+  const asyncFactory: unknown = Reflect.get(source, Symbol.asyncIterator)
+  const syncFactory: unknown = Reflect.get(source, Symbol.iterator)
   const iterator = typeof asyncFactory === 'function'
     ? Reflect.apply(asyncFactory, source, []) as AsyncIterator<unknown>
     : Reflect.apply(syncFactory as (...args: never[]) => Iterator<unknown>, source, [])
@@ -1020,7 +1020,7 @@ function validateBinding(
   endpoint: string,
 ): ResolvedBinding {
   const original = originalOf(receiver)
-  const value = Reflect.get(original, 'typertRemote') as unknown
+  const value: unknown = Reflect.get(original, 'typertRemote')
   if (value === undefined) {
     throw new TypertGatewayError(
       'gateway/binding-invalid',
@@ -1052,11 +1052,11 @@ function readBinding(
       `Service ${JSON.stringify(serviceKey)} has an inconsistent typertRemote binding`,
     )
   }
-  return value as unknown as TypertGatewayBinding
+  return value as TypertGatewayBinding
 }
 
 function originalOf(receiver: object): object {
-  const original = Reflect.get(receiver, symbols.original) as unknown
+  const original: unknown = Reflect.get(receiver, symbols.original)
   return isObject(original) ? original : receiver
 }
 

packages/api/gateway/src/stream-protocol.ts

@@ -270,14 +270,14 @@ export type RemoteStreamServerMessage =
 export function parseRemoteStreamClientMessage(text: string): RemoteStreamClientMessage {
   return parseMessage(text, (value) => {
     if (value.type === 'cancel' && exactKeys(value, ['type', 'streamId']) && validId(value.streamId)) {
-      return value as unknown as RemoteStreamClientMessage
+      return value as RemoteStreamClientMessage
     }
     if (value.type === 'open'
       && exactKeys(value, ['type', 'streamId', 'endpoint', 'payload'])
       && validId(value.streamId)
       && typeof value.endpoint === 'string'
       && value.endpoint.length > 0) {
-      return value as unknown as RemoteStreamClientMessage
+      return value as RemoteStreamClientMessage
     }
     throw new Error('api gateway: invalid Remote stream client message')
   })
@@ -293,10 +293,10 @@ export function parseRemoteStreamServerMessage(text: string): RemoteStreamServer
     if (value.type === 'item'
       && (exactKeys(value, ['type', 'streamId']) || exactKeys(value, ['type', 'streamId', 'value']))
       && validId(value.streamId)) {
-      return value as unknown as RemoteStreamServerMessage
+      return value as RemoteStreamServerMessage
     }
     if (value.type === 'end' && exactKeys(value, ['type', 'streamId']) && validId(value.streamId)) {
-      return value as unknown as RemoteStreamServerMessage
+      return value as RemoteStreamServerMessage
     }
     if (value.type === 'error'
       && exactKeys(value, ['type', 'streamId', 'error'])
@@ -306,7 +306,7 @@ export function parseRemoteStreamServerMessage(text: string): RemoteStreamServer
       && typeof value.error.code === 'string'
       && typeof value.error.message === 'string'
       && isRecord(value.error.details)) {
-      return value as unknown as RemoteStreamServerMessage
+      return value as RemoteStreamServerMessage
     }
     throw new Error('api gateway: invalid Remote stream server message')
   })

packages/api/gateway/tests/gateway-stream.host.spec.ts

@@ -1080,7 +1080,7 @@ function rawText(data: RawData): string {
 function streamErrorMessage(frames: readonly Record<string, unknown>[], streamId: string): string | undefined {
   const error = frames.find(frame => frame.streamId === streamId)?.error
   if (typeof error !== 'object' || error === null) return undefined
-  const message = Reflect.get(error, 'message') as unknown
+  const message: unknown = Reflect.get(error, 'message')
   return typeof message === 'string' ? message : undefined
 }
 

packages/api/gateway/tests/gateway.client.spec.ts

@@ -981,7 +981,7 @@ describe('Client Typert API', () => {
     await vi.waitFor(() => { expect(ctx.typert.remotes.list()).toEqual([]) })
     const retry = await ctx.remote.$mount({ package: '@fixture/retry-batch', descriptors: [first, second] })
     expect(ctx.remote.probe.create).toBeTypeOf('function')
-    expect((ctx.remote.probe as unknown as Record<string, unknown>).archive).toBeTypeOf('function')
+    expect((ctx.remote.probe as Record<string, unknown>).archive).toBeTypeOf('function')
     await retry()
   })
 

packages/api/gateway/tests/gateway.host.spec.ts

@@ -1223,7 +1223,7 @@ describe('TypertGatewayService', () => {
         }),
       })
       expect(invalid.status).toBe(200)
-      const invalidBody = await invalid.json() as unknown
+      const invalidBody: unknown = await invalid.json()
       expect(invalidBody).toMatchObject({
         type: 'server-response',
         rpcId: 'rpc-invalid',
@@ -1247,7 +1247,7 @@ describe('TypertGatewayService', () => {
         }),
       })
       expect(withdrawn.status).toBe(200)
-      const withdrawnBody = await withdrawn.json() as unknown
+      const withdrawnBody: unknown = await withdrawn.json()
       expect(withdrawnBody).toMatchObject({
         type: 'server-response',
         rpcId: 'rpc-withdrawn',

packages/api/gateway/tests/stream-server.host.spec.ts

@@ -172,7 +172,7 @@ describe('Remote stream mux server carrier lifecycle', () => {
     client.send(openFrame('write-failure'))
     await didOpen
     const serverSocket = acceptedSocket(entry.mux)
-    const mutable = serverSocket as unknown as {
+    const mutable = serverSocket as {
       send(data: unknown, callback: (error?: Error) => void): void
     }
     mutable.send = (_data, callback): void => {

packages/api/remotes/tests/remote-events.host.spec.ts

@@ -52,7 +52,7 @@ function sourceOf(gateway: GatewayProbe): TypertRemoteEventSource {
 }
 
 function emitRaw(ctx: Context, event: string, args: readonly unknown[]): void {
-  const emit = ctx.emit.bind(ctx) as unknown as (name: string, ...values: readonly unknown[]) => void
+  const emit = ctx.emit.bind(ctx) as (name: string, ...values: readonly unknown[]) => void
   emit(event, ...args)
 }
 
@@ -63,7 +63,7 @@ function waterfallRaw(
   args: readonly unknown[],
   next: () => Promise<unknown>,
 ): Promise<unknown> {
-  const waterfall = ctx.waterfall.bind(ctx) as unknown as (
+  const waterfall = ctx.waterfall.bind(ctx) as (
     receiver: object,
     name: string,
     ...values: readonly unknown[]

packages/api/session-controller/src/client/session-wire-event.ts

@@ -40,7 +40,7 @@ export function assertSessionWireEvent(value: unknown): asserts value is Session
     throw new Error(`${subject} has an invalid envelope`)
   }
   // Event names and payloads are merge-extensible; only event-local owner rules run here.
-  const current = event as unknown as SessionEvent
+  const current = event as SessionEvent
   validateSurfaceMetadata(current)
   validateSessionEventData(current, subject)
 }

packages/api/session-controller/src/model-selection-projection.ts

@@ -19,12 +19,12 @@ const modelSelectionSchema = z.object({
 const modelSelectionProjectionStateSchema = z.object({
   lastUsed: modelSelectionSchema.nullable(),
   pending: modelSelectionSchema.nullable(),
-}) as unknown as z.ZodType<ModelSelectionProjectionState>
+}) as z.ZodType<ModelSelectionProjectionState>
 
 const modelSelectionProjectionSchema = z.object({
   lastUsed: modelSelectionSchema.nullable(),
   next: modelSelectionSchema.nullable(),
-}) as unknown as z.ZodType<ModelSelectionProjection>
+}) as z.ZodType<ModelSelectionProjection>
 
 /**
  * Advance durable model-selection state by one Session event.

packages/api/session-controller/tests/session-search.host.spec.ts

@@ -164,7 +164,7 @@ describe('session.search', () => {
       },
     })
     expect(searchSessions).toHaveBeenCalledOnce()
-    const [query, exec] = searchSessions.mock.calls[0] as unknown as [
+    const [query, exec] = searchSessions.mock.calls[0] as [
       SessionSearchRequest,
       { signal: AbortSignal },
     ]

packages/bundle/headless/src/json-stream.ts

@@ -156,12 +156,12 @@ function parseArguments(raw: string): unknown {
   if (raw === '') return {}
   const seen = { nonFinite: false }
   try {
-    const parsed = JSON.parse(raw, (_key, value: unknown) => {
+    const parsed: unknown = JSON.parse(raw, (_key, value: unknown) => {
       // `1e400` is valid JSON but parses to Infinity, which JSON.stringify
       // reports as null; keep the raw text rather than misdescribe the call.
       if (typeof value === 'number' && !Number.isFinite(value)) seen.nonFinite = true
       return value
-    }) as unknown
+    })
     return seen.nonFinite ? raw : parsed
   } catch {
     return raw

packages/bundle/web-app/tests/web-app.spec.ts

@@ -57,7 +57,7 @@ type BrowserLauncher = ChildProcess & { stderr: PassThrough }
 
 /** Minimal browser-launcher process for the native handoff adapter. */
 function launcher(): BrowserLauncher {
-  return Object.assign(new EventEmitter(), { stderr: new PassThrough() }) as unknown as BrowserLauncher
+  return Object.assign(new EventEmitter(), { stderr: new PassThrough() }) as BrowserLauncher
 }
 
 /** Stage a dist fixture and point the bundle's resolver at it. */

packages/client/connection/tests/http-bridge.host.spec.ts

@@ -7,7 +7,7 @@ import { bridge } from '../src/http-bridge.ts'
 describe('HTTP bridge abort', () => {
   it('destroys a declared-oversize request instead of draining it', async () => {
     const destroyed: true[] = []
-    const request = Readable.from([]) as unknown as IncomingMessage
+    const request = Readable.from([]) as IncomingMessage
     Object.assign(request, {
       url: '/api/session.prompt',
       method: 'POST',
@@ -38,7 +38,7 @@ describe('HTTP bridge abort', () => {
     const body = JSON.stringify({
       type: 'client-request', rpcId: 'picker-1', method: 'directoryPicker/pick', payload: { args: {} },
     })
-    const request = Readable.from([Buffer.from(body)]) as unknown as IncomingMessage
+    const request = Readable.from([Buffer.from(body)]) as IncomingMessage
     Object.assign(request, {
       url: '/api/directoryPicker/pick',
       method: 'POST',
@@ -76,7 +76,7 @@ describe('HTTP bridge abort', () => {
   })
 
   it('streams a declared 2.19 GiB request before the body ends and bypasses the JSON buffer cap', async () => {
-    const request = new Readable({ read() {} }) as unknown as IncomingMessage
+    const request = new Readable({ read() {} }) as IncomingMessage
     Object.assign(request, {
       url: '/api/session/uploadFileBinary?sessionId=s1',
       method: 'POST',
@@ -120,7 +120,7 @@ describe('HTTP bridge abort', () => {
 
   it('closes an unread streaming request after returning an early validation response', async () => {
     const destroyed: true[] = []
-    const request = new Readable({ read() {} }) as unknown as IncomingMessage
+    const request = new Readable({ read() {} }) as IncomingMessage
     Object.assign(request, {
       url: '/api/session/uploadFileBinary',
       method: 'POST',

packages/client/connection/tests/node-half.host.spec.ts

@@ -36,21 +36,21 @@ function fakeHttpServer(
 
 /** Bodyless GET carrying the given headers (enough for the trust fence + bridge). */
 function fakeRequest(headers: Record<string, string>, url = `${API_PATH}/session.list`): IncomingMessage {
-  const request = Readable.from([]) as unknown as IncomingMessage
+  const request = Readable.from([]) as IncomingMessage
   Object.assign(request, { url, method: 'GET', headers })
   return request
 }
 
 /** JSON POST carrying a complete client-request envelope. */
 function fakePost(headers: Record<string, string>, url: string, body: unknown): IncomingMessage {
-  const request = Readable.from([Buffer.from(JSON.stringify(body))]) as unknown as IncomingMessage
+  const request = Readable.from([Buffer.from(JSON.stringify(body))]) as IncomingMessage
   Object.assign(request, { url, method: 'POST', headers: { 'content-type': 'application/json', ...headers } })
   return request
 }
 
 /** Raw POST for malformed-body and media-type boundary cases. */
 function fakeRawPost(headers: Record<string, string>, url: string, body: string): IncomingMessage {
-  const request = Readable.from([Buffer.from(body)]) as unknown as IncomingMessage
+  const request = Readable.from([Buffer.from(body)]) as IncomingMessage
   Object.assign(request, { url, method: 'POST', headers })
   return request
 }

packages/client/file-upload/src/client/runtime.ts

@@ -298,7 +298,7 @@ function workerTransport(): FileUploadTransport {
 }
 
 function parseFileUploadResult(body: string): RemoteResult<FileUploadValue> {
-  const value = JSON.parse(body) as unknown
+  const value: unknown = JSON.parse(body)
   if (!isRecord(value) || typeof value.ok !== 'boolean') {
     throw new TypeError('file upload transport returned an invalid result')
   }

packages/client/modules/src/index.ts

@@ -325,7 +325,7 @@ function readSourceMap(clientPath: string): Record<string, unknown> | undefined
     if ((error as NodeJS.ErrnoException).code === 'ENOENT') return undefined
     throw error
   }
-  const value = JSON.parse(body.toString('utf8')) as unknown
+  const value: unknown = JSON.parse(body.toString('utf8'))
   const parsed = typeof value === 'object' && value !== null ? value as Record<string, unknown> : undefined
   if (
     parsed === undefined

packages/client/modules/tests/node-half.client.spec.ts

@@ -771,7 +771,7 @@ describe('client bundle activation', () => {
     expect((await routeRequest(route, batch.url, 'HEAD')).body).toHaveLength(0)
     expect((await routeRequest(route, batch.url, 'POST')).status).toBe(405)
     const batchMap = await routeRequest(route, mapUrl(batch.url))
-    const parsedBatchMap = JSON.parse(batchMap.body.toString('utf8')) as unknown
+    const parsedBatchMap: unknown = JSON.parse(batchMap.body.toString('utf8'))
     const parsedPluginMap = JSON.parse(map) as Record<string, unknown>
     expect(parsedBatchMap).toMatchObject({
       version: 3,
@@ -945,12 +945,13 @@ describe('shared module declarations', () => {
     const { service } = constructWithRoute([packageName])
     const row = service.graph().entries[0]
     if (row === undefined) throw new Error('shared-declared graph row missing')
+    const revisionMatcher: unknown = expect.any(String)
     // The browser resolves this reference against its own document; the
     // response table still answers the absolute route it resolves to.
     expect(row).toEqual({
       id: packageName,
       url: `plugins/??${packageName}/client.js&rev=${row.rev}`,
-      rev: expect.any(String) as unknown,
+      rev: revisionMatcher,
       external: ['react'],
     })
   })

packages/client/ui-attachment/src/AttachmentRail.tsx

@@ -32,7 +32,7 @@ const WHEEL_LINE_PX = 16
 function pageBehavior(): ScrollBehavior {
   // jsdom (the unit lane) implements no matchMedia despite lib.dom's
   // non-optional typing; the optional call keeps that lane on the default.
-  const matchMedia = (window as unknown as { matchMedia?: Window['matchMedia'] }).matchMedia
+  const matchMedia = (window as { matchMedia?: Window['matchMedia'] }).matchMedia
   return matchMedia?.('(prefers-reduced-motion: reduce)').matches ? 'auto' : 'smooth'
 }
 

packages/client/ui-chat/src/client/conversation-nodes/command.ts

@@ -80,7 +80,7 @@ function compactSource(event: Parameters<ConversationNodeDefinition['match']>[0]
   sourceCommandId?: CommandId
 } | undefined {
   if (event.type !== 'user/message' || !isReplacementSurfaceEvent(event)) return undefined
-  const source = event.data.source as unknown as {
+  const source = event.data.source as {
     kind?: unknown
     compactionId?: unknown
     sourceCommandId?: CommandId

packages/client/ui-chat/tests/assistant-markdown-path-images.client.spec.tsx

@@ -7,8 +7,8 @@ import type { AssistantBlock } from '../src/client/contract/snapshot.ts'
 
 afterEach(cleanup)
 
-const t = ((_key: string) => 'label') as unknown as ChatViewSlotProps['t']
-const renderMessageImages = (() => null) as unknown as ChatNodeOwnerProps['renderMessageImages']
+const t = ((_key: string) => 'label') as ChatViewSlotProps['t']
+const renderMessageImages = (() => null) as ChatNodeOwnerProps['renderMessageImages']
 
 function textBlock(text: string): AssistantBlock {
   return { kind: 'text', text }

packages/client/ui-chat/tests/chat-apply.client.spec.tsx

@@ -129,7 +129,7 @@ describe('Chat apply wiring', () => {
       b.runtime.slots.entries('conversation.composer.dock').find(entry => entry.options.id === 'stats')!,
       b.runtime.slots.entries('conversation.chat.node').find(entry => entry.options.key === 'turn-tail')!,
     ]) {
-      const injected = (entry.inject as unknown as () => Pick<PerformanceUsageRowInjected, 'hooks'>)()
+      const injected = (entry.inject as () => Pick<PerformanceUsageRowInjected, 'hooks'>)()
       expect(injected.hooks.performanceUsage).toBe(face.hooks.performanceUsage)
     }
     await b.runtime.dispose()

packages/client/ui-chat/tests/chat-view.client.spec.tsx

@@ -285,8 +285,8 @@ function makeHarness(
     inspectCall: ChatNodeOwnerProps['inspectCall']
   }> = []
   const renderCommandSlot = ((_key: string, _owner: object, opts?: { fallback?: React.ReactNode }) =>
-    opts?.fallback ?? null) as unknown as React.ComponentProps<typeof CommandNodeView>['renderSlot']
-  const renderTurnTailSlot = (() => null) as unknown as
+    opts?.fallback ?? null) as React.ComponentProps<typeof CommandNodeView>['renderSlot']
+  const renderTurnTailSlot = (() => null) as
     React.ComponentProps<typeof TurnTailNodeView>['renderSlot']
   let nodeSlotOverride: React.ComponentProps<typeof ChatNodeSeat>['renderSlot'] | undefined
   const renderNodeSlot = ((key: string, owner: object, opts?: {
@@ -367,7 +367,7 @@ function makeHarness(
       default:
         return opts?.fallback ?? null
     }
-  }) as unknown as React.ComponentProps<typeof ChatNodeSeat>['renderSlot']
+  }) as React.ComponentProps<typeof ChatNodeSeat>['renderSlot']
   const renderSlot = renderNodeSlot
   // SessionProvider seat arrives with the session-scope child declaration;
   // ChatView never invokes it (pass-through stub).
@@ -1244,7 +1244,7 @@ describe('ChatView', () => {
           data-first={JSON.stringify(images[0])}
         />
       )
-    }) as unknown as ChatViewSlotProps['renderSlot']
+    }) as ChatViewSlotProps['renderSlot']
     const view = render(<h.ChatView {...{ ...h.props, renderSlot }} />)
     const images = view.getAllByTestId('echo-image')
     expect(images).toHaveLength(2)
@@ -1289,7 +1289,7 @@ describe('ChatView', () => {
           data-compact={String(compact)}
         />
       )
-    }) as unknown as ChatViewSlotProps['renderSlot']
+    }) as ChatViewSlotProps['renderSlot']
     const view = render(<h.ChatView {...{ ...h.props, renderSlot }} />)
     const first = view.getByTestId('images-first.png')
     const file = view.getByTitle('notes.txt')

packages/client/ui-chat/tests/partial.client.spec.ts

@@ -7,7 +7,7 @@ import { describe, expect, it } from 'vitest'
 import type { StreamChunk } from '@deepseek-ai/dsh-api-remotes/client'
 import { PartialAccumulator } from '../src/client/conversation-nodes/partial.ts'
 
-const chunk = (c: Record<string, unknown>): StreamChunk => c as unknown as StreamChunk
+const chunk = (c: Record<string, unknown>): StreamChunk => c as StreamChunk
 
 describe('PartialAccumulator', () => {
   it('builds empty blocks per block-start type, unknown type falls to other', () => {

packages/client/ui-commands/tests/service.client.spec.ts

@@ -839,7 +839,7 @@ describe('execute payload', () => {
     const after = vi.fn()
     const warn = vi.spyOn(b.ctx.logger, 'warn').mockImplementation(() => undefined)
     b.ctx.on('command/executed', () => { throw syncFailure })
-    const rejectingListener = (() => Promise.reject(asyncFailure)) as unknown as () => void
+    const rejectingListener = (() => Promise.reject(asyncFailure)) as () => void
     b.ctx.on('command/executed', rejectingListener)
     b.ctx.on('command/executed', after)
 

packages/client/ui-conversation/src/client/conversation/assembly.ts

@@ -69,7 +69,7 @@ class BoundConversation implements ConversationBinding {
   ): ObservableSnapshot<ConversationViewSnapshotMap[Target] | undefined> {
     let source = this.targetSources.get(target)
     if (source === undefined) {
-      const views = this.viewStore as unknown as { get(key: string): unknown }
+      const views = this.viewStore as { get(key: string): unknown }
       source = {
         getSnapshot: () => views.get(target),
         subscribe: (listener) => {

packages/client/ui-conversation/tests/queue-dock.client.spec.tsx

@@ -102,7 +102,7 @@ function kitFor(snapshot: SessionSnapshot, injected: Partial<QueueDockInjected>
     sessionId: SID,
     t,
     usePanelInfo,
-    useSessions: (() => { throw new Error('unused') }) as unknown as SnapshotSelectorHook<SessionListState>,
+    useSessions: (() => { throw new Error('unused') }) as SnapshotSelectorHook<SessionListState>,
     useSessionRetainInfo: () => undefined,
     useResource,
     useSessionStatus: bindSnapshotSelector(

packages/client/ui-deliverables/tests/deliverables.client.spec.tsx

@@ -745,7 +745,7 @@ describe('plugin registration', () => {
       3,
       (path) => { opened.push(path) },
     )
-    const service = (ctx as unknown as { get(name: string): ChatFileMentions | undefined }).get('chatFileMentions')
+    const service = (ctx as { get(name: string): ChatFileMentions | undefined }).get('chatFileMentions')
     const mentions = service?.forClosing(owner, SessionId('viewed-session'))
     expect(mentions?.resolve('report.html')?.label).toBe('Open site/report.html in sidebar')
     mentions?.resolve('report.html')?.open()
@@ -813,7 +813,7 @@ describe('plugin registration', () => {
     expect(ctx.slots.entries('sidebar.right.pane.tab')).toHaveLength(0)
     expect(registered).toBeUndefined()
     // Fiber teardown retracts the service: the consumer's ctx.get sees the off state.
-    expect((ctx as unknown as { get(name: string): unknown }).get('chatFileMentions')).toBeUndefined()
+    expect((ctx as { get(name: string): unknown }).get('chatFileMentions')).toBeUndefined()
   })
 })
 

packages/client/ui-message-feedback/tests/feedback-dialog.client.spec.tsx

@@ -36,7 +36,7 @@ function mount(overrides: Partial<FeedbackDialogState> = {}) {
   }
   const useDialog = (<T,>(select: (v: FeedbackDialogState) => T): T =>
     useSyncExternalStore(() => () => {}, () => select(state))) as never
-  const props = { useDialog, ...verbs, t } as unknown as Parameters<typeof FeedbackDialog>[0]
+  const props = { useDialog, ...verbs, t } as Parameters<typeof FeedbackDialog>[0]
   return { ...render(<FeedbackDialog {...props} />), ...verbs }
 }
 

packages/client/ui-permission-presets/src/client/settings-store.ts

@@ -61,7 +61,7 @@ export function permissionDefaultOf(view: SettingsNamespaceView, schema: Setting
     ? (node.list as SchemaNode[] | undefined) ?? []
     : [node]
   const options = rawChoices.flatMap((candidate) => {
-    const choice = candidate as unknown as ConstChoice
+    const choice = candidate as ConstChoice
     if (choice.type !== 'const' || typeof choice.value !== 'string') return []
     const described = choice.meta?.description
     return [{

packages/client/ui-plan/tests/plan-preview.client.spec.tsx

@@ -176,14 +176,14 @@ describe('plan entry points and document', () => {
     fireEvent.click(screen.getByRole('button', { name: 'Open plan in sidebar' }))
     expect(openReview).toHaveBeenCalledTimes(2)
     const revised = { plan: '# Revised', ...(logged ? { callId: 'call:2' } : {}) }
-    second.rerender(<PlanReviewOpen {...{ ...props, review: revised, requestKey: 'question:2' } as unknown as Parameters<typeof PlanReviewOpen>[0]} />)
+    second.rerender(<PlanReviewOpen {...{ ...props, review: revised, requestKey: 'question:2' } as Parameters<typeof PlanReviewOpen>[0]} />)
     expect(openReview).toHaveBeenLastCalledWith(revised, 'question:2')
     expect(openReview).toHaveBeenCalledTimes(3)
     second.unmount()
     const other = createPlanReviewStore().create()
     render(<PlanReviewOpen {...{ ...props, actions: other.actions,
       useStore: (select: (state: ReturnType<typeof other.getSnapshot>) => unknown) => select(other.getSnapshot()),
-    } as unknown as Parameters<typeof PlanReviewOpen>[0]} />)
+    } as Parameters<typeof PlanReviewOpen>[0]} />)
     expect(openReview).toHaveBeenCalledTimes(4)
   })
   it('renders temporary Markdown and reports expired navigation after reload', () => {

packages/client/ui-renderer/src/client/registry.ts

@@ -487,7 +487,7 @@ export class SlotRegistry extends Service {
     // Core write first: all load-time validation (undeclared target,
     // duplicate declaration, kind conflicts, cross-scope handle) throws
     // there before this layer commits anything.
-    const dispose = (this._core as unknown as ErasedCore).register(erased, component)
+    const dispose = (this._core as ErasedCore).register(erased, component)
     if (store !== undefined) {
       const scope = (this._core.specDynamic(options.name) as SlotSpec<SlotEntryDef>).scope
       this._acquire(store, scope)
@@ -507,7 +507,7 @@ export class SlotRegistry extends Service {
       ...options,
       ...(registrant === undefined ? {} : { registrant }),
     }
-    const dispose = (this._core as unknown as ErasedFactoryCore).registerFactory(erased, component)
+    const dispose = (this._core as ErasedFactoryCore).registerFactory(erased, component)
     const definition = this._core.factory(options.name)
     if (definition === undefined) throw new Error(`slot factory "${options.name}" disappeared during registration`)
     if (definition.store !== undefined && typeof definition.store !== 'function') {
@@ -551,7 +551,7 @@ export class SlotRegistry extends Service {
       storeOf: (entry, scopeBinding) =>
         entry.store === undefined
           ? undefined
-          : this.resolveStore(entry.store as unknown as EngineStoreHandle, scopeBinding),
+          : this.resolveStore(entry.store as EngineStoreHandle, scopeBinding),
       factoryStoreOf: (definition, scopeBinding, occurrence) =>
         this.resolveFactoryStore(definition, scopeBinding, occurrence),
       retainFactoryOccurrence: (definition, occurrence) =>

packages/client/ui-renderer/tests/factory-slots.client.spec.tsx

@@ -346,8 +346,8 @@ describe('Factory rendering', () => {
     const view = runtime.renderRoot()
     expect(view.container.textContent).toBe('selected')
     if (retainedRender === undefined || retainedChain === undefined) throw new Error('Factory child bindings are missing')
-    const render = retainedRender as unknown as (key: string, owner: object) => ReactNode
-    const renderChain = retainedChain as unknown as (key: string, owner: object) => ReactNode
+    const render = retainedRender as (key: string, owner: object) => ReactNode
+    const renderChain = retainedChain as (key: string, owner: object) => ReactNode
     expect(() => render('renderer.factory.chain', {})).toThrow(/use renderSlotChain/)
     expect(() => renderChain('renderer.factory.child', {})).toThrow(/not 'chain'/)
     dispose()

packages/client/ui-renderer/tests/invariant.client.spec.ts

@@ -28,7 +28,7 @@ describe('renderer slots/changed invariant', () => {
     // A real registration bumps the version first and re-emits through
     // onMutate — the audit sees version > 0 and stays quiet. (Erased call:
     // the typed register face rides the wave-1 ui-slots types.)
-    const slots = ctx.slots as unknown as { register(options: object, component: unknown): () => void }
+    const slots = ctx.slots as { register(options: object, component: unknown): () => void }
     expect(() => slots.register({ name: 'root' }, () => null)).not.toThrow()
   })
 

packages/client/ui-renderer/tests/registry.client.spec.ts

@@ -50,7 +50,7 @@ async function boot(): Promise<Bench> {
   // Service accessor (ctx.get reads the reflect store, which Service-class
   // plugins do not write; the accessor is the product path).
   const svc = ctx.slots
-  return { ctx, svc, erased: svc as unknown as ErasedService }
+  return { ctx, svc, erased: svc }
 }
 
 /** Engine-shaped instance stub (bare-source form: subscribe/getSnapshot + baked actions + clearPersisted). */
@@ -910,7 +910,7 @@ describe('entry-unload cascade', () => {
       name: 'occupant',
       inject: ['slots'],
       apply: (pluginCtx: Context) => {
-        ;(pluginCtx.slots as unknown as ErasedService).register({ name: 't.host' }, C)
+        ;(pluginCtx.slots as ErasedService).register({ name: 't.host' }, C)
       },
     })
     await fiber.await()

packages/client/ui-session/tests/ui-session.client.spec.ts

@@ -723,12 +723,13 @@ describe('ui-session apply', () => {
     apply(ctx)
 
     expect(ctx.uiSession).toBeInstanceOf(UiSession)
+    const retainInfoMatcher: unknown = expect.any(Function)
     expect(slots.provideRoot).toHaveBeenCalledWith({
       hooks: {
         sessions: bench.sessions.list,
         sessionStatus: ctx.uiSession.sessionStatus,
       },
-      keyedHooks: { sessionRetainInfo: expect.any(Function) as unknown },
+      keyedHooks: { sessionRetainInfo: retainInfoMatcher },
     })
     expect(slots.installScope).toHaveBeenCalledWith('session', ctx.uiSession.adapter)
     const root = slots.provideRoot.mock.calls[0]![0] as RootStandardSourceContribution

packages/client/ui-settings-models/tests/apply.client.spec.ts

@@ -230,13 +230,13 @@ describe('pushed invalidations', () => {
       store: { getSnapshot: () => ({ status: 'ready' }) },
       load: () => { loads.push(1); return Promise.resolve() },
     }
-    refreshIfLoaded(controller as unknown as import('../src/client/store.ts').ModelsSettingsStore)
+    refreshIfLoaded(controller as import('../src/client/store.ts').ModelsSettingsStore)
     expect(loads).toHaveLength(1)
     const idle = {
       store: { getSnapshot: () => ({ status: 'idle' }) },
       load: () => { loads.push(2); return Promise.resolve() },
     }
-    refreshIfLoaded(idle as unknown as import('../src/client/store.ts').ModelsSettingsStore)
+    refreshIfLoaded(idle as import('../src/client/store.ts').ModelsSettingsStore)
     expect(loads).toHaveLength(1)
   })
 

packages/client/ui-settings-models/tests/provider-form.client.spec.tsx

@@ -181,7 +181,7 @@ interface MutateCall {
 
 /** The latest interrogation payload; fails the case when nothing was asked. */
 function lastProbe(discover: ReturnType<typeof vi.fn>): unknown {
-  const call = (discover.mock.calls as unknown as [string, Record<string, unknown>][]).at(-1)
+  const call = (discover.mock.calls as [string, Record<string, unknown>][]).at(-1)
   if (call === undefined) throw new Error('no interrogation was recorded')
   return { settingsNs: call[0], ...call[1] }
 }

packages/client/ui-settings/src/client/schema.ts

@@ -59,7 +59,7 @@ export class SettingsSchemaService extends Service {
    */
   validate(schema: SchemaNode, draft: unknown): string | undefined {
     try {
-      ;(schema as unknown as (value: unknown) => unknown)(draft)
+      ;(schema as (value: unknown) => unknown)(draft)
       return undefined
     } catch (error) {
       return error instanceof Error ? error.message : String(error)

packages/client/ui-sidebar-documentpreview/tests/document-toolbar.client.spec.tsx

@@ -174,8 +174,9 @@ describe('document toolbar', () => {
     const renderSlot = vi.fn(() => null)
     view.rerender(<TextPreview {...h.props()} useDocumentPreviews={selector => selector([{ ...binary, loading: 'renderer' }])} renderSlot={renderSlot} />)
     expect(view.container.textContent).not.toContain('previous reader content')
+    const rendererContentMatcher: unknown = expect.objectContaining({ kind: 'renderer' })
     expect(renderSlot).toHaveBeenCalledWith('sidebar.right.tab.document', expect.objectContaining({
-      content: expect.objectContaining({ kind: 'renderer' }) as unknown,
+      content: rendererContentMatcher,
     }), expect.any(Object))
     expect(h.instance.getSnapshot().byTab[TAB_ID]?.complete).toBeUndefined()
     expect(h.bytes).not.toHaveBeenCalled()

packages/client/ui-skill/src/client/SkillRow.tsx

@@ -28,7 +28,7 @@ function firstLine(text: string): string {
 /** Skill names are the only call argument the compact row presents. */
 function skillName(argsRaw: string, callId: string): string {
   try {
-    const parsed = JSON.parse(argsRaw) as unknown
+    const parsed: unknown = JSON.parse(argsRaw)
     if (typeof parsed === 'object' && parsed !== null) {
       const name = (parsed as Record<string, unknown>).name
       if (typeof name === 'string' && name !== '') return firstLine(name)

packages/client/ui-slots/tests/core.client.spec.ts

@@ -86,7 +86,7 @@ describe('lifecycle cascade (one axis)', () => {
     core.onMutate((key) => {
       if (key === 'test.single') observed.push(core.specDynamic('test.session'))
     })
-    const registerFactory = core.registerFactory as unknown as (
+    const registerFactory = core.registerFactory as (
       options: object,
       component: unknown,
     ) => () => void

packages/client/ui-trajectory/src/client/trajectory-compaction-definition.ts

@@ -16,7 +16,7 @@ function checkpointId(
   event: Parameters<ConversationNodeDefinition['match']>[0],
 ): string | undefined {
   if (event.type !== 'user/message') return undefined
-  const source = event.data.source as unknown as {
+  const source = event.data.source as {
     readonly kind?: unknown
     readonly plugin?: unknown
     readonly compactionId?: unknown

packages/client/ui-trajectory/tests/views.client.spec.tsx

@@ -457,7 +457,7 @@ describe('plugin registration', () => {
 
     expect(resolveSource(binding)).toBe(source)
     expect(resolveSource(binding)).toBe(source)
-    const optionalTrajectory = b.trajectoryStore as unknown as {
+    const optionalTrajectory = b.trajectoryStore as {
       set(value: TrajectorySnapshot | undefined): void
     }
     optionalTrajectory.set(undefined)

packages/client/web/tests/boot.client.spec.ts

@@ -15,7 +15,7 @@ const win = globalThis as DshWindow
 const transportGlobal = globalThis as {
   __DSH_TRANSPORT__?: { loadBundle(url: string): Promise<void> }
 }
-const moduleFace = modulesClient as unknown as Record<string, unknown>
+const moduleFace = modulesClient as Record<string, unknown>
 
 afterEach(() => {
   vi.restoreAllMocks()

packages/compaction/compaction-basic/tests/loader-composition.spec.ts

@@ -86,7 +86,7 @@ describe('real Loader composition', () => {
     expect(unloaded).toEqual([])
     expect(loaded.get('toolResultPruner')).toBeInstanceOf(ToolResultPruner)
     expect(loaded.get('compaction')).toBeInstanceOf(BasicCompactionEngine)
-    expect((loaded.compaction as unknown as BasicCompactionEngine).config).toMatchObject({
+    expect((loaded.compaction as BasicCompactionEngine).config).toMatchObject({
       thresholdRatio: 0.5,
       headroomTokens: 4000,
       modelPolicies: [{ provider: 'mock', model: 'small', headroomTokens: 0, maxTokens: 32 }],

packages/core/scope/tests/scope.spec.ts

@@ -207,7 +207,7 @@ describe('scope parent chain', () => {
     agentScope.ctx.on('probe/event' as never, ((): void => { seen.push('agent') }) as never)
     otherScope.ctx.on('probe/event' as never, ((): void => { seen.push('other') }) as never)
 
-    const emit = ctx as unknown as { emit: (carrier: object, type: string) => void }
+    const emit = ctx as { emit: (carrier: object, type: string) => void }
     // Dispatch at the AGENT key: its own tag and its ancestor's admit; a
     // sibling root does not.
     emit.emit(scopeTarget({}, agent), 'probe/event')

packages/core/session/tests/repair.spec.ts

@@ -14,7 +14,7 @@ interface SessionEvent {
 
 function interruptedTurnClosers(events: readonly SessionEvent[]): LogicalSessionEvent[] {
   for (const event of events) SessionSeq(event.seq)
-  return repairInterruptedTurn(events as unknown as readonly LogicalSessionEvent[])
+  return repairInterruptedTurn(events as readonly LogicalSessionEvent[])
 }
 
 function openTurnClosers(events: readonly SessionEvent[], cause: OpenTurnCloseCause): LogicalSessionEvent[] {

packages/core/session/tests/session.spec.ts

@@ -270,14 +270,14 @@ describe('Session', () => {
       data: { header: { config: { provider: 'mock', model: 'model' } }, reason: 'initial' },
     } as const
     for (const reason of ['fallback', 'unknown', null]) {
-      const invalid = structuredClone(base) as unknown as SessionEvent
+      const invalid = structuredClone(base) as SessionEvent
       if (invalid.type !== 'request/header') throw new Error('test fixture must be a request header')
       invalid.data.reason = reason as never
       expect(() => Session.create(SessionId('invalid-header-reason'), [invalid]))
         .toThrow('seed request/header at index 0 has an invalid reason')
     }
     for (const startsSeries of [false, 1, 'true']) {
-      const invalid = structuredClone(base) as unknown as SessionEvent
+      const invalid = structuredClone(base) as SessionEvent
       if (invalid.type !== 'request/header') throw new Error('test fixture must be a request header')
       invalid.data.startsSeries = startsSeries as never
       expect(() => Session.create(SessionId('invalid-series-marker'), [invalid]))
@@ -543,7 +543,7 @@ describe('Session', () => {
       .toEqual(valid)
 
     for (const reasoningEffort of ['', 1]) {
-      const invalid = structuredClone(valid) as unknown as SessionEvent
+      const invalid = structuredClone(valid) as SessionEvent
       if (invalid.type !== 'request/header') throw new Error('test fixture must be a request header')
       const config = invalid.data.header.config as unknown as Record<string, unknown>
       config.reasoningEffort = reasoningEffort
@@ -578,7 +578,7 @@ describe('Session', () => {
       { maxTokens: false },
       { reasoningEffort: true },
     ]) {
-      const invalid = structuredClone(valid) as unknown as SessionEvent
+      const invalid = structuredClone(valid) as SessionEvent
       if (invalid.type !== 'request/header') throw new Error('test fixture must be a request header')
       invalid.data.header.adapterDefaults = adapterDefaults as never
       expect(() => Session.create(SessionId('invalid-adapter-defaults'), [invalid]))

packages/core/tools/src/schema.ts

@@ -575,11 +575,11 @@ export function defineTool<const S extends ParameterSchemaSpec, const O extends
     output: {
       schema: outputSchema,
       render(args: unknown, value: JsonValue): ContentBlock[] {
-        return userRender(args as InferArgs<S>, value as unknown as InferValue<NoInfer<O>>)
+        return userRender(args as InferArgs<S>, value as InferValue<NoInfer<O>>)
       },
       ...userPresentationMeta !== undefined ? {
         presentationMeta(args: unknown, value: JsonValue): JsonValue {
-          return userPresentationMeta(args as InferArgs<S>, value as unknown as InferValue<NoInfer<O>>)
+          return userPresentationMeta(args as InferArgs<S>, value as InferValue<NoInfer<O>>)
         },
       } : {},
     },

packages/core/tools/tests/json-schema.spec.ts

@@ -231,13 +231,13 @@ describe('the enforced raw JSON Schema subset', () => {
   })
 
   it('accepts lossless annotation containers from another JavaScript realm', () => {
-    const schema = runInNewContext(`({
+    const schema: unknown = runInNewContext(`({
       type: 'object',
       properties: { value: { type: 'string', enum: ['x'] } },
       required: ['value'],
       default: { x: 1 },
       examples: [[{ ok: true }]],
-    })`) as unknown
+    })`)
 
     expect(() => { assertSupportedJsonSchema(schema) }).not.toThrow()
   })

packages/core/tools/tests/tools.spec.ts

@@ -351,10 +351,10 @@ describe('ToolRuntime', () => {
       output: {
         schema: { type: 'string' },
         render: () => projector === 'render'
-          ? hostile as unknown as ContentBlock[]
+          ? hostile as ContentBlock[]
           : [{ type: 'text', text: 'ok' }],
         presentationMeta: () => projector === 'presentationMeta'
-          ? hostile as unknown as JsonValue
+          ? hostile as JsonValue
           : null,
       },
       execute: async () => 'ok',

packages/experimental/inspector/src/client/bridge/transport.ts

@@ -156,7 +156,7 @@ export class ClientInspectorSource extends InspectorSourceConnection {
         if (new TextEncoder().encode(event.data).byteLength > this.bootstrap.maxFrameBytes) {
           throw new Error(`inspector protocol: Worker frame exceeds ${String(this.bootstrap.maxFrameBytes)} bytes`)
         }
-        const value = JSON.parse(event.data) as unknown
+        const value: unknown = JSON.parse(event.data)
         if (this.queries.receive(value)) return
         const frame = parseWorkerSourceFrame(value)
         if (frame.t !== 'source/rejected'

packages/experimental/inspector/src/client/cdp/console.ts

@@ -125,8 +125,8 @@ export class ClientConsoleObserver {
   }
 
   private readonly onError = (event: Event): void => {
-    const error = Reflect.get(event, 'error') as unknown
-    const message = Reflect.get(event, 'message') as unknown
+    const error: unknown = Reflect.get(event, 'error')
+    const message: unknown = Reflect.get(event, 'message')
     this.captureException(error ?? new Error(typeof message === 'string' ? message : 'Client error'))
   }
 
@@ -166,11 +166,11 @@ export class ClientConsoleObserver {
 }
 
 function addGlobalListener(type: string, listener: EventListener): void {
-  const add = Reflect.get(globalThis, 'addEventListener') as unknown
+  const add: unknown = Reflect.get(globalThis, 'addEventListener')
   if (typeof add === 'function') Reflect.apply(add, globalThis, [type, listener])
 }
 
 function removeGlobalListener(type: string, listener: EventListener): void {
-  const remove = Reflect.get(globalThis, 'removeEventListener') as unknown
+  const remove: unknown = Reflect.get(globalThis, 'removeEventListener')
   if (typeof remove === 'function') Reflect.apply(remove, globalThis, [type, listener])
 }

packages/experimental/inspector/src/client/cdp/objects.ts

@@ -212,7 +212,7 @@ function serializeByValue(value: unknown): InspectorJsonValue {
     throw new ClientRuntimeExecutionError('unsupported', `Value cannot be returned by value: ${renderError(error)}`)
   }
   if (typeof serialized !== 'string') throw new ClientRuntimeExecutionError('unsupported', 'Value cannot be returned by value')
-  const result = JSON.parse(serialized) as unknown
+  const result: unknown = JSON.parse(serialized)
   if (!isJsonValue(result)) throw new ClientRuntimeExecutionError('unsupported', 'Value is outside the JSON value set')
   return result
 }

packages/experimental/inspector/src/client/cdp/runtime.ts

@@ -365,7 +365,7 @@ class ClientRuntimeSession {
     const args = (command.arguments ?? []).map(argument => this.resolveArgument(argument))
     let value: unknown
     try {
-      const fn = globalThis.eval(`(${command.functionDeclaration}\n)`) as unknown
+      const fn: unknown = globalThis.eval(`(${command.functionDeclaration}\n)`)
       if (typeof fn !== 'function') throw new TypeError('functionDeclaration did not evaluate to a function')
       value = Reflect.apply(fn, receiver, args)
       if (command.awaitPromise === true) value = await awaitWithCancellation(value, signal)
@@ -460,9 +460,9 @@ function parseUnserializable(value: string): unknown {
 }
 
 function clientUrl(): { readonly url?: string } {
-  const location = Reflect.get(globalThis, 'location') as unknown
+  const location: unknown = Reflect.get(globalThis, 'location')
   if (typeof location !== 'object' || location === null) return {}
-  const href = Reflect.get(location, 'href') as unknown
+  const href: unknown = Reflect.get(location, 'href')
   return typeof href === 'string' ? { url: href } : {}
 }
 

packages/experimental/inspector/src/client/cdp/sources.ts

@@ -172,9 +172,9 @@ export class ClientSourceCatalog {
  * @returns A lazy catalog, or `undefined` outside the assembled web application.
  */
 export function discoverInspectorClientSourceCatalog(): ClientSourceCatalog | undefined {
-  const graph = Reflect.get(globalThis, '__DSH_BOOT__') as unknown
+  const graph: unknown = Reflect.get(globalThis, '__DSH_BOOT__')
   if (typeof graph !== 'object' || graph === null) return undefined
-  const entries = Reflect.get(graph, 'entries') as unknown
+  const entries: unknown = Reflect.get(graph, 'entries')
   if (!Array.isArray(entries)) return undefined
   const row = entries.find((value) => {
     if (typeof value !== 'object' || value === null) return false
@@ -208,14 +208,14 @@ async function fetchText(url: string): Promise<string> {
  * `baseURI`, else the location URL, else undefined outside a browser.
  */
 function documentBase(): string | undefined {
-  const document = Reflect.get(globalThis, 'document') as unknown
+  const document: unknown = Reflect.get(globalThis, 'document')
   if (typeof document === 'object' && document !== null) {
-    const baseURI = Reflect.get(document, 'baseURI') as unknown
+    const baseURI: unknown = Reflect.get(document, 'baseURI')
     if (typeof baseURI === 'string' && baseURI !== '') return baseURI
   }
-  const location = Reflect.get(globalThis, 'location') as unknown
+  const location: unknown = Reflect.get(globalThis, 'location')
   if (typeof location !== 'object' || location === null) return undefined
-  const href = Reflect.get(location, 'href') as unknown
+  const href: unknown = Reflect.get(location, 'href')
   return typeof href === 'string' ? href : undefined
 }
 

packages/experimental/inspector/src/client/inspection/realm.ts

@@ -119,8 +119,8 @@ function tryClaimSourceId(
 }
 
 function clientOrigin(): string {
-  const location = Reflect.get(globalThis, 'location') as unknown
+  const location: unknown = Reflect.get(globalThis, 'location')
   if (typeof location !== 'object' || location === null) return ''
-  const origin = Reflect.get(location, 'origin') as unknown
+  const origin: unknown = Reflect.get(location, 'origin')
   return typeof origin === 'string' ? origin : ''
 }

packages/experimental/inspector/src/shared/cordis/object-registry.ts

@@ -168,7 +168,7 @@ export function identifyRealmObject(value: unknown): InspectorObjectReference |
 
 function registries(): Map<InspectorObjectRegistryId, RealmObjectRegistry> {
   const key = Symbol.for(REGISTRIES_SYMBOL)
-  const existing = Reflect.get(globalThis, key) as unknown
+  const existing: unknown = Reflect.get(globalThis, key)
   if (existing instanceof Map) return existing as Map<InspectorObjectRegistryId, RealmObjectRegistry>
   const value = new Map<InspectorObjectRegistryId, RealmObjectRegistry>()
   Reflect.set(globalThis, key, value)

packages/experimental/inspector/src/worker/bridge/endpoint.ts

@@ -188,7 +188,7 @@ export class InspectorEndpoint {
     this.ingestConnections.set(socket, connection)
     socket.on('message', (data) => {
       try {
-        const value = JSON.parse(rawText(data)) as unknown
+        const value: unknown = JSON.parse(rawText(data))
         if (!queryPeer.receive(value)) this.sources.receive(connection, value)
       } catch {
         connection.close(1008, 'source frame must be JSON')

packages/experimental/inspector/src/worker/entry.ts

@@ -9,7 +9,7 @@ import { startInspectorWorker } from './server.ts'
 if (parentPort === null) throw new Error('experimental inspector: Worker entry loaded on the main thread')
 const controlPort = parentPort
 
-const bootData = workerData as unknown
+const bootData: unknown = workerData
 if (!isPlainObject(bootData)
   || !(bootData.hostSourcePort instanceof MessagePort)) {
   throw new Error('experimental inspector: invalid Worker boot data')

packages/experimental/inspector/src/worker/realms/host/bridge.ts

@@ -19,7 +19,7 @@ interface DynamicInspectorSession {
 
 /** Connection-local carrier for requests and notifications from the Host V8 inspector. */
 export class HostInspectorSession {
-  private readonly session = new Session() as unknown as DynamicInspectorSession
+  private readonly session = new Session() as DynamicInspectorSession
   private readonly listeners = new Set<(message: HostInspectorNotification) => void>()
   private connected = false
   private failure: string | undefined

packages/experimental/inspector/tests/cordis-tree.host.spec.ts

@@ -291,7 +291,7 @@ describe('Cordis tree inspection', () => {
     const runtimeFiber = fiber.ctx.fiber
     const uidDescriptor = Object.getOwnPropertyDescriptor(runtimeFiber, 'uid')
     Object.defineProperty(runtimeFiber, 'uid', { ...uidDescriptor, value: null })
-    const hooks = root.events._hooks as unknown as Record<PropertyKey, Array<{ ctx: unknown }> | undefined>
+    const hooks = root.events._hooks as Record<PropertyKey, Array<{ ctx: unknown }> | undefined>
     const probe = Symbol('inspector-collector-probe')
     const empty = Symbol('inspector-collector-empty')
     const shadow = Object.create(root) as object

packages/experimental/inspector/tests/shared-validation.host.spec.ts

@@ -27,7 +27,7 @@ describe('Inspector JSON values', () => {
     cyclic.self = cyclic
     const arrayWithField = [1]
     Reflect.set(arrayWithField, 'extra', true)
-    const inheritedArray = Object.setPrototypeOf([1], null) as unknown
+    const inheritedArray: unknown = Object.setPrototypeOf([1], null)
     const symbolObject = { [Symbol('field')]: true }
     const hidden = {}
     Object.defineProperty(hidden, 'value', { value: 1, enumerable: false })

packages/experimental/ptc-runtime-python/src/index.ts

@@ -1986,7 +1986,7 @@ export class PythonPtcRuntime extends PtcRuntime {
       // that reads fd 3 continuously, so arrival order was never observable,
       // and the bindings themselves still run concurrently. Only the host's peak
       // memory and the flush timing change.
-      const replyQueue: ReplyMessage[] = []
+      const replyQueue: (ReplyMessage | undefined)[] = []
       // Replies queued but not yet written, tracked separately from
       // `replyQueue.length`: the drain loop clears consumed slots to `undefined`
       // but does not shrink the array until it finishes, so `length` counts
@@ -2050,7 +2050,7 @@ export class PythonPtcRuntime extends PtcRuntime {
             // in `replyQueue` for the whole busy period, making host memory grow
             // with cumulative processing rather than the current backlog.
             const payload = replyQueue[head] as ReplyMessage
-            replyQueue[head] = undefined as unknown as ReplyMessage
+            replyQueue[head] = undefined
             head += 1
             pendingReplies -= 1
             // Compact the consumed prefix once it reaches the backlog bound:

packages/experimental/ptc-runtime-python/tests/protocol.spec.ts

@@ -297,7 +297,7 @@ describe('checkDoneValue', () => {
   it('emits exact digits for beyond-safe integral doubles', () => {
     // String(2**60) prints the ROUNDED ...847000; echoing that to the child
     // would change the integer. BigInt digits give the exact ...846976.
-    const v = JSON.parse('[1152921504606846976]') as unknown
+    const v: unknown = JSON.parse('[1152921504606846976]')
     expect(encodeJsonPlain(v)).toBe('[1152921504606846976]')
     expect(checkDoneValue(v, 100)).toEqual({ ok: true, bytes: Buffer.byteLength('[1152921504606846976]', 'utf8') })
   })

packages/experimental/ptc-runtime-python/tests/runtime.spec.ts

@@ -1260,7 +1260,7 @@ describe('PythonPtcRuntime — programs and bindings', () => {
           cyclic.self = cyclic
           const error = new Error('placeholder')
           // Writable per spec, so no cast is needed to install a non-string.
-          ;(error as unknown as { message: unknown }).message = cyclic
+          ;(error as { message: unknown }).message = cyclic
           throw error
         },
       }),
@@ -1289,7 +1289,7 @@ describe('PythonPtcRuntime — programs and bindings', () => {
       bindings: tools({
         absent: async () => {
           const error = new Error('placeholder')
-          ;(error as unknown as { message: unknown }).message = undefined
+          ;(error as { message: unknown }).message = undefined
           throw error
         },
       }),

packages/experimental/webworker-runtime/src/node/builtin_modules/implemented/child_process.ts

@@ -215,7 +215,7 @@ export function spawn(
   if (typeof program !== 'string' || program === '') {
     // Node refuses a non-string command with this error rather than starting
     // anything; a caller whose own lookup produced nothing reads why.
-    const invalid = new TypeError(`The "file" argument must be a non-empty string. Received ${program as unknown as string}`) as NodeJS.ErrnoException
+    const invalid = new TypeError(`The "file" argument must be a non-empty string. Received ${program as string}`) as NodeJS.ErrnoException
     invalid.code = 'ERR_INVALID_ARG_TYPE'
     throw invalid
   }

packages/experimental/webworker-runtime/src/node/builtin_modules/implemented/fs-watch.ts

@@ -283,12 +283,12 @@ type RefTimer = { ref?: () => unknown; unref?: () => unknown }
 
 /** Browser timers are numeric; Node timers expose optional liveness methods. */
 const timerRef = (timer: ReturnType<typeof setTimeout>): void => {
-  ;(timer as unknown as RefTimer).ref?.()
+  ;(timer as RefTimer).ref?.()
 }
 
 /** Browser timers are numeric; Node timers expose optional liveness methods. */
 const timerUnref = (timer: ReturnType<typeof setTimeout>): void => {
-  ;(timer as unknown as RefTimer).unref?.()
+  ;(timer as RefTimer).unref?.()
 }
 
 const statWatchers = new Map<string, StatWatcher>()

packages/experimental/webworker-runtime/src/node/builtin_modules/implemented/stream.ts

@@ -28,7 +28,7 @@ const {
   Duplex, PassThrough, Readable, Stream: StreamBase, Transform, Writable,
   addAbortSignal, compose, destroy, finished, isDisturbed, isErrored, isReadable, pipeline, promises,
 } = nodeStream
-const streamStatics = StreamBase as unknown as StreamStatics
+const streamStatics = StreamBase as StreamStatics
 const {
   getDefaultHighWaterMark, isDestroyed, isWritable, setDefaultHighWaterMark,
 } = streamStatics

packages/experimental/webworker-runtime/src/node/builtin_modules/implemented/util.ts

@@ -31,7 +31,7 @@ export function callbackify<A extends unknown[], R>(
 ): (...args: [...A, (error: unknown, value?: R) => void]) => void {
   return (...args) => {
     const callback = args.at(-1) as (error: unknown, value?: R) => void
-    const rest = args.slice(0, -1) as unknown as A
+    const rest = args.slice(0, -1) as A
     fn(...rest).then((value) => { callback(null, value) }, (error: unknown) => { callback(error) })
   }
 }

packages/experimental/webworker-runtime/src/node/globals/timers.ts

@@ -53,11 +53,11 @@ const wrapClear = (clear: Clear): ((handle?: unknown) => void) =>
 
 /** Replace the worker's timer globals with the Node-shaped wrappers. */
 export function installTimerGlobals(): void {
-  const scope = globalThis as unknown as Record<string, unknown>
-  const setTimeoutRaw = globalThis.setTimeout.bind(globalThis) as unknown as Scheduler
-  const setIntervalRaw = globalThis.setInterval.bind(globalThis) as unknown as Scheduler
-  const clearTimeoutRaw = globalThis.clearTimeout.bind(globalThis) as unknown as Clear
-  const clearIntervalRaw = globalThis.clearInterval.bind(globalThis) as unknown as Clear
+  const scope = globalThis as Record<string, unknown>
+  const setTimeoutRaw = globalThis.setTimeout.bind(globalThis) as Scheduler
+  const setIntervalRaw = globalThis.setInterval.bind(globalThis) as Scheduler
+  const clearTimeoutRaw = globalThis.clearTimeout.bind(globalThis) as Clear
+  const clearIntervalRaw = globalThis.clearInterval.bind(globalThis) as Clear
   scope.setTimeout = wrapScheduler(setTimeoutRaw)
   scope.setInterval = wrapScheduler(setIntervalRaw)
   scope.clearTimeout = wrapClear(clearTimeoutRaw)

packages/experimental/webworker-runtime/tests/node/chokidar.spec.ts

@@ -84,7 +84,7 @@ afterEach(async () => {
 function onceEvent<T>(watcher: import('chokidar').FSWatcher, event: string): Promise<T> {
   return new Promise<T>((resolve, reject) => {
     const timeout = setTimeout(() => { reject(new Error(`timed out waiting for chokidar ${event}`)) }, 2_000)
-    const emitter = watcher as unknown as {
+    const emitter = watcher as {
       once(name: string, listener: (...args: unknown[]) => void): void
     }
     emitter.once(event, (...args: unknown[]) => {

packages/experimental/webworker-runtime/tests/node/fs-watch-stream.spec.ts

@@ -301,7 +301,7 @@ describe('file streams', () => {
       once(event: string, listener: (...args: unknown[]) => void): unknown
       destroy(): unknown
     }
-    const streams = [nativeRead, nativeWrite, workerRead, workerWrite] as unknown as CloseableStream[]
+    const streams = [nativeRead, nativeWrite, workerRead, workerWrite] as CloseableStream[]
     const closed = streams.map(stream => new Promise<void>((resolve) => {
       stream.once('error', () => {})
       stream.once('close', () => { resolve() })

packages/experimental/webworker-runtime/tests/transport/tunnel-client.spec.ts

@@ -96,7 +96,7 @@ function stubWorker(): {
   const { worker, sent, deliver } = stubWorker()
   const tunnel = new WorkerTunnel(worker)
   const response = tunnel.fetch('/api/session.list', { method: 'POST', body: '{"a":1}' })
-  const request = sent[0] as unknown as { t: string; id: number; method: string; url: string; body: ArrayBuffer }
+  const request = sent[0] as { t: string; id: number; method: string; url: string; body: ArrayBuffer }
   check('the request frame carries method and absolute url', [request.t, request.id, request.method, request.url],
     ['req', 1, 'POST', 'http://localhost:4173/api/session.list'])
   check('the request body travels as bytes', new TextDecoder().decode(request.body), '{"a":1}')

packages/extensions/cordis-client-runner/src/client/guard.ts

@@ -71,10 +71,10 @@ function denyContext(value: unknown, service: string, env: DynamicCordisGuardEnv
 function guardedService(service: object, name: string, env: DynamicCordisGuardEnv): unknown {
   return new Proxy(service, {
     get(target, prop) {
-      const value = Reflect.get(target, prop, target) as unknown
+      const value: unknown = Reflect.get(target, prop, target)
       if (typeof value !== 'function') return denyContext(value, name, env)
       return (...args: unknown[]): unknown => {
-        const result = Reflect.apply(value, target, args) as unknown
+        const result: unknown = Reflect.apply(value, target, args)
         if (result instanceof Promise) return result.then(resolved => denyContext(resolved, name, env))
         return denyContext(result, name, env)
       }
@@ -96,7 +96,7 @@ interface ErasedSlotOptions {
 function guardedSlots(slots: SlotRegistry, env: DynamicCordisGuardEnv): unknown {
   return new Proxy(slots, {
     get(target, prop) {
-      const value = Reflect.get(target, prop, target) as unknown
+      const value: unknown = Reflect.get(target, prop, target)
       if (prop !== 'register' && prop !== 'registerFactory') {
         if (typeof value !== 'function') return denyContext(value, 'slots', env)
         return (...args: unknown[]): unknown => denyContext(Reflect.apply(value, target, args), 'slots', env)
@@ -130,7 +130,7 @@ function guardedSlots(slots: SlotRegistry, env: DynamicCordisGuardEnv): unknown
           priority = env.allocatePriority()
           options.priority = priority
         }
-        const register = Reflect.get(target, 'register', target) as unknown as (opts: object, comp: unknown) => () => void
+        const register = Reflect.get(target, 'register', target) as (opts: object, comp: unknown) => () => void
         const dispose = register.call(target, options, component)
         env.ledger.push({ slot, priority })
         // After the registry accepted it: a rejected registration seats no entry,
@@ -155,10 +155,10 @@ function guardedTheme(theme: ThemeRuntime, env: DynamicCordisGuardEnv, ctx: Cont
   return new Proxy(theme, {
     get(target, prop) {
       if (prop !== 'overrideTokens') {
-        const value = Reflect.get(target, prop, target) as unknown
+        const value: unknown = Reflect.get(target, prop, target)
         if (typeof value !== 'function') return denyContext(value, 'theme', env)
         return (...args: unknown[]): unknown => {
-          const result = Reflect.apply(value, target, args) as unknown
+          const result: unknown = Reflect.apply(value, target, args)
           if (result instanceof Promise) return result.then(resolved => denyContext(resolved, 'theme', env))
           return denyContext(result, 'theme', env)
         }
@@ -235,7 +235,7 @@ export function dynamicCordisContext(ctx: Context, env: DynamicCordisGuardEnv):
     has: (_target, prop) => prop === 'get'
       || (typeof prop === 'string'
         && ((CTX_VERBS.has(prop) && (!TIMER_VERBS.has(prop) || declared.has('timer'))) || declared.has(prop))),
-  }) as unknown as Context
+  }) as Context
 }
 
 function rejectGuard(env: DynamicCordisGuardEnv, message: string): never {

packages/extensions/cordis-client-runner/tests/guard.client.spec.ts

@@ -126,7 +126,7 @@ describe('facade surface', () => {
     expect('slots' in bench.facade).toBe(true)
     expect('registry' in bench.facade).toBe(false)
     expect(Symbol.iterator in bench.facade).toBe(false)
-    expect((bench.facade as unknown as Record<symbol, unknown>)[Symbol.iterator]).toBeUndefined()
+    expect((bench.facade as Record<symbol, unknown>)[Symbol.iterator]).toBeUndefined()
     expect(() => { bench.facade.slots = 1 }).toThrow(/dynamic ctx is read-only/)
   })
 

packages/extensions/cordis-client-runner/tests/providers.client.spec.ts

@@ -11,7 +11,7 @@ describe('Client inspect providers', () => {
     const ctx = new Context()
     const fiber = ctx.plugin(SlotRegistry)
     await fiber
-    const slots = ctx.slots as unknown as {
+    const slots = ctx.slots as {
       registerFactory(options: object, component: unknown): () => void
     }
     slots.registerFactory({

packages/extensions/cordis-host-runner/src/guard.ts

@@ -564,7 +564,7 @@ export function sandboxDefineTool(options: unknown): ToolDefinition {
   const rawExecute = options.execute as (args: unknown, exec: unknown) => Promise<unknown>
   const rawRender = output.render as (args: unknown, value: unknown) => unknown
   const rawPresentationMeta = output.presentationMeta as ((args: unknown, value: unknown) => unknown) | undefined
-  const erasedDefineTool = defineTool as unknown as (definition: unknown) => ToolDefinition
+  const erasedDefineTool = defineTool as (definition: unknown) => ToolDefinition
   const tool = erasedDefineTool({
     ...options,
     parameters: normalized.spec,
@@ -685,10 +685,10 @@ function denyContext(value: unknown, service: string, reportFailure: (error: Err
 function guardedService(service: object, name: string, reportFailure: (error: Error) => void): unknown {
   return new Proxy(service, {
     get(target, prop) {
-      const value = Reflect.get(target, prop, target) as unknown
+      const value: unknown = Reflect.get(target, prop, target)
       if (typeof value !== 'function') return denyContext(value, name, reportFailure)
       return (...args: unknown[]): unknown => {
-        const result = Reflect.apply(value, target, args) as unknown
+        const result: unknown = Reflect.apply(value, target, args)
         if (result instanceof Promise) return result.then(v => denyContext(v, name, reportFailure))
         return denyContext(result, name, reportFailure)
       }
@@ -776,7 +776,7 @@ function sandboxContext(ctx: Context, reportFailure: (error: Error) => void): Co
     has: (_target, prop) => prop === 'tools' || prop === 'get'
       || (typeof prop === 'string'
         && ((CTX_VERBS.has(prop) && (!TIMER_VERBS.has(prop) || declared.has('timer'))) || declared.has(prop))),
-  }) as unknown as Context
+  }) as Context
   /* jscpd:ignore-end */
 }
 

packages/extensions/ui-cordis/src/client/card-model.ts

@@ -60,7 +60,7 @@ function objectAt(source: Record<string, unknown>, key: string): Record<string,
 
 function parseArgs(argsRaw: string): Record<string, unknown> | null {
   try {
-    const parsed = JSON.parse(argsRaw) as unknown
+    const parsed: unknown = JSON.parse(argsRaw)
     return typeof parsed === 'object' && parsed !== null ? parsed as Record<string, unknown> : null
   } catch {
     // Running calls can expose a truncated JSON prefix.

packages/host/directory-picker-native/src/win32-dialog-bindings.ts

@@ -92,7 +92,7 @@ const IID_IFILE_OPEN_DIALOG = guidBytes('d57c7288-d4ad-4768-be02-9d969532d960')
  * @returns the bindings {@link runFolderDialog} sequences against.
  */
 export async function loadWin32DialogBindings(): Promise<Win32DialogBindings> {
-  const koffi = (await import('koffi')).default as unknown as Koffi
+  const koffi = (await import('koffi')).default as Koffi
   const ole32 = koffi.load('ole32.dll')
   const user32 = koffi.load('user32.dll')
   const kernel32 = koffi.load('kernel32.dll')
@@ -189,7 +189,7 @@ export async function loadWin32DialogBindings(): Promise<Win32DialogBindings> {
  * @param threadId - the dialog thread's native id (from the `showing` notice).
  */
 export async function closeThreadWindows(threadId: number): Promise<void> {
-  const koffi = (await import('koffi')).default as unknown as Koffi
+  const koffi = (await import('koffi')).default as Koffi
   const user32 = koffi.load('user32.dll')
   const enumThreadWindows = user32.func('__stdcall', 'EnumThreadWindows', 'int', ['uint32', 'void *', 'intptr'])
   const postMessageW = user32.func('__stdcall', 'PostMessageW', 'int', ['void *', 'uint32', 'uintptr', 'intptr'])

packages/host/webserver/src/index.ts

@@ -97,7 +97,7 @@ function createGzipMiddleware(config: ResolvedConfig): NodeMiddleware {
       if (typeof contentType === 'string' && contentType.toLowerCase().startsWith('text/event-stream')) return false
       return compressionMiddleware.filter(request, response)
     },
-  }) as unknown as NodeMiddleware
+  }) as NodeMiddleware
 
   return (req, res, next) => {
     // The Web Worker tunnel has no socket and transfers identity bytes.

packages/interaction/commands/tests/commands.spec.ts

@@ -299,7 +299,7 @@ describe('CommandRuntime', () => {
     [{ ...command('bad-handler'), handler: undefined }, /handler/],
   ] as const)('rejects invalid definition %#', async (definition, expected) => {
     const ctx = await mount()
-    expect(() => ctx.commands.register(definition as unknown as CommandDefinition)).toThrow(expected)
+    expect(() => ctx.commands.register(definition as CommandDefinition)).toThrow(expected)
   })
 
   it('logs a paired command/run + command/done around a successful handler', async () => {

packages/jobs/jobs/tests/service.spec.ts

@@ -90,7 +90,7 @@ describe('JobRegistry seam', () => {
 
   it('mounting the abstract seam directly fails loudly at load (stale-composition fence)', async () => {
     const ctx = new Context()
-    await expect(ctx.plugin(JobRegistry as unknown as typeof StubJobRegistry))
+    await expect(ctx.plugin(JobRegistry as typeof StubJobRegistry))
       .rejects.toThrow(/abstract job registry seam; load an implementation such as @deepseek-ai\/dsh-jobs-local/)
   })
 })

packages/llm/llm-deepseek/src/common/files-api.ts

@@ -249,7 +249,7 @@ export class DeepSeekFilesClient {
     if (options.limit !== undefined) query.set('limit', String(options.limit))
     if (options.order !== undefined && this.protocol === 'chat-completions') query.set('order', options.order)
     const response = await this.request(`${this.path}?${query.toString()}`, { method: 'GET' }, options.signal)
-    const value = await response.json() as unknown
+    const value: unknown = await response.json()
     if (value === null || typeof value !== 'object' || Array.isArray(value)) throw invalidResponse('list')
     const wire = value as { object?: unknown; data?: unknown; first_id?: unknown; last_id?: unknown; has_more?: unknown }
     const firstId = this.protocol === 'messages' ? wire.first_id ?? undefined : wire.first_id
@@ -285,7 +285,7 @@ export class DeepSeekFilesClient {
    */
   async delete(fileId: DeepSeekFileIdType, signal?: AbortSignal): Promise<void> {
     const response = await this.request(`${this.path}/${encodeURIComponent(fileId)}`, { method: 'DELETE' }, signal)
-    const value = await response.json() as unknown
+    const value: unknown = await response.json()
     if (value === null || typeof value !== 'object' || Array.isArray(value)) throw invalidResponse('delete')
     const wire = value as { id?: unknown; object?: unknown; deleted?: unknown; type?: unknown }
     if (wire.id !== fileId || (this.protocol === 'messages'

packages/llm/llm-pi-ai/tests/config.spec.ts

@@ -101,7 +101,7 @@ describe('request image policy bounds', () => {
           [field]: value,
         },
       },
-    } as unknown as Config
+    } as Config
     expect(() => {
       assertServiceable(programmatic)
     }).toThrow(message)

packages/llm/llm/src/assistant-stream.ts

@@ -465,7 +465,7 @@ function validateRecord(value: unknown): AssistantStreamRecord {
       const texts = stringArray(record.texts, `${record.type} texts`)
       if (texts.length === 0) throw new TypeError(`${record.type} texts must be non-empty`)
       validateRun(record, texts.length, record.type)
-      return record as unknown as AssistantStreamRecord
+      return record as AssistantStreamRecord
     }
     case 'tool-call-chunks': {
       const keys = Object.hasOwn(record, 'name')
@@ -481,7 +481,7 @@ function validateRecord(value: unknown): AssistantStreamRecord {
         throw new TypeError('tool-call-chunks name must be a non-empty string')
       }
       validateRun(record, args.length, record.type)
-      return record as unknown as AssistantStreamRecord
+      return record as AssistantStreamRecord
     }
     case 'chunk': {
       exactKeys(record, ['type', 'time', 'chunk'], 'chunk')

packages/llm/llm/tests/service.spec.ts

@@ -365,7 +365,7 @@ describe('LlmRuntime', () => {
     Object.defineProperty(result, field, { get: () => { throw original } })
     let cleanupLookups = 0
     const iterator: AsyncIterator<StreamChunk> = {
-      next: () => Promise.resolve(result as unknown as IteratorResult<StreamChunk>),
+      next: () => Promise.resolve(result as IteratorResult<StreamChunk>),
     }
     Object.defineProperty(iterator, 'return', {
       get: () => {

packages/llm/token-meter/tests/token-meter.spec.ts

@@ -126,7 +126,7 @@ describe('TokenMeter configuration and registration', () => {
   it.each(['models', 'contextWindow', 'contextWidow'])(
     'rejects stale or unknown top-level config key %s',
     (key) => {
-      expect(() => meter({ [key]: {} } as unknown as TokenMeterConfig))
+      expect(() => meter({ [key]: {} } as TokenMeterConfig))
         .toThrow(`TokenMeterConfig: unknown key "${key}"`)
     },
   )