diff options
Diffstat (limited to 'modules/changes/changes.js')
-rw-r--r-- | modules/changes/changes.js | 72 |
1 files changed, 72 insertions, 0 deletions
diff --git a/modules/changes/changes.js b/modules/changes/changes.js index 7cbe7ee..8a0b3d9 100644 --- a/modules/changes/changes.js +++ b/modules/changes/changes.js @@ -5,6 +5,7 @@ var cmn=require("../$common.js"), crypto=require("crypto"), http=require("http"), https=require("https"), + fs=require("fs"), URL=require("url"), child_process=require("child_process"); @@ -376,4 +377,75 @@ module.exports=function(app,io,_moddir){ refreshURLs(); res.send(); }); + app.post("/changes/diff",function(req,res){ + var param; + try {param=JSON.parse(req.body);} + catch(e){ + res.status(400); + res.send("Invalid JSON sent"); + return; + } + var url=param.url; + var newdate=new Date(param.newdate); + var olddate=new Date(param.olddate); + if(!urls[url]){ + res.status(404); + res.send("URL not found in watch list"); + return; + } + if(newdate.getTime()==NaN||olddate.getTime()==NaN){ + res.status(400); + res.send("Invalid time(s) sent"); + return; + } + if(newdate.getTime()==olddate.getTime()){ + res.status(400); + res.send("Please select different records to diff"); + return; + } + var tl=urls[url].timeline; + var newi=-1,oldi=-1,i; + for(i=0;i<tl.length;i++){ + if(tl[i][0].getTime()==newdate.getTime()){ + newi=i; + } + if(tl[i][0].getTime()==olddate.getTime()){ + oldi=i; + } + } + if(newi==-1||oldi==-1){ + res.status(404); + res.send("Times not found in timeline for URL"); + return; + } + //res.send(tl[newi][1]+"\n"+tl[oldi][1]+"\n"); + fs.mkdtemp("/tmp/changes-diff-tmp-",function(err,folder){ + if(err){ + console.log(err); + res.status(500); + res.send(); + return; + } + var counter=0; + var fscb=function(err){ + if(err){ + console.log(err); + res.status(500); + res.send(); + return; + } + counter++; + if(counter<2)return; + var proc=child_process.spawn( + "diff", + [folder+"/old.html",folder+"/new.html"], + {stdio:[process.stdin,fs.openSync(folder+"/diff.txt","w"),process.stderr]}); + proc.on("exit",function(code,signal){ + fs.createReadStream(folder+"/diff.txt").pipe(res); + }); + }; + fs.writeFile(folder+"/old.html",tl[oldi][2],fscb); + fs.writeFile(folder+"/new.html",tl[newi][2],fscb); + }); + }); }; |