import { Node, NodeAPI, NodeMessageInFlow } from 'node-red';
import { invokeChaincode } from '../../libs/fabric-functions';
import { buildGenericDecoder } from './../../libs/fabric-decoder';
import { closeConnection } from './../../libs/fabric-functions';
import { buildConnectionConfig } from './../../models/connection-config.model';
import { FabricCCEvaluateDef } from './fabric-cc-evaluate.def';
import { handleError } from './../../libs/fabric-error-handler';

export = (RED: NodeAPI): void => {

  RED.nodes.registerType('fabric-cc-evaluate', fabricCCEvaluateNode);

  function fabricCCEvaluateNode(this: Node<FabricCCEvaluateDef>, config: FabricCCEvaluateDef) {

    RED.nodes.createNode(this, config); // First line always!

    const connection = buildConnectionConfig(RED, config);
    const genericDecoder = buildGenericDecoder();

    this.debug('Fabric Generic Node Created');
    this.status({ fill: 'green', shape: 'dot', text: 'Ready' });

    this.on('input', async (msg: NodeMessageInFlow, send, done) => {
      try {

        this.status({ fill: 'yellow', shape: 'dot', text: 'Evaluating...' });

        await invokeChaincode(RED, this, msg, genericDecoder, 'evaluate', connection, config);

        this.status({ fill: 'green', shape: 'dot', text: 'Done' });

        send(msg);
        done();

      } catch (error: any) {
        handleError(this, done, error);
      }

    });

    // removed -> "Node disabled / deleted" | !removed -> "Node is reestarted"
    this.on('close', async (removed: boolean, done: () => void) => {
      await closeConnection.call(this, connection, done);
    });

  }

}