feat: Native HTTP port

src/ports/native-http/index.ts

@@ -0,0 +1,17 @@
+import http from 'http'
+import { env } from '@/helpers/env'
+
+import { app } from './server'
+
+const PORT = env('PORT')
+
+export function start () {
+  return new Promise((resolve) => {
+    http
+      .createServer(app)
+      .listen(PORT, () => {
+        console.log(`Server is listening on port ${PORT}`)
+        resolve(null)
+      })
+  })
+}

src/ports/native-http/middlewares.ts

@@ -0,0 +1,42 @@
+import { pipe } from 'fp-ts/function'
+import * as TE from 'fp-ts/TaskEither'
+import { authMiddleware } from '@/ports/adapters/http/http'
+import { httpResponse, RequestListener } from './server'
+
+type WithAuthMiddleware = (handler: RequestListener) => RequestListener
+export const withAuth: WithAuthMiddleware = (handler) => {
+  return async (request, response) => {
+    pipe(
+      authMiddleware(request.headers.authorization),
+      TE.map(
+        (payload) => {
+          request.auth = payload
+          return handler(request, response)
+        },
+      ),
+      TE.mapLeft(
+        (result) => httpResponse(response, result.error, result.code),
+      ),
+    )()
+  }
+}
+
+export const withTryAuth: WithAuthMiddleware = (handler) => {
+  return async (request, response) => {
+    pipe(
+      authMiddleware(request.headers.authorization),
+      TE.map(
+        (payload) => {
+          request.auth = payload
+          return handler(request, response)
+        },
+      ),
+      TE.mapLeft(
+        () => {
+          request.auth = undefined
+          return handler(request, response)
+        },
+      ),
+    )()
+  }
+}

src/ports/native-http/modules/article.ts

@@ -0,0 +1,209 @@
+import { pipe, identity } from 'fp-ts/function'
+import * as E from 'fp-ts/Either'
+import * as TE from 'fp-ts/TaskEither'
+import * as article from '@/ports/adapters/http/modules/article'
+import { getPayload } from '@/ports/adapters/http/http'
+import { CreateArticle, UpdateArticle } from '@/core/article/types'
+import { CreateComment } from '@/core/comment/types'
+import { Slug } from '@/core/types'
+import { Routes, httpResponse } from '../server'
+import { withAuth, withTryAuth } from '../middlewares'
+
+type GetPropFromRequestBody = <T>(data: string, prop: string) => T
+const getPropFromRequestBody: GetPropFromRequestBody = (data, prop) => {
+  return pipe(
+    E.tryCatch(
+      () => JSON.parse(data),
+      E.toError,
+    ),
+    E.fold(identity, (body) => body[prop] ?? {}),
+  )
+}
+
+const articleRoutes: Routes = {
+  'POST /api/articles': withAuth(async (request, response) => {
+    const payload = getPayload(request.auth)
+
+    for await (const body of request) {
+      const data = {
+        ...getPropFromRequestBody<CreateArticle>(body, 'article'),
+        authorId: payload.id,
+      }
+
+      pipe(
+        data,
+        article.registerArticle,
+        TE.map(result => httpResponse(response, result)),
+        TE.mapLeft(result => httpResponse(response, result.error, result.code)),
+      )()
+    }
+  }),
+
+  'GET /api/articles/:slug': withTryAuth(async (request, response) => {
+    const payload = getPayload(request.auth)
+    const slug = 'slug'
+
+    pipe(
+      article.fetchArticle({
+        slug: request.params?.[slug] ?? '',
+        userId: payload.id,
+      }),
+      TE.map(result => httpResponse(response, result)),
+      TE.mapLeft(result => httpResponse(response, result.error, result.code)),
+    )()
+  }),
+
+  'GET /api/articles': withTryAuth(async (request, response) => {
+    const payload = getPayload(request.auth)
+
+    pipe(
+      article.fetchArticles({
+        filter: request.query ?? {},
+        userId: payload.id,
+      }),
+      TE.map(result => httpResponse(response, result)),
+      TE.mapLeft(result => httpResponse(response, result.error, result.code)),
+    )()
+  }),
+
+  'PUT /api/articles/:slug': withAuth(async (request, response) => {
+    const payload = getPayload(request.auth)
+    const slug = 'slug'
+
+    for await (const body of request) {
+      const data: UpdateArticle = {
+        ...getPropFromRequestBody<UpdateArticle>(body, 'article'),
+        slug: request.params?.[slug] as Slug,
+        authorId: payload.id,
+      }
+
+      pipe(
+        data,
+        article.updateArticle,
+        TE.map(result => httpResponse(response, result)),
+        TE.mapLeft(result => httpResponse(response, result.error, result.code)),
+      )()
+    }
+  }),
+
+  'DELETE /api/articles/:slug': withAuth(async (request, response) => {
+    const payload = getPayload(request.auth)
+    const slug = 'slug'
+
+    pipe(
+      article.deleteArticle({
+        slug: request.params?.[slug] ?? '',
+        userId: payload.id,
+      }),
+      TE.map(() => httpResponse(response)),
+      TE.mapLeft(result => httpResponse(response, result.error, result.code)),
+    )()
+  }),
+
+  'GET /api/articles/feed': withAuth(async (request, response) => {
+    const payload = getPayload(request.auth)
+
+    pipe(
+      article.fetchArticlesFeed({
+        filter: request.query || {},
+        userId: payload.id,
+      }),
+      TE.map(result => httpResponse(response, result)),
+      TE.mapLeft(result => httpResponse(response, result.error, result.code)),
+    )()
+  }),
+
+  'POST /api/articles/:slug/favorite': withAuth(async (request, response) => {
+    const payload = getPayload(request.auth)
+    const slug = 'slug'
+
+    pipe(
+      article.favoriteArticle({
+        userId: payload.id,
+        slug: request.params?.[slug] ?? '',
+      }),
+      TE.map(result => httpResponse(response, result)),
+      TE.mapLeft(result => httpResponse(response, result.error, result.code)),
+    )()
+  }),
+
+  'DELETE /api/articles/:slug/favorite': withAuth(async (request, response) => {
+    const payload = getPayload(request.auth)
+    const slug = 'slug'
+
+    pipe(
+      article.unfavoriteArticle({
+        userId: payload.id,
+        slug: request.params?.[slug] ?? '',
+      }),
+      TE.map(result => httpResponse(response, result)),
+      TE.mapLeft(result => httpResponse(response, result.error, result.code)),
+    )()
+  }),
+
+  'POST /api/articles/:slug/comments': withAuth(async (request, response) => {
+    const payload = getPayload(request.auth)
+    const slug = 'slug'
+
+    for await (const body of request) {
+      const data: CreateComment = {
+        ...getPropFromRequestBody<CreateComment>(body, 'comment'),
+        authorId: payload.id,
+        articleSlug: request.params?.[slug] as Slug,
+      }
+
+      pipe(
+        data,
+        article.addCommentToAnArticle,
+        TE.map(result => httpResponse(response, result)),
+        TE.mapLeft(result => httpResponse(response, result.error, result.code)),
+      )()
+    }
+  }),
+
+  'GET /api/articles/:slug/comments': withTryAuth(async (request, response) => {
+    const payload = getPayload(request.auth)
+    const slug = 'slug'
+
+    const data = {
+      slug: request.params?.[slug] ?? '',
+      userId: payload.id,
+    }
+
+    pipe(
+      data,
+      article.getCommentsFromAnArticle,
+      TE.map(result => httpResponse(response, result)),
+      TE.mapLeft(result => httpResponse(response, result.error, result.code)),
+    )()
+  }),
+
+  'DELETE /api/articles/:slug/comments/:id': withAuth(async (request, response) => {
+    const payload = getPayload(request.auth)
+    const slug = 'slug'
+    const id = 'id'
+
+    const data = {
+      commentId: Number(request.params?.[id]),
+      slug: request.params?.[slug] ?? '',
+      userId: payload.id,
+    }
+
+    pipe(
+      data,
+      article.deleteComment,
+      TE.map(() => httpResponse(response)),
+      TE.mapLeft(result => httpResponse(response, result.error, result.code)),
+    )()
+  }),
+
+  'GET /api/tags': async (_request, response) => {
+    pipe(
+      article.getTags(),
+      TE.map(result => httpResponse(response, result)),
+      TE.mapLeft(result => httpResponse(response, result.error, result.code)),
+    )()
+  },
+}
+
+export { articleRoutes }

