feat: Add projects and templates API (#61)

Author: spicyzboss

apps/api/auth/src/main.ts

@@ -1,13 +1,13 @@
 import { Hono } from 'hono';
-import { D1Database } from '@cloudflare/workers-types';
+import { D1Database, R2Bucket } from '@cloudflare/workers-types';
 import { typeid } from 'typeid-js';
 
 interface ResponseWrapper<T, E> {
   data: T;
   error: E;
 }
 
-const response = <T, E> (data: T, error ?: E): ResponseWrapper<T, E> => {
+const response = <T, E>(data: T, error?: E): ResponseWrapper<T, E> => {
   return {
     data,
     error
@@ -16,6 +16,7 @@ const response = <T, E> (data: T, error ?: E): ResponseWrapper<T, E> => {
 
 type Bindings = {
   DB: D1Database;
+  BUCKET: R2Bucket;
 }
 
 const app = new Hono<{ Bindings: Bindings }>();
@@ -84,7 +85,7 @@ interface CreateOAuthParams {
   oaid: string;
   provider: string;
   email: string;
-}
+};
 
 type CreateUserRequest = CreateUserParams & CreateOAuthParams;
 
@@ -155,4 +156,198 @@ app.post('/providers', async (c) => {
   return c.json(response(result));
 });
 
+interface Template {
+  id: string;
+  userId: string;
+  name: string;
+  createdAt: number;
+  updatedAt: number;
+  deletedAt: number;
+};
+
+type CreateTemplateParams = Pick<Template,
+  | 'name'
+  | 'userId'
+>;
+
+type FindTemplateParams = Pick<Template,
+  | 'userId'
+>;
+
+interface TemplateDataParams {
+  data: JSON;
+};
+
+type UpdateTemplateParams = Pick<Template,
+  | 'name'
+>;
+
+type CreateTemplateRequest = CreateTemplateParams & TemplateDataParams;
+type UpdateTemplateRequest = UpdateTemplateParams & TemplateDataParams;
+
+app.post('/templates', async (c) => {
+  const body = await c.req.json<CreateTemplateRequest>();
+
+  const id = typeid('tmpl').toString();
+
+  const key = ['templates', body.userId, id].join('/');
+
+  const createTemplateStatement = c.env.DB.prepare(`
+    INSERT INTO template (id, user_id, name, created_at)        
+    VALUES (?1, ?2, ?3, ?4)
+  `);
+
+  try {
+    await c.env.BUCKET.put(key, JSON.stringify(body.data));
+
+    const { results } = await createTemplateStatement.bind(id, body.userId, body.name, Date.now()).run();
+
+    return c.json(response(results));
+  } catch (e) {
+    return c.json(response(null, e));
+  }
+});
+
+app.get('/templates/:userId', async (c) => {
+  const { userId } = c.req.param() as FindTemplateParams;
+
+  const getTemplateStatement = c.env.DB.prepare(`
+    SELECT
+      t.id,
+      t.user_id 'userId',
+      t.key,
+      t.created_at 'createdAt',
+      t.updated_at 'updatedAt'
+    FROM template as t
+    WHERE t.user_id = ?1 AND t.deleted_at NOT NULL
+  `);
+
+  const { results } = await getTemplateStatement.bind(userId).all<Template>();
+
+  results.map((template) => {
+    template.id;
+  });
+
+  return c.json(response(results));
+});
+
+app.get('/templates/:userId/:id', async (c) => {
+  const { userId, id } = c.req.param();
+  const key = ['templates', userId, id].join('/');
+
+  try {
+    const objectRef = await c.env.BUCKET.get(key);
+    const data = objectRef.json();
+
+    return c.json(response(data));
+  } catch (e) {
+    return c.json(response(null, e));
+  }
+});
+
+app.put('/templates/:userId/:id', async (c) => {
+  const { userId, id } = c.req.param();
+  const { data, name } = await c.req.json() as UpdateTemplateRequest;
+
+  const key = ['templates', userId, id].join('/');
+
+  const updateTemplateStatement = c.env.DB.prepare(`
+    UPDATE template
+    SET name = ?1
+    WHERE id = ?2 AND deleted_at NOT NULL
+  `);
+
+  try {
+    await c.env.BUCKET.put(key, JSON.stringify(data));
+
+    const { results } = await updateTemplateStatement.bind(name, id).run();
+
+    return c.json(response(results));
+  } catch (e) {
+    return c.json(response(null, e));
+  }
+});
+
+interface Project {
+  id: string;
+  userId: string;
+  templateId: string;
+  name: string;
+  createdAt: number;
+  updatedAt: number;
+  deletedAt: number;
+};
+
+type CreateProjectRequest = Pick<Project,
+  | 'userId'
+  | 'templateId'
+  | 'name'
+>;
+
+type FindProjectRequest = Pick<Project,
+  | 'userId'
+>;
+
+type UpdateProjectRequest = Pick<Project,
+  | 'id'
+  | 'name'
+>;
+
+app.post('/projects', async (c) => {
+  const body = await c.req.json<CreateProjectRequest>();
+
+  const createProjectStatement = c.env.DB.prepare(`
+    INSERT INTO project (id, user_id, template_id, name, created_at)
+    VALUES (?1, ?2, ?3, ?4, ?5)
+  `);
+
+  const id = typeid('proj').toString();
+
+  const result = createProjectStatement.bind(id, body.userId, body.templateId, body.name, Date.now()).run();
+
+  return c.json(response(result));
+});
+
+app.get('/projects', async (c) => {
+  const { userId } = c.req.query() as FindProjectRequest;
+
+  const getProjectStatement = c.env.DB.prepare(`
+    SELECT
+      p.id,
+      p.user_id 'userId',
+      p.template_id 'templateId',
+      p.created_at 'createdAt',
+      p.updated_at 'updatedAt'
+    FROM project as p
+    WHERE p.user_id = ?1 AND p.deleted_at NOT NULL
+  `);
+
+  const { results } = await getProjectStatement.bind(userId).all<Project>();
+
+  return c.json(response(results));
+});
+
+app.patch('/projects', async (c) => {
+  const body = await c.req.json<UpdateProjectRequest>();
+
+  const updateProjectStatement = c.env.DB.prepare(`
+    UPDATE project
+    SET name = ?1
+    WHERE id = ?2 AND deleted_at NOT NULL
+  `);
+
+  const { results } = await updateProjectStatement.bind(body.name, body.id).run();
+
+  return c.json(response(results));
+});
+
+// interface Generate {
+//   id: string;
+//   projectId: string;
+//   key: string;
+//   args: string;
+//   createdAt: number;
+//   deletedAt: number;
+// }
+
 export default app;

db/schema/schema.sql

@@ -39,3 +39,37 @@ CREATE TABLE IF NOT EXISTS oauth_account (
     FOREIGN KEY (user_id) REFERENCES user (id),
     FOREIGN KEY (oauth_provider_id) REFERENCES oauth_provider (id)
 );
+
+CREATE TABLE IF NOT EXISTS template (
+    id TEXT PRIMARY KEY,
+    user_id TEXT NOT NULL,
+    name TEXT NOT NULL,
+    created_at INTEGER NOT NULL,
+    updated_at INTEGER,
+    deleted_at INTEGER,
+
+    FOREIGN KEY (user_id) REFERENCES user (id)
+);
+
+CREATE TABLE IF NOT EXISTS project (
+    id TEXT PRIMARY KEY,
+    user_id TEXT NOT NULL,
+    template_id TEXT NOT NULL,
+    name TEXT NOT NULL,
+    created_at INTEGER NOT NULL,
+    updated_at INTEGER,
+    deleted_at INTEGER,
+
+    FOREIGN KEY (user_id) REFERENCES user (id),
+    FOREIGN KEY (template_id) REFERENCES template (id)
+);
+
+CREATE TABLE IF NOT EXISTS generate (
+    id TEXT PRIMARY KEY,
+    project_id TEXT NOT NULL,
+    args TEXT,
+    created_at INTEGER NOT NULL,
+    deleted_at INTEGER,
+
+    FOREIGN KEY (project_id) REFERENCES project (id)
+);

libs/web/dashboard/editor/src/lib/toolbar.tsx

@@ -5,7 +5,7 @@ import { Frame } from './context';
 export default component$(() => {
   const { frame } = useContext(Frame);
 
-  const exportObject = $(() => {
+  const saveTemplate = $(() => {
     if (!frame) return;
 
     console.log(frame.toObject());
@@ -15,7 +15,7 @@ export default component$(() => {
     <Navigation.Bar>
       <Box></Box>
       <Box>
-        <Navigation.Action onClick$={exportObject}>Export</Navigation.Action>
+        <Navigation.Action onClick$={saveTemplate}>Save</Navigation.Action>
       </Box>
     </Navigation.Bar>
   );

wrangler.toml

@@ -10,6 +10,9 @@ workers_dev = true
 d1_databases = [
   { binding = "DB", database_name = "dev-certifine", database_id = "ba778eb8-bf82-4984-a21a-88dc8913f2fe" }  
 ]
+r2_buckets = [
+  { binding = "BUCKET", bucket_name = "dev-certifine" }
+]
 
 [env.staging]
 vars = { ENVIRONMENT = "staging" }
@@ -20,6 +23,9 @@ workers_dev = true
 d1_databases = [
   { binding = "DB", database_name = "staging-certifine", database_id = "c0534c42-4517-4068-af84-a458e02866b0" }  
 ]
+r2_buckets = [
+  { binding = "BUCKET", bucket_name = "staging-certifine" }
+]
 
 [env.production]
 vars = { ENVIRONMENT = "production" }
@@ -31,3 +37,6 @@ workers_dev = false
 d1_databases = [
   { binding = "DB", database_name = "certifine", database_id = "fae83b0b-b945-4a5b-ad5f-23d3b13dd581" }  
 ]
+r2_buckets = [
+  { binding = "BUCKET", bucket_name = "certifine" }
+]