setup create database

src/commands/database/create.mjs

@@ -1,19 +1,46 @@
 //@ts-check
 
+import { fql } from "fauna";
 import { container } from "../../cli.mjs";
+import { runV10Query } from "../../lib/fauna.mjs";
+import { commonQueryOptions } from "../../lib/command-helpers.mjs";
 
-async function createDatabase() {
+async function createDatabase(argv) {
   const logger = container.resolve("logger");
-  logger.stdout(`TBD`);
+
+  await runV10Query({
+    url: argv.url,
+    secret: argv.secret,
+    query: fql`Database.create({
+      name: ${argv.name},
+      protected: ${argv.protected ?? false},
+      typechecked: ${argv.typechecked ?? false}
+    })`,
+  });
+
+  logger.stdout(`Database ${argv.name} created`);
 }
 
 function buildCreateCommand(yargs) {
   return yargs
     .options({
+      ...commonQueryOptions,
       name: {
         type: "string",
         description: "the name of the database to create",
       },
+      typechecked: {
+        type: "boolean",
+        description: "enable typechecking for the database",
+      },
+      protected: {
+        type: "boolean",
+        description: "allow destructive schema changes",
+      },
+      priority: {
+        type: "number",
+        description: "user-defined priority assigned to the child database",
+      },
     })
     .demandOption("name")
     .version(false)

src/lib/fauna.mjs

@@ -0,0 +1,31 @@
+export const getV10Client = async ({ url, secret }) => {
+  const { Client } = (await import("fauna")).default;
+  return new Client({
+    secret,
+    endpoint: url,
+  });
+};
+
+export const runV10Query = async ({
+  query,
+  url = undefined,
+  secret = undefined,
+  client = undefined,
+  options = {
+    format: "simple",
+    typecheck: false,
+  },
+}) => {
+  let _client = client;
+
+  if (!_client && url && secret) {
+    _client = await getV10Client({ url, secret });
+  } else if (!_client) {
+    throw new Error("No client provided and no url and secret provided");
+  }
+
+  return _client.query(query, options).finally(() => {
+    // Clean up the client if one was created internally.
+    if (!client) _client.close();
+  });
+};