'esversion: 8';
'use strict';

async function FetchUserWallet (Username)
{
    const walletPath = path.join(process.cwd(), 'wallet');
    const wallet = new FileSystemWallet(walletPath);
    let appAdmin = "FIXME";

    if ( await wallet.exists(Username) )
        return [undefined, "An identity for the  ${Username} already exists in the wallet"];

    if (!await wallet.exists(appAdmin))
        return [undefined, "Am admin identity is not registered . please register admin first"];

    return [wallet, undefined];
}

async function connectToGateway(wallet)
{
    const gateway = new Gateway();

    let ccp = "FIXME";
    let appAdmin = "FIXME";
    await gateway.connect(ccp, {
        wallet,
        identity: appAdmin,
        discovery: {
            enabled: false,
            asLocalhost: true
        }
    });

    return gateway;
}

function BadRegistration(code, error)
{
    let response = {};
    response.data = null;
    response.httpstatus = code;
    response.message = error;
    return response;
}

async function FetchNameFromDFARM (config, roleid) {
    let query = { RoleId: roleid };

    MongoClient.connect(config.Database.DFARM.connectString, function (err, client) {
        if (err)
            return [ undefined, "Error connecting to DFARM database: " + err ];

        client
        .db(config.Database.DFARM.dbName)
        .collection("Role")
        .find( query )
    // I don't know, this seems to be a strange construct
    // Are you sure that's correct?
        .toArray( function (err, docs) {
            if (err)
                return [ undefined, "Error with DB :" + err ];

            return [docs[0].name, undefined];
        });

        //client.close();
    });
}

async function DoRegistration(Username, name, wallet, ca, adminIdentity)
{
    const secret = await ca.register({
        enrollmentID: Username,
        role: 'client',
        attrs: [{name: "approle", value: name, ecert: true }]
    }, adminIdentity);
    console.log('secret', secret);   // return secret;

    const enrollment = await ca.enroll({
        enrollmentID: Username,enrollmentSecret: secret
    });
    // console.log('enrollment', enrollment);
    const userIdentity = X509WalletMixin.createIdentity('DfarmadminMSP', enrollment.certificate, enrollment.key.toBytes());
    // console.log("userIdentity", userIdentity)
    await wallet.import(Username, userIdentity);
    console.log(`Successfully  enrolled  user ${Username}  and imported it into the wallet`);

    return [secret, userIdentity];
}

async function RegisterUser(Username, roleid, callback)
{
    try
    {
      var fs = require('fs');
      var config = JSON.parse(fs.readFileSync('./config/Config.json', 'utf8'));

      const [wallet, wallet_error] = await FetchUserWallet( Username );
      if ( !wallet )
        return BadRegistration( 400, wallet_error );

      let gateway = await connectToGateway(wallet);
      if ( !gateway )
        return BadRegistration( 502, "Bad Gateway" );

      let [name, db_error] = await FetchNameFromDFARM( config, roleid );
      if ( !name )
        return BadRegistration( 500, db_error );

      const ca = gateway.getClient().getCertificateAuthority();
      const adminIdentity = gateway.getCurrentIdentity();
      if ( adminIdentity != "" ) // or whatever is appropriate here
        return BadRegistration( 4711, "Unknown Admin" );

      let [secret, userIdentity] = await DoRegistration(Username, name, wallet, ca, adminIdentity);
      if ( ! (secret && userIdentity) )
        return BadRegistration( 500, "Failed to enroll admin due to above error" );

      return {
        secret: secret,
        data: userIdentity,
        httpstatus: 200,
        message: "Successfully registered admin user ${Username} and imported it into the wallet"
      };

    }
    catch (error)
    {
      return BadRegistration( 500, "Failed to enroll admin due to above error" );
    }
}