s

Author: jesieldotdev

package.json

@@ -10,14 +10,11 @@
   },
   "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",
-    "sequelize": "^6.37.5",
-    "utf-8-validate": "^6.0.5"
+    "react-dom": "latest"
   },
   "devDependencies": {
     "@types/node": "latest",

src/app/api/blog/posts.json

@@ -1,10 +1,10 @@
-import { deletePost, getById, updatePost } from "@/app/lib/data";
+import { deletePost, getPostById, updatePost } from "@/app/lib/posts_controller";
 import { NextResponse } from "next/server";
 
 export const GET = async (req: Request) => {
   try {
-    const id = req.url.split("blog/")[1];
-    const post = getById(id);
+    const id = req.url.split("posts/")[1];
+    const post = await getPostById(id);
     console.log(post);
     if (!post) {
       return NextResponse.json({ message: "Error" }, { status: 404 });
@@ -18,9 +18,9 @@ export const GET = async (req: Request) => {
 
 export const PUT = async (req: Request) => {
   try {
-    const { title, desc } = await req.json();
-    const id = req.url.split("blog/")[1];
-    updatePost(id, title, desc);
+    const { title, slug, author_id} = await req.json();
+    const id = req.url.split("posts/")[1];
+    updatePost(id, title, slug, author_id);
     return NextResponse.json({ message: "OK" }, { status: 200 });
   } catch (err) {
     return NextResponse.json({message: 'Error'}, {status: 500})
@@ -29,9 +29,9 @@ export const PUT = async (req: Request) => {
 
 export const DELETE = async (req: Request) => {
   try {
-    const id = req.url.split("blog/")[1];
+    const id = req.url.split("posts/")[1];
 
-    const post = getById(id);
+    const post = getPostById(id);
 
     if (!post) {
       return NextResponse.json({ message: "Error" }, { status: 404 });

src/app/api/posts.json

@@ -1,4 +1,4 @@
-import { getPosts, addPost, deletePost } from "@/app/lib/data"
+import { getPosts, addPost, deletePost } from "@/app/lib/posts_controller"
 import { NextResponse } from "next/server"
 
 export const GET = async (req: Request) => {
@@ -18,10 +18,10 @@ export const GET = async (req: Request) => {
 }
 
 export const POST = async (req: Request) => {
-    const { title } = await req.json();
+    const { title, slug, author_id } = await req.json();
 
     try {
-        const post = { title };
+        const post = { title, slug, author_id };
         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) {

src/app/api/blog/[id]/route.ts renamed to src/app/api/posts/[id]/route.ts

@@ -0,0 +1,51 @@
+import { deleteUser, getUserById, updateUser } from "@/app/lib/users_controller";
+import { NextResponse } from "next/server";
+
+export const GET = async (req: Request) => {
+  try {
+    const id = req.url.split("users/")[1]
+    const user = await getUserById(id)
+    
+    
+    if (!user) {
+      return NextResponse.json({ message: "Error" }, { status: 404 });
+    }
+  
+
+    return NextResponse.json({ message: "OK", user}, { status: 200 });
+  } catch (err) {
+    NextResponse.json({ message: "Error", err }, { status: 500 });
+  }
+};
+
+export const PUT = async (req: Request) => {
+  try {
+    const { username, password, email, is_admin } = await req.json();
+    const id = req.url.split("users/")[1];
+    updateUser(id, username, password, is_admin);
+    return NextResponse.json({ message: "OK" }, { status: 200 });
+  } catch (err) {
+    return NextResponse.json({message: 'Error'}, {status: 500})
+  }
+};
+
+export const DELETE = async (req: Request) => {
+  try {
+    const id = req.url.split("users/")[1];
+
+    const user = getUserById(id);
+
+    if (!post) {
+      return NextResponse.json({ message: "Error" }, { status: 404 });
+    }
+    deleteUser(id);
+
+    return NextResponse.json({ message: "OK" }, { status: 200 });
+  } catch (err) {
+    NextResponse.json({ message: "Error", err }, { status: 500 });
+  }
+};
+
+export const POST = async (req: Request) => {
+  console.log("GET");
+};

src/app/api/blog/route.ts renamed to src/app/api/posts/route.ts

@@ -0,0 +1,35 @@
+import { getUsers, addUser, deleteUser } from "@/app/lib/users_controller"
+import { NextResponse } from "next/server"
+
+export const GET = async (req: Request) => {
+    try {
+        // Aguarda a resolução da promessa
+        const users = await getUsers(); 
+        
+        return NextResponse.json({ message: 'OK', users }, { status: 200 });
+    } 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 });
+        }
+    }
+    
+}
+
+export const POST = async (req: Request) => {
+    const { username, email, password, is_admin } = await req.json();
+
+    try {
+        const user = { username, email, password, is_admin };
+        await addUser(user); // Garantir que a função addPost aguarde a inserção do post
+        return NextResponse.json({ message: "Ok", user }, { 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/api/users/[id]/route.ts

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

src/app/api/users/route.ts

@@ -0,0 +1,88 @@
+import supabase from "../config/database"; // Caminho para o seu cliente Supabase
+
+interface User {
+  id: string;
+  username: string;
+  password: string;
+  createsAt: Date
+  is_admin: boolean; // O Supabase geralmente lida com datas como strings em formato ISO
+}
+
+interface UserInputProps{
+  username: string
+  password: string
+  is_admin: boolean
+}
+
+class UserModel {
+  // Função para obter todos os posts
+  static async getAllUsers(): Promise<User[]> {
+    const { data, error } = await supabase
+      .from("users")
+      .select("*");
+
+    if (error) {
+      throw new Error(error.message);
+    }
+
+    return data as User[];
+  }
+
+  // Função para criar um novo post
+  static async createUser(UserInputProps): Promise<User> {
+    const { data, error } = await supabase
+      .from("users")
+      .insert([{ username, password, is_admin }])
+      .single();
+
+    if (error) {
+      throw new Error(error.message);
+    }
+
+    return data as User;
+  }
+
+  // Função para obter um post por ID
+  static async getUserById(userId: string): Promise<User | null> {
+    const { data, error } = await supabase
+      .from("users")
+      .select("*")
+      .eq("id", userId)
+      .single();
+
+    if (error) {
+      throw new Error(error.message);
+    }
+
+    return data as User | null;
+  }
+
+  // Função para atualizar um post
+  static async updateUser(UserInputProps): Promise<User> {
+    const { data, error } = await supabase
+      .from("users")
+      .update({ username, password, is_admin})
+      .eq("id", userId)
+      .single();
+
+    if (error) {
+      throw new Error(error.message);
+    }
+
+    return data as User;
+  }
+
+  // Função para deletar um post
+  static async deleteUser(userId: string): Promise<void> {
+    const { error } = await supabase
+      .from("users")
+      .delete()
+      .eq("id", userId);
+
+    if (error) {
+      throw new Error(error.message);
+    }
+  }
+}
+
+export default UserModel;