3 * Copyright 2016 RIFT.IO Inc
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
9 * http://www.apache.org/licenses/LICENSE-2.0
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.
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');
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'] + '/';
39 if (!fs
.existsSync(dir
)){
40 mkdirp(dir
, function(err
) {
42 console
.log('Error creating folder for uploads. All systems FAIL!');
51 filename: function (req
, file
, cb
) {
52 if (req
.query
['package_id']) {
53 cb(null, file
.originalname
);
55 cb(null, Date
.now() + '_' + file
.fieldname
+ '_' + file
.originalname
);
59 // fieldNameSize: 100,
75 router
.get('/api/catalog', cors(), function(req
, res
) {
76 Composer
.get(req
).then(function(data
) {
77 utils
.sendSuccessResponse(data
, res
);
79 utils
.sendErrorResponse(error
, res
);
82 router
.delete('/api/catalog/:catalogType/:id', cors(), function(req
, res
) {
83 Composer
.delete(req
).then(function(response
) {
84 res
.status(response
.statusCode
);
87 res
.status(error
.statusCode
);
88 res
.send(error
.errorMessage
);
91 router
.post('/api/catalog/:catalogType', cors(), function(req
, res
) {
92 Composer
.create(req
).then(function(data
) {
95 res
.status(error
.statusCode
);
96 res
.send(error
.errorMessage
);
99 router
.put('/api/catalog/:catalogType/:id', cors(), function(req
, res
) {
100 Composer
.updateSave(req
).then(function(data
) {
103 res
.status(error
.statusCode
);
104 res
.send(error
.errorMessage
);
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
);
112 utils
.sendErrorResponse(error
, res
);
116 router
.get('/api/file-manager', cors(), function(req
, res
) {
117 FileManager
.get(req
).then(function(data
) {
118 utils
.sendSuccessResponse(data
, res
);
120 utils
.sendErrorResponse(error
, res
);
123 router
.get('/api/file-manager/jobs/:id', cors(), function(req
, res
) {
124 FileManager
.job(req
).then(function(data
) {
125 utils
.sendSuccessResponse(data
, res
);
127 utils
.sendErrorResponse(error
, res
);
130 router
.delete('/api/file-manager', cors(), function(req
, res
) {
131 FileManager
.get(req
).then(function(data
) {
132 utils
.sendSuccessResponse(data
, res
);
134 utils
.sendErrorResponse(error
, res
);
138 // Catalog operations via package manager
140 router
.post('/upload', cors(), upload
.single('package'), function (req
, res
, next
) {
141 PackageManager
.upload(req
).then(function(data
) {
142 utils
.sendSuccessResponse(data
, res
);
144 utils
.sendErrorResponse(error
, res
);
147 router
.use('/upload', cors(), express
.static('upload/packages'));
149 router
.post('/update', cors(), upload
.single('package'), function (req
, res
, next
) {
150 PackageManager
.update(req
).then(function(data
) {
151 utils
.sendSuccessResponse(data
, res
);
153 utils
.sendErrorResponse(error
, res
);
156 router
.use('/update', cors(), express
.static('upload/packages'));
158 router
.post('/api/package-export', cors(), function (req
, res
, next
) {
159 PackageManager
.export(req
).then(function(data
) {
160 utils
.sendSuccessResponse(data
, res
);
162 utils
.sendErrorResponse(error
, res
);
165 router
.post('/api/package-copy', cors(), function (req
, res
, next
) {
166 PackageManager
.copy(req
).then(function(data
) {
167 utils
.sendSuccessResponse(data
, res
);
169 utils
.sendErrorResponse(error
, res
);
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
);
176 utils
.sendErrorResponse(error
, res
);
180 module
.exports
= router
;