Merge pull request #719 from Chia-Network/feature/cancelEndpoint

feat: cancel offer endpoint

src/controllers/index.js

@@ -7,3 +7,4 @@ export * as LabelController from './label.controller';
 export * as AuditController from './audit.controller';
 export * as GovernanceController from './governance.controller';
 export * as FileStoreController from './fileStore.controller';
+export * as OfferController from './offer.controller';

src/controllers/offer.controller.js

@@ -0,0 +1,54 @@
+import { Meta, Staging } from '../models';
+
+import {
+  assertHomeOrgExists,
+  assertNoPendingCommits,
+  assertWalletIsSynced,
+  assertIfReadOnlyMode,
+  assertStagingTableNotEmpty,
+} from '../utils/data-assertions';
+
+import * as datalayer from '../datalayer/persistance';
+
+export const generateOfferFile = async (req, res) => {
+  try {
+    await assertIfReadOnlyMode();
+    await assertStagingTableNotEmpty();
+    await assertHomeOrgExists();
+    await assertWalletIsSynced();
+    await assertNoPendingCommits();
+
+    const offerFile = await Staging.generateOfferFile();
+    res.json(offerFile);
+  } catch (error) {
+    console.trace(error);
+    res.status(400).json({
+      message: 'Error generating offer file.',
+      error: error.message,
+    });
+  }
+};
+
+export const cancelActiveOffer = async (req, res) => {
+  try {
+    const activeOffer = await Meta.findOne({
+      where: { metaKey: 'activeOfferTradeId' },
+    });
+
+    if (!activeOffer) {
+      throw new Error(`There is no active offer to cancel`);
+    }
+
+    await datalayer.cancelActiveOffer(activeOffer.metaValue);
+    await Meta.destroy({ where: { metaKey: 'activeOfferTradeId' } });
+
+    res.json({
+      message: 'Active offer has been canceled.',
+    });
+  } catch (error) {
+    res.status(400).json({
+      message: 'Can not cancel active offer',
+      error: error.message,
+    });
+  }
+};

src/controllers/staging.controller.js

@@ -71,25 +71,6 @@ export const findAll = async (req, res) => {
   }
 };
 
-export const generateOfferFile = async (req, res) => {
-  try {
-    await assertIfReadOnlyMode();
-    await assertStagingTableNotEmpty();
-    await assertHomeOrgExists();
-    await assertWalletIsSynced();
-    await assertNoPendingCommits();
-
-    const offerFile = await Staging.generateOfferFile();
-    res.json(offerFile);
-  } catch (error) {
-    console.trace(error);
-    res.status(400).json({
-      message: 'Error generating offer file.',
-      error: error.message,
-    });
-  }
-};
-
 export const commit = async (req, res) => {
   try {
     await assertIfReadOnlyMode();

src/datalayer/persistance.js

@@ -372,7 +372,7 @@ const addMirror = async (storeId, url, forceAddMirror = false) => {
       body: JSON.stringify({
         id: storeId,
         urls: [url],
-        amount: _.get(CONFIG, 'MIRROR_FEE', 1000000000 /* 1 billion mojos */),
+        amount: _.get(CONFIG, 'DEFAULT_FEE', 1000000000 /* 1 billion mojos */),
       }),
     };
 
@@ -514,6 +514,34 @@ const makeOffer = async (offer) => {
   }
 };
 
+const cancelOffer = async (tradeId) => {
+  const options = {
+    url: `${CONFIG.DATALAYER_URL}/cancel_offer `,
+    body: JSON.stringify({
+      trade_id: tradeId,
+      secure: true,
+      fee: _.get(CONFIG, 'DEFAULT_FEE', 1000000000 /* 1 billion mojos */),
+    }),
+  };
+
+  try {
+    const response = await request(
+      Object.assign({}, getBaseOptions(), options),
+    );
+
+    const data = JSON.parse(response);
+
+    if (data.success) {
+      return data;
+    }
+
+    throw new Error(data.error);
+  } catch (error) {
+    console.log(error);
+    throw error;
+  }
+};
+
 export {
   addMirror,
   makeOffer,
@@ -530,4 +558,5 @@ export {
   pushChangeListToDataLayer,
   createDataLayerStore,
   getSubscriptions,
+  cancelOffer,
 };