feat: Allow clisk konnectors to run server job (SCR-845)

src/libs/Launcher.js

@@ -471,6 +471,58 @@
     }
   }
 
+  /**
+   * Allow client konnector to run a server version of itself. Wait for the end of the execution
+   * and the returns the result of the execution
+   *
+   * @param {Object} args - any arguments we want to pass to server job. Must be serializable as string
+   * @param {Object} [options] - options object
+   * @param {Number} [options.timeout] - timeout in ms
+   * @param {Number} [options.max_exec_count] - maximum errored execution count
+   * @returns {Promise<Object>}
+   */
+  async runServerJob(args = {}, options = {}) {
+    const { client, konnector, trigger, account } = this.getStartContext() || {}
+    const jobArgs = {
+      ...args,
+      konnector: konnector.slug,
+      account: account._id,
+      folder_to_save: trigger.message?.folder_to_save
+    }
+    const { data: job } = await client
+      .collection('io.cozy.jobs')
+      .create('konnector', jobArgs, options, true)
+    return await client.collection('io.cozy.jobs').waitFor(job.id)
+  }
+
+  /**
+   * Save data in the current account's data attribute
+   *
+   * @param {Object} data - any object serializable with JSON.stringify
+   * @returns <Promise<import('cozy-client/types/types').IOCozyAccount>>
+   */
+  async saveAccountData(data) {
+    const { launcherClient: client, account } = this.getStartContext() || {}
+
+    if (!account._id) {
+      throw new Error(
+        'Launcher: No associated account. Cannot save account data yet'
+      )
+    }
+
+    const { data: currentAccount } = await client.query(
+      Q('io.cozy.accounts').getById(account._id)
+    )
+    currentAccount.data = data
+    const { data: newAccount } = await client.save(currentAccount)
+
+    this.setStartContext({
+      ...this.getStartContext(),
+      account: newAccount
+    })
+    return newAccount
+  }
+
   /**
    * Calls cozy-konnector-libs' saveFiles function
    *

src/libs/ReactNativeLauncher.js

@@ -151,12 +151,15 @@ class ReactNativeLauncher extends Launcher {
           'saveIdentity',
           'queryAll',
           'setUserAgent',
+          'setIncognito',
           'getCredentials',
           'saveCredentials',
           'getCookiesByDomain',
           'saveCookieToKeychain',
           'getCookieByDomainAndName',
-          'getCookieFromKeychainByName'
+          'getCookieFromKeychainByName',
+          'saveAccountData',
+          'runServerJob'
         ],
         listenedEventsNames: ['log']
       }),
@@ -581,6 +584,15 @@ class ReactNativeLauncher extends Launcher {
     this.emit('SET_USER_AGENT', userAgent)
   }
 
+  /**
+   * Set incognito mode for worker webview
+   *
+   * @param {Boolean} incognito
+   */
+  async setIncognito(incognito) {
+    this.emit('SET_INCOGNITO', incognito)
+  }
+
   /**
    * Run the specified method in the worker and make it fail with WORKER_WILL_RELOAD message
    * if the worker page is reloaded

src/libs/ReactNativeLauncher.spec.js

@@ -69,6 +69,8 @@ describe('ReactNativeLauncher', () => {
     const ensureDirectoryExists = jest.fn()
     const addReferencesTo = jest.fn()
     const get = jest.fn().mockResolvedValue({ data: { _id: 'testfolderid' } })
+    const create = jest.fn()
+    const waitFor = jest.fn()
     const statByPath = jest
       .fn()
       .mockResolvedValue({ data: { _id: 'testfolderid' } })
@@ -93,7 +95,9 @@ describe('ReactNativeLauncher', () => {
         get,
         statByPath,
         statById,
-        add
+        add,
+        create,
+        waitFor
       }),
       getInstanceOptions: jest.fn().mockReturnValueOnce({ locale: 'fr' })
     }
@@ -103,10 +107,12 @@ describe('ReactNativeLauncher', () => {
       client,
       findReferencedBy,
       get,
+      create,
       ensureDirectoryExists,
       addReferencesTo,
       statByPath,
-      add
+      add,
+      waitFor
     }
   }
 
@@ -947,4 +953,39 @@ describe('ReactNativeLauncher', () => {
       ).rejects.toEqual(ERRORS.SET_WORKER_STATE_TOO_LONG_TO_INIT)
     })
   })
+  describe('runServerJob', () => {
+    it('should create job with proper parameters', async () => {
+      const { launcher, client, create, waitFor } = setup()
+      create.mockResolvedValueOnce({ data: { id: 'testjobid' } })
+      waitFor.mockResolvedValueOnce({ data: { id: 'testjobid' } })
+      const konnector = {
+        slug: 'konnectorslug',
+        clientSide: true
+      }
+      launcher.setStartContext({
+        client,
+        konnector,
+        manifest: konnector,
+        launcherClient: {
+          setAppMetadata: () => null
+        },
+        account: fixtures.account,
+        trigger: fixtures.trigger
+      })
+      const result = await launcher.runServerJob({ test: 'testvalue' })
+      expect(create).toHaveBeenCalledTimes(1)
+      expect(create).toHaveBeenCalledWith(
+        'konnector',
+        {
+          test: 'testvalue',
+          account: 'normal_account_id',
+          folder_to_save: 'testfolderid',
+          konnector: 'konnectorslug'
+        },
+        {},
+        true
+      )
+      expect(result).toEqual({ data: { id: 'testjobid' } })
+    })
+  })
 })

src/screens/konnectors/LauncherView.js

@@ -57,6 +57,7 @@ export class LauncherView extends Component {
     this.workerWebview = null
     this.state = {
       userAgent: undefined,
+      incognito: false,
       konnector: null,
       workerInnerUrl: null,
       worker: {},
@@ -220,6 +221,9 @@ export class LauncherView extends Component {
     this.launcher.on('SET_USER_AGENT', userAgent => {
       this.setState({ userAgent })
     })
+    this.launcher.on('SET_INCOGNITO', incognito => {
+      this.setState({ incognito })
+    })
     this.launcher.on('CREATED_ACCOUNT', this.onCreatedAccount)
     this.launcher.on('CREATED_JOB', this.onCreatedJob)
     this.launcher.on('STOPPED_JOB', this.onStoppedJob)
@@ -304,6 +308,7 @@ export class LauncherView extends Component {
                 javaScriptEnabled={true}
                 onContentProcessDidTerminate={this.onWorkerWebviewKilled}
                 onRenderProcessGone={this.onWorkerWebviewKilled}
+                incognito={this.state.incognito}
                 userAgent={this.state.userAgent}
                 source={{
                   uri: this.state.worker.url