]>
git.immae.eu Git - perso/Immae/Projets/Nodejs/Surfer.git/blob - cli/actions.js
0c621f674784da462ab00247f60a9ebc8ea28ec7
4 exports
.logout
= logout
;
9 var superagent
= require('superagent'),
10 config
= require('./config.js'),
11 readlineSync
= require('readline-sync'),
12 safe
= require('safetydance'),
13 async
= require('async'),
15 request
= require('request'),
17 path
= require('path');
21 var API
= '/api/files/';
26 function checkConfig(options
) {
27 if (!options
.parent
.server
&& !config
.server()) {
28 console
.log('Run %s first, or provide %s', 'surfer login'.bold
, '--server <url>'.bold
);
32 if (options
.parent
.server
) {
33 var tmp
= url
.parse(options
.parent
.server
);
34 if (!tmp
.slashes
) tmp
= url
.parse('https://' + options
.parent
.server
);
35 gServer
= tmp
.protocol
+ '//' + tmp
.host
;
37 gServer
= config
.server();
40 if (!options
.parent
.token
&& !config
.accessToken()) {
41 console
.log('Run %s first or provide %s', 'surfer login'.bold
, '--token <access token>'.bold
);
45 gQuery
= { access_token: options
.parent
.token
|| config
.accessToken() };
47 console
.error('Using server %s', gServer
.cyan
);
50 function collectFiles(filesOrFolders
, options
) {
53 filesOrFolders
.forEach(function (filePath
) {
54 var baseName
= path
.basename(filePath
);
55 if (!options
.all
&& baseName
[0] === '.' && baseName
.length
> 1) return;
57 var stat
= fs
.statSync(filePath
);
61 } else if (stat
.isDirectory()) {
62 var files
= fs
.readdirSync(filePath
).map(function (file
) { return path
.join(filePath
, file
); });
63 tmp
= tmp
.concat(collectFiles(files
, options
));
65 console
.log('Skipping %s', filePath
.cyan
);
72 function login(uri
, options
) {
73 var tmp
= url
.parse(uri
);
74 if (!tmp
.slashes
) tmp
= url
.parse('https://' + uri
);
76 var server
= tmp
.protocol
+ '//' + tmp
.host
;
78 console
.log('Using server', server
.cyan
);
80 var username
= options
.username
|| readlineSync
.question('Username: ');
81 var password
= options
.password
|| readlineSync
.question('Password: ', { hideEchoBack: true, mask: '' });
83 if (!username
|| !password
) process
.exit(1);
85 superagent
.post(server
+ '/api/login').send({ username: username
, password: password
}).end(function (error
, result
) {
86 if (error
&& error
.code
=== 'ENOTFOUND') {
87 console
.log('Server %s not found.'.red
, server
.bold
);
90 if (error
&& error
.code
) {
91 console
.log('Failed to connect to server %s'.red
, server
.bold
, error
.code
);
94 if (result
.status
!== 201) {
95 console
.log('Login failed.\n'.red
);
97 // remove the password to avoid a login loop
98 delete options
.password
;
100 return login(uri
, options
);
103 // TODO remove at some point, this is just to clear the previous old version values
104 config
.set('username', '');
105 config
.set('password', '');
107 config
.set('server', server
);
108 config
.set('accessToken', result
.body
.accessToken
);
110 console
.log('Login successful'.green
);
115 if (!config
.accessToken()) return console
.log('Done'.green
);
117 superagent
.post(gServer
+ '/api/logout').query({ access_token: config
.accessToken() }).end(function (error
, result
) {
118 if (result
&& result
.statusCode
!== 200) console
.log('Failed to logout: ' + result
.statusCode
);
119 if (error
) console
.log(error
);
121 // TODO remove at some point, this is just to clear the previous old version values
122 config
.set('username', '');
123 config
.set('password', '');
124 config
.set('server', '');
125 config
.set('accessToken', '');
127 console
.log('Done'.green
);
131 function put(filePath
, otherFilePaths
, options
) {
132 checkConfig(options
);
134 var destination
= '';
136 // take the last argument as destination
137 if (otherFilePaths
.length
> 0) {
138 destination
= otherFilePaths
.pop();
139 if (otherFilePaths
.length
> 0 && destination
[destination
.length
-1] !== '/') destination
+= '/';
142 var files
= collectFiles([ filePath
].concat(otherFilePaths
), options
);
144 async
.eachSeries(files
, function (file
, callback
) {
145 var relativeFilePath
;
147 if (path
.isAbsolute(file
)) {
148 relativeFilePath
= path
.basename(file
);
149 } else if (path
.resolve(file
).indexOf(process
.cwd()) === 0) { // relative to current dir
150 relativeFilePath
= path
.resolve(file
).slice(process
.cwd().length
+ 1);
151 } else { // relative but somewhere else
152 relativeFilePath
= path
.basename(file
);
155 var destinationPath
= (destination
? '/' + destination : '') + '/' + relativeFilePath
;
156 console
.log('Uploading file %s -> %s', relativeFilePath
.cyan
, destinationPath
.cyan
);
158 superagent
.post(gServer
+ API
+ destinationPath
).query(gQuery
).attach('file', file
).end(function (error
, result
) {
159 if (result
&& result
.statusCode
=== 403) return callback(new Error('Upload destination ' + destinationPath
+ ' not allowed'));
160 if (result
&& result
.statusCode
!== 201) return callback(new Error('Error uploading file: ' + result
.statusCode
));
161 if (error
) return callback(error
);
163 console
.log('Uploaded to ' + gServer
+ destinationPath
);
167 }, function (error
) {
169 console
.log('Failed to put file.', error
.message
.red
);
177 function get(filePath
, options
) {
178 checkConfig(options
);
180 // if no argument provided, fetch root
181 filePath
= filePath
|| '/';
183 request
.get(gServer
+ API
+ filePath
, { qs: gQuery
}, function (error
, result
, body
) {
184 if (result
&& result
.statusCode
=== 401) return console
.log('Login failed');
185 if (result
&& result
.statusCode
=== 404) return console
.log('No such file or directory %s', filePath
.yellow
);
186 if (error
) return console
.error(error
);
188 // 222 indicates directory listing
189 if (result
.statusCode
=== 222) {
190 var files
= safe
.JSON
.parse(body
);
191 if (!files
|| files
.entries
.length
=== 0) {
192 console
.log('No files on the server. Use %s to upload some.', 'surfer put <file>'.yellow
);
194 console
.log('Entries:');
195 files
.entries
.forEach(function (entry
) {
196 console
.log('\t %s', entry
.isDirectory
? entry
.filePath
+ '/' : entry
.filePath
);
200 process
.stdout
.write(body
);
203 // var req = superagent.get(gServer + API + filePath);
204 // req.query(gQuery);
205 // req.end(function (error, result) {
206 // if (error && error.status === 401) return console.log('Login failed');
207 // if (error && error.status === 404) return console.log('No such file or directory');
208 // if (error) return console.log('Failed', result ? result.body : error);
210 // if (result.body && result.body.entries) {
211 // console.log('Files:');
212 // result.body.entries.forEach(function (entry) {
213 // console.log('\t %s', entry);
216 // req.pipe(process.stdout);
221 function del(filePath
, options
) {
222 checkConfig(options
);
224 var query
= safe
.JSON
.parse(safe
.JSON
.stringify(gQuery
));
225 query
.recursive
= options
.recursive
;
226 query
.dryRun
= options
.dryRun
;
228 var relativeFilePath
= path
.resolve(filePath
).slice(process
.cwd().length
+ 1);
229 superagent
.del(gServer
+ API
+ relativeFilePath
).query(query
).end(function (error
, result
) {
230 if (error
&& error
.status
=== 401) return console
.log('Login failed'.red
);
231 if (error
&& error
.status
=== 404) return console
.log('No such file or directory');
232 if (error
&& error
.status
=== 403) return console
.log('Failed. Target is a directory. Use %s to delete directories.', '--recursive'.yellow
);
233 if (error
) return console
.log('Failed', result
? result
.body : error
);
235 if (options
.dryRun
) {
236 console
.log('This would remove %s files:', result
.body
.entries
.length
);
237 result
.body
.entries
.forEach(function (entry
) {
238 console
.log('\t %s', entry
);
241 console
.log('Success. Removed %s files.', result
.body
.entries
.length
);