sf orders cancel <id> (#11)

* ping & me

* nodes label & start date floor

* epoch

* cancel order

* cancel

Author: bephrem1

src/helpers/errors.ts

@@ -28,6 +28,7 @@ export const ApiErrorCode = {
     InvalidStart: "order.invalid_start",
     InvalidDuration: "order.invalid_duration",
     InsufficientFunds: "order.insufficient_funds",
+    AlreadyCancelled: "order.already_cancelled",
     NotFound: "order.not_found",
   },
   Tokens: {

src/helpers/urls.ts

@@ -8,11 +8,13 @@ const webPaths = {
 
 const apiPaths = {
   index: "/",
+  me: "/v0/me",
   ping: "/v0/ping",
 
   orders_create: "/v0/orders",
   orders_list: "/v0/orders",
   orders_get: ({ id }: { id: string }) => `/v0/orders/${id}`,
+  orders_cancel: ({ id }: { id: string }) => `/v0/orders/${id}`,
 
   instances_list: "/v0/instances",
   instances_get: ({ id }: { id: string }) => `/v0/instances/${id}`,

src/lib/buy.ts

@@ -35,6 +35,7 @@ export function registerBuy(program: Command) {
 
 function confirmPlaceOrderParametersMessage(params: PlaceOrderParameters) {
   const { quantity, price, instance_type, duration, start_at } = params;
+  const nodesLabel = quantity > 1 ? "nodes" : "node";
 
   const startDate = new Date(start_at);
 
@@ -43,11 +44,11 @@ function confirmPlaceOrderParametersMessage(params: PlaceOrderParameters) {
   const centicentsAsDollars = (price / 10_000).toFixed(2);
   const durationHumanReadable = formatDuration(duration * 1000);
 
-  const topLine = `${c.green(quantity)} ${c.green(instance_type)} nodes for ${c.green(durationHumanReadable)} starting ${c.green(humanReadableStartAt)} (${c.green(fromNowTime)})`;
+  const topLine = `${c.green(quantity)} ${c.green(instance_type)} ${nodesLabel} for ${c.green(durationHumanReadable)} starting ${c.green(humanReadableStartAt)} (${c.green(fromNowTime)})`;
 
   const priceLine = `\nBuy for ${c.green(`$${centicentsAsDollars}`)}? ${c.dim("(y/n)")}`;
 
-  return `\n${topLine}\n${priceLine} `;
+  return `${topLine}\n${priceLine} `;
 }
 
 interface PostOrderResponse {
@@ -91,7 +92,9 @@ async function placeBuyOrder(props: PlaceBuyOrderArguments) {
     return logAndQuit("Invalid duration");
   }
 
-  const startDate = start ? chrono.parseDate(start) : new Date();
+  const startDate = start
+    ? chrono.parseDate(start)
+    : dayjs().add(1, "hour").toDate();
   if (!startDate) {
     return logAndQuit("Invalid start date");
   }

src/lib/dev.ts

@@ -1,19 +1,46 @@
 import { confirm } from "@inquirer/prompts";
 import type { Command } from "commander";
-import { deleteConfig, getConfigPath, loadConfig } from "../helpers/config";
+import {
+  deleteConfig,
+  getConfigPath,
+  isLoggedIn,
+  loadConfig,
+} from "../helpers/config";
+import {
+  logAndQuit,
+  logLoginMessageAndQuit,
+  logSessionTokenExpiredAndQuit,
+} from "../helpers/errors";
+import { getApiUrl } from "../helpers/urls";
 
 // development only commands
 export function registerDev(program: Command) {
   if (process.env.IS_DEVELOPMENT_CLI_ENV) {
-    program.command("ping").action(async () => {
-      console.log("pong");
+    registerConfig(program);
+
+    program.command("me").action(async () => {
+      const accountId = await getLoggedInAccountId();
+      console.log(accountId);
+
       process.exit(0);
     });
+    program.command("epoch").action(async () => {
+      const MILLS_PER_EPOCH = 1000 * 60 * 60;
+      console.log(Math.floor(Date.now() / MILLS_PER_EPOCH));
 
-    registerConfig(program);
+      process.exit(0);
+    });
+    program.command("ping").action(async () => {
+      const data = await pingServer();
+      console.log(data);
+
+      process.exit(0);
+    });
   }
 }
 
+// --
+
 function registerConfig(program: Command) {
   const configCmd = program
     .command("config")
@@ -44,8 +71,6 @@ function registerConfig(program: Command) {
     .action(removeConfigAction);
 }
 
-// --
-
 async function showConfigAction() {
   const config = await loadConfig();
   console.log(config);
@@ -62,3 +87,59 @@ async function removeConfigAction() {
   }
   process.exit(0);
 }
+
+// --
+
+async function getLoggedInAccountId() {
+  const loggedIn = await isLoggedIn();
+  if (!loggedIn) {
+    logLoginMessageAndQuit();
+  }
+  const config = await loadConfig();
+
+  const response = await fetch(await getApiUrl("me"), {
+    method: "GET",
+    headers: {
+      "Content-Type": "application/json",
+      Authorization: `Bearer ${config.auth_token}`,
+    },
+  });
+  if (!response.ok) {
+    if (response.status === 401) {
+      logSessionTokenExpiredAndQuit();
+    }
+
+    logAndQuit("Failed to fetch account info");
+  }
+
+  const data = await response.json();
+
+  return data.id;
+}
+
+async function pingServer() {
+  const loggedIn = await isLoggedIn();
+  if (!loggedIn) {
+    logLoginMessageAndQuit();
+  }
+  const config = await loadConfig();
+
+  const response = await fetch(await getApiUrl("ping"), {
+    method: "GET",
+    headers: {
+      "Content-Type": "application/json",
+      Authorization: `Bearer ${config.auth_token}`,
+    },
+  });
+  if (!response.ok) {
+    if (response.status === 401) {
+      logSessionTokenExpiredAndQuit();
+    }
+
+    logAndQuit("Failed to ping server");
+  }
+
+  const data = await response.json();
+
+  return data;
+}

src/lib/orders.ts

@@ -4,7 +4,13 @@ import dayjs from "dayjs";
 import duration from "dayjs/plugin/duration";
 import relativeTime from "dayjs/plugin/relativeTime";
 import { getAuthToken, isLoggedIn } from "../helpers/config";
-import { logAndQuit, logLoginMessageAndQuit } from "../helpers/errors";
+import {
+  ApiErrorCode,
+  logAndQuit,
+  logLoginMessageAndQuit,
+  logSessionTokenExpiredAndQuit,
+  type ApiError,
+} from "../helpers/errors";
 import { getApiUrl } from "../helpers/urls";
 import type { ListResponseBody, Order } from "./types";
 
@@ -65,7 +71,7 @@ export function priceToCenticents(price: string | number): number {
     const numericPrice = Number.parseFloat(price.replace(/^\$/, ""));
 
     // Convert dollars to centicents
-    return Math.round(numericPrice * 10000);
+    return Math.round(numericPrice * 10_000);
   } catch (error) {
     logAndQuit("Invalid price");
   }
@@ -142,6 +148,11 @@ export function registerOrders(program: Command) {
 
       process.exit(0);
     });
+
+  ordersCommand
+    .command("cancel <id>")
+    .description("Cancel an order")
+    .action(submitOrderCancellationByIdAction);
 }
 
 export async function getOrders(props: {
@@ -186,3 +197,48 @@ export async function getOrders(props: {
   const resp = (await response.json()) as ListResponseBody<Order>;
   return resp.data;
 }
+
+export async function submitOrderCancellationByIdAction(
+  orderId: string,
+): Promise<void> {
+  const loggedIn = await isLoggedIn();
+  if (!loggedIn) {
+    logLoginMessageAndQuit();
+  }
+
+  const url = await getApiUrl("orders_cancel", { id: orderId });
+  const response = await fetch(url, {
+    method: "DELETE",
+    body: JSON.stringify({}),
+    headers: {
+      "Content-Type": "application/json",
+      Authorization: `Bearer ${await getAuthToken()}`,
+    },
+  });
+  if (!response.ok) {
+    if (response.status === 401) {
+      await logSessionTokenExpiredAndQuit();
+    }
+
+    const error = (await response.json()) as ApiError;
+    if (error.code === ApiErrorCode.Orders.NotFound) {
+      logAndQuit(`Order ${orderId} not found`);
+    } else if (error.code === ApiErrorCode.Orders.AlreadyCancelled) {
+      logAndQuit(`Order ${orderId} is already cancelled`);
+    }
+
+    // TODO: handle more specific errors
+
+    logAndQuit(`Failed to cancel order ${orderId}`);
+  }
+
+  const resp = await response.json();
+  const cancellationSubmitted = resp.object === "pending";
+  if (!cancellationSubmitted) {
+    logAndQuit(`Failed to cancel order ${orderId}`);
+  }
+
+  // cancellation submitted successfully
+  console.log(`Cancellation for Order ${orderId} submitted.`);
+  process.exit(0);
+}