feat: Allow to clean the pouches with dataproxy.cleanPouches flag

Author: doubleface

src/App.tsx

@@ -1,6 +1,7 @@
-import React from 'react'
+import React, { useEffect } from 'react'
 
 import { useClient } from 'cozy-client'
+import flag from 'cozy-flags'
 import Minilog from 'cozy-minilog'
 
 import { ParentWindowProvider } from '@/dataproxy/parent/ParentWindowProvider'
@@ -15,6 +16,12 @@ const App = (): JSX.Element => {
   const client = useClient()
   const { worker, workerState } = useSharedWorker()
 
+  useEffect(() => {
+    if (flag('dataproxy.cleanPouch') === true) {
+      worker.forceSyncPouch({ clean: true })
+    }
+  }, [])
+
   return (
     <div className="content">
       <h1>Cozy DataProxy</h1>

src/dataproxy/common/DataProxyInterface.ts

@@ -17,7 +17,7 @@ export interface DataProxyWorker {
     clientData: ClientData,
     options?: { sharedDriveIds: string[] }
   ) => Promise<void>
-  forceSyncPouch: () => void
+  forceSyncPouch: (options?: { clean: boolean }) => Promise<void>
   requestLink: (
     definition: QueryDefinition | Mutation,
     options?: QueryOptions | MutationOptions

src/dataproxy/worker/worker.ts

@@ -188,14 +188,24 @@ const dataProxy: DataProxyWorker = {
     return queryRes
   },
 
-  forceSyncPouch: () => {
+  forceSyncPouch: async (
+    options: { clean: boolean } = { clean: false }
+  ): Promise<void> => {
     if (!client) {
       throw new Error(
         'Client is required to execute a forceSyncPouch, please initialize CozyClient'
       )
     }
     const pouchLink = getPouchLink(client)
     if (pouchLink) {
+      if (options.clean) {
+        await pouchLink.reset()
+        await pouchLink.registerClient(client) // because reset also resets the client
+        await pouchLink.onLogin()
+      } else {
+        await pouchLink.pouches.waitForCurrentReplications()
+      }
+
       pouchLink.startReplication()
     }
   },
@@ -221,7 +231,7 @@ const dataProxy: DataProxyWorker = {
       const replicationOptions = { strategy: 'fromRemote', driveId }
       const options = { shouldStartReplication: true }
       if (pouchLink.addDoctype) {
-        pouchLink.addDoctype(doctype, replicationOptions, options)
+        await pouchLink.addDoctype(doctype, replicationOptions, options)
       }
     }
 
@@ -232,15 +242,15 @@ const dataProxy: DataProxyWorker = {
     searchEngine.addSharedDrive(driveId)
   },
 
-  removeSharedDrive: (driveId: string) => {
+  removeSharedDrive: async (driveId: string) => {
     log.debug(`Worker: Removing shared drive ${driveId}`)
     if (!client) {
       throw new Error('Client is required to remove a shared drive')
     }
     const pouchLink = getPouchLink(client)
     if (pouchLink) {
       const doctype = `${SHARED_DRIVE_FILE_DOCTYPE}-${driveId}`
-      pouchLink.removeDoctype(doctype)
+      await pouchLink.removeDoctype(doctype)
     }
 
     if (!searchEngine) {