Fiat onboarding

src/apiServices/assetApi.ts

@@ -0,0 +1,158 @@
+import log from '../lib/log';
+import { 
+  showFiatAssets,
+  showCryptoAssets,
+  getPurchaseDetailByPurchaseId,
+  submitPurchase,
+  getPurchaseHistory,
+  getPurchaseDetails,
+  getPurchaseDetailsSelectedAsset,
+  createPurchase,
+  getPurchaseStatus,
+  getProviders
+} from '../services/assetService';
+
+async function getFiatAssets(req, res) {
+  try {
+    const value = await showFiatAssets();
+    res.json(value);
+  } catch (error) {
+    log.error(error);
+    res.sendStatus(404);
+  }
+}
+
+async function getCryptoAssets(req, res) {
+  try {
+    const value = await showCryptoAssets();
+    res.json(value);
+  } catch (error) {
+    log.error(error);
+    res.sendStatus(404);
+  }
+}
+
+async function getAssetProviders(req, res) {
+  try {
+    const value = await getProviders();
+    res.json(value);
+  } catch (error) {
+    log.error(error);
+    res.sendStatus(404);
+  }
+}
+
+async function getPurchaseDetailsByPurchaseId(req, res) {
+  try {
+    let { purchaseid } = req.params;
+    purchaseid = purchaseid ?? req.query.purchaseid;
+    const value = await getPurchaseDetailByPurchaseId(purchaseid);
+    res.json(value);
+  } catch (error) {
+    log.error(error);
+    res.sendStatus(404);
+  }
+}
+
+async function sendPurchase(req, res) {
+  try {
+    let { purchaseid } = req.params;
+    purchaseid = purchaseid ?? req.query.purchaseid;
+
+    let { providerid } = req.params;
+    providerid = providerid ?? req.query.providerid;
+
+    const value = await submitPurchase(purchaseid, providerid);
+    res.json(value);
+  } catch (error) {
+    log.error(error);
+    res.sendStatus(404);
+  }
+}
+
+async function getAllPurchase(req, res) {
+  try {
+    let { zelid } = req.params;
+    zelid = zelid ?? req.query.zelid;
+
+    const value = await getPurchaseHistory(zelid);
+    res.json(value);
+  } catch (error) {
+    log.error(error);
+    res.sendStatus(404);
+  }
+}
+
+async function getAllPurchaseDetails(req, res) {
+  try {
+    let body = '';
+    await req.on('data', (data) => {
+      body += data;
+    });
+    const value = await getPurchaseDetails(body);
+    res.json(value);
+  } catch (error) {
+    log.error(error);
+    res.sendStatus(404);
+  }
+}
+
+async function getPurchaseDetailsOnSelectedAsset(req, res) {
+  try {
+    let body = '';
+    await req.on('data', (data) => {
+      body += data;
+    });
+    const value = await getPurchaseDetailsSelectedAsset(body);
+    res.json(value);
+  } catch (error) {
+    log.error(error);
+    res.sendStatus(404);
+  }
+}
+
+async function createPurchaseDetails(req, res) {
+  try {
+    let body = '';
+    await req.on('data', (data) => {
+      body += data;
+    });
+
+    let { zelid } = req.params;
+    zelid = zelid ?? req.query.zelid;
+
+    const value = await createPurchase(body, zelid);
+    res.json(value);
+  } catch (error) {
+    log.error(error);
+    res.sendStatus(404);
+  }
+}
+
+async function getAllPurchaseStatus(req, res) {
+  try {
+    let body = '';
+    await req.on('data', (data) => {
+      body += data;
+    });
+    const value = await getPurchaseStatus(body);
+    res.json(value);
+  } catch (error) {
+    log.error(error);
+    res.sendStatus(404);
+  }
+}
+
+
+export default {
+  getFiatAssets,
+  getCryptoAssets,
+  getPurchaseDetailsByPurchaseId,
+  sendPurchase,
+  getAllPurchase,
+  getAllPurchaseDetails,
+  getPurchaseDetailsOnSelectedAsset,
+  createPurchaseDetails,
+  getAllPurchaseStatus,
+  getAssetProviders
+}

src/routes.ts

@@ -4,6 +4,7 @@ import ratesApi from './apiServices/ratesApi';
 import ticketsApi from './apiServices/ticketsApi';
 import feeService from './services/networkFeesService';
 import tokenApi from './apiServices/tokenApi';
