diff --git a/kevinChuang/promise.js b/kevinChuang/promise.js deleted file mode 100644 index 1ac7d5f..0000000 --- a/kevinChuang/promise.js +++ /dev/null @@ -1,16 +0,0 @@ -/*eslint-env es6*/ -/*jshint esversion:6*/ - - -module.exports = function(str) { - return new Promise((resolve,reject)=> { - console.log('promising',str); - try { - var jsonObj = JSON.parse(str); - console.log('jsonObj',jsonObj); - resolve(jsonObj); - } catch(e){ - reject('json parse failed'); - } - }); -}; diff --git a/kevinChuang/server.js b/kevinChuang/server.js index 1ba2240..f331924 100644 --- a/kevinChuang/server.js +++ b/kevinChuang/server.js @@ -4,7 +4,6 @@ const http = require('http'); const fs = require('fs'); const stream = require('stream'); -const jsonParse = require('./promise'); exports = module.exports = {}; @@ -17,51 +16,31 @@ http.createServer((req,res)=> { } - if(req.url === '/' && req.method === 'POST'){ - var bufferArray = []; - // var bufferString; + else if(req.url === '/' && req.method === 'POST'){ + var bufferString = ''; req.on('data',(data)=> { - bufferArray.push(data); - console.log('data',data); - // bufferString += data.toString(); - console.log(bufferArray); - return res.end(); + bufferString += data.toString(); }); req.on('end',()=> { - var string = bufferArray.toString(); - console.log('string',string,typeof string); - // var jsonObject = {}; - - jsonParse(string).then((data)=> { - console.log('data',data, typeof data); - var fileNum = fs.readdirSync(__dirname+'/data').length+1; - var file = fs.createWriteStream(__dirname + '/data/'+ fileNum +'.json'); - - console.log('fileNumber',fileNum); - - var bufferStream = new stream.PassThrough(); - var incomingBuffer = new Buffer(JSON.stringify(data)); - - console.log('incomingBuffer',incomingBuffer, typeof incomingBuffer); - - bufferStream.end(incomingBuffer); - bufferStream.pipe(file); - res.statusCode = 200; - res.end(console.log("Data written to file")); - }, (err)=> { - res.statusCode = 400; - res.end(err); - }); + var newFile = (fs.readdirSync(__dirname + '/data/')).length + 1; + var file = fs.createWriteStream(__dirname + '/data/test' + newFile + '.json'); + var bufferStream = new stream.PassThrough(); + var incomingBuffer = new Buffer(bufferString); + + bufferStream.end(incomingBuffer); + bufferStream.pipe(file); + res.statusCode=200; + return res.end('File written\n'); + }); + } else { + res.writeHead(404,{ + 'Content-Type' : 'text/html' }); - return; + res.write('Not Found'); + res.statusHead = 404; } - res.writeHead(404,{ - 'Content-Type' : 'text/html' - }); - res.write('Not Found'); - res.statusHead = 404; }).listen(3000,()=>{ console.log('Listening on port 3000'); });