Command to start a local container

package.json

@@ -13,6 +13,7 @@
     "@shikijs/cli": "^1.24.0",
     "awilix": "^12.0.2",
     "chalk": "^5.3.0",
+    "dockerode": "^4.0.2",
     "eslint": "^9.12.0",
     "esprima": "^4.0.1",
     "fauna": "^2.4.0",
@@ -79,7 +80,7 @@
     "pretest:ci": "npm run build:app",
     "test:ci": "mocha --forbid-only --recursive ./test --require ./test/mocha-root-hooks.mjs --reporter mocha-multi-reporters --reporter-options configFile=./test/config/reporter.json",
     "build": "npm run build:app && npm run build:sea",
-    "build:app": "esbuild --bundle ./src/user-entrypoint.mjs --platform=node --outfile=./dist/cli.cjs --format=cjs --inject:./sea/import-meta-url.js --define:import.meta.url=importMetaUrl --define:process.env.NODE_ENV=\\\"production\\\"",
+    "build:app": "esbuild --loader:.node=file --bundle ./src/user-entrypoint.mjs --platform=node --outfile=./dist/cli.cjs --format=cjs --inject:./sea/import-meta-url.js --define:import.meta.url=importMetaUrl --define:process.env.NODE_ENV=\\\"production\\\"",
     "build:sea": "node ./sea/build.cjs",
     "format": "prettier -w --log-level silent .",
     "format:check": "prettier -c .",

src/cli.mjs

@@ -4,6 +4,7 @@ import chalk from "chalk";
 import yargs from "yargs";
 
 import databaseCommand from "./commands/database/database.mjs";
+import localCommand from "./commands/local.mjs";
 import loginCommand from "./commands/login.mjs";
 import queryCommand from "./commands/query.mjs";
 import schemaCommand from "./commands/schema/schema.mjs";
@@ -108,6 +109,7 @@ function buildYargs(argvInput) {
     .command(loginCommand)
     .command(schemaCommand)
     .command(databaseCommand)
+    .command(localCommand)
     .demandCommand()
     .strictCommands(true)
     .options({

src/commands/local.mjs

@@ -0,0 +1,55 @@
+import { ensureContainerRunning } from "../lib/docker-containers.mjs";
+
+/**
+ * Starts the local Fauna container
+ * @param {import('yargs').Arguments} argv The arguments from yargs
+ * @returns {Promise<void>} a promise that resolves when the container is ready.
+ * It will reject if the container is not ready after the maximum number of attempts.
+ */
+async function startLocal(argv) {
+  await ensureContainerRunning({
+    imageName: argv.image,
+    containerName: argv.name,
+    hostPort: argv.hostPort,
+    containerPort: argv.containerPort,
+    pull: argv.pull,
+  });
+}
+
+/**
+ * Builds the yargs command for the local command
+ * @param {import('yargs').Argv} yargs The yargs instance
+ * @returns {import('yargs').Argv} The yargs instance
+ */
+function buildLocalCommand(yargs) {
+  return yargs.options({
+    containerPort: {
+      describe: "The port inside the container Fauna listens on.",
+      type: "number",
+      default: "8443",
+    },
+    hostPort: {
+      describe:
+        "The port on the host machine mapped to the container's port. This is the port you'll connect to Fauna on.",
+      type: "number",
+      default: "8443",
+    },
+    name: {
+      describe: "The name to give the container",
+      type: "string",
+      default: "faunadb",
+    },
+    pull: {
+      describe: "Pull the latest image before starting the container.",
+      type: "boolean",
+      default: true,
+    },
+  });
+}
+
+export default {
+  command: "local",
+  describe: "Start a local Fauna container",
+  builder: buildLocalCommand,
+  handler: startLocal,
+};

src/config/setup-container.mjs

@@ -7,6 +7,7 @@ import { exit } from "node:process";
 import { confirm } from "@inquirer/prompts";
 import * as awilix from "awilix";
 import { Lifetime } from "awilix";
+import Docker from "dockerode";
 import fauna from "fauna";
 import faunadb from "faunadb";
 import open from "open";
@@ -74,6 +75,14 @@ export const injectables = {
   // generic lib (homemade utilities)
   parseYargs: awilix.asValue(parseYargs),
   logger: awilix.asFunction(buildLogger, { lifetime: Lifetime.SINGLETON }),
+  docker: awilix.asFunction(
+    () => {
+      const dockerInstance = new Docker(); // Create instance
+      // If Docker requires additional async setup, perform it here and return a promise
+      return dockerInstance;
+    },
+    { lifetime: Lifetime.SINGLETON },
+  ),
   oauthClient: awilix.asClass(OAuthClient, { lifetime: Lifetime.SCOPED }),
   makeAccountRequest: awilix.asValue(makeAccountRequest),
   makeFaunaRequest: awilix.asValue(makeRetryableFaunaRequest),

src/config/setup-test-container.mjs

@@ -81,6 +81,15 @@ export function setupTestContainer() {
       getSession: stub(),
     })),
     oauthClient: awilix.asFunction(stub()),
+    docker: awilix.asValue({
+      createContainer: stub(),
+      getContainer: stub(),
+      listContainers: stub(),
+      modem: {
+        followProgress: stub(),
+      },
+      pull: stub(),
+    }),
     credentials: awilix.asClass(stub()).singleton(),
     errorHandler: awilix.asValue((error, exitCode) => {
       error.code = exitCode;

src/lib/auth/oauth-client.mjs

@@ -6,10 +6,10 @@
 import SuccessPage from "./successPage.mjs";
 
 // Default to prod client id and secret
-const clientId = process.env.FAUNA_CLIENT_ID ?? "Aq4_G0mOtm_F1fK3PuzE0k-i9F0";
+const CLIENT_ID = process.env.FAUNA_CLIENT_ID ?? "Aq4_G0mOtm_F1fK3PuzE0k-i9F0";
 // Native public clients are not confidential. The client secret is not used beyond
 //   client identification. https://datatracker.ietf.org/doc/html/rfc8252#section-8.5
-const clientSecret =
+const CLIENT_SECRET =
   process.env.FAUNA_CLIENT_SECRET ??
   "2W9eZYlyN5XwnpvaP3AwOfclrtAjTXncH6k-bdFq1ZV0hZMFPzRIfg";
 const REDIRECT_URI = `http://127.0.0.1`;
@@ -28,7 +28,7 @@
 
   getOAuthParams() {
     return {
-      client_id: clientId, // eslint-disable-line camelcase
+      client_id: CLIENT_ID, // eslint-disable-line camelcase
       redirect_uri: `${REDIRECT_URI}:${this.port}`, // eslint-disable-line camelcase
       code_challenge: this.codeChallenge, // eslint-disable-line camelcase
       code_challenge_method: "S256", // eslint-disable-line camelcase
@@ -40,8 +40,8 @@
 
   getTokenParams() {
     return {
-      clientId,
-      clientSecret,
+      clientId: CLIENT_ID,
+      clientSecret: CLIENT_SECRET,
       authCode: this.authCode,
       redirectURI: `${REDIRECT_URI}:${this.port}`,
       codeVerifier: this.codeVerifier,
@@ -53,7 +53,7 @@
   }
 
   // req: IncomingMessage, res: ServerResponse
   _handleRequest(req, res) {
     const logger = container.resolve("logger");
     const allowedOrigins = [
       "http://localhost:3005",