DMleadgen
46d973904b
Next.js website for Rocky Mountain Vending company featuring: - Product catalog with Stripe integration - Service areas and parts pages - Admin dashboard with Clerk authentication - SEO optimized pages with JSON-LD structured data Co-authored-by: Cursor <cursoragent@cursor.com>
90 lines
No EOL
2.8 KiB
Text
90 lines
No EOL
2.8 KiB
Text
import { CDPSession } from '../api/CDPSession.js';
|
|
import { TargetCloseError, UnsupportedOperation } from '../common/Errors.js';
|
|
import { Deferred } from '../util/Deferred.js';
|
|
/**
|
|
* @internal
|
|
*/
|
|
export class BidiCdpSession extends CDPSession {
|
|
static sessions = new Map();
|
|
#detached = false;
|
|
#connection;
|
|
#sessionId = Deferred.create();
|
|
frame;
|
|
constructor(frame, sessionId) {
|
|
super();
|
|
this.frame = frame;
|
|
if (!this.frame.page().browser().cdpSupported) {
|
|
return;
|
|
}
|
|
const connection = this.frame.page().browser().connection;
|
|
this.#connection = connection;
|
|
if (sessionId) {
|
|
this.#sessionId.resolve(sessionId);
|
|
BidiCdpSession.sessions.set(sessionId, this);
|
|
}
|
|
else {
|
|
(async () => {
|
|
try {
|
|
const { result } = await connection.send('goog:cdp.getSession', {
|
|
context: frame._id,
|
|
});
|
|
this.#sessionId.resolve(result.session);
|
|
BidiCdpSession.sessions.set(result.session, this);
|
|
}
|
|
catch (error) {
|
|
this.#sessionId.reject(error);
|
|
}
|
|
})();
|
|
}
|
|
// SAFETY: We never throw #sessionId.
|
|
BidiCdpSession.sessions.set(this.#sessionId.value(), this);
|
|
}
|
|
connection() {
|
|
return undefined;
|
|
}
|
|
get detached() {
|
|
return this.#detached;
|
|
}
|
|
async send(method, params, options) {
|
|
if (this.#connection === undefined) {
|
|
throw new UnsupportedOperation('CDP support is required for this feature. The current browser does not support CDP.');
|
|
}
|
|
if (this.#detached) {
|
|
throw new TargetCloseError(`Protocol error (${method}): Session closed. Most likely the page has been closed.`);
|
|
}
|
|
const session = await this.#sessionId.valueOrThrow();
|
|
const { result } = await this.#connection.send('goog:cdp.sendCommand', {
|
|
method: method,
|
|
params: params,
|
|
session,
|
|
}, options?.timeout);
|
|
return result.result;
|
|
}
|
|
async detach() {
|
|
if (this.#connection === undefined ||
|
|
this.#connection.closed ||
|
|
this.#detached) {
|
|
return;
|
|
}
|
|
try {
|
|
await this.frame.client.send('Target.detachFromTarget', {
|
|
sessionId: this.id(),
|
|
});
|
|
}
|
|
finally {
|
|
this.onClose();
|
|
}
|
|
}
|
|
/**
|
|
* @internal
|
|
*/
|
|
onClose = () => {
|
|
BidiCdpSession.sessions.delete(this.id());
|
|
this.#detached = true;
|
|
};
|
|
id() {
|
|
const value = this.#sessionId.value();
|
|
return typeof value === 'string' ? value : '';
|
|
}
|
|
}
|
|
//# sourceMappingURL=CDPSession.js.map |