Added post endpoints

RunOnFlux · Nov 15, 2024 · 736cd53 · 736cd53
1 parent e466d69
commit 736cd53
Show file tree

Hide file tree

Showing 3 changed files with 139 additions and 9 deletions.
diff --git a/src/apiServices/assetApi.ts b/src/apiServices/assetApi.ts
@@ -4,7 +4,11 @@ import {
   showCryptoAssets,
   getPurchaseDetailByPurchaseId,
   submitPurchase,
-  getPurchaseHistory
+  getPurchaseHistory,
+  getPurchaseDetails,
+  getPurchaseDetailsSelectedAsset,
+  createPurchase,
+  getPurchaseStatus
 } from '../services/assetService';
 
 async function getFiatAssets(req, res) {
@@ -68,10 +72,63 @@ async function getAllPurchase(req, res) {
   }
 }
 
+async function getAllPurchaseDetails(req, res) {
+  try {
+    const data = req.data;
+    const value = await getPurchaseDetails(data);
+    res.json(value);
+  } catch (error) {
+    log.error(error);
+    res.sendStatus(404);
+  }
+}
+
+async function getPurchaseDetailsOnSelectedAsset(req, res) {
+  try {
+    const data = req.data;
+    const value = await getPurchaseDetailsSelectedAsset(data);
+    res.json(value);
+  } catch (error) {
+    log.error(error);
+    res.sendStatus(404);
+  }
+}
+
+async function createPurchaseDetails(req, res) {
+  try {
+    const data = req.data;
+
+    let { zelid } = req.params;
+    zelid = zelid ?? req.query.zelid;
+
+    const value = await createPurchase(data, zelid);
+    res.json(value);
+  } catch (error) {
+    log.error(error);
+    res.sendStatus(404);
+  }
+}
+
+async function getAllPurchaseStatus(req, res) {
+  try {
+    const data = req.data;
+    const value = await getPurchaseStatus(data);
+    res.json(value);
+  } catch (error) {
+    log.error(error);
+    res.sendStatus(404);
+  }
+}
+
+
 export default {
   getFiatAssets,
   getCryptoAssets,
   getPurchaseDetailsByPurchaseId,
   sendPurchase,
-  getAllPurchase
+  getAllPurchase,
+  getAllPurchaseDetails,
+  getPurchaseDetailsOnSelectedAsset,
+  createPurchaseDetails,
+  getAllPurchaseStatus
 }
diff --git a/src/routes.ts b/src/routes.ts
@@ -37,6 +37,10 @@ export default (app) => {
   app.post('/v1/ticket', (req, res) => {
     ticketsApi.postTicket(req, res);
   });
+  // get token information endpoint
+  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);
@@ -57,8 +61,19 @@ export default (app) => {
   app.get('/v1/assetinfo/purchase/history/:zelid?', (req, res) => {
     assetApi.getAllPurchase(req, res);
   });
-  // get token information endpoint
-  app.get('/v1/tokeninfo/:network?/:address?', (req, res) => {
-    tokenApi.getTokenInfo(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);
   });
 };
diff --git a/src/services/assetService.ts b/src/services/assetService.ts
@@ -6,7 +6,7 @@ export async function showFiatAssets () {
     return response.data;
   } catch(error) {
     console.log(error);
-    return {};
+    return {message: "Error occured in processing"};
   };
 }
 
@@ -16,7 +16,7 @@ export async function showCryptoAssets () {
     return response.data;
   } catch(error) {
     console.log(error);
-    return {};
+    return {message: "Error occured in processing"};
   };
 }
 
@@ -26,7 +26,7 @@ export async function getPurchaseDetailByPurchaseId (purchaseid: string) {
     return response.data;
   } catch(error) {
     console.log(error);
-    return {};
+    return {message: "Error occured in processing"};
   };
 }
 
@@ -36,14 +36,71 @@ export async function submitPurchase (purchaseid: string, providerid: string) {
     return response.data;
   } catch(error) {
     console.log(error);
-    return {};
+    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 {};
@@ -53,3 +110,4 @@ export async function getPurchaseHistory (zelid: string) {
 
 
 
+