Merge pull request #1 from jesieldotdev/new-db

New db

Author: jesieldotdev

.env

@@ -0,0 +1,2 @@
+SUPABASE_URL=https://smjvdyhhwzdzvloweoxt.supabase.co
+SUPABASE_KEY=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZSIsInJlZiI6InNtanZkeWhod3pkenZsb3dlb3h0Iiwicm9sZSI6ImFub24iLCJpYXQiOjE3MzA5ODkzMDQsImV4cCI6MjA0NjU2NTMwNH0.-3NznwUsudhDwP03sXVOYufG-_ARGHDpXF99R9Ah8oc

package.json

@@ -9,16 +9,22 @@
     "lint": "next lint"
   },
   "dependencies": {
+    "@supabase/supabase-js": "^2.46.1",
+    "bufferutil": "^4.0.8",
+    "next": "latest",
+    "pg": "^8.13.1",
+    "pg-hstore": "^2.3.4",
     "react": "latest",
     "react-dom": "latest",
-    "next": "latest"
+    "sequelize": "^6.37.5",
+    "utf-8-validate": "^6.0.5"
   },
   "devDependencies": {
-    "typescript": "latest",
-    "@types/react": "latest",
     "@types/node": "latest",
+    "@types/react": "latest",
     "@types/react-dom": "latest",
     "eslint": "latest",
-    "eslint-config-next": "latest"
+    "eslint-config-next": "latest",
+    "typescript": "latest"
   }
 }

src/app/api/blog/route.ts

@@ -1,36 +1,35 @@
 import { getPosts, addPost, deletePost } from "@/app/lib/data"
 import { NextResponse } from "next/server"
 
