first commit

.gitignore

@@ -0,0 +1,2 @@
+.idea
+node_modules/

README.md

@@ -0,0 +1,9 @@
+file-receiver
+===
+An http server to receive files posted from remote clients,
+by listening on '/receiver'.
+
+### Usage
+```bash
+fisrcv <port> # port defaults to 8999
+```

bin/filercv.js

@@ -0,0 +1,7 @@
+#!/usr/bin/env node
+var server = require('../server');
+
+var PORT = process.argv[2] || 8999;
+server.listen(PORT, function(){
+    console.log('file receiver listening on port ' + PORT);
+});

package.json

@@ -0,0 +1,15 @@
+{
+  "name": "file-receiver",
+  "version": "1.0.0",
+  "description": "an http server to receive files pushed from remote client",
+  "main": "fis-receiver.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "gongruixue",
+  "license": "ISC",
+  "dependencies": {
+    "formidable": "^1.0.17",
+    "mkdirp": "^0.5.1"
+  }
+}

server.js

@@ -0,0 +1,42 @@
+var http = require('http'),
+    path = require('path'),
+    formidable = require('formidable'),
+    mkdirp = require('mkdirp');
+
+var server = http.createServer(function(req, res){
+    function onError(msg){
+        res.statusCode = 500;
+        res.statusMessage = msg;
+        res.end();
+    }
+    function onSuccess(){
+        res.end();
+    }
+
+    if(req.url == '/receiver' && req.method.toLowerCase() == 'post'){
+        var form = new formidable.IncomingForm();
+        var to = '';
+        form.on('field', function onField(name, value){
+            if(name == 'to'){
+                to = value;
+                form.removeListener('field', onField);
+            }
+        });
+        form.on('fileBegin', function(name, file){
+            try{
+                mkdirp.sync(path.dirname(to));
+                file.path = to;
+            }catch(e){
+                onError('cannot make dir ' + to + ' to save file ' + name);
+                form.emit('aborted');
+            }
+
+        });
+        form.parse(req, function(err, fields, file){
+            if(err) onError(err.message);
+            else onSuccess();
+        });
+    }
+});
+
+module.exports = server;