LukeParke/dokploy
1
0
Fork 0
mirror of https://github.com/LukeHagar/dokploy.git synced 2025-12-07 20:37:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: add prefix and remove resolution esm flag (#1095)

Browse Source 
* fix: add prefix and remove resolution esm flag

* refactor: revert
This commit is contained in:
Mauricio Siu
2025-01-12 15:10:25 -06:00
committed by GitHub
parent ae97595610
commit a965c0e924
7 changed files with 24 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
apps/api/package.json
View File

@@ -5,7 +5,7 @@
"scripts": { "scripts": {
"dev": "PORT=4000 tsx watch src/index.ts", "dev": "PORT=4000 tsx watch src/index.ts",
"build": "tsc --project tsconfig.json", "build": "tsc --project tsconfig.json",
"start": "node --experimental-specifier-resolution=node dist/index.js", "start": "node dist/index.js",
"typecheck": "tsc --noEmit" "typecheck": "tsc --noEmit"
}, },
"dependencies": { "dependencies": {

6
apps/api/src/index.ts
View File

@@ -4,9 +4,9 @@ import "dotenv/config";
import { zValidator } from "@hono/zod-validator"; import { zValidator } from "@hono/zod-validator";
import { Queue } from "@nerimity/mimiqueue"; import { Queue } from "@nerimity/mimiqueue";
import { createClient } from "redis"; import { createClient } from "redis";
import { logger } from "./logger"; import { logger } from "./logger.js";
import { type DeployJob, deployJobSchema } from "./schema"; import { type DeployJob, deployJobSchema } from "./schema.js";
import { deploy } from "./utils"; import { deploy } from "./utils.js";
const app = new Hono(); const app = new Hono();
const redisClient = createClient({ const redisClient = createClient({

2
apps/schedules/package.json
View File

@@ -4,7 +4,7 @@
"scripts": { "scripts": {
"dev": "PORT=4001 tsx watch src/index.ts", "dev": "PORT=4001 tsx watch src/index.ts",
"build": "tsc --project tsconfig.json", "build": "tsc --project tsconfig.json",
"start": "node --experimental-specifier-resolution=node dist/index.js", "start": "node dist/index.js",
"typecheck": "tsc --noEmit" "typecheck": "tsc --noEmit"
}, },
"dependencies": { "dependencies": {

15
apps/schedules/src/index.ts
View File

@@ -2,11 +2,16 @@ import { serve } from "@hono/node-server";
import { Hono } from "hono"; import { Hono } from "hono";
import "dotenv/config"; import "dotenv/config";
import { zValidator } from "@hono/zod-validator"; import { zValidator } from "@hono/zod-validator";
import { logger } from "./logger"; import { logger } from "./logger.js";
import { cleanQueue, getJobRepeatable, removeJob, scheduleJob } from "./queue"; import {
import { jobQueueSchema } from "./schema"; cleanQueue,
import { initializeJobs } from "./utils"; getJobRepeatable,
import { firstWorker, secondWorker } from "./workers"; removeJob,
scheduleJob,
} from "./queue.js";
import { jobQueueSchema } from "./schema.js";
import { initializeJobs } from "./utils.js";
import { firstWorker, secondWorker } from "./workers.js";
const app = new Hono(); const app = new Hono();

4
apps/schedules/src/queue.ts
View File

@@ -1,7 +1,7 @@
import { Queue, type RepeatableJob } from "bullmq"; import { Queue, type RepeatableJob } from "bullmq";
import IORedis from "ioredis"; import IORedis from "ioredis";
import { logger } from "./logger"; import { logger } from "./logger.js";
import type { QueueJob } from "./schema"; import type { QueueJob } from "./schema.js";
export const connection = new IORedis(process.env.REDIS_URL!, { export const connection = new IORedis(process.env.REDIS_URL!, {
maxRetriesPerRequest: null, maxRetriesPerRequest: null,

6
apps/schedules/src/utils.ts
View File

@@ -12,9 +12,9 @@ import {
import { db } from "@dokploy/server/dist/db"; import { db } from "@dokploy/server/dist/db";
import { backups, server } from "@dokploy/server/dist/db/schema"; import { backups, server } from "@dokploy/server/dist/db/schema";
import { eq } from "drizzle-orm"; import { eq } from "drizzle-orm";
import { logger } from "./logger"; import { logger } from "./logger.js";
import { scheduleJob } from "./queue"; import { scheduleJob } from "./queue.js";
import type { QueueJob } from "./schema"; import type { QueueJob } from "./schema.js";
export const runJobs = async (job: QueueJob) => { export const runJobs = async (job: QueueJob) => {
try { try {

8
apps/schedules/src/workers.ts
View File

@@ -1,8 +1,8 @@
import { type Job, Worker } from "bullmq"; import { type Job, Worker } from "bullmq";
import { logger } from "./logger"; import { logger } from "./logger.js";
import { connection } from "./queue"; import { connection } from "./queue.js";
import type { QueueJob } from "./schema"; import type { QueueJob } from "./schema.js";
import { runJobs } from "./utils"; import { runJobs } from "./utils.js";
export const firstWorker = new Worker( export const firstWorker = new Worker(
"backupQueue", "backupQueue",