+import assetApi from './apiServices/assetApi';
 
 export default (app) => {
   // return sync data
@@ -40,4 +41,43 @@ export default (app) => {
   app.get('/v1/tokeninfo/:network?/:address?', (req, res) => {
     tokenApi.getTokenInfo(req, res);
   });
+  // get fiat assets
+  app.get('/v1/assetinfo/assets/fiat', (req, res) => {
+    assetApi.getFiatAssets(req, res);
+  });
+  // get crypto assets
+  app.get('/v1/assetinfo/assets/crypto', (req, res) => {
+    assetApi.getCryptoAssets(req, res);
+  });
+  // get asset providers
+  app.get('/v1/assetinfo/assets/providers', (req, res) => {
+    assetApi.getAssetProviders(req, res);
+  });
+  // get purchase by id
+  app.get('/v1/assetinfo/purchase/id/:purchaseid?', (req, res) => {
+    assetApi.getPurchaseDetailsByPurchaseId(req, res);
+  });
+  // send purchase
+  app.get('/v1/assetinfo/purchase/send/:purchaseid?/:providerid?', (req, res) => {
+    assetApi.sendPurchase(req, res);
+  });
+  // get purchase history
+  app.get('/v1/assetinfo/purchase/history/:zelid?', (req, res) => {
+    assetApi.getAllPurchase(req, res);
+  });
+  app.post('/v1/assetinfo/purchase/details', (req, res) => {
+    assetApi.getAllPurchaseDetails(req, res);
+  });
+  // send purchase
+  app.post('/v1/assetinfo/purchase/details/assets', (req, res) => {
+    assetApi.getPurchaseDetailsOnSelectedAsset(req, res);
+  });
+  // get purchase history
+  app.post('/v1/assetinfo/purchase/create/:zelid?', (req, res) => {
+    assetApi.createPurchaseDetails(req, res);
+  });
+  // get purchase history
+  app.post('/v1/assetinfo/purchase/status', (req, res) => {
+    assetApi.getAllPurchaseStatus(req, res);
+  });
 };

src/services/assetService.ts

@@ -0,0 +1,123 @@
+import axios from 'axios';
+
+export async function showFiatAssets () {
+  try {
+    const response = await axios.get('https://abe.zelcore.io/v1/purchase/sellassets');
+    return response.data;
+  } catch(error) {
+    console.log(error);
+    return {message: "Error occured in processing"};
+  };
+}
+
+export async function showCryptoAssets () {
+  try {
+    const response = await axios.get('https://abe.zelcore.io/v1/purchase/buyassets');
+    return response.data;
+  } catch(error) {
+    console.log(error);
+    return {message: "Error occured in processing"};
+  };
+}
+
+export async function getPurchaseDetailByPurchaseId (purchaseid: string) {
+  try {
+    const response = await axios.get(`https://abe.zelcore.io/v1/purchase/detail?purchaseid=${purchaseid}`);
+    return response.data;
+  } catch(error) {
+    console.log(error);
+    return {message: "Error occured in processing"};
+  };
+}
+
+export async function submitPurchase (purchaseid: string, providerid: string) {
+  try {
+    const response = await axios.get(`https://abe.zelcore.io/v1/purchase/submit?purchaseid=${purchaseid}&providerid=${providerid}`);
+    return response.data;
+  } catch(error) {
+    console.log(error);
+    return {message: "Error occured in processing"};
+  };
+}
+
+export async function getPurchaseHistory (zelid: string) {
+  try {
+    const response = await axios.get(`https://abe.zelcore.io/v1/offramp/user/history?zelid=${zelid}`);
+    return response.data;
+  } catch(error) {
+    console.log(error);
+    return {message: "Error occured in processing"};
+  };
+}
+
+export async function getPurchaseDetails (data: any) {
+  try {
+    const response = await axios.post(`https://abe.zelcore.io/v1/purchase/pairdetails`, data, {
+      headers: { 
+        'Content-Type' : 'application/json'
+      }
+    });
+    return response.data;
+  } catch(error) {
+    console.log(error);
+    return {message: "Error occured in processing"};
+  };
+}
+
+export async function getPurchaseDetailsSelectedAsset (data: any) {
+  try {
+    const response = await axios.post(`https://abe.zelcore.io/v1/purchase/pairdetailssellamount`, data, {
+      headers: { 
+        'Content-Type' : 'application/json'
+      }
+    });
+    return response.data;
+  } catch(error) {
+    console.log(error);
+    return {message: "Error occured in processing"};
+  };
+}
+
+export async function createPurchase (data: any, zelid: string) {
+  try {
+    const response = await axios.post(`https://abe.zelcore.io/v1/purchase/createpurchase`, data, {
+      headers: { 
+        'Content-Type' : 'application/json',
+        'zedid': zelid
+      }
+    });
+    return response.data;
+  } catch(error) {
+    console.log(error);
+    return {message: "Error occured in processing"};
+  };
+}
+
+export async function getPurchaseStatus (data: any) {
+  try {
+    const response = await axios.post(`https://abe.zelcore.io/v1/purchase/status`, data, {
+      headers: { 
+        'Content-Type' : 'application/json'
+      }
+    });
+    return response.data;
+  } catch(error) {
+    console.log(error);
+    return {};
+  };
+}
+
+export async function getProviders () {
+  try {
+    const response = await axios.get('https://abe.zelcore.io/v1/purchases');
+    return response.data;
+  } catch(error) {
+    console.log(error);
+    return {message: "Error occured in processing"};
+  };
+}
+
+
+
+
+