const axios = require('axios');
const {
  recordInterBankTransaction,
} = require('../services/recordkeeping.service');

async function send(
  customerNo,
  fromAccount,
  toAccount,
  amount,
  ifscCode,
  beneficiaryName,
  remitterName
) {
  const commission = 0;
  try {
    const response = await axios.post(
      'http://localhost:8690/kccb/Rtgsfundtransfer',
      {
        stFromAcc: fromAccount,
        stToAcc: toAccount,
        stTranAmt: amount,
        stCommission: commission,
        stIfscCode: ifscCode,
        stFullName: remitterName,
        stBeneName: beneficiaryName,
        stAddress1: '',
        stAddress2: '',
        stAddress3: '',
      }
    );
    await recordInterBankTransaction(
      customerNo,
      'rtgs',
      fromAccount,
      toAccount,
      ifscCode,
      amount,
      commission,
      beneficiaryName,
      remitterName,
      response.data.status
    );
    return response.data;
  } catch (error) {
    throw new Error(
      'API call to CBS failed' +
        (error.response?.data?.message || error.message)
    );
  }
}

module.exports = { send };