Merge pull request #5 from VinylaCrew/feature_#4

Feat: VinylSearch #4

vinyla/controllers/vinyl.js

@@ -0,0 +1,16 @@
+const util = require('../modules/util');
+const resMessage = require('../modules/responseMessage');
+const statusCode = require('../modules/statusCode');
+const VinylModel = require('../models/vinyl');
+
+module.exports = {
+    search: async(req, res) => {
+        const q = req.query.q;
+        if(!q){
+            return await res.status(statusCode.BAD_REQUEST).send(util.fail(statusCode.BAD_REQUEST, resMessage.NULL_VALUE));
+        }
+
+        const searchResult = await VinylModel.search(q);
+        return await res.status(statusCode.OK).send(util.success(statusCode.OK, resMessage.DISCOGS_SEARCH_SUCCESS, searchResult));
+    }
+};

vinyla/data/dto/vinylSearchDto.js

@@ -0,0 +1,8 @@
+module.exports = (vinylSearchDto) =>{
+    vinylSearchDto = {
+        "id": vinylSearchDto.id,
+        "thumb": vinylSearchDto.thumb,
+        "title": vinylSearchDto.title,
+        "artist": vinylSearchDto.artist
+    }
+}

vinyla/models/vinyl.js

@@ -0,0 +1,99 @@
+const pool = require('../modules/pool');
+const request = require('request');
+const discogsKey = require('../config/discogsKey');
+const Discogs = require('disconnect').Client;
+const vinylSearchDto = require('../data/dto/vinylSearchDto');
+
+const vinyl = {
+    search: (q) => {
+
+        var dis = new Discogs({
+            consumerKey: discogsKey.key,
+            consumerSecret: discogsKey.secret
+        });
+
+        // return new Promise((resolve, reject) => {
+        //     const db = new Discogs().database();
+        //     const auth = new Discogs({
+        //         consumerKey: discogsKey.key,
+        //         consumerSecret: discogsKey.secret
+        //     });
+        //     db.search({query: q, options: auth})
+        //     .then(res => {
+        //         console.log(res);
+        //     })
+        //     .catch(err => {
+        //         console.log(err);
+        //     })
+        // })
+
+        // var db = dis.database();
+        // db.getRelease(1)
+        //     .then(function(release){
+        //         return db.getArtist(release.artists[0].id);
+        //     })
+        //     .then(function(artist){
+        //         console.log(artist.name);
+        //     });
+
+        // db.search(q, function(err, data){
+        //     console.log(q);
+
+        // });
+
+        // return new Promise((resolve, reject)=>{
+        //     const options = {
+        //         'uri' : `https://api.discogs.com/database/search`,
+        //         'method' : 'GET',
+        //         'headers' : {
+        //             // 'Authorization' : `KakaoAK ${ak}`,
+        //             'Authorization' : `Discogs key=${discogsKey.key}, secret=${discogsKey.secret}`
+        //         },
+        //         'qs' : {
+        //             'q' : `${q}`,
+        //             'type' : `release`,
+        //             'key' : `${discogsKey.key}`,
+        //             'secret' : `${discogsKey.secret}`
+        //         }
+        //     };
+
+        //     request(options, async (err, result)=>{
+        //         const jsonResult = JSON.parse(result.body);
+        //         console.log(jsonResult);
+        //         if(err) {
+        //             console.log('request err : ' + err);
+        //             reject(err)
+        //         }
+        //         else resolve(jsonResult);
+        //     })
+        // })
+
+        return new Promise((resolve, reject) => {
+            const db = dis.database();
+            db.search({q: q, type: 'release'})
+            .then(res => {
+                const data = res.results;
+                let results = [];
+                Promise.all(data.map(async(elem) => {
+                    elem.artist = elem.title.split('-')[0].trim();
+                    elem.title = elem.title.split('-')[1].trim();
+                    results.push({
+                        'id': elem.id,
+                        'thumb': elem.thumb,
+                        'title': elem.title,
+                        'artist': elem.artist
+                    });
+                    results.map(vinylSearchDto);
+                }));
+                resolve(results);
+            })
+            .catch(err =>{
+                console.log('[VINYLSEARCH] err' + err);
+                reject(err);
+            });
+        })
+
+    }
+};
+
+module.exports = vinyl;

vinyla/modules/responseMessage.js

@@ -11,5 +11,8 @@ module.exports = {
 
     LOGIN_SUCCESS: "로그인 성공",
     LOGIN_FAIL: "로그인 실패",
-    NO_USER: "존재하지 않는 회원입니다."
+    NO_USER: "존재하지 않는 회원입니다.",
+
+    // Vinyl
+    DISCOGS_SEARCH_SUCCESS: "바이닐 검색 성공"
 }

vinyla/package.json

@@ -9,6 +9,7 @@
     "cookie-parser": "~1.4.4",
     "crypto": "^1.0.1",
     "debug": "~2.6.9",
+    "disconnect": "^1.2.2",
     "express": "~4.16.1",
     "http-errors": "~1.6.3",
     "jade": "~1.11.0",

vinyla/routes/index.js

@@ -7,5 +7,6 @@ var router = express.Router();
 // });
 
 router.use('/users', require('./users'));
+router.use('/vinyls', require('./vinyls'));
 
 module.exports = router;

vinyla/routes/vinyls/index.js

@@ -2,6 +2,7 @@ var express = require('express');
 var router = express.Router();
 const VinylController = require('../../controllers/vinyl');
 
-router.get('/home', VinylController.home);
+// router.get('/home', VinylController.home);
+router.get('/search', VinylController.search);
 
 module.exports = router;