src/ports/native-http/modules/index.ts

@@ -0,0 +1,3 @@
+export * from './user'
+export * from './profile'
+export * from './article'

src/ports/native-http/modules/profile.ts

@@ -0,0 +1,52 @@
+import { pipe } from 'fp-ts/function'
+import * as TE from 'fp-ts/TaskEither'
+import * as user from '@/ports/adapters/http/modules/user'
+import { getPayload } from '@/ports/adapters/http/http'
+import { Routes, httpResponse } from '../server'
+import { withAuth, withTryAuth } from '../middlewares'
+
+const profileRoutes: Routes = {
+  'GET /api/profiles/:username': withTryAuth(async (request, response) => {
+    const username = 'username'
+    const payload = getPayload(request.auth)
+
+    pipe(
+      user.getProfile({
+        username: request.params?.[username] ?? '',
+        userId: payload.id,
+      }),
+      TE.map(result => httpResponse(response, result)),
+      TE.mapLeft(result => httpResponse(response, result.error, result.code)),
+    )()
+  }),
+
+  'POST /api/profiles/:username/follow': withAuth(async (request, response) => {
+    const username = 'username'
+    const payload = getPayload(request.auth)
+
+    pipe(
+      user.followUser({
+        userToFollow: request.params?.[username] ?? '',
+        userId: payload.id,
+      }),
+      TE.map(result => httpResponse(response, result)),
+      TE.mapLeft(result => httpResponse(response, result.error, result.code)),
+    )()
+  }),
+
+  'DELETE /api/profiles/:username/follow': withAuth(async (request, response) => {
+    const username = 'username'
+    const payload = getPayload(request.auth)
+
+    pipe(
+      user.unfollowUser({
+        userToUnfollow: request.params?.[username] ?? '',
+        userId: payload.id,
+      }),
+      TE.map(result => httpResponse(response, result)),
+      TE.mapLeft(result => httpResponse(response, result.error, result.code)),
+    )()
+  }),
+}
+
+export { profileRoutes }