wtf I have no idea

This commit is contained in:
Omer Sabic 2024-05-29 23:08:37 +02:00
parent 565ac26123
commit a51529042e
3 changed files with 21 additions and 14 deletions

View File

@ -21,14 +21,14 @@ export const initDb = async () => {
schema,
});
await migrate(db, {
migrationsFolder: "./src/db/migrations",
})
.then(() => {
Logger.info("INIT", "Migrated database");
})
.catch((error) => {
Logger.error("INIT", `Failed to migrate database ${String(error)}`);
throw new Error(`Failed to migrate database ${String(error)}`);
});
// await migrate(db, {
// migrationsFolder: "./src/db/migrations",
// })
// .then(() => {
// Logger.info("INIT", "Migrated database");
// })
// .catch((error) => {
// Logger.error("INIT", `Failed to migrate database ${String(error)}`);
// throw new Error(`Failed to migrate database ${String(error)}`);
// });
};

View File

@ -44,12 +44,19 @@ export const blogRoutes = (fastify, _, done) => {
let site;
if (mine) {
if (!(await authMiddlewareFn(request, response))) return;
[site] = await db.select().from(sites).where(and(eq(sites.user_id, request.session.user_id)));
try {
[site] = await db.select().from(sites).where(and(eq(sites.user_id, request.session.user_id)));
} catch (e) {
console.log(e);
}
}
else {
let referer = new URL(request.headers.origin).host;
console.log(referer)
[site] = await db.select().from(sites).where(eq(sites.domain, referer)).limit(1);
try {
[site] = await db.select().from(sites).where(or(eq(sites.domain, referer), eq(sites.subdomain_slug, referer.split(".")[0])));
} catch (e) {
console.log(e);
}
}
if (!site) {
response.status(400).send({

View File

@ -45,7 +45,7 @@ export const meRoutes = (fastify, _, done) => {
fastify.get("/billing", async (request, response) => {
try {
const [user] = await db.select().from(users).where(eq(users.id, request.session.user_id));
const billing_session_url = await getBillingDashboard(user.stripe_id, env.FRONTEND_URL+"/app");
const billing_session_url = await getBillingDashboard(user.stripe_id, env.FRONTEND_URL);
response.redirect(billing_session_url);
return;