vodorod/parcer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: add earliest selectors from workflow

Browse Source
This commit is contained in:
RohitR311
2024-12-06 17:06:20 +05:30
parent 0d66331305
commit bffe838988
1 changed files with 17 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
maxun-core/src/interpret.ts
View File

@@ -127,6 +127,7 @@ export default class Interpreter extends EventEmitter {
while (index >= 0) { while (index >= 0) {
const previousSelectors = workflow[index]?.where?.selectors; const previousSelectors = workflow[index]?.where?.selectors;
console.log("Previous Selectors:", previousSelectors);
if (previousSelectors && previousSelectors.length > 0) { if (previousSelectors && previousSelectors.length > 0) {
previousSelectors.forEach((selector) => { previousSelectors.forEach((selector) => {
if (!selectors.includes(selector)) { if (!selectors.includes(selector)) {
@@ -156,6 +157,8 @@ export default class Interpreter extends EventEmitter {
*/ */
// const selectors = Preprocessor.extractSelectors(workflow); // const selectors = Preprocessor.extractSelectors(workflow);
console.log("All selectors:", selectors);
/** /**
* Determines whether the element targetted by the selector is [actionable](https://playwright.dev/docs/actionability). * Determines whether the element targetted by the selector is [actionable](https://playwright.dev/docs/actionability).
* @param selector Selector to be queried * @param selector Selector to be queried
@@ -164,8 +167,8 @@ export default class Interpreter extends EventEmitter {
const actionable = async (selector: string): Promise<boolean> => { const actionable = async (selector: string): Promise<boolean> => {
try { try {
const proms = [ const proms = [
page.isEnabled(selector, { timeout: 500 }), page.isEnabled(selector, { timeout: 2000 }),
page.isVisible(selector, { timeout: 500 }), page.isVisible(selector, { timeout: 2000 }),
]; ];
return await Promise.all(proms).then((bools) => bools.every((x) => x)); return await Promise.all(proms).then((bools) => bools.every((x) => x));
@@ -629,17 +632,24 @@ export default class Interpreter extends EventEmitter {
} }
repeatCount = action === lastAction ? repeatCount + 1 : 0; repeatCount = action === lastAction ? repeatCount + 1 : 0;
if (this.options.maxRepeats && repeatCount >= this.options.maxRepeats) {
console.log("REPEAT COUNT", repeatCount);
if (this.options.maxRepeats && repeatCount > this.options.maxRepeats) {
return; return;
} }
lastAction = action; lastAction = action;
try { try {
console.log("Carrying out:", action.what);
await this.carryOutSteps(p, action.what); await this.carryOutSteps(p, action.what);
usedActions.push(action.id ?? 'undefined'); usedActions.push(action.id ?? 'undefined');
selectors.push(...this.getPreviousSelectors(workflow, actionId)); const newSelectors = this.getPreviousSelectors(workflow, actionId);
console.log("SELECTORS", selectors); newSelectors.forEach(selector => {
if (!selectors.includes(selector)) {
selectors.push(selector);
}
});
} catch (e) { } catch (e) {
this.log(<Error>e, Level.ERROR); this.log(<Error>e, Level.ERROR);
} }