/**
 * 导入下面的文件会初始化扩展的后台环境。
 *
 * 注意事项：
 * 1. 不要移除下面的 import 语句。它是扩展正常工作所必需的。
 *    如果你不需要 createBridge()，保留 "import '#q-app/bex/background'" 即可。
 * 2. 不要在多个后台脚本中导入此文件。只能在一个中导入！
 * 3. 在你的后台 Service Worker 中导入（如果目标浏览器支持的话）。
 */
import { createBridge } from "#q-app/bex/background";

/**
 * 调用 createBridge() 以启用与应用和内容脚本的通信
 *（以及应用与内容脚本之间的通信），否则跳过调用
 * createBridge() 即表示不使用 bridge。
 */
const bridge = createBridge({ debug: false });

/**
 * 导入下面的文件会初始化内容脚本。
 *
 * 注意事项：
 *   不要移除下面的 import 语句。它是扩展正常工作所必需的。
 *   如果你不需要 createBridge()，保留 "import '#q-app/bex/content'" 即可。
 */
import { createBridge } from "#q-app/bex/content";

// bridge 的使用是可选的。
const bridge = createBridge({ debug: false });
/**
 * bridge.portName 的格式为 'content@<path>-<number>'
 *   其中 <path> 是该内容脚本文件相对于 /src-bex 的路径
 *   （不含扩展名）
 *   （例如 'my-content-script'、'subdir/my-script'）
 *   <number> 是一个唯一的实例编号（1-10000）。
 */

// 附加初始的 bridge 监听器...

/**
 * 请在附加完初始监听器之后再执行此步骤，
 * 以便 bridge 能够正确处理它们。
 *
 * 你也可以稍后通过调用 bridge.disconnectFromBackground()
 * 断开与后台脚本的连接。
 *
 * 要检查连接状态，访问 bridge.isConnected
 */
bridge
  .connectToBackground()
  .then(() => {
    console.log("Connected to background");
  })
  .catch((err) => {
    console.error("Failed to connect to background:", err);
  });

// 监听来自客户端的消息
bridge.on('test', message => {
  console.log(message)
  console.log(message.payload)
  console.log(message.from)
})

// 发送消息并将 payload 拆分为块（chunk）
// 以避免 BEX 消息的最大大小限制。
// 注意！当 payload 是数组时，这会自动发生。
// 如果你确实要发送一个数组，请将它包装在对象中。
bridge.send({
  event: 'test',
  to: 'app',
  payload: [ 'chunk1', 'chunk2', 'chunk3', ... ]
}).then(responsePayload => { ... }).catch(err => { ... })

// 发送消息并等待响应
bridge.send({
  event: 'test',
  to: 'background',
  payload: { banner: 'Hello from content-script' }
}).then(responsePayload => { ... }).catch(err => { ... })

// 监听来自客户端的消息并同步响应
bridge.on('test', message => {
  console.log(message)
  return { banner: 'Hello from a content-script!' }
})

// 监听来自客户端的消息并异步响应
bridge.on('test', async message => {
  console.log(message)
  const result = await someAsyncFunction()
  return result
})
bridge.on('test', message => {
  console.log(message)
  return new Promise(resolve => {
    setTimeout(() => {
      resolve({ banner: 'Hello from a content-script!' })
    }, 1000)
  })
})

// 向应用和内容脚本广播消息
bridge.portList.forEach(portName => {
  bridge.send({ event: 'test', to: portName, payload: 'Hello from background!' })
})

// 查找任意已连接的内容脚本并向其发送消息
const contentPort = bridge.portList.find(portName => portName.startsWith('content@'))
if (contentPort) {
  bridge.send({ event: 'test', to: contentPort, payload: 'Hello from background!' })
}

// 向特定的内容脚本发送消息
bridge
  .send({ event: 'test', to: 'content@my-content-script-2345', payload: 'Hello from a content-script!' })
  .then(responsePayload => { ... })
  .catch(err => { ... })

// 监听连接事件
// （"@quasar:ports" 是 bridge 自动注册的内部事件名）
// --> ({ portList: string[], added?: string } | { portList: string[], removed?: string })
bridge.on('@quasar:ports', ({ portList, added, removed }) => {
  console.log('Ports:', portList)
  if (added) {
    console.log('New connection:', added)
  } else if (removed) {
    console.log('Connection removed:', removed)
  }
})

// 当前 bridge 端口名称（可能是 'background'、'app' 或 'content@<name>-<xxxxx>'）
console.log(bridge.portName)

// 动态设置调试模式
bridge.setDebug(true); // boolean

// 在控制台输出日志（仅在调试模式启用时）
bridge.log("Hello world!");
bridge.log("Hello", "world!");
bridge.log("Hello world!", { some: "data" });
bridge.log("Hello", "world", "!", { some: "object" });
// 在控制台输出警告（不受调试模式设置的影响）
bridge.warn("Hello world!");
bridge.warn("Hello", "world!");
bridge.warn("Hello world!", { some: "data" });
bridge.warn("Hello", "world", "!", { some: "object" });

bridge.off("some.event", this.someFunction);