2219335671

Build # 2219335671

Build Type

github

Committed by GitHub

Commit Message

Merge 8825ee190 into 026232ab6

Pull Request Pull Request #975: migrate phase 1: support old/new instances both sending over jobs

Run Details

553 of 742 branches covered (74.53%)

Branch coverage included in aggregate %.

9 of 10 new or added lines in 2 files covered. (90.0%)

21 existing lines in 4 files now uncovered.

1080 of 1267 relevant lines covered (85.24%)

22.77 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

66.67

/src/cli/commands/update-cron.ts

import { Command } from "commander";
import { promises as fs } from "fs";
import { QuirrelClient } from "../../client";
import {
  RouteScheduleManifest,
  RouteScheduleManifestSchema,
} from "./detect-cron";
import * as config from "../../client/config";
import Table from "easy-table";

export function formatRouteScheduleMapAsTable(jobs: RouteScheduleManifest) {
  return Table.print(
    jobs.map((job) => ({
      Route: job.route,
      Schedule: job.schedule,
    }))
  );
}
export async function updateCron(
  scheduleMap: RouteScheduleManifest,
  dryRun: boolean,
  production: boolean
) {
  if (production) {
    process.env.NODE_ENV = "production";
  }

  const quirrel = new QuirrelClient({
    async handler() {},
    route: "",
  });

  console.log("Jobs:\n");

  console.log(formatRouteScheduleMapAsTable(scheduleMap));

  console.log("Updating server ... ");

  const endpointsResponse = await quirrel.makeRequest("/queues/update-cron", {
    method: "PUT",
    body: JSON.stringify({
      baseUrl: config.withoutTrailingSlash(
        config.prefixWithProtocol(config.getApplicationBaseUrl())
      ),
      crons: scheduleMap,
      dryRun,
    }),
    headers: { "content-type": "application/json" },
  });

  if (endpointsResponse.status !== 200) {
    console.error("Something went wrong: " + (await endpointsResponse.text()));
    return;
  }

  if (dryRun) {
    console.error(`This was a --dry-run, so nothing was applied.`);
  } else {
    console.error(`Successfully updated jobs.`);
  }

  const { deleted } = (await endpointsResponse.json()) as { deleted: string[] };
  if (deleted.length > 0) {
    console.error(
      `These jobs are obsolete, and ${dryRun ? "would be" : "were"} removed: `
    );
    deleted.forEach((route) => console.log(route));
  }
}

export default function registerUpdateCron(program: Command) {
  program
    .command("update-cron [filename]")
    .description(
      "Updates the Quirrel API with cron jobs that have been detected using detect-cron."
    )
    .option("-d, --dry-run", "Only plan the update, don't execute.", false)
    .option("-p, --production", "Use production config.", false)
    .action(
      async (
        filename = "/dev/stdin",
        { dryRun, production }: { dryRun: boolean; production: boolean }
      ) => {
        const routeScheduleMapString = await fs.readFile(filename, "utf-8");
        const routeScheduleMap = RouteScheduleManifestSchema.parse(
          JSON.parse(routeScheduleMapString)
        );

        await updateCron(routeScheduleMap, dryRun, production);
      }
    );
}

1	import { Command } from "commander";
2	import { promises as fs } from "fs";	1✔
3	import { QuirrelClient } from "../../client";	1✔
4	import {	1✔
5	RouteScheduleManifest,
6	RouteScheduleManifestSchema,
7	} from "./detect-cron";
8	import * as config from "../../client/config";	1✔
9	import Table from "easy-table";	1✔
10
11	export function formatRouteScheduleMapAsTable(jobs: RouteScheduleManifest) {	1✔
12	return Table.print(	3✔
13	jobs.map((job) => ({	4✔
14	Route: job.route,
15	Schedule: job.schedule,
16	}))
17	);
18	}
19	export async function updateCron(	1✔
20	scheduleMap: RouteScheduleManifest,
21	dryRun: boolean,
22	production: boolean
23	) {
24	if (production) {	3!
25	process.env.NODE_ENV = "production";	×
26	}
27
28	const quirrel = new QuirrelClient({	3✔
29	async handler() {},
30	route: "",
31	});
32
33	console.log("Jobs:\n");	3✔
34
35	console.log(formatRouteScheduleMapAsTable(scheduleMap));	3✔
36
37	console.log("Updating server ... ");	3✔
38
39	const endpointsResponse = await quirrel.makeRequest("/queues/update-cron", {	3✔
40	method: "PUT",
41	body: JSON.stringify({
42	baseUrl: config.withoutTrailingSlash(
43	config.prefixWithProtocol(config.getApplicationBaseUrl())
44	),
45	crons: scheduleMap,
46	dryRun,
47	}),
48	headers: { "content-type": "application/json" },
49	});
50
51	if (endpointsResponse.status !== 200) {	3!
52	console.error("Something went wrong: " + (await endpointsResponse.text()));	×
UNCOV 53	return;	×
54	}
55
56	if (dryRun) {	3!
UNCOV 57	console.error(`This was a --dry-run, so nothing was applied.`);	×
58	} else {
59	console.error(`Successfully updated jobs.`);	3✔
60	}
61
62	const { deleted } = (await endpointsResponse.json()) as { deleted: string[] };	3✔
63	if (deleted.length > 0) {	3✔
64	console.error(	1✔
65	`These jobs are obsolete, and ${dryRun ? "would be" : "were"} removed: `	1!
66	);
67	deleted.forEach((route) => console.log(route));	2✔
68	}
69	}
70
71	export default function registerUpdateCron(program: Command) {	1✔
UNCOV 72	program	×
73	.command("update-cron [filename]")
74	.description(
75	"Updates the Quirrel API with cron jobs that have been detected using detect-cron."
76	)
77	.option("-d, --dry-run", "Only plan the update, don't execute.", false)
78	.option("-p, --production", "Use production config.", false)
79	.action(
80	async (
81	filename = "/dev/stdin",	×
82	{ dryRun, production }: { dryRun: boolean; production: boolean }
83	) => {
84	const routeScheduleMapString = await fs.readFile(filename, "utf-8");	×
UNCOV 85	const routeScheduleMap = RouteScheduleManifestSchema.parse(	×
86	JSON.parse(routeScheduleMapString)
87	);
88
UNCOV 89	await updateCron(routeScheduleMap, dryRun, production);	×
90	}
91	);
92	}

quirrel-dev / quirrel / 2219335671

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous