Compare commits
No commits in common. "main" and "dev" have entirely different histories.
17 changed files with 436 additions and 745 deletions
|
|
@ -1,6 +1,8 @@
|
|||
# Build stage
|
||||
FROM oven/bun:1 AS builder
|
||||
|
||||
WORKDIR /app
|
||||
|
||||
# Copy package files
|
||||
COPY package.json .
|
||||
COPY bun.lockb .
|
||||
|
|
@ -14,8 +16,6 @@ COPY . .
|
|||
# Build the application
|
||||
RUN bun run build
|
||||
|
||||
EXPOSE 5005
|
||||
|
||||
# Production stage
|
||||
# FROM debian:bookworm-slim
|
||||
|
||||
|
|
|
|||
|
|
@ -3,8 +3,8 @@ services:
|
|||
build:
|
||||
context: .
|
||||
dockerfile: Dockerfile
|
||||
ports:
|
||||
- "5005:5005"
|
||||
# ports:
|
||||
# - "${SERVER_PORT}:${SERVER_PORT}"
|
||||
depends_on:
|
||||
db:
|
||||
condition: service_healthy
|
||||
|
|
@ -34,8 +34,8 @@ services:
|
|||
minio:
|
||||
image: minio/minio:latest
|
||||
# ports:
|
||||
# - "9000:9000"
|
||||
# - "9001:9001"
|
||||
# - "9000:9000"
|
||||
# - "9001:9001"
|
||||
environment:
|
||||
MINIO_ROOT_USER: ${MINIO_ROOT_USER}
|
||||
MINIO_ROOT_PASSWORD: ${MINIO_ROOT_PASSWORD}
|
||||
|
|
|
|||
|
|
@ -1,11 +1,11 @@
|
|||
import { defineConfig } from "drizzle-kit";
|
||||
import { ENV } from "./src/config/env";
|
||||
import { defineConfig } from 'drizzle-kit';
|
||||
import { ENV } from './src/config/env';
|
||||
|
||||
export default defineConfig({
|
||||
out: "./drizzle",
|
||||
schema: "./src/db/schema.ts",
|
||||
dialect: "postgresql",
|
||||
dbCredentials: {
|
||||
url: ENV.DATABASE_URL!,
|
||||
},
|
||||
out: './drizzle',
|
||||
schema: './src/db/schema.ts',
|
||||
dialect: 'postgresql',
|
||||
dbCredentials: {
|
||||
url: ENV.DATABASE_URL!,
|
||||
},
|
||||
});
|
||||
|
|
|
|||
21
env.example
21
env.example
|
|
@ -1,21 +0,0 @@
|
|||
SERVER_URL=
|
||||
SERVER_PORT=
|
||||
|
||||
DATABASE_URL=
|
||||
|
||||
MINIO_ACCESS_KEY=
|
||||
MINIO_SECRET_KEY=
|
||||
MINIO_ENDPOINT=
|
||||
MINIO_PORT=
|
||||
|
||||
CLERK_SECRET_KEY=
|
||||
|
||||
JWT_ACCESS_TOKEN_SECRET=
|
||||
|
||||
JWT_REFRESH_TOKEN_SECRET=
|
||||
|
||||
# developer canvas server url
|
||||
CANVAS_SERVER_URL_DEV=
|
||||
|
||||
PEXELS_URL=
|
||||
PEXELS_ACCESS_KEY=
|
||||
|
|
@ -1,5 +1,5 @@
|
|||
import { createClerkClient } from "@clerk/backend";
|
||||
import { ENV } from "../../config/env";
|
||||
import { ENV } from "../../config/env"
|
||||
import { users } from "../../db/schema";
|
||||
import { db } from "../../db";
|
||||
import { eq } from "drizzle-orm";
|
||||
|
|
@ -7,160 +7,119 @@ import { eq } from "drizzle-orm";
|
|||
// @ts-ignore
|
||||
import jwt from "jsonwebtoken";
|
||||
|
||||
import {
|
||||
checkUserInDB,
|
||||
createUser,
|
||||
storeRefreshToken,
|
||||
} from "../../helper/auth/auth.helper";
|
||||
import { checkUserInDB, createUser, storeRefreshToken } from "../../helper/auth/auth.helper";
|
||||
import { verifyAuth } from "../../middlewares/auth.middlewares";
|
||||
|
||||
// Initialize Clerk with your API key
|
||||
const clerk = createClerkClient({ secretKey: ENV.CLERK_SECRET_KEY });
|
||||
|
||||
export const getUserData = async (userId: string) => {
|
||||
try {
|
||||
const [user, checkInDB] = await Promise.all([
|
||||
clerk.users.getUser(userId),
|
||||
checkUserInDB(userId),
|
||||
]);
|
||||
try {
|
||||
const [user, checkInDB] = await Promise.all([
|
||||
clerk.users.getUser(userId),
|
||||
checkUserInDB(userId)
|
||||
]);
|
||||
|
||||
if (user && !checkInDB.found) {
|
||||
// Validate and transform user data
|
||||
const userDBData = {
|
||||
id: user.id,
|
||||
email: user.emailAddresses[0].emailAddress, // Assuming the first email address
|
||||
firstName: user.firstName || "N/A", // Provide a default value if needed
|
||||
lastName: user.lastName || "N/A",
|
||||
image: user.imageUrl,
|
||||
};
|
||||
if (user && !checkInDB.found) {
|
||||
|
||||
const userData = await createUser(userDBData);
|
||||
// Validate and transform user data
|
||||
const userDBData = {
|
||||
id: user.id,
|
||||
email: user.emailAddresses[0].emailAddress, // Assuming the first email address
|
||||
firstName: user.firstName || "N/A", // Provide a default value if needed
|
||||
lastName: user.lastName || "N/A",
|
||||
image: user.imageUrl,
|
||||
};
|
||||
|
||||
return {
|
||||
status: 200,
|
||||
message: "User retrieved successfully",
|
||||
data: userData,
|
||||
};
|
||||
const userData = await createUser(userDBData);
|
||||
|
||||
return { status: 200, message: "User retrieved successfully", data: userData };
|
||||
}
|
||||
if (user && checkInDB.found) {
|
||||
return { status: 200, message: "User retrieved successfully", data: checkInDB };
|
||||
}
|
||||
if (!user) {
|
||||
return { status: 404, message: "User not found" };
|
||||
}
|
||||
} catch (error: any) {
|
||||
console.error("Error in getUserData:", error.message || error.toString());
|
||||
return { status: 500, message: `An error occurred while getting the user` };
|
||||
}
|
||||
if (user && checkInDB.found) {
|
||||
return {
|
||||
status: 200,
|
||||
message: "User retrieved successfully",
|
||||
data: checkInDB,
|
||||
};
|
||||
}
|
||||
if (!user) {
|
||||
return { status: 404, message: "User not found" };
|
||||
}
|
||||
} catch (error: any) {
|
||||
console.error("Error in getUserData:", error.message || error.toString());
|
||||
return { status: 500, message: `An error occurred while getting the user` };
|
||||
}
|
||||
};
|
||||
|
||||
export const updateUser = async (
|
||||
id: string,
|
||||
body: {
|
||||
paid_status: string;
|
||||
package_expire_date: string;
|
||||
}
|
||||
) => {
|
||||
try {
|
||||
const updateUserData = await db
|
||||
.update(users)
|
||||
.set({
|
||||
paid_status: body?.paid_status,
|
||||
expires_in: body?.package_expire_date,
|
||||
})
|
||||
.where(eq(users.id, id))
|
||||
.returning({ updatedId: users.id });
|
||||
export const updateUser = async (id: string, body: {
|
||||
paid_status: string,
|
||||
package_expire_date: string,
|
||||
}) => {
|
||||
try {
|
||||
const updateUserData = await db.update(users).set({ paid_status: body?.paid_status, expires_in: body?.package_expire_date }).where(eq(users.id, id)).returning({ updatedId: users.id });
|
||||
|
||||
return {
|
||||
status: 200,
|
||||
message: "User updated successfully",
|
||||
updateUserData,
|
||||
};
|
||||
} catch (error: any) {
|
||||
console.error("Error in updateUser:", error.message || error.toString());
|
||||
return {
|
||||
status: 500,
|
||||
message: `An error occurred while updating the user`,
|
||||
};
|
||||
}
|
||||
};
|
||||
return { status: 200, message: "User updated successfully", updateUserData };
|
||||
|
||||
} catch (error: any) {
|
||||
console.error("Error in updateUser:", error.message || error.toString());
|
||||
return { status: 500, message: `An error occurred while updating the user` };
|
||||
}
|
||||
}
|
||||
|
||||
export const generateToken = async (context: any) => {
|
||||
try {
|
||||
const userId = context?.params?.userId;
|
||||
const access_cookie = context?.cookie?.access_token?.value;
|
||||
const refresh_cookie = context?.cookie?.refresh_token?.value;
|
||||
try {
|
||||
const userId = context?.params?.userId;
|
||||
const access_cookie = context?.cookie?.access_token?.value;
|
||||
const refresh_cookie = context?.cookie?.refresh_token?.value;
|
||||
|
||||
if (access_cookie !== undefined || refresh_cookie !== undefined) {
|
||||
const verify = await verifyAuth(context?.cookie);
|
||||
return verify;
|
||||
} else if (
|
||||
access_cookie === undefined &&
|
||||
refresh_cookie === undefined &&
|
||||
userId !== undefined
|
||||
) {
|
||||
const user = await checkUserInDB(userId);
|
||||
if (user?.found === true) {
|
||||
// generate access token
|
||||
const accessToken = jwt.sign({ userId }, ENV.JWT_ACCESS_TOKEN_SECRET, {
|
||||
expiresIn: "3h",
|
||||
});
|
||||
|
||||
// generate refresh token
|
||||
const refreshToken = jwt.sign(
|
||||
{ userId },
|
||||
ENV.JWT_REFRESH_TOKEN_SECRET,
|
||||
{ expiresIn: "7d" }
|
||||
);
|
||||
|
||||
// store refresh token in db
|
||||
const storeRToken = await storeRefreshToken(userId, refreshToken);
|
||||
|
||||
if (storeRToken.status === 200) {
|
||||
context.cookie.access_token.set({
|
||||
value: accessToken,
|
||||
httpOnly: true,
|
||||
secure: true, // Set to true in production
|
||||
sameSite: "none", // Adjust based on your needs
|
||||
path: "/",
|
||||
maxAge: 3 * 60 * 60, // 3 hours in seconds
|
||||
});
|
||||
|
||||
context.cookie.refresh_token.set({
|
||||
value: refreshToken,
|
||||
httpOnly: true,
|
||||
secure: true, // Set to true in production
|
||||
sameSite: "none", // Adjust based on your needs
|
||||
path: "/",
|
||||
maxAge: 7 * 24 * 60 * 60, // 7 days in seconds
|
||||
});
|
||||
|
||||
return {
|
||||
status: 201,
|
||||
message: "Token generated successfully",
|
||||
token: accessToken,
|
||||
user: user.user,
|
||||
};
|
||||
if (access_cookie !== undefined || refresh_cookie !== undefined) {
|
||||
const verify = await verifyAuth(context?.cookie);
|
||||
return verify;
|
||||
}
|
||||
return {
|
||||
status: 500,
|
||||
message: "An error occurred while storing the refresh token",
|
||||
};
|
||||
} else {
|
||||
return { status: 404, message: "User not found" };
|
||||
}
|
||||
} else {
|
||||
return { status: 404, message: "Unauthorized!!!" };
|
||||
else if (access_cookie === undefined && refresh_cookie === undefined && userId !== undefined) {
|
||||
const user = await checkUserInDB(userId);
|
||||
if (user?.found === true) {
|
||||
|
||||
// generate access token
|
||||
const accessToken = jwt.sign({ userId }, ENV.JWT_ACCESS_TOKEN_SECRET, { expiresIn: '3h' });
|
||||
|
||||
// generate refresh token
|
||||
const refreshToken = jwt.sign({ userId }, ENV.JWT_REFRESH_TOKEN_SECRET, { expiresIn: '7d' });
|
||||
|
||||
// store refresh token in db
|
||||
const storeRToken = await storeRefreshToken(userId, refreshToken);
|
||||
|
||||
if (storeRToken.status === 200) {
|
||||
context.cookie.access_token.set({
|
||||
value: accessToken,
|
||||
httpOnly: true,
|
||||
secure: true, // Set to true in production
|
||||
sameSite: 'none', // Adjust based on your needs
|
||||
path: "/",
|
||||
maxAge: 3 * 60 * 60, // 3 hours in seconds
|
||||
});
|
||||
|
||||
context.cookie.refresh_token.set({
|
||||
value: refreshToken,
|
||||
httpOnly: true,
|
||||
secure: true, // Set to true in production
|
||||
sameSite: 'none', // Adjust based on your needs
|
||||
path: "/",
|
||||
maxAge: 7 * 24 * 60 * 60, // 7 days in seconds
|
||||
});
|
||||
|
||||
return { status: 201, message: "Token generated successfully", token: accessToken, user: user.user };
|
||||
}
|
||||
return { status: 500, message: "An error occurred while storing the refresh token" };
|
||||
}
|
||||
else {
|
||||
return { status: 404, message: "User not found" };
|
||||
}
|
||||
}
|
||||
else {
|
||||
return { status: 404, message: "Unauthorized!!!" };
|
||||
}
|
||||
} catch (error: any) {
|
||||
console.error("Error in generateToken:", error.message || error.toString());
|
||||
return { status: 500, message: `An error occurred while generating the token` };
|
||||
}
|
||||
} catch (error: any) {
|
||||
console.error("Error in generateToken:", error.message || error.toString());
|
||||
return {
|
||||
status: 500,
|
||||
message: `An error occurred while generating the token`,
|
||||
};
|
||||
}
|
||||
};
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -1,80 +1,47 @@
|
|||
import { Elysia, t } from "elysia";
|
||||
import Elysia, { t } from "elysia";
|
||||
import { generateToken, getUserData, updateUser } from "./auth.controller";
|
||||
import { verifyAuth } from "../../middlewares/auth.middlewares";
|
||||
|
||||
export const authRoute = new Elysia({ prefix: "/auth" });
|
||||
|
||||
authRoute.get(
|
||||
"/user/:userId",
|
||||
async ({ params: { userId } }) => await getUserData(userId),
|
||||
{
|
||||
export const authRoute = new Elysia({
|
||||
prefix: "/auth",
|
||||
tags: ["Auth"],
|
||||
detail: {
|
||||
tags: ["Auth"],
|
||||
summary: "Get user data",
|
||||
},
|
||||
params: t.Object({
|
||||
userId: t.String(),
|
||||
}),
|
||||
}
|
||||
);
|
||||
description: "Routes for managing users",
|
||||
}
|
||||
})
|
||||
|
||||
authRoute.post(
|
||||
"/user/update/:userId",
|
||||
async ({ params: { userId }, body }) => await updateUser(userId, body),
|
||||
{
|
||||
detail: {
|
||||
tags: ["Auth"],
|
||||
summary: "Update user",
|
||||
},
|
||||
authRoute.get("/user/:userId", async ({ params: { userId } }) => await getUserData(userId), {
|
||||
params: t.Object({
|
||||
userId: t.String(),
|
||||
userId: t.String()
|
||||
})
|
||||
});
|
||||
|
||||
authRoute.post("/user/update/:userId", async ({ params: { userId }, body }) => await updateUser(userId, body), {
|
||||
params: t.Object({
|
||||
userId: t.String()
|
||||
}),
|
||||
body: t.Object({
|
||||
paid_status: t.String(),
|
||||
package_expire_date: t.String(),
|
||||
}),
|
||||
}
|
||||
);
|
||||
paid_status: t.String(),
|
||||
package_expire_date: t.String(),
|
||||
})
|
||||
});
|
||||
|
||||
authRoute.get(
|
||||
"/generate-token/:userId",
|
||||
async (context) => await generateToken(context),
|
||||
{
|
||||
detail: {
|
||||
tags: ["Auth"],
|
||||
summary: "Generate token",
|
||||
},
|
||||
params: t.Object({
|
||||
userId: t.String(),
|
||||
}),
|
||||
}
|
||||
);
|
||||
authRoute.get("/generate-token/:userId", async (context) => await generateToken(context));
|
||||
|
||||
authRoute.get(
|
||||
"/user/me",
|
||||
async ({ cookie }) => {
|
||||
authRoute.get("/user/me", async ({ cookie }) => {
|
||||
const authData = await verifyAuth(cookie);
|
||||
if (authData.status !== 200) {
|
||||
return authData;
|
||||
} else {
|
||||
const userId = authData.userId;
|
||||
const response = await getUserData(userId);
|
||||
if (response?.status === 200) {
|
||||
return {
|
||||
...response.data,
|
||||
token: authData.token,
|
||||
status: 200,
|
||||
message: "User data fetched successfully",
|
||||
};
|
||||
} else {
|
||||
return response;
|
||||
}
|
||||
return authData;
|
||||
}
|
||||
},
|
||||
{
|
||||
detail: {
|
||||
tags: ["Auth"],
|
||||
summary: "Get current user",
|
||||
},
|
||||
}
|
||||
);
|
||||
else {
|
||||
const userId: string | any = authData.userId;
|
||||
const response = await getUserData(userId);
|
||||
if (response?.status === 200) {
|
||||
return { ...response.data, token: authData.token, status: 200, message: "User data fetched successfully" };
|
||||
}
|
||||
else {
|
||||
return response;
|
||||
}
|
||||
}
|
||||
})
|
||||
|
||||
|
|
|
|||
|
|
@ -1,19 +0,0 @@
|
|||
import { ENV } from "../../config/env";
|
||||
|
||||
export const getAllDesign = async (token: string) => {
|
||||
try {
|
||||
const response = await fetch(`${ENV.CANVAS_SERVER_URL_DEV}/design`, {
|
||||
method: "GET",
|
||||
headers: {
|
||||
Authorization: `Bearer ${token}`,
|
||||
"Content-Type": "application/json",
|
||||
},
|
||||
});
|
||||
const data = await response.json();
|
||||
console.log(response);
|
||||
return data;
|
||||
} catch (error: any) {
|
||||
console.log(error);
|
||||
return { status: 500, message: error.message, token };
|
||||
}
|
||||
};
|
||||
|
|
@ -1,24 +0,0 @@
|
|||
import Elysia from "elysia";
|
||||
import { verifyAuth } from "../../middlewares/auth.middlewares";
|
||||
import { getAllDesign } from "./design.controller";
|
||||
|
||||
export const designRoute = new Elysia({
|
||||
prefix: "/design",
|
||||
tags: ["Design"],
|
||||
detail: {
|
||||
description: "Routes for managing designs",
|
||||
}
|
||||
}).derive(async ({ cookie }) => {
|
||||
const authData = await verifyAuth(cookie);
|
||||
return { authData }; // Inject into context
|
||||
})
|
||||
|
||||
designRoute.get("/", async ({ authData }) => {
|
||||
if (authData.status !== 200)
|
||||
return authData;
|
||||
else {
|
||||
const token = authData.token;
|
||||
const response = await getAllDesign(token);
|
||||
return response;
|
||||
}
|
||||
})
|
||||
|
|
@ -1,27 +1,16 @@
|
|||
import { Elysia } from "elysia";
|
||||
import Elysia from "elysia";
|
||||
import { projectRoutes } from "./project/project.route";
|
||||
import { uploadRoutes } from "./upload/upload.route";
|
||||
import { authRoute } from "./auth/auth.route";
|
||||
import { downloadRoute } from "./downloadCount/download.count.route";
|
||||
import { photoLibraryRoutes } from "./photoLibrary/photo.library.route";
|
||||
import { designRoute } from "./design/design.route";
|
||||
|
||||
export const api = new Elysia({ prefix: "" })
|
||||
.get("/", () => {
|
||||
console.log("Root endpoint accessed");
|
||||
return "Hello from PlanPostAI Canvas API";
|
||||
})
|
||||
.use(authRoute)
|
||||
.use(projectRoutes)
|
||||
.use(uploadRoutes)
|
||||
.use(downloadRoute)
|
||||
.use(photoLibraryRoutes)
|
||||
.use(designRoute)
|
||||
.onError(({ code, error, set }) => {
|
||||
console.error(`API Error: ${code}`, error);
|
||||
if (code === "NOT_FOUND") {
|
||||
set.status = 404;
|
||||
return "API Endpoint Not Found";
|
||||
}
|
||||
return "API Error Occurred";
|
||||
});
|
||||
export const api = new Elysia({
|
||||
prefix: "/api",
|
||||
});
|
||||
api.get("/", () => {
|
||||
return "Hello from PlanPostAI Canvas API";
|
||||
});
|
||||
api.use(authRoute);
|
||||
api.use(projectRoutes);
|
||||
api.use(uploadRoutes);
|
||||
api.use(downloadRoute);
|
||||
|
|
@ -1,21 +0,0 @@
|
|||
import { ENV } from "../../config/env";
|
||||
|
||||
export const getPhotos = async (keyword: string, pre_page: number, token: string) => {
|
||||
try {
|
||||
const url = `${ENV.PEXELS_URL}/search?query=${keyword}&per_page=${pre_page}`;
|
||||
const response = await fetch(url, {
|
||||
headers: {
|
||||
Authorization: process.env.PEXELS_ACCESS_KEY as string,
|
||||
},
|
||||
})
|
||||
|
||||
if (!response.ok) {
|
||||
return { status: 500, message: "An error occurred while getting the photos", token }
|
||||
}
|
||||
const data = await response.json();
|
||||
return { data, token }
|
||||
} catch (error: any) {
|
||||
console.log("Error in getting photos:", error.message || error.toString());
|
||||
return { status: 500, message: "An error occurred while getting the photos", token };
|
||||
}
|
||||
}
|
||||
|
|
@ -1,31 +0,0 @@
|
|||
import Elysia, { t } from "elysia";
|
||||
import { getPhotos } from "./photo.library.controller";
|
||||
import { verifyAuth } from "../../middlewares/auth.middlewares";
|
||||
|
||||
export const photoLibraryRoutes = new Elysia({
|
||||
prefix: "/photos",
|
||||
tags: ["Photos"],
|
||||
detail: {
|
||||
description: "Routes for managing photo library",
|
||||
}
|
||||
}).derive(async ({ cookie }) => {
|
||||
const authData = await verifyAuth(cookie);
|
||||
return { authData }; // Inject into context
|
||||
});
|
||||
|
||||
photoLibraryRoutes.get("/", async ({ query, authData
|
||||
}) => {
|
||||
if (authData.status !== 200)
|
||||
return authData;
|
||||
else {
|
||||
const { keyword, per_page } = query;
|
||||
const token = authData.token;
|
||||
const data = await getPhotos(keyword, per_page, token);
|
||||
return { data };
|
||||
}
|
||||
}, {
|
||||
query: t.Object({
|
||||
keyword: t.String(),
|
||||
per_page: t.Number(),
|
||||
})
|
||||
})
|
||||
|
|
@ -6,225 +6,155 @@ import { createBucket } from "../../helper/upload/createBucket";
|
|||
import { removeBucket } from "../../helper/upload/removeBucket";
|
||||
|
||||
export const getAllProjects = async (userId: string, token: string) => {
|
||||
try {
|
||||
// Fetch all projects for the given user
|
||||
const allProjects = await db
|
||||
.select({
|
||||
id: projects.id,
|
||||
name: projects.name,
|
||||
description: projects.description,
|
||||
preview_url: projects.preview_url,
|
||||
object: projects.object,
|
||||
})
|
||||
.from(projects)
|
||||
.where(eq(projects.userId, userId));
|
||||
try {
|
||||
// Fetch all projects for the given user
|
||||
const allProjects = await db.select({
|
||||
id: projects.id,
|
||||
name: projects.name,
|
||||
description: projects.description,
|
||||
preview_url: projects.preview_url,
|
||||
object: projects.object,
|
||||
}).from(projects).where(eq(projects.userId, userId));
|
||||
|
||||
// Identify projects where 'object' is empty or 'object.objects' is empty
|
||||
const projectsToDelete = allProjects.filter(
|
||||
(proj) =>
|
||||
(proj.object &&
|
||||
typeof proj.object === "object" &&
|
||||
Object.keys(proj.object).length === 0) ||
|
||||
(proj.object?.objects &&
|
||||
Array.isArray(proj.object.objects) &&
|
||||
proj.object.objects.length === 0)
|
||||
);
|
||||
// Identify projects where 'object' is empty or 'object.objects' is empty
|
||||
const projectsToDelete = allProjects.filter(proj =>
|
||||
(proj.object && typeof proj.object === "object" && Object.keys(proj.object).length === 0) ||
|
||||
(proj.object?.objects && Array.isArray(proj.object.objects) && proj.object.objects.length === 0)
|
||||
);
|
||||
|
||||
// Delete projects with empty 'object' or empty 'object.objects'
|
||||
await Promise.all(
|
||||
projectsToDelete.map(async (proj) => {
|
||||
// Step 1: Delete associated uploads first
|
||||
await db.delete(uploads).where(eq(uploads.projectId, proj.id));
|
||||
// Delete projects with empty 'object' or empty 'object.objects'
|
||||
await Promise.all(
|
||||
projectsToDelete.map(async (proj) => {
|
||||
// Step 1: Delete associated uploads first
|
||||
await db.delete(uploads).where(eq(uploads.projectId, proj.id));
|
||||
|
||||
// Step 2: Delete the project itself
|
||||
await db.delete(projects).where(eq(projects.id, proj.id));
|
||||
// Step 2: Delete the project itself
|
||||
await db.delete(projects).where(eq(projects.id, proj.id));
|
||||
|
||||
// Step 3: Delete the associated bucket
|
||||
await removeBucket(proj.id);
|
||||
})
|
||||
);
|
||||
// Step 3: Delete the associated bucket
|
||||
await removeBucket(proj.id);
|
||||
})
|
||||
);
|
||||
|
||||
// Get remaining projects
|
||||
const remainingProjects = allProjects.filter(
|
||||
(proj) =>
|
||||
!(
|
||||
(proj.object &&
|
||||
typeof proj.object === "object" &&
|
||||
Object.keys(proj.object).length === 0) ||
|
||||
(proj.object?.objects &&
|
||||
Array.isArray(proj.object.objects) &&
|
||||
proj.object.objects.length === 0)
|
||||
)
|
||||
);
|
||||
// Get remaining projects
|
||||
const remainingProjects = allProjects.filter(proj =>
|
||||
!(
|
||||
(proj.object && typeof proj.object === "object" && Object.keys(proj.object).length === 0) ||
|
||||
(proj.object?.objects && Array.isArray(proj.object.objects) && proj.object.objects.length === 0)
|
||||
)
|
||||
);
|
||||
|
||||
if (remainingProjects.length === 0) {
|
||||
return { status: 404, message: "No projects found", token };
|
||||
if (remainingProjects.length === 0) {
|
||||
return { status: 404, message: "No projects found", token };
|
||||
}
|
||||
|
||||
return { status: 200, message: "Projects fetched successfully", data: remainingProjects, token };
|
||||
} catch (error: any) {
|
||||
console.log(error.message);
|
||||
return { status: 500, message: "An error occurred while fetching projects", token };
|
||||
}
|
||||
|
||||
return {
|
||||
status: 200,
|
||||
message: "Projects fetched successfully",
|
||||
data: remainingProjects,
|
||||
token,
|
||||
};
|
||||
} catch (error: any) {
|
||||
console.log(error.message);
|
||||
return {
|
||||
status: 500,
|
||||
message: "An error occurred while fetching projects",
|
||||
token,
|
||||
};
|
||||
}
|
||||
};
|
||||
|
||||
export const getEachProjects = async (id: string, token: string) => {
|
||||
try {
|
||||
const project = await db
|
||||
.select({
|
||||
id: projects.id,
|
||||
name: projects.name,
|
||||
description: projects.description,
|
||||
preview_url: projects.preview_url,
|
||||
object: projects.object,
|
||||
})
|
||||
.from(projects)
|
||||
.where(eq(projects.id, id))
|
||||
.limit(1);
|
||||
if (project.length === 0) {
|
||||
return { status: 404, message: "Project not found", token };
|
||||
try {
|
||||
const project = await db.select({
|
||||
id: projects.id,
|
||||
name: projects.name,
|
||||
description: projects.description,
|
||||
preview_url: projects.preview_url,
|
||||
object: projects.object,
|
||||
}).from(projects).where(eq(projects.id, id)).limit(1);
|
||||
if (project.length === 0) {
|
||||
return { status: 404, message: "Project not found", token };
|
||||
}
|
||||
return { status: 200, message: "Project fetched successfully", data: project[0], token };
|
||||
} catch (error: any) {
|
||||
console.log(error.message);
|
||||
return { status: 500, message: "An error occurred while fetching projects", token };
|
||||
}
|
||||
return {
|
||||
status: 200,
|
||||
message: "Project fetched successfully",
|
||||
data: project[0],
|
||||
token,
|
||||
};
|
||||
} catch (error: any) {
|
||||
console.log(error.message);
|
||||
return {
|
||||
status: 500,
|
||||
message: "An error occurred while fetching projects",
|
||||
token,
|
||||
};
|
||||
}
|
||||
};
|
||||
|
||||
export const createProject = async (userId: string, token: string) => {
|
||||
try {
|
||||
const { id } = await createEmptyProject(userId);
|
||||
const bucket = await createBucket(id);
|
||||
return {
|
||||
status: 200,
|
||||
message: "New project created successfully",
|
||||
data: { id, bucketName: bucket },
|
||||
token,
|
||||
};
|
||||
} catch (error: any) {
|
||||
console.log(error.message);
|
||||
return {
|
||||
status: 500,
|
||||
message: "An error occurred while creating projects",
|
||||
token,
|
||||
};
|
||||
}
|
||||
try {
|
||||
const { id } = await createEmptyProject(userId);
|
||||
const bucket = await createBucket(id);
|
||||
return { status: 200, message: "New project created successfully", data: { id, bucketName: bucket }, token };
|
||||
|
||||
} catch (error: any) {
|
||||
console.log(error.message);
|
||||
return { status: 500, message: "An error occurred while creating projects", token }
|
||||
}
|
||||
};
|
||||
|
||||
export const updateProject = async (
|
||||
id: string,
|
||||
body: any,
|
||||
token: string,
|
||||
user_id: string
|
||||
) => {
|
||||
try {
|
||||
// 1. Validate if project exists
|
||||
const existingProject = await db
|
||||
.select()
|
||||
.from(projects)
|
||||
.where(eq(projects.id, id));
|
||||
if (existingProject.length === 0) {
|
||||
return { status: 404, message: "Project not found", token };
|
||||
export const updateProject = async (id: string, body: any, token: string) => {
|
||||
try {
|
||||
// 1. Validate if project exists
|
||||
const existingProject = await db.select().from(projects).where(eq(projects.id, id)).limit(1);
|
||||
if (existingProject.length === 0) {
|
||||
return { status: 404, message: "Project not found", token };
|
||||
}
|
||||
|
||||
const { object, name, description, preview_url } = body;
|
||||
// The preview_url will come from client-side as well, where before updating the project a project capture will be taken and uploaded to the bucket. than the url will be sent to the server.And rest of them are normal process
|
||||
|
||||
const updatedProject = await db.update(projects).set({
|
||||
object,
|
||||
name,
|
||||
description,
|
||||
preview_url
|
||||
}).where(eq(projects.id, id)).returning({
|
||||
id: projects.id,
|
||||
object: projects.object,
|
||||
name: projects.name,
|
||||
description: projects.description,
|
||||
preview_url: projects.preview_url
|
||||
});
|
||||
|
||||
if (updatedProject.length === 0) {
|
||||
return { status: 500, message: "Failed to update the project", token };
|
||||
}
|
||||
return { status: 200, message: "Project updated successfully", data: updatedProject[0], token };
|
||||
} catch (error: any) {
|
||||
console.log("Error updating project:", error.message || error.toString());
|
||||
return { status: 500, message: "An error occurred while updating the project", token };
|
||||
}
|
||||
|
||||
const { object, name, description, preview_url } = body;
|
||||
// The preview_url will come from client-side as well, where before updating the project a project capture will be taken and uploaded to the bucket. than the url will be sent to the server.And rest of them are normal process
|
||||
|
||||
const updatedProject = await db
|
||||
.update(projects)
|
||||
.set({
|
||||
object,
|
||||
name,
|
||||
description,
|
||||
preview_url,
|
||||
userId: user_id,
|
||||
})
|
||||
.where(eq(projects.id, id))
|
||||
.returning({
|
||||
id: projects.id,
|
||||
object: projects.object,
|
||||
name: projects.name,
|
||||
description: projects.description,
|
||||
preview_url: projects.preview_url,
|
||||
});
|
||||
|
||||
if (updatedProject.length === 0) {
|
||||
return { status: 500, message: "Failed to update the project", token };
|
||||
}
|
||||
return {
|
||||
status: 200,
|
||||
message: "Project updated successfully",
|
||||
data: updatedProject[0],
|
||||
token,
|
||||
};
|
||||
} catch (error: any) {
|
||||
console.log("Error updating project:", error.message || error.toString());
|
||||
return {
|
||||
status: 500,
|
||||
message: "An error occurred while updating the project",
|
||||
token,
|
||||
};
|
||||
}
|
||||
};
|
||||
|
||||
export const deleteProject = async (id: string, token: string) => {
|
||||
try {
|
||||
const deletedUploads = await db
|
||||
.delete(uploads)
|
||||
.where(eq(uploads.projectId, id))
|
||||
.returning({ id: uploads.id });
|
||||
try {
|
||||
const deletedUploads = await db
|
||||
.delete(uploads)
|
||||
.where(eq(uploads.projectId, id))
|
||||
.returning({ id: uploads.id });
|
||||
|
||||
if (deletedUploads.length >= 0) {
|
||||
// Step 4: Delete the project
|
||||
const deletedProject = await db
|
||||
.delete(projects)
|
||||
.where(eq(projects.id, id))
|
||||
.returning({ id: projects.id });
|
||||
if (deletedUploads.length >= 0) {
|
||||
// Step 4: Delete the project
|
||||
const deletedProject = await db
|
||||
.delete(projects)
|
||||
.where(eq(projects.id, id))
|
||||
.returning({ id: projects.id });
|
||||
|
||||
if (deletedProject.length === 0) {
|
||||
return { status: 404, message: "Project not found", token };
|
||||
}
|
||||
if (deletedProject.length === 0) {
|
||||
return { status: 404, message: "Project not found", token };
|
||||
}
|
||||
|
||||
// Step 5: Delete the associated bucket
|
||||
const bucketDeletionResult = await removeBucket(id);
|
||||
// Step 5: Delete the associated bucket
|
||||
const bucketDeletionResult = await removeBucket(id);
|
||||
|
||||
if (bucketDeletionResult.status !== 200) {
|
||||
return {
|
||||
status: bucketDeletionResult.status,
|
||||
message: `Error deleting bucket: ${bucketDeletionResult.message}`,
|
||||
token,
|
||||
};
|
||||
}
|
||||
return {
|
||||
status: 200,
|
||||
message: "Project and associated bucket deleted successfully",
|
||||
token,
|
||||
};
|
||||
if (bucketDeletionResult.status !== 200) {
|
||||
return {
|
||||
status: bucketDeletionResult.status,
|
||||
message: `Error deleting bucket: ${bucketDeletionResult.message}`,
|
||||
token
|
||||
};
|
||||
}
|
||||
return { status: 200, message: "Project and associated bucket deleted successfully", token };
|
||||
}
|
||||
} catch (error: any) {
|
||||
console.log("Error in deleteProject:", error.message || error.toString());
|
||||
return { status: 500, message: "An error occurred while deleting the project", token };
|
||||
}
|
||||
} catch (error: any) {
|
||||
console.log("Error in deleteProject:", error.message || error.toString());
|
||||
return {
|
||||
status: 500,
|
||||
message: "An error occurred while deleting the project",
|
||||
token,
|
||||
};
|
||||
}
|
||||
};
|
||||
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -1,104 +1,85 @@
|
|||
import { Elysia, t } from "elysia";
|
||||
import {
|
||||
createProject,
|
||||
deleteProject,
|
||||
getAllProjects,
|
||||
getEachProjects,
|
||||
updateProject,
|
||||
} from "./project.controller";
|
||||
import { createProject, deleteProject, getAllProjects, getEachProjects, updateProject } from "./project.controller";
|
||||
import { verifyAuth } from "../../middlewares/auth.middlewares";
|
||||
|
||||
export const projectRoutes = new Elysia({
|
||||
prefix: "/projects",
|
||||
tags: ["Projects"],
|
||||
detail: {
|
||||
description: "Routes for managing projects",
|
||||
},
|
||||
prefix: "/projects",
|
||||
tags: ["Projects"],
|
||||
detail: {
|
||||
description: "Routes for managing projects",
|
||||
}
|
||||
}).derive(async ({ cookie }) => {
|
||||
const authData = await verifyAuth(cookie);
|
||||
return { authData }; // Inject into context
|
||||
const authData = await verifyAuth(cookie);
|
||||
return { authData }; // Inject into context
|
||||
});
|
||||
|
||||
projectRoutes.get(
|
||||
"/each/:project_id",
|
||||
async ({ params: { project_id }, authData }) => {
|
||||
if (authData.status !== 200) return authData;
|
||||
projectRoutes.get("/each/:project_id", async ({ params: { project_id }, authData }) => {
|
||||
if (authData.status !== 200)
|
||||
return authData;
|
||||
else {
|
||||
const token = authData.token;
|
||||
const response = await getEachProjects(project_id, token);
|
||||
return response;
|
||||
const token = authData.token;
|
||||
const response = await getEachProjects(project_id, token);
|
||||
return response;
|
||||
}
|
||||
},
|
||||
{
|
||||
}, {
|
||||
params: t.Object({
|
||||
project_id: t.String(),
|
||||
}),
|
||||
}
|
||||
);
|
||||
project_id: t.String()
|
||||
})
|
||||
});
|
||||
|
||||
projectRoutes.get("/", async ({ authData }: any) => {
|
||||
if (authData.status !== 200) return authData;
|
||||
else {
|
||||
const userId = authData.userId;
|
||||
const token = authData.token;
|
||||
const response = await getAllProjects(userId, token);
|
||||
return response;
|
||||
}
|
||||
if (authData.status !== 200)
|
||||
return authData;
|
||||
else {
|
||||
const userId = authData.userId;
|
||||
const token = authData.token;
|
||||
const response = await getAllProjects(userId, token);
|
||||
return response;
|
||||
}
|
||||
});
|
||||
|
||||
projectRoutes.post("/create", async ({ authData }: any) => {
|
||||
if (authData.status !== 200) return authData;
|
||||
else {
|
||||
const userId = authData.userId;
|
||||
const token = authData.token;
|
||||
const response = await createProject(userId, token);
|
||||
return response;
|
||||
}
|
||||
if (authData.status !== 200)
|
||||
return authData;
|
||||
else {
|
||||
const userId = authData.userId;
|
||||
const token = authData.token;
|
||||
const response = await createProject(userId, token);
|
||||
return response;
|
||||
}
|
||||
});
|
||||
|
||||
projectRoutes.put(
|
||||
"/update/:project_id",
|
||||
async ({ body, params: { project_id }, authData }) => {
|
||||
if (authData.status !== 200) return authData;
|
||||
projectRoutes.put("/update/:project_id", async ({ body, params: { project_id }, authData }) => {
|
||||
if (authData.status !== 200)
|
||||
return authData;
|
||||
else {
|
||||
const token = authData.token;
|
||||
const user_id = authData?.userId;
|
||||
// sending user_id to the controller to update the project with the user_id, when user tried to design a existing project from the design project panel
|
||||
const response = await updateProject(
|
||||
project_id,
|
||||
body,
|
||||
token,
|
||||
user_id as string
|
||||
);
|
||||
return response;
|
||||
const token = authData.token;
|
||||
const response = await updateProject(project_id, body, token);
|
||||
return response;
|
||||
}
|
||||
},
|
||||
{
|
||||
}, {
|
||||
params: t.Object({
|
||||
project_id: t.String(),
|
||||
project_id: t.String()
|
||||
}),
|
||||
body: t.Object({
|
||||
object: t.Record(t.String(), t.Any()), // Allows any JSON object
|
||||
name: t.String(),
|
||||
description: t.String(),
|
||||
preview_url: t.String(),
|
||||
}),
|
||||
}
|
||||
);
|
||||
object: t.Record(t.String(), t.Any()), // Allows any JSON object
|
||||
name: t.String(),
|
||||
description: t.String(),
|
||||
preview_url: t.String(),
|
||||
})
|
||||
});
|
||||
|
||||
projectRoutes.delete(
|
||||
"/delete/:project_id",
|
||||
async ({ params: { project_id }, authData }) => {
|
||||
if (authData.status !== 200) return authData;
|
||||
projectRoutes.delete("/delete/:project_id", async ({ params: { project_id }, authData }) => {
|
||||
if (authData.status !== 200)
|
||||
return authData;
|
||||
else {
|
||||
const token = authData.token;
|
||||
const response = await deleteProject(project_id, token);
|
||||
return response;
|
||||
const token = authData.token;
|
||||
const response = await deleteProject(project_id, token);
|
||||
return response;
|
||||
}
|
||||
},
|
||||
{
|
||||
}, {
|
||||
params: t.Object({
|
||||
project_id: t.String(),
|
||||
}),
|
||||
}
|
||||
);
|
||||
project_id: t.String()
|
||||
})
|
||||
});
|
||||
|
||||
|
|
|
|||
99
src/app.ts
99
src/app.ts
|
|
@ -1,52 +1,59 @@
|
|||
import { Elysia, t } from "elysia";
|
||||
import swagger from "@elysiajs/swagger";
|
||||
import cors from "@elysiajs/cors";
|
||||
import { Elysia } from "elysia";
|
||||
import swagger from '@elysiajs/swagger';
|
||||
|
||||
import { ENV } from "./config/env";
|
||||
import cors from "@elysiajs/cors";
|
||||
import { api } from "./api";
|
||||
|
||||
const app = new Elysia()
|
||||
.use(
|
||||
cors({
|
||||
origin: [
|
||||
"http://localhost:5175",
|
||||
"http://localhost:5174",
|
||||
"https://dashboard.planpostai.com",
|
||||
"https://dev.dashboard.planpostai.com",
|
||||
"https://canvas.planpostai.com",
|
||||
"https://canvasdev.planpostai.com",
|
||||
],
|
||||
methods: ["GET", "POST", "PUT", "DELETE", "PATCH", "HEAD", "OPTIONS"],
|
||||
allowedHeaders: [
|
||||
"Content-Type",
|
||||
"Authorization",
|
||||
"X-Requested-With",
|
||||
"Accept",
|
||||
"Origin",
|
||||
"Access-Control-Allow-Origin",
|
||||
],
|
||||
credentials: true,
|
||||
})
|
||||
)
|
||||
.get("/test", () => "Hello World", {})
|
||||
.use(api)
|
||||
.use(
|
||||
swagger({
|
||||
path: "/swagger",
|
||||
documentation: {
|
||||
openapi: "3.1.0",
|
||||
info: {
|
||||
title: "Canvas API",
|
||||
version: "1.0.0",
|
||||
description: "Canvas API Documentation",
|
||||
},
|
||||
const allowedOrigins = [
|
||||
"http://localhost:5175",
|
||||
"http://localhost:5173",
|
||||
"https://dashboard.planpostai.com",
|
||||
"https://canvas.planpostai.com",
|
||||
];
|
||||
|
||||
const app = new Elysia({
|
||||
prefix: "",
|
||||
tags: ["Default"],
|
||||
})
|
||||
.use(cors({
|
||||
origin: allowedOrigins,
|
||||
methods: ["GET", "POST", "PUT", "DELETE", "PATCH", "HEAD", "OPTIONS"],
|
||||
allowedHeaders: ["Content-Type", "Authorization", "X-Requested-With", "Accept", "Origin", "Access-Control-Allow-Origin"],
|
||||
credentials: true,
|
||||
}))
|
||||
.use(swagger({
|
||||
path: "/api/docs",
|
||||
documentation: {
|
||||
info: {
|
||||
title: "Canvas API",
|
||||
version: "1.0.0",
|
||||
description: "Canvas API Documentation",
|
||||
},
|
||||
})
|
||||
)
|
||||
.listen(ENV.SERVER_PORT);
|
||||
tags: [
|
||||
{
|
||||
name: "Projects",
|
||||
description: "All APIs related to Projects",
|
||||
},
|
||||
{
|
||||
name: "Uploads",
|
||||
description: "All APIs related to Uploads"
|
||||
}
|
||||
],
|
||||
}
|
||||
}))
|
||||
.onError(({ code, error }) => {
|
||||
if (code === 'NOT_FOUND')
|
||||
return 'Not Found :(';
|
||||
console.log("hello from app.ts under error");
|
||||
console.error(error)
|
||||
});
|
||||
|
||||
// all routes here
|
||||
app.use(api);
|
||||
|
||||
app.listen(ENV.SERVER_PORT, () => {
|
||||
console.log(`🦊 Elysia is running at ${ENV.SERVER_URL}:${ENV.SERVER_PORT}`)
|
||||
})
|
||||
|
||||
app.routes.forEach((route) => {
|
||||
console.log(`Route: ${route.method} ${route.path}`);
|
||||
});
|
||||
|
||||
console.log(`🦊 Elysia is running at ${ENV.SERVER_URL}`);
|
||||
console.log(`Swagger docs available at ${ENV.SERVER_URL}/swagger`);
|
||||
|
|
|
|||
|
|
@ -1,17 +1,14 @@
|
|||
import "dotenv/config";
|
||||
import 'dotenv/config'
|
||||
|
||||
export const ENV = {
|
||||
SERVER_URL: process.env.SERVER_URL,
|
||||
SERVER_PORT: process.env.SERVER_PORT || 5000,
|
||||
CANVAS_SERVER_URL_DEV: process.env.CANVAS_SERVER_URL_DEV,
|
||||
DATABASE_URL: process.env.DATABASE_URL,
|
||||
MINIO_ACCESS_KEY: process.env.MINIO_ACCESS_KEY,
|
||||
MINIO_SECRET_KEY: process.env.MINIO_SECRET_KEY,
|
||||
MINIO_ENDPOINT: process.env.MINIO_URL,
|
||||
MINIO_PORT: process.env.MINIO_PORT,
|
||||
CLERK_SECRET_KEY: process.env.CLERK_SECRET_KEY,
|
||||
JWT_ACCESS_TOKEN_SECRET: process.env.JWT_ACCESS_TOKEN_SECRET,
|
||||
JWT_REFRESH_TOKEN_SECRET: process.env.JWT_REFRESH_TOKEN_SECRET,
|
||||
PEXELS_URL: process.env.PEXELS_URL,
|
||||
PEXELS_ACCESS_KEY: process.env.PEXELS_ACCESS_KEY,
|
||||
};
|
||||
SERVER_URL: process.env.SERVER_URL,
|
||||
SERVER_PORT: process.env.SERVER_PORT || 5000,
|
||||
DATABASE_URL: process.env.DATABASE_URL,
|
||||
MINIO_ACCESS_KEY: process.env.MINIO_ACCESS_KEY,
|
||||
MINIO_SECRET_KEY: process.env.MINIO_SECRET_KEY,
|
||||
MINIO_ENDPOINT: process.env.MINIO_ENDPOINT,
|
||||
MINIO_PORT: process.env.MINIO_PORT,
|
||||
CLERK_SECRET_KEY: process.env.CLERK_SECRET_KEY,
|
||||
JWT_ACCESS_TOKEN_SECRET: process.env.JWT_ACCESS_TOKEN_SECRET,
|
||||
JWT_REFRESH_TOKEN_SECRET: process.env.JWT_REFRESH_TOKEN_SECRET,
|
||||
}
|
||||
|
|
@ -3,7 +3,8 @@ import { ENV } from "../config/env";
|
|||
|
||||
export const minioClient = new Client({
|
||||
endPoint: ENV.MINIO_ENDPOINT!.replace("http://", "").replace("https://", ""),
|
||||
useSSL: ENV.MINIO_ENDPOINT!.startsWith("https"),
|
||||
port: ENV.MINIO_PORT,
|
||||
useSSL: false,
|
||||
accessKey: ENV.MINIO_ACCESS_KEY,
|
||||
secretKey: ENV.MINIO_SECRET_KEY,
|
||||
});
|
||||
|
|
|
|||
|
|
@ -1,59 +1,35 @@
|
|||
import {
|
||||
boolean,
|
||||
integer,
|
||||
json,
|
||||
pgTable,
|
||||
text,
|
||||
timestamp,
|
||||
uuid,
|
||||
jsonb,
|
||||
} from "drizzle-orm/pg-core";
|
||||
import { boolean, integer, json, pgTable, text, timestamp, uuid, jsonb } from "drizzle-orm/pg-core";
|
||||
|
||||
export const users = pgTable("users", {
|
||||
id: text("user_id").primaryKey().notNull(),
|
||||
email: text("email").notNull(),
|
||||
lastName: text("last_name"),
|
||||
firstName: text("first_name"),
|
||||
image: text("image"),
|
||||
paid_status: text("paid_status"),
|
||||
expires_in: text("expires_in"),
|
||||
refresh_token: text("refresh_token"),
|
||||
download_limit: integer("download_limit").notNull().default(10),
|
||||
downloads_today: jsonb("downloads_today").default({ date: null, count: 0 }),
|
||||
id: text("user_id").primaryKey().notNull(),
|
||||
email: text("email").notNull(),
|
||||
lastName: text("last_name"),
|
||||
firstName: text("first_name"),
|
||||
image: text("image"),
|
||||
paid_status: text("paid_status"),
|
||||
expires_in: text("expires_in"),
|
||||
refresh_token: text("refresh_token"),
|
||||
download_limit: integer("download_limit").notNull().default(10),
|
||||
downloads_today: jsonb("downloads_today").default({ date: null, count: 0 }),
|
||||
});
|
||||
|
||||
export const projects = pgTable("projects", {
|
||||
id: uuid("project_id").defaultRandom().primaryKey(),
|
||||
userId: text("user_id").references(() => users.id),
|
||||
object: json(),
|
||||
name: text("name"),
|
||||
description: text("description"),
|
||||
is_public: boolean("is_active").notNull().default(false),
|
||||
preview_url: text("preview_url"),
|
||||
created_at: timestamp("created_at").defaultNow(),
|
||||
updated_at: timestamp("updated_at").defaultNow(),
|
||||
id: uuid("project_id").defaultRandom().primaryKey(),
|
||||
userId: text("user_id").references(() => users.id),
|
||||
object: json(),
|
||||
name: text("name"),
|
||||
description: text("description"),
|
||||
is_public: boolean("is_active").notNull().default(false),
|
||||
preview_url: text("preview_url"),
|
||||
created_at: timestamp("created_at").defaultNow(),
|
||||
updated_at: timestamp("updated_at").defaultNow(),
|
||||
});
|
||||
|
||||
export const uploads = pgTable("uploads", {
|
||||
id: uuid().defaultRandom().primaryKey(),
|
||||
filename: text("filename").notNull(),
|
||||
url: text("url").notNull(),
|
||||
projectId: uuid().references(() => projects.id),
|
||||
created_at: timestamp("created_at").defaultNow(),
|
||||
updated_at: timestamp("updated_at").defaultNow(),
|
||||
});
|
||||
|
||||
export const shapes = pgTable("shapes", {
|
||||
id: uuid("shape_id").defaultRandom().primaryKey(),
|
||||
shapes: text("shapes").notNull(),
|
||||
created_at: timestamp("created_at").defaultNow(),
|
||||
updated_at: timestamp("updated_at").defaultNow(),
|
||||
});
|
||||
|
||||
export const category = pgTable("project_category", {
|
||||
id: uuid("category_id").defaultRandom().primaryKey(),
|
||||
user_id: uuid().references(() => users.id),
|
||||
category: text("category").notNull(),
|
||||
created_at: timestamp("created_at").defaultNow(),
|
||||
updated_at: timestamp("updated_at").defaultNow(),
|
||||
id: uuid().defaultRandom().primaryKey(),
|
||||
filename: text("filename").notNull(),
|
||||
url: text("url").notNull(),
|
||||
projectId: uuid().references(() => projects.id),
|
||||
created_at: timestamp("created_at").defaultNow(),
|
||||
updated_at: timestamp("updated_at").defaultNow(),
|
||||
});
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue