//
// Test that data can be appended to a cache entry even when the data is 
// compressed by the cache compression feature - bug 648429.
//
const Cc = Components.classes;
const Ci = Components.interfaces;
const Cr = Components.results;

function write_and_check(str, data, len)
{
  var written = str.write(data, len);
  if (written != len) {
    do_throw("str.write has not written all data!\n" +
             "  Expected: " + len  + "\n" +
             "  Actual: " + written + "\n");
  }
}

function TestAppend(compress, callback)
{
  this._compress = compress;
  this._callback = callback;
  this.run();
}

TestAppend.prototype = {
  _compress: false,
  _callback: null,

  run: function() {
    evict_cache_entries();
    asyncOpenCacheEntry("data",
                        "HTTP",
                        Ci.nsICache.STORE_ON_DISK,
                        Ci.nsICache.ACCESS_WRITE,
                        this.writeData.bind(this));
  },

  writeData: function(status, entry) {
    do_check_eq(status, Cr.NS_OK);
    if (this._compress)
      entry.setMetaDataElement("uncompressed-len", "0");
    var os = entry.openOutputStream(0);
    write_and_check(os, "12345", 5);
    os.close();
    entry.close();
    asyncOpenCacheEntry("data",
                        "HTTP",
                        Ci.nsICache.STORE_ON_DISK,
                        Ci.nsICache.ACCESS_READ_WRITE,
                        this.appendData.bind(this));
  },

  appendData: function(status, entry) {
    do_check_eq(status, Cr.NS_OK);
    var os = entry.openOutputStream(entry.storageDataSize);
    write_and_check(os, "abcde", 5);
    os.close();
    entry.close();

    asyncOpenCacheEntry("data",
                        "HTTP",
                        Ci.nsICache.STORE_ON_DISK,
                        Ci.nsICache.ACCESS_READ,
                        this.checkData.bind(this));
  },

  checkData: function(status, entry) {
    do_check_eq(status, Cr.NS_OK);
    var wrapper = Cc["@mozilla.org/scriptableinputstream;1"].
                  createInstance(Ci.nsIScriptableInputStream);
    wrapper.init(entry.openInputStream(0));
    var str = wrapper.read(wrapper.available());
    do_check_eq(str.length, 10);
    do_check_eq(str, "12345abcde");

    wrapper.close();
    entry.close();

    do_execute_soon(this._callback);
  }
};

function run_test() {
  do_get_profile();
  new TestAppend(false, run_test2);
  do_test_pending();
}

function run_test2() {
  new TestAppend(true, do_test_finished);
}