var fs = require('fs');
var PNG = require('../lib/png').PNG;
var test = require('tape');

var noLargeOption = process.argv.indexOf("nolarge") >= 0;

fs.readdir(__dirname + '/in/', function (err, files) {
  if (err) throw err;

  files = files.filter(function (file) {
    return (!noLargeOption || !file.match(/large/i)) && Boolean(file.match(/\.png$/i));
  });

  console.log("Converting images");

  files.forEach(function (file) {

    var expectedError = false;
    if (file.match(/^x/)) {
      expectedError = true;
    }

    test('convert sync - ' + file, function (t) {

      t.timeoutAfter(1000 * 60 * 5);

      var data = fs.readFileSync(__dirname + '/in/' + file);
      try {
        var png = PNG.sync.read(data);
      } catch (e) {
        if (!expectedError) {
          t.fail('Unexpected error parsing..' + file + '\n' + e.message + "\n" + e.stack);
        } else {
          t.pass("completed");
        }
        return t.end();
      }

      if (expectedError) {
        t.fail("Sync: Error expected, parsed fine .. - " + file);
        return t.end();
      }

      var outpng = new PNG();
      outpng.gamma = png.gamma;
      outpng.data = png.data;
      outpng.width = png.width;
      outpng.height = png.height;
      outpng.pack()
        .pipe(fs.createWriteStream(__dirname + '/outsync/' + file)
          .on("finish", function () {
            t.pass("completed");
            t.end();
          }));
    });

    test('convert async - ' + file, function (t) {

      t.timeoutAfter(1000 * 60 * 5);

      fs.createReadStream(__dirname + '/in/' + file)
        .pipe(new PNG())
        .on('error', function (err) {
          if (!expectedError) {
            t.fail("Async: Unexpected error parsing.." + file + '\n' + err.message + '\n' + err.stack);
          } else {
            t.pass("completed");
          }
          t.end();
        })
        .on('parsed', function () {

          if (expectedError) {
            t.fail("Async: Error expected, parsed fine .." + file);
            return t.end();
          }

          this.pack()
            .pipe(
            fs.createWriteStream(__dirname + '/out/' + file)
              .on("finish", function () {
                t.pass("completed");
                t.end();
              }));
        });
    });
  });
});