Merge pull request 100xdevs-cohort-2#881 from tarunclub/master

week-11 solution

Author: hkirat

week-11/solution/.env.example

@@ -0,0 +1,2 @@
+DATABASE_URL=""
+DIRECT_URL=""

week-11/solution/.gitignore

@@ -0,0 +1,10 @@
+node_modules
+dist
+.wrangler
+.dev.vars
+
+# Change them to your taste:
+package-lock.json
+yarn.lock
+pnpm-lock.yaml
+bun.lockb

week-11/solution/README.md

@@ -0,0 +1,8 @@
+```
+npm install
+npm run dev
+```
+
+```
+npm run deploy
+```

week-11/solution/package.json

@@ -0,0 +1,18 @@
+{
+  "scripts": {
+    "dev": "wrangler dev src/index.ts",
+    "deploy": "wrangler deploy --minify src/index.ts"
+  },
+  "dependencies": {
+    "@prisma/client": "^5.9.1",
+    "@prisma/extension-accelerate": "^0.6.3",
+    "hono": "^4.0.3",
+    "jsonwebtoken": "^9.0.2"
+  },
+  "devDependencies": {
+    "@cloudflare/workers-types": "^4.20240208.0",
+    "@types/jsonwebtoken": "^9.0.5",
+    "prisma": "^5.9.1",
+    "wrangler": "^3.25.0"
+  }
+}

week-11/solution/prisma/migrations/20240311164032_init/migration.sql

