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

feat: add input type for workflow type actions

Browse Source
This commit is contained in:
Rohit
2025-01-23 01:18:47 +05:30
parent ef3ec295d7
commit ee65ea8406
1 changed files with 19 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -154,48 +154,52 @@ function formatRunResponse(run: any) {
return formattedRun; return formattedRun;
} }
interface CredentialUpdate { interface CredentialInfo {
[selector: string]: string; value: string;
type: string;
} }
function updateTypeActionsInWorkflow(workflow: any[], credentials: CredentialUpdate) { interface Credentials {
[key: string]: CredentialInfo;
}
function updateTypeActionsInWorkflow(workflow: any[], credentials: Credentials) {
return workflow.map(step => { return workflow.map(step => {
if (!step.what) return step; if (!step.what) return step;
// First pass: mark indices to remove
const indicesToRemove = new Set<number>(); const indicesToRemove = new Set<number>();
step.what.forEach((action: any, index: any) => { step.what.forEach((action: any, index: number) => {
if (!action.action || !action.args?.[0]) return; if (!action.action || !action.args?.[0]) return;
// If it's a type/press action for a credential
if ((action.action === 'type' || action.action === 'press') && credentials[action.args[0]]) { if ((action.action === 'type' || action.action === 'press') && credentials[action.args[0]]) {
indicesToRemove.add(index); indicesToRemove.add(index);
// Check if next action is waitForLoadState
if (step.what[index + 1]?.action === 'waitForLoadState') { if (step.what[index + 1]?.action === 'waitForLoadState') {
indicesToRemove.add(index + 1); indicesToRemove.add(index + 1);
} }
} }
}); });
// Filter out marked indices and create new what array const filteredWhat = step.what.filter((_: any, index: number) => !indicesToRemove.has(index));
const filteredWhat = step.what.filter((_: any, index: any) => !indicesToRemove.has(index));
// Add new type actions after click actions Object.entries(credentials).forEach(([selector, credentialInfo]) => {
Object.entries(credentials).forEach(([selector, credential]) => {
const clickIndex = filteredWhat.findIndex((action: any) => const clickIndex = filteredWhat.findIndex((action: any) =>
action.action === 'click' && action.args?.[0] === selector action.action === 'click' && action.args?.[0] === selector
); );
if (clickIndex !== -1) { if (clickIndex !== -1) {
const chars = credential.split(''); const chars = credentialInfo.value.split('');
chars.forEach((char, i) => { chars.forEach((char, i) => {
// Add type action
filteredWhat.splice(clickIndex + 1 + (i * 2), 0, { filteredWhat.splice(clickIndex + 1 + (i * 2), 0, {
action: 'type', action: 'type',
args: [selector, encrypt(char)] args: [
selector,
encrypt(char),
credentialInfo.type
]
}); });
// Add waitForLoadState
filteredWhat.splice(clickIndex + 2 + (i * 2), 0, { filteredWhat.splice(clickIndex + 2 + (i * 2), 0, {
action: 'waitForLoadState', action: 'waitForLoadState',
args: ['networkidle'] args: ['networkidle']