Method setupIPC

src/main/api/shared/database.ts:63–387

()

  }

  private setupIPC(): void {
    // ============ 同步API（供插件使用） ============
    ipcMain.on('db:put', (event, doc) => {
      const prefix = this.getPluginPrefix(event)
      if (prefix) {
        doc._id = prefix + doc._id
      }
      const result = lmdbInstance.put(doc)
      // 如果是插件调用，需要去除返回结果中的前缀
      if (prefix && result.id && result.id.startsWith(prefix)) {
        result.id = result.id.slice(prefix.length)
      }
      event.returnValue = result
    })

    ipcMain.on('db:get', (event, id) => {
      const prefix = this.getPluginPrefix(event)
      if (prefix) {
        id = prefix + id
      }
      const doc = lmdbInstance.get(id)
      // 如果是插件调用，需要去除返回文档的前缀
      if (doc && prefix && doc._id.startsWith(prefix)) {
        doc._id = doc._id.slice(prefix.length)
      }
      event.returnValue = doc
    })

    ipcMain.on('db:remove', (event, docOrId) => {
      const prefix = this.getPluginPrefix(event)
      if (prefix) {
        if (typeof docOrId === 'string') {
          docOrId = prefix + docOrId
        } else {
          docOrId._id = prefix + docOrId._id
        }
      }
      const result = lmdbInstance.remove(docOrId)
      console.log('[Database] sync db:remove', docOrId, 'result', result)
      // 如果是插件调用，需要去除返回结果中的前缀
      if (prefix && result.id && result.id.startsWith(prefix)) {
        result.id = result.id.slice(prefix.length)
      }
      event.returnValue = result
    })

    ipcMain.on('db:bulk-docs', (event, docs) => {
      const prefix = this.getPluginPrefix(event)
      if (prefix) {
        docs.forEach((doc: any) => {
          doc._id = prefix + doc._id
        })
      }
      const results = lmdbInstance.bulkDocs(docs)
      // 如果是插件调用，需要去除返回结果中的前缀
      if (prefix && Array.isArray(results)) {
        results.forEach((result) => {
          if (result.id && result.id.startsWith(prefix)) {