@@ -0,0 +1,52 @@
+-- CreateTable
+CREATE TABLE "User" (
+    "id" SERIAL NOT NULL,
+    "username" TEXT NOT NULL,
+    "email" TEXT NOT NULL,
+    "password" TEXT NOT NULL,
+
+    CONSTRAINT "User_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateTable
+CREATE TABLE "Posts" (
+    "id" SERIAL NOT NULL,
+    "title" TEXT NOT NULL,
+    "body" TEXT NOT NULL,
+    "userId" INTEGER NOT NULL,
+    "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+
+    CONSTRAINT "Posts_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateTable
+CREATE TABLE "Tags" (
+    "id" SERIAL NOT NULL,
+    "tag" TEXT NOT NULL,
+
+    CONSTRAINT "Tags_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateTable
+CREATE TABLE "_PostsToTags" (
+    "A" INTEGER NOT NULL,
+    "B" INTEGER NOT NULL
+);
+
+-- CreateIndex
+CREATE UNIQUE INDEX "Tags_tag_key" ON "Tags"("tag");
+
+-- CreateIndex
+CREATE UNIQUE INDEX "_PostsToTags_AB_unique" ON "_PostsToTags"("A", "B");
+
+-- CreateIndex
+CREATE INDEX "_PostsToTags_B_index" ON "_PostsToTags"("B");
+
+-- AddForeignKey
+ALTER TABLE "Posts" ADD CONSTRAINT "Posts_userId_fkey" FOREIGN KEY ("userId") REFERENCES "User"("id") ON DELETE RESTRICT ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "_PostsToTags" ADD CONSTRAINT "_PostsToTags_A_fkey" FOREIGN KEY ("A") REFERENCES "Posts"("id") ON DELETE CASCADE ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "_PostsToTags" ADD CONSTRAINT "_PostsToTags_B_fkey" FOREIGN KEY ("B") REFERENCES "Tags"("id") ON DELETE CASCADE ON UPDATE CASCADE;

week-11/solution/prisma/migrations/migration_lock.toml

@@ -0,0 +1,3 @@
+# Please do not edit this file manually
+# It should be added in your version-control system (i.e. Git)
+provider = "postgresql"

week-11/solution/prisma/schema.prisma

@@ -0,0 +1,36 @@
+// This is your Prisma schema file,
+// learn more about it in the docs: https://pris.ly/d/prisma-schema
+
+generator client {
+  provider = "prisma-client-js"
+}
+
+datasource db {
+  provider  = "postgresql"
+  url       = env("DATABASE_URL")
+  directUrl = env("DIRECT_URL")
+}
+
+model User {
+  id       Int     @id @default(autoincrement())
+  username String
+  email    String
+  password String
+  posts    Posts[]
+}
+
+model Posts {
+  id     Int      @id @default(autoincrement())
+  title  String
+  body   String
+  tags   Tags[]
+  User   User     @relation(fields: [userId], references: [id])
+  userId Int
+  createdAt  DateTime   @default(now())
+}
+
+model Tags {
+  id Int @id @default(autoincrement())
+  tag String @unique
+  post Posts[]
+}

week-11/solution/src/controller/postController.ts

@@ -0,0 +1,236 @@
+import { PrismaClient } from '@prisma/client/edge';
+import { withAccelerate } from '@prisma/extension-accelerate';
+
+import { Context } from 'hono';
+
+enum StatusCode {
+  BADREQ = 400,
+  NOTFOUND = 404,
+  NOTPERMISSIOON = 403,
+}
+
+export async function getPosts(c: Context) {
+  const prisma = new PrismaClient({
+    datasourceUrl: c.env.DATABASE_URL,
+  }).$extends(withAccelerate());
+
+  try {
+    const response = await prisma.posts.findMany({
+      include: {
+        tags: true,
+        User: true,
+      },
+    });
+    return c.json({
+      post: response.map((res) => ({
+        id: res.id,
+        username: res.User.username,
+        userId: res.User.id,
+        title: res.title,
+        body: res.body,
+        tags: res.tags,
+        createdAt: res.createdAt,
+      })),
+    });
+  } catch (error) {
+    return c.body(`Internal server error: ${error}`, 500);
+  }
+}
+
+export async function getUserPosts(c: Context) {
+  const prisma = new PrismaClient({
+    datasourceUrl: c.env.DATABASE_URL,
+  }).$extends(withAccelerate());
+
+  try {
+    const resp = await prisma.posts.findMany({
+      where: {
+        userId: c.get('userId'),
+      },
+    });
+    return c.json({
+      post: resp,
+    });
+  } catch (error) {
+    return c.body(`Internal server error: ${error}`, 500);
+  }
+}
+
+export async function createPost(c: Context) {
+  const prisma = new PrismaClient({
+    datasourceUrl: c.env.DATABASE_URL,
+  }).$extends(withAccelerate());
+
+  try {
+    const body: {
+      title: string;
+      body: string;
+      tags: string;
+    } = await c.req.json();
+
+    const tagNames = body.tags.split(',').map((tag) => tag.trim());
+
+    if ((body.body && body.title) == null) {
+      return c.body('Invalid user input', StatusCode.BADREQ);
+    }
+    const res = await prisma.posts.create({
+      data: {
+        title: body.title,
+        body: body.body,
+        userId: c.get('userId'),
+        tags: {
+          connectOrCreate: tagNames.map((tag) => ({
+            where: { tag },
+            create: { tag },
+          })),
+        },
+      },
+      include: {
+        tags: true,
+      },
+    });
+
+    return c.json({
+      message: 'Post successfully',
+      post: {
+        id: res.id,
+        title: res.title,
+        body: res.body,
+        tags: res.tags.map((tag) => tag.tag),
+        createdAt: res.createdAt,
+      },
+    });
+  } catch (error) {
+    return c.body(`Internal server error: ${error}`, 500);
+  }
+}
+
+export async function getPost(c: Context) {
+  const prisma = new PrismaClient({
+    datasourceUrl: c.env.DATABASE_URL,
+  }).$extends(withAccelerate());
+
+  try {
+    const id: number = Number(c.req.param('id'));
+
+    const isPostExist = await prisma.posts.findFirst({
+      where: {
+        id: id,
+        userId: c.get('userId'),
+      },
+      include: {
+        tags: true,
+      },
+    });
+
+    if (isPostExist == null) {
+      return c.body('Post does not exists', StatusCode.NOTFOUND);
+    }
+    return c.json({
+      data: {
+        id: isPostExist.id,
+        title: isPostExist.title,
+        body: isPostExist.body,
+        tags: isPostExist.tags,
+        createdAt: isPostExist.createdAt,
+      },
+    });
+  } catch (error) {
+    return c.body(`Internal server error: ${error}`, 500);
+  }
+}
+
+// this controller update the specific post
+export async function updatePost(c: Context) {
+  const prisma = new PrismaClient({
+    datasourceUrl: c.env.DATABASE_URL,
+  }).$extends(withAccelerate());
+
+  try {
+    const id: number = Number(c.req.param('id'));
+
+    const body: {
+      title: string;
+      body: string;
+      tags: string;
+    } = await c.req.json();
+
+    const tagNames = body.tags.split(',').map((tag) => tag.trim());
+
+    const isPostExist = await prisma.posts.findFirst({
+      where: {
+        id: id,
+        userId: c.get('userId'),
+      },
+    });
+
+    if (isPostExist == null) {
+      return c.body('Post does not exists', StatusCode.NOTFOUND);
+    }
+
+    const res = await prisma.posts.update({
+      where: {
+        id: id,
+        userId: c.get('userId'),
+      },
+      data: {
+        title: body.title,
+        body: body.body,
+        tags: {
+          connectOrCreate: tagNames.map((tag) => ({
+            where: { tag },
+            create: { tag },
+          })),
+        },
+      },
+      include: {
+        tags: true,
+      },
+    });
+
+    return c.json({
+      data: {
+        id: res.id,
+        title: res.title,
+        body: res.body,
+        tags: res.tags,
+        createdAt: res.createdAt,
+      },
+    });
+  } catch (error) {
+    return c.body(`Internal server error: ${error}`, 500);
+  }
+}
+
+export async function deletePost(c: Context) {
+  const prisma = new PrismaClient({
+    datasourceUrl: c.env.DATABASE_URL,
+  }).$extends(withAccelerate());
+
+  try {
+    const id: number = Number(c.req.param('id'));
+
+    const isPostExist = await prisma.posts.findFirst({
+      where: {
+        id: id,
+        userId: c.get('userId'),
+      },
+    });
+
+    if (isPostExist == null) {
+      return c.body('Post does not exists', StatusCode.NOTFOUND);
+    }
+
+    const res = await prisma.posts.delete({
+      where: {
+        id: id,
+        userId: c.get('userId'),
+      },
+    });
+    return c.json({
+      message: 'post deleted',
+    });
+  } catch (error) {
+    return c.json({ msg: `Internal server error: ${error}` }, 500);
+  }
+}