0

有 3 个基础（前端、节点、远程）。前端 <=> 节点，节点 <=> 远程。当前端基地更新时，数据会转到远程基地，但节点没有更新。理论上应该先更新节点，再更新远程基地。

渲染数据库

addPouchPlugin(PouchdbAdapterIdb)
addPouchPlugin(PouchHttpPlugin)

addRxPlugin(RxDBReplicationCouchDBPlugin)
addRxPlugin(RxDBMigrationPlugin)
addRxPlugin(RxDBLeaderElectionPlugin)
addRxPlugin(RxDBQueryBuilderPlugin)
addRxPlugin(RxDBAjvValidatePlugin)
addRxPlugin(RxDBUpdatePlugin)

export const createDb = async () => {
  console.log('[src/renderer/database/createDb] createDb')
  const productsName = collectionName.getCollectionProductsName()
  const documentsName = collectionName.getCollectionDocumentsName()
  const settingsName = collectionName.getCollectionSettingsName()

  const db = await createRxDatabase<Collections>({
    name: 'renderer',
    // use pouchdb with the indexeddb-adapter as storage engine.
    storage: getRxStoragePouch('idb'),
  })
  await initCommonCollections({ db, documentsName, productsName, settingsName })
  syncDbCollections(db, [productsName, documentsName, settingsName])

  db.$.subscribe(({ operation, documentId, documentData }) => {
    if (documentData.type === SettingsTypes.DEVICE_SETTING) {
      console.log(`Change database RENDER event:\n ${operation}, \n documentData:`, documentData)
    }
  })

  return db
}

渲染同步

const remoteDbUrl = `http://localhost:3030/db/`
const logPath = '[src/renderer/database/syncDbCollections]'

export const syncDbCollections = (db: RxDatabase<Collections>, collectionNames: (keyof Collections)[]) => {
  console.log('syncDbCollections', collectionNames)
  collectionNames.forEach(name => {
    const rxReplicationState = db.collections[name].syncCouchDB({
      remote: `${remoteDbUrl}${name}`,
      options: {
        live: true,
        retry: true,
      },
    })

    rxReplicationState.error$.subscribe(error => {
      console.error(logPath, name, 'error', JSON.stringify(error))
    })
  })
}

节点基础

addPouchPlugin(PouchdbAdapterHttp)
addPouchPlugin(LevelDbAdapter)
addRxPlugin(RxDBAjvValidatePlugin)
addRxPlugin(RxDBMigrationPlugin)
addRxPlugin(RxDBServerPlugin)
addRxPlugin(RxDBLeaderElectionPlugin)
addRxPlugin(RxDBQueryBuilderPlugin)
addRxPlugin(RxDBUpdatePlugin)
addRxPlugin(RxDBReplicationCouchDBPlugin)

let db: RxDatabase<Collections>

export const getMainDb = () => {
  if (!db) {
    throw new Error('No available database.')
  }
  return db
}

export const getDocumentCollection = (): DocumentsRxCol => {
  return db[collectionNames.getCollectionDocumentsName()]
}

export const getSettingsCollection = (): SettingsRxCol => {
  return db[collectionNames.getCollectionSettingsName()]
}

export const getProductsCollection = (): ProductsRxCol => {
  return db[collectionNames.getCollectionProductsName()]
}

export const initDatabase = async () => {
  console.log(logPathAlias, 'initDatabase')
  if (db) {
    console.warn(logPathAlias, 'db instance already created!')
    return db
  }
  db = await createRxDatabase<Collections>({
    name: `${electronApp.getPath('userData')}/db`,
    storage: getRxStoragePouch(LevelDown),
  })

  const productsName = collectionNames.getCollectionProductsName()
  const documentsName = collectionNames.getCollectionDocumentsName()
  const settingsName = collectionNames.getCollectionSettingsName()

  await initCommonCollections({ db, productsName, documentsName, settingsName })
  await syncCollections([productsName, documentsName, settingsName])

  db.$.subscribe(({ operation, documentId, documentData }) => {
    // if (documentData.type === SettingsTypes.DEVICE_SETTING) {
    console.log(`Change database NODE event:\n ${operation}, \n documentData:`, documentData)
    // }
  })

  const { app } = await db.server({
    startServer: false, // (optional), start express server
    // options of the pouchdb express server
    cors: false,
    pouchdbExpressOptions: {
      inMemoryConfig: true, // do not write a config.json
      logPath: `${electronApp.getPath('temp')}/rxdb-server.log`, // save logs in tmp folder
    },
  })

  return app
}

const lastRetryTime = {}
const syncCollections = async (collections: CollectionNames[]) => {
  collections.map(collectionName => {
    const rxReplicationState = db.collections[collectionName].syncCouchDB({
      remote: `${CouchDbServerUrl}/${collectionName}`,
      options: {
        live: true,
        retry: true,
        // @ts-ignore
        // headers: {
        //   Authorization: `Bearer ${getAccessToken()}`,
        // },
      },
    })
    rxReplicationState.error$.subscribe(async error => {
      console.error(logPathAlias, collectionName, String(error))
      if (error.status === 401 && dayjs().diff(lastRetryTime[collectionName], 'seconds') > 10 && getIsRefreshFresh()) {
        lastRetryTime[collectionName] = dayjs()
        await rxReplicationState.cancel()
        await refreshTokens()
        await syncCollections([collectionName])
      }
    })
  })
}

没有错误

此外，如果您将数据保存在远程数据库中，那么它们将与节点同步

帮我 ：（

4

0 回答 0