Files
wehub-resource-sync bcbd1bdb22
Integ / changes (push) Has been skipped
Pre-commit / pre-commit (push) Failing after 1s
CLI exit codes / changes (push) Has been skipped
Test (Install) / changes (push) Has been skipped
Test (Python) / changes (push) Has been skipped
Test (TypeScript) / changes (push) Has been skipped
CLI exit codes / cli-gate (push) Has been cancelled
Test (Install) / test-install-gate (push) Has been cancelled
Integ / integ-gate (push) Has been cancelled
Test (Python) / test-python-gate (push) Has been cancelled
Test (TypeScript) / test-typescript-gate (push) Has been cancelled
Test (Install) / python-minimal (3.12) (push) Has been cancelled
Test (Install) / python-minimal (3.11) (push) Has been cancelled
Test (Install) / python-extra (agno, mirage.agents.agno) (push) Has been cancelled
Test (Install) / python-extra (chroma, mirage.resource.chroma) (push) Has been cancelled
Test (Install) / python-extra (pdf, mirage.core.filetype.pdf) (push) Has been cancelled
Integ / integ (push) Has been cancelled
Integ / integ-database (push) Has been cancelled
Integ / integ-database-ts (push) Has been cancelled
Integ / integ-data (push) Has been cancelled
Integ / integ-ssh (push) Has been cancelled
Integ / integ-ssh-ts (push) Has been cancelled
Test (Python) / audit (push) Has been cancelled
Test (TypeScript) / test (push) Has been cancelled
Test (TypeScript) / python-fs-shim (push) Has been cancelled
CLI exit codes / Python CLI (push) Has been cancelled
CLI exit codes / TypeScript CLI (push) Has been cancelled
CLI exit codes / Cross-language snapshot interop (push) Has been cancelled
Test (Python) / test (push) Has been cancelled
Test (Python) / import-isolation (deepagents, openai, mirage.agents.openai_agents) (push) Has been cancelled
Test (Python) / import-isolation (deepagents, pydantic-ai, mirage.agents.pydantic_ai) (push) Has been cancelled
Integ / integ-ts (push) Has been cancelled
Integ / integ-fuse (push) Has been cancelled
Test (Install) / python-extra (databricks, mirage.resource.databricks_volume) (push) Has been cancelled
Test (Install) / python-extra (deepagents, mirage.agents.langchain) (push) Has been cancelled
Test (Install) / python-extra (email, mirage.resource.email) (push) Has been cancelled
Test (Install) / python-extra (fuse, mirage.fuse.mount) (push) Has been cancelled
Test (Install) / python-extra (hdf5, mirage.core.filetype.hdf5) (push) Has been cancelled
Test (Install) / python-extra (hf, mirage.resource.hf_buckets) (push) Has been cancelled
Test (Install) / python-extra (lancedb, mirage.resource.lancedb) (push) Has been cancelled
Test (Install) / python-extra (langfuse, mirage.resource.langfuse) (push) Has been cancelled
Test (Install) / python-extra (mongodb, mirage.resource.mongodb) (push) Has been cancelled
Test (Install) / python-extra (nextcloud, mirage.resource.nextcloud) (push) Has been cancelled
Test (Install) / python-extra (openai, mirage.agents.openai_agents) (push) Has been cancelled
Test (Install) / python-extra (openhands, mirage.agents.openhands, 3.12) (push) Has been cancelled
Test (Install) / python-extra (parquet, mirage.core.filetype.parquet) (push) Has been cancelled
Test (Install) / python-extra (postgres, mirage.resource.postgres) (push) Has been cancelled
Test (Install) / python-extra (pydantic-ai, mirage.agents.pydantic_ai) (push) Has been cancelled
Test (Install) / python-extra (qdrant, mirage.resource.qdrant) (push) Has been cancelled
Test (Install) / python-extra (redis, mirage.resource.redis) (push) Has been cancelled
Test (Install) / python-extra (s3, mirage.resource.s3) (push) Has been cancelled
Test (Install) / python-extra (ssh, mirage.resource.ssh) (push) Has been cancelled
Test (Install) / ts-minimal (push) Has been cancelled
chore: import upstream snapshot with attribution
2026-07-13 12:30:44 +08:00

