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

feat: remove throttle wrapper from emit screenshot

Browse Source
This commit is contained in:
amhsirak
2025-01-06 21:10:39 +05:30
parent de2ddfd2b8
commit 66c964f8b1
1 changed files with 20 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

53
server/src/browser-management/classes/RemoteBrowser.ts
View File

@@ -18,6 +18,7 @@ import { WorkflowGenerator } from "../../workflow-management/classes/Generator";
import { WorkflowInterpreter } from "../../workflow-management/classes/Interpreter"; import { WorkflowInterpreter } from "../../workflow-management/classes/Interpreter";
import { getDecryptedProxyConfig } from '../../routes/proxy'; import { getDecryptedProxyConfig } from '../../routes/proxy';
import { getInjectableScript } from 'idcac-playwright'; import { getInjectableScript } from 'idcac-playwright';
chromium.use(stealthPlugin()); chromium.use(stealthPlugin());
const MEMORY_CONFIG = { const MEMORY_CONFIG = {
@@ -88,7 +89,7 @@ export class RemoteBrowser {
maxConcurrency: 1, maxConcurrency: 1,
maxRepeats: 1, maxRepeats: 1,
}; };
private lastEmittedUrl: string | null = null; private lastEmittedUrl: string | null = null;
/** /**
@@ -101,20 +102,10 @@ export class RemoteBrowser {
*/ */
public interpreter: WorkflowInterpreter; public interpreter: WorkflowInterpreter;
//private performanceMonitor: BackendPerformanceMonitor;
private screenshotQueue: Buffer[] = []; private screenshotQueue: Buffer[] = [];
private isProcessingScreenshot = false; private isProcessingScreenshot = false;
private screencastInterval: NodeJS.Timeout | null = null; private screencastInterval: NodeJS.Timeout | null = null
// private startPerformanceReporting() {
// setInterval(() => {
// const report = this.performanceMonitor.getPerformanceReport();
// console.log('Backend Performance Report:', report);
// }, 5000);
// }
/** /**
* Initializes a new instances of the {@link Generator} and {@link WorkflowInterpreter} classes and * Initializes a new instances of the {@link Generator} and {@link WorkflowInterpreter} classes and
@@ -126,8 +117,6 @@ export class RemoteBrowser {
this.socket = socket; this.socket = socket;
this.interpreter = new WorkflowInterpreter(socket); this.interpreter = new WorkflowInterpreter(socket);
this.generator = new WorkflowGenerator(socket); this.generator = new WorkflowGenerator(socket);
//this.performanceMonitor = new BackendPerformanceMonitor();
//this.startPerformanceReporting();
} }
private initializeMemoryManagement(): void { private initializeMemoryManagement(): void {
@@ -422,22 +411,22 @@ export class RemoteBrowser {
public async switchOff(): Promise<void> { public async switchOff(): Promise<void> {
try { try {
await this.interpreter.stopInterpretation(); await this.interpreter.stopInterpretation();
if (this.screencastInterval) { if (this.screencastInterval) {
clearInterval(this.screencastInterval); clearInterval(this.screencastInterval);
} }
if (this.client) { if (this.client) {
await this.stopScreencast(); await this.stopScreencast();
} }
if (this.browser) { if (this.browser) {
await this.browser.close(); await this.browser.close();
} }
this.screenshotQueue = []; this.screenshotQueue = [];
//this.performanceMonitor.reset(); //this.performanceMonitor.reset();
} catch (error) { } catch (error) {
logger.error('Error during browser shutdown:', error); logger.error('Error during browser shutdown:', error);
} }
@@ -653,37 +642,35 @@ export class RemoteBrowser {
* @param payload the screenshot binary data * @param payload the screenshot binary data
* @returns void * @returns void
*/ */
private emitScreenshot = throttle(async (payload: Buffer): Promise<void> => { private emitScreenshot = async (payload: Buffer): Promise<void> => {
if (this.isProcessingScreenshot) { if (this.isProcessingScreenshot) {
if (this.screenshotQueue.length < SCREENCAST_CONFIG.maxQueueSize) { if (this.screenshotQueue.length < SCREENCAST_CONFIG.maxQueueSize) {
this.screenshotQueue.push(payload); this.screenshotQueue.push(payload);
} }
return; return;
} }
this.isProcessingScreenshot = true; this.isProcessingScreenshot = true;
try { try {
const optimizedScreenshot = await this.optimizeScreenshot(payload); const optimizedScreenshot = await this.optimizeScreenshot(payload);
const base64Data = optimizedScreenshot.toString('base64'); const base64Data = optimizedScreenshot.toString('base64');
const dataWithMimeType = `data:image/jpeg;base64,${base64Data}`; const dataWithMimeType = `data:image/jpeg;base64,${base64Data}`;
await new Promise<void>((resolve) => { this.socket.emit('screencast', dataWithMimeType);
this.socket.emit('screencast', dataWithMimeType, () => resolve()); logger.debug('Screenshot emitted');
});
} catch (error) { } catch (error) {
logger.error('Screenshot emission failed:', error); logger.error('Screenshot emission failed:', error);
} finally { } finally {
this.isProcessingScreenshot = false; this.isProcessingScreenshot = false;
// Process next screenshot in queue if any
if (this.screenshotQueue.length > 0) { if (this.screenshotQueue.length > 0) {
const nextScreenshot = this.screenshotQueue.shift(); const nextScreenshot = this.screenshotQueue.shift();
if (nextScreenshot) { if (nextScreenshot) {
this.emitScreenshot(nextScreenshot); setTimeout(() => this.emitScreenshot(nextScreenshot), 1000 / SCREENCAST_CONFIG.targetFPS);
} }
} }
} }
}, 1000 / SCREENCAST_CONFIG.targetFPS); };
} }