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 (!fs
.existsSync(dir
)){
37 mkdirp(dir
, function(err
) {
39 console
.log('Error creating folder for uploads. All systems FAIL!');
46 filename: function (req
, file
, cb
) {
47 cb(null, Date
.now() + '_' + file
.fieldname
+ '_' + file
.originalname
);
50 // fieldNameSize: 100,
66 router
.get('/api/catalog', cors(), function(req
, res
) {
67 Composer
.get(req
).then(function(data
) {
68 utils
.sendSuccessResponse(data
, res
);
70 utils
.sendErrorResponse(error
, res
);
73 router
.delete('/api/catalog/:catalogType/:id', cors(), function(req
, res
) {
74 Composer
.delete(req
).then(function(response
) {
75 res
.status(response
.statusCode
);
78 res
.status(error
.statusCode
);
79 res
.send(error
.errorMessage
);
82 router
.post('/api/catalog/:catalogType', cors(), function(req
, res
) {
83 Composer
.create(req
).then(function(data
) {
86 res
.status(error
.statusCode
);
87 res
.send(error
.errorMessage
);
90 router
.put('/api/catalog/:catalogType/:id', cors(), function(req
, res
) {
91 Composer
.updateSave(req
).then(function(data
) {
94 res
.status(error
.statusCode
);
95 res
.send(error
.errorMessage
);
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
);
103 utils
.sendErrorResponse(error
, res
);
107 router
.get('/api/file-manager', cors(), function(req
, res
) {
108 FileManager
.get(req
).then(function(data
) {
109 utils
.sendSuccessResponse(data
, res
);
111 utils
.sendErrorResponse(error
, res
);
114 router
.get('/api/file-manager/jobs/:id', cors(), function(req
, res
) {
115 FileManager
.job(req
).then(function(data
) {
116 utils
.sendSuccessResponse(data
, res
);
118 utils
.sendErrorResponse(error
, res
);
121 router
.delete('/api/file-manager', cors(), function(req
, res
) {
122 FileManager
.get(req
).then(function(data
) {
123 utils
.sendSuccessResponse(data
, res
);
125 utils
.sendErrorResponse(error
, res
);
129 // Catalog operations via package manager
131 router
.post('/upload', cors(), upload
.single('package'), function (req
, res
, next
) {
132 PackageManager
.upload(req
).then(function(data
) {
133 utils
.sendSuccessResponse(data
, res
);
135 utils
.sendErrorResponse(error
, res
);
138 router
.use('/upload', cors(), function(req
, res
, next
) {
139 console
.log('Received request for ', req
.originalUrl
, ' from ', req
.ip
);
141 }, express
.static(constants
.BASE_PACKAGE_UPLOAD_DESTINATION
));
143 router
.post('/update', cors(), upload
.single('package'), function (req
, res
, next
) {
144 PackageManager
.update(req
).then(function(data
) {
145 utils
.sendSuccessResponse(data
, res
);
147 utils
.sendErrorResponse(error
, res
);
150 router
.use('/update', cors(), express
.static('upload/packages'));
152 router
.post('/api/package-export', cors(), function (req
, res
, next
) {
153 PackageManager
.export(req
).then(function(data
) {
154 utils
.sendSuccessResponse(data
, res
);
156 utils
.sendErrorResponse(error
, res
);
159 router
.post('/api/package-copy', cors(), function (req
, res
, next
) {
160 PackageManager
.copy(req
).then(function(data
) {
161 utils
.sendSuccessResponse(data
, res
);
163 utils
.sendErrorResponse(error
, res
);
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
);
170 utils
.sendErrorResponse(error
, res
);
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
);
177 utils
.sendErrorResponse(error
, res
);
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
);
184 utils
.sendErrorResponse(error
, res
);
188 module
.exports
= router
;