-
-export const GET = async (req: Request, res: Response) => {
-
-    try{
-        const posts = getPosts()
+export const GET = async (req: Request) => {
+    try {
+        // Aguarda a resolução da promessa
+        const posts = await getPosts(); 
 
-        return NextResponse.json({message: 'OK', posts},{
-            status: 200
-        })
+        return NextResponse.json({ message: 'OK', posts }, { status: 200 });
     } catch (err) {
-        return NextResponse.json({message: 'Error', err}, {
-            status: 500,
-        })
+        if (err instanceof Error) {
+            return NextResponse.json({ message: 'Error', err: err.message }, { status: 500 });
+        } else {
+            return NextResponse.json({ message: 'Unknown error' }, { status: 500 });
+        }
     }
+    
 }
 
-export const POST = async (req: Request, res: Response) => {
-    const {title, desc} = await req.json()
+export const POST = async (req: Request) => {
+    const { title } = await req.json();
 
     try {
-        const post = {title, desc, date: new Date(), id: Date.now().toString()}
-        addPost(post)
-        return NextResponse.json({message: "Ok", post}, {status: 201})
-    } catch (err){
-        return NextResponse.json({message: 'Error', err}, {
-            status: 500
-        })
+        const post = { title };
+        await addPost(post); // Garantir que a função addPost aguarde a inserção do post
+        return NextResponse.json({ message: "Ok", post }, { status: 201 });
+    } catch (err) {
+        if (err instanceof Error) {
+            return NextResponse.json({ message: 'Error', err: err.message }, { status: 500 });
+        } else {
+            return NextResponse.json({ message: 'Unknown error' }, { status: 500 });
+        }
     }
+    
 }
-
-
-
-

src/app/lib/data.ts

@@ -1,56 +1,66 @@
-import file from "../api/posts.json" assert { type: "json" };
-const fs = require("fs");
-const customer = 
-  {
-    name: "d Co.",
-    order_count: 0,
-    address: "Po Box City",
-  }
-
-function saveJson(data:any){
-    const jsonString = JSON.stringify(data);
-fs.writeFile("./src/app/api/posts.json", jsonString, (err:any) => {
-  if (err) {
-    console.log("Error writing file", err);
-  } else {
-    console.log("Successfully wrote file");
-  }
-});
-}
+import supabase  from '../../config/database'; // Importando o cliente Supabase
 
+// Obter todos os posts
+export const getPosts = async () => {
+  const { data, error } = await supabase
+    .from('posts') // Nome da tabela
+    .select('*');  // Seleciona todos os campos
 
+    console.log(data)
 
-type Post = {
-  id: string;
-  title: string;
-  desc: string;
-  date: any;
+  if (error) throw new Error(error.message);
+  return data;
 };
 
-let posts: Post[] = file;
+// Adicionar um novo post
+export const addPost = async (post: {  title: string;  }) => {
+  const { data, error } = await supabase
+    .from('posts') // Nome da tabela
+    .insert([
+      {title: post.title }
+    ]);
 
-export const getPosts = () => posts;
-export const addPost = (post: Post) => {
-  posts.push(post);
-  saveJson(posts)
+  if (error) throw new Error(error.message);
+  return data;
 };
-export const deletePost = (id: string) => {
-  posts = posts.filter((post) => post.id !== id);
-  saveJson(posts)
-};
-export const updatePost = (id: string, title: string, desc: string) => {
-  const post = posts.find((post) => post.id === id);
-  
 
-  if (post) {
-    post.title = title;
-    post.desc = desc;
-    saveJson(posts)
-  } else {
+// Deletar um post pelo id
+export const deletePost = async (id: string) => {
+  const { data, error } = await supabase
+    .from('posts')
+    .delete()
+    .eq('id', id); // A condição de deletar pelo id
+
+  if (error) throw new Error(error.message);
+  if (!data) {
     throw new Error("NO POST FOUND");
   }
+  
+  
+  return data;
+};
+
+// Atualizar um post pelo id
+export const updatePost = async (id: string, title: string, desc: string) => {
+  const { data, error } = await supabase
+    .from('posts')
+    .update({ title, desc })
+    .eq('id', id); // A condição de atualizar pelo id
+
+  if (error) throw new Error(error.message);
+  if (!data) throw new Error("NO POST FOUND");
+  return data;
 };
 
-export const getById = (id: string) => {
-  return posts.find((post) => post.id === id);
+// Obter um post pelo id
+export const getById = async (id: string) => {
+  const { data, error } = await supabase
+    .from('posts')
+    .select('*')
+    .eq('id', id)
+    .single(); // Para pegar apenas um resultado (usamos .single() para retornar um único item)
+
+  if (error) throw new Error(error.message);
+  if (!data) throw new Error("NO POST FOUND");
+  return data;
 };

src/app/page.tsx

@@ -4,6 +4,7 @@ export default function Home() {
   return (
 <main>
   <p>My Api</p>
+  <a href='/api/blog'>Blog</a>
 </main>
   )
 }

src/config/database.ts

@@ -0,0 +1,8 @@
+import { createClient } from '@supabase/supabase-js';
+
+// Substitua pelos valores reais da sua instância Supabase
+const SUPABASE_URL = process.env.SUPABASE_URL; // URL da sua instância do Supabase
+const SUPABASE_ANON_KEY = process.env.SUPABASE_KEY; // Chave pública anônima (encontrada no painel do Supabase)
+
+ const supabase = createClient(SUPABASE_URL, SUPABASE_ANON_KEY);
+ export default supabase    

src/models/Post.ts

@@ -0,0 +1,81 @@
+import supabase from "../config/database"; // Caminho para o seu cliente Supabase
+
+interface Post {
+  id: string;
+  title: string;
+  desc: string;
+  date: string; // O Supabase geralmente lida com datas como strings em formato ISO
+}
+
+class PostModel {
+  // Função para obter todos os posts
+  static async getAllPosts(): Promise<Post[]> {
+    const { data, error } = await supabase
+      .from("posts")
+      .select("*");
+
+    if (error) {
+      throw new Error(error.message);
+    }
+
+    return data as Post[];
+  }
+
+  // Função para criar um novo post
+  static async createPost(title: string, desc: string): Promise<Post> {
+    const { data, error } = await supabase
+      .from("posts")
+      .insert([{ title, desc, date: new Date().toISOString() }])
+      .single();
+
+    if (error) {
+      throw new Error(error.message);
+    }
+
+    return data as Post;
+  }
+
+  // Função para obter um post por ID
+  static async getPostById(postId: string): Promise<Post | null> {
+    const { data, error } = await supabase
+      .from("posts")
+      .select("*")
+      .eq("id", postId)
+      .single();
+
+    if (error) {
+      throw new Error(error.message);
+    }
+
+    return data as Post | null;
+  }
+
+  // Função para atualizar um post
+  static async updatePost(postId: string, title: string, desc: string): Promise<Post> {
+    const { data, error } = await supabase
+      .from("posts")
+      .update({ title, desc })
+      .eq("id", postId)
+      .single();
+
+    if (error) {
+      throw new Error(error.message);
+    }
+
+    return data as Post;
+  }
+
+  // Função para deletar um post
+  static async deletePost(postId: string): Promise<void> {
+    const { error } = await supabase
+      .from("posts")
+      .delete()
+      .eq("id", postId);
+
+    if (error) {
+      throw new Error(error.message);
+    }
+  }
+}
+
+export default PostModel;

tsconfig.json

@@ -1,10 +1,11 @@
 {
   "compilerOptions": {
+    "noImplicitAny": false,
     "target": "es5",
     "lib": ["dom", "dom.iterable", "esnext"],
     "allowJs": true,
     "skipLibCheck": true,
-    "strict": true,
+    "strict": false,
     "noEmit": true,
     "esModuleInterop": true,
     "module": "esnext",