skyquake/plugins/composer/routes.js

   1 /*
   2  *
   3  *   Copyright 2016 RIFT.IO Inc
   4  *
   5  *   Licensed under the Apache License, Version 2.0 (the "License");
   6  *   you may not use this file except in compliance with the License.
   7  *   You may obtain a copy of the License at
   8  *
   9  *       http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  *   Unless required by applicable law or agreed to in writing, software
  12  *   distributed under the License is distributed on an "AS IS" BASIS,
  13  *   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  *   See the License for the specific language governing permissions and
  15  *   limitations under the License.
  16  *
  17  */
  18 var express = require('express');
  19 var router = express.Router();
  20 var cors = require('cors');
  21 var utils = require('../../framework/core/api_utils/utils.js')
  22 var constants = require('../../framework/core/api_utils/constants.js');
  23 var C = require('./api/composer.js');
  24 var Composer = C.Composer;
  25 var FileManager = C.FileManager;
  26 var PackageManager = C.PackageManager;
  27 var multer = require('multer');
  28 var fs = require('fs');
  29 var path = require('path');
  30 var mkdirp = require('mkdirp');
  31
  32 var storage = multer.diskStorage({
  33     // destination: 'upload/packages/',
  34     destination: function(req, file, cb) {
  35         var dir = constants.BASE_PACKAGE_UPLOAD_DESTINATION;
  36         if (!fs.existsSync(dir)){
  37             mkdirp(dir, function(err) {
  38                 if (err) {
  39                     console.log('Error creating folder for uploads. All systems FAIL!');
  40                     throw err;
  41                 }
  42             });
  43         }
  44         cb(null, dir);
  45     },
  46     filename: function (req, file, cb) {
  47         cb(null, Date.now() + '_' + file.fieldname + '_' + file.originalname);
  48     },
  49     // limits: {
  50     //     fieldNameSize: 100,
  51     //     fieldSize: 10000,
  52     //     fields: Infinity,
  53     //     fileSize: 10000,
  54     //     files: Infinity
  55     //     parts: Infinity
  56     //     headerPairs: 2000
  57     // }
  58 });
  59
  60
  61 var upload = multer({
  62     storage: storage
  63 });
  64
  65
  66 router.get('/api/catalog', cors(), function(req, res) {
  67     Composer.get(req).then(function(data) {
  68         utils.sendSuccessResponse(data, res);
  69     }, function(error) {
  70         utils.sendErrorResponse(error, res);
  71     });
  72 });
  73 router.delete('/api/catalog/:catalogType/:id', cors(), function(req, res) {
  74     Composer.delete(req).then(function(response) {
  75         res.status(response.statusCode);
  76         res.send({});
  77     }, function(error) {
  78         res.status(error.statusCode);
  79         res.send(error.errorMessage);
  80     });
  81 });
  82 router.post('/api/catalog/:catalogType', cors(), function(req, res) {
  83     Composer.create(req).then(function(data) {
  84         res.send(data);
  85     }, function(error) {
  86         res.status(error.statusCode);
  87         res.send(error.errorMessage);
  88     });
  89 });
  90 router.put('/api/catalog/:catalogType/:id', cors(), function(req, res) {
  91     Composer.updateSave(req).then(function(data) {
  92         res.send(data);
  93     }, function(error) {
  94         res.status(error.statusCode);
  95         res.send(error.errorMessage);
  96     });
  97 });
  98
  99 router.post('/api/file-manager', cors(), upload.single('file'), function (req, res, next) {
 100     FileManager.addFile(req).then(function(data) {
 101         utils.sendSuccessResponse(data, res);
 102     }, function(error) {
 103         utils.sendErrorResponse(error, res);
 104     });
 105 });
 106
 107 router.get('/api/file-manager', cors(), function(req, res) {
 108     FileManager.get(req).then(function(data) {
 109         utils.sendSuccessResponse(data, res);
 110     }, function(error) {
 111         utils.sendErrorResponse(error, res);
 112     });
 113 })
 114 router.get('/api/file-manager/jobs/:id', cors(), function(req, res) {
 115     FileManager.job(req).then(function(data) {
 116         utils.sendSuccessResponse(data, res);
 117     }, function(error) {
 118         utils.sendErrorResponse(error, res);
 119     });
 120 });
 121 router.delete('/api/file-manager', cors(), function(req, res) {
 122     FileManager.get(req).then(function(data) {
 123         utils.sendSuccessResponse(data, res);
 124     }, function(error) {
 125         utils.sendErrorResponse(error, res);
 126     });
 127 });
 128
 129 // Catalog operations via package manager
 130
 131 router.post('/upload', cors(), upload.single('package'), function (req, res, next) {
 132     PackageManager.upload(req).then(function(data) {
 133         utils.sendSuccessResponse(data, res);
 134     }, function(error) {
 135         utils.sendErrorResponse(error, res);
 136     });
 137 });
 138 router.use('/upload', cors(), function(req, res, next) {
 139     console.log('Received request for ', req.originalUrl, ' from ', req.ip);
 140     next();
 141 }, express.static(constants.BASE_PACKAGE_UPLOAD_DESTINATION));
 142
 143 router.post('/update', cors(), upload.single('package'), function (req, res, next) {
 144     PackageManager.update(req).then(function(data) {
 145         utils.sendSuccessResponse(data, res);
 146     }, function(error) {
 147         utils.sendErrorResponse(error, res);
 148     });
 149 });
 150 router.use('/update', cors(), express.static('upload/packages'));
 151
 152 router.post('/api/package-export', cors(), function (req, res, next) {
 153     PackageManager.export(req).then(function(data) {
 154         utils.sendSuccessResponse(data, res);
 155     }, function(error) {
 156         utils.sendErrorResponse(error, res);
 157     });
 158 });
 159 router.post('/api/package-copy', cors(), function (req, res, next) {
 160     PackageManager.copy(req).then(function(data) {
 161         utils.sendSuccessResponse(data, res);
 162     }, function(error) {
 163         utils.sendErrorResponse(error, res);
 164     });
 165 });
 166 router.get('/api/package-copy/jobs/:id', cors(), function (req, res, next) {
 167     PackageManager.getCopyJobStatus(req).then(function(data) {
 168         utils.sendSuccessResponse(data, res);
 169     }, function(error) {
 170         utils.sendErrorResponse(error, res);
 171     });
 172 });
 173 router.get('/api/package-import/jobs/:id', cors(), function (req, res, next) {
 174     PackageManager.getImportJobStatus(req).then(function(data) {
 175         utils.sendSuccessResponse(data, res);
 176     }, function(error) {
 177         utils.sendErrorResponse(error, res);
 178     });
 179 });
 180 router.get('/api/package-update/jobs/:id', cors(), function (req, res, next) {
 181     PackageManager.getUpdateJobStatus(req).then(function(data) {
 182         utils.sendSuccessResponse(data, res);
 183     }, function(error) {
 184         utils.sendErrorResponse(error, res);
 185     });
 186 });
 187
 188 module.exports = router;