complete the script

Author: Rishi Raj Jain

packages/cli/package.json

@@ -53,6 +53,7 @@
   },
   "dependencies": {
     "@types/degit": "^2.8.3",
+    "axios": "^1.4.0",
     "chalk": "^5.2.0",
     "chokidar": "^3.5.3",
     "commander": "^9.4.1",

packages/cli/src/cli/index.ts

@@ -7,6 +7,7 @@ import { initCommand } from "../commands/init.js";
 import { CLOUD_TRIGGER_URL, COMMAND_NAME } from "../consts.js";
 import { telemetryClient } from "../telemetry/telemetry.js";
 import { getVersion } from "../utils/getVersion.js";
+import { updateCommand } from "../commands/update.js";
 
 export const program = new Command();
 
@@ -78,6 +79,14 @@ program
     await createIntegrationCommand(path, options);
   });
 
+program
+  .command("update")
+  .description("Updates all @trigger.dev/* packages to their latest compatible versions")
+  .argument("[path]", "The path to the directory that contains the package.json file", ".")
+  .action(async (path) => {
+    await updateCommand(path);
+  });
+
 export const promptTriggerUrl = async (): Promise<string> => {
   const { instanceType } = await inquirer.prompt<{
     instanceType: "cloud" | "self-hosted";

packages/cli/src/commands/update.ts

@@ -0,0 +1,77 @@
+import fs from "fs";
+import path from "path";
+import axios from "axios";
+import inquirer from "inquirer";
+import { installDependencies } from "../utils/installDependencies.js";
+
+export async function updateCommand(projectPath: string) {
+  const packageJsonPath = path.join(projectPath, "package.json");
+
+  if (!fs.existsSync(packageJsonPath)) {
+    console.error("package.json not found in the current directory.");
+    return;
+  }
+
+  const packageJsonData = JSON.parse(fs.readFileSync(packageJsonPath, "utf8"));
+  const dependencies = packageJsonData.dependencies || {};
+  const devDependencies = packageJsonData.devDependencies || {};
+
+  const triggerPackages = Object.keys({ ...dependencies, ...devDependencies }).filter(
+    (packageName) => packageName.startsWith("@trigger.dev/")
+  );
+
+  if (triggerPackages.length === 0) {
+    console.log("No @trigger.dev/* packages found in package.json.");
+    return;
+  }
+
+  const newVersions = await Promise.all(
+    triggerPackages.map(async (packageName) => {
+      try {
+        const response = await axios.get(`https://registry.npmjs.org/${packageName}`);
+        const latestVersion = response.data["dist-tags"].latest;
+        return { packageName, latestVersion };
+      } catch (error) {
+        // @ts-ignore
+        console.error(`Error fetching version for ${packageName}: ${error.message}`);
+        return null;
+      }
+    })
+  );
+  const packagesToUpdate = newVersions.filter(
+    (entry) => entry !== null && entry.latestVersion !== dependencies[entry.packageName]
+  );
+
+  if (packagesToUpdate.length === 0) {
+    console.log("All @trigger.dev/* packages are up to date.");
+    return;
+  }
+
+  console.log("Newer versions found for the following packages:");
+  packagesToUpdate.forEach((entry) => {
+    console.log(
+      `- ${entry.packageName}: current ${dependencies[entry.packageName]} -> latest ${
+        entry.latestVersion
+      }`
+    );
+  });
+
+  const { confirm } = await inquirer.prompt({
+    type: "confirm",
+    name: "confirm",
+    message: "Do you want to update these packages in package.json and re-install dependencies?",
+  });
+
+  if (confirm) {
+    packagesToUpdate.forEach((entry) => {
+      dependencies[entry.packageName] = entry.latestVersion;
+    });
+
+    fs.writeFileSync(packageJsonPath, JSON.stringify(packageJsonData, null, 2));
+
+    console.log("package.json updated. Reinstalling dependencies...");
+    await installDependencies(projectPath);
+  } else {
+    console.log("Operation canceled. No changes were made.");
+  }
+}