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
122 lines
4.1 KiB
TypeScript
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()
|