Add files using upload-large-folder tool

499d3d5 verified about 1 month ago

3.61 kB

import { deepFreeze, snapshotJsonValue } from '@deepseek-ai/dsh-util-values'
import { SessionFormatError } from './error.ts'
import type {
  SessionFormatHeader,
  SessionFormatJsonValue,
} from './types.ts'

/**
 * Test whether a value is a non-null, non-array object.
 * @param value - candidate value.
 * @returns whether the value is an object record.
 */
export function isSessionFormatJsonObject(value: unknown): value is Record<string, unknown> {
  return typeof value === 'object' && value !== null && !Array.isArray(value)
}

/**
 * Require a non-negative safe integer without the JSON-unstable negative zero.
 * @param value - candidate count.
 * @param label - diagnostic subject.
 * @returns validated count.
 */
export function sessionFormatCount(value: unknown, label: string): number {
  if (!Number.isSafeInteger(value) || (value as number) < 0 || Object.is(value, -0)) {
    throw new SessionFormatError(`${label} must be a non-negative safe integer`)
  }
  return value as number
}

/**
 * Require a safe integer without the JSON-unstable negative zero.
 * @param value - candidate integer.
 * @param label - diagnostic subject.
 * @returns validated integer.
 */
export function sessionFormatSafeInteger(value: unknown, label: string): number {
  if (!Number.isSafeInteger(value) || Object.is(value, -0)) {
    throw new SessionFormatError(`${label} must be a safe integer`)
  }
  return value as number
}

/**
 * Require a non-negative integral format version.
 * @param value - candidate version.
 * @param label - diagnostic subject.
 * @returns validated version.
 */
export function sessionFormatVersion(value: unknown, label = 'Session format version'): number {
  return sessionFormatCount(value, label)
}

/**
 * Read only the version required for directional dispatch.
 * @param headerValue - untrusted physical header value.
 * @returns validated stored version.
 */
export function inspectSessionFormatVersion(headerValue: unknown): number {
  if (!isSessionFormatJsonObject(headerValue)) {
    throw new SessionFormatError('Session header must be a JSON object')
  }
  return sessionFormatVersion(headerValue['version'])
}

/**
 * Detach and deeply freeze a caller-supplied lossless JSON value.
 * @param value - borrowed candidate.
 * @param label - diagnostic subject.
 * @returns an immutable detached JSON snapshot.
 */
export function snapshotSessionFormatJson(value: unknown, label = 'Session value'): SessionFormatJsonValue {
  const snapshot = snapshotJsonValue(value)
  if (snapshot === undefined) {
    throw new SessionFormatError(`${label} is not lossless JSON`)
  }
  return deepFreeze(snapshot) as SessionFormatJsonValue
}

/**
 * Snapshot one logical header without inspecting an event body.
 * @param header - borrowed logical header.
 * @param label - diagnostic subject.
 * @returns immutable detached header.
 */
export function snapshotSessionFormatHeader(header: SessionFormatHeader, label = 'Session header'): SessionFormatHeader {
  const snapshot = snapshotSessionFormatJson(header, label)
  if (!isSessionFormatJsonObject(snapshot)) throw new SessionFormatError(`${label} must be a JSON object`)
  inspectSessionFormatVersion(snapshot)
  if (typeof snapshot['id'] !== 'string') throw new SessionFormatError(`${label} id must be a string`)
  sessionFormatCount(snapshot['createdAt'], `${label} createdAt`)
  if (typeof snapshot['isSeeded'] !== 'boolean') throw new SessionFormatError(`${label} isSeeded must be a boolean`)
  sessionFormatCount(snapshot['delegationDepth'], `${label} delegationDepth`)
  return snapshot as unknown as SessionFormatHeader
}

	import { deepFreeze, snapshotJsonValue } from '@deepseek-ai/dsh-util-values'
	import { SessionFormatError } from './error.ts'
	import type {
	SessionFormatHeader,
	SessionFormatJsonValue,
	} from './types.ts'

	/**
	* Test whether a value is a non-null, non-array object.
	* @param value - candidate value.
	* @returns whether the value is an object record.
	*/
	export function isSessionFormatJsonObject(value: unknown): value is Record<string, unknown> {
	return typeof value === 'object' && value !== null && !Array.isArray(value)
	}

	/**
	* Require a non-negative safe integer without the JSON-unstable negative zero.
	* @param value - candidate count.
	* @param label - diagnostic subject.
	* @returns validated count.
	*/
	export function sessionFormatCount(value: unknown, label: string): number {
	if (!Number.isSafeInteger(value) \|\| (value as number) < 0 \|\| Object.is(value, -0)) {
	throw new SessionFormatError(`${label} must be a non-negative safe integer`)
	}
	return value as number
	}

	/**
	* Require a safe integer without the JSON-unstable negative zero.
	* @param value - candidate integer.
	* @param label - diagnostic subject.
	* @returns validated integer.
	*/
	export function sessionFormatSafeInteger(value: unknown, label: string): number {
	if (!Number.isSafeInteger(value) \|\| Object.is(value, -0)) {
	throw new SessionFormatError(`${label} must be a safe integer`)
	}
	return value as number
	}

	/**
	* Require a non-negative integral format version.
	* @param value - candidate version.
	* @param label - diagnostic subject.
	* @returns validated version.
	*/
	export function sessionFormatVersion(value: unknown, label = 'Session format version'): number {
	return sessionFormatCount(value, label)
	}

	/**
	* Read only the version required for directional dispatch.
	* @param headerValue - untrusted physical header value.
	* @returns validated stored version.
	*/
	export function inspectSessionFormatVersion(headerValue: unknown): number {
	if (!isSessionFormatJsonObject(headerValue)) {
	throw new SessionFormatError('Session header must be a JSON object')
	}
	return sessionFormatVersion(headerValue['version'])
	}

	/**
	* Detach and deeply freeze a caller-supplied lossless JSON value.
	* @param value - borrowed candidate.
	* @param label - diagnostic subject.
	* @returns an immutable detached JSON snapshot.
	*/
	export function snapshotSessionFormatJson(value: unknown, label = 'Session value'): SessionFormatJsonValue {
	const snapshot = snapshotJsonValue(value)
	if (snapshot === undefined) {
	throw new SessionFormatError(`${label} is not lossless JSON`)
	}
	return deepFreeze(snapshot) as SessionFormatJsonValue
	}

	/**
	* Snapshot one logical header without inspecting an event body.
	* @param header - borrowed logical header.
	* @param label - diagnostic subject.
	* @returns immutable detached header.
	*/
	export function snapshotSessionFormatHeader(header: SessionFormatHeader, label = 'Session header'): SessionFormatHeader {
	const snapshot = snapshotSessionFormatJson(header, label)
	if (!isSessionFormatJsonObject(snapshot)) throw new SessionFormatError(`${label} must be a JSON object`)
	inspectSessionFormatVersion(snapshot)
	if (typeof snapshot['id'] !== 'string') throw new SessionFormatError(`${label} id must be a string`)
	sessionFormatCount(snapshot['createdAt'], `${label} createdAt`)
	if (typeof snapshot['isSeeded'] !== 'boolean') throw new SessionFormatError(`${label} isSeeded must be a boolean`)
	sessionFormatCount(snapshot['delegationDepth'], `${label} delegationDepth`)
	return snapshot as unknown as SessionFormatHeader
	}