/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements. See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership. The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * 'License'); you may not use this file except in compliance
 * with the License. You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * 'AS IS' BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied. See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */

// This is the Node.js test driver for the standard Apache Thrift
// test service. The driver invokes every function defined in the
// Thrift Test service with a representative range of parameters.
//
// The ThriftTestDriver function requires a client object
// connected to a server hosting the Thrift Test service and
// supports an optional callback function which is called with
// a status message when the test is complete.

import test = require("tape");
import ttypes = require("./gen-nodejs/ThriftTest_types");
import ThriftTest = require("./gen-nodejs/ThriftTest");
import thrift = require("thrift");
import Q = thrift.Q;
import TException = thrift.Thrift.TException;
var Int64 = require("node-int64");
import testCases = require("./test-cases");

export function ThriftTestDriver(
  client: ThriftTest.Client,
  callback: (status: string) => void,
) {
  test("NodeJS Style Callback Client Tests", function (assert) {
    var checkRecursively = makeRecursiveCheck(assert);

    function makeAsserter(assertionFn: (a: any, b: any, msg?: string) => void) {
      return function (c: (string | any)[]) {
        var fnName = c[0];
        var expected = c[1];
        (<any>client)[fnName](expected, function (err: any, actual: any) {
          assert.error(err, fnName + ": no callback error");
          assertionFn(actual, expected, fnName);
        });
      };
    }

    testCases.simple.forEach(makeAsserter(assert.equal));
    testCases.simpleLoose.forEach(
      makeAsserter(function (a, e, m) {
        assert.ok(a == e, m);
      }),
    );
    testCases.deep.forEach(makeAsserter(assert.deepEqual));

    client.testMapMap(42, function (err, response) {
      var expected: typeof response = {
        "4": { "1": 1, "2": 2, "3": 3, "4": 4 },
        "-4": { "-4": -4, "-3": -3, "-2": -2, "-1": -1 },
      };
      assert.error(err, "testMapMap: no callback error");
      assert.deepEqual(expected, response, "testMapMap");
    });

    client.testStruct(testCases.out, function (err, response) {
      assert.error(err, "testStruct: no callback error");
      checkRecursively(testCases.out, response, "testStruct");
    });

    client.testNest(testCases.out2, function (err, response) {
      assert.error(err, "testNest: no callback error");
      checkRecursively(testCases.out2, response, "testNest");
    });

    client.testInsanity(testCases.crazy, function (err, response) {
      assert.error(err, "testInsanity: no callback error");
      checkRecursively(testCases.insanity, response, "testInsanity");
    });

    client.testException("TException", function (err, response) {
      assert.ok(err instanceof TException, "testException: correct error type");
      assert.ok(!Boolean(response), "testException: no response");
    });

    client.testException("Xception", function (err, response) {
      assert.ok(
        err instanceof ttypes.Xception,
        "testException: correct error type",
      );
      assert.ok(!Boolean(response), "testException: no response");
      assert.equal(err.errorCode, 1001, "testException: correct error code");
      assert.equal(
        "Xception",
        err.message,
        "testException: correct error message",
      );
    });

    client.testException("no Exception", function (err, response) {
      assert.error(err, "testException: no callback error");
      assert.ok(!Boolean(response), "testException: no response");
    });

    client.testOneway(0, function (err, response) {
      assert.error(err, "testOneway: no callback error");
      assert.strictEqual(response, undefined, "testOneway: void response");
    });

    checkOffByOne(function (done) {
      client.testI32(-1, function (err, response) {
        assert.error(err, "checkOffByOne: no callback error");
        assert.equal(-1, response);
        assert.end();
        done();
      });
    }, callback);
  });
}

