arthur/xtablo-source
1
0
Fork 0
Code Issues Pull requests 1 Projects Releases Packages Wiki Activity Actions 5

Remove worker for now

Browse source
This commit is contained in:
Arthur Belleville 2025-09-23 22:22:33 +02:00
parent 0b1f1158dd
commit 9e8ba248a3
No known key found for this signature in database
3 changed files with 21 additions and 26 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
api/.env.development
View file

@ -1,8 +1,6 @@
SUPABASE_URL=https://mhcafqvzbrrwvahpvvzd.supabase.co
SUPABASE_SERVICE_ROLE_KEY=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZSIsInJlZiI6Im1oY2FmcXZ6YnJyd3ZhaHB2dnpkIiwicm9sZSI6InNlcnZpY2Vfcm9sZSIsImlhdCI6MTc0MTI0MTMyMSwiZXhwIjoyMDU2ODE3MzIxfQ.9r33CUsu6ZR4vyv4ed-UY6cLE1FZzSSxTNE8pFUKjN4
SUPABASE_CONNECTION_STRING="postgresql://postgres.mhcafqvzbrrwvahpvvzd:mke0dwp@cnv.MFZ@mpa@aws-0-eu-west-3.pooler.supabase.com:6543/postgres"
STREAM_CHAT_API_KEY=t5vvvddteapa
STREAM_CHAT_API_SECRET=zrr32sqenw3atpv9rnz2nhhyyncf7bunr7fmfqy9r7e69fcw978dhzevmhpxa2jj

9
api/src/config.ts
View file

@ -26,14 +26,14 @@ function validateEnvVar(name: string, value: string | undefined): string {
}
function createConfig(): AppConfig {
dotenv.config({ path: `.env.${process.env.NODE_ENV}` });
const NODE_ENV = (process.env.NODE_ENV || "development") as
| "development"
| "production"
| "staging"
| "test";
dotenv.config({ path: `.env.${NODE_ENV}` });
// Base configuration
const baseConfig: AppConfig = {
NODE_ENV,
@ -43,10 +43,7 @@ function createConfig(): AppConfig {
"SUPABASE_SERVICE_ROLE_KEY",
process.env.SUPABASE_SERVICE_ROLE_KEY
),
SUPABASE_CONNECTION_STRING: validateEnvVar(
"SUPABASE_CONNECTION_STRING",
process.env.SUPABASE_CONNECTION_STRING
),
SUPABASE_CONNECTION_STRING: process.env.SUPABASE_CONNECTION_STRING || "",
STREAM_CHAT_API_KEY: validateEnvVar(
"STREAM_CHAT_API_KEY",
process.env.STREAM_CHAT_API_KEY

36
api/src/index.ts
View file

@ -36,27 +36,27 @@ app.use("*", async (c, next) => {
app.route("/api/v1", mainRouter);
const worker = async () => {
const connectionString = `${
config.SUPABASE_CONNECTION_STRING
}?ssl=true&sslrootcert=${path.resolve(__dirname, "..", "supabase_ca.crt")}`;
// const worker = async () => {
// const connectionString = `${
// config.SUPABASE_CONNECTION_STRING
// }?ssl=true&sslrootcert=${path.resolve(__dirname, "..", "supabase_ca.crt")}`;
const runner = await run({
connectionString,
concurrency: 1,
pollInterval: 1000,
taskDirectory: path.resolve(__dirname, "tasks"),
noPreparedStatements: true,
crontabFile: path.resolve(__dirname, "crontab"),
});
// const runner = await run({
// connectionString,
// concurrency: 1,
// pollInterval: 1000,
// taskDirectory: path.resolve(__dirname, "tasks"),
// noPreparedStatements: true,
// crontabFile: path.resolve(__dirname, "crontab"),
// });
await runner.promise;
};
// await runner.promise;
// };
worker().catch((err) => {
console.error(err);
process.exit(1);
});
// worker().catch((err) => {
// console.error(err);
// process.exit(1);
// });
serve(
{