143 lines
		
	
	
		
			3.8 KiB
		
	
	
	
		
			JavaScript
		
	
	
	
	
	
			
		
		
	
	
			143 lines
		
	
	
		
			3.8 KiB
		
	
	
	
		
			JavaScript
		
	
	
	
	
	
| 'use strict';
 | |
| 
 | |
| require('require-yaml');
 | |
| 
 | |
| var connect     = require('connect')
 | |
|   //, PromiseA  = require('bluebird').Promise
 | |
|   , query       = require('connect-query')
 | |
|   , bodyParser  = require('body-parser')
 | |
|   , serveStatic = require('serve-static')
 | |
|   , send        = require('connect-send-json')
 | |
| 
 | |
|   , app         = connect()
 | |
|   , fsapi       = require('./lib/fsapi')
 | |
|   , walk        = require('./lib/fsapi').walk
 | |
|   , getfs       = require('./lib/fsapi').getfs
 | |
|   , putfs       = require('./lib/fsapi').putfs
 | |
| 
 | |
|   , config      = require('./config.yml')
 | |
|   , path        = require('path')
 | |
|   , blogdir     = path.resolve(config.blogdir || __dirname)
 | |
|   ;
 | |
| 
 | |
| 
 | |
| app
 | |
|   .use(send.json())
 | |
|   .use(query())
 | |
|   .use(bodyParser.json({ limit: 10 * 1024 * 1024 })) // 10mb
 | |
|   .use(require('compression')())
 | |
|   .use('/api/fs/walk', function (req, res, next) {
 | |
|       if (!(/^GET$/i.test(req.method) || /^GET$/i.test(req.query._method))) {
 | |
|         next();
 | |
|         return;
 | |
|       }
 | |
| 
 | |
|       var opts = {}
 | |
|         , dirnames = req.query.dir && [req.query.dir] || (req.query.dirs && req.query.dirs.split(/,/g)) || req.body.dirs
 | |
|         ;
 | |
| 
 | |
|       if (!dirnames || !dirnames.length) {
 | |
|         res.json({ error: "please specify GET w/ req.query.dir or POST w/ _method=GET&dirs=path/to/thing,..." });
 | |
|         return;
 | |
|       }
 | |
| 
 | |
|       /*
 | |
|       if (req.query.excludes) {
 | |
|         opts.excludes = req.query.excludes.split(',');
 | |
|       }
 | |
|       */
 | |
| 
 | |
|       if (req.query.extensions) {
 | |
|         opts.extensions = req.query.extensions.split(/,/g);
 | |
|       }
 | |
| 
 | |
|       if ('true' === req.query.dotfiles) {
 | |
|         opts.dotfiles = true;
 | |
|       }
 | |
| 
 | |
|       // TODO opts.contents?
 | |
|       walk.walkDirs(blogdir, dirnames, opts).then(function (stats) {
 | |
|         if (!req.body.dirs && !req.query.dirs) {
 | |
|           res.json(stats[dirnames[0]]);
 | |
|         } else {
 | |
|           res.json(stats);
 | |
|         }
 | |
|       });
 | |
|     })
 | |
|   .use('/api/fs/files', function (req, res, next) {
 | |
|       if (!(/^GET$/i.test(req.method) || /^GET$/i.test(req.query._method))) {
 | |
|         next();
 | |
|         return;
 | |
|       }
 | |
| 
 | |
|       var filepaths = req.query.path && [req.query.path] || (req.query.paths && req.query.paths.split(/,/g)) || req.body.paths
 | |
|         ;
 | |
| 
 | |
|       if (!filepaths || !filepaths.length) {
 | |
|         res.json({ error: "please specify GET w/ req.query.path or POST _method=GET&paths=path/to/thing,..." });
 | |
|         return;
 | |
|       }
 | |
| 
 | |
|       return getfs(blogdir, filepaths).then(function (files) {
 | |
|         if (!req.body.paths && !req.query.paths) {
 | |
|           res.json(files[0]);
 | |
|         } else {
 | |
|           res.send(files);
 | |
|         }
 | |
|       });
 | |
|     })
 | |
|   .use('/api/fs/files', function (req, res, next) {
 | |
|       if (!(/^POST|PUT$/i.test(req.method) || /^POST|PUT$/i.test(req.query._method))) {
 | |
|         next();
 | |
|         return;
 | |
|       }
 | |
| 
 | |
|       var opts = {}
 | |
|         , files = req.body.files
 | |
|         ;
 | |
| 
 | |
|       if (!files || !files.length) {
 | |
|         res.json({ error: "please specify POST w/ req.body.files" });
 | |
|         return;
 | |
|       }
 | |
| 
 | |
|       return putfs(blogdir, files, opts).then(function (results) {
 | |
|         res.json(results);
 | |
|       });
 | |
|     })
 | |
|   .use('/api/fs/copy', function (req, res, next) {
 | |
|       if (!(/^POST|PUT$/i.test(req.method) || /^POST|PUT$/i.test(req.query._method))) {
 | |
|         next();
 | |
|         return;
 | |
|       }
 | |
| 
 | |
|       var opts = {}
 | |
|         , files = req.body.files
 | |
|         ;
 | |
| 
 | |
|       if ('object' !== typeof files || !Object.keys(files).length) {
 | |
|         res.json({ error: "please specify POST w/ req.body.files" });
 | |
|         return;
 | |
|       }
 | |
| 
 | |
|       return fsapi.copyfs(blogdir, files, opts).then(function (results) {
 | |
|         res.json(results);
 | |
|       });
 | |
|     })
 | |
| 
 | |
|   .use('/api/fs', function (req, res, next) {
 | |
|       next();
 | |
|       return;
 | |
|     })
 | |
|   .use('/api/fs/static', serveStatic('.'))
 | |
| 
 | |
|   .use(serveStatic('.'))
 | |
|   .use(serveStatic(blogdir))
 | |
|   ;
 | |
| 
 | |
| module.exports = app;
 | |
| 
 | |
| require('http').createServer().on('request', app).listen(process.argv[2] || 65080, function () {
 | |
|   console.log('listening ' + (process.argv[2] || 65080));
 | |
| });
 |