Skip to content
This repository has been archived by the owner on Oct 27, 2023. It is now read-only.

Closes #34 Listen vendor token transfers #35

Merged
merged 2 commits into from
Jul 19, 2021
Merged

Closes #34 Listen vendor token transfers #35

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
30a4236
listen token transfers
Jul 19, 2021
c21ac19
record token transfers
Jul 19, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
48 changes: 48 additions & 0 deletions helpers/blockchain/tokenTxListener.js
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,48 @@
const ethers = require('ethers');
const config = require('config');
const { ethersContract } = require('./contract');
const { getAbi } = require('./abi');
const { token } = require('../../config/settings.json');

const network = config.get('blockchain.httpProvider');
const provider = new ethers.providers.JsonRpcProvider(network);
const abi = getAbi('AidToken');
const { Vendor, Agency } = require('../../modules');

const listenTokenTx = async () => {
try {
const {
contracts: { token: tokenAddress, rahat_admin: rahatAdmin },
} = await Agency.getFirst();
const filter = {
address: tokenAddress,
topics: [
// the name of the event, parnetheses containing the data type of each event, no spaces
ethers.utils.id('Transfer(address,address,uint256)'),
],
};
const tokenContract = ethersContract(abi, tokenAddress);
provider.on(filter, async (log) => {
const {
args: { from, to, value },
} = tokenContract.interface.parseLog(log);
const vendor = await Vendor.getbyWallet(from);
if (vendor && to === rahatAdmin) {
await Vendor.addTokenRedemption({
vendor_wallet: from,
amount: value,
tx_hash: log.transactionHash,
success: true,
});
}
});
} catch (e) {
throw Error(e);
}
};

const stopListener = async () => {
provider.removeAllListeners();
};

module.exports = { listenTokenTx, stopListener };
9 changes: 9 additions & 0 deletions index.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,13 +6,18 @@ const path = require('path');
const Vision = require('@hapi/vision');
const HapiSwagger = require('hapi-swagger');

const ethers = require('ethers');
const Logger = require('./helpers/logger');
const app = require('./app');
const registerFeats = require('./helpers/register-modules');
const ws = require('./helpers/utils/socket');

const logger = Logger.getInstance();
const port = config.get('app.port');
const { listenTokenTx, stopListener } = require('./helpers/blockchain/tokenTxListener');

const network = config.get('blockchain.httpProvider');
const provider = new ethers.providers.JsonRpcProvider(network);

mongoose.connect(config.get('app.db'), {
useNewUrlParser: true,
Expand Down Expand Up @@ -117,6 +122,8 @@ async function startServer() {
});
await server.start();
logger.info(`Server running at: ${server.info.uri}`);
logger.info('Listening to Token Transfer events...');
listenTokenTx();
}

