home *** CD-ROM | disk | FTP | other *** search
/ PC Professionell 2005 August / PCpro_2005_08.ISO / files / firefox / flashgot-0.5.9.6-fxmztb.xpi / components / flashgotService.js < prev   
Encoding:
JavaScript  |  2005-06-09  |  65.0 KB  |  2,157 lines
  1. /***** BEGIN LICENSE BLOCK *****
  2.  
  3.     FlashGot - a Firefox extension for external download managers integration
  4.     Copyright (C) 2004-2005 Giorgio Maone - g.maone@informaction.com
  5.  
  6.     This program is free software; you can redistribute it and/or modify
  7.     it under the terms of the GNU General Public License as published by
  8.     the Free Software Foundation; either version 2 of the License, or
  9.     (at your option) any later version.
  10.  
  11.     This program is distributed in the hope that it will be useful,
  12.     but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14.     GNU General Public License for more details.
  15.  
  16.     You should have received a copy of the GNU General Public License
  17.     along with this program; if not, write to the Free Software
  18.     Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  19.  
  20. ***** END LICENSE BLOCK *****/
  21.  
  22. function FlashGotDM(name) {
  23.   if(arguments.length>0) {
  24.     this._init(name);
  25.   }
  26. }
  27.  
  28. FlashGotDM.dms=[];
  29. FlashGotDM.dmtests={};
  30. FlashGotDM.executables={};
  31. FlashGotDM.cleanup=function() {
  32.   var name;
  33.   for(name in FlashGotDM.executables) {
  34.     var f=FlashGotDM.executables[name];
  35.     if(f instanceof Components.interfaces.nsIFile) {
  36.       try { f.remove(true); } catch(ex) {}
  37.     }
  38.   }
  39. }
  40.  
  41. FlashGotDM.prototype = {
  42.   _init: function(name) {
  43.     this.name=name;
  44.     const dms=FlashGotDM.dms;
  45.     dms[name]=dms[dms.length]=this;
  46.   }
  47. ,
  48.   _service: null,
  49.   _cookieManager: null,
  50.   _exeFile: false,
  51.   _supported: null
  52. ,
  53.   exeName: "FlashGot.exe",
  54.   askPath: [false,false,false],
  55.   cookieSupport: true
  56. ,  
  57.   get codeName() {
  58.     return this.name.replace(/\W/g,"_");
  59.   }
  60. ,
  61.   get service() {
  62.     return this._service?this._service:this._service=
  63.     Components.classes[SERVICE_CTRID].getService(Components.interfaces.nsISupports).wrappedJSObject;
  64.   }
  65. ,
  66.   get cookieManager() {
  67.     return this._cookieManager?this._cookieManager:this._cookieManager=
  68.       Components.classes["@mozilla.org/cookiemanager;1"
  69.         ].getService(Components.interfaces.nsICookieManager);
  70.   }
  71. ,
  72.   get exeFile() {
  73.     if(typeof(this._exeFile)=="object") return this._exeFile;
  74.     const exeName=this.exeName;
  75.     if(!exeName) return this._exeFile=null;
  76.     if(typeof(FlashGotDM.executables[exeName])=="object") {
  77.       return this._exeFile=FlashGotDM.executables[exeName];
  78.     }
  79.     try {
  80.       const exeFile=Components.classes["@mozilla.org/file/local;1"].createInstance(
  81.         Components.interfaces.nsILocalFile);
  82.       exeFile.initWithPath(this.service.globals.profDir.path);
  83.       exeFile.append(exeName);
  84.       if(exeFile.exists()) {
  85.         try { exeFile.remove(true); } catch(ex) { this.log(ex.message); }
  86.       }
  87.       this._exeFile=this.checkExePlatform(exeFile);
  88.       if(this._exeFile!=null && this.createExecutable()) {
  89.         this.log(this._exeFile.path+" created");
  90.       }
  91.     } catch(ex) {
  92.       this._exeFile=null;
  93.       this.log("Can't init "+exeName+":\n"+ex.message);
  94.     }
  95.     return FlashGotDM.executables[exeName]=this._exeFile;
  96.   }
  97. ,
  98.   checkExePlatform: function(exeFile) {
  99.     return /(\/.*\.exe)|(\\.*\.sh)$/i.test(exeFile.path)?null:exeFile;
  100.   }
  101. ,
  102.   get supported() {
  103.     if(typeof(this._supported)=="boolean") return this._supported;
  104.     if(!this.exeName) return true;
  105.     if(!this.exeFile) return false;
  106.     
  107.     var dmtest;
  108.     if(typeof(FlashGotDM.dmtests[this.exeName])!="string") {
  109.       const dmtestFile=this.service.tmpDir.clone();
  110.       dmtestFile.append(this.exeName+".test");
  111.       try {
  112.         this.launchSupportTest(dmtestFile);
  113.         this.log(dmtest=this.service.readFile(dmtestFile)); 
  114.       } catch(ex) {
  115.         this.log(ex.message);
  116.         dmtest="";
  117.       }
  118.       FlashGotDM.dmtests[this.exeName]=dmtest;
  119.     } else dmtest=FlashGotDM.dmtests[this.exeName];
  120.     return this._supported=dmtest.indexOf(this.name+"|OK")>-1;
  121.   }
  122. ,
  123.   launchSupportTest: function (testFile) {
  124.     this.runNative(["-o",testFile.path],true);
  125.   }
  126. ,
  127.   log: function(msg) {
  128.     this.service.log(msg);
  129.   }
  130. ,
  131.   updateProgress: function(links,idx,len) {
  132.     links.progress.value=50 + 49 * idx / len;
  133.   }
  134. ,
  135.   isValidLink: function(url) {
  136.     return true;
  137.   }
  138. ,
  139.   createJobHeader: function(links, opType) {
  140.     return links.length+";"+this.name+";"+
  141.       (this.service.getPref(this.codeName+".quiet."+opType,false)
  142.         ?this.service.OP_QET:opType)
  143.       +";"+links.folder+";\n"
  144.   }
  145. ,
  146.   createJobBody: function(links) {
  147.     var job="";
  148.     var l,url;
  149.     const len=links.length;
  150.     this.checkCookieSupport();
  151.     var postData=links.postData;
  152.     if(!postData) postData="";
  153.     for(var j=0; j<len; j++) {
  154.       job+="\n"+(url=(l=links[j]).href)+"\n"
  155.       +l._description+"\n"
  156.       +this.getCookie(l,links)+"\n"
  157.       +postData;
  158.       this.updateProgress(links,j,len);
  159.     }
  160.     return job;
  161.   }
  162. ,
  163.   createJob: function(links,opType) {
  164.     var job=this.createJobHeader(links,opType) 
  165.     + this.getReferrer(links)
  166.     + this.createJobBody(links)+"\n";
  167.      if(job.substring(job.length-1)!="\n") {
  168.       job+="\n";
  169.      }
  170.     if(typeof(links.document)=="object") {
  171.       job+= links.document.referrer+ "\n" +links.document.cookie;
  172.     } else {
  173.       job+="\n";
  174.     }
  175.     return job;
  176.   }
  177. ,
  178.   _bgJob: true,
  179.   get bgJob() {
  180.     return this._bgJob && this.service.bgProcessing; 
  181.   }
  182. ,
  183.   download: function(links, opType) {
  184.     try {
  185.       links.folder=(links.length>0)?this.selectFolder(links,opType):""; 
  186.       const dm=this;
  187.       var asyncError=null;
  188.       function performJob() {
  189.         try {
  190.           dm.performJob(dm.createJob(links,opType));
  191.         } catch(ex) {
  192.           asyncError=ex;
  193.         }
  194.         links.progress.value=100;
  195.       }
  196.       if(links.length>1 && this.bgJob) {
  197.         this.log("Async download job");
  198.         this.service.runAsync(
  199.           performJob,
  200.           function() { if(asyncError) dm.log(asyncError.message); }
  201.         );
  202.       } else {
  203.         this.log("Synchronous download job");
  204.         performJob();
  205.       }
  206.     } catch(ex) {
  207.       this.log(ex.message);
  208.       links.progress.value=100;
  209.     }
  210.   }
  211. ,
  212.   getReferrer: function(links) {
  213.     return this.service.getPref("autoReferrer",true)?
  214.       (links.referrer?links.referrer
  215.       :typeof(links.document)=="object"?links.document.URL
  216.       :links[0]?links[0].href:"about:blank"
  217.       ):this.service.getPref("fakeReferrer","");
  218.   }
  219. ,
  220.   checkCookieSupport: function() {
  221.     this.getCookie=this.cookieSupport && !this.service.getPref("omitCookies")
  222.     ?this._getCookie
  223.     :function() { return ""; }
  224.     ;
  225.   }
  226. ,
  227.   getCookie: function() { return ""; }
  228. ,
  229.   _getCookie: function(link,links) {
  230.     if(!this.cookieSupport) return (this.getCookie=function() { return ""; })();
  231.     
  232.     var host,cookies;
  233.     if(cookies=links.cookies) {
  234.       host=link.host;
  235.       if(host) {
  236.         var c=cookies[host];
  237.         return c?c:"";
  238.       }
  239.       return "";
  240.     }
  241.     
  242.     var j,objCookie;
  243.     const hostCookies={};
  244.     
  245.     
  246.     var rxHost=/http[s]{0,1}:\/\/([^\/]+\.[^\/]+)/i;
  247.     var l,parts;
  248.     for(j=links.length; j-->0;) {
  249.       l=links[j];
  250.       parts=l.href.match(rxHost);
  251.       if(parts) {
  252.         hostCookies[l.host=parts[1]]="";
  253.       } else {
  254.         l.host=null;
  255.       }
  256.     }
  257.     
  258.     var cookieHost,cookieTable,tmpCookie;
  259.     const domainCookies={};
  260.  
  261.     for(var iter = this.cookieManager.enumerator; iter.hasMoreElements();) {
  262.       if((objCookie=iter.getNext()) instanceof Components.interfaces.nsICookie) {
  263.         cookieHost=objCookie.host;
  264.         if(cookieHost.charAt(0)==".") {
  265.           cookieHost=cookieHost.substring(1);
  266.           cookieTable=domainCookies;
  267.           if(typeof(tmpCookie=domainCookies[cookieHost])!="string") {
  268.             tmpCookie="";
  269.           }
  270.         } else {
  271.           if(typeof(tmpCookie=hostCookies[cookieHost])!="string") continue;
  272.           cookieTable=hostCookies;
  273.         }
  274.         cookieTable[cookieHost]=tmpCookie.concat(objCookie.name+"="+objCookie.value+"; ");
  275.       }
  276.     }
  277.     
  278.    
  279.     for(cookieHost in hostCookies) {
  280.       var dotPos;
  281.       for(host=cookieHost; (dotPos=host.indexOf('.'))>=0; ) { 
  282.         if(tmpCookie=domainCookies[host]) {
  283.           hostCookies[cookieHost]+=tmpCookie;
  284.         }
  285.         host=host.substring(dotPos+1);
  286.       }
  287.     }
  288.     
  289.     links.cookies=hostCookies;
  290.     return this.getCookie(link,links);
  291.   }
  292. ,
  293.   createJobFile: function(job) {
  294.     const jobFile=this.service.tmpDir.clone();
  295.     jobFile.append("flashgot.fgt");
  296.     jobFile.createUnique(0,0700);
  297.     this.service.writeFile(jobFile,job);
  298.     return jobFile;
  299.   }
  300. , 
  301.   _waitForNative: true,
  302.   get waitForNative() {
  303.     return this._waitForNative && ! this.service.isUIThread;
  304.   }
  305. ,
  306.   performJob: function(job) {
  307.     const jobFile=this.createJobFile(job);
  308.     this.runNative([jobFile.path],this.waitForNative);
  309.   }
  310. ,
  311.   createExecutable: function() {
  312.     const exeFile=this.exeFile;
  313.     if(!exeFile) return false;
  314.     
  315.     const cc=Components.classes;
  316.     const ci=Components.interfaces;
  317.     const ios=cc['@mozilla.org/network/io-service;1'].getService(ci.nsIIOService);
  318.     const bis=cc['@mozilla.org/binaryinputstream;1'].createInstance(ci.nsIBinaryInputStream);
  319.     
  320.     var channel;
  321.     bis.setInputStream((
  322.       channel=
  323.         ios.newChannel("chrome://flashgot/content/"+this.exeName,null,null)
  324.     ).open())
  325.     ;
  326.     const bytesCount=channel.contentLength;
  327.     
  328.     const os=cc["@mozilla.org/network/file-output-stream;1"].createInstance(
  329.       ci.nsIFileOutputStream);
  330.     
  331.     try {
  332.       
  333.       os.init(exeFile,0x02 | 0x08, 0700, 0);
  334.       const bos=cc['@mozilla.org/binaryoutputstream;1'].createInstance(ci.nsIBinaryOutputStream);
  335.       bos.setOutputStream(os);
  336.       bos.writeByteArray(bis.readByteArray(bytesCount),bytesCount);
  337.       bos.close();
  338.  
  339.     } catch(ioErr) { // locked?
  340.       try {
  341.         if(exeFile.exists()) { // security check: it must be the right exe!
  342.           const testBis=cc['@mozilla.org/binaryinputstream;1'].createInstance(
  343.             ci.nsIBinaryInputStream);
  344.           testBis.setInputStream(
  345.             (channel=ios.newChannelFromURI(ios.newFileURI(exeFile))).open());
  346.           const error=new Error("Old, corrupt or unlegitemately modified "
  347.             +exeFile.path
  348.             +".\nThe file is locked: please delete it manually\n");
  349.             +ioErr.message;
  350.           if(channel.contentLength!=bytesCount) throw error;
  351.          
  352.           const legitimateData=bis.readByteArray(bytesCount);
  353.           const testData=testBis.readByteArray(bytesCount);
  354.           for(var j=bytesCount; j-->0;) {
  355.             if(legitimateData[j]!=testData[j]) throw new error;
  356.           }
  357.         } else throw ioErr;
  358.       } catch(unrecoverableErr) {
  359.          this.log("Error creating native executable\n"+exeFile.path+"\n"+unrecoverableErr.message);
  360.       }
  361.     } finally {
  362.       os.close();
  363.       bis.close();
  364.     }
  365.     
  366.     return true;
  367.   }
  368. ,
  369.   runNative: function(args,blocking,exeFile) {
  370.     try {
  371.       if(typeof(exeFile)=="object"
  372.         || (exeFile=this.exeFile).exists()
  373.         || this.createExecutable()) {
  374.         const proc=Components.classes['@mozilla.org/process/util;1'].createInstance(
  375.           Components.interfaces.nsIProcess);
  376.         proc.init(exeFile);
  377.         this.log("Running "+exeFile.path+" ("+(blocking?"blocking":"async")+")");
  378.         proc.run(blocking,args,args.length,{});
  379.         if(blocking && proc.exitValue!=0) {
  380.           this.log("Warning: native invocation of\n"
  381.             +exeFile.path
  382.             +"\nwith arguments <"
  383.             +args.join(" ")
  384.             +">\nreturned "+proc.exitValue);
  385.         }
  386.         return proc.exitValue;
  387.       } else {
  388.         this.log("Bad executable "+exeFile);
  389.       }
  390.     } catch(err) {
  391.       this.log("Error running native executable:\n"+exeFile.path+" "+args.join(" ")+"\n"+err.message);
  392.     }  
  393.     return 0xffffffff;
  394.   }
  395. ,
  396.   getWindow: function() {
  397.     return this.service.getWindow();
  398.   }
  399. ,
  400.   selectFolder: function(links,opType) { 
  401.     const cc=Components.classes;
  402.     const ci=Components.interfaces;
  403.     const downloadDirPref="browser.download.dir";
  404.     const autoPref_FF="browser.download.useDownloadDir";
  405.     const autoPref_Moz="browser.download.autoDownload";
  406.     
  407.     var initialDir=null;
  408.     var downloadDir=null;
  409.     links.quickDownload=false;
  410.     const pref = cc["@mozilla.org/preferences-service;1"].getService(ci.nsIPrefBranch);
  411.     
  412.     try {
  413.       initialDir = pref.getComplexValue("browser.download.dir", ci.nsILocalFile);
  414.     } catch(ex) {}
  415.    
  416.     try {
  417.       if(links.quickDownload=pref.getBoolPref(autoPref_FF)) {
  418.         downloadDir=pref.getComplexValue("browser.download.defaultFolder",ci.nsILocalFile);
  419.       }
  420.     } catch(noFFEx) {
  421.       try {
  422.         links.quickDownload=pref.getBoolPref(autoPref_Moz);
  423.         downloadDir=initialDir;
  424.       } catch(noMozEx) {
  425.         links.quickDownload=false;
  426.       }
  427.     } 
  428.    
  429.     if(!this.askPath[opType]) return "";
  430.     
  431.     if(downloadDir && downloadDir.exists() && downloadDir.isDirectory()  && 
  432.         links.quickDownload) {
  433.       return downloadDir.path;
  434.     }
  435.     
  436.     var title;
  437.     try {
  438.       var bundle = cc["@mozilla.org/intl/stringbundle;1"].getService(ci.nsIStringBundleService);
  439.       bundle = bundle.createBundle("chrome://mozapps/locale/downloads/unknownContentType.properties");
  440.       title = bundle.GetStringFromName("myDownloads");
  441.     } catch(ex) {
  442.       title="Download directory";
  443.     }
  444.     title='FlashGot ('+this.name+') - '+title;
  445.     
  446.    
  447.     const fp = cc["@mozilla.org/filepicker;1"].createInstance(ci.nsIFilePicker);
  448.     const win=this.getWindow();
  449.     fp.init(win, title, ci.nsIFilePicker.modeGetFolder);
  450.     try {
  451.       if (initialDir &&  initialDir.exists() && initialDir.isDirectory()) {
  452.         fp.displayDirectory = initialDir;
  453.       }
  454.     } catch (ex) { this.log(ex); }
  455.     
  456.     fp.appendFilters(ci.nsIFilePicker.filterAll);
  457.  
  458.     if (fp.show()==ci.nsIFilePicker.returnOK) {
  459.       var localFile = fp.file.QueryInterface(ci.nsILocalFile);
  460.       pref.setComplexValue(downloadDirPref, ci.nsILocalFile, localFile);
  461.       var path=new String(localFile.path);
  462.       path._fgSelected=true;
  463.       return path;
  464.     }
  465.     
  466.     throw new Error("Download cancelled by user");
  467.   }
  468.   
  469. }
  470.  
  471. function FlashGotDMX(name,cmd, argsTemplate) {
  472.   if(arguments.length!=0) {
  473.     this._init(name);
  474.     const cmds=FlashGotDMX.prototype.unixCmds;
  475.     cmds[cmds.length]={longName: name, shortName: cmd};
  476.     this.unixCmd=cmd;
  477.     if(argsTemplate) this.argsTemplate=argsTemplate;
  478.   }
  479. }
  480. FlashGotDMX.prototype=new FlashGotDM();
  481. FlashGotDMX.constructor=FlashGotDMX;
  482. FlashGotDMX.prototype.exeName="flashgot.sh";
  483. FlashGotDMX.prototype.cookieSupport=false;
  484. FlashGotDMX.prototype.askPath=[true,true,true];
  485. FlashGotDMX.prototype.unixCmds=[];
  486. FlashGotDMX.prototype.unixShell=null;
  487. FlashGotDMX.prototype.argsTemplate="[URL]";
  488. FlashGotDMX.prototype.launchSupportTest=function(testFile) {
  489.   const cmds=this.unixCmds;
  490.   var script="(\n";
  491.   var cmd;
  492.   for(var j=cmds.length; j-->0;) {
  493.     cmd=cmds[j];
  494.     script+=" [ -x \"`which '"+cmd.shortName+"'`\" ] && echo '"
  495.       +cmd.longName+"|OK' || echo '"+cmd.longName+"|KO'\n"; 
  496.   }
  497.   script+=") > '"+ testFile.path + "'\n"; 
  498.   this.performJob(script,true);
  499. };
  500. FlashGotDMX.prototype.createCmdLine=function(URL,REFERER,COOKIE,FOLDER,POST) {
  501.   return this.unixCmd+ " " +
  502.     this.argsTemplate.replace(/\[(.*?)\b(URL|REFERER|COOKIE|FOLDER|POST)\b(.*?)\]/g,
  503.       function(all,before,parm,after) { 
  504.           v=eval("typeof("+parm+")=='string'?"+parm+":null"); 
  505.           return v
  506.             ?before+v+after
  507.             :"";
  508.       }
  509.       ) +" &\n";
  510. };
  511. FlashGotDMX.prototype.createJob=function(links,opType) {
  512.   function shellEsc(s) {
  513.     return s?s.replace(/([\\\*\?\[\]\$&<>\|\(\)\{\};"'`])/g,"\\$1").replace(/\s/g,"\\ "):"";
  514.   }
  515.   // basic implementation
  516.   const len=links.length;
  517.   const folder=shellEsc(links.folder);
  518.   const referrer=shellEsc(this.getReferrer(links));
  519.   const postData=shellEsc(links.postData);
  520.   var job="";
  521.   var l,url;
  522.   this.checkCookieSupport();
  523.   for(var j=0; j<len; j++) {
  524.     l=links[j];
  525.     url=l.href;
  526.     job+=this.createCmdLine(
  527.       shellEsc(url), 
  528.       referrer, 
  529.       shellEsc(this.getCookie(l,links)), 
  530.       folder, 
  531.       postData);
  532.     this.updateProgress(links,j,len);
  533.   }
  534.   return job;
  535. };
  536. FlashGotDMX.prototype.performJob=function(job,blocking) {
  537.   const jobFile=this.createJobFile("#!"+this.unixShell.path+"\n"+job);
  538.   jobFile.permissions=0700;
  539.   this.runNative([],
  540.     this.waitForNative || (typeof(blocking)!="undefined" && blocking),
  541.     jobFile);
  542. };
  543. FlashGotDMX.prototype.checkExePlatform=function(exeFile) {
  544.   const f=Components.classes["@mozilla.org/file/local;1"].createInstance(
  545.     Components.interfaces.nsILocalFile);
  546.   try {
  547.     f.initWithPath("/bin/sh");
  548.     if(f.exists()) {
  549.       FlashGotDMX.prototype.unixShell=f;
  550.       return exeFile;
  551.     }
  552.     this.log(f.path+" not found");
  553.   } catch(ex) {
  554.     this.log(ex.message);
  555.   }
  556.   return null;
  557. };
  558. FlashGotDMX.prototype.createExecutable=function() {
  559.   return false;
  560. };
  561.  
  562. function FlashGotDMMac(name, creatorId, macAppName) {
  563.   if(arguments.length!=0) {
  564.     this._initMac(name,creatorId,macAppName);
  565.   }
  566. }
  567. FlashGotDMMac.prototype=new FlashGotDM();
  568. FlashGotDMMac.constructor=FlashGotDMMac;
  569. FlashGotDMMac.prototype.exeName="flashgot-mac.sh";
  570. FlashGotDMMac.prototype.cookieSupport=false;
  571. FlashGotDMMac.prototype.OSASCRIPT="/usr/bin/osascript";
  572. FlashGotDMMac.prototype.macCreators=[];
  573. FlashGotDMMac.prototype._initMac=function(name, creatorId, macAppName) {
  574.   this._init(name);
  575.   if(creatorId) {
  576.     const creators=FlashGotDMMac.prototype.macCreators;
  577.     creators[creators.length]={name: name, id: creatorId};
  578.   }
  579.   this.macAppName = macAppName?macAppName:name;
  580. };
  581. FlashGotDMMac.prototype.createScriptLauncher=function(scriptPath) {
  582.   return "#!/bin/sh\n"
  583.     +this.OSASCRIPT+" '"+scriptPath+"'";
  584. };
  585. FlashGotDMMac.prototype.checkExePlatform=function(exeFile) {
  586.   const f=Components.classes["@mozilla.org/file/local;1"].createInstance(
  587.     Components.interfaces.nsILocalFile);
  588.   try {
  589.     f.initWithPath(this.OSASCRIPT);
  590.     if(f.exists()) return exeFile;
  591.     this.log(f.path+" not found");
  592.   } catch(ex) {
  593.     this.log(ex.message);
  594.   }
  595.   return null;
  596. };
  597. FlashGotDMMac.prototype.createExecutable=function() {
  598.   const exeFile=this.exeFile;
  599.   if(exeFile) {
  600.     try {
  601.      const script=this.service.tmpDir.clone();
  602.      script.append("flashgot-test.scpt");
  603.      FlashGotDMMac.prototype.testAppleScript=script;
  604.      script.createUnique(0,0700);
  605.      if(exeFile.exists()) exeFile.remove(true);
  606.      exeFile.create(0,0700);
  607.      this.service.writeFile(exeFile,this.createScriptLauncher(script.path));
  608.      exeFile.permissions=0700;
  609.      return true;
  610.     } catch(ex) {
  611.       this.log(ex.message);
  612.     }
  613.   }
  614.   return false;
  615. };
  616. FlashGotDMMac.prototype.launchSupportTest=function(testFile) {
  617.   const creators=FlashGotDMMac.prototype.macCreators;
  618.   const RESP="    do shell script \"echo >>'"+testFile.path+"' '\" & theName & \"|";
  619.   function response(msg) {
  620.     return RESP+msg+"'\"\n";
  621.   }
  622.   var s="on test(theName, theCreator)\n"
  623.        +" tell app \"Finder\"\n"
  624.        +"  set theResponse to \"KO\"\n"
  625.        +"  try\n"
  626.        +"   get name of application file id theCreator\n"
  627.        +"   if result contains theName then\n"
  628.        +"     set theResponse to \"OK\"\n"
  629.        +"   end if\n"
  630.        +"  on error\n"
  631.        +"  end try\n"
  632.        +"  do shell script \"echo >>'"+testFile.path+"' '\" & theName & \"|\" & theResponse & \"'\"\n"
  633.        +" end tell\n"
  634.        +"end test\n"
  635.        +"\n";
  636.   for(var j=creators.length; j-->0;) {
  637.      s+='get test("'+creators[j].name+'","'+creators[j].id+'")\n'; 
  638.    }
  639.    this.service.writeFile(this.testAppleScript,s);
  640.    this.runNative([],true,this.exeFile);
  641. };
  642. FlashGotDMMac.prototype.performJob=function(job) {
  643.   const script=this.createJobFile(job);
  644.   const launcher=this.createJobFile(this.createScriptLauncher(script.path));
  645.   launcher.permissions=0700;
  646.   this.runNative([],this.waitForNative,launcher);
  647. };
  648. FlashGotDMMac.prototype.createJob=function(links,opType) {
  649.   const referrer=this.getReferrer(links);
  650.   var job = "tell application \""+ this.macAppName+ "\"\n";
  651.   for(var j=0,len=links.length; j<len; j++) {
  652.     job+="GetURL \""+links[j].href+"\" from \""+ referrer  +"\"\n";
  653.     this.updateProgress(links,j,len);
  654.   }
  655.   job+="end tell\n";
  656.   return job;
  657. };
  658.  
  659. // END DMS classes
  660.  
  661. // DMS initialization
  662.  
  663. FlashGotDM.initDMS=function() {
  664.   var dm;
  665.   
  666.   dm=new FlashGotDM("Download Accelerator Plus");
  667.   dm.exclusive=true;
  668.   
  669.   new FlashGotDM("Download Master");
  670.   
  671.   new FlashGotDM("FlashGet");
  672.   
  673.   dm=new FlashGotDM("Free Download Manager");
  674.   dm._waitForNative=false;
  675.   
  676.   new FlashGotDM("FreshDownload");
  677.   
  678.   dm=new FlashGotDM("GetRight");
  679.   dm.super_download=FlashGotDM.prototype.download;
  680.   dm.super_createJob=FlashGotDM.prototype.createJob;
  681.   dm.download=function(links, opType) {
  682.     const service=this.service;
  683.     if(opType==service.OP_ONE && !service.getPref("GetRight.quick")) {
  684.       opType=service.OP_SEL;
  685.     }
  686.     this.super_download(links,opType);
  687.   };
  688.   dm.createJob=function(links, opType) {
  689.     const service=this.service;
  690.     var folder=links.folder;
  691.     if(!(folder && folder._fgSelected)) folder=false;
  692.     
  693.     var referrer=this.getReferrer(links);
  694.     
  695.     switch(opType) {
  696.       case service.OP_ONE:
  697.         var job=this.super_createJob(links,opType);
  698.         if(this.service.getPref("GetRight.old")) job+="\nold";
  699.         return job;
  700.       case service.OP_SEL:
  701.       case service.OP_ALL:
  702.         var urlList="";
  703.         var referrerLine=(referrer && referrer.length>0)?"\r\nReferer: "+referrer+"\r\n":"\r\n";
  704.         var l,decodedURL,fileSpec,cookie;
  705.         for(var j=0, len=links.length; j<len; j++) {
  706.           l=links[j];
  707.           
  708.           if(folder) {
  709.             var decodedURL=l.href;
  710.             try { decodedURL=decodeURI(decodedURL) } catch(ex) {};
  711.             var urlParts=decodedURL.match(/\/\/.+[=\/]([^\/]+\.[\w\d]+)/);
  712.             if(!urlParts) urlParts=l.href.match(/.*\/(.+)/);
  713.             if(urlParts && (fileSpec=urlParts[1])
  714.               // && (links.length==1 ||  !/\.(php|[\w]?htm[l]?|asp|jsp|do|xml|rdf|\d+)$/i.test(fileSpec))
  715.              ) {
  716.               fileSpec="File: "+folder+"\\"+fileSpec+"\r\n";
  717.             } else continue;
  718.           } else fileSpec="";
  719.           urlList+="URL: "+l.href
  720.             +"\r\nDesc: "+l._description
  721.             +referrerLine+fileSpec;
  722.           if(cookie=this.getCookie(l,links)) {
  723.             urlList+="Cookie: " + cookie + "\r\n";
  724.           }
  725.           this.updateProgress(links,j,len);
  726.         }
  727.         var file=service.tmpDir.clone();
  728.         file.append("flashgot.grx");
  729.         file.createUnique(0,0600);
  730.         service.writeFile(file,urlList);
  731.         referrer=file.path;
  732.         break;
  733.     }
  734.     var cmdOpts="/Q";
  735.     if(service.getPref("GetRight.autostart",false)) { // CHECK ME!!!
  736.       cmdOpts+="\n /AUTO";
  737.     }
  738.     return this.createJobHeader({ length: 0, folder: "" },opType) +
  739.       referrer + "\n" + cmdOpts;
  740.   };
  741.   dm.askPath=[false,true,true];
  742.   
  743.   new FlashGotDM("HiDownload");
  744.   new FlashGotDM("InstantGet");
  745.   new FlashGotDM("Internet Download Accelerator");
  746.  
  747.   var lg2002=new FlashGotDM("LeechGet 2002");
  748.   var lg2004=new FlashGotDM("LeechGet");
  749.   lg2004._bgJob=lg2002._bgJob=false;
  750.   lg2004.super_createJob=lg2002.super_createJob=FlashGotDM.prototype.createJob;
  751.   lg2004.createJob=lg2002.createJob=function(links, opType) {
  752.     const service=this.service;
  753.     var referrer;
  754.     switch(opType) {
  755.       case service.OP_ONE:
  756.         return this.super_createJob(links, links.quickDownload?service.OP_ONE:service.OP_SEL);
  757.       case service.OP_SEL:
  758.         var htmlDoc="<html><head><title>FlashGot selection</title></head><body>";
  759.         var l;
  760.         for(var j=0, len=links.length; j<len; j++) {
  761.           l=links[j];
  762.           var des=l._description;
  763.           var tag=l.tagName?l.tagName.toLowerCase():"";
  764.           htmlDoc=htmlDoc.concat(tag=="img"
  765.             ?"<img src=\""+l.href+"\" alt=\""+des
  766.               +"\" width=\""+l.width+"\" height=\""+l.height+
  767.               "\" />\n"
  768.             :"<a href=\""+l.href+"\">"+des+"</a>\n");
  769.           this.updateProgress(links,j,len);
  770.         }
  771.         referrer=service.httpServer.addDoc(
  772.           htmlDoc.concat("</body></html>")
  773.         );
  774.         break;
  775.        default:
  776.         referrer=links.document.URL;
  777.         if(referrer.match(/^\s*file:/i)) { // fix for local URLs
  778.           // we serve local URLs through built-in HTTP server...
  779.           return this.createJob(links,service.OP_SEL);
  780.         }
  781.     }
  782.     return this.createJobHeader({ length: 0, folder: "" },opType)+referrer+"\n";
  783.   };
  784.  
  785.   new FlashGotDM("Net Transport");
  786.   new FlashGotDM("NetAnts");
  787.   new FlashGotDM("Mass Downloader");
  788.   
  789.   new FlashGotDM("ReGet"); 
  790.   
  791.   const httpFtpRx=/^(http:|ftp:)/;
  792.   const httpFtpValidator=function(url) {
  793.     return this.validLinkRx.test(url);
  794.   };
  795.   dm=new FlashGotDM("Star Downloader");
  796.   dm.cookieSupport=false;
  797.   dm.isValidLink=httpFtpValidator;
  798.   dm._waitForNative=false;
  799.   
  800.   dm=new FlashGotDM("TrueDownloader");
  801.   dm.isValidLink=httpFtpValidator;
  802.   dm._waitForNative=false;
  803.   
  804.   new FlashGotDM("Thunder");
  805.   new FlashGotDM("WellGet");
  806.   
  807.   dm=new FlashGotDMX("Aria","aria", "[-r REFERER] [-d FOLDER] -g [URL]");
  808.   dm.createJob=function(links,opType) {
  809.     return FlashGotDMX.prototype.createJob.call(this,links,opType) + "\nsleep 4\n" + this.unixCmd+" -s &\n";
  810.   };
  811.   dm._waitForNative=false;
  812.   
  813.   dm=new FlashGotDMX("Downloader 4 X (nt)","nt");
  814.   dm.createJob=function(links,opType) {
  815.     return this.unixCmd+"&\nsleep 1\n" +
  816.       (links.folder && links.folder._fgSelected
  817.       ? this.unixCmd+" -d '"+links.folder+"'\n"
  818.       :"") + 
  819.       FlashGotDMX.prototype.createJob.call(this,links,opType);
  820.   };
  821.   (new FlashGotDMX("Downloader 4 X","d4x")).createJob=dm.createJob;
  822.   
  823.   dm=new FlashGotDMX("KDE KGet","kget");
  824.   dm.askPath=[false,false,false];
  825.   dm.createJob=function(links,opType) {
  826.     return FlashGotDMX.prototype.createJob.call(this,links,opType);
  827.   };
  828.   
  829.   // Needs a lot of work, not ready for prime time
  830.  
  831.   dm=new FlashGotDMX("cURL","curl", '-L -O [--referer REFERER] [-b COOKIE] [-d POST] [URL]');
  832.   dm.createJob=function(links,opType) {
  833.     var job="[ -x \"`which 'xterm'`\" ] &&  CURL_CMD='xterm -e curl' || CURL_CMD='curl'\n";
  834.     if (links.folder) job+="cd '"+links.folder+"'\n";
  835.     this.unixCmd="$CURL_CMD";
  836.     return job + FlashGotDMX.prototype.createJob.call(this,links,opType);
  837.   };
  838.  
  839.   
  840.   function FlashGotDMSD(version) {
  841.     this._initMac("Speed Download "+version,"Spee");
  842.     this.version=version;
  843.   };
  844.   FlashGotDMSD.prototype=new FlashGotDMMac();
  845.   FlashGotDMSD.prototype.createJob=function(links,opType) {
  846.     const v=this.version;
  847.    
  848.     var job = "tell app \""+ this.macAppName+ "\" to AddURL {";
  849.     var urlList=[];
  850.     var cookieList=[];
  851.     var l;
  852.     for(var j=0,len=links.length; j<len; j++) {
  853.       l=links[j];
  854.       urlList[urlList.length]='"'+l.href+'"';
  855.       if(v>2) {
  856.         cookieList[cookieList.length]='"'+this.getCookie(l,links)+'"';
  857.       }
  858.       this.updateProgress(links,j,len);
  859.     }
  860.     job+=urlList.join(',')+"}";
  861.     if(v>2) {
  862.       if(links.postData && links.postData.length) { 
  863.         job+=' with form data "'+links.postData+'"';
  864.       }
  865.       const referer=this.getReferrer(links);
  866.       if(referer && referer.length) {
  867.         job+=' from "'+referer+'"';
  868.       }
  869.       if(cookieList.length) {
  870.         job+=' with cookies {' + cookieList.join(',') + '}';
  871.       }
  872.     }  
  873.     return job;
  874.   };
  875.   
  876.   new FlashGotDMSD(2);
  877.   new FlashGotDMSD(3).cookieSupport=true;
  878.  
  879.   new FlashGotDMMac("iGetter","iGET");
  880.   
  881.   FlashGotDM.dms.sort(function(a,b) { a=a.name.toLowerCase(); b=b.name.toLowerCase(); return a>b?1:a<b?-1:0; });
  882.   
  883.   
  884. };
  885. FlashGotDM.initDMS();
  886.  
  887. const SHUTDOWN="profile-before-change";
  888. const STARTUP="profile-after-change";
  889.  
  890. function FlashGotService() {
  891.   
  892.   const osvr=Components.classes['@mozilla.org/observer-service;1'].getService(
  893.     Components.interfaces.nsIObserverService);
  894.   
  895.   osvr.addObserver(this,SHUTDOWN,false);
  896.   osvr.addObserver(this,"xpcom-shutdown",false);
  897.   osvr.addObserver(this,STARTUP,false);
  898.   
  899.   Components.classes["@mozilla.org/uriloader;1"].getService(
  900.     Components.interfaces.nsIURILoader).registerContentListener(this);
  901.   
  902. }
  903.  
  904. FlashGotService.prototype = {
  905.   OP_ONE: 0, 
  906.   OP_SEL: 1,
  907.   OP_ALL: 2,
  908.   OP_QET: 3
  909. ,
  910.   get wrappedJSObject() {
  911.     return this;
  912.   }
  913. ,
  914.   unregister: function() {
  915.     try {
  916.       const osvr=Components.classes['@mozilla.org/observer-service;1'].getService(
  917.       Components.interfaces.nsIObserverService);
  918.       osvr.removeObserver(this,SHUTDOWN);
  919.       osvr.removeObserver(this,"xpcom-shutdown");
  920.       osvr.removeObserver(this,STARTUP);
  921.       Components.classes["@mozilla.org/uriloader;1"].getService(
  922.         Components.interfaces.nsIURILoader).unRegisterContentListener(this);
  923.     } catch(ex) {
  924.       this.log("Error unregistering service as observer: "+ex);
  925.     }
  926.   }
  927. ,
  928.   QueryInterface: function(iid) {
  929.      xpcom_checkInterfaces(iid,SERVICE_IIDS,Components.results.NS_ERROR_NO_INTERFACE);
  930.      return this;
  931.   }
  932. ,
  933.   /* nsIObserver */  
  934.   observe: function(subject, topic, data) {
  935.     if(subject==this.prefs) {
  936.       this.syncPrefs(data);
  937.     } else {
  938.       switch(topic) {
  939.         case "xpcom-shutdown":
  940.           this.unregister();
  941.           break;
  942.         case SHUTDOWN: 
  943.           this.cleanup();
  944.           break;
  945.         case STARTUP:
  946.           // apparently the following caused problems reported in 0.5.9.5
  947.           // this.initGlobals(); 
  948.           break;
  949.       }
  950.     }
  951.   }
  952. ,
  953.   syncPrefs: function(name) {
  954.     this.logEnabled=this.getPref("logEnabled",true);
  955.     if(name) {
  956.       switch(name) {
  957.       case "hide-icons":
  958.         var w;
  959.         for(var wins=this.windowMediator.getEnumerator(null);   wins.hasMoreElements();) {
  960.            w=wins.getNext();
  961.            if(typeof(w.flashGot)=="object" && w.flashGot.toggleMainMenuIcon) {
  962.              w.flashGot.toggleMainMenuIcon();
  963.            }
  964.         }
  965.       }
  966.     }
  967.   }
  968. ,
  969.   _shouldIntercept: function(contentType) {
  970.     if(this.bypassAutostart || !this.DMS.found) { 
  971.       return false;
  972.     }
  973.     if(this.forceAutostart) return true;
  974.     if(!this.getPref("autoStart",true)) return false;
  975.     
  976.     if(this.getPref("interceptAll",false)) { 
  977.       if(!/\bxpinstall\b/.test(contentType)) {
  978.         return true;
  979.       }
  980.     }
  981.     
  982.     if(contentType=="application/x-unknown-content-type") return false;
  983.      var ms=Components.classes['@mozilla.org/uriloader/external-helper-app-service;1'
  984.       ].getService(Components.interfaces.nsIMIMEService);
  985.     const exts=this.extensions;
  986.     for(var j=exts.length; j-->0;) {
  987.       if(contentType==ms.getTypeFromExtension(exts[j])) return true;
  988.     }    
  989.     
  990.   }
  991. , 
  992.   _willHandle: function(url, contentType) {
  993.     if(!/^(http|https|ftp|sftp|rtsp|mms):/i.test(url) ) {
  994.       if((/^\s*javascript/i).test(url)) this.log("JavaScript url intercepted: "+url);
  995.       return false;
  996.     }
  997.     return true;
  998.   }
  999. ,
  1000.   /* nsIURIContentListener */
  1001.   canHandleContent: function(contentType, isContentPreferred, desiredContentType) {
  1002.     return this._shouldIntercept(contentType);
  1003.   }
  1004. ,
  1005.   doContent: function(contentType, isContentPreferred, channel, contentHandler) {
  1006.     const ci=Components.interfaces;
  1007.     channel.QueryInterface(ci.nsIChannel);
  1008.     const uri=channel.URI;
  1009.     
  1010.     if(!this._willHandle(uri.spec,contentType)) {
  1011.       throw new Error("FlashGot not interested in "+contentType+" from "+uri.spec);
  1012.     }
  1013.     
  1014.     this.log("Intercepting download...");
  1015.  
  1016.     const pathParts=uri.path.split(/\//);
  1017.     var links=[ {
  1018.      href: channel.URI.spec, 
  1019.      title: pathParts[pathParts.length-1]
  1020.     } ];
  1021.     
  1022.     if(channel instanceof ci.nsIHttpChannel) {
  1023.       links.referrer=channel.referrer.spec;
  1024.       if(channel instanceof ci.nsIUploadChannel 
  1025.           && channel.uploadStream instanceof Components.interfaces.nsISeekableStream) {
  1026.         this.log("Extracting post data...");
  1027.           try {
  1028.             channel.uploadStream.seek(0,0);
  1029.             const sis=Components.classes[
  1030.               '@mozilla.org/scriptableinputstream;1'].createInstance(
  1031.               ci.nsIScriptableInputStream);
  1032.             sis.init(channel.uploadStream);
  1033.             var postData=sis.read(sis.available()).replace(/\s$/,'').split(/[\r\n]/);
  1034.             links.postData=postData[postData.length-1];
  1035.             sis.close();
  1036.           } catch(ex) {
  1037.             this.log(ex.message);
  1038.           }
  1039.         }
  1040.       }
  1041.       
  1042.       if(this.download(links)) {
  1043.         this.log("...interception done!");
  1044.       } else {
  1045.          throw new Error("Can't download from this URL: "+uri.spec);
  1046.       }
  1047.       
  1048.       channel.cancel(Components.results.NS_BINDING_ABORTED); 
  1049.      
  1050.       this.log("Original request cancelled.");
  1051.       contentHandler.value=null;
  1052.       return true;
  1053.   }
  1054. ,
  1055.   isPreferred: function(contentType, desiredContentType) {
  1056.     return this._shouldIntercept(contentType);
  1057.   }
  1058. ,
  1059.   onStartURIOpen: function(uri) {
  1060.     return false;
  1061.   }
  1062. ,
  1063.   mailer: false // is Thunderbird?
  1064. ,
  1065.   get defaultDM() {
  1066.     return this.getPref("defaultDM",null);
  1067.   }
  1068. ,
  1069.   set defaultDM(name) {
  1070.     this.setPref("defaultDM", name);
  1071.     return name;
  1072.   }
  1073. ,
  1074.   get tmpDir() {
  1075.     return this.globals.tmpDir; 
  1076.   }
  1077. ,
  1078.   get profDir() {
  1079.     return this.globals.profDir; 
  1080.   }
  1081. ,
  1082.   get DMS() {
  1083.     return this.globals.DMS;
  1084.   }
  1085. ,
  1086.   get extensions() {
  1087.     var s=this.getPref("extensions","");
  1088.     return s?s.split(','):[];
  1089.   }
  1090. ,
  1091.   set extensions(v) {
  1092.     var arr=null;
  1093.     var s = typeof(v)=="string" 
  1094.       ? v : typeof(v)=="object" && typeof(v.join)=="function" 
  1095.         ? (arr=v).join(',') : "";
  1096.     this.setPref("extensions", s);
  1097.     return arr?arr:[];
  1098.   }
  1099. ,
  1100.   addExtension: function(ext) {
  1101.     if(ext) {
  1102.       var extensions=this.extensions;
  1103.       if(!this.extensionExists(ext,extensions)) {
  1104.         extensions[extensions.length]=ext;
  1105.         extensions.sort();
  1106.         this.extensions=extensions;
  1107.         return true;
  1108.       }
  1109.     }
  1110.     return false;
  1111.   }
  1112. ,
  1113.   removeExtension: function(ext) {
  1114.     var extensions=this.extensions;
  1115.     var j=this.indexOfExtension(ext,extensions);
  1116.     if(j>-1) {
  1117.       extensions.splice(j,1);
  1118.       this.extensions=extensions;
  1119.       return true;
  1120.     }
  1121.     return false;
  1122.   }
  1123. ,
  1124.   extensionExists: function(ext,extensions) {
  1125.     return this.indexOfExtension(ext,extensions)>-1;
  1126.   }
  1127. ,
  1128.   indexOfExtension: function(ext,extensions) {
  1129.     var ext=ext.toLowerCase();
  1130.     if(typeof(extensions)!="object") extensions=this.extensions;
  1131.     for(var j=extensions.length; j-->0;) {
  1132.       if(extensions[j].toLowerCase()==ext) return j;
  1133.     }
  1134.     return -1;
  1135.   }
  1136. ,
  1137.  
  1138.   get httpServer() {
  1139.     return (!this._httpServer) || this._httpServer.isDown
  1140.       ?this._httpServer=new FlashGotHttpServer(this)
  1141.       :this._httpServer;
  1142.   }
  1143.  
  1144. ,
  1145.   download: function(links, opType, dmName) {
  1146.     if(links.length==0) return false;
  1147.     if(!opType) opType=links.length>1?this.OP_SEL:this.OP_ONE;
  1148.     if(!dmName) dmName=this.defaultDM;
  1149.     const dm=this.globals.DMS[dmName];
  1150.     if(!dm) {
  1151.       this.log("FlashGot error: no download manager selected!");
  1152.       return false;
  1153.     }
  1154.     const encodedURLs=this.getPref(dm.codeName+".encode",this.getPref("encode",true));
  1155.     
  1156.     if(!links.postData) links.postData="";
  1157.     links.progress = { value: 0 };
  1158.     
  1159.     function parseDesc(link) {
  1160.         return link._description?link._description.replace(/\s+/g," ")
  1161.           :link._description = (typeof(link.title)=="string" && link.title.length>0
  1162.               ?link.title.replace(/\s+/g," "):link.innerHTML
  1163.                 ?link.innerHTML.replace(/\s+/g," ").replace(/<.*?>/g,"")
  1164.                 :"");
  1165.     }
  1166.  
  1167.     function prepareArray() {
  1168.       var l,j,len;
  1169.       for(j=0,len=links.length; j<len; j++) {
  1170.         l=links[j];
  1171.         links[j]={
  1172.            href: l.href,
  1173.           _description: parseDesc(l),
  1174.           _position: j
  1175.         };
  1176.       }
  1177.     }
  1178.     
  1179.     function processLinks() {
  1180.       const pg=links.progress;
  1181.       var len=links.length;
  1182.       if(len>1) {
  1183.         pg.value=12;
  1184.         // sort by href asc,_description.length desc
  1185.         dm.log("Sorting links");
  1186.         links.sort(function(a,b) {
  1187.           var aurl,burl,ades,bdes;
  1188.           return (aurl=a.href)>(burl=b.href)?1:aurl<burl?-1
  1189.               :(ades=a._description.length)>(bdes=b._description.length)?-1:ades<bdes?1
  1190.               :0;
  1191.         });
  1192.       }
  1193.       pg.value=24;
  1194.       //kill duplicates and sanitize
  1195.       dm.log("Killing duplicates and sanitizing");
  1196.       const escapeCheckNo=/(%[0-9a-f]{2,4})/i;
  1197.       const escapeCheckYes=/[\s]+/;
  1198.       var j,len,l,href,urlParts;
  1199.       var currentURL=null;
  1200.       var pos1,pos2;
  1201.       for(j=0,len=links.length; j<len; j++) {
  1202.         l=links[j];
  1203.         href=l.href;
  1204.         if( href==currentURL || (len>1 && !dm.isValidLink(href)) ) {
  1205.           links.splice(j--,1);
  1206.           --len;
  1207.         } else {
  1208.           currentURL=href;
  1209.           try {
  1210.             if(encodedURLs) { 
  1211.               if(escapeCheckYes.test(href) || !escapeCheckNo.test(href)) { 
  1212.                 href=encodeURI(href);
  1213.               }
  1214.               // workaround for malformed hash urls... I have still to think about it :-)
  1215.               while((pos1=href.indexOf('#'))>-1 
  1216.                 && ((pos2=href.indexOf('?'))<0 
  1217.                     || pos2>pos1 || pos1!=href.lastIndexOf('#'))) {
  1218.                 href=href.substring(0,pos1)+'%23'+href.substring(pos1+1);
  1219.               }
  1220.               l.href=href;
  1221.             } else {  
  1222.               l.href=decodeURI(href);
  1223.             }
  1224.           } catch(e) {
  1225.             dm.log("Problem "
  1226.               +encodedURLs?"escaping":"unescaping"
  1227.               +" URL "+href+": "+e.message);
  1228.           }
  1229.         }
  1230.         pg.value=25+25*j/len;
  1231.       }
  1232.       if(len>1) {
  1233.         dm.log("Sorting again "+links.length+" links");
  1234.         links.sort(function(a,b) {
  1235.           a=a._position; b=b._position;
  1236.           return a>b?1:a<b?-1:0;
  1237.         });
  1238.         dm.log("Preprocessing done");
  1239.       }
  1240.     }
  1241.     
  1242.  
  1243.  
  1244.     function trueDownload() {
  1245.       links.progress.value=50;
  1246.       dm.log("Starting download");
  1247.       dm.download(links,opType);
  1248.     }
  1249.     
  1250.     prepareArray();
  1251.     
  1252.     this.log("Processing "+links.length+" links");
  1253.     if(links.length>1 && this.bgProcessing) {
  1254.       this.log("(background processing)");
  1255.       this.runAsync(
  1256.         processLinks, 
  1257.         trueDownload);
  1258.     } else {
  1259.       this.log("(blocking processing)");
  1260.       processLinks();
  1261.       trueDownload();
  1262.     }
  1263.     return true;
  1264.   }
  1265. ,
  1266.   get bgProcessing() {
  1267.     return this.getPref("bgProcessing",true);
  1268.   }
  1269. ,
  1270.   runAsync: function(asyncJob,postJob) {
  1271.     const cc=Components.classes;
  1272.     const ci=Components.interfaces;
  1273.     var postRunnable=null;
  1274.     
  1275.     if(postJob) {
  1276.       postRunnable = cc["@mozilla.org/xpcomproxy;1"].getService(ci.nsIProxyObjectManager
  1277.         ).getProxyForObject(
  1278.           cc["@mozilla.org/event-queue-service;1"].getService(ci.nsIEventQueueService
  1279.               ).getSpecialEventQueue(ci.nsIEventQueueService.UI_THREAD_EVENT_QUEUE),
  1280.           ci.nsIRunnable, 
  1281.           {
  1282.             QueryInterface: function(iid) {
  1283.               if(iid.equals(ci.nsISupport) || iid.equals(ci.nsIRunnable)) {
  1284.                return this;
  1285.               }
  1286.               throw Components.results.NS_ERROR_NO_INTERFACE;
  1287.             },
  1288.             run: function() { postJob(); }
  1289.           }
  1290.         , 5); // 5 == PROXY_ALWAYS | PROXY_SYNC
  1291.     }
  1292.     
  1293.     const asyncRunnable={
  1294.       run: function() { 
  1295.         try {
  1296.           asyncJob();
  1297.         } catch(ex) {
  1298.         }
  1299.         if(postRunnable) postRunnable.run();
  1300.       }
  1301.     };
  1302.  
  1303.     const thread=cc['@mozilla.org/thread;1'].createInstance(ci.nsIThread);
  1304.     this.uiThread=thread.currentThread;
  1305.     thread.init(asyncRunnable, 0,  
  1306.       ci.nsIThread.PRIORITY_NORMAL, ci.nsIThread.SCOPE_GLOBAL, ci.nsIThread.STATE_JOINABLE);
  1307.   }
  1308. ,
  1309.   get prefService() {
  1310.     return Components.classes["@mozilla.org/preferences-service;1"].getService(
  1311.       Components.interfaces.nsIPrefService);
  1312.   }
  1313. ,
  1314.   getPref: function(name,def) {
  1315.     const IPC=Components.interfaces.nsIPrefBranch;
  1316.     const prefs=this.prefs;
  1317.     try {
  1318.       switch(prefs.getPrefType(name)) {
  1319.         case IPC.PREF_STRING:
  1320.           return prefs.getCharPref(name);
  1321.         case IPC.PREF_INT:
  1322.           return prefs.getIntPref(name);
  1323.         case IPC.PREF_BOOL:
  1324.           return prefs.getBoolPref(name);
  1325.       }
  1326.     } catch(e) {}
  1327.     return def;
  1328.   }
  1329. ,
  1330.   setPref: function(name,value) {
  1331.     const prefs=this.prefs;
  1332.     switch(typeof(value)) {
  1333.       case "string":
  1334.           prefs.setCharPref(name,value);
  1335.           break;
  1336.       case "boolean":
  1337.         prefs.setBoolPref(name,value);
  1338.         break;
  1339.       case "number":
  1340.         prefs.setIntPref(name,value);
  1341.         break;
  1342.       default:
  1343.         throw new Error("Unsupported type "+typeof(value)+" for preference "+name);
  1344.     }
  1345.   }
  1346. ,
  1347.   uiThread: null
  1348. ,
  1349.   get isUIThread() { 
  1350.     // returns true if current thread is equal to uiThread
  1351.     // if uiThread is not initialized, it gets initialized with current thread
  1352.     // and returned
  1353.     const uiThread=this.uiThread;
  1354.     const currentThread=this.currentThread;
  1355.     return uiThread?uiThread==currentThread:this.uiThread=currentThread;
  1356.   }
  1357. ,
  1358.   get currentThread() {
  1359.     return Components.classes['@mozilla.org/thread;1'
  1360.         ].createInstance(Components.interfaces.nsIThread).currentThread;
  1361.   }
  1362. ,
  1363.   _logFile: null,
  1364.   get logFile() {
  1365.     if(this._logFile==null) {
  1366.       this._logFile=this.profDir.clone();
  1367.       this._logFile.append("flashgot.log");
  1368.     }
  1369.     return this._logFile;
  1370.   }
  1371. ,
  1372.   logStream: null,
  1373.   logEnabled: false,
  1374.   log: function(msg) {
  1375.     if(this.logEnabled) {
  1376.       try {
  1377.         if(!this.logStream) {
  1378.           const logFile=this.logFile;
  1379.           const logStream=Components.classes["@mozilla.org/network/file-output-stream;1"
  1380.             ].createInstance(Components.interfaces.nsIFileOutputStream );
  1381.           logStream.init(logFile, 0x02 | 0x08 | 0x10, 0600, 0 );
  1382.           this.logStream=logStream;
  1383.           const header="*** Log start at "+new Date().toGMTString()+"\n";
  1384.           this.logStream.write(header,header.length);
  1385.         }
  1386.         
  1387.         if(msg!=null) {
  1388.           msg+="\n";
  1389.           this.logStream.write(msg,msg.length);
  1390.         }
  1391.         this.logStream.flush();
  1392.       } catch(ex) {
  1393.         if(this.isUIThread) dump(ex.message+"\noccurred logging this message:\n"+msg);
  1394.       }
  1395.     }
  1396.   }
  1397. ,
  1398.   dumpStack: function(msg) {
  1399.     dump( (msg?msg:"")+"\n"+new Error().stack+"\n");
  1400.   }
  1401. ,
  1402.   clearLog: function() {
  1403.     try {
  1404.       if(this.logStream) {
  1405.         try {
  1406.           this.logStream.close();
  1407.         } catch(eexx) {
  1408.           dump(eexx.message);
  1409.         }
  1410.       }
  1411.       if(this.logFile) this.logFile.remove(true);
  1412.       this.logStream=null;
  1413.       this.log(null);
  1414.     } catch(ex) { dump(ex.message); }
  1415.   } 
  1416. ,
  1417.   get windowMediator() {
  1418.     return Components.classes["@mozilla.org/appshell/window-mediator;1"
  1419.       ].getService(Components.interfaces.nsIWindowMediator);
  1420.   }
  1421. ,
  1422.   getWindow: function() {
  1423.     return this.windowMediator.getMostRecentWindow(null);
  1424.   }
  1425. ,
  1426.   checkLocale: function() {
  1427.     if(typeof(this._checkedLocale)=="undefined") {
  1428.       try {
  1429.        this._checkedLocale=(new IA_LocaleChecker("flashgot")).check();
  1430.       } catch(ex) {
  1431.         this.log("Locale check failed: "+ex);
  1432.         this._checkedLocale=null;
  1433.       }
  1434.     }
  1435.     return this._checkedLocale;
  1436.   }
  1437. ,
  1438.   _globals: null,
  1439.   get globals() {
  1440.     if(!this._initialized) {
  1441.       const currentThread=this.currentThread;
  1442.       if(currentThread==this._initThread) return this._globals;
  1443.       this.initGlobals();
  1444.       for(var t=0; !this._initialized; t++) {
  1445.         currentThread.sleep(100);
  1446.         if(t>60) {
  1447.           this._initialized=true;
  1448.           throw new Error("FlashGot initialization timeout");
  1449.         }
  1450.       }
  1451.     }
  1452.     return this._globals;
  1453.   }
  1454. ,
  1455.   PREFS_BRANCH: "flashgot."
  1456. ,
  1457.   _prefs: null,
  1458.   get prefs() {
  1459.     var prefs=this._prefs;
  1460.     if(!prefs) {
  1461.       this._prefs=prefs=this.prefService.getBranch(this.PREFS_BRANCH
  1462.         ).QueryInterface(Components.interfaces.nsIPrefBranchInternal);
  1463.     }
  1464.     return prefs;
  1465.   }
  1466. ,
  1467.   _initialized: false,
  1468.   _initializing: false,
  1469.   _initThread: null,
  1470.   _initException: null,
  1471.   initGlobals: function() {
  1472.     // this.dumpStack("FG.initGlobals()");
  1473.     if(this._globals || this._initializing || this._initialized) return;
  1474.     this._initializing=true;
  1475.     const service=this;
  1476.     this.runAsync(function() { service._asyncInit(); });
  1477.   }
  1478. ,
  1479.   _asyncInit: function() {
  1480.     function prepareTmp(t) {
  1481.       t.append("flashgot");
  1482.       t.createUnique(1,0700);
  1483.       return t;
  1484.     }
  1485.     try {
  1486.      
  1487.       this._initThread=this.currentThread;
  1488.       
  1489.       const startTime=new Date().getTime();
  1490.       const prefs=this.prefs;
  1491.       const cc=Components.classes;
  1492.       const ci=Components.interfaces; 
  1493.  
  1494.       const fileLocator=cc["@mozilla.org/file/directory_service;1"].getService(
  1495.         ci.nsIProperties);
  1496.       const profDir=fileLocator.get("ProfD",ci.nsIFile);
  1497.       var tmpDir;
  1498.       try {
  1499.         tmpDir=prepareTmp(prefs.getComplexValue("tmpDir", ci.nsILocalFile));
  1500.       } catch(ex) {
  1501.         tmpDir=prepareTmp(fileLocator.get("TmpD",ci.nsIFile));
  1502.       }
  1503.        
  1504.       this._globals={
  1505.         tmpDir: tmpDir,
  1506.         profDir: profDir,
  1507.         prefs: prefs
  1508.       };
  1509.       
  1510.       prefs.addObserver("", this, false);
  1511.       this.syncPrefs();
  1512.       
  1513.       this.log("Per-session init started");
  1514.         
  1515.       this._setupLegacyPrefs();
  1516.      
  1517.       this._globals.DMS=this.checkDownloadManagers();
  1518.       this.log("Per-session init done in "+(new Date().getTime()-startTime)+"ms");
  1519.     } catch(initEx) {
  1520.       this._initException=initEx;
  1521.     }
  1522.     this._initializing=false;
  1523.     this._initialized=true; 
  1524.   }
  1525. ,
  1526.   dispose: function() {
  1527.     this.prefs.removeObserver("",this);
  1528.     this._prefs=null;
  1529.     this._initializing=this._initialized=false;
  1530.     this._initThread=this._initException=null;
  1531.     this._globals=null;
  1532.   }
  1533. ,
  1534.   checkDownloadManagers: function() {
  1535.     
  1536.     const dms=FlashGotDM.dms;
  1537.     dms.found=false;
  1538.     
  1539.     
  1540.     var defaultDM=this.defaultDM;
  1541.     if(!dms[defaultDM]) defaultDM=null;
  1542.     var firstSupported=null;
  1543.     var dm;
  1544.     for(var j=dms.length; j-- >0;) {
  1545.       dm=dms[j];
  1546.       if(dm.supported ) {
  1547.         dms.found=true;
  1548.         firstSupported=dm.name;
  1549.       } else {
  1550.         this.log("Warning: download manager "+dm.name+" not found");
  1551.         if(defaultDM==dm.name) {
  1552.           defaultDM=null;
  1553.           this.log(dm.name+" was default download manager: resetting.");
  1554.         }
  1555.         if(dm.exclusive) {
  1556.           dms.splice(j,1);
  1557.         }
  1558.       }
  1559.     }
  1560.  
  1561.     if( (!defaultDM) && firstSupported!=null) {
  1562.       this.defaultDM=firstSupported;
  1563.       this.log("Default download manager set to "+this.defaultDM);
  1564.     } else if(!dms.found) {
  1565.       this.log("Serious warning! no supported download manager found...");
  1566.     } else {
  1567.       if(dms[defaultDM].exclusive) {
  1568.         for(j=dms.length; j-->0;) {
  1569.           if(dms[j].name!=defaultDM) {
  1570.             dms.splice(j,1);
  1571.           }
  1572.         }
  1573.       }
  1574.     }
  1575.     
  1576.     return dms;
  1577.   }
  1578. ,
  1579.   _cleaningup: false
  1580. ,
  1581.   cleanup: function() {
  1582.     if(this._cleaningup) return;
  1583.     try {
  1584.       this._cleaningup=true;
  1585.       this.log("Starting cleanup");
  1586.       if(this._httpServer) {
  1587.         this._httpServer.shutdown();
  1588.       }
  1589.       
  1590.       try {
  1591.         FlashGotDM.cleanup();
  1592.       } catch(eexx) {
  1593.         dump(eexx.message);
  1594.       }
  1595.       
  1596.       if(this._globals && this._globals.tmpDir.exists()) {
  1597.         this._globals.tmpDir.remove(true);
  1598.       }
  1599.       
  1600.       this.log("Cleanup done");
  1601.       if(this._logFile) try {
  1602.         if(this.logStream) this.logStream.close();
  1603.         var maxLogSize=Math.max(Math.min(this.getPref('maxLogSize',100000),1000000),50000);
  1604.         const logFile=this.logFile;
  1605.         const logSize=logFile.fileSize;
  1606.         if(logSize>maxLogSize) { // log rotation
  1607.           dump("Cutting log (size: "+logSize+", max: "+maxLogSize+")");
  1608.           const cc=Components.classes;
  1609.           const ci=Components.interfaces;
  1610.          
  1611.           const logBak=logFile.clone();
  1612.           logBak.leafName=logBak.leafName+".bak";
  1613.           if(logBak.exists()) logBak.remove(true);
  1614.           logFile.copyTo(logBak.parent,logBak.leafName);
  1615.           const is=cc['@mozilla.org/network/file-input-stream;1'].createInstance(
  1616.             ci.nsIFileInputStream);
  1617.           is.init(logBak,0x01, 0400, null);
  1618.           is.QueryInterface(ci.nsISeekableStream);
  1619.           is.seek(ci.nsISeekableStream.NS_SEEK_END,-maxLogSize);
  1620.           const sis=cc['@mozilla.org/scriptableinputstream;1'].createInstance(
  1621.           ci.nsIScriptableInputStream);
  1622.           sis.init(is);
  1623.           var buffer;
  1624.           var content="\n";
  1625.           var logStart=-1;
  1626.           while(buffer=sis.read(5000)) {
  1627.             content+=buffer;
  1628.             if((logStart=content.indexOf("\n*** Log start at "))>-1) { 
  1629.               content=content.substring(logStart);
  1630.               break;
  1631.             }
  1632.             content=buffer;
  1633.           }
  1634.           if(logStart>-1) {
  1635.              const os=cc["@mozilla.org/network/file-output-stream;1"].createInstance(
  1636.               ci.nsIFileOutputStream);
  1637.             os.init(logFile,0x02 | 0x08 | 0x20, 0700, 0);
  1638.             os.write(content,content.length);
  1639.             while(buffer=sis.read(20000)) {
  1640.               os.write(buffer,buffer.length);
  1641.             } 
  1642.             os.close();
  1643.           }
  1644.           sis.close();
  1645.         }
  1646.       } catch(eexx) {
  1647.         dump("Error cleaning up log: "+eexx.message);
  1648.       }
  1649.       this.logStream=null;
  1650.     } catch(ex) {
  1651.        this.log(ex.message);
  1652.     }
  1653.     this._cleaningup=false;
  1654.     this.dispose();
  1655.   }
  1656. ,
  1657.   readFile: function(file) {
  1658.     const cc=Components.classes;
  1659.     const ci=Components.interfaces; 
  1660.     
  1661.     const is = cc["@mozilla.org/network/file-input-stream;1"].createInstance(
  1662.           ci.nsIFileInputStream );
  1663.     is.init(file ,0x01, 0400, null);
  1664.     const sis = cc["@mozilla.org/scriptableinputstream;1"].createInstance(
  1665.       ci.nsIScriptableInputStream );
  1666.     sis.init(is);
  1667.     const res=sis.read(sis.available());
  1668.     is.close();
  1669.     return res;
  1670.   }
  1671. ,
  1672.   writeFile: function(file, content) {
  1673.     const cc=Components.classes;
  1674.     const ci=Components.interfaces;
  1675.     const unicodeConverter = cc["@mozilla.org/intl/scriptableunicodeconverter"].createInstance(
  1676.     ci.nsIScriptableUnicodeConverter);
  1677.     unicodeConverter.charset = "UTF-8";
  1678.     content=unicodeConverter.ConvertFromUnicode(content);
  1679.     const os=cc["@mozilla.org/network/file-output-stream;1"].createInstance(
  1680.       ci.nsIFileOutputStream);
  1681.     os.init(file,0x02,0700,0);
  1682.     os.write(content,content.length);
  1683.     os.close();
  1684.   }
  1685. ,
  1686.   _setupLegacyPrefs: function() {
  1687.     try {
  1688.       const file=this._globals.profDir.clone();
  1689.       const defFile=file.clone();
  1690.       file.append("pref");
  1691.       file.append("flashgot.js");
  1692.       defFile.append("prefs.js");
  1693.       if(file.exists() && defFile.exists()) {
  1694.         this.prefService.readUserPrefs(file);
  1695.         this.prefService.readUserPrefs(defFile);
  1696.         this.prefService.savePrefFile(null);
  1697.         file.remove(true);
  1698.       }
  1699.     } catch(e) {
  1700.       this.log(e.message);
  1701.     }
  1702.   }
  1703. ,
  1704.   showDMSReference: function() {
  1705.     this.getWindow().open("http://www.flashgot.net/dms","_blank");
  1706.   }
  1707. ,
  1708. _dirtyJobsDone: false,
  1709. doDirtyJobs: function() {
  1710.     if(this._dirtyJobsDone) {
  1711.       return; 
  1712.     }
  1713.     const cc=Components.classes;
  1714.     const ci=Components.interfaces;
  1715.     const locator = cc["@mozilla.org/file/directory_service;1"].getService(ci.nsIProperties);
  1716.     const chromeDirs=[locator.get("AChrom", ci.nsIFile).path,
  1717.       locator.get("UChrm", ci.nsIFile).path];
  1718.     const rdf = cc["@mozilla.org/rdf/rdf-service;1"].getService(ci.nsIRDFService);
  1719.     const rdfUtil  = cc["@mozilla.org/rdf/container-utils;1"].getService(ci.nsIRDFContainerUtils);
  1720.     const overlays=new Object();
  1721.     overlays['browser']
  1722.     =overlays['navigator']  
  1723.       =["chrome://flashgot/localeCheckOverlay.xul","chrome://flashgot/content/localeCheckOverlay.xul"];
  1724.     
  1725.     var url, ds, overlayName, overlay, literal, res, src;
  1726.     for(var j = 0; j < chromeDirs.length; j++) { // Application & Profile Dirs
  1727.       // Loop files
  1728.       var overlayDir=chromeDirs[j].replace(/\\/g,'/')+'/overlayinfo/';
  1729.       for(overlayName in overlays){
  1730.         try{
  1731.           url="file:///"+ overlayDir +overlayName+ '/content/overlays.rdf';
  1732.           ds = rdf.GetDataSourceBlocking(url).QueryInterface(ci.nsIRDFRemoteDataSource);
  1733.           // Loop overlay elements for this file
  1734.           var overlay=overlays[overlayName];
  1735.           for(var i = 0; i < overlay.length; i++){
  1736.             var literal=rdf.GetLiteral(overlay[i]);
  1737.             // Find Element
  1738.             var archs = ds.ArcLabelsIn(literal);
  1739.             while(archs.hasMoreElements()){
  1740.               var res = archs.getNext().QueryInterface(ci.nsIRDFResource);
  1741.               var sources = ds.GetSources(res, literal, true);
  1742.               
  1743.               // Get parent element for element
  1744.               while(sources.hasMoreElements()){
  1745.                 src = sources.getNext().QueryInterface(ci.nsIRDFResource);
  1746.                 
  1747.                 try {
  1748.                     ds.Unassert(src, res, literal);
  1749.                     this.log("Removed "+ literal.Value +" from "+url);
  1750.                 } catch(ex) {
  1751.                     this.log("Failed to remove "+ listeral.Value +" from "+url);
  1752.                     this.log(ex.message);
  1753.                 }
  1754.               }
  1755.             }
  1756.           }
  1757.           
  1758.           ds.Flush();
  1759.           this.log("Cleaned "+url);
  1760.          } catch(ex) {
  1761.             this.log("Failed to clean "+url);
  1762.             this.log(ex.message);
  1763.          }
  1764.       }
  1765.     }
  1766.     
  1767.     try {
  1768.       const xulFile=locator.get("ProfD", ci.nsIFile).clone();
  1769.       xulFile.append("XUL.mfl");
  1770.       xulFile.remove(true);
  1771.       this.log(xulFile.path+" deleted");
  1772.     } catch(ex) { 
  1773.       this.log("Failed to delete XUL.mfl: "+ex.message);
  1774.     }
  1775.     this._dirtyJobsDone=true;
  1776.   }
  1777. }
  1778.  
  1779. /* Data Swap HTTP server */
  1780.  
  1781. FlashGotHttpServer=function(fgService) {
  1782.   this.fgService=fgService;
  1783.   this.isDown=true;
  1784.   this.serverSocket=Components.classes['@mozilla.org/network/server-socket;1'
  1785.     ].createInstance(Components.interfaces.nsIServerSocket);
  1786.   this.serverSocket.init(-1,true,-1);
  1787.   this.isDown=false;
  1788.   this.serverSocket.asyncListen(this);
  1789.   this.tmpDir=this.fgService.globals.tmpDir.clone();
  1790.   this.tmpDir.append("httpserv");
  1791.   this.logEnabled=fgService.getPref("LeechGet.httpLog",false);
  1792.   this.log("Listening");
  1793. }
  1794.  
  1795. FlashGotHttpServer.prototype={
  1796.   documents: []
  1797. ,
  1798.   log: function(msg){
  1799.     if(this.logEnabled && this.fgService.logEnabled) {
  1800.       try {
  1801.         if(!this.logStream) {
  1802.           const logFile=this.tmpDir.clone();
  1803.           logFile.append("server.log");
  1804.           logFile.createUnique(0,0600);
  1805.           const logStream=Components.classes["@mozilla.org/network/file-output-stream;1"
  1806.             ].createInstance(Components.interfaces.nsIFileOutputStream );
  1807.           logStream.init(logFile, 0x02 | 0x10, 0600, 0 );
  1808.           this.logStream=logStream;
  1809.         }
  1810.         msg="HttpServer:"+this.serverSocket.port+" - "+msg+"\n";
  1811.         this.logStream.write(msg,msg.length);
  1812.         this.logStream.flush();
  1813.       } catch(ex) {}
  1814.     }
  1815.   }
  1816. ,
  1817.   onSocketAccepted: function(ss,transport) {
  1818.     this.log("Accepted request from "
  1819.       +transport.host+":"+transport.port);
  1820.      try {
  1821.         new FlashGotHttpHandler(this,transport);
  1822.      } catch(ex) {
  1823.        this.log(ex.message);
  1824.      }
  1825.   }
  1826. ,
  1827.   onStopListening: function(ss,status) {
  1828.     this.isDown=true;
  1829.     if(this.logStream) {
  1830.       this.log("Stopped, status "+status);
  1831.     }
  1832.   }
  1833. ,
  1834.   randomName: function(len) {
  1835.     if(!len) len=8;
  1836.     var name="";
  1837.     for(var j=len; j-->0;) {
  1838.       name+=String.fromCharCode(65+(Math.round(Math.random()*25)));
  1839.     }
  1840.     return name;
  1841.   }
  1842. ,
  1843.   addDoc: function(docSource,docType) {
  1844.     if(typeof(docType)=="undefined") docType="html";
  1845.     var file=this.tmpDir.clone();
  1846.     file.append(this.randomName()+"."+docType);
  1847.     file.createUnique(0,0600);
  1848.     this.fgService.writeFile(file,docSource);
  1849.     const name=file.leafName;
  1850.     this.documents.push(name);
  1851.     return "http://localhost:"+this.serverSocket.port+"/"+name;
  1852.   }
  1853. ,
  1854.   getDoc: function(name) {
  1855.     const docs=this.documents;
  1856.     for(var j=docs.length; j-->0;) {
  1857.       if(docs[j]==name) break;
  1858.     }
  1859.     if(j<0) return null;
  1860.     var file=this.tmpDir.clone();
  1861.     file.append(name);
  1862.     return file.exists()?this.fgService.readFile(file):null;
  1863.   }
  1864. ,  
  1865.   shutdown: function() {
  1866.     try {
  1867.       this.log("Shutting down");
  1868.       if(this.logStream) {
  1869.         this.logStream.close();
  1870.         this.logStream=null;
  1871.       }
  1872.       this.serverSocket.close();
  1873.     } catch(ex) {}
  1874.   }
  1875. }
  1876.  
  1877. function FlashGotHttpHandler(server,transport) {
  1878.   this.server=server;
  1879.   this.inputBuffer="";
  1880.   this.transport=transport;
  1881.   this.asyncStream=transport.openInputStream(0,0,0).QueryInterface(
  1882.     Components.interfaces.nsIAsyncInputStream);
  1883.   this.log("Waiting for request data...");
  1884.   
  1885.   const nsIThread=Components.interfaces.nsIThread;
  1886.   var thread=Components.classes['@mozilla.org/thread;1'].createInstance(nsIThread);
  1887.   thread.init(this, 0,  nsIThread.PRIORITY_NORMAL, nsIThread.SCOPE_GLOBAL,nsIThread.STATE_JOINABLE);
  1888.   this.log("Thread started");
  1889. }
  1890.  
  1891. FlashGotHttpHandler.prototype = {
  1892.   log: function(msg) {
  1893.     this.server.log(this.transport.host+":"+this.transport.port+" - "+msg);
  1894.   }
  1895. ,
  1896.   run: function() {
  1897.      this.log("I'm in thread");
  1898.      this.asyncStream.asyncWait(this,0,0,null);
  1899.      this.log("Asyncwait issued");
  1900.   }
  1901. ,  
  1902.   onInputStreamReady: function(asyncStream) {
  1903.     const bytesCount=asyncStream.available();
  1904.     this.log("Input stream ready, available bytes: "+bytesCount);
  1905.     if(bytesCount) {
  1906.       const inStream=Components.classes['@mozilla.org/scriptableinputstream;1'].createInstance(
  1907.         Components.interfaces.nsIScriptableInputStream);
  1908.       inStream.init(asyncStream);
  1909.       var chunk=inStream.read(inStream.available());
  1910.       this.log("Received data chunk "+chunk);
  1911.       var buffer=this.inputBuffer.concat(chunk);
  1912.       var eor=chunk.length==0?buffer.length:buffer.search("\r?\n\r?\n");
  1913.       this.log("EOR: "+eor);
  1914.       if(eor>-1) {
  1915.         var request=buffer.substring(0,eor);
  1916.         this.inputBuffer="";
  1917.         this.handleRequest(request);
  1918.         this.close();
  1919.       } else {
  1920.         this.inputBuffer=buffer;
  1921.         this.run();
  1922.       }
  1923.     } else {
  1924.       this.close();
  1925.     }
  1926.   }
  1927. ,
  1928.   close: function() {
  1929.     this.asyncStream.close();
  1930.   }
  1931. ,
  1932.   buildResponse: function(body,status,contentType) {
  1933.     if(!contentType) contentType="text/html";
  1934.     if(!status) {
  1935.       status="200 OK";
  1936.     } else {
  1937.       body="<h1>"+status+"</h1><pre>"
  1938.         +body
  1939.         +"</pre><h5>FlashGot Http Server v. 0.1</h5>"
  1940.     }
  1941.     return "HTTP/1.1 "+status+"\r\nContent-type: "+contentType+"\r\n\r\n"+body;
  1942.   }
  1943. ,
  1944.   handleRequest: function(request) {
  1945.     var response;
  1946.     var match;
  1947.     this.log("Handling request\n"+request);
  1948.     try {
  1949.       if(!(match=request.match(/^GET \/([^\s]*)/))) {
  1950.         response=this.buildResponse(request,"400 Bad Request"); 
  1951.       } else {
  1952.         var doc=this.server.getDoc(match[1]);
  1953.         
  1954.         if(doc==null) {
  1955.           response=this.buildResponse(request,"404 Not Found");
  1956.         } else {
  1957.           response=this.buildResponse(doc);
  1958.         }
  1959.       }
  1960.     } catch(ex) {
  1961.       response=this.buildResponse(ex.message+"\n"+request,"500 Server error");
  1962.     }
  1963.     var out=this.transport.openOutputStream(1,0,0);
  1964.     out.write(response,response.length);
  1965.     out.close();
  1966.     this.log("Sent response\n"+response);
  1967.   } 
  1968. }
  1969.  
  1970.  
  1971. /* Locale check */
  1972. IA_LocaleChecker=function(module) {  
  1973.   this.module=module;
  1974. }
  1975.  
  1976. IA_LocaleChecker.prototype = {
  1977.  
  1978.   check: function() {
  1979.     const module=this.module;
  1980.     const cc=Components.classes;
  1981.     const ci=Components.interfaces;
  1982.  
  1983.     const localeURL="chrome://"+module+"/locale";
  1984.     
  1985.     try {
  1986.       const window=cc['@mozilla.org/appshell/appShellService;1'
  1987.             ].getService(ci.nsIAppShellService
  1988.         ).hiddenDOMWindow
  1989.     } catch(ex) {}
  1990.     
  1991.     function log(msg) {
  1992.       dump("LocaleChecker: "+msg+"\n");
  1993.     }
  1994.   
  1995.     function checkLocale(locale) {
  1996.       function isLocaleSelected() {
  1997.         try {
  1998.           return chreg.getSelectedLocale(module)==locale;
  1999.         } catch(ex) {
  2000.           log(ex.message);
  2001.           return false;
  2002.         }
  2003.       }
  2004.       
  2005.       try {
  2006.         if(!isLocaleSelected()) {
  2007.           log("trying to select locale "+locale);
  2008.           chreg.selectLocaleForPackage(locale,module,true);
  2009.           if(isLocaleSelected()) {
  2010.             
  2011.             for(var j=2; j-->0;) {
  2012.               chreg.checkForNewChrome();
  2013.               chreg.reloadChrome();
  2014.               log("chrome reloaded! "+j);
  2015.             }
  2016.             
  2017.           } else {
  2018.             log("Can't select locale "+locale+" for "+module); 
  2019.             locale=null;
  2020.           }
  2021.         }
  2022.       } catch(ex) {
  2023.         log("Error checking/setting locale "+locale+" for "+module+"\n"+ex.message);
  2024.         locale=null;
  2025.       }
  2026.       return locale;
  2027.     }
  2028.      
  2029.     var chreg=cc["@mozilla.org/chrome/chrome-registry;1"].getService(ci.nsIChromeRegistry);
  2030.     try {
  2031.       if(ci.nsIXULChromeRegistry) chreg.QueryInterface(ci.nsIXULChromeRegistry);
  2032.       return; // it is Firefox, we can leave safely now!
  2033.     } catch(ex) { log(ex.message); }
  2034.     try {
  2035.       if(ci.nsIChromeRegistrySea) chreg.QueryInterface(ci.nsIChromeRegistrySea);
  2036.     } catch(ex) { log(ex.message); }
  2037.     
  2038.     var browserLocale=null;
  2039.     try {
  2040.       browserLocale=chreg.getSelectedLocale("browser",true);
  2041.     } catch(ex1) {
  2042.       log("It seems no locale is selected for browser... trying with navigator");
  2043.       try {
  2044.         browserLocale=chreg.getSelectedLocale("navigator",true);
  2045.       } catch(ex2) {
  2046.         log("It seems no locale is selected for navigator...");
  2047.       }
  2048.     }
  2049.     var ret=null;
  2050.     if(browserLocale==null
  2051.       || !(ret=checkLocale(browserLocale))) {
  2052.         ret=checkLocale("en-US");
  2053.     }
  2054.     return ret;
  2055.   }
  2056. }
  2057.  
  2058.  
  2059. // XPCOM Scaffolding code
  2060.  
  2061. // component defined in this file
  2062.  
  2063. const SERVICE_NAME="FlashGot Service";
  2064. const SERVICE_CID =
  2065.     Components.ID("{2a55fc5c-7b31-4ee1-ab15-5ee2eb428cbe}");
  2066. const SERVICE_CTRID =
  2067.     "@maone.net/flashgot-service;1";
  2068.     
  2069. const SERVICE_CONSTRUCTOR=FlashGotService;
  2070.  
  2071.  
  2072. // interfaces implemented by this component
  2073. const SERVICE_IIDS = 
  2074. [ 
  2075. Components.interfaces.nsIObserver,
  2076. Components.interfaces.nsISupports,
  2077. Components.interfaces.nsISupportsWeakReference,
  2078. Components.interfaces.nsIURIContentListener
  2079. ];
  2080.  
  2081. // Factory object
  2082. const SERVICE_FACTORY = {
  2083.   _instance: null,
  2084.   createInstance: function (outer, iid) {
  2085.     if (outer != null)
  2086.         throw Components.results.NS_ERROR_NO_AGGREGATION;
  2087.  
  2088.     xpcom_checkInterfaces(iid,SERVICE_IIDS,Components.results.NS_ERROR_INVALID_ARG);
  2089.     // kept this for flexibility sake, but we're really adopting an
  2090.     // early instantiation and late init singleton pattern
  2091.     return this._instance==null?this._instance=new SERVICE_CONSTRUCTOR():this._instance;
  2092.   }
  2093. };
  2094.  
  2095. function xpcom_checkInterfaces(iid,iids,ex) {
  2096.   for(var j=iids.length; j-- >0;) {
  2097.     if(iid.equals(iids[j])) return true;
  2098.   }
  2099.   throw ex;
  2100. }
  2101.  
  2102. // Module
  2103.  
  2104. var Module = new Object();
  2105. Module.firstTime=true;
  2106. Module.registerSelf = function (compMgr, fileSpec, location, type) {
  2107.   if(this.firstTime) {
  2108.    
  2109.     debug("*** Registering "+SERVICE_CTRID+".\n");
  2110.     
  2111.     compMgr.QueryInterface(Components.interfaces.nsIComponentRegistrar
  2112.       ).registerFactoryLocation(SERVICE_CID,
  2113.       SERVICE_NAME,
  2114.       SERVICE_CTRID, 
  2115.       fileSpec,
  2116.       location, 
  2117.       type);
  2118.       
  2119.     Components.classes['@mozilla.org/categorymanager;1'].getService(
  2120.       Components.interfaces.nsICategoryManager
  2121.      ).addCategoryEntry("app-startup",
  2122.         SERVICE_NAME, "service," + SERVICE_CTRID, true, true, null);
  2123.       
  2124.     this.firstTime=false;
  2125.   } 
  2126. }
  2127. Module.unregisterSelf = function(compMgr, fileSpec, location) {
  2128.   compMgr.QueryInterface(Components.interfaces.nsIComponentRegistrar
  2129.     ).unregisterFactoryLocation(SERVICE_CID, fileSpec);
  2130.   Components.classes['@mozilla.org/categorymanager;1'].getService(
  2131.       Components.interfaces.nsICategoryManager
  2132.      ).deleteCategoryEntry("app-startup",SERVICE_NAME, true);
  2133. }
  2134.  
  2135. Module.getClassObject = function (compMgr, cid, iid) {
  2136.   if(cid.equals(SERVICE_CID))
  2137.     return SERVICE_FACTORY;
  2138.  
  2139.   if (!iid.equals(Components.interfaces.nsIFactory))
  2140.     throw Components.results.NS_ERROR_NOT_IMPLEMENTED;
  2141.   
  2142.   throw Components.results.NS_ERROR_NO_INTERFACE;
  2143.     
  2144. }
  2145.  
  2146. Module.canUnload = function(compMgr) {
  2147.   return true;
  2148. }
  2149.  
  2150. // entrypoint
  2151. function NSGetModule(compMgr, fileSpec) {
  2152.   return Module;
  2153. }
  2154.  
  2155.  
  2156.  
  2157.