Merge pull request #8 from fiit-tp7-2023/#287-prepare-api-endpoints

AB#287 Prepare api endpoints
fiit-tp7-2023 · Mar 24, 2024 · 734ea81 · 734ea81
2 parents 1e9b4ab + c4829cd
commit 734ea81
Show file tree

Hide file tree

Showing 30 changed files with 555 additions and 60 deletions.
diff --git a/.env.example b/.env.example
@@ -1,14 +1,5 @@
 # REST API configuration
 REST_API_URL=
 
-# Auth configuration - required in production
-AUTH_ORIGIN=
-AUTH_SECRET=
-
-# Google configuration
-GOOGLE_CLIENT_ID=
-GOOGLE_CLIENT_SECRET=
-GOOGLE_REFRESH_TOKEN_URL=
-
 # .NET backend runs locally on HTTPS (must be set to 0), for production must be set to 1
 NODE_TLS_REJECT_UNAUTHORIZED=
diff --git a/.vscode/settings.json b/.vscode/settings.json
@@ -13,12 +13,14 @@
     "Lato",
     "nuxt",
     "nuxtjs",
+    "ofetch",
     "Raleway",
     "Roboto",
     "sidebase",
     "tailwindcss",
     "vueuc",
-    "wght"
+    "wght",
+    "dtos"
   ],
   "files.eol": "\n",
   "[typescript]": {

diff --git a/components/posts/NftPost.vue b/components/posts/NftPost.vue
@@ -15,7 +15,7 @@
       <p>{{ post.description }}</p>
     </div>
     <div class="mx-4 my-2 flex flex-wrap items-center gap-2">
-      <template v-for="attribute in post.nft.attributes">
+      <template v-for="attribute in post.nft.attributes" :key="attribute.traitType">
         <p class="bg-slate-600 text-white px-2 py-1 rounded">{{ attribute.traitType }}</p>
       </template>
       <p class="underline text-gray-300">Show more</p>
@@ -25,9 +25,9 @@
 
 <script setup lang="ts">
 import { defineProps } from 'vue';
-import type { NFTPost } from '~/types';
+import type { NFTPost } from '~/types/dtos';
 
-const props = defineProps<{
+defineProps<{
   post: NFTPost;
 }>();
 </script>

diff --git a/nuxt.config.ts b/nuxt.config.ts
@@ -1,6 +1,9 @@
 // https://nuxt.com/docs/api/configuration/nuxt-config
 export default defineNuxtConfig({
   devtools: { enabled: true },
+  runtimeConfig: {
+    restApiUrl: process.env.REST_API_URL,
+  },
   modules: [
     '@nuxtjs/tailwindcss',
     'nuxt-icon',

diff --git a/server/api/auth.ts b/server/api/auth.ts
diff --git a/server/api/auth/login.post.ts b/server/api/auth/login.post.ts
@@ -0,0 +1,8 @@
+import { useAuthService } from '~/server/services/auth.service';
+import { VerifyNonce } from '~/types/auth';
+
+export default defineEventHandler(async (event) => {
+  const { signature, address } = await readBody<VerifyNonce>(event);
+  const service = useAuthService();
+  return await service.verifyNonce(signature, address);
+});
diff --git a/server/api/auth/nonce.post.ts b/server/api/auth/nonce.post.ts
@@ -0,0 +1,8 @@
+import { useAuthService } from '~/server/services/auth.service';
+import { GetNonceDTO } from '~/types/auth';
+
+export default defineEventHandler(async (event) => {
+  const { address } = await readBody<GetNonceDTO>(event);
+  const service = useAuthService();
+  return await service.getNonce(address);
+});
diff --git a/server/api/auth/refresh.post.ts b/server/api/auth/refresh.post.ts
@@ -0,0 +1,10 @@
+import { useAuthService } from '~/server/services/auth.service';
+import { AuthenticatedUser, RefreshTokenRequestDTO } from '~/types/auth';
+
+type Body = RefreshTokenRequestDTO & AuthenticatedUser;
+
+export default defineEventHandler(async (event) => {
+  const { refreshToken: refToken, jwt } = await readBody<Body>(event);
+  const service = useAuthService(jwt);
+  return await service.refreshToken(refToken);
+});
diff --git a/server/api/comment/[id]/index.delete.ts b/server/api/comment/[id]/index.delete.ts
@@ -0,0 +1,16 @@
+import { useCommentService } from '~/server/services/comment.service';
+import { AuthenticatedUser } from '~/types/auth';
+
+type Body = AuthenticatedUser;
+
+export default defineEventHandler(async (event) => {
+  const { jwt } = await readBody<Body>(event);
+  const commentId = getRouterParam(event, 'id');
+  if (Number.isNaN(commentId)) {
+    return createError({
+      message: 'Invalid comment id',
+    });
+  }
+  const service = useCommentService(jwt);
+  return await service.remove(Number(commentId));
+});
diff --git a/server/api/comment/[id]/index.put.ts b/server/api/comment/[id]/index.put.ts
@@ -0,0 +1,17 @@
+import { useCommentService } from '~/server/services/comment.service';
+import { AuthenticatedUser } from '~/types/auth';
+import { UpdateCommentDTO } from '~/types/dtos';
+
+type Body = AuthenticatedUser & UpdateCommentDTO;
+
+export default defineEventHandler(async (event) => {
+  const { jwt, content } = await readBody<Body>(event);
+  const commentId = getRouterParam(event, 'id');
+  if (Number.isNaN(commentId)) {
+    return createError({
+      message: 'Invalid comment id',
+    });
+  }
+  const service = useCommentService(jwt);
+  return await service.update(Number(commentId), content);
+});
diff --git a/server/api/comment/[id]/like/index.delete.ts b/server/api/comment/[id]/like/index.delete.ts
@@ -0,0 +1,15 @@
+import { useCommentService } from '~/server/services/comment.service';
+import { AuthenticatedUser } from '~/types/auth';
+
+export default defineEventHandler(async (event) => {
+  const { jwt } = await readBody<AuthenticatedUser>(event);
+  const commentId = getRouterParam(event, 'id');
+  if (Number.isNaN(commentId)) {
+    return createError({
+      message: 'Invalid comment id',
+    });
+  }
+
+  const service = useCommentService(jwt);
+  return await service.unlike(Number(commentId));
+});
diff --git a/server/api/comment/[id]/like/index.get.ts b/server/api/comment/[id]/like/index.get.ts
@@ -0,0 +1,15 @@
+import { useCommentService } from '~/server/services/comment.service';
+import { AuthenticatedUser } from '~/types/auth';
+
+export default defineEventHandler(async (event) => {
+  const { jwt } = await readBody<AuthenticatedUser>(event);
+  const commentId = getRouterParam(event, 'id');
+  if (Number.isNaN(commentId)) {
+    return createError({
+      message: 'Invalid comment id',
+    });
+  }
+
+  const service = useCommentService(jwt);
+  return await service.getLikes(Number(commentId));
+});
diff --git a/server/api/comment/[id]/like/index.post.ts b/server/api/comment/[id]/like/index.post.ts
@@ -0,0 +1,15 @@
+import { useCommentService } from '~/server/services/comment.service';
+import { AuthenticatedUser } from '~/types/auth';
+
+export default defineEventHandler(async (event) => {
+  const { jwt } = await readBody<AuthenticatedUser>(event);
+  const commentId = getRouterParam(event, 'id');
+  if (Number.isNaN(commentId)) {
+    return createError({
+      message: 'Invalid comment id',
+    });
+  }
+
+  const service = useCommentService(jwt);
+  return await service.like(Number(commentId));
+});
diff --git a/server/api/comment/index.post.ts b/server/api/comment/index.post.ts
@@ -0,0 +1,11 @@
+import { useCommentService } from '~/server/services/comment.service';
+import { AuthenticatedUser } from '~/types/auth';
+import { AddCommentDTO, NFTAddress } from '~/types/dtos';
+
+type Body = AuthenticatedUser & AddCommentDTO & NFTAddress;
+
+export default defineEventHandler(async (event) => {
+  const { jwt, content, parentCommentId, address } = await readBody<Body>(event);
+  const service = useCommentService(jwt);
+  return await service.add(address, content, parentCommentId);
+});
diff --git a/server/api/post/[id]/like/index.delete.ts b/server/api/post/[id]/like/index.delete.ts
@@ -0,0 +1,15 @@
+import { usePostService } from '~/server/services/post.service';
+import { AuthenticatedUser } from '~/types/auth';
+
+export default defineEventHandler(async (event) => {
+  const { jwt } = await readBody<AuthenticatedUser>(event);
+  const nftAddress = getRouterParam(event, 'id');
+  if (!nftAddress) {
+    return createError({
+      message: 'Invalid NFT address',
+    });
+  }
+
+  const service = usePostService(jwt);
+  return await service.unlike(nftAddress);
+});
diff --git a/server/api/post/[id]/like/index.get.ts b/server/api/post/[id]/like/index.get.ts
@@ -0,0 +1,15 @@
+import { usePostService } from '~/server/services/post.service';
+import { AuthenticatedUser } from '~/types/auth';
+
+export default defineEventHandler(async (event) => {
+  const { jwt } = await readBody<AuthenticatedUser>(event);
+  const nftAddress = getRouterParam(event, 'id');
+  if (!nftAddress) {
+    return createError({
+      message: 'Invalid NFT address',
+    });
+  }
+
+  const service = usePostService(jwt);
+  return await service.getLikes(nftAddress);
+});
diff --git a/server/api/post/[id]/like/index.post.ts b/server/api/post/[id]/like/index.post.ts
@@ -0,0 +1,15 @@
+import { usePostService } from '~/server/services/post.service';
+import { AuthenticatedUser } from '~/types/auth';
+
+export default defineEventHandler(async (event) => {
+  const { jwt } = await readBody<AuthenticatedUser>(event);
+  const nftAddress = getRouterParam(event, 'id');
+  if (!nftAddress) {
+    return createError({
+      message: 'Invalid NFT address',
+    });
+  }
+
+  const service = usePostService(jwt);
+  return await service.like(nftAddress);
+});
diff --git a/server/api/post/my.get.ts b/server/api/post/my.get.ts
@@ -0,0 +1,11 @@
+import { usePostService } from '~/server/services/post.service';
+import { AuthenticatedUser } from '~/types/auth';
+import { PaginationDTO } from '~/types/dtos';
+
+export default defineEventHandler(async (event) => {
+  const { jwt } = await readBody<AuthenticatedUser>(event);
+  const { pageNumber, pageSize } = getQuery<PaginationDTO>(event);
+
+  const service = usePostService(jwt);
+  return await service.getMyPosts(pageNumber, pageSize);
+});
diff --git a/server/errors/index.ts b/server/errors/index.ts
@@ -0,0 +1,55 @@
+import { ServerErrorType } from '~/types/error';
+
+export class ServerError {
+  static notFound(_reason: string) {
+    return createError({
+      status: ServerErrorType.NOT_FOUND,
+      statusText: 'Not found',
+      statusMessage: _reason,
+    });
+  }
+
+  static unauthorized(_reason: string) {
+    return createError({
+      status: ServerErrorType.UNAUTHORIZED,
+      statusText: 'Unauthorized',
+      statusMessage: _reason,
+    });
+  }
+
+  static forbidden(_reason: string) {
+    return createError({
+      status: ServerErrorType.FORBIDDEN,
+      statusText: 'Forbidden',
+      statusMessage: _reason,
+    });
+  }
+
+  static internalServerError(_reason: string) {
+    return createError({
+      status: ServerErrorType.INTERNAL_SERVER_ERROR,
+      statusText: 'Internal server error',
+      statusMessage: _reason,
+    });
+  }
+
+  static unavailable() {
+    return createError({
+      status: ServerErrorType.UNAVAILABLE,
+      statusText: 'Service unavailable',
+    });
+  }
+
+  static fromCode(code: number, _reason: string) {
+    switch (code) {
+      case 401:
+        return ServerError.unauthorized(_reason);
+      case 403:
+        return ServerError.forbidden(_reason);
+      case 404:
+        return ServerError.notFound(_reason);
+      default:
+        return ServerError.internalServerError(_reason);
+    }
+  }
+}
diff --git a/server/services/auth.service.ts b/server/services/auth.service.ts
@@ -0,0 +1,42 @@
+import { useApi } from '../utils/api';
+import { GetNonceDTO, RefreshTokenDTO, RefreshTokenRequestDTO, VerifyNonce } from '~/types/auth';
+
+export function useAuthService(token?: string) {
+  const getNonce = async (address: string): Promise<string> =>
+    await useApi<string, GetNonceDTO>('auth/nonce-message', undefined, {
+      method: 'POST',
+      body: {
+        address,
+      },
+    });
+
+  const verifyNonce = async (signature: string, address: string): Promise<RefreshTokenDTO> => {
+    const response = await useApi<RefreshTokenDTO, VerifyNonce>('auth/login', undefined, {
+      method: 'POST',
+      body: {
+        signature,
+        address,
+      },
+    });
+    return response;
+  };
+
+  const refreshToken = async (refreshToken: string): Promise<RefreshTokenDTO> => {
+    if (!token) {
+      throw new Error('Missing user token');
+    }
+    const response = await useApi<RefreshTokenDTO, RefreshTokenRequestDTO>('auth/refresh', token, {
+      method: 'POST',
+      body: {
+        refreshToken,
+      },
+    });
+    return response;
+  };
+
+  return {
+    getNonce,
+    verifyNonce,
+    refreshToken,
+  };
+}