CreateCabn completed in cabnHelper. Structure is also modified.

app/helpers/multiSwapHelpers/cabnsHelper.ts

@@ -12,16 +12,68 @@ export const doValidationForCreateUserCabn = async (req: any): Promise<any> => {
 };
 
 export const createUserCabn = async (req: any): Promise<any> => {
-  let countFilter: any = {};
+  let cabnFilter: any = {};
   const userId = req.user._id;
-  const networkId = await db.Networks.countDocuments({
+  const network = await db.Networks.findOne({
     chainId: req.body.chainId,
   });
-  if (!networkId) {
+  if (!network) {
     throw stringHelper.chainIdNotSupported;
   }
+  req.body.tokenContractAddress = req.body.tokenContractAddress.toLowerCase();
+  cabnFilter.network = network._id;
+  cabnFilter.tokenContractAddress = req.body.tokenContractAddress;
+  console.log("cabn count", await countCabnByFilter(cabnFilter));
+  if ((await countCabnByFilter(cabnFilter)) == 0) {
+    req.body.nonDefaultCurrencyInformation =
+      getNonDefaultCurrencyInformationObject(req.body);
+    req.body.createdByusers = [userId];
+    req.body.network = network._id;
+    req.body.isAllowedOnMultiSwap = true;
+    req.body.isDefault = false;
+    req.body.createdAt = new Date();
+    req.body.updatedAt = new Date();
+    return await db.CurrencyAddressesByNetwork.create(req.body);
+  } else {
+    return addUserIdIntoCabn(cabnFilter, req);
+  }
+};
+
+const countCabnByFilter = async (cabnFilter: any): Promise<any> => {
+  console.log(cabnFilter);
+  return await db.CurrencyAddressesByNetwork.countDocuments(cabnFilter);
+};
+
+const findCabnByFilter = async (cabnFilter: any): Promise<any> => {
+  console.log(cabnFilter);
+  return await db.CurrencyAddressesByNetwork.findOne(cabnFilter);
+};
+
+const getNonDefaultCurrencyInformationObject = (body: any): any => {
+  return {
+    name: body.currencyName,
+    symbol: body.currencySymbol,
+  };
 };
 
-const countCabnByFilter = async (filter: any): Promise<any> => {
-  return await db.CurrencyAddressesByNetwork.countDocuments(filter);
+const addUserIdIntoCabn = async (cabnFilter: any, req: any): Promise<any> => {
+  let cabn;
+  cabnFilter.createdByusers = { $in: req.user._id };
+  let byPass = true;
+  if ((await countCabnByFilter(cabnFilter)) == 0 || byPass) {
+    delete cabnFilter.createdByusers;
+    cabn = await findCabnByFilter(cabnFilter);
+    if (cabn) {
+      let users = cabn.createdByusers;
+      users.push(req.user._id);
+      cabn.createdByusers = users;
+      cabn.updatedAt = new Date();
+      cabn = await db.CurrencyAddressesByNetwork.findOneAndUpdate(
+        cabnFilter,
+        cabn,
+        { new: true }
+      );
+    }
+  }
+  return cabn ? cabn : await findCabnByFilter(cabnFilter);
 };

app/helpers/stringHelper.ts

@@ -75,6 +75,7 @@ let transactionFailedMessageOne = "Backend_Transaction_Failed_Message_One";
 let transactionFailedMessageTwo = "Backend_Transaction_Failed_Message_Two";
 let invalidHashMessage = "Backend_Invalid_Hash_Message";
 let swapFailedMessage = "Backend_Swap_Failed_Message";
+var strErrorCabnAlreadyExist = "Backend_Error_Cabn_Already_Exist";
 var strErrorNodePairAlreadyExist = "This pair already exist.";
 
 // success messages
@@ -162,4 +163,5 @@ module.exports = {
   withdrawlSuccessfulMessage,
   strErrorNodePairAlreadyExist,
   chainIdNotSupported,
+  strErrorCabnAlreadyExist,
 };

app/lib/stringsPhrase.json

@@ -60,5 +60,6 @@
   "Backend_Transaction_Failed_Message_Two": "We are having trouble processing the Transaction, please contact support to proceed further.",
   "Backend_Invalid_Hash_Message": "Swap unsuccessful due to invalid hash.",
   "Backend_Swap_Failed_Message": "Swap transaction has failed.",
-  "Backend_Withdrawl_Successful_Message": "Transaction withdrawal successful."
+  "Backend_Withdrawl_Successful_Message": "Transaction withdrawal successful.",
+  "Backend_Error_Cabn_Already_Exist": "This cabn already exist."
 }

app/models/currencyAddressesByNetwork.ts

@@ -10,6 +10,12 @@ var schema = mongoose.Schema(
       type: mongoose.Schema.Types.ObjectId,
       ref: "organizations",
     },
+    createdByusers: [
+      {
+        type: mongoose.Schema.Types.ObjectId,
+        ref: "users",
+      },
+    ],
     tokenContractAddress: { type: String, default: "" },
     isAllowedOnMultiSwap: { type: Boolean, default: false },
     isFeeToken: { type: Boolean, default: false },
@@ -24,6 +30,10 @@ var schema = mongoose.Schema(
     isNative: { type: Boolean, default: false },
     oneInchAddress: { type: String, default: "" },
     isDefault: { type: Boolean, default: true },
+    nonDefaultCurrencyInformation: {
+      name: { type: String, default: "" },
+      symbol: { type: String, default: "" },
+    },
     createdAt: { type: Date, default: new Date() },
     updatedAt: { type: Date, default: new Date() },
   },