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

feat: comment cleanup

Browse Source
This commit is contained in:
Rohit
2025-02-13 16:15:27 +05:30
parent ff21f5355b
commit 99696aaba2
1 changed files with 0 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
server/src/routes/storage.ts
View File

@@ -164,18 +164,15 @@ interface Credentials {
} }
function handleWorkflowActions(workflow: any[], credentials: Credentials) { function handleWorkflowActions(workflow: any[], credentials: Credentials) {
// Process one step at a time to avoid memory issues
return workflow.map(step => { return workflow.map(step => {
if (!step.what) return step; if (!step.what) return step;
// Use a more memory-efficient approach
const newWhat: any[] = []; const newWhat: any[] = [];
const processedSelectors = new Set<string>(); const processedSelectors = new Set<string>();
for (let i = 0; i < step.what.length; i++) { for (let i = 0; i < step.what.length; i++) {
const action = step.what[i]; const action = step.what[i];
// Skip invalid actions
if (!action?.action || !action?.args?.[0]) { if (!action?.action || !action?.args?.[0]) {
newWhat.push(action); newWhat.push(action);
continue; continue;
@@ -184,28 +181,23 @@ function handleWorkflowActions(workflow: any[], credentials: Credentials) {
const selector = action.args[0]; const selector = action.args[0];
const credential = credentials[selector]; const credential = credentials[selector];
// Handle non-credential actions
if (!credential) { if (!credential) {
newWhat.push(action); newWhat.push(action);
continue; continue;
} }
// Handle credential-related actions
if (action.action === 'click') { if (action.action === 'click') {
newWhat.push(action); newWhat.push(action);
// If we haven't processed this selector and there's a following type/press action
if (!processedSelectors.has(selector) && if (!processedSelectors.has(selector) &&
i + 1 < step.what.length && i + 1 < step.what.length &&
(step.what[i + 1].action === 'type' || step.what[i + 1].action === 'press')) { (step.what[i + 1].action === 'type' || step.what[i + 1].action === 'press')) {
// Add type action
newWhat.push({ newWhat.push({
action: 'type', action: 'type',
args: [selector, encrypt(credential.value), credential.type] args: [selector, encrypt(credential.value), credential.type]
}); });
// Add single waitForLoadState
newWhat.push({ newWhat.push({
action: 'waitForLoadState', action: 'waitForLoadState',
args: ['networkidle'] args: ['networkidle']
@@ -213,7 +205,6 @@ function handleWorkflowActions(workflow: any[], credentials: Credentials) {
processedSelectors.add(selector); processedSelectors.add(selector);
// Skip subsequent type/press/waitForLoadState actions for this selector
while (i + 1 < step.what.length && while (i + 1 < step.what.length &&
(step.what[i + 1].action === 'type' || (step.what[i + 1].action === 'type' ||
step.what[i + 1].action === 'press' || step.what[i + 1].action === 'press' ||
@@ -223,7 +214,6 @@ function handleWorkflowActions(workflow: any[], credentials: Credentials) {
} }
} else if ((action.action === 'type' || action.action === 'press') && } else if ((action.action === 'type' || action.action === 'press') &&
!processedSelectors.has(selector)) { !processedSelectors.has(selector)) {
// Handle standalone type/press action
newWhat.push({ newWhat.push({
action: 'type', action: 'type',
args: [selector, encrypt(credential.value), credential.type] args: [selector, encrypt(credential.value), credential.type]