netwerk/test/unit/test_bug455311.js

   1 const Ci = Components.interfaces;
   2 const Cc = Components.classes;
   3 const Cr = Components.results;
   4 const isWindows = ("@mozilla.org/windows-registry-key;1" in Cc);
   5 const isLinux = ("@mozilla.org/gnome-gconf-service;1" in Cc);
   6
   7 function getLinkFile()
   8 {
   9   if (isWindows) {
  10     return do_get_file("netwerk/test/unit/test_link.url");
  11   }
  12   if (isLinux) {
  13     return do_get_file("netwerk/test/unit/test_link.desktop");
  14   }
  15   do_throw("Unexpected platform");
  16   return null;
  17 }
  18
  19 const ios = Cc["@mozilla.org/network/io-service;1"].getService(Ci.nsIIOService);
  20 var link;
  21 var linkURI;
  22 const newURI = ios.newURI("http://www.mozilla.org/", null, null);
  23
  24 function NotificationCallbacks(origURI, newURI)
  25 {
  26   this._origURI = origURI;
  27   this._newURI = newURI;
  28 }
  29 NotificationCallbacks.prototype = {
  30   QueryInterface: function(iid)
  31   {
  32     if (iid.equals(Ci.nsISupports) ||
  33         iid.equals(Ci.nsIInterfaceRequestor) ||
  34         iid.equals(Ci.nsIChannelEventSink)) {
  35       return this;
  36     }
  37     throw Cr.NS_ERROR_NO_INTERFACE;
  38   },
  39   getInterface: function (iid)
  40   {
  41     return this.QueryInterface(iid);
  42   },
  43   onChannelRedirect: function(oldChan, newChan, flags)
  44   {
  45     do_check_eq(oldChan.URI.spec, this._origURI.spec);
  46     do_check_eq(oldChan.URI, this._origURI);
  47     do_check_eq(oldChan.originalURI.spec, this._origURI.spec);
  48     do_check_eq(oldChan.originalURI, this._origURI);
  49     do_check_eq(newChan.originalURI.spec, this._newURI.spec);
  50     do_check_eq(newChan.originalURI, newChan.URI);
  51     do_check_eq(newChan.URI.spec, this._newURI.spec);
  52     throw Cr.NS_ERROR_ABORT;
  53   }
  54 };
  55
  56 function RequestObserver(origURI, newURI, nextTest)
  57 {
  58   this._origURI = origURI;
  59   this._newURI = newURI;
  60   this._nextTest = nextTest;
  61 }
  62 RequestObserver.prototype = {
  63   QueryInterface: function(iid)
  64   {
  65     if (iid.equals(Ci.nsISupports) ||
  66         iid.equals(Ci.nsIRequestObserver) ||
  67         iid.equals(Ci.nsIStreamListener)) {
  68       return this;
  69     }
  70     throw Cr.NS_ERROR_NO_INTERFACE;
  71   },
  72   onStartRequest: function (req, ctx)
  73   {
  74     var chan = req.QueryInterface(Ci.nsIChannel);
  75     do_check_eq(chan.URI.spec, this._origURI.spec);
  76     do_check_eq(chan.URI, this._origURI);
  77     do_check_eq(chan.originalURI.spec, this._origURI.spec);
  78     do_check_eq(chan.originalURI, this._origURI);
  79   },
  80   onDataAvailable: function(req, ctx, stream, offset, count)
  81   {
  82     do_throw("Unexpected call to onDataAvailable");
  83   },
  84   onStopRequest: function (req, ctx, status)
  85   {
  86     var chan = req.QueryInterface(Ci.nsIChannel);
  87     try {
  88       do_check_eq(chan.URI.spec, this._origURI.spec);
  89       do_check_eq(chan.URI, this._origURI);
  90       do_check_eq(chan.originalURI.spec, this._origURI.spec);
  91       do_check_eq(chan.originalURI, this._origURI);
  92       do_check_eq(status, Cr.NS_ERROR_ABORT);
  93       do_check_false(chan.isPending());
  94     } catch(e) {}
  95     this._nextTest();
  96   }
  97 };
  98
  99 function test_cancel()
 100 {
 101   var chan = ios.newChannelFromURI(linkURI);
 102   do_check_eq(chan.URI, linkURI);
 103   do_check_eq(chan.originalURI, linkURI);
 104   chan.asyncOpen(new RequestObserver(linkURI, newURI, do_test_finished), null);
 105   do_check_true(chan.isPending());
 106   chan.cancel(Cr.NS_ERROR_ABORT);
 107   do_check_true(chan.isPending());
 108 }
 109
 110 function run_test()
 111 {
 112   if (!isWindows && !isLinux) {
 113     return;
 114   }
 115
 116   link = getLinkFile();
 117   linkURI = ios.newFileURI(link);
 118
 119   do_test_pending();
 120
 121   var chan = ios.newChannelFromURI(linkURI);
 122   do_check_eq(chan.URI, linkURI);
 123   do_check_eq(chan.originalURI, linkURI);
 124   chan.notificationCallbacks = new NotificationCallbacks(linkURI, newURI);
 125   chan.asyncOpen(new RequestObserver(linkURI, newURI, test_cancel), null);
 126   do_check_true(chan.isPending());
 127 }