下载校验，桌面通知，md5库换成nodejs的

app/candy/index.html

@@ -43,7 +43,7 @@ $(document).ready(function () {
     $(Candy).on('candy:core.chat.connection', function(event, args){
         if(args.status == Strophe.Status.CONNECTED){
             Candy.Core.Action.Jabber.Roster()
-            //Candy.Core.getConnection().send($iq({type: 'get'}).c('vCard', {xmlns: 'vcard-temp'}).tree());
+            Candy.Core.getConnection().send($iq({type: 'get'}).c('vCard', {xmlns: 'vcard-temp'}).tree());
         }
     });
 

app/index.html

@@ -104,7 +104,6 @@
 <script src="lib/js/bootstrap-switch.min.js"></script>
 
 <script src="lib/js/nw-desktop-notifications.js"></script>
-<script src="lib/js/md5.js"></script>
 
 <script src="lib/angular/angular.min.js"></script>
 <script src="lib/angular/angular-route.min.js"></script>

app/js/controllers.coffee

 path = require 'path'
+fs = require 'fs'
 child_process = require 'child_process'
+crypto = require('crypto');
 
 mkdirp = require 'mkdirp'
 gui = require 'nw.gui'
@@ -29,11 +31,8 @@ angular.module('maotama.controllers', [])
           $scope.app.extra_languages[lang] = download
 
       $scope.installing = {};
-
       $scope.$digest();
 
-
-
     $scope.add = (installation)->
       $scope.app.installation = path.dirname installation
       db.update {
@@ -53,13 +52,14 @@ angular.module('maotama.controllers', [])
         label: '正在连接'
       mkdirp path.join(process.cwd(), 'cache'), (err)->
         throw err if err
-        aria2c = child_process.spawn 'bin/aria2c', ["--dir=cache", "--enable-color=false", "-c", $scope.app.download.url]
+        aria2c = child_process.spawn 'bin/aria2c', ["--check-integrity", "--checksum=md5=#{$scope.app.download.checksum}", "--dir=cache", "--enable-color=false", "-c", $scope.app.download.url]
         aria2c.stdout.setEncoding('utf8');
         aria2c.stderr.setEncoding('utf8');
         aria2c.stdout.on 'data', (data)->
           console.log data
           #[#06c774 35MiB/298MiB(11%) CN:1 DL:62MiB ETA:4s]
-          if matches = data.match(/\[(?:#\w+ )?(\w+)\/(\w+)\((\d+)%\) CN:(\d+) DL:(\w+) ETA:(\w+)\]/)
+          #[#d1b179 752KiB/298MiB(0%) CN:1 DL:109KiB ETA:46m17s]
+          if matches = data.match(/\[(?:#\w+ )?([\w\.]+)\/([\w\.]+)\((\d+)%\) CN:(\d+) DL:([\w\.]+) ETA:(\w+)\]/)
             [d, downloaded, total, progress, connections, speed, eta] = matches
             $scope.installing[$scope.app.id].progress = progress
             $scope.installing[$scope.app.id].label = "#{progress}% #{speed}/s"
@@ -68,14 +68,33 @@ angular.module('maotama.controllers', [])
         aria2c.stderr.on 'data', (data)->
           console.log 'err: ', data
         aria2c.on 'close', (code)->
-          if code == 0
+          if code != 0
+            window.LOCAL_NW.desktopNotifications.notify "TODO://icon", '下载失败', "错误: #{code}"
+            delete $scope.installing[$scope.app.id]
+            $scope.$digest();
+          else
             $scope.installing[$scope.app.id].progress = 100
             $scope.installing[$scope.app.id].label = '正在安装'
             $scope.$digest();
+
+            downloaded = "cache/#{path.basename($scope.app.download.url)}";
+
+            # 二次校验，如果aria2c被强制退出了，返回码也是0
+            checksum = crypto.createHash('md5');
+            file = fs.ReadStream(downloaded);
+            file.on 'data', (d)->
+              checksum.update(d)
+
+            file.on 'end', ()->
+              if checksum.digest('hex') != $scope.app.download.checksum
+                window.LOCAL_NW.desktopNotifications.notify "TODO://icon", '下载失败', "校验错误"
+                delete $scope.installing[$scope.app.id]
+                $scope.$digest();
+              else
                 p = path.join "apps/#{$scope.app.id}"
                 mkdirp p, (err)->
                   throw err if err
-              console.log ["x", "-y", "-o#{p}", "cache/#{path.basename($scope.app.download.url)}"]
+                  console.log ["x", "-y", "-o#{p}", downloaded]
                   console.log p7zip = child_process.spawn 'bin/7za', ["x", "-y", "-o#{p}", "cache/#{path.basename($scope.app.download.url)}"]
                   p7zip.stdout.setEncoding('utf8');
                   p7zip.stderr.setEncoding('utf8');
@@ -84,14 +103,17 @@ angular.module('maotama.controllers', [])
                   p7zip.stderr.on 'data', (data)->
                     console.log 'err: ', data
                   p7zip.on 'close', (code)->
-                console.log code
-                if code == 0
+                    if code != 0
+                      window.LOCAL_NW.desktopNotifications.notify "TODO://icon", '安装失败', "错误: #{code}"
                       delete $scope.installing[$scope.app.id]
-                  $scope.add path.join(p, $scope.app.main)
-                else
-                  throw "安装失败: #{code}"
+                      $scope.$digest();
                     else
-            throw "下载失败: #{code}"
+                      $scope.add path.join(p, $scope.app.main)
+                      delete $scope.installing[$scope.app.id]
+                      $scope.$digest();
+
+
+
 
     $scope.run = ()->
       console.log $scope.app
@@ -121,14 +143,16 @@ if false #for debug
       nyanpass nyanpass"
       "download": {
         "url": "http://test2.my-card.in/downloads/maotama/th135_1.33.7z"
-        "size": 313177239
+        "size": 313177031
+        "checksum":"ab3c7f4646e080fb88959978865ebf24"
       }
       "main": 'th135.exe'
       "languages": {
         "ja-JP": true
         "zh-CN": {
           url: "http://test2.my-card.in/downloads/maotama/th135_lang_zh-CN_1.33.7z"
-          size: 74751963
+          size: 74749190
+          checksum: "49111c67d941e30384251a2026ba67ba"
         }
       }
     },{
@@ -142,7 +166,8 @@ if false #for debug
       "summary":"",
       "download": {
         url: "http://test2.my-card.in/downloads/maotama/th123_1.10a.7z"
-        "size": 313177239
+        "size": 250272482
+        "checksum": "027a358a7ac014f725ebb8659f1caa6f"
       },
       "main": 'th123.exe'
       "languages": {

app/js/controllers.js

 // Generated by CoffeeScript 1.7.1
 (function() {
-  var Datastore, child_process, db, gui, mkdirp, path;
+  var Datastore, child_process, crypto, db, fs, gui, mkdirp, path;
 
   path = require('path');
 
+  fs = require('fs');
+
   child_process = require('child_process');
 
+  crypto = require('crypto');
+
   mkdirp = require('mkdirp');
 
   gui = require('nw.gui');
@@ -78,13 +82,13 @@
           if (err) {
             throw err;
           }
-          aria2c = child_process.spawn('bin/aria2c', ["--dir=cache", "--enable-color=false", "-c", $scope.app.download.url]);
+          aria2c = child_process.spawn('bin/aria2c', ["--check-integrity", "--checksum=md5=" + $scope.app.download.checksum, "--dir=cache", "--enable-color=false", "-c", $scope.app.download.url]);
           aria2c.stdout.setEncoding('utf8');
           aria2c.stderr.setEncoding('utf8');
           aria2c.stdout.on('data', function(data) {
             var connections, d, downloaded, eta, matches, progress, speed, total;
             console.log(data);
-            if (matches = data.match(/\[(?:#\w+ )?(\w+)\/(\w+)\((\d+)%\) CN:(\d+) DL:(\w+) ETA:(\w+)\]/)) {
+            if (matches = data.match(/\[(?:#\w+ )?([\w\.]+)\/([\w\.]+)\((\d+)%\) CN:(\d+) DL:([\w\.]+) ETA:(\w+)\]/)) {
               d = matches[0], downloaded = matches[1], total = matches[2], progress = matches[3], connections = matches[4], speed = matches[5], eta = matches[6];
               $scope.installing[$scope.app.id].progress = progress;
               $scope.installing[$scope.app.id].label = "" + progress + "% " + speed + "/s";
@@ -95,18 +99,35 @@
             return console.log('err: ', data);
           });
           return aria2c.on('close', function(code) {
-            var p;
-            if (code === 0) {
+            var checksum, downloaded, file;
+            if (code !== 0) {
+              window.LOCAL_NW.desktopNotifications.notify("TODO://icon", '下载失败', "错误: " + code);
+              delete $scope.installing[$scope.app.id];
+              return $scope.$digest();
+            } else {
               $scope.installing[$scope.app.id].progress = 100;
               $scope.installing[$scope.app.id].label = '正在安装';
               $scope.$digest();
+              downloaded = "cache/" + (path.basename($scope.app.download.url));
+              checksum = crypto.createHash('md5');
+              file = fs.ReadStream(downloaded);
+              file.on('data', function(d) {
+                return checksum.update(d);
+              });
+              return file.on('end', function() {
+                var p;
+                if (checksum.digest('hex') !== $scope.app.download.checksum) {
+                  window.LOCAL_NW.desktopNotifications.notify("TODO://icon", '下载失败', "校验错误");
+                  delete $scope.installing[$scope.app.id];
+                  return $scope.$digest();
+                } else {
                   p = path.join("apps/" + $scope.app.id);
                   return mkdirp(p, function(err) {
                     var p7zip;
                     if (err) {
                       throw err;
                     }
-                console.log(["x", "-y", "-o" + p, "cache/" + (path.basename($scope.app.download.url))]);
+                    console.log(["x", "-y", "-o" + p, downloaded]);
                     console.log(p7zip = child_process.spawn('bin/7za', ["x", "-y", "-o" + p, "cache/" + (path.basename($scope.app.download.url))]));
                     p7zip.stdout.setEncoding('utf8');
                     p7zip.stderr.setEncoding('utf8');
@@ -117,17 +138,19 @@
                       return console.log('err: ', data);
                     });
                     return p7zip.on('close', function(code) {
-                  console.log(code);
-                  if (code === 0) {
+                      if (code !== 0) {
+                        window.LOCAL_NW.desktopNotifications.notify("TODO://icon", '安装失败', "错误: " + code);
                         delete $scope.installing[$scope.app.id];
-                    return $scope.add(path.join(p, $scope.app.main));
+                        return $scope.$digest();
                       } else {
-                    throw "安装失败: " + code;
+                        $scope.add(path.join(p, $scope.app.main));
+                        delete $scope.installing[$scope.app.id];
+                        return $scope.$digest();
                       }
                     });
                   });
-            } else {
-              throw "下载失败: " + code;
+                }
+              });
             }
           });
         });
@@ -168,14 +191,16 @@
           "summary": "喵喵喵喵喵帕斯 nyanpass nyanpass",
           "download": {
             "url": "http://test2.my-card.in/downloads/maotama/th135_1.33.7z",
-            "size": 313177239
+            "size": 313177031,
+            "checksum": "ab3c7f4646e080fb88959978865ebf24"
           },
           "main": 'th135.exe',
           "languages": {
             "ja-JP": true,
             "zh-CN": {
               url: "http://test2.my-card.in/downloads/maotama/th135_lang_zh-CN_1.33.7z",
-              size: 74751963
+              size: 74749190,
+              checksum: "49111c67d941e30384251a2026ba67ba"
             }
           }
         }, {
@@ -189,7 +214,8 @@
           "summary": "",
           "download": {
             url: "http://test2.my-card.in/downloads/maotama/th123_1.10a.7z",
-            "size": 313177239
+            "size": 250272482,
+            "checksum": "027a358a7ac014f725ebb8659f1caa6f"
           },
           "main": 'th123.exe',
           "languages": {

app/js/maotama.coffee

 path = require 'path'
+crypto = require 'crypto'
 
 gui = require 'nw.gui'
 
@@ -51,7 +52,7 @@ pre_load_photo = (jid, name, domain)->
     when 'public.talk.google.com'
       'data:image/gif;base64,R0lGODlhAQABAAAAACH5BAEKAAEALAAAAAABAAEAAAICTAEAOw=='
     else
-      hash = CryptoJS.MD5(jid);
+      hash = crypto.createHash('md5').update(jid).digest('hex')
       "http://en.gravatar.com/avatar/#{hash}?s=48&d=404"
 
 #聊天

app/js/maotama.js

 // Generated by CoffeeScript 1.7.1
 (function() {
-  var gui, path, pre_load_photo, tunnel, win;
+  var crypto, gui, path, pre_load_photo, tunnel, win;
 
   path = require('path');
 
+  crypto = require('crypto');
+
   gui = require('nw.gui');
 
   win = gui.Window.get();
@@ -77,7 +79,7 @@
       case 'public.talk.google.com':
         return 'data:image/gif;base64,R0lGODlhAQABAAAAACH5BAEKAAEALAAAAAABAAEAAAICTAEAOw==';
       default:
-        hash = CryptoJS.MD5(jid);
+        hash = crypto.createHash('md5').update(jid).digest('hex');
         return "http://en.gravatar.com/avatar/" + hash + "?s=48&d=404";
     }
   };

app/lib/js/md5.js

-/*
-CryptoJS v3.1.2
-code.google.com/p/crypto-js
-(c) 2009-2013 by Jeff Mott. All rights reserved.
-code.google.com/p/crypto-js/wiki/License
-*/
-var CryptoJS=CryptoJS||function(s,p){var m={},l=m.lib={},n=function(){},r=l.Base={extend:function(b){n.prototype=this;var h=new n;b&&h.mixIn(b);h.hasOwnProperty("init")||(h.init=function(){h.$super.init.apply(this,arguments)});h.init.prototype=h;h.$super=this;return h},create:function(){var b=this.extend();b.init.apply(b,arguments);return b},init:function(){},mixIn:function(b){for(var h in b)b.hasOwnProperty(h)&&(this[h]=b[h]);b.hasOwnProperty("toString")&&(this.toString=b.toString)},clone:function(){return this.init.prototype.extend(this)}},
-q=l.WordArray=r.extend({init:function(b,h){b=this.words=b||[];this.sigBytes=h!=p?h:4*b.length},toString:function(b){return(b||t).stringify(this)},concat:function(b){var h=this.words,a=b.words,j=this.sigBytes;b=b.sigBytes;this.clamp();if(j%4)for(var g=0;g<b;g++)h[j+g>>>2]|=(a[g>>>2]>>>24-8*(g%4)&255)<<24-8*((j+g)%4);else if(65535<a.length)for(g=0;g<b;g+=4)h[j+g>>>2]=a[g>>>2];else h.push.apply(h,a);this.sigBytes+=b;return this},clamp:function(){var b=this.words,h=this.sigBytes;b[h>>>2]&=4294967295<<
-32-8*(h%4);b.length=s.ceil(h/4)},clone:function(){var b=r.clone.call(this);b.words=this.words.slice(0);return b},random:function(b){for(var h=[],a=0;a<b;a+=4)h.push(4294967296*s.random()|0);return new q.init(h,b)}}),v=m.enc={},t=v.Hex={stringify:function(b){var a=b.words;b=b.sigBytes;for(var g=[],j=0;j<b;j++){var k=a[j>>>2]>>>24-8*(j%4)&255;g.push((k>>>4).toString(16));g.push((k&15).toString(16))}return g.join("")},parse:function(b){for(var a=b.length,g=[],j=0;j<a;j+=2)g[j>>>3]|=parseInt(b.substr(j,
-2),16)<<24-4*(j%8);return new q.init(g,a/2)}},a=v.Latin1={stringify:function(b){var a=b.words;b=b.sigBytes;for(var g=[],j=0;j<b;j++)g.push(String.fromCharCode(a[j>>>2]>>>24-8*(j%4)&255));return g.join("")},parse:function(b){for(var a=b.length,g=[],j=0;j<a;j++)g[j>>>2]|=(b.charCodeAt(j)&255)<<24-8*(j%4);return new q.init(g,a)}},u=v.Utf8={stringify:function(b){try{return decodeURIComponent(escape(a.stringify(b)))}catch(g){throw Error("Malformed UTF-8 data");}},parse:function(b){return a.parse(unescape(encodeURIComponent(b)))}},
-g=l.BufferedBlockAlgorithm=r.extend({reset:function(){this._data=new q.init;this._nDataBytes=0},_append:function(b){"string"==typeof b&&(b=u.parse(b));this._data.concat(b);this._nDataBytes+=b.sigBytes},_process:function(b){var a=this._data,g=a.words,j=a.sigBytes,k=this.blockSize,m=j/(4*k),m=b?s.ceil(m):s.max((m|0)-this._minBufferSize,0);b=m*k;j=s.min(4*b,j);if(b){for(var l=0;l<b;l+=k)this._doProcessBlock(g,l);l=g.splice(0,b);a.sigBytes-=j}return new q.init(l,j)},clone:function(){var b=r.clone.call(this);
-b._data=this._data.clone();return b},_minBufferSize:0});l.Hasher=g.extend({cfg:r.extend(),init:function(b){this.cfg=this.cfg.extend(b);this.reset()},reset:function(){g.reset.call(this);this._doReset()},update:function(b){this._append(b);this._process();return this},finalize:function(b){b&&this._append(b);return this._doFinalize()},blockSize:16,_createHelper:function(b){return function(a,g){return(new b.init(g)).finalize(a)}},_createHmacHelper:function(b){return function(a,g){return(new k.HMAC.init(b,
-g)).finalize(a)}}});var k=m.algo={};return m}(Math);
-(function(s){function p(a,k,b,h,l,j,m){a=a+(k&b|~k&h)+l+m;return(a<<j|a>>>32-j)+k}function m(a,k,b,h,l,j,m){a=a+(k&h|b&~h)+l+m;return(a<<j|a>>>32-j)+k}function l(a,k,b,h,l,j,m){a=a+(k^b^h)+l+m;return(a<<j|a>>>32-j)+k}function n(a,k,b,h,l,j,m){a=a+(b^(k|~h))+l+m;return(a<<j|a>>>32-j)+k}for(var r=CryptoJS,q=r.lib,v=q.WordArray,t=q.Hasher,q=r.algo,a=[],u=0;64>u;u++)a[u]=4294967296*s.abs(s.sin(u+1))|0;q=q.MD5=t.extend({_doReset:function(){this._hash=new v.init([1732584193,4023233417,2562383102,271733878])},
-_doProcessBlock:function(g,k){for(var b=0;16>b;b++){var h=k+b,w=g[h];g[h]=(w<<8|w>>>24)&16711935|(w<<24|w>>>8)&4278255360}var b=this._hash.words,h=g[k+0],w=g[k+1],j=g[k+2],q=g[k+3],r=g[k+4],s=g[k+5],t=g[k+6],u=g[k+7],v=g[k+8],x=g[k+9],y=g[k+10],z=g[k+11],A=g[k+12],B=g[k+13],C=g[k+14],D=g[k+15],c=b[0],d=b[1],e=b[2],f=b[3],c=p(c,d,e,f,h,7,a[0]),f=p(f,c,d,e,w,12,a[1]),e=p(e,f,c,d,j,17,a[2]),d=p(d,e,f,c,q,22,a[3]),c=p(c,d,e,f,r,7,a[4]),f=p(f,c,d,e,s,12,a[5]),e=p(e,f,c,d,t,17,a[6]),d=p(d,e,f,c,u,22,a[7]),
-c=p(c,d,e,f,v,7,a[8]),f=p(f,c,d,e,x,12,a[9]),e=p(e,f,c,d,y,17,a[10]),d=p(d,e,f,c,z,22,a[11]),c=p(c,d,e,f,A,7,a[12]),f=p(f,c,d,e,B,12,a[13]),e=p(e,f,c,d,C,17,a[14]),d=p(d,e,f,c,D,22,a[15]),c=m(c,d,e,f,w,5,a[16]),f=m(f,c,d,e,t,9,a[17]),e=m(e,f,c,d,z,14,a[18]),d=m(d,e,f,c,h,20,a[19]),c=m(c,d,e,f,s,5,a[20]),f=m(f,c,d,e,y,9,a[21]),e=m(e,f,c,d,D,14,a[22]),d=m(d,e,f,c,r,20,a[23]),c=m(c,d,e,f,x,5,a[24]),f=m(f,c,d,e,C,9,a[25]),e=m(e,f,c,d,q,14,a[26]),d=m(d,e,f,c,v,20,a[27]),c=m(c,d,e,f,B,5,a[28]),f=m(f,c,
-d,e,j,9,a[29]),e=m(e,f,c,d,u,14,a[30]),d=m(d,e,f,c,A,20,a[31]),c=l(c,d,e,f,s,4,a[32]),f=l(f,c,d,e,v,11,a[33]),e=l(e,f,c,d,z,16,a[34]),d=l(d,e,f,c,C,23,a[35]),c=l(c,d,e,f,w,4,a[36]),f=l(f,c,d,e,r,11,a[37]),e=l(e,f,c,d,u,16,a[38]),d=l(d,e,f,c,y,23,a[39]),c=l(c,d,e,f,B,4,a[40]),f=l(f,c,d,e,h,11,a[41]),e=l(e,f,c,d,q,16,a[42]),d=l(d,e,f,c,t,23,a[43]),c=l(c,d,e,f,x,4,a[44]),f=l(f,c,d,e,A,11,a[45]),e=l(e,f,c,d,D,16,a[46]),d=l(d,e,f,c,j,23,a[47]),c=n(c,d,e,f,h,6,a[48]),f=n(f,c,d,e,u,10,a[49]),e=n(e,f,c,d,
-C,15,a[50]),d=n(d,e,f,c,s,21,a[51]),c=n(c,d,e,f,A,6,a[52]),f=n(f,c,d,e,q,10,a[53]),e=n(e,f,c,d,y,15,a[54]),d=n(d,e,f,c,w,21,a[55]),c=n(c,d,e,f,v,6,a[56]),f=n(f,c,d,e,D,10,a[57]),e=n(e,f,c,d,t,15,a[58]),d=n(d,e,f,c,B,21,a[59]),c=n(c,d,e,f,r,6,a[60]),f=n(f,c,d,e,z,10,a[61]),e=n(e,f,c,d,j,15,a[62]),d=n(d,e,f,c,x,21,a[63]);b[0]=b[0]+c|0;b[1]=b[1]+d|0;b[2]=b[2]+e|0;b[3]=b[3]+f|0},_doFinalize:function(){var a=this._data,k=a.words,b=8*this._nDataBytes,h=8*a.sigBytes;k[h>>>5]|=128<<24-h%32;var l=s.floor(b/
-4294967296);k[(h+64>>>9<<4)+15]=(l<<8|l>>>24)&16711935|(l<<24|l>>>8)&4278255360;k[(h+64>>>9<<4)+14]=(b<<8|b>>>24)&16711935|(b<<24|b>>>8)&4278255360;a.sigBytes=4*(k.length+1);this._process();a=this._hash;k=a.words;for(b=0;4>b;b++)h=k[b],k[b]=(h<<8|h>>>24)&16711935|(h<<24|h>>>8)&4278255360;return a},clone:function(){var a=t.clone.call(this);a._hash=this._hash.clone();return a}});r.MD5=t._createHelper(q);r.HmacMD5=t._createHmacHelper(q)})(Math);

app/lib/js/nw-desktop-notifications.js

@@ -14,7 +14,7 @@
 
 	function makeNewNotifyWindow(){
 		var win = gui.Window.open(
-			'nw-desktop-notifications.html', {
+			'file:///'+process.cwd()+'/app/nw-desktop-notifications.html', { //modified by zh. 不知道为什么，默认的不能用
 			frame: false,
 			toolbar: false,
 			width: WINDOW_WIDTH,
@@ -28,7 +28,7 @@
 		win.on('loaded', function(){
 			window.LOCAL_NW.DesktopNotificationsWindowIsLoaded = true;
 			$(win.window.document.body).find('#closer').click(function(){
-				slideOutNotificationWindow();
+				slideOutNotificationWindow(closeAnyOpenNotificationWindows);
 			});
 		});
 	}

app/nw-desktop-notifications.html

@@ -2,7 +2,7 @@
 <html>
 	<head>
 		<title>Desktop Notification</title>
-		<script src="js/jquery-2.1.0.min.js"></script>
+		<script src="lib/js/jquery-2.1.0.min.js"></script>
 		<style type="text/css">
 			body {
 				font-family : Helvetica, Arial, sans-serif;