mirror of
https://github.com/badlogic/pi-mono.git
synced 2026-11-05 23:37:25 +00:00
05dc8d239d
p2 (Pi Mobile on Chord v2) moves from pi-private into pi as one commit. Root scripts that loop all workspaces use --if-present; npm test, ./test.sh and the release script cover packages/* only (p2: cd apps/p2 && npm test); sync-versions also updates apps' workspace pins.
59 lines
2.2 KiB
TypeScript
59 lines
2.2 KiB
TypeScript
import { defineFacet, forbidden, isWorker, nativeOf } from "@p2/app/v1";
|
|
import { envRevision, listLocalDirectory } from "@p2/app/v1/node";
|
|
import { Hosts } from "@p2/app/v1/server";
|
|
import { EnvManagers, EnvService } from "../envs/contract.ts";
|
|
import { SessionMoves } from "../sessions/contract.ts";
|
|
import { AgentLocations, type EnvInfo } from "./contract.ts";
|
|
|
|
export default defineFacet((host) => {
|
|
// Only a current worker generation, for its own session; the worker checked that the owner started the turn.
|
|
host.serve(AgentLocations, (_params, principal, self) => {
|
|
if (!isWorker(principal)) throw forbidden("location tools are for session workers");
|
|
const { session, generation } = principal;
|
|
const hosts = self.get(Hosts, {});
|
|
const envs = self.get(EnvService, {});
|
|
const managers = nativeOf(self, EnvManagers, "The SSH manager");
|
|
const moves = self.get(SessionMoves, {});
|
|
const current = () => {
|
|
const worker = hosts.workers.value[session];
|
|
if (!worker?.running || worker.generation !== generation) throw forbidden("stale worker");
|
|
};
|
|
return {
|
|
variant: "worker",
|
|
members: {
|
|
envs: async () => {
|
|
current();
|
|
const tests = envs.tests.value;
|
|
return {
|
|
envs: Object.entries(envs.configs.value)
|
|
.sort(([a], [b]) => a.localeCompare(b))
|
|
.map(([name, config]): EnvInfo => {
|
|
const last = tests[name]?.revision === envRevision(config) ? tests[name]?.test : undefined;
|
|
return {
|
|
name,
|
|
host: config.host,
|
|
...(config.user === undefined ? {} : { user: config.user }),
|
|
...(config.port === undefined ? {} : { port: config.port }),
|
|
...(last === undefined
|
|
? {}
|
|
: {
|
|
tested: last.ok
|
|
? { ok: true, platform: last.platform, arch: last.arch }
|
|
: { ok: false, error: last.error },
|
|
}),
|
|
};
|
|
}),
|
|
};
|
|
},
|
|
directories: async ({ env, path }) => {
|
|
current();
|
|
return env ? managers().manager.listDirectory(env, path) : listLocalDirectory(path);
|
|
},
|
|
move: async ({ env, cwd }, ctx) => {
|
|
current();
|
|
return moves.relocate({ id: session, env, cwd }, ctx);
|
|
},
|
|
},
|
|
};
|
|
});
|
|
});
|