// eslint-disable-next-line no-shadow, no-unused-vars
Expand All @@ -135,6 +142,8 @@ server.ext('onPostStop', (server) => {
let isStopping = false;
async function shutDown() {
if (!isStopping) {
logger.info('closing all listeners...');
stopListener();
logger.info('shutDown...');
isStopping = true;
const lapse = process.env.STOP_SERVER_WAIT_SECONDS ? process.env.STOP_SERVER_WAIT_SECONDS : 5;
Expand Down
293 changes: 155 additions & 138 deletions modules/vendor/vendor.controllers.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,152 +4,169 @@ const { addFileToIpfs } = require('../../helpers/utils/ipfs');
const Logger = require('../../helpers/logger');
const { DataUtils } = require('../../helpers/utils');
const { VendorModel } = require('../models');
const { TokenRedemption } = require('./vendorTokenRedemption.model');
const { VendorConstants } = require('../../constants');
const { Agency } = require('../agency/agency.controllers');
const { tokenTransaction } = require('../../helpers/blockchain/tokenTransaction');
const tokenRedemptionModel = require('./vendorTokenRedemption.model');

const logger = Logger.getInstance();

const Vendor = {
async add(payload) {
payload.agencies = [{ agency: payload.currentUser.agency }];
const ipfsIdHash = await this.uploadToIpfs(this.decodeBase64Image(payload.govt_id_image).data);
const ipfsPhotoHash = await this.uploadToIpfs(this.decodeBase64Image(payload.photo).data);
payload.govt_id_image = ipfsIdHash;
payload.photo = ipfsPhotoHash;
return VendorModel.create(payload);
},

async register(agencyId, payload) {
payload.agencies = [{ agency: agencyId }];
const ipfsIdHash = await this.uploadToIpfs(this.decodeBase64Image(payload.govt_id_image).data);
const ipfsPhotoHash = await this.uploadToIpfs(this.decodeBase64Image(payload.photo).data);
payload.govt_id_image = ipfsIdHash;
payload.photo = ipfsPhotoHash;
return VendorModel.create(payload);
},

decodeBase64Image(dataString) {
if (!dataString) return { type: null, data: null };
const matches = dataString.match(/^data:([A-Za-z-+\/]+);base64,(.+)$/);
const response = {};
if (matches.length !== 3) {
return new Error('Invalid input string');
}
response.type = matches[1];
response.data = new Buffer(matches[2], 'base64');
return response;
},
async uploadToIpfs(file) {
if (!file) return '';
const ipfsHash = await addFileToIpfs(file);
return ipfsHash.cid.toString();
},

// Approve after event from Blockchain
async approve(wallet_address, currentUser) {
return VendorModel.findOneAndUpdate(
{ wallet_address, agencies: { $elemMatch: { agency: Types.ObjectId(currentUser.agency) } } },
{ $set: { 'agencies.$.status': VendorConstants.status.Active } },
{ new: true },
);
},
async changeStatus(id, payload, currentUser) {
const { status } = payload;
return VendorModel.findOneAndUpdate(
{ _id: id, agencies: { $elemMatch: { agency: Types.ObjectId(currentUser.agency) } } },
{ $set: { 'agencies.$.status': status } },
{ new: true },
);
},

getbyId(id, currentUser) {
return VendorModel.findOne({ _id: id });
},

getbyWallet(wallet_address, currentUser) {
return VendorModel.findOne({ wallet_address });
},

list(query, currentUser) {
const start = query.start || 0;
const limit = query.limit || 20;
const $match = {
is_archived: false,
agencies: { $elemMatch: { agency: Types.ObjectId(currentUser.agency) } },
};
if (query.show_archive) $match.is_archived = true;
if (query.phone) $match.phone = { $regex: new RegExp(`${query.phone}`), $options: 'i' };
if (query.name) $match.name = { $regex: new RegExp(`${query.name}`), $options: 'i' };

const sort = {};
if (query.sort === 'address' || query.sort === 'name') sort[query.sort] = 1;
else sort.created_at = -1;

return DataUtils.paging({
start,
limit,
sort,
model: VendorModel,
query: [{ $match }],
});
},

async remove(id, curUserId) {
const ben = await VendorModel.findOneAndUpdate(
{ _id: id },
{ is_archived: true, updated_by: curUserId },
{ new: true },
);
// TODO blockchain call
return ben;
},

update(id, payload) {
delete payload.status;
delete payload.balance;
delete payload.agency;

return VendorModel.findOneAndUpdate({ _id: id, is_archived: false }, payload, {
new: true,
runValidators: true,
});
},
countVendor(currentUser) {
const query = { is_archived: false };
query.agencies = { $elemMatch: { agency: Types.ObjectId(currentUser.agency) } };

return VendorModel.find(query).countDocuments();
},

async getTransactions(id, tokenAddress) {
const vendor = await this.getbyId(id);
const transactions = await tokenTransaction(tokenAddress, vendor.wallet_address);
return transactions;
},
async add(payload) {
payload.agencies = [{ agency: payload.currentUser.agency }];
const ipfsIdHash = await this.uploadToIpfs(this.decodeBase64Image(payload.govt_id_image).data);
const ipfsPhotoHash = await this.uploadToIpfs(this.decodeBase64Image(payload.photo).data);
payload.govt_id_image = ipfsIdHash;
payload.photo = ipfsPhotoHash;
return VendorModel.create(payload);
},

async register(agencyId, payload) {
payload.agencies = [{ agency: agencyId }];
const ipfsIdHash = await this.uploadToIpfs(this.decodeBase64Image(payload.govt_id_image).data);
const ipfsPhotoHash = await this.uploadToIpfs(this.decodeBase64Image(payload.photo).data);
payload.govt_id_image = ipfsIdHash;
payload.photo = ipfsPhotoHash;
return VendorModel.create(payload);
},

decodeBase64Image(dataString) {
if (!dataString) return { type: null, data: null };
const matches = dataString.match(/^data:([A-Za-z-+\/]+);base64,(.+)$/);
const response = {};
if (matches.length !== 3) {
return new Error('Invalid input string');
}
response.type = matches[1];
response.data = new Buffer(matches[2], 'base64');
return response;
},
async uploadToIpfs(file) {
if (!file) return '';
const ipfsHash = await addFileToIpfs(file);
return ipfsHash.cid.toString();
},

// Approve after event from Blockchain
async approve(wallet_address, currentUser) {
return VendorModel.findOneAndUpdate(
{ wallet_address, agencies: { $elemMatch: { agency: Types.ObjectId(currentUser.agency) } } },
{ $set: { 'agencies.$.status': VendorConstants.status.Active } },
{ new: true }
);
},
async changeStatus(id, payload, currentUser) {
const { status } = payload;
return VendorModel.findOneAndUpdate(
{ _id: id, agencies: { $elemMatch: { agency: Types.ObjectId(currentUser.agency) } } },
{ $set: { 'agencies.$.status': status } },
{ new: true }
);
},

getbyId(id, currentUser) {
return VendorModel.findOne({ _id: id });
},

getbyWallet(wallet_address, currentUser) {
return VendorModel.findOne({ wallet_address });
},

list(query, currentUser) {
const start = query.start || 0;
const limit = query.limit || 20;
const $match = {
is_archived: false,
agencies: { $elemMatch: { agency: Types.ObjectId(currentUser.agency) } }
};
if (query.show_archive) $match.is_archived = true;
if (query.phone) $match.phone = { $regex: new RegExp(`${query.phone}`), $options: 'i' };
if (query.name) $match.name = { $regex: new RegExp(`${query.name}`), $options: 'i' };

const sort = {};
if (query.sort === 'address' || query.sort === 'name') sort[query.sort] = 1;
else sort.created_at = -1;

return DataUtils.paging({
start,
limit,
sort,
model: VendorModel,
query: [{ $match }]
});
},

async remove(id, curUserId) {
const ben = await VendorModel.findOneAndUpdate(
{ _id: id },
{ is_archived: true, updated_by: curUserId },
{ new: true }
);
// TODO blockchain call
return ben;
},

update(id, payload) {
delete payload.status;
delete payload.balance;
delete payload.agency;

return VendorModel.findOneAndUpdate({ _id: id, is_archived: false }, payload, {
new: true,
runValidators: true
});
},
countVendor(currentUser) {
const query = { is_archived: false };
query.agencies = { $elemMatch: { agency: Types.ObjectId(currentUser.agency) } };

return VendorModel.find(query).countDocuments();
},

async getTransactions(id, tokenAddress) {
const vendor = await this.getbyId(id);
const transactions = await tokenTransaction(tokenAddress, vendor.wallet_address);
return transactions;
},

async addTokenRedemption(payload) {
return tokenRedemptionModel.create(payload);
},

async countVendorTokenRedemption() {
// const query = { vendor_wallet: vendorWallet };
const total = await tokenRedemptionModel.aggregate([
{ $group: { _id: '$vendor_wallet', totalSum: { $sum: '$amount' } } }
]);
const totalToken = total.reduce((acc, obj) => acc + obj.totalSum, 0);
console.log({ totalTokenRedemption: totalToken, tokenRedemption: total });

return { totalTokenRedemption: totalToken, tokenRedemption: total };
}
};

module.exports = {
Vendor,
add: (req) => Vendor.add(req.payload),
getbyId: (req) => {
const { id } = req.params;
if (ethers.utils.isAddress(id)) return Vendor.getbyWallet(id, req.currentUser);
return Vendor.getbyId(req.params.id, req.currentUser);
},
list: (req) => Vendor.list(req.query, req.currentUser),
remove: (req) => Vendor.remove(req.params.id, req.currentUserId),
update: (req) => Vendor.update(req.params.id, req.payload),
approve: (req) => Vendor.approve(req.payload.wallet_address, req.currentUser),
changeStatus: (req) => Vendor.changeStatus(req.params.id, req.payload, req.currentUser),
register: async (req) => {
const { _id: agencyId } = await Agency.getFirst();
return Vendor.register(agencyId, req.payload);
},
getTransactions: async (req) => {
const {
contracts: { token: tokenAddress },
} = await Agency.getFirst();
return Vendor.getTransactions(req.params.id, tokenAddress);
},
Vendor,
add: req => Vendor.add(req.payload),
getbyId: req => {
const { id } = req.params;
if (ethers.utils.isAddress(id)) return Vendor.getbyWallet(id, req.currentUser);
return Vendor.getbyId(req.params.id, req.currentUser);
},
list: req => Vendor.list(req.query, req.currentUser),
remove: req => Vendor.remove(req.params.id, req.currentUserId),
update: req => Vendor.update(req.params.id, req.payload),
approve: req => Vendor.approve(req.payload.wallet_address, req.currentUser),
changeStatus: req => Vendor.changeStatus(req.params.id, req.payload, req.currentUser),
register: async req => {
const { _id: agencyId } = await Agency.getFirst();
return Vendor.register(agencyId, req.payload);
},
getTransactions: async req => {
const {
contracts: { token: tokenAddress }
} = await Agency.getFirst();
return Vendor.getTransactions(req.params.id, tokenAddress);
}
};
Loading