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

chore: lint

Browse Source
This commit is contained in:
karishmas6
2024-06-01 11:22:43 +05:30
parent fc57daef61
commit af897a2b49
1 changed files with 67 additions and 67 deletions
Download Patch File Download Diff File Expand all files Collapse all files

134
server/src/browser-management/controller.ts
View File

@@ -21,27 +21,27 @@ import logger from "../logger";
* @category BrowserManagement-Controller * @category BrowserManagement-Controller
*/ */
export const initializeRemoteBrowserForRecording = (options: RemoteBrowserOptions): string => { export const initializeRemoteBrowserForRecording = (options: RemoteBrowserOptions): string => {
const id = getActiveBrowserId() || uuid(); const id = getActiveBrowserId() || uuid();
createSocketConnection( createSocketConnection(
io.of(id), io.of(id),
async (socket: Socket) => { async (socket: Socket) => {
// browser is already active // browser is already active
const activeId = getActiveBrowserId(); const activeId = getActiveBrowserId();
if (activeId) { if (activeId) {
const remoteBrowser = browserPool.getRemoteBrowser(activeId); const remoteBrowser = browserPool.getRemoteBrowser(activeId);
remoteBrowser?.updateSocket(socket); remoteBrowser?.updateSocket(socket);
await remoteBrowser?.makeAndEmitScreenshot(); await remoteBrowser?.makeAndEmitScreenshot();
} else { } else {
const browserSession = new RemoteBrowser(socket); const browserSession = new RemoteBrowser(socket);
browserSession.interpreter.subscribeToPausing(); browserSession.interpreter.subscribeToPausing();
await browserSession.initialize(options); await browserSession.initialize(options);
await browserSession.registerEditorEvents(); await browserSession.registerEditorEvents();
await browserSession.subscribeToScreencast(); await browserSession.subscribeToScreencast();
browserPool.addRemoteBrowser(id, browserSession, true); browserPool.addRemoteBrowser(id, browserSession, true);
} }
socket.emit('loaded'); socket.emit('loaded');
}); });
return id; return id;
}; };
/** /**
@@ -53,16 +53,16 @@ export const initializeRemoteBrowserForRecording = (options: RemoteBrowserOption
* @category BrowserManagement-Controller * @category BrowserManagement-Controller
*/ */
export const createRemoteBrowserForRun = (options: RemoteBrowserOptions): string => { export const createRemoteBrowserForRun = (options: RemoteBrowserOptions): string => {
const id = uuid(); const id = uuid();
createSocketConnectionForRun( createSocketConnectionForRun(
io.of(id), io.of(id),
async (socket: Socket) => { async (socket: Socket) => {
const browserSession = new RemoteBrowser(socket); const browserSession = new RemoteBrowser(socket);
await browserSession.initialize(options); await browserSession.initialize(options);
browserPool.addRemoteBrowser(id, browserSession, true); browserPool.addRemoteBrowser(id, browserSession, true);
socket.emit('ready-for-run'); socket.emit('ready-for-run');
}); });
return id; return id;
}; };
/** /**
@@ -72,14 +72,14 @@ export const createRemoteBrowserForRun = (options: RemoteBrowserOptions): string
* @returns {Promise<boolean>} * @returns {Promise<boolean>}
* @category BrowserManagement-Controller * @category BrowserManagement-Controller
*/ */
export const destroyRemoteBrowser = async (id: string) : Promise<boolean> => { export const destroyRemoteBrowser = async (id: string): Promise<boolean> => {
const browserSession = browserPool.getRemoteBrowser(id); const browserSession = browserPool.getRemoteBrowser(id);
if (browserSession) { if (browserSession) {
logger.log('debug', `Switching off the browser with id: ${id}`); logger.log('debug', `Switching off the browser with id: ${id}`);
await browserSession.stopCurrentInterpretation(); await browserSession.stopCurrentInterpretation();
await browserSession.switchOff(); await browserSession.switchOff();
} }
return browserPool.deleteRemoteBrowser(id); return browserPool.deleteRemoteBrowser(id);
}; };
/** /**
@@ -88,8 +88,8 @@ export const destroyRemoteBrowser = async (id: string) : Promise<boolean> => {
* @returns {string | null} * @returns {string | null}
* @category BrowserManagement-Controller * @category BrowserManagement-Controller
*/ */
export const getActiveBrowserId = (): string | null=> { export const getActiveBrowserId = (): string | null => {
return browserPool.getActiveBrowserId(); return browserPool.getActiveBrowserId();
}; };
/** /**
@@ -99,7 +99,7 @@ export const getActiveBrowserId = (): string | null=> {
* @category BrowserManagement-Controller * @category BrowserManagement-Controller
*/ */
export const getRemoteBrowserCurrentUrl = (id: string): string | undefined => { export const getRemoteBrowserCurrentUrl = (id: string): string | undefined => {
return browserPool.getRemoteBrowser(id)?.getCurrentPage()?.url(); return browserPool.getRemoteBrowser(id)?.getCurrentPage()?.url();
}; };
/** /**
@@ -109,15 +109,15 @@ export const getRemoteBrowserCurrentUrl = (id: string): string | undefined => {
* @category BrowserManagement-Controller * @category BrowserManagement-Controller
*/ */
export const getRemoteBrowserCurrentTabs = (id: string): string[] | undefined => { export const getRemoteBrowserCurrentTabs = (id: string): string[] | undefined => {
return browserPool.getRemoteBrowser(id)?.getCurrentPage()?.context().pages() return browserPool.getRemoteBrowser(id)?.getCurrentPage()?.context().pages()
.map((page) => { .map((page) => {
const parsedUrl = new URL(page.url()); const parsedUrl = new URL(page.url());
const host = parsedUrl.hostname.match(/\b(?!www\.)[a-zA-Z0-9]+/g)?.join('.'); const host = parsedUrl.hostname.match(/\b(?!www\.)[a-zA-Z0-9]+/g)?.join('.');
if (host) { if (host) {
return host; return host;
} }
return 'new tab'; return 'new tab';
}); });
}; };
/** /**
@@ -126,18 +126,18 @@ export const getRemoteBrowserCurrentTabs = (id: string): string[] | undefined =>
* @returns {Promise<void>} * @returns {Promise<void>}
* @category BrowserManagement-Controller * @category BrowserManagement-Controller
*/ */
export const interpretWholeWorkflow = async() => { export const interpretWholeWorkflow = async () => {
const id = getActiveBrowserId(); const id = getActiveBrowserId();
if (id) { if (id) {
const browser = browserPool.getRemoteBrowser(id); const browser = browserPool.getRemoteBrowser(id);
if (browser) { if (browser) {
await browser.interpretCurrentRecording(); await browser.interpretCurrentRecording();
} else {
logger.log('error', `No active browser with id ${id} found in the browser pool`);
}
} else { } else {
logger.log('error', `Cannot interpret the workflow: bad id ${id}.`); logger.log('error', `No active browser with id ${id} found in the browser pool`);
} }
} else {
logger.log('error', `Cannot interpret the workflow: bad id ${id}.`);
}
}; };
/** /**
@@ -146,12 +146,12 @@ export const interpretWholeWorkflow = async() => {
* @returns {Promise<void>} * @returns {Promise<void>}
* @category BrowserManagement-Controller * @category BrowserManagement-Controller
*/ */
export const stopRunningInterpretation = async() => { export const stopRunningInterpretation = async () => {
const id = getActiveBrowserId(); const id = getActiveBrowserId();
if (id) { if (id) {
const browser = browserPool.getRemoteBrowser(id); const browser = browserPool.getRemoteBrowser(id);
await browser?.stopCurrentInterpretation(); await browser?.stopCurrentInterpretation();
} else { } else {
logger.log('error', 'Cannot stop interpretation: No active browser or generator.'); logger.log('error', 'Cannot stop interpretation: No active browser or generator.');
} }
}; };