Added Digital Ocean

.env.example

@@ -103,6 +103,17 @@ X_ACCESS_TOKEN_SECRET=
 # YouTube
 YOUTUBE_API_KEY=
 
+## Digital Ocean
+DO_TOKEN=
+
+## Todoist
+TODOIST_API_TOKEN=
+
+## Svix
+SVIX_API_KEY=
+
+## ZBD
+
 # ZBD
 ZBD_API_KEY=
 ZBD_BASE_URL=https://sandbox-api.zebedee.io

package.json

@@ -20,6 +20,7 @@
     "hubspot": "node -r dotenv/config -r ts-node/register src/hubspot.ts",
     "stability": "node -r dotenv/config -r ts-node/register src/stability.ts",
     "x": "node -r dotenv/config -r ts-node/register src/x.ts",
+    "node-digitalocean": "node -r dotenv/config -r ts-node/register src/digitalOcean.ts",
     "youtube": "node -r dotenv/config -r ts-node/register src/youtube.ts",
     "todoist": "node -r dotenv/config -r ts-node/register src/todoist.ts",
     "hugging-face": "node -r dotenv/config -r ts-node/register src/hugging-face.ts",
@@ -58,6 +59,7 @@
     "deepl-node": "^1.10.2",
     "googleapis": "^105.0.0",
     "jsforce": "^1.11.1",
+    "node-digitalocean": "^2.1.0",
     "mailgun.js": "^9.3.0",
     "oauth-1.0a": "^2.2.6",
     "octokit": "^3.1.1",

src/digitalOcean.ts

@@ -0,0 +1,55 @@
+// digitalOcean.ts
+import { TriggerClient, eventTrigger } from '@trigger.dev/sdk';
+import { z } from 'zod';
+import DigitalOcean from "node-digitalocean";
+
+const client = new TriggerClient({ id: "api-reference" });
+
+// Initialize DigitalOcean client
+const digitalOceanClient = new DigitalOcean(process.env.DO_TOKEN?? "");
+
+client.defineJob({
+  id: "digitalOcean-deployDroplet",
+  name: "Deploy Droplet from a Master Snapshot",
+  version: "1.0.0",
+  trigger: eventTrigger({
+    name: "digitalOcean.deployDroplet",
+    schema: z.object({
+      snapshotId: z.string(),
+      dropletName: z.string(),
+      region: z.string(),
+      size: z.string(),
+    }),
+  }),
+
+run: async (payload, io, ctx) => {
+    // Wrap any SDK call in io.runTask so it's resumable and displays in logs
+    return io.runTask(
+        "Deploy Droplet",
+        async () => {
+            const droplet = await digitalOceanClient.droplets.create({
+                name: payload.dropletName,
+                region: payload.region,
+                size: payload.size,
+                image: payload.snapshotId,
+                ssh_keys: [], // add any additional properties here
+                backups: false,
+                ipv6: false,
+                user_data: null,
+                private_networking: false,
+                volumes: [],
+                monitoring: false,
+                tags: [],
+            });
+
+            return droplet;
+        },
+        // You can add metadata to the task to improve the display in the logs
+        { name: "DigitalOcean Deploy Droplet", icon: "digitalOcean" }
+    );
+},
+});
+
+// These lines can be removed if you don't want to use express
+import { createExpressServer } from '@trigger.dev/express';
+createExpressServer(client);