+3

deno.json

··· 8 8 }, 9 9 "imports": { 10 10 "@cliffy/command": "jsr:@cliffy/command@^1.0.0-rc.8", 11 11 + "@cliffy/prompt": "jsr:@cliffy/prompt@^1.0.0-rc.8", 11 12 "@cliffy/flags": "jsr:@cliffy/flags@^1.0.0-rc.8", 12 13 "@cliffy/table": "jsr:@cliffy/table@^1.0.0-rc.8", 13 14 "@db/sqlite": "jsr:@db/sqlite@^0.12.0", ··· 15 16 "@paralleldrive/cuid2": "npm:@paralleldrive/cuid2@^3.0.4", 16 17 "@soapbox/kysely-deno-sqlite": "jsr:@soapbox/kysely-deno-sqlite@^2.2.0", 17 18 "@std/assert": "jsr:@std/assert@1", 19 19 + "@std/io": "jsr:@std/io@^0.225.2", 20 20 + "@std/path": "jsr:@std/path@^1.1.2", 18 21 "@std/toml": "jsr:@std/toml@^1.0.11", 19 22 "@zod/zod": "jsr:@zod/zod@^4.1.12", 20 23 "chalk": "npm:chalk@^5.6.2",

+47 -1

deno.lock

··· 1 1 { 2 2 "version": "5", 3 3 "specifiers": { 4 4 + "jsr:@cliffy/ansi@1.0.0-rc.8": "1.0.0-rc.8", 4 5 "jsr:@cliffy/command@^1.0.0-rc.8": "1.0.0-rc.8", 5 6 "jsr:@cliffy/flags@1.0.0-rc.8": "1.0.0-rc.8", 6 7 "jsr:@cliffy/flags@^1.0.0-rc.8": "1.0.0-rc.8", 7 8 "jsr:@cliffy/internal@1.0.0-rc.8": "1.0.0-rc.8", 9 9 + "jsr:@cliffy/keycode@1.0.0-rc.8": "1.0.0-rc.8", 10 10 + "jsr:@cliffy/prompt@^1.0.0-rc.8": "1.0.0-rc.8", 8 11 "jsr:@cliffy/table@1.0.0-rc.8": "1.0.0-rc.8", 9 12 "jsr:@cliffy/table@^1.0.0-rc.8": "1.0.0-rc.8", 10 13 "jsr:@db/sqlite@0.12": "0.12.0", ··· 13 16 "jsr:@soapbox/kysely-deno-sqlite@^2.2.0": "2.2.0", 14 17 "jsr:@std/assert@0.217": "0.217.0", 15 18 "jsr:@std/assert@1": "1.0.15", 19 19 + "jsr:@std/assert@~1.0.6": "1.0.15", 20 20 + "jsr:@std/bytes@^1.0.5": "1.0.6", 16 21 "jsr:@std/collections@^1.1.3": "1.1.3", 17 22 "jsr:@std/encoding@1": "1.0.10", 23 23 + "jsr:@std/encoding@~1.0.5": "1.0.10", 18 24 "jsr:@std/fmt@1": "1.0.8", 19 25 "jsr:@std/fmt@~1.0.2": "1.0.8", 20 26 "jsr:@std/fs@1": "1.0.19", 21 27 "jsr:@std/internal@^1.0.10": "1.0.12", 22 28 "jsr:@std/internal@^1.0.12": "1.0.12", 23 29 "jsr:@std/internal@^1.0.9": "1.0.12", 30 30 + "jsr:@std/io@~0.225.2": "0.225.2", 24 31 "jsr:@std/path@0.217": "0.217.0", 25 32 "jsr:@std/path@1": "1.1.2", 26 33 "jsr:@std/path@^1.1.1": "1.1.2", 34 34 + "jsr:@std/path@^1.1.2": "1.1.2", 35 35 + "jsr:@std/path@~1.0.6": "1.0.9", 27 36 "jsr:@std/text@~1.0.7": "1.0.16", 28 37 "jsr:@std/toml@^1.0.11": "1.0.11", 29 38 "jsr:@zod/zod@^4.1.12": "4.1.12", ··· 37 46 "npm:moniker@~0.1.2": "0.1.2" 38 47 }, 39 48 "jsr": { 49 49 + "@cliffy/ansi@1.0.0-rc.8": { 50 50 + "integrity": "ba37f10ce55bbfbdd8ddd987f91f029b17bce88385b98ba3058870f3b007b80c", 51 51 + "dependencies": [ 52 52 + "jsr:@cliffy/internal", 53 53 + "jsr:@std/encoding@~1.0.5" 54 54 + ] 55 55 + }, 40 56 "@cliffy/command@1.0.0-rc.8": { 41 57 "integrity": "758147790797c74a707e5294cc7285df665422a13d2a483437092ffce40b5557", 42 58 "dependencies": [ ··· 56 72 "@cliffy/internal@1.0.0-rc.8": { 57 73 "integrity": "34cdf2fad9b084b5aed493b138d573f52d4e988767215f7460daf0b918ff43d8" 58 74 }, 75 75 + "@cliffy/keycode@1.0.0-rc.8": { 76 76 + "integrity": "76dbf85a67ec0aea2e29ca049b8507b6b3f62a2a971bd744d8d3fc447c177cd9" 77 77 + }, 78 78 + "@cliffy/prompt@1.0.0-rc.8": { 79 79 + "integrity": "eba403ea1d47b9971bf2210fa35f4dc7ebd2aba87beec9540ae47552806e2f25", 80 80 + "dependencies": [ 81 81 + "jsr:@cliffy/ansi", 82 82 + "jsr:@cliffy/internal", 83 83 + "jsr:@cliffy/keycode", 84 84 + "jsr:@std/assert@~1.0.6", 85 85 + "jsr:@std/fmt@~1.0.2", 86 86 + "jsr:@std/path@~1.0.6", 87 87 + "jsr:@std/text" 88 88 + ] 89 89 + }, 59 90 "@cliffy/table@1.0.0-rc.8": { 60 91 "integrity": "8bbcdc2ba5e0061b4b13810a24e6f5c6ab19c09f0cce9eb691ccd76c7c6c9db5", 61 92 "dependencies": [ ··· 72 103 "@denosaurs/plug@1.1.0": { 73 104 "integrity": "eb2f0b7546c7bca2000d8b0282c54d50d91cf6d75cb26a80df25a6de8c4bc044", 74 105 "dependencies": [ 75 75 - "jsr:@std/encoding", 106 106 + "jsr:@std/encoding@1", 76 107 "jsr:@std/fmt@1", 77 108 "jsr:@std/fs", 78 109 "jsr:@std/path@1" ··· 95 126 "dependencies": [ 96 127 "jsr:@std/internal@^1.0.12" 97 128 ] 129 129 + }, 130 130 + "@std/bytes@1.0.6": { 131 131 + "integrity": "f6ac6adbd8ccd99314045f5703e23af0a68d7f7e58364b47d2c7f408aeb5820a" 98 132 }, 99 133 "@std/collections@1.1.3": { 100 134 "integrity": "bf8b0818886df6a32b64c7d3b037a425111f28278d69fd0995aeb62777c986b0" ··· 115 149 "@std/internal@1.0.12": { 116 150 "integrity": "972a634fd5bc34b242024402972cd5143eac68d8dffaca5eaa4dba30ce17b027" 117 151 }, 152 152 + "@std/io@0.225.2": { 153 153 + "integrity": "3c740cd4ee4c082e6cfc86458f47e2ab7cb353dc6234d5e9b1f91a2de5f4d6c7", 154 154 + "dependencies": [ 155 155 + "jsr:@std/bytes" 156 156 + ] 157 157 + }, 118 158 "@std/path@0.217.0": { 119 159 "integrity": "1217cc25534bca9a2f672d7fe7c6f356e4027df400c0e85c0ef3e4343bc67d11", 120 160 "dependencies": [ 121 161 "jsr:@std/assert@0.217" 122 162 ] 163 163 + }, 164 164 + "@std/path@1.0.9": { 165 165 + "integrity": "260a49f11edd3db93dd38350bf9cd1b4d1366afa98e81b86167b4e3dd750129e" 123 166 }, 124 167 "@std/path@1.1.2": { 125 168 "integrity": "c0b13b97dfe06546d5e16bf3966b1cadf92e1cc83e56ba5476ad8b498d9e3038", ··· 204 247 "dependencies": [ 205 248 "jsr:@cliffy/command@^1.0.0-rc.8", 206 249 "jsr:@cliffy/flags@^1.0.0-rc.8", 250 250 + "jsr:@cliffy/prompt@^1.0.0-rc.8", 207 251 "jsr:@cliffy/table@^1.0.0-rc.8", 208 252 "jsr:@db/sqlite@0.12", 209 253 "jsr:@es-toolkit/es-toolkit@^1.41.0", 210 254 "jsr:@soapbox/kysely-deno-sqlite@^2.2.0", 211 255 "jsr:@std/assert@1", 256 256 + "jsr:@std/io@~0.225.2", 257 257 + "jsr:@std/path@^1.1.2", 212 258 "jsr:@std/toml@^1.0.11", 213 259 "jsr:@zod/zod@^4.1.12", 214 260 "npm:@paralleldrive/cuid2@^3.0.4",

+128

main.ts

··· 1 1 #!/usr/bin/env -S deno run --allow-run --allow-read --allow-env 2 2 3 3 import { Command } from "@cliffy/command"; 4 4 + import { Secret } from "@cliffy/prompt/secret"; 5 5 + import { readAll } from "@std/io"; 4 6 import chalk from "chalk"; 5 7 import { Effect, pipe } from "effect"; 6 8 import pkg from "./deno.json" with { type: "json" }; 7 9 import { initVmFile, mergeConfig, parseVmFile } from "./src/config.ts"; 8 10 import { CONFIG_FILE_NAME } from "./src/constants.ts"; 11 11 + import { getImage } from "./src/images.ts"; 9 12 import { createBridgeNetworkIfNeeded } from "./src/network.ts"; 13 13 + import { getImageArchivePath } from "./src/oras.ts"; 14 14 + import images from "./src/subcommands/images.ts"; 10 15 import inspect from "./src/subcommands/inspect.ts"; 16 16 + import login from "./src/subcommands/login.ts"; 17 17 + import logout from "./src/subcommands/logout.ts"; 11 18 import logs from "./src/subcommands/logs.ts"; 12 19 import ps from "./src/subcommands/ps.ts"; 20 20 + import pull from "./src/subcommands/pull.ts"; 21 21 + import push from "./src/subcommands/push.ts"; 13 22 import restart from "./src/subcommands/restart.ts"; 14 23 import rm from "./src/subcommands/rm.ts"; 24 24 + import rmi from "./src/subcommands/rmi.ts"; 25 25 + import run from "./src/subcommands/run.ts"; 15 26 import start from "./src/subcommands/start.ts"; 16 27 import stop from "./src/subcommands/stop.ts"; 28 28 + import tag from "./src/subcommands/tag.ts"; 17 29 import { 18 30 createDriveImageIfNeeded, 19 31 downloadIso, ··· 70 82 .option( 71 83 "-p, --port-forward <mappings:string>", 72 84 "Port forwarding rules in the format hostPort:guestPort (comma-separated for multiple)", 85 85 + ) 86 86 + .option( 87 87 + "--install", 88 88 + "Persist changes to the VM disk image", 73 89 ) 74 90 .example( 75 91 "Default usage", ··· 88 104 "openbsd-up https://cdn.openbsd.org/pub/OpenBSD/7.8/amd64/install78.iso", 89 105 ) 90 106 .example( 107 107 + "From OCI Registry", 108 108 + "openbsd-up ghcr.io/tsirysndr/openbsd:7.8", 109 109 + ) 110 110 + .example( 91 111 "List running VMs", 92 112 "openbsd-up ps", 93 113 ) ··· 113 133 ) 114 134 .action(async (options: Options, input?: string) => { 115 135 const program = Effect.gen(function* () { 136 136 + if (input) { 137 137 + const [image, archivePath] = yield* Effect.all([ 138 138 + getImage(input), 139 139 + pipe( 140 140 + getImageArchivePath(input), 141 141 + Effect.catchAll(() => Effect.succeed(null)), 142 142 + ), 143 143 + ]); 144 144 + 145 145 + if (image || archivePath) { 146 146 + yield* Effect.tryPromise({ 147 147 + try: () => run(input), 148 148 + catch: () => {}, 149 149 + }); 150 150 + return; 151 151 + } 152 152 + } 153 153 + 116 154 const resolvedInput = handleInput(input); 117 155 let isoPath: string | null = resolvedInput; 118 156 ··· 241 279 `You can edit this file to customize your VM settings and then start the VM with:`, 242 280 ); 243 281 console.log(` ${chalk.greenBright(`openbsd-up`)}`); 282 282 + }) 283 283 + .command( 284 284 + "pull", 285 285 + "Pull VM image from an OCI-compliant registry, e.g., ghcr.io, docker hub", 286 286 + ) 287 287 + .arguments("<image:string>") 288 288 + .action(async (_options: unknown, image: string) => { 289 289 + await pull(image); 290 290 + }) 291 291 + .command( 292 292 + "push", 293 293 + "Push VM image to an OCI-compliant registry, e.g., ghcr.io, docker hub", 294 294 + ) 295 295 + .arguments("<image:string>") 296 296 + .action(async (_options: unknown, image: string) => { 297 297 + await push(image); 298 298 + }) 299 299 + .command( 300 300 + "tag", 301 301 + "Create a tag 'image' that refers to the VM image of 'vm-name'", 302 302 + ) 303 303 + .arguments("<vm-name:string> <image:string>") 304 304 + .action(async (_options: unknown, vmName: string, image: string) => { 305 305 + await tag(vmName, image); 306 306 + }) 307 307 + .command( 308 308 + "login", 309 309 + "Authenticate to an OCI-compliant registry, e.g., ghcr.io, docker.io (docker hub), etc.", 310 310 + ) 311 311 + .option("-u, --username <username:string>", "Registry username") 312 312 + .arguments("<registry:string>") 313 313 + .action(async (options: unknown, registry: string) => { 314 314 + const username = (options as { username: string }).username; 315 315 + 316 316 + let password: string | undefined; 317 317 + const stdinIsTTY = Deno.stdin.isTerminal(); 318 318 + 319 319 + if (!stdinIsTTY) { 320 320 + const buffer = await readAll(Deno.stdin); 321 321 + password = new TextDecoder().decode(buffer).trim(); 322 322 + } else { 323 323 + password = await Secret.prompt("Registry Password: "); 324 324 + } 325 325 + 326 326 + console.log( 327 327 + `Authenticating to registry ${chalk.greenBright(registry)} as ${ 328 328 + chalk.greenBright(username) 329 329 + }...`, 330 330 + ); 331 331 + await login(username, password, registry); 332 332 + }) 333 333 + .command("logout", "Logout from an OCI-compliant registry") 334 334 + .arguments("<registry:string>") 335 335 + .action(async (_options: unknown, registry: string) => { 336 336 + await logout(registry); 337 337 + }) 338 338 + .command("images", "List all local VM images") 339 339 + .action(async () => { 340 340 + await images(); 341 341 + }) 342 342 + .command("rmi", "Remove a local VM image") 343 343 + .arguments("<image:string>") 344 344 + .action(async (_options: unknown, image: string) => { 345 345 + await rmi(image); 346 346 + }) 347 347 + .command("run", "Create and run a VM from an image") 348 348 + .arguments("<image:string>") 349 349 + .option("-c, --cpu <type:string>", "Type of CPU to emulate", { 350 350 + default: "host", 351 351 + }) 352 352 + .option("-C, --cpus <number:number>", "Number of CPU cores", { 353 353 + default: 2, 354 354 + }) 355 355 + .option("-m, --memory <size:string>", "Amount of memory for the VM", { 356 356 + default: "2G", 357 357 + }) 358 358 + .option( 359 359 + "-b, --bridge <name:string>", 360 360 + "Name of the network bridge to use for networking (e.g., br0)", 361 361 + ) 362 362 + .option( 363 363 + "-d, --detach", 364 364 + "Run VM in the background and print VM name", 365 365 + ) 366 366 + .option( 367 367 + "-p, --port-forward <mappings:string>", 368 368 + "Port forwarding rules in the format hostPort:guestPort (comma-separated for multiple)", 369 369 + ) 370 370 + .action(async (_options: unknown, image: string) => { 371 371 + await run(image); 244 372 }) 245 373 .parse(Deno.args); 246 374 }

+1

src/constants.ts

··· 3 3 export const LOGS_DIR: string = `${CONFIG_DIR}/logs`; 4 4 export const EMPTY_DISK_THRESHOLD_KB: number = 100; 5 5 export const CONFIG_FILE_NAME: string = "vmconfig.toml"; 6 6 + export const IMAGE_DIR: string = `${CONFIG_DIR}/images`;

+2 -1

src/context.ts

··· 1 1 import { DB_PATH } from "./constants.ts"; 2 2 - import { createDb, type Database, migrateToLatest } from "./db.ts"; 2 2 + import { createDb, type Database } from "./db.ts"; 3 3 + import { migrateToLatest } from "./migrations.ts"; 3 4 4 5 export const db: Database = createDb(DB_PATH); 5 6 await migrateToLatest(db);

+11 -72

src/db.ts

··· 1 1 import { Database as Sqlite } from "@db/sqlite"; 2 2 import { DenoSqlite3Dialect } from "@soapbox/kysely-deno-sqlite"; 3 3 - import { 4 4 - Kysely, 5 5 - type Migration, 6 6 - type MigrationProvider, 7 7 - Migrator, 8 8 - sql, 9 9 - } from "kysely"; 3 3 + import { Kysely } from "kysely"; 10 4 import { CONFIG_DIR } from "./constants.ts"; 11 5 import type { STATUS } from "./types.ts"; 12 6 ··· 21 15 22 16 export type DatabaseSchema = { 23 17 virtual_machines: VirtualMachine; 18 18 + images: Image; 24 19 }; 25 20 26 21 export type VirtualMachine = { ··· 43 38 updatedAt?: string; 44 39 }; 45 40 46 46 - const migrations: Record<string, Migration> = {}; 47 47 - 48 48 - const migrationProvider: MigrationProvider = { 49 49 - // deno-lint-ignore require-await 50 50 - async getMigrations() { 51 51 - return migrations; 52 52 - }, 53 53 - }; 54 54 - 55 55 - migrations["001"] = { 56 56 - async up(db: Kysely<unknown>): Promise<void> { 57 57 - await db.schema 58 58 - .createTable("virtual_machines") 59 59 - .addColumn("id", "varchar", (col) => col.primaryKey()) 60 60 - .addColumn("name", "varchar", (col) => col.notNull().unique()) 61 61 - .addColumn("bridge", "varchar") 62 62 - .addColumn("macAddress", "varchar", (col) => col.notNull().unique()) 63 63 - .addColumn("memory", "varchar", (col) => col.notNull()) 64 64 - .addColumn("cpus", "integer", (col) => col.notNull()) 65 65 - .addColumn("cpu", "varchar", (col) => col.notNull()) 66 66 - .addColumn("diskSize", "varchar", (col) => col.notNull()) 67 67 - .addColumn("drivePath", "varchar") 68 68 - .addColumn("version", "varchar", (col) => col.notNull()) 69 69 - .addColumn("diskFormat", "varchar") 70 70 - .addColumn("isoPath", "varchar") 71 71 - .addColumn("status", "varchar", (col) => col.notNull()) 72 72 - .addColumn("pid", "integer") 73 73 - .addColumn( 74 74 - "createdAt", 75 75 - "varchar", 76 76 - (col) => col.notNull().defaultTo(sql`CURRENT_TIMESTAMP`), 77 77 - ) 78 78 - .addColumn( 79 79 - "updatedAt", 80 80 - "varchar", 81 81 - (col) => col.notNull().defaultTo(sql`CURRENT_TIMESTAMP`), 82 82 - ) 83 83 - .execute(); 84 84 - }, 85 85 - 86 86 - async down(db: Kysely<unknown>): Promise<void> { 87 87 - await db.schema.dropTable("virtual_machines").execute(); 88 88 - }, 89 89 - }; 90 90 - 91 91 - migrations["002"] = { 92 92 - async up(db: Kysely<unknown>): Promise<void> { 93 93 - await db.schema 94 94 - .alterTable("virtual_machines") 95 95 - .addColumn("portForward", "varchar") 96 96 - .execute(); 97 97 - }, 98 98 - 99 99 - async down(db: Kysely<unknown>): Promise<void> { 100 100 - await db.schema 101 101 - .alterTable("virtual_machines") 102 102 - .dropColumn("portForward") 103 103 - .execute(); 104 104 - }, 105 105 - }; 106 106 - 107 107 - export const migrateToLatest = async (db: Database): Promise<void> => { 108 108 - const migrator = new Migrator({ db, provider: migrationProvider }); 109 109 - const { error } = await migrator.migrateToLatest(); 110 110 - if (error) throw error; 41 41 + export type Image = { 42 42 + id: string; 43 43 + repository: string; 44 44 + tag: string; 45 45 + size: number; 46 46 + path: string; 47 47 + format: string; 48 48 + digest?: string; 49 49 + createdAt?: string; 111 50 }; 112 51 113 52 export type Database = Kysely<DatabaseSchema>;

+87

src/images.ts

··· 1 1 + import { Data, Effect } from "effect"; 2 2 + import type { DeleteResult, InsertResult } from "kysely"; 3 3 + import { ctx } from "./context.ts"; 4 4 + import type { Image } from "./db.ts"; 5 5 + 6 6 + export class DbError extends Data.TaggedError("DatabaseError")<{ 7 7 + message?: string; 8 8 + }> {} 9 9 + 10 10 + export const listImages = (): Effect.Effect<Image[], DbError, never> => 11 11 + Effect.tryPromise({ 12 12 + try: () => ctx.db.selectFrom("images").selectAll().execute(), 13 13 + catch: (error) => 14 14 + new DbError({ 15 15 + message: error instanceof Error ? error.message : String(error), 16 16 + }), 17 17 + }); 18 18 + 19 19 + export const getImage = ( 20 20 + id: string, 21 21 + ): Effect.Effect<Image | undefined, DbError, never> => 22 22 + Effect.tryPromise({ 23 23 + try: () => 24 24 + ctx.db 25 25 + .selectFrom("images") 26 26 + .selectAll() 27 27 + .where((eb) => 28 28 + eb.or([ 29 29 + eb.and([ 30 30 + eb("repository", "=", id.split(":")[0]), 31 31 + eb("tag", "=", id.split(":")[1] || "latest"), 32 32 + ]), 33 33 + eb("id", "=", id), 34 34 + eb("digest", "=", id), 35 35 + ]) 36 36 + ) 37 37 + .executeTakeFirst(), 38 38 + catch: (error) => 39 39 + new DbError({ 40 40 + message: error instanceof Error ? error.message : String(error), 41 41 + }), 42 42 + }); 43 43 + 44 44 + export const saveImage = ( 45 45 + image: Image, 46 46 + ): Effect.Effect<InsertResult[], DbError, never> => 47 47 + Effect.tryPromise({ 48 48 + try: () => 49 49 + ctx.db.insertInto("images") 50 50 + .values(image) 51 51 + .onConflict((oc) => 52 52 + oc 53 53 + .column("repository") 54 54 + .column("tag") 55 55 + .doUpdateSet({ 56 56 + size: image.size, 57 57 + path: image.path, 58 58 + format: image.format, 59 59 + digest: image.digest, 60 60 + }) 61 61 + ) 62 62 + .execute(), 63 63 + catch: (error) => 64 64 + new DbError({ 65 65 + message: error instanceof Error ? error.message : String(error), 66 66 + }), 67 67 + }); 68 68 + 69 69 + export const deleteImage = ( 70 70 + id: string, 71 71 + ): Effect.Effect<DeleteResult[], DbError, never> => 72 72 + Effect.tryPromise({ 73 73 + try: () => 74 74 + ctx.db.deleteFrom("images").where((eb) => 75 75 + eb.or([ 76 76 + eb.and([ 77 77 + eb("repository", "=", id.split(":")[0]), 78 78 + eb("tag", "=", id.split(":")[1] || "latest"), 79 79 + ]), 80 80 + eb("id", "=", id), 81 81 + ]) 82 82 + ).execute(), 83 83 + catch: (error) => 84 84 + new DbError({ 85 85 + message: error instanceof Error ? error.message : String(error), 86 86 + }), 87 87 + });

+225

src/migrations.ts

··· 1 1 + import { 2 2 + type Kysely, 3 3 + type Migration, 4 4 + type MigrationProvider, 5 5 + Migrator, 6 6 + sql, 7 7 + } from "kysely"; 8 8 + import type { Database } from "./db.ts"; 9 9 + 10 10 + const migrations: Record<string, Migration> = {}; 11 11 + 12 12 + const migrationProvider: MigrationProvider = { 13 13 + // deno-lint-ignore require-await 14 14 + async getMigrations() { 15 15 + return migrations; 16 16 + }, 17 17 + }; 18 18 + 19 19 + migrations["001"] = { 20 20 + async up(db: Kysely<unknown>): Promise<void> { 21 21 + await db.schema 22 22 + .createTable("virtual_machines") 23 23 + .addColumn("id", "varchar", (col) => col.primaryKey()) 24 24 + .addColumn("name", "varchar", (col) => col.notNull().unique()) 25 25 + .addColumn("bridge", "varchar") 26 26 + .addColumn("macAddress", "varchar", (col) => col.notNull().unique()) 27 27 + .addColumn("memory", "varchar", (col) => col.notNull()) 28 28 + .addColumn("cpus", "integer", (col) => col.notNull()) 29 29 + .addColumn("cpu", "varchar", (col) => col.notNull()) 30 30 + .addColumn("diskSize", "varchar", (col) => col.notNull()) 31 31 + .addColumn("drivePath", "varchar") 32 32 + .addColumn("version", "varchar", (col) => col.notNull()) 33 33 + .addColumn("diskFormat", "varchar") 34 34 + .addColumn("isoPath", "varchar") 35 35 + .addColumn("status", "varchar", (col) => col.notNull()) 36 36 + .addColumn("pid", "integer") 37 37 + .addColumn( 38 38 + "createdAt", 39 39 + "varchar", 40 40 + (col) => col.notNull().defaultTo(sql`CURRENT_TIMESTAMP`), 41 41 + ) 42 42 + .addColumn( 43 43 + "updatedAt", 44 44 + "varchar", 45 45 + (col) => col.notNull().defaultTo(sql`CURRENT_TIMESTAMP`), 46 46 + ) 47 47 + .execute(); 48 48 + }, 49 49 + 50 50 + async down(db: Kysely<unknown>): Promise<void> { 51 51 + await db.schema.dropTable("virtual_machines").execute(); 52 52 + }, 53 53 + }; 54 54 + 55 55 + migrations["002"] = { 56 56 + async up(db: Kysely<unknown>): Promise<void> { 57 57 + await db.schema 58 58 + .alterTable("virtual_machines") 59 59 + .addColumn("portForward", "varchar") 60 60 + .execute(); 61 61 + }, 62 62 + 63 63 + async down(db: Kysely<unknown>): Promise<void> { 64 64 + await db.schema 65 65 + .alterTable("virtual_machines") 66 66 + .dropColumn("portForward") 67 67 + .execute(); 68 68 + }, 69 69 + }; 70 70 + 71 71 + migrations["003"] = { 72 72 + async up(db: Kysely<unknown>): Promise<void> { 73 73 + await db.schema 74 74 + .createTable("images") 75 75 + .addColumn("id", "varchar", (col) => col.primaryKey()) 76 76 + .addColumn("repository", "varchar", (col) => col.notNull()) 77 77 + .addColumn("tag", "varchar", (col) => col.notNull()) 78 78 + .addColumn("size", "integer", (col) => col.notNull()) 79 79 + .addColumn("path", "varchar", (col) => col.notNull()) 80 80 + .addColumn("createdAt", "varchar", (col) => col.notNull()) 81 81 + .execute(); 82 82 + }, 83 83 + 84 84 + async down(db: Kysely<unknown>): Promise<void> { 85 85 + await db.schema.dropTable("images").execute(); 86 86 + }, 87 87 + }; 88 88 + 89 89 + migrations["004"] = { 90 90 + async up(db: Kysely<unknown>): Promise<void> { 91 91 + await db.schema 92 92 + .alterTable("images") 93 93 + .addColumn("format", "varchar", (col) => col.notNull().defaultTo("qcow2")) 94 94 + .execute(); 95 95 + }, 96 96 + 97 97 + async down(db: Kysely<unknown>): Promise<void> { 98 98 + await db.schema 99 99 + .alterTable("images") 100 100 + .dropColumn("format") 101 101 + .execute(); 102 102 + }, 103 103 + }; 104 104 + 105 105 + migrations["005"] = { 106 106 + async up(db: Kysely<unknown>): Promise<void> { 107 107 + await db.schema 108 108 + .createTable("images_new") 109 109 + .addColumn("id", "varchar", (col) => col.primaryKey()) 110 110 + .addColumn("repository", "varchar", (col) => col.notNull()) 111 111 + .addColumn("tag", "varchar", (col) => col.notNull()) 112 112 + .addColumn("size", "integer", (col) => col.notNull()) 113 113 + .addColumn("path", "varchar", (col) => col.notNull()) 114 114 + .addColumn("format", "varchar", (col) => col.notNull().defaultTo("qcow2")) 115 115 + .addColumn("createdAt", "varchar", (col) => col.notNull()) 116 116 + .addUniqueConstraint("images_repository_tag_unique", [ 117 117 + "repository", 118 118 + "tag", 119 119 + ]) 120 120 + .execute(); 121 121 + 122 122 + await sql` 123 123 + INSERT INTO images_new (id, repository, tag, size, path, format, createdAt) 124 124 + SELECT id, repository, tag, size, path, format, createdAt FROM images 125 125 + `.execute(db); 126 126 + 127 127 + await db.schema.dropTable("images").execute(); 128 128 + await sql`ALTER TABLE images_new RENAME TO images`.execute(db); 129 129 + }, 130 130 + 131 131 + async down(db: Kysely<unknown>): Promise<void> { 132 132 + await db.schema 133 133 + .createTable("images_old") 134 134 + .addColumn("id", "varchar", (col) => col.primaryKey()) 135 135 + .addColumn("repository", "varchar", (col) => col.notNull()) 136 136 + .addColumn("tag", "varchar", (col) => col.notNull()) 137 137 + .addColumn("size", "integer", (col) => col.notNull()) 138 138 + .addColumn("path", "varchar", (col) => col.notNull()) 139 139 + .addColumn("format", "varchar", (col) => col.notNull().defaultTo("qcow2")) 140 140 + .addColumn("createdAt", "varchar", (col) => col.notNull()) 141 141 + .execute(); 142 142 + 143 143 + await sql` 144 144 + INSERT INTO images_old (id, repository, tag, size, path, format, createdAt) 145 145 + SELECT id, repository, tag, size, path, format, createdAt FROM images 146 146 + `.execute(db); 147 147 + 148 148 + await db.schema.dropTable("images").execute(); 149 149 + await sql`ALTER TABLE images_old RENAME TO images`.execute(db); 150 150 + }, 151 151 + }; 152 152 + 153 153 + migrations["006"] = { 154 154 + async up(db: Kysely<unknown>): Promise<void> { 155 155 + await db.schema 156 156 + .createTable("images_new") 157 157 + .addColumn("id", "varchar", (col) => col.primaryKey()) 158 158 + .addColumn("repository", "varchar", (col) => col.notNull()) 159 159 + .addColumn("tag", "varchar", (col) => col.notNull()) 160 160 + .addColumn("size", "integer", (col) => col.notNull()) 161 161 + .addColumn("path", "varchar", (col) => col.notNull()) 162 162 + .addColumn("format", "varchar", (col) => col.notNull().defaultTo("qcow2")) 163 163 + .addColumn( 164 164 + "createdAt", 165 165 + "varchar", 166 166 + (col) => col.notNull().defaultTo(sql`CURRENT_TIMESTAMP`), 167 167 + ) 168 168 + .addUniqueConstraint("images_repository_tag_unique", [ 169 169 + "repository", 170 170 + "tag", 171 171 + ]) 172 172 + .execute(); 173 173 + 174 174 + await sql` 175 175 + INSERT INTO images_new (id, repository, tag, size, path, format, createdAt) 176 176 + SELECT id, repository, tag, size, path, format, createdAt FROM images 177 177 + `.execute(db); 178 178 + 179 179 + await db.schema.dropTable("images").execute(); 180 180 + await sql`ALTER TABLE images_new RENAME TO images`.execute(db); 181 181 + }, 182 182 + 183 183 + async down(db: Kysely<unknown>): Promise<void> { 184 184 + await db.schema 185 185 + .createTable("images_old") 186 186 + .addColumn("id", "varchar", (col) => col.primaryKey()) 187 187 + .addColumn("repository", "varchar", (col) => col.notNull()) 188 188 + .addColumn("tag", "varchar", (col) => col.notNull()) 189 189 + .addColumn("size", "integer", (col) => col.notNull()) 190 190 + .addColumn("path", "varchar", (col) => col.notNull()) 191 191 + .addColumn("format", "varchar", (col) => col.notNull().defaultTo("qcow2")) 192 192 + .addColumn("createdAt", "varchar", (col) => col.notNull()) 193 193 + .addUniqueConstraint("images_repository_tag_unique", [ 194 194 + "repository", 195 195 + "tag", 196 196 + ]) 197 197 + .execute(); 198 198 + 199 199 + await sql` 200 200 + INSERT INTO images_old (id, repository, tag, size, path, format, createdAt) 201 201 + SELECT id, repository, tag, size, path, format, createdAt FROM images 202 202 + `.execute(db); 203 203 + }, 204 204 + }; 205 205 + 206 206 + migrations["007"] = { 207 207 + async up(db: Kysely<unknown>): Promise<void> { 208 208 + await db.schema 209 209 + .alterTable("images") 210 210 + .addColumn("digest", "varchar") 211 211 + .execute(); 212 212 + }, 213 213 + async down(db: Kysely<unknown>): Promise<void> { 214 214 + await db.schema 215 215 + .alterTable("images") 216 216 + .dropColumn("digest") 217 217 + .execute(); 218 218 + }, 219 219 + }; 220 220 + 221 221 + export const migrateToLatest = async (db: Database): Promise<void> => { 222 222 + const migrator = new Migrator({ db, provider: migrationProvider }); 223 223 + const { error } = await migrator.migrateToLatest(); 224 224 + if (error) throw error; 225 225 + };

+1

src/mod.ts

··· 3 3 export * from "./context.ts"; 4 4 export * from "./db.ts"; 5 5 export * from "./network.ts"; 6 6 + export * from "./oras.ts"; 6 7 export * from "./state.ts"; 7 8 export * from "./types.ts"; 8 9 export * from "./utils.ts";

+406

src/oras.ts

··· 1 1 + import { createId } from "@paralleldrive/cuid2"; 2 2 + import { basename, dirname } from "@std/path"; 3 3 + import chalk from "chalk"; 4 4 + import { Data, Effect, pipe } from "effect"; 5 5 + import { IMAGE_DIR } from "./constants.ts"; 6 6 + import { getImage, saveImage } from "./images.ts"; 7 7 + import { CONFIG_DIR, failOnMissingImage } from "./mod.ts"; 8 8 + import { du, getCurrentArch } from "./utils.ts"; 9 9 + 10 10 + const DEFAULT_ORAS_VERSION = "1.3.0"; 11 11 + 12 12 + export class PushImageError extends Data.TaggedError("PushImageError")<{ 13 13 + cause?: unknown; 14 14 + }> {} 15 15 + 16 16 + export class PullImageError extends Data.TaggedError("PullImageError")<{ 17 17 + cause?: unknown; 18 18 + }> {} 19 19 + 20 20 + export class CreateDirectoryError 21 21 + extends Data.TaggedError("CreateDirectoryError")<{ 22 22 + cause?: unknown; 23 23 + }> {} 24 24 + 25 25 + export class ImageAlreadyPulledError 26 26 + extends Data.TaggedError("ImageAlreadyPulledError")<{ 27 27 + name: string; 28 28 + }> {} 29 29 + 30 30 + export async function setupOrasBinary(): Promise<void> { 31 31 + Deno.env.set( 32 32 + "PATH", 33 33 + `${CONFIG_DIR}/bin:${Deno.env.get("PATH")}`, 34 34 + ); 35 35 + 36 36 + const oras = new Deno.Command("which", { 37 37 + args: ["oras"], 38 38 + stdout: "null", 39 39 + stderr: "null", 40 40 + }) 41 41 + .spawn(); 42 42 + 43 43 + const orasStatus = await oras.status; 44 44 + if (orasStatus.success) { 45 45 + return; 46 46 + } 47 47 + 48 48 + const version = Deno.env.get("ORAS_VERSION") || DEFAULT_ORAS_VERSION; 49 49 + 50 50 + console.log(`Downloading ORAS version ${version}...`); 51 51 + 52 52 + const os = Deno.build.os; 53 53 + let arch = "amd64"; 54 54 + 55 55 + if (Deno.build.arch === "aarch64") { 56 56 + arch = "arm64"; 57 57 + } 58 58 + 59 59 + if (os !== "linux" && os !== "darwin") { 60 60 + console.error("Unsupported OS. Please download ORAS manually."); 61 61 + Deno.exit(1); 62 62 + } 63 63 + 64 64 + // https://github.com/oras-project/oras/releases/download/v1.3.0/oras_1.3.0_darwin_amd64.tar.gz 65 65 + const downloadUrl = 66 66 + `https://github.com/oras-project/oras/releases/download/v${version}/oras_${version}_${os}_${arch}.tar.gz`; 67 67 + 68 68 + console.log(`Downloading ORAS from ${chalk.greenBright(downloadUrl)}`); 69 69 + 70 70 + const downloadProcess = new Deno.Command("curl", { 71 71 + args: ["-L", downloadUrl, "-o", `oras_${version}_${os}_${arch}.tar.gz`], 72 72 + stdout: "inherit", 73 73 + stderr: "inherit", 74 74 + cwd: "/tmp", 75 75 + }) 76 76 + .spawn(); 77 77 + 78 78 + const status = await downloadProcess.status; 79 79 + if (!status.success) { 80 80 + console.error("Failed to download ORAS binary."); 81 81 + Deno.exit(1); 82 82 + } 83 83 + 84 84 + console.log("Extracting ORAS binary..."); 85 85 + 86 86 + const extractProcess = new Deno.Command("tar", { 87 87 + args: [ 88 88 + "-xzf", 89 89 + `oras_${version}_${os}_${arch}.tar.gz`, 90 90 + "-C", 91 91 + "./", 92 92 + ], 93 93 + stdout: "inherit", 94 94 + stderr: "inherit", 95 95 + cwd: "/tmp", 96 96 + }) 97 97 + .spawn(); 98 98 + 99 99 + const extractStatus = await extractProcess.status; 100 100 + if (!extractStatus.success) { 101 101 + console.error("Failed to extract ORAS binary."); 102 102 + Deno.exit(1); 103 103 + } 104 104 + 105 105 + await Deno.remove(`/tmp/oras_${version}_${os}_${arch}.tar.gz`); 106 106 + 107 107 + await Deno.mkdir(`${CONFIG_DIR}/bin`, { recursive: true }); 108 108 + 109 109 + await Deno.rename( 110 110 + `/tmp/oras`, 111 111 + `${CONFIG_DIR}/bin/oras`, 112 112 + ); 113 113 + await Deno.chmod(`${CONFIG_DIR}/bin/oras`, 0o755); 114 114 + 115 115 + console.log( 116 116 + `ORAS binary installed at ${ 117 117 + chalk.greenBright( 118 118 + `${CONFIG_DIR}/bin/oras`, 119 119 + ) 120 120 + }`, 121 121 + ); 122 122 + } 123 123 + 124 124 + const archiveImage = (img: { path: string }) => 125 125 + Effect.tryPromise({ 126 126 + try: async () => { 127 127 + console.log("Archiving image for push..."); 128 128 + const tarProcess = new Deno.Command("tar", { 129 129 + args: [ 130 130 + "-cSzf", 131 131 + `${img.path}.tar.gz`, 132 132 + "-C", 133 133 + dirname(img.path), 134 134 + basename(img.path), 135 135 + ], 136 136 + stdout: "inherit", 137 137 + stderr: "inherit", 138 138 + }).spawn(); 139 139 + 140 140 + const tarStatus = await tarProcess.status; 141 141 + if (!tarStatus.success) { 142 142 + throw new Error(`Failed to create tar archive for image`); 143 143 + } 144 144 + return `${img.path}.tar.gz`; 145 145 + }, 146 146 + catch: (error: unknown) => 147 147 + new PushImageError({ 148 148 + cause: error instanceof Error ? error.message : String(error), 149 149 + }), 150 150 + }); 151 151 + 152 152 + const pushToRegistry = ( 153 153 + img: { repository: string; tag: string; path: string }, 154 154 + ) => 155 155 + Effect.tryPromise({ 156 156 + try: async () => { 157 157 + console.log(`Pushing image ${img.repository}...`); 158 158 + const process = new Deno.Command("oras", { 159 159 + args: [ 160 160 + "push", 161 161 + `${img.repository}:${img.tag}-${getCurrentArch()}`, 162 162 + "--artifact-type", 163 163 + "application/vnd.oci.image.layer.v1.tar", 164 164 + "--annotation", 165 165 + `org.opencontainers.image.architecture=${getCurrentArch()}`, 166 166 + "--annotation", 167 167 + "org.opencontainers.image.os=openbsd", 168 168 + "--annotation", 169 169 + "org.opencontainers.image.description=QEMU raw disk image", 170 170 + basename(img.path), 171 171 + ], 172 172 + stdout: "inherit", 173 173 + stderr: "inherit", 174 174 + cwd: dirname(img.path), 175 175 + }).spawn(); 176 176 + 177 177 + const { code } = await process.status; 178 178 + if (code !== 0) { 179 179 + throw new Error(`ORAS push failed with exit code ${code}`); 180 180 + } 181 181 + return img.path; 182 182 + }, 183 183 + catch: (error: unknown) => 184 184 + new PushImageError({ 185 185 + cause: error instanceof Error ? error.message : String(error), 186 186 + }), 187 187 + }); 188 188 + 189 189 + const cleanup = (path: string) => 190 190 + Effect.tryPromise({ 191 191 + try: () => Deno.remove(path), 192 192 + catch: (error: unknown) => 193 193 + new PushImageError({ 194 194 + cause: error instanceof Error ? error.message : String(error), 195 195 + }), 196 196 + }); 197 197 + 198 198 + const createImageDirIfMissing = Effect.promise(() => 199 199 + Deno.mkdir(IMAGE_DIR, { recursive: true }) 200 200 + ); 201 201 + 202 202 + const checkIfImageAlreadyPulled = (image: string) => 203 203 + pipe( 204 204 + getImageDigest(image), 205 205 + Effect.flatMap(getImage), 206 206 + Effect.flatMap((img) => { 207 207 + if (img) { 208 208 + return Effect.fail( 209 209 + new ImageAlreadyPulledError({ name: image }), 210 210 + ); 211 211 + } 212 212 + return Effect.succeed(void 0); 213 213 + }), 214 214 + ); 215 215 + 216 216 + export const pullFromRegistry = (image: string) => 217 217 + pipe( 218 218 + Effect.tryPromise({ 219 219 + try: async () => { 220 220 + console.log(`Pulling image ${image}`); 221 221 + const process = new Deno.Command("oras", { 222 222 + args: [ 223 223 + "pull", 224 224 + `${image}-${getCurrentArch()}`, 225 225 + ], 226 226 + stdin: "inherit", 227 227 + stdout: "inherit", 228 228 + stderr: "inherit", 229 229 + cwd: IMAGE_DIR, 230 230 + }).spawn(); 231 231 + 232 232 + const { code } = await process.status; 233 233 + if (code !== 0) { 234 234 + throw new Error(`ORAS pull failed with exit code ${code}`); 235 235 + } 236 236 + }, 237 237 + catch: (error: unknown) => 238 238 + new PullImageError({ 239 239 + cause: error instanceof Error ? error.message : String(error), 240 240 + }), 241 241 + }), 242 242 + ); 243 243 + 244 244 + export const getImageArchivePath = (image: string) => 245 245 + Effect.tryPromise({ 246 246 + try: async () => { 247 247 + const process = new Deno.Command("oras", { 248 248 + args: [ 249 249 + "manifest", 250 250 + "fetch", 251 251 + `${image}-${getCurrentArch()}`, 252 252 + ], 253 253 + stdout: "piped", 254 254 + stderr: "inherit", 255 255 + }).spawn(); 256 256 + 257 257 + const { code, stdout } = await process.output(); 258 258 + if (code !== 0) { 259 259 + throw new Error(`ORAS manifest fetch failed with exit code ${code}`); 260 260 + } 261 261 + 262 262 + const manifest = JSON.parse(new TextDecoder().decode(stdout)); 263 263 + const layers = manifest.layers; 264 264 + if (!layers || layers.length === 0) { 265 265 + throw new Error(`No layers found in manifest for image ${image}`); 266 266 + } 267 267 + 268 268 + if ( 269 269 + !layers[0].annotations || 270 270 + !layers[0].annotations["org.opencontainers.image.title"] 271 271 + ) { 272 272 + throw new Error( 273 273 + `No title annotation found for layer in image ${image}`, 274 274 + ); 275 275 + } 276 276 + 277 277 + const path = `${IMAGE_DIR}/${ 278 278 + layers[0].annotations["org.opencontainers.image.title"] 279 279 + }`; 280 280 + 281 281 + if (!(await Deno.stat(path).catch(() => false))) { 282 282 + throw new Error(`Image archive not found at expected path ${path}`); 283 283 + } 284 284 + 285 285 + return path; 286 286 + }, 287 287 + catch: (error: unknown) => 288 288 + new PullImageError({ 289 289 + cause: error instanceof Error ? error.message : String(error), 290 290 + }), 291 291 + }); 292 292 + 293 293 + const getImageDigest = (image: string) => 294 294 + Effect.tryPromise({ 295 295 + try: async () => { 296 296 + const process = new Deno.Command("oras", { 297 297 + args: [ 298 298 + "manifest", 299 299 + "fetch", 300 300 + `${image}-${getCurrentArch()}`, 301 301 + ], 302 302 + stdout: "piped", 303 303 + stderr: "inherit", 304 304 + }).spawn(); 305 305 + 306 306 + const { code, stdout } = await process.output(); 307 307 + if (code !== 0) { 308 308 + throw new Error(`ORAS manifest fetch failed with exit code ${code}`); 309 309 + } 310 310 + 311 311 + const manifest = JSON.parse(new TextDecoder().decode(stdout)); 312 312 + if (!manifest.layers[0] || !manifest.layers[0].digest) { 313 313 + throw new Error(`No digest found in manifest for image ${image}`); 314 314 + } 315 315 + 316 316 + return manifest.layers[0].digest as string; 317 317 + }, 318 318 + catch: (error: unknown) => 319 319 + new PullImageError({ 320 320 + cause: error instanceof Error ? error.message : String(error), 321 321 + }), 322 322 + }); 323 323 + 324 324 + const extractImage = (path: string) => 325 325 + Effect.tryPromise({ 326 326 + try: async () => { 327 327 + console.log("Extracting image archive..."); 328 328 + const tarProcess = new Deno.Command("tar", { 329 329 + args: [ 330 330 + "-xSzf", 331 331 + path, 332 332 + "-C", 333 333 + dirname(path), 334 334 + ], 335 335 + stdout: "inherit", 336 336 + stderr: "inherit", 337 337 + cwd: IMAGE_DIR, 338 338 + }).spawn(); 339 339 + 340 340 + const tarStatus = await tarProcess.status; 341 341 + if (!tarStatus.success) { 342 342 + throw new Error(`Failed to extract tar archive for image`); 343 343 + } 344 344 + return path.replace(/\.tar\.gz$/, ""); 345 345 + }, 346 346 + catch: (error: unknown) => 347 347 + new PullImageError({ 348 348 + cause: error instanceof Error ? error.message : String(error), 349 349 + }), 350 350 + }); 351 351 + 352 352 + const savePulledImage = ( 353 353 + imagePath: string, 354 354 + digest: string, 355 355 + name: string, 356 356 + ) => 357 357 + Effect.gen(function* () { 358 358 + yield* saveImage({ 359 359 + id: createId(), 360 360 + repository: name.split(":")[0], 361 361 + tag: name.split(":")[1] || "latest", 362 362 + size: yield* du(imagePath), 363 363 + path: imagePath, 364 364 + format: imagePath.endsWith(".qcow2") ? "qcow2" : "raw", 365 365 + digest, 366 366 + }); 367 367 + return `${imagePath}.tar.gz`; 368 368 + }); 369 369 + 370 370 + export const pushImage = (image: string) => 371 371 + pipe( 372 372 + getImage(image), 373 373 + Effect.flatMap(failOnMissingImage), 374 374 + Effect.flatMap((img) => 375 375 + pipe( 376 376 + archiveImage(img), 377 377 + Effect.tap((archivedPath) => { 378 378 + img.path = archivedPath; 379 379 + return Effect.succeed(void 0); 380 380 + }), 381 381 + Effect.flatMap(() => pushToRegistry(img)), 382 382 + Effect.flatMap(cleanup), 383 383 + ) 384 384 + ), 385 385 + ); 386 386 + 387 387 + export const pullImage = (image: string) => 388 388 + pipe( 389 389 + Effect.all([createImageDirIfMissing, checkIfImageAlreadyPulled(image)]), 390 390 + Effect.flatMap(() => pullFromRegistry(image)), 391 391 + Effect.flatMap(() => getImageArchivePath(image)), 392 392 + Effect.flatMap(extractImage), 393 393 + Effect.flatMap((imagePath: string) => 394 394 + Effect.all([ 395 395 + Effect.succeed(imagePath), 396 396 + getImageDigest(image), 397 397 + Effect.succeed(image), 398 398 + ]) 399 399 + ), 400 400 + Effect.flatMap(([imagePath, digest, image]) => 401 401 + savePulledImage(imagePath, digest, image) 402 402 + ), 403 403 + Effect.flatMap(cleanup), 404 404 + Effect.catchTag("ImageAlreadyPulledError", () => 405 405 + Effect.sync(() => console.log(`Image ${image} is already pulled.`))), 406 406 + );

+55

src/subcommands/images.ts

··· 1 1 + import { Table } from "@cliffy/table"; 2 2 + import dayjs from "dayjs"; 3 3 + import relativeTime from "dayjs/plugin/relativeTime.js"; 4 4 + import utc from "dayjs/plugin/utc.js"; 5 5 + import { Effect, pipe } from "effect"; 6 6 + import type { Image } from "../db.ts"; 7 7 + import { type DbError, listImages } from "../images.ts"; 8 8 + import { humanFileSize } from "../utils.ts"; 9 9 + 10 10 + dayjs.extend(relativeTime); 11 11 + dayjs.extend(utc); 12 12 + 13 13 + const createTable = () => 14 14 + Effect.succeed( 15 15 + new Table( 16 16 + ["REPOSITORY", "TAG", "IMAGE ID", "CREATED", "SIZE"], 17 17 + ), 18 18 + ); 19 19 + 20 20 + const populateTable = (table: Table, images: Image[]) => 21 21 + Effect.gen(function* () { 22 22 + for (const image of images) { 23 23 + table.push([ 24 24 + image.repository, 25 25 + image.tag, 26 26 + image.id, 27 27 + dayjs.utc(image.createdAt).local().fromNow(), 28 28 + yield* humanFileSize(image.size), 29 29 + ]); 30 30 + } 31 31 + return table; 32 32 + }); 33 33 + 34 34 + const displayTable = (table: Table) => 35 35 + Effect.sync(() => { 36 36 + console.log(table.padding(2).toString()); 37 37 + }); 38 38 + 39 39 + const handleError = (error: DbError | Error) => 40 40 + Effect.sync(() => { 41 41 + console.error(`Failed to fetch virtual machines: ${error}`); 42 42 + Deno.exit(1); 43 43 + }); 44 44 + 45 45 + const lsEffect = () => 46 46 + pipe( 47 47 + Effect.all([listImages(), createTable()]), 48 48 + Effect.flatMap(([images, table]) => populateTable(table, images)), 49 49 + Effect.flatMap(displayTable), 50 50 + Effect.catchAll(handleError), 51 51 + ); 52 52 + 53 53 + export default async function () { 54 54 + await Effect.runPromise(lsEffect()); 55 55 + }

+14 -11

src/subcommands/inspect.ts

··· 1 1 import { Data, Effect, pipe } from "effect"; 2 2 - import type { VirtualMachine } from "../db.ts"; 2 2 + import type { Image, VirtualMachine } from "../db.ts"; 3 3 + import { getImage } from "../images.ts"; 3 4 import { getInstanceState } from "../state.ts"; 4 5 5 5 - class VmNotFoundError extends Data.TaggedError("VmNotFoundError")<{ 6 6 + class ItemNotFoundError extends Data.TaggedError("ItemNotFoundError")<{ 6 7 name: string; 7 8 }> {} 8 9 9 9 - const findVm = (name: string) => 10 10 + const find = (name: string) => 10 11 pipe( 11 11 - getInstanceState(name), 12 12 - Effect.flatMap((vm) => 13 13 - vm ? Effect.succeed(vm) : Effect.fail(new VmNotFoundError({ name })) 12 12 + Effect.all([getInstanceState(name), getImage(name)]), 13 13 + Effect.flatMap(([vm, image]) => 14 14 + vm || image 15 15 + ? Effect.succeed(vm || image) 16 16 + : Effect.fail(new ItemNotFoundError({ name })) 14 17 ), 15 18 ); 16 19 17 17 - const displayVm = (vm: VirtualMachine) => 20 20 + const display = (vm: VirtualMachine | Image | undefined) => 18 21 Effect.sync(() => { 19 22 console.log(vm); 20 23 }); 21 24 22 22 - const handleError = (error: VmNotFoundError | Error) => 25 25 + const handleError = (error: ItemNotFoundError | Error) => 23 26 Effect.sync(() => { 24 24 - if (error instanceof VmNotFoundError) { 27 27 + if (error instanceof ItemNotFoundError) { 25 28 console.error( 26 29 `Virtual machine with name or ID ${error.name} not found.`, 27 30 ); ··· 33 36 34 37 const inspectEffect = (name: string) => 35 38 pipe( 36 36 - findVm(name), 37 37 - Effect.flatMap(displayVm), 39 39 + find(name), 40 40 + Effect.flatMap(display), 38 41 Effect.catchAll(handleError), 39 42 ); 40 43

+35

src/subcommands/login.ts

··· 1 1 + import { setupOrasBinary } from "../oras.ts"; 2 2 + 3 3 + export default async function ( 4 4 + username: string, 5 5 + password: string, 6 6 + reqistry: string, 7 7 + ) { 8 8 + await setupOrasBinary(); 9 9 + 10 10 + const cmd = new Deno.Command("oras", { 11 11 + args: [ 12 12 + "login", 13 13 + "--username", 14 14 + username, 15 15 + "--password-stdin", 16 16 + reqistry, 17 17 + ], 18 18 + stdin: "piped", 19 19 + stderr: "inherit", 20 20 + stdout: "inherit", 21 21 + }); 22 22 + 23 23 + const process = cmd.spawn(); 24 24 + if (process.stdin) { 25 25 + const writer = process.stdin.getWriter(); 26 26 + await writer.write(new TextEncoder().encode(password + "\n")); 27 27 + writer.close(); 28 28 + } 29 29 + 30 30 + const status = await process.status; 31 31 + 32 32 + if (!status.success) { 33 33 + Deno.exit(status.code); 34 34 + } 35 35 + }

+19

src/subcommands/logout.ts

··· 1 1 + import { setupOrasBinary } from "../oras.ts"; 2 2 + 3 3 + export default async function (registry: string) { 4 4 + await setupOrasBinary(); 5 5 + 6 6 + const cmd = new Deno.Command("oras", { 7 7 + args: ["logout", registry], 8 8 + stderr: "inherit", 9 9 + stdout: "inherit", 10 10 + }); 11 11 + 12 12 + const process = cmd.spawn(); 13 13 + 14 14 + const status = await process.status; 15 15 + 16 16 + if (!status.success) { 17 17 + Deno.exit(status.code); 18 18 + } 19 19 + }

+19

src/subcommands/pull.ts

··· 1 1 + import { Effect, pipe } from "effect"; 2 2 + import { pullImage, setupOrasBinary } from "../oras.ts"; 3 3 + import { validateImage } from "../utils.ts"; 4 4 + 5 5 + export default async function (image: string): Promise<void> { 6 6 + await Effect.runPromise( 7 7 + pipe( 8 8 + Effect.promise(() => setupOrasBinary()), 9 9 + Effect.tap(() => validateImage(image)), 10 10 + Effect.tap(() => pullImage(image)), 11 11 + Effect.catchAll((error) => 12 12 + Effect.sync(() => { 13 13 + console.error(`Failed to pull image: ${error.cause}`); 14 14 + Deno.exit(1); 15 15 + }) 16 16 + ), 17 17 + ), 18 18 + ); 19 19 + }

+19

src/subcommands/push.ts

··· 1 1 + import { Effect, pipe } from "effect"; 2 2 + import { pushImage, setupOrasBinary } from "../oras.ts"; 3 3 + import { validateImage } from "../utils.ts"; 4 4 + 5 5 + export default async function (image: string): Promise<void> { 6 6 + await Effect.runPromise( 7 7 + pipe( 8 8 + Effect.promise(() => setupOrasBinary()), 9 9 + Effect.tap(() => validateImage(image)), 10 10 + Effect.tap(() => pushImage(image)), 11 11 + Effect.catchAll((error) => 12 12 + Effect.sync(() => { 13 13 + console.error(`Failed to push image: ${error.cause}`); 14 14 + Deno.exit(1); 15 15 + }) 16 16 + ), 17 17 + ), 18 18 + ); 19 19 + }

+20

src/subcommands/rmi.ts

··· 1 1 + import { Effect, pipe } from "effect"; 2 2 + import { deleteImage, getImage } from "../images.ts"; 3 3 + import { failOnMissingImage } from "../utils.ts"; 4 4 + 5 5 + export default async function (id: string) { 6 6 + await Effect.runPromise( 7 7 + pipe( 8 8 + getImage(id), 9 9 + Effect.flatMap(failOnMissingImage), 10 10 + Effect.tap(() => deleteImage(id)), 11 11 + Effect.tap(() => console.log(`Image ${id} removed successfully.`)), 12 12 + Effect.catchAll((error) => 13 13 + Effect.sync(() => { 14 14 + console.error(`Failed to remove image: ${error.message}`); 15 15 + Deno.exit(1); 16 16 + }) 17 17 + ), 18 18 + ), 19 19 + ); 20 20 + }

+73

src/subcommands/run.ts

··· 1 1 + import { parseFlags } from "@cliffy/flags"; 2 2 + import { Effect, pipe } from "effect"; 3 3 + import type { Image } from "../db.ts"; 4 4 + import { getImage } from "../images.ts"; 5 5 + import { createBridgeNetworkIfNeeded } from "../network.ts"; 6 6 + import { pullImage, PullImageError, setupOrasBinary } from "../oras.ts"; 7 7 + import { type Options, runQemu, validateImage } from "../utils.ts"; 8 8 + 9 9 + const pullImageOnMissing = ( 10 10 + name: string, 11 11 + ): Effect.Effect<Image, Error, never> => 12 12 + pipe( 13 13 + getImage(name), 14 14 + Effect.flatMap((img) => { 15 15 + if (img) { 16 16 + return Effect.succeed(img); 17 17 + } 18 18 + console.log(`Image ${name} not found locally`); 19 19 + return pipe( 20 20 + pullImage(name), 21 21 + Effect.flatMap(() => getImage(name)), 22 22 + Effect.flatMap((pulledImg) => 23 23 + pulledImg ? Effect.succeed(pulledImg) : Effect.fail( 24 24 + new PullImageError({ cause: "Failed to pull image" }), 25 25 + ) 26 26 + ), 27 27 + ); 28 28 + }), 29 29 + ); 30 30 + 31 31 + const runImage = (image: Image) => 32 32 + Effect.gen(function* () { 33 33 + console.log(`Running image ${image.repository}...`); 34 34 + const options = mergeFlags(image); 35 35 + if (options.bridge) { 36 36 + yield* createBridgeNetworkIfNeeded(options.bridge); 37 37 + } 38 38 + yield* runQemu(null, options); 39 39 + }); 40 40 + 41 41 + export default async function ( 42 42 + image: string, 43 43 + ): Promise<void> { 44 44 + await Effect.runPromise( 45 45 + pipe( 46 46 + Effect.promise(() => setupOrasBinary()), 47 47 + Effect.tap(() => validateImage(image)), 48 48 + Effect.flatMap(() => pullImageOnMissing(image)), 49 49 + Effect.flatMap(runImage), 50 50 + Effect.catchAll((error) => 51 51 + Effect.sync(() => { 52 52 + console.error(`Failed to run image: ${error.cause} ${image}`); 53 53 + Deno.exit(1); 54 54 + }) 55 55 + ), 56 56 + ), 57 57 + ); 58 58 + } 59 59 + 60 60 + function mergeFlags(image: Image): Options { 61 61 + const { flags } = parseFlags(Deno.args); 62 62 + return { 63 63 + cpu: flags.cpu ? flags.cpu : "host", 64 64 + cpus: flags.cpus ? flags.cpus : 2, 65 65 + memory: flags.memory ? flags.memory : "2G", 66 66 + image: image.path, 67 67 + bridge: flags.bridge, 68 68 + portForward: flags.portForward, 69 69 + detach: flags.detach, 70 70 + install: false, 71 71 + diskFormat: image.format, 72 72 + }; 73 73 + }

+46

src/subcommands/tag.ts

··· 1 1 + import { createId } from "@paralleldrive/cuid2"; 2 2 + import { Effect, pipe } from "effect"; 3 3 + import { saveImage } from "../images.ts"; 4 4 + import { getInstanceState, type VirtualMachine } from "../mod.ts"; 5 5 + import { du, extractTag } from "../utils.ts"; 6 6 + 7 7 + const failIfNoVM = ( 8 8 + [vm, tag]: [VirtualMachine | undefined, string], 9 9 + ) => 10 10 + Effect.gen(function* () { 11 11 + if (!vm) { 12 12 + throw new Error(`VM with name ${name} not found`); 13 13 + } 14 14 + if (!vm.drivePath) { 15 15 + throw new Error(`VM with name ${name} has no drive attached`); 16 16 + } 17 17 + 18 18 + const size = yield* du(vm.drivePath); 19 19 + 20 20 + return [vm, tag, size] as [VirtualMachine, string, number]; 21 21 + }); 22 22 + 23 23 + export default async function (name: string, image: string) { 24 24 + await Effect.runPromise( 25 25 + pipe( 26 26 + Effect.all([getInstanceState(name), extractTag(image)]), 27 27 + Effect.flatMap(failIfNoVM), 28 28 + Effect.flatMap(([vm, tag, size]) => 29 29 + saveImage({ 30 30 + id: createId(), 31 31 + repository: image.split(":")[0], 32 32 + tag, 33 33 + size, 34 34 + path: vm.drivePath!, 35 35 + format: vm.diskFormat, 36 36 + }) 37 37 + ), 38 38 + Effect.catchAll((error) => 39 39 + Effect.sync(() => { 40 40 + console.error(`Failed to tag image: ${error.cause}`); 41 41 + Deno.exit(1); 42 42 + }) 43 43 + ), 44 44 + ), 45 45 + ); 46 46 + }

+86 -9

src/utils.ts

··· 1 1 import _ from "@es-toolkit/es-toolkit/compat"; 2 2 import { createId } from "@paralleldrive/cuid2"; 3 3 import chalk from "chalk"; 4 4 - import { Data, Effect } from "effect"; 4 4 + import { Data, Effect, pipe } from "effect"; 5 5 import Moniker from "moniker"; 6 6 import { EMPTY_DISK_THRESHOLD_KB, LOGS_DIR } from "./constants.ts"; 7 7 + import type { Image } from "./db.ts"; 7 8 import { generateRandomMacAddress } from "./network.ts"; 8 9 import { 9 10 type DbError, ··· 19 20 cpus: number; 20 21 memory: string; 21 22 image?: string; 22 22 - diskFormat: string; 23 23 - size: string; 23 23 + diskFormat?: string; 24 24 + size?: string; 24 25 bridge?: string; 25 26 portForward?: string; 26 27 detach?: boolean; 28 28 + install?: boolean; 27 29 } 28 30 29 31 class LogCommandError extends Data.TaggedError("LogCommandError")<{ 30 32 cause?: unknown; 31 33 }> {} 32 34 35 35 + class InvalidImageNameError extends Data.TaggedError("InvalidImageNameError")<{ 36 36 + image: string; 37 37 + cause?: unknown; 38 38 + }> {} 39 39 + 40 40 + class NoSuchImageError extends Data.TaggedError("NoSuchImageError")<{ 41 41 + cause: string; 42 42 + }> {} 43 43 + 44 44 + export const getCurrentArch = (): string => { 45 45 + switch (Deno.build.arch) { 46 46 + case "x86_64": 47 47 + return "amd64"; 48 48 + case "aarch64": 49 49 + return "arm64"; 50 50 + default: 51 51 + return Deno.build.arch; 52 52 + } 53 53 + }; 54 54 + 33 55 export const isValidISOurl = (url?: string): boolean => { 34 56 return Boolean( 35 57 (url?.startsWith("http://") || url?.startsWith("https://")) && ··· 37 59 ); 38 60 }; 39 61 40 40 - const du = (path: string): Effect.Effect<number, LogCommandError, never> => 62 62 + export const humanFileSize = (blocks: number) => 63 63 + Effect.sync(() => { 64 64 + const blockSize = 512; // bytes per block 65 65 + let bytes = blocks * blockSize; 66 66 + const thresh = 1024; 67 67 + 68 68 + if (Math.abs(bytes) < thresh) { 69 69 + return `${bytes}B`; 70 70 + } 71 71 + 72 72 + const units = ["KB", "MB", "GB", "TB", "PB", "EB", "ZB", "YB"]; 73 73 + let u = -1; 74 74 + 75 75 + do { 76 76 + bytes /= thresh; 77 77 + ++u; 78 78 + } while (Math.abs(bytes) >= thresh && u < units.length - 1); 79 79 + 80 80 + return `${bytes.toFixed(1)}${units[u]}`; 81 81 + }); 82 82 + 83 83 + export const validateImage = ( 84 84 + image: string, 85 85 + ): Effect.Effect<string, InvalidImageNameError, never> => { 86 86 + const regex = 87 87 + /^(?:[a-zA-Z0-9.-]+(?:\.[a-zA-Z0-9.-]+)*\/)?[a-z0-9]+(?:[._-][a-z0-9]+)*\/[a-z0-9]+(?:[._-][a-z0-9]+)*(?::[a-zA-Z0-9._-]+)?$/; 88 88 + 89 89 + if (!regex.test(image)) { 90 90 + return Effect.fail( 91 91 + new InvalidImageNameError({ 92 92 + image, 93 93 + cause: 94 94 + "Image name does not conform to expected format. Should be in the format 'repository/name:tag'.", 95 95 + }), 96 96 + ); 97 97 + } 98 98 + return Effect.succeed(image); 99 99 + }; 100 100 + 101 101 + export const extractTag = (name: string) => 102 102 + pipe( 103 103 + validateImage(name), 104 104 + Effect.flatMap((image) => Effect.succeed(image.split(":")[1] || "latest")), 105 105 + ); 106 106 + 107 107 + export const failOnMissingImage = ( 108 108 + image: Image | undefined, 109 109 + ): Effect.Effect<Image, Error, never> => 110 110 + image 111 111 + ? Effect.succeed(image) 112 112 + : Effect.fail(new NoSuchImageError({ cause: "No such image" })); 113 113 + 114 114 + export const du = ( 115 115 + path: string, 116 116 + ): Effect.Effect<number, LogCommandError, never> => 41 117 Effect.tryPromise({ 42 118 try: async () => { 43 119 const cmd = new Deno.Command("du", { ··· 253 329 : setupNATNetworkArgs(options.portForward), 254 330 "-device", 255 331 `e1000,netdev=net0,mac=${macAddress}`, 332 332 + ...(options.install ? [] : ["-snapshot"]), 256 333 "-nographic", 257 334 "-monitor", 258 335 "none", ··· 307 384 memory: options.memory, 308 385 cpus: options.cpus, 309 386 cpu: options.cpu, 310 310 - diskSize: options.size, 311 311 - diskFormat: options.diskFormat, 387 387 + diskSize: options.size || "20G", 388 388 + diskFormat: options.diskFormat || "raw", 312 389 portForward: options.portForward, 313 390 isoPath: isoPath ? Deno.realPathSync(isoPath) : undefined, 314 391 drivePath: options.image ? Deno.realPathSync(options.image) : undefined, ··· 341 418 memory: options.memory, 342 419 cpus: options.cpus, 343 420 cpu: options.cpu, 344 344 - diskSize: options.size, 345 345 - diskFormat: options.diskFormat, 421 421 + diskSize: options.size || "20G", 422 422 + diskFormat: options.diskFormat || "raw", 346 423 portForward: options.portForward, 347 424 isoPath: isoPath ? Deno.realPathSync(isoPath) : undefined, 348 425 drivePath: options.image ? Deno.realPathSync(options.image) : undefined, ··· 478 555 const status = yield* Effect.tryPromise({ 479 556 try: async () => { 480 557 const cmd = new Deno.Command("qemu-img", { 481 481 - args: ["create", "-f", format, path!, size!], 558 558 + args: ["create", "-f", format || "raw", path!, size || "20G"], 482 559 stdin: "inherit", 483 560 stdout: "inherit", 484 561 stderr: "inherit",