update: parser, add send_tx
This commit is contained in:
parent
99fe592d81
commit
e449b37f25
@ -2,7 +2,6 @@ const crypto = require("crypto");
|
|||||||
|
|
||||||
const scenario = require("./scenario");
|
const scenario = require("./scenario");
|
||||||
const config = require("./config");
|
const config = require("./config");
|
||||||
const request = require("./request").request;
|
|
||||||
|
|
||||||
function builder(scenarioName, scenarioConfig) {
|
function builder(scenarioName, scenarioConfig) {
|
||||||
const scenes = [];
|
const scenes = [];
|
||||||
@ -21,9 +20,9 @@ function builder(scenarioName, scenarioConfig) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
function parseScenario(scenarioString) {
|
function parseScenario(scenarioString) {
|
||||||
const parsedScenario = scenarioString.split(" ");
|
const [scenarioName, scrnarioConfig] = scenarioString.split(" ");
|
||||||
|
|
||||||
return builder(parsedScenario[0], parseScenarioConfig(parsedScenario[1]));
|
return builder(scenarioName, parseScenarioConfig(scrnarioConfig));
|
||||||
}
|
}
|
||||||
|
|
||||||
function parseScenarioConfig(scenarioConfigString) {
|
function parseScenarioConfig(scenarioConfigString) {
|
||||||
|
@ -1,13 +1,19 @@
|
|||||||
const setTimeout = require("timers/promises").setTimeout;
|
const setTimeout = require("timers/promises").setTimeout;
|
||||||
|
const readFile = require("fs").readFile;
|
||||||
|
|
||||||
const parseScenario = require("./builder").parseScenario;
|
const parseScenario = require("./builder").parseScenario;
|
||||||
const request = require("./request").request;
|
const request = require("./request").request;
|
||||||
|
|
||||||
let scenarioFile = `reset_pin current_pin=2222,new_pin=3333\nreset_pin current_pin=3333,new_pin=4444`;
|
readFile(process.argv[2], "utf8", (err, data) => {
|
||||||
|
if (err) {
|
||||||
|
return console.log(err);
|
||||||
|
}
|
||||||
|
execute(data);
|
||||||
|
});
|
||||||
|
|
||||||
const parsedScenarioFile = scenarioFile.split("\n");
|
async function execute(input) {
|
||||||
|
const parsedScenarioFile = input.split("\n");
|
||||||
|
|
||||||
async function execute() {
|
|
||||||
for (const work of parsedScenarioFile) {
|
for (const work of parsedScenarioFile) {
|
||||||
const parsedWork = parseScenario(work);
|
const parsedWork = parseScenario(work);
|
||||||
|
|
||||||
@ -17,5 +23,3 @@ async function execute() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
execute();
|
|
@ -16,10 +16,10 @@ async function request(builtObject) {
|
|||||||
};
|
};
|
||||||
|
|
||||||
try {
|
try {
|
||||||
|
console.log(rangi.yellow(`${builtObject.input}\n-------------`));
|
||||||
const { body } = await phin(requestOptions);
|
const { body } = await phin(requestOptions);
|
||||||
|
|
||||||
if (body.length > 1) {
|
if (body.length > 1) {
|
||||||
console.log(rangi.yellow(`${builtObject.input}\n-------------`));
|
|
||||||
console.log(rangi.cyan(`${body.slice(4)}\n-------------`));
|
console.log(rangi.cyan(`${body.slice(4)}\n-------------`));
|
||||||
|
|
||||||
return;
|
return;
|
||||||
|
4
src/sample_scenrios
Normal file
4
src/sample_scenrios
Normal file
@ -0,0 +1,4 @@
|
|||||||
|
reset_pin current_pin=2222,new_pin=3333
|
||||||
|
reset_pin current_pin=3333,new_pin=2222
|
||||||
|
send_tx to=0727806655,amount=1,pin=2222
|
||||||
|
send_tx to=0706533739,amount=1,pin=2222
|
@ -13,4 +13,14 @@ module.exports = {
|
|||||||
},
|
},
|
||||||
];
|
];
|
||||||
},
|
},
|
||||||
|
send_tx: function (input) {
|
||||||
|
return [
|
||||||
|
{ input: `` },
|
||||||
|
{ input: `1` },
|
||||||
|
{ input: `1*${input.to}` },
|
||||||
|
{ input: `1*${input.to}*${input.amount}` },
|
||||||
|
{ input: `1*${input.to}*${input.amount}*${input.pin}` },
|
||||||
|
{ input: `1*${input.to}*${input.amount}*${input.pin}*99` },
|
||||||
|
];
|
||||||
|
},
|
||||||
};
|
};
|
||||||
|
Reference in New Issue
Block a user