1
|
|
|
|
2
|
|
|
var fs = require('fs-extra');
|
3
|
|
|
var request = require('request');
|
4
|
|
|
var express = require('express');
|
5
|
|
|
var extend = require('extend');
|
6
|
|
|
var AdmZip = require('adm-zip');
|
7
|
|
|
var path = require('path');
|
8
|
|
|
|
9
|
|
|
// ------------------------------------------
|
10
|
|
|
// CONSTRUCTOR
|
11
|
|
|
// ------------------------------------------
|
12
|
|
|
|
13
|
|
|
var TMP = '';
|
14
|
|
|
var init = function(){
|
15
|
|
|
info('Starting Marketplace ...');
|
16
|
|
|
|
17
|
|
|
// Create temp plugin directory
|
18
|
|
|
TMP = SARAH.ConfigManager.PLUGIN+'/tmp';
|
|
|
|
|
19
|
|
|
if (!fs.existsSync(TMP)){ fs.mkdirSync(TMP); }
|
20
|
|
|
|
21
|
|
|
// Refresh remote plugins
|
22
|
|
|
refresh();
|
23
|
|
|
|
24
|
|
|
return Marketplace;
|
25
|
|
|
}
|
26
|
|
|
|
27
|
|
|
// ------------------------------------------
|
28
|
|
|
// MARKETPLACE
|
29
|
|
|
// ------------------------------------------
|
30
|
|
|
|
31
|
|
|
var MARKETPLACE = 'http://plugins.sarah.encausse.net';
|
32
|
|
|
|
33
|
|
|
var cache = {};
|
34
|
|
|
var refresh = function(){
|
35
|
|
|
request({
|
36
|
|
|
'uri' : MARKETPLACE,
|
37
|
|
|
'json' : true,
|
38
|
|
|
'headers': {'user-agent': SARAH.USERAGENT}
|
|
|
|
|
39
|
|
|
},
|
40
|
|
|
function (err, response, json){
|
41
|
|
|
if (err || response.statusCode != 200) {
|
42
|
|
|
return warn("Can't retrieve remote plugins");
|
43
|
|
|
}
|
44
|
|
|
cache = json;
|
|
|
|
|
45
|
|
|
});
|
46
|
|
|
}
|
47
|
|
|
|
48
|
|
|
|
49
|
|
|
// ------------------------------------------
|
50
|
|
|
// SEARCH
|
51
|
|
|
// ------------------------------------------
|
52
|
|
|
|
53
|
|
|
var filter = function(name, plugin, search){
|
54
|
|
|
if (!search) return true;
|
|
|
|
|
55
|
|
|
search = search.toLowerCase();
|
56
|
|
|
|
57
|
|
|
for (var key in plugin){
|
|
|
|
|
58
|
|
|
if (name.toLowerCase().indexOf(search) >= 0) return true;
|
|
|
|
|
59
|
|
|
if(plugin[key] && plugin[key].toLowerCase().indexOf(search) >= 0) return true;
|
|
|
|
|
60
|
|
|
}
|
61
|
|
|
return false;
|
62
|
|
|
}
|
63
|
|
|
|
64
|
|
|
// ------------------------------------------
|
65
|
|
|
// INSTALL
|
66
|
|
|
// ------------------------------------------
|
67
|
|
|
|
68
|
|
|
|
69
|
|
|
var install = function(name, callback){
|
70
|
|
|
var market = cache[name];
|
71
|
|
|
if (!market || !market.dl){ return callback(); }
|
72
|
|
|
installURL(market.dl, SARAH.ConfigManager.PLUGIN+'/'+name, callback);
|
|
|
|
|
73
|
|
|
}
|
74
|
|
|
|
75
|
|
|
var installURL = function(url, path, callback){
|
76
|
|
|
|
77
|
|
|
// Delete previous zip if exists
|
78
|
|
|
var archive = TMP + '/' + 'tmp.zip';
|
79
|
|
|
var drop = TMP + '/' + 'archive';
|
80
|
|
|
if ( fs.existsSync(archive)){ fs.unlinkSync(archive); }
|
81
|
|
|
if ( fs.existsSync(drop)) { fs.removeSync(drop); }
|
82
|
|
|
if (!fs.existsSync(drop)) { fs.mkdirSync(drop); }
|
83
|
|
|
info('Downloading %s to store...', url, drop, path);
|
84
|
|
|
|
85
|
|
|
// Download file
|
86
|
|
|
request({
|
87
|
|
|
'uri' : url,
|
88
|
|
|
'headers': {'user-agent': SARAH.USERAGENT}
|
|
|
|
|
89
|
|
|
},
|
90
|
|
|
function (err, response, json){
|
|
|
|
|
91
|
|
|
if (err || response.statusCode != 200) {
|
|
|
|
|
92
|
|
|
warn("Can't download remote plugin", url, err);
|
93
|
|
|
return callback();
|
94
|
|
|
}
|
95
|
|
|
}).pipe(fs.createWriteStream(archive)).on('close', function(){
|
96
|
|
|
|
97
|
|
|
var zip = new AdmZip(archive);
|
98
|
|
|
zip.extractAllTo(drop, true);
|
99
|
|
|
|
100
|
|
|
// Recursive function
|
101
|
|
|
var copy = function(root){
|
102
|
|
|
var files = fs.readdirSync(root);
|
103
|
|
|
if (files.length != 1){
|
104
|
|
|
fs.rename(root, path, function(){});
|
105
|
|
|
} else {
|
106
|
|
|
root += '/' + files[0];
|
107
|
|
|
if (fs.statSync(root).isDirectory()){ copy(root); }
|
108
|
|
|
}
|
109
|
|
|
}
|
110
|
|
|
|
111
|
|
|
copy(drop); // Perform copy
|
112
|
|
|
fs.removeSync(drop); // Clean remaining stuff
|
113
|
|
|
callback();
|
114
|
|
|
|
115
|
|
|
});
|
116
|
|
|
}
|
117
|
|
|
|
118
|
|
|
// ------------------------------------------
|
119
|
|
|
// GITHUB
|
120
|
|
|
// ------------------------------------------
|
121
|
|
|
|
122
|
|
|
var TEMPLATE = 'http://template.sarah.encausse.net';
|
123
|
|
|
var clone = function(body, callback){
|
124
|
|
|
if (!body.name) { return callback('store.github.msg.name'); }
|
125
|
|
|
if (!body.url) { return callback('store.github.msg.url'); }
|
126
|
|
|
|
127
|
|
|
var name = body.name.toLowerCase().replace(' ', '_');
|
128
|
|
|
var path = SARAH.ConfigManager.PLUGIN+'/'+name;
|
|
|
|
|
129
|
|
|
if (fs.existsSync(path)){ return callback('store.msg.exists'); }
|
130
|
|
|
|
131
|
|
|
gitClone(body.url, path, callback);
|
|
|
|
|
132
|
|
|
}
|
133
|
|
|
|
134
|
|
|
var create = function(body, callback){
|
135
|
|
|
if (!body.name) { return callback('store.new.msg.name'); }
|
136
|
|
|
|
137
|
|
|
var name = body.name.toLowerCase().replace(' ', '_');
|
138
|
|
|
var path = SARAH.ConfigManager.PLUGIN+'/'+body.name;
|
|
|
|
|
139
|
|
|
if (fs.existsSync(path)){ return callback('store.msg.exists'); }
|
140
|
|
|
|
141
|
|
|
gitClone(TEMPLATE, path, function(){
|
142
|
|
|
rename(path, {
|
143
|
|
|
"template": name,
|
144
|
|
|
"template_description": body.description
|
145
|
|
|
});
|
146
|
|
|
callback('store.msg.ok');
|
147
|
|
|
});
|
|
|
|
|
148
|
|
|
}
|
149
|
|
|
|
150
|
|
|
/*
|
151
|
|
|
var Git = require("nodegit");
|
152
|
|
|
var gitClone = function(giturl, path, callback){
|
153
|
|
|
info('Cloning repository %s at %s', giturl, path);
|
154
|
|
|
Git.Clone(giturl, path).then(function(repository) {
|
155
|
|
|
callback('store.msg.ok');
|
156
|
|
|
});
|
157
|
|
|
}*/
|
158
|
|
|
|
159
|
|
|
var gitClone = function(giturl, path, callback){
|
160
|
|
|
var url = giturl.replace('.git', '/archive/master.zip');
|
161
|
|
|
installURL(url, path, callback);
|
162
|
|
|
}
|
163
|
|
|
|
164
|
|
|
var rename = function(file, matches){
|
165
|
|
|
|
166
|
|
|
// Directory
|
167
|
|
|
if (fs.statSync(file).isDirectory()){
|
168
|
|
|
var files = fs.readdirSync(file);
|
169
|
|
|
for(var i in files){
|
|
|
|
|
170
|
|
|
rename(file+'/'+files[i], matches);
|
171
|
|
|
}
|
172
|
|
|
return;
|
173
|
|
|
}
|
174
|
|
|
|
175
|
|
|
// Replace filename
|
176
|
|
|
var name = path.basename(file);
|
177
|
|
|
if (name.indexOf('template') >= 0){
|
178
|
|
|
var dest = path.dirname(file) + '/' + name.replace(/template/g, matches.template);
|
179
|
|
|
fs.renameSync(file, dest);
|
180
|
|
|
file = dest;
|
181
|
|
|
}
|
182
|
|
|
|
183
|
|
|
// Clean path
|
184
|
|
|
file = path.normalize(file);
|
185
|
|
|
|
186
|
|
|
var ext = path.extname(file);
|
187
|
|
|
if (!(ext == '.html' || ext == '.ejs' || ext == '.js' || ext == '.xml' || ext == '.prop' || ext == '.less' || ext == '.md')){ return; }
|
188
|
|
|
|
189
|
|
|
// Search and replace
|
190
|
|
|
var data = fs.readFileSync(file, 'utf8');
|
191
|
|
|
data = data.replace(/template_description/g, matches.template_description || '');
|
192
|
|
|
data = data.replace(/template_version/g, matches.template_version || '');
|
193
|
|
|
data = data.replace(/template/g, matches.template);
|
194
|
|
|
data = data.replace(/Template/g, matches.template.capitalize());
|
195
|
|
|
fs.writeFile(file, data, 'utf8');
|
196
|
|
|
}
|
197
|
|
|
|
198
|
|
|
|
199
|
|
|
// ------------------------------------------
|
200
|
|
|
// TEST
|
201
|
|
|
// ------------------------------------------
|
202
|
|
|
|
203
|
|
|
var getMostRecentCommit = function(repository) {
|
204
|
|
|
return repository.getBranchCommit("master");
|
205
|
|
|
};
|
206
|
|
|
|
207
|
|
|
var getCommitMessage = function(commit) {
|
208
|
|
|
return commit.message();
|
209
|
|
|
};
|
210
|
|
|
|
211
|
|
|
var getCommits = function(name, callback){
|
212
|
|
|
var path = SARAH.ConfigManager.PLUGIN+'/'+name;
|
|
|
|
|
213
|
|
|
var err = function(){ callback(); }
|
214
|
|
|
|
215
|
|
|
Git.Repository.open(path)
|
|
|
|
|
216
|
|
|
.then(getMostRecentCommit, err)
|
217
|
|
|
.then(getCommitMessage, err)
|
218
|
|
|
.then(function(message) { callback(message); }, err);
|
219
|
|
|
}
|
220
|
|
|
|
221
|
|
|
// ------------------------------------------
|
222
|
|
|
// ROUTER
|
223
|
|
|
// ------------------------------------------
|
224
|
|
|
|
225
|
|
|
var Router = express.Router();
|
226
|
|
|
|
227
|
|
|
Router.get('/portal/store', function(req, res, next) {
|
|
|
|
|
228
|
|
|
res.locals.sidebar.nav[0].active = true;
|
229
|
|
|
res.render('store/store.ejs', { marketplace : cache });
|
230
|
|
|
});
|
231
|
|
|
|
232
|
|
|
Router.post('/portal/store', function(req, res, next) {
|
|
|
|
|
233
|
|
|
|
234
|
|
|
var callback = function(msg){
|
235
|
|
|
var url = '/portal/store';
|
236
|
|
|
url += msg ? '?msg='+msg : '';
|
237
|
|
|
res.redirect(url);
|
238
|
|
|
}
|
239
|
|
|
|
240
|
|
|
var name = req.body.opInstall;
|
241
|
|
|
if (name){ install(name, callback); }
|
242
|
|
|
|
243
|
|
|
var name = req.body.opDelete;
|
|
|
|
|
244
|
|
|
if (name){ SARAH.PluginManager.remove(name, callback); }
|
|
|
|
|
245
|
|
|
|
246
|
|
|
var op = req.body.opCreate;
|
247
|
|
|
if (op){ create(req.body, callback); }
|
248
|
|
|
|
249
|
|
|
var op = req.body.opGitClone;
|
|
|
|
|
250
|
|
|
if (op){ clone(req.body, callback); }
|
251
|
|
|
|
252
|
|
|
});
|
253
|
|
|
|
254
|
|
|
// ------------------------------------------
|
255
|
|
|
// PUBLIC
|
256
|
|
|
// ------------------------------------------
|
257
|
|
|
|
258
|
|
|
var Marketplace = {
|
259
|
|
|
'init' : init,
|
260
|
|
|
'filter' : filter,
|
261
|
|
|
'getCommits' : getCommits,
|
262
|
|
|
'Router' : Router
|
263
|
|
|
}
|
264
|
|
|
|
265
|
|
|
// Exports Manager
|
266
|
|
|
exports.init = Marketplace.init;
|
267
|
|
|
|
268
|
|
|
|
This checks looks for references to variables that have not been declared. This is most likey a typographical error or a variable has been renamed.
To learn more about declaring variables in Javascript, see the MDN.