Merge pull request #61 from webdonalds/feature/like

Implement like api

docs/yas_api_like_doc.md

@@ -0,0 +1,71 @@
+## POST - /v1/like/
+
+set like
+
+#### Header
+
+| KEY            | VALUE            | REQUIRED |
+| -------------- | ---------------- | -------- |
+| Content-type   | application/json | O        |
+| x-access-token | ACCESS_TOKEN     | O        |
+
+
+#### Body Parameters
+
+| KEY         | VALUE            | REQUIRED |
+| ----------- | ---------------- | -------- |
+| videoId     | VIDEO_ID         | O        |
+
+
+#### URL Parameters
+
+X
+
+
+#### Success Response
+
+Code: 200 (success)
+
+Content:
+~~~
+{
+    "message": "success"
+}
+~~~
+
+
+
+## DELETE - /v1/like
+
+unset like
+
+
+#### Header
+
+| KEY            | VALUE            | REQUIRED |
+| -------------- | ---------------- | -------- |
+| Content-type   | application/json | O        |
+| x-access-token | ACCESS_TOKEN     | O        |
+
+
+#### Body Parameters
+
+| KEY     | VALUE    | REQUIRED |
+| ------- | -------- | -------- |
+| videoId | VIDEO_ID | O        |
+
+
+#### URL Parameters
+
+X
+
+
+#### Success Response
+
+Code: 200 (success)
+Content:
+~~~
+{
+  "message": "success"
+}
+~~~

src/api/index.ts

@@ -3,6 +3,7 @@ import * as express from 'express';
 import auth from './v1/auth';
 import user from './v1/user';
 import contents from './v1/contents';
+import like from './v1/like';
 import post from './v1/post';
 import logoffedPostList from './v1/logoffedPostList';
 
@@ -13,6 +14,7 @@ const router = express.Router();
 router.use('/v1/auth', auth);
 router.use('/v1/user', middleware.validateToken, user);
 router.use('/v1/contents', middleware.validateToken, middleware.getGoogleAccessToken, contents);
+router.use('/v1/like', middleware.validateToken, like);
 // handle middleware in post
 router.use('/v1/post', post);
 router.use('/v1/logoffed-post-list', logoffedPostList);

src/api/v1/auth.ts

@@ -73,6 +73,7 @@ router.get('/login', async (request: express.Request, response: express.Response
         }
     } catch(e) {
         errorSend(response, 'internal_server_error', e);
+        return;
     }
 
     const data = {
@@ -102,6 +103,7 @@ router.get('/login', async (request: express.Request, response: express.Response
         });
     } catch(e) {
         errorSend(response, 'fail_create_token', null);
+        return;
     }
 
     response.json({
@@ -143,6 +145,7 @@ router.get('/access-token', async (request: express.Request, response: express.R
         });
     } catch(e) {
         errorSend(response, 'cannot_find_token', null);
+        return;
     }
 
     // no token found from database

src/api/v1/like.ts

@@ -0,0 +1,91 @@
+import * as express from 'express';
+import { Like, Video } from '../../model/index';
+import { errorSend } from '../../error/errorUtil';
+import { Sequelize } from 'sequelize';
+
+const router = express.Router();
+
+
+// post like (set like)
+router.post('/', async (request: express.Request, response: express.Response) => {
+  const userId = request.body.userInfo.userId;
+  const videoId = request.body.videoId;
+
+  try {
+    await Like.create({
+      userId: userId,
+      videoId: videoId
+    });
+  }
+  catch (e) {
+    errorSend(response, 'videoId is invalid', null);
+    return;
+  }
+
+  try {
+    Video.update({
+      totalLikes: Sequelize.literal('totalLikes + 1')
+    }, {
+      where: {
+        id: videoId
+      }
+    });
+    response.json({
+      message: 'success'
+    });
+  } catch (e) {
+    await Like.destroy({
+      where: {
+        userId: userId,
+        videoId: videoId
+      }
+    });
+    errorSend(response, 'fail to update video totalLikes', null);
+    return;
+  }
+});
+
+
+// delete like (unset like)
+router.delete('/', async (request: express.Request, response: express.Response) => {
+  const userId = request.body.userInfo.userId;
+  const videoId = request.body.videoId;
+
+  try {
+    const deleteCount = await Like.destroy({
+      where: {
+        userId: userId,
+        videoId: videoId
+      }
+    });
+    if(deleteCount == 0) {
+      throw '';
+    }
+  } catch (e) {
+    errorSend(response, 'videoId is invalid', null);
+    return;
+  }
+
+  try {
+    await Video.update({
+      totalLikes: Sequelize.literal('totalLikes - 1')
+    }, {
+      where: {
+        id: videoId
+      }
+    });
+    response.json({
+      message: 'success'
+    });
+  } catch (e) {
+    await Like.create({
+      userId: userId,
+      videoId: videoId
+    });
+    errorSend(response, 'fail to update video totalLikes', null);
+    return;
+  }
+});
+
+
+export default router;

src/api/v1/logoffedPostList.ts

@@ -48,6 +48,7 @@ router.get('/recent-videos', async (request: express.Request, response: express.
         }
     } catch(e) {
         errorSend(response, 'fail_get_video', null);
+        return;
     }
 
     const recentVideoList = [];

src/api/v1/post.ts

@@ -87,6 +87,7 @@ router.get('/user-videos/:userId', async (request: express.Request, response: ex
         }
     } catch(e) {
         errorSend(response, 'not_found', null);
+        return;
     }
 
     const userVideos = [];
@@ -143,6 +144,7 @@ router.post('/video', middleware.validateToken, async (request: express.Request,
         });
     } catch(e) {
         errorSend(response, 'internal_server_error', e);
+        return;
     }
     return;
 });
@@ -192,6 +194,7 @@ router.put('/video', middleware.validateToken, async (request: express.Request,
         tagService.addVideoHasTag(videoPostId, tagIds);
     } catch(e) {
         errorSend(response, 'internal_server_error', null);
+        return;
     }
 
     response.json({
@@ -230,6 +233,7 @@ router.delete('/video', middleware.validateToken, async (request: express.Reques
         // video_has_tag will be deleted automatically by Database setting.
     } catch(e) {
         errorSend(response, 'internal_server_error', null);
+        return;
     }
 
     response.json({

src/api/v1/user.ts

@@ -38,6 +38,7 @@ router.put('/user-info', async (request: express.Request, response: express.Resp
         );
     } catch(e) {
         errorSend(response, 'fail_update_user', null);
+        return;
     }
 
     response.json({
@@ -75,6 +76,7 @@ router.put('/profile-image', async (request: express.Request, response: express.
         );
     } catch(e) {
         errorSend(response, 'fail_update_user', null);
+        return;
     }
 
     response.json({

src/model/Like.ts

@@ -9,10 +9,12 @@ class Like extends Model {
             {
                 userId: {
                     type: DataTypes.INTEGER,
+                    primaryKey: true,
                     allowNull: false
                 },
                 videoId: {
                     type: DataTypes.INTEGER,
+                    primaryKey: true,
                     allowNull: false
                 }
             },