122 lines
4.1 KiB
TypeScript

// ========= Copyright 2026 @ Strukto.AI All Rights Reserved. =========
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
// ========= Copyright 2026 @ Strukto.AI All Rights Reserved. =========
import { mkdirSync, writeFileSync } from 'node:fs'
import { resolve } from 'node:path'
import { fileURLToPath } from 'node:url'
import * as Browser from '@struktoai/mirage-browser'
import * as Core from '@struktoai/mirage-core'
import * as Node from '@struktoai/mirage-node'
import type { CommandSpec, Operand, Option, RegisteredCommand } from '@struktoai/mirage-core'
const __dirname = resolve(fileURLToPath(import.meta.url), '..')
const SPEC_ROOT = resolve(__dirname, '..', '..', 'spec', 'typescript')
type ModuleBag = Record<string, unknown>
function collectRegistrations(modules: ModuleBag[]): Record<string, RegisteredCommand[]> {
const out: Record<string, RegisteredCommand[]> = {}
for (const mod of modules) {
for (const [key, value] of Object.entries(mod)) {
if (!key.endsWith('_COMMANDS') || !Array.isArray(value)) continue
for (const rc of value as RegisteredCommand[]) {
if (!out[rc.name]) out[rc.name] = []
out[rc.name].push(rc)
}
}
}
return out
}
function metaFor(rcs: RegisteredCommand[]): Record<string, unknown> {
const resources = [
...new Set(rcs.map((r) => r.resource).filter((r): r is string => r !== null)),
].sort()
const filetypes = [
...new Set(rcs.map((r) => r.filetype).filter((f): f is string => f !== null)),
].sort()
return {
filetypes,
has_aggregate: rcs.some((r) => r.aggregate !== null),
has_provision: rcs.some((r) => r.provisionFn !== null),
has_write: rcs.some((r) => r.write),
resources,
}
}
function serializeOperand(op: Operand): Record<string, unknown> {
return { kind: op.kind, provided_by: [...op.providedBy] }
}
function serializeOption(o: Option): Record<string, unknown> {
return {
description: o.description,
long: o.long,
numeric_shorthand: o.numericShorthand,
repeatable: o.repeatable,
short: o.short,
value_kind: o.valueKind,
value_optional: o.valueOptional,
}
}
function serializeSpec(spec: CommandSpec, rcs: RegisteredCommand[]): Record<string, unknown> {
return {
_meta: metaFor(rcs),
description: spec.description,
ignore_tokens: [...spec.ignoreTokens].sort(),
options: spec.options.map(serializeOption),
positional: spec.positional.map(serializeOperand),
rest: spec.rest === null ? null : serializeOperand(spec.rest),
}
}
function sortedStringify(value: unknown): string {
return JSON.stringify(
value,
(_k, v) => {
if (v && typeof v === 'object' && !Array.isArray(v)) {
return Object.fromEntries(
Object.entries(v as Record<string, unknown>).sort(([a], [b]) => a.localeCompare(b)),
)
}
return v
},
2,
)
}
function emitVariant(name: string, modules: ModuleBag[]): void {
const registry = collectRegistrations(modules)
const outDir = resolve(SPEC_ROOT, name, 'general')
mkdirSync(outDir, { recursive: true })
const cmdNames = Object.keys(Core.SPECS).sort()
for (const cmd of cmdNames) {
const spec = Core.SPECS[cmd]
const rcs = registry[cmd] ?? []
const payload = serializeSpec(spec, rcs)
writeFileSync(resolve(outDir, `${cmd}.json`), sortedStringify(payload) + '\n')
}
console.log(`emitted ${cmdNames.length} specs to ${outDir}`)
}
function main(): void {
emitVariant('node', [Core as unknown as ModuleBag, Node as unknown as ModuleBag])
emitVariant('browser', [Core as unknown as ModuleBag, Browser as unknown as ModuleBag])
}
main()