export function ThriftTestDriverPromise(
  client: ThriftTest.Client,
  callback: (status: string) => void,
) {
  test("Q Promise Client Tests", function (assert) {
    var checkRecursively = makeRecursiveCheck(assert);

    function fail(msg: string) {
      return function (error, response) {
        if (error !== null) {
          assert.fail(msg);
        }
      };
    }

    function makeAsserter(assertionFn: (a: any, b: any, msg?: string) => void) {
      return function (c: (string | any)[]) {
        var fnName = c[0];
        var expected = c[1];
        (<any>client)
          [fnName](expected)
          .then(function (actual: any) {
            assertionFn(actual, expected, fnName);
          })
          .fail(fail("fnName"));
      };
    }

    testCases.simple.forEach(makeAsserter(assert.equal));
    testCases.simpleLoose.forEach(
      makeAsserter(function (a, e, m) {
        assert.ok(a == e, m);
      }),
    );
    testCases.deep.forEach(makeAsserter(assert.deepEqual));

    Q.resolve(client.testStruct(testCases.out))
      .then(function (response) {
        checkRecursively(testCases.out, response, "testStruct");
      })
      .fail(fail("testStruct"));

    Q.resolve(client.testNest(testCases.out2))
      .then(function (response) {
        checkRecursively(testCases.out2, response, "testNest");
      })
      .fail(fail("testNest"));

    Q.resolve(client.testInsanity(testCases.crazy))
      .then(function (response) {
        checkRecursively(testCases.insanity, response, "testInsanity");
      })
      .fail(fail("testInsanity"));

    Q.resolve(client.testException("TException"))
      .then(function (response) {
        fail("testException: TException");
      })
      .fail(function (err) {
        assert.ok(err instanceof TException);
      });

    Q.resolve(client.testException("Xception"))
      .then(function (response) {
        fail("testException: Xception");
      })
      .fail(function (err) {
        assert.ok(err instanceof ttypes.Xception);
        assert.equal(err.errorCode, 1001);
        assert.equal("Xception", err.message);
      });

    Q.resolve(client.testException("no Exception"))
      .then(function (response) {
        assert.equal(undefined, response); //void
      })
      .fail(fail("testException"));

    client.testOneway(0, fail("testOneway: should not answer"));

    checkOffByOne(function (done) {
      Q.resolve(client.testI32(-1))
        .then(function (response) {
          assert.equal(-1, response);
          assert.end();
          done();
        })
        .fail(fail("checkOffByOne"));
    }, callback);
  });
}

// Helper Functions
// =========================================================

function makeRecursiveCheck(assert: test.Test) {
  return function (map1: any, map2: any, msg: string) {
    var equal = true;

    var equal = checkRecursively(map1, map2);

    assert.ok(equal, msg);

    // deepEqual doesn't work with fields using node-int64
    function checkRecursively(map1: any, map2: any): boolean {
      if (!(typeof map1 !== "function" && typeof map2 !== "function")) {
        return false;
      }
      if (!map1 || typeof map1 !== "object") {
        //Handle int64 types (which use node-int64 in Node.js JavaScript)
        if (
          typeof map1 === "number" &&
          typeof map2 === "object" &&
          map2.buffer &&
          map2.buffer instanceof Buffer &&
          map2.buffer.length === 8
        ) {
          var n = new Int64(map2.buffer);
          return map1 === n.toNumber();
        } else {
          return map1 == map2;
        }
      } else {
        return Object.keys(map1).every(function (key) {
          return checkRecursively(map1[key], map2[key]);
        });
      }
    }
  };
}

function checkOffByOne(
  done: (callback: () => void) => void,
  callback: (message: string) => void,
) {
  var retry_limit = 30;
  var retry_interval = 100;
  var test_complete = false;
  var retrys = 0;

  /**
   * redo a simple test after the oneway to make sure we aren't "off by one" --
   * if the server treated oneway void like normal void, this next test will
   * fail since it will get the void confirmation rather than the correct
   * result. In this circumstance, the client will throw the exception:
   *
   * Because this is the last test against the server, when it completes
   * the entire suite is complete by definition (the tests run serially).
   */
  done(function () {
    test_complete = true;
  });

  //We wait up to retry_limit * retry_interval for the test suite to complete
  function TestForCompletion() {
    if (test_complete && callback) {
      callback("Server successfully tested!");
    } else {
      if (++retrys < retry_limit) {
        setTimeout(TestForCompletion, retry_interval);
      } else if (callback) {
        callback(
          "Server test failed to complete after " +
            (retry_limit * retry_interval) / 1000 +
            " seconds",
        );
      }
    }
  }

  setTimeout(TestForCompletion, retry_interval);
}