'use strict';

const mm = require('mm');
const path = require('path');
const antpb = require('antpb');
const assert = require('assert');
const protocol = require('sofa-bolt-node');
const RpcClient = require('../..').client.RpcClient;
const RpcConsumer = require('../..').client.RpcConsumer;
const ZookeeperRegistry = require('../../').registry.ZookeeperRegistry;
const server = require('../supports/pb_server');
const logger = console;

const proto = antpb.loadAll(path.join(__dirname, '../fixtures/proto'));
protocol.setOptions({ proto });

describe('test/client/client.test.js', () => {
  let registry;
  before(async () => {
    registry = new ZookeeperRegistry({
      logger,
      address: '127.0.0.1:2181',
    });
    await Promise.all([
      registry.ready(),
      server.start(),
    ]);
  });

  after(async function() {
    await server.close();
    await registry.close();
  });
  afterEach(mm.restore);

  it('should work well', async function() {
    const client = new RpcClient({
      registry,
      protocol,
      logger,
    });
    client.consumerClass = RpcConsumer;

    let consumer = client.createConsumer({
      interfaceName: 'com.alipay.sofa.rpc.test.ProtoService',
      targetAppName: 'pb',
      loadbalancerClass: 'consistentHash',
    });
    let req;
    consumer.once('request', r => { req = r; });
    assert(consumer.targetAppName === 'pb');
    assert(client.consumerMap && client.consumerMap.size === 1);
    assert(client.consumerMap.get('com.alipay.sofa.rpc.test.ProtoService:1.0@SOFA@pb') === consumer);
    await consumer.ready();

    const args = [{
      name: 'Peter',
      group: 'A',
    }];
    const ctx = { foo: 'bar' };
    let res = await consumer.invoke('echoObj', args, { ctx });
    assert.deepEqual(res, { code: 200, message: 'hello Peter, you are in A' });

    assert(req && req.targetAppName === 'pb');
    assert(req.ctx === ctx);

    consumer.close();

    consumer = client.createConsumer({
      interfaceName: 'com.alipay.sofa.rpc.test.ProtoService',
      targetAppName: 'pb',
    });
    res = await consumer.invoke('echoObj', args, { ctx });
    assert.deepEqual(res, { code: 200, message: 'hello Peter, you are in A' });

    await client.close();
  });

  it('should support without registry or serverHost in unittest env', async function() {
    const client = new RpcClient({
      protocol,
      logger,
      allowMock: true, // 标识当前支持 mock
    });
    const consumer = client.createConsumer({
      interfaceName: 'com.alipay.sofa.rpc.test.ProtoService',
      targetAppName: 'pb',
    });
    await consumer.ready();

    const args = [{
      name: 'Peter',
      group: 'A',
    }];
    try {
      await consumer.invoke('echoObj', args);
      assert(false);
    } catch (err) {
      assert(err.name === 'RpcNoProviderError');
      assert(err.message === 'No provider of com.alipay.sofa.rpc.test.ProtoService:1.0@SOFA:echoObj() found!');
    }

    await client.close();
  });

  it('should support middleware', async function() {
    const client = new RpcClient({
      protocol,
      logger,
      allowMock: true, // 标识当前支持 mock
    });

    client.use(async function(ctx, next) {
      try {
        await next();
      } catch (err) {
        assert(err.name === 'RpcNoProviderError');
        ctx.body = 'empty';
      }
    });

    const consumer = client.createConsumer({
      interfaceName: 'com.alipay.sofa.rpc.test.ProtoService',
      targetAppName: 'pb',
    });
    await consumer.ready();

    const args = [{
      name: 'Peter',
      group: 'A',
    }];
    let result = await consumer.invoke('echoObj', args);
    assert(result === 'empty');

    async function mw1(ctx, next) {
      const req = ctx.req;
      assert(req.methodName === 'echoObj');

      await next();
    }

    async function mw2(ctx, next) {
      try {
        await next();
      } catch (err) {
        assert(err.name === 'RpcNoProviderError');
      }
    }

    client.use([ mw1, mw2 ]);

    result = await consumer.invoke('echoObj', args);
    assert(!result);


    const consumer2 = client.createConsumer({
      interfaceName: 'com.alipay.sofa.rpc.test.ProtoService2',
      targetAppName: 'pb',
    });
    await consumer2.ready();

    result = await consumer2.invoke('echoObj', []);
    assert(!result);

    await client.close();
  });

  it('should createConsumer no cache', async function() {
    const client = new RpcClient({
      registry,
      protocol,
      logger,
    });
    client.consumerClass = RpcConsumer;

    const options = {
      interfaceName: 'com.alipay.sofa.rpc.test.ProtoService',
      targetAppName: 'pb',
    };

    const consumer1 = client.createConsumer(options);
    await consumer1.ready();

    const consumer2 = client.createConsumer(options);
    await consumer2.ready();

    const consumer3 = client.createConsumer(Object.assign({}, options, { cache: false }));
    await consumer3.ready();

    // consumer1 close，in fact consumer2 will close too
    consumer1.close();

    // consumer3 will not effect because createConsumer with cache: false
    const args = [{
      name: 'Peter',
      group: 'A',
    }];
    const ctx = { foo: 'bar' };
    const res = await consumer3.invoke('echoObj', args, { ctx });
    assert.deepEqual(res, { code: 200, message: 'hello Peter, you are in A' });


    try {
      await consumer2.invoke('echoObj', args, { ctx });
      assert(false);
    } catch (err) {
      assert(err.message === 'No provider of com.alipay.sofa.rpc.test.ProtoService:1.0@SOFA:echoObj() found!');
    }
  });

  it('should createConsumer with no cache not override client._consumerCache map', async function() {
    const client = new RpcClient({
      registry,
      protocol,
      logger,
    });
    client.consumerClass = RpcConsumer;

    const options = {
      interfaceName: 'com.alipay.sofa.rpc.test.ProtoService',
      targetAppName: 'pb',
    };

    const consumer1 = client.createConsumer(options);
    await consumer1.ready();

    const consumer2 = client.createConsumer(Object.assign({}, options, { cache: false }));
    await consumer2.ready();

    assert(client._consumerCache.size === 1);

    // client close will not effect consumer with cache: false
    // need close manually
    await client.close();

    const args = [{
      name: 'Peter',
      group: 'A',
    }];
    const ctx = { foo: 'bar' };

    try {
      await consumer1.invoke('echoObj', args, { ctx });
      assert(false);
    } catch (err) {
      assert(err.message === 'No provider of com.alipay.sofa.rpc.test.ProtoService:1.0@SOFA:echoObj() found!');
    }

    const res = await consumer2.invoke('echoObj', args, { ctx });
    assert.deepEqual(res, { code: 200, message: 'hello Peter, you are in A' });

    await consumer2.close();
    try {
      await consumer2.invoke('echoObj', args, { ctx });
      assert(false);
    } catch (err) {
      assert(err.message === 'No provider of com.alipay.sofa.rpc.test.ProtoService:1.0@SOFA:echoObj() found!');
    }
  });
});