核心能力

// 基础创建
const session = await client.sessions.create();

// 指定浏览器模式
const session = await client.sessions.create({
  browserMode: 'normal',
});

// 挂载已上传扩展
const session = await client.sessions.create({
  browserMode: 'normal',
  extensionIds: ['ext_11ff6ce20fb0'],
});

// 配置带认证的上游代理
const session = await client.sessions.create({
  proxy: {
    type: 'external',
    server: 'http://192.168.1.1:8080',
    username: 'user',
    password: 'pass',
  },
});

// 可选浏览器模式：
// - 'normal': 标准浏览器容器
// - 'light': 轻量浏览器模式

const context = await client.contexts.create({
  metadata: { userId: '1001' },
});

const session = await client.sessions.create({
  context: { id: context.id, mode: 'readWrite' },
});

// SDK 也接受 'read_write'、'readOnly'、'read_only'
// 并会自动转换成 API 需要的格式。

const result = await client.sessions.list();
console.log(`Total: ${result.pagination.totalCount}`);
console.log(`Active: ${result.pagination.activeCount}`);

for (const session of result) {
  console.log(`${session.id}: ${session.status}`);
}

const activeSessions = await client.sessions.list({ status: 'active' });
console.log(`Found ${activeSessions.length} active sessions`);

await client.sessions.delete({ sessionId: 'session-id' });

// 或者直接使用会话对象上的辅助方法
await session.close();

const browser = await chromium.connectOverCDP(session.connectUrl);
const cdp = await browser.newBrowserCDPSession();
await cdp.send('Browser.setDownloadBehavior', {
  behavior: 'allow',
  downloadPath: '/config/Downloads',
  eventsEnabled: true,
});

const downloads = await client.sessions.downloads.list(session.id);
console.log(downloads.summary.count);

const fileBuffer = await client.sessions.downloads.get(session.id, 'download-id');
const archiveBuffer = await client.sessions.downloads.archive(session.id);

await client.sessions.downloads.delete(session.id);

const context = await client.contexts.create({
  metadata: { owner: 'demo' },
});

const contexts = await client.contexts.list({
  status: 'available',
  limit: 20,
});

const details = await client.contexts.get(context.id);
console.log(details.status);

await client.contexts.forceRelease(context.id);
await client.contexts.delete(context.id);

const extension = await client.extensions.upload('/absolute/path/to/extension.zip', {
  name: 'demo-extension',
});

const extensions = await client.extensions.list({ limit: 10 });
for (const item of extensions) {
  console.log(item.id, item.name);
}

const details = await client.extensions.get(extension.id);
await client.extensions.delete(extension.id);

import {
  APIError,
  AuthenticationError,
  ContextLockedError,
  ContextNotFoundError,
  NetworkError,
  TimeoutError,
} from 'lexmount';

try {
  await client.sessions.create({
    context: { id: 'ctx_123', mode: 'readWrite' },
  });
} catch (error) {
  if (error instanceof AuthenticationError) {
    console.error('鉴权失败');
  } else if (error instanceof ContextNotFoundError) {
    console.error('Context 不存在');
  } else if (error instanceof ContextLockedError) {
    console.error(error.activeSessionId, error.retryAfter);
  } else if (error instanceof TimeoutError || error instanceof NetworkError) {
    console.error('网络或超时异常');
  } else if (error instanceof APIError) {
    console.error(error.statusCode);
  } else {
    throw error;
  }
}

import { disableLogging, enableLogging, setLogLevel } from 'lexmount';

setLogLevel('DEBUG');
enableLogging('INFO');
disableLogging();