dokploy/apps/api/src/test.ts

import { Hono } from "hono";
import { Client } from "@upstash/qstash";
import { serve } from "@hono/node-server";
import dotenv from "dotenv";
import Redis from "ioredis";

dotenv.config();

const redis = new Redis({
	host: "localhost",
	port: 7777,
	password: "xlfvpQ0ma2BkkkPX",
});

// redis.set("test", "test");
// console.log(await redis.get("test"));

// console.log(await redis.get("user-1-processing"));
const app = new Hono();
console.log("QStash Token:", process.env.PUBLIC_URL);

const qstash = new Client({
	token: process.env.QSTASH_TOKEN as string,
});

const queue = qstash.queue({
	queueName: "deployments",
});

// Endpoint que publica un mensaje en QStash
app.post("/enqueue", async (c) => {
	const { userId, deploymentId } = await c.req.json();
	const response = await qstash.publishJSON({
		url: `${process.env.PUBLIC_URL}/process`, // Endpoint para procesar la tarea
		body: { userId, deploymentId }, // Datos del despliegue
				
	});

	return c.json({ message: "Task enqueued", id: response.messageId });
});

// Endpoint que recibe el mensaje procesado
app.post("/process", async (c) => {
	const { userId, deploymentId } = await c.req.json();

	const isProcessing = await redis.get(`user-${userId}-processing`);
	console.log(`isProcessing for user ${userId}:`, isProcessing);

	if (isProcessing === "true") {
		console.log(
			`User ${userId} is already processing a deployment. Queuing the next one.`,
		);
		return c.json(
			{
				status: "User is already processing a deployment, waiting...",
			},
			{
				status: 400,
			},
		);
	}
	redis.set(`user-${userId}-processing`, "true");

	try {
		await new Promise((resolve) => setTimeout(resolve, 5000));
	} catch (error) {
	} finally {
		await redis.del(`user-${userId}-processing`);
	}

	return c.json({ status: "Processed", userId, deploymentId });
});

// Inicia el servidor en el puerto 3000
const port = 3000;
console.log(`Server is running on port http://localhost:${port}`);

serve({
	fetch: app.fetch,
	port,
});
// 18