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 (req.query['package_id']) {
  37             dir += req.query['package_id'] + '/';
  38         }
  39         if (!fs.existsSync(dir)){
  40             mkdirp(dir, function(err) {
  41                 if (err) {
  42                     console.log('Error creating folder for uploads. All systems FAIL!');
  43                     throw err;
  44                 }
  45                 cb(null, dir);
  46             });
  47         } else {
  48             cb(null, dir);
  49         }
  50     },
  51     filename: function (req, file, cb) {
  52         if (req.query['package_id']) {
  53             cb(null, file.originalname);
  54         } else  {
  55             cb(null, Date.now() + '_' + file.fieldname + '_' + file.originalname);
  56         }
  57     },
  58     // limits: {
  59     //     fieldNameSize: 100,
  60     //     fieldSize: 10000,
  61     //     fields: Infinity,
  62     //     fileSize: 10000,
  63     //     files: Infinity
  64     //     parts: Infinity
  65     //     headerPairs: 2000
  66     // }
  67 });
  68
  69
  70 var upload = multer({
  71     storage: storage
  72 });
  73
  74
  75 router.get('/api/catalog', cors(), function(req, res) {
  76     Composer.get(req).then(function(data) {
  77         utils.sendSuccessResponse(data, res);
  78     }, function(error) {
  79         utils.sendErrorResponse(error, res);
  80     });
  81 });
  82 router.delete('/api/catalog/:catalogType/:id', cors(), function(req, res) {
  83     Composer.delete(req).then(function(response) {
  84         res.status(response.statusCode);
  85         res.send({});
  86     }, function(error) {
  87         res.status(error.statusCode);
  88         res.send(error.errorMessage);
  89     });
  90 });
  91 router.post('/api/catalog/:catalogType', cors(), function(req, res) {
  92     Composer.create(req).then(function(data) {
  93         res.send(data);
  94     }, function(error) {
  95         res.status(error.statusCode);
  96         res.send(error.errorMessage);
  97     });
  98 });
  99 router.put('/api/catalog/:catalogType/:id', cors(), function(req, res) {
 100     Composer.updateSave(req).then(function(data) {
 101         res.send(data);
 102     }, function(error) {
 103         res.status(error.statusCode);
 104         res.send(error.errorMessage);
 105     });
 106 });
 107
 108 router.post('/api/file-manager', cors(), upload.single('package'), function (req, res, next) {
 109     FileManager.addFile(req).then(function(data) {
 110         utils.sendSuccessResponse(data, res);
 111     }, function(error) {
 112         utils.sendErrorResponse(error, res);
 113     });
 114 });
 115
 116 router.get('/api/file-manager', cors(), function(req, res) {
 117     FileManager.get(req).then(function(data) {
 118         utils.sendSuccessResponse(data, res);
 119     }, function(error) {
 120         utils.sendErrorResponse(error, res);
 121     });
 122 })
 123 router.get('/api/file-manager/jobs/:id', cors(), function(req, res) {
 124     FileManager.job(req).then(function(data) {
 125         utils.sendSuccessResponse(data, res);
 126     }, function(error) {
 127         utils.sendErrorResponse(error, res);
 128     });
 129 });
 130 router.delete('/api/file-manager', cors(), function(req, res) {
 131     FileManager.get(req).then(function(data) {
 132         utils.sendSuccessResponse(data, res);
 133     }, function(error) {
 134         utils.sendErrorResponse(error, res);
 135     });
 136 });
 137
 138 // Catalog operations via package manager
 139
 140 router.post('/upload', cors(), upload.single('package'), function (req, res, next) {
 141     PackageManager.upload(req).then(function(data) {
 142         utils.sendSuccessResponse(data, res);
 143     }, function(error) {
 144         utils.sendErrorResponse(error, res);
 145     });
 146 });
 147 router.use('/upload', cors(), express.static('upload/packages'));
 148
 149 router.post('/update', cors(), upload.single('package'), function (req, res, next) {
 150     PackageManager.update(req).then(function(data) {
 151         utils.sendSuccessResponse(data, res);
 152     }, function(error) {
 153         utils.sendErrorResponse(error, res);
 154     });
 155 });
 156 router.use('/update', cors(), express.static('upload/packages'));
 157
 158 router.post('/api/package-export', cors(), function (req, res, next) {
 159     PackageManager.export(req).then(function(data) {
 160         utils.sendSuccessResponse(data, res);
 161     }, function(error) {
 162         utils.sendErrorResponse(error, res);
 163     });
 164 });
 165 router.post('/api/package-copy', cors(), function (req, res, next) {
 166     PackageManager.copy(req).then(function(data) {
 167         utils.sendSuccessResponse(data, res);
 168     }, function(error) {
 169         utils.sendErrorResponse(error, res);
 170     });
 171 });
 172 router.get('/api/package-manager/jobs/:id', cors(), function (req, res, next) {
 173     PackageManager.getJobStatus(req).then(function(data) {
 174         utils.sendSuccessResponse(data, res);
 175     }, function(error) {
 176         utils.sendErrorResponse(error, res);
 177     });
 178 });
 179
 180 module.exports = router;