feat: homemade scnario executor

This commit is contained in:
Mohamed Sohail 2022-03-28 14:03:06 +03:00
parent 97098482af
commit 99fe592d81
Signed by: kamikazechaser
GPG Key ID: 7DD45520C01CD85D
5 changed files with 125 additions and 0 deletions

41
src/builder.js Normal file
View File

@ -0,0 +1,41 @@
const crypto = require("crypto");
const scenario = require("./scenario");
const config = require("./config");
const request = require("./request").request;
function builder(scenarioName, scenarioConfig) {
const scenes = [];
const builtScenario = scenario[scenarioName](scenarioConfig);
const sessionId = crypto.randomBytes(16).toString("hex");
for (const scene of builtScenario) {
scene.sessionId = sessionId;
Object.assign(scene, config);
scenes.push(scene);
}
return scenes;
}
function parseScenario(scenarioString) {
const parsedScenario = scenarioString.split(" ");
return builder(parsedScenario[0], parseScenarioConfig(parsedScenario[1]));
}
function parseScenarioConfig(scenarioConfigString) {
const configs = scenarioConfigString.split(",");
const configObject = {};
for (const conf of configs) {
[key, value] = conf.split("=");
configObject[key] = value;
}
return configObject;
}
module.exports = { parseScenario };

13
src/config.js Normal file
View File

@ -0,0 +1,13 @@
module.exports = {
ussd: {
serviceCode: "*483*061#",
endpoint: "https://ussd.grassecon.net",
timeout: 3000,
},
test: {
waitNextMenu: 3000,
},
user: {
ussdPhone: "254711777734",
},
};

21
src/executor.js Normal file
View File

@ -0,0 +1,21 @@
const setTimeout = require("timers/promises").setTimeout;
const parseScenario = require("./builder").parseScenario;
const request = require("./request").request;
let scenarioFile = `reset_pin current_pin=2222,new_pin=3333\nreset_pin current_pin=3333,new_pin=4444`;
const parsedScenarioFile = scenarioFile.split("\n");
async function execute() {
for (const work of parsedScenarioFile) {
const parsedWork = parseScenario(work);
for (const requestJob of parsedWork) {
await request(requestJob);
await setTimeout(requestJob.test.waitNextMenu);
}
}
}
execute();

34
src/request.js Normal file
View File

@ -0,0 +1,34 @@
const phin = require("phin");
const rangi = require("rangi");
async function request(builtObject) {
const requestOptions = {
url: builtObject.ussd.endpoint,
method: "POST",
parse: "string",
timeout: builtObject.ussd.timeout,
form: {
sessionId: builtObject.sessionId,
phoneNumber: builtObject.user.ussdPhone,
serviceCode: builtObject.ussd.serviceCode,
text: builtObject.input,
},
};
try {
const { body } = await phin(requestOptions);
if (body.length > 1) {
console.log(rangi.yellow(`${builtObject.input}\n-------------`));
console.log(rangi.cyan(`${body.slice(4)}\n-------------`));
return;
}
throw new Error("EMPTY_BODY");
} catch (error) {
console.log(error);
}
}
module.exports = { request };

16
src/scenario.js Normal file
View File

@ -0,0 +1,16 @@
module.exports = {
reset_pin: function (input) {
return [
{ input: `` },
{ input: `3` },
{ input: `3*5` },
{ input: `3*5*1` },
{ input: `3*5*1*${input.current_pin}` },
{ input: `3*5*1*${input.current_pin}*${input.new_pin}` },
{ input: `3*5*1*${input.current_pin}*${input.new_pin}*${input.new_pin}` },
{
input: `3*5*1*${input.current_pin}*${input.new_pin}*${input.new_pin}*99`,
},
];
},
};