feat(splash): init fluidPrices for latest data

src/components/Splash/SplashRoot.tsx

@@ -204,7 +204,7 @@ const SplashRoot = ({ fadeTimer = 1000, children }: SplashRootProps) => {
         if (subscribed) dispatch(updateTermsStatus(termsStatus))
 
         // Init fluidPrices
-        await initializationService.initFluidPrices()
+        await initializationService.initFluidPrices(client)
 
         // Init profile and update ecogestures, challenges, analysis
         const profile = await initializationService.initProfile()

src/services/initialization.service.ts

 import * as Sentry from '@sentry/react'
-import { Client } from 'cozy-client'
+import { Client, Q, QueryDefinition, QueryResult } from 'cozy-client'
 import logger from 'cozy-logger'
 import challengeEntityData from 'db/challengeEntity.json'
 import duelEntityData from 'db/duelEntity.json'
@@ -29,6 +29,7 @@ import {
   ProfileEcogesture,
   ProfileType,
   TermsStatus,
+  Trigger,
   UserChallenge,
 } from 'models'
 import React from 'react'
@@ -161,14 +162,13 @@ export default class InitializationService {
     }
   }
 
-  public async initFluidPrices(): Promise<boolean> {
+  public async initFluidPrices(client: Client): Promise<boolean> {
     const startTime = performance.now()
     const fpService = new FluidPricesService(this._client)
     // Populate data if none ecogesture exists
     const loadedPrices = await fpService.getAllPrices()
     if (loadedPrices?.length) {
       logDuration('[Initialization] FluidPrices db already created', startTime)
-      return true
     } else {
       try {
         const fluidTypes: FluidType[] = [
@@ -192,7 +192,6 @@ export default class InitializationService {
           await fpService.createPrice(price)
         }
         logDuration('[Initialization] FluidPrices db created', startTime)
-        return true
       } catch (error) {
         const errorMessage = `Initialization error - initFluidPrices: ${JSON.stringify(
           error
@@ -203,6 +202,29 @@ export default class InitializationService {
         return false
       }
     }
+    // Launching fluidPrices service to apply new price to latest data
+    logDuration('[Initialization] Launching fluidPrices service', startTime)
+    const triggerQuery: QueryDefinition = Q('io.cozy.triggers').where({
+      'message.name': 'fluidsPrices',
+    })
+    const {
+      data: [trigger],
+    }: QueryResult<Array<Trigger>> = await client.query(triggerQuery)
+    if (trigger?._id) {
+      client
+        .getStackClient()
+        .fetchJSON('POST', `/jobs/triggers/${trigger._id}/launch`)
+      logDuration(
+        '[Initialization] fluidPrices service launched successfully',
+        startTime
+      )
+    } else {
+      logDuration(
+        '[Initialization] FluidPrices service trigger not found',
+        startTime
+      )
+    }
+    return true
   }
 
   public async initChallengeEntity(hash: string): Promise<string> {