-
Notifications
You must be signed in to change notification settings - Fork 160
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
6 changed files
with
204 additions
and
9 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,158 @@ | ||
| var fs = require('fs'); | ||
| var csv = require('fast-csv'); | ||
| var BigNumber = require('bignumber.js'); | ||
| var chalk = require('chalk'); | ||
| var common = require('./common/common_functions'); | ||
| var global = require('./common/global'); | ||
| var contracts = require('./helpers/contract_addresses'); | ||
| var abis = require('./helpers/contract_abis') | ||
|
|
||
| /////////////////////////////ARTIFACTS////////////////////////////////////////// | ||
| let tickerRegistry; | ||
| let securityTokenRegistry; | ||
| let securityToken; | ||
| let usdTieredSTO; | ||
|
|
||
| ////////////////////////////USER INPUTS////////////////////////////////////////// | ||
| let tokenSymbol = process.argv.slice(2)[0]; //token symbol | ||
| let BATCH_SIZE = process.argv.slice(2)[1]; //batch size | ||
| if (!BATCH_SIZE) BATCH_SIZE = 75; | ||
| let remoteNetwork = process.argv.slice(2)[2]; | ||
|
|
||
| /////////////////////////GLOBAL VARS////////////////////////////////////////// | ||
| //distribData is an array of batches. i.e. if there are 200 entries, with batch sizes of 75, we get [[75],[75],[50]] | ||
| let distribData = new Array(); | ||
| //allocData is a temporary array that stores up to the batch size, | ||
| //then gets push into distribData, then gets set to 0 to start another batch | ||
| let allocData = new Array(); | ||
| //full file data is a single array that contains all arrays. i.e. if there are 200 entries we get [[200]] | ||
| let fullFileData = new Array(); | ||
| //baa data is an array that contains invalid entries | ||
| let badData = new Array(); | ||
|
|
||
| //////////////////////////////////////////ENTRY INTO SCRIPT////////////////////////////////////////// | ||
| startScript(); | ||
|
|
||
| async function startScript() { | ||
| await global.initialize(remoteNetwork); | ||
| try { | ||
| let tickerRegistryAddress = await contracts.tickerRegistry(); | ||
| let tickerRegistryABI = abis.tickerRegistry(); | ||
| tickerRegistry = new web3.eth.Contract(tickerRegistryABI, tickerRegistryAddress); | ||
| tickerRegistry.setProvider(web3.currentProvider); | ||
|
|
||
| let securityTokenRegistryAddress = await contracts.securityTokenRegistry(); | ||
| let securityTokenRegistryABI = abis.securityTokenRegistry(); | ||
| securityTokenRegistry = new web3.eth.Contract(securityTokenRegistryABI, securityTokenRegistryAddress); | ||
| securityTokenRegistry.setProvider(web3.currentProvider); | ||
| console.log("Processing investor CSV upload. Batch size is " + BATCH_SIZE + " accounts per transaction"); | ||
| readFile(); | ||
| } catch (err) { | ||
| console.log(err) | ||
| console.log('\x1b[31m%s\x1b[0m', "There was a problem getting the contracts. Make sure they are deployed to the selected network."); | ||
| return; | ||
| } | ||
| } | ||
|
|
||
| ///////////////////////////FUNCTION READING THE CSV FILE | ||
| function readFile() { | ||
| var stream = fs.createReadStream("./CLI/data/nonAccreditedLimits_data.csv"); | ||
|
|
||
| let index = 0; | ||
| console.log(` | ||
| -------------------------------------------- | ||
| ----------- Parsing the csv file ----------- | ||
| -------------------------------------------- | ||
| `); | ||
|
|
||
| var csvStream = csv() | ||
| .on("data", function (data) { | ||
| let isAddress = web3.utils.isAddress(data[0]); | ||
| let isNumber = !isNaN(data[1]); | ||
|
|
||
| if (isAddress && isNumber) { | ||
| let userArray = new Array(); | ||
| let checksummedAddress = web3.utils.toChecksumAddress(data[0]); | ||
|
|
||
| userArray.push(checksummedAddress); | ||
| userArray.push(data[1]); | ||
|
|
||
| allocData.push(userArray); | ||
| fullFileData.push(userArray); | ||
|
|
||
| index++; | ||
| if (index >= BATCH_SIZE) { | ||
| distribData.push(allocData); | ||
| allocData = []; | ||
| index = 0; | ||
| } | ||
| } else { | ||
| let userArray = new Array() | ||
| userArray.push(data[0]); | ||
| userArray.push(data[1]); | ||
|
|
||
| badData.push(userArray); | ||
| fullFileData.push(userArray) | ||
| } | ||
| }) | ||
| .on("end", function () { | ||
| //Add last remainder batch | ||
| distribData.push(allocData); | ||
| allocData = []; | ||
|
|
||
| changeNonAccreditedLimit(); | ||
| }); | ||
|
|
||
| stream.pipe(csvStream); | ||
| } | ||
|
|
||
| // MAIN FUNCTION COMMUNICATING TO BLOCKCHAIN | ||
| async function changeNonAccreditedLimit() { | ||
| // Let's check if token has already been deployed, if it has, skip to STO | ||
| let tokenDeployedAddress = await securityTokenRegistry.methods.getSecurityTokenAddress(tokenSymbol).call(); | ||
| if (tokenDeployedAddress != "0x0000000000000000000000000000000000000000") { | ||
| let securityTokenABI = abis.securityToken(); | ||
| securityToken = new web3.eth.Contract(securityTokenABI, tokenDeployedAddress); | ||
| let result = await securityToken.methods.getModule(3, 0).call(); | ||
| if (result[1] != "0x0000000000000000000000000000000000000000") { | ||
| let stoName = web3.utils.toAscii(result[0]).replace(/\u0000/g, ''); | ||
| if (stoName == 'USDTieredSTO') { | ||
| let usdTieredSTOABI = abis.usdTieredSTO(); | ||
| usdTieredSTO = new web3.eth.Contract(usdTieredSTOABI, result[1]); | ||
| console.log(` | ||
| -------------------------------------------------------------- | ||
| ----- Sending non accredited limit changes to blockchain ----- | ||
| -------------------------------------------------------------- | ||
| `); | ||
| //this for loop will do the batches, so it should run 75, 75, 50 with 200 | ||
| for (let i = 0; i < distribData.length; i++) { | ||
| try { | ||
| let investorArray = []; | ||
| let limitArray = []; | ||
|
|
||
| //splitting the user arrays to be organized by input | ||
| for (let j = 0; j < distribData[i].length; j++) { | ||
| investorArray.push(distribData[i][j][0]); | ||
| limitArray.push(web3.utils.toWei(distribData[i][j][1].toString())); | ||
| } | ||
|
|
||
| let changeNonAccreditedLimitAction = usdTieredSTO.methods.changeNonAccreditedLimit(investorArray, limitArray); | ||
| let r = await common.sendTransaction(Issuer, changeNonAccreditedLimitAction, defaultGasPrice); | ||
| console.log(`Batch ${i} - Attempting to change non accredited limits to accounts:\n\n`, investorArray, "\n\n"); | ||
| console.log("---------- ---------- ---------- ---------- ---------- ---------- ---------- ----------"); | ||
| console.log("Change accredited transaction was successful.", r.gasUsed, "gas used. Spent:", web3.utils.fromWei(BigNumber(r.gasUsed * defaultGasPrice).toString()), "Ether"); | ||
| console.log("---------- ---------- ---------- ---------- ---------- ---------- ---------- ----------\n\n"); | ||
| } catch (err) { | ||
| console.log("ERROR:", err); | ||
| } | ||
| } | ||
| } else { | ||
| console.log(chalk.red(`The STO attached is ${stoName} and this module only works for USDTieredSTO.`)); | ||
| } | ||
| } else { | ||
| console.log(chalk.red(`There is no STO module attached to the ${tokenSymbol.toUpperCase()} Token. No further actions can be taken.`)); | ||
| } | ||
| } else { | ||
| console.log(chalk.red(`Token symbol provided is not a registered Security Token.`)); | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,10 @@ | ||
| 0xf26bb01507a076c83e26d3c8d0f2eab7b77f96f2,3000 | ||
| 0xb42de462906eb0f6a10c7bdf5b100c5da9dc376c,5000 | ||
| 0x3270d07c6552d6334e485c4e8af41ce9e0c34cfd,1000 | ||
| 0x92fdab26ac0c7ae2a40d45b09c9f74846697c40a,2 | ||
| 0xf1819ecb5e81a8f8c0f1d325c8de017caf4fd4fb,1000.500 | ||
| 0xa26cc0567e29fda3c77369791e926b4c46456fcb,1 | ||
| 0x97c09f763a699a51cb947f95e602c08f7bcba202,10000 | ||
| 0x308a3ea530e5b160f1f7115f2ddb30cb44d8b54d,10000 | ||
| 0xbc1bfb5d90692854672febe76ca5379dea1015e4,10000 | ||
| 0x7442dcd2eb074ea6dbfaa8338300bc86238c2aae,10000 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters