diff --git a/src/services/initDataManagerService.ts b/src/services/initDataManagerService.ts index 81194bb9f7189861d4fde2d6d80a5cf9ef4f8b49..5701fb20f30d20408c28dea67de769e6f578f25e 100644 --- a/src/services/initDataManagerService.ts +++ b/src/services/initDataManagerService.ts @@ -25,6 +25,8 @@ import ecogestureData from 'db/ecogestureData.json' import UserProfileDataManager from 'services/userProfileDataManagerService' import userProfileData from 'db/userProfileData.json' import KonnectorStatusService from 'services/konnectorStatusService' +import KonnectorService from 'services/konnectorService' +import { AccountService } from 'services/accountService' import { hashFile } from 'utils/hash' import { @@ -388,6 +390,8 @@ export default class InitDataManager { await this.createIndex(GRDF_HOUR_DOCTYPE) await this.createIndex(GRDF_MONTH_DOCTYPE) await this.createIndex(GRDF_YEAR_DOCTYPE) + await KonnectorService.createIndexKonnector(this._client) + await AccountService.createIndexAccount(this._client) return true } catch (error) { console.log('Context error: ', error) diff --git a/src/services/konnectorService.ts b/src/services/konnectorService.ts index b2521df2e609aac2e7a7176becb204ced0021d12..8684ae0e408c47e0136fc818a4bc2b4d8030d792 100644 --- a/src/services/konnectorService.ts +++ b/src/services/konnectorService.ts @@ -98,4 +98,13 @@ export default class KonnectorService { throw error } } + + static createIndexKonnector = async (client: Client) => { + const query = client + .find('io.cozy.konnectors') + // eslint-disable-next-line @typescript-eslint/camelcase + .where({ _id: 'index' }) + .limitBy(1) + return await client.query(query) + } } diff --git a/src/services/konnectorStatusService.ts b/src/services/konnectorStatusService.ts index 3bce39885e646ebb8513f7f6d7b76d622736c270..0b241f9f9152794bc6bee4ea6f2a1812677bef6f 100644 --- a/src/services/konnectorStatusService.ts +++ b/src/services/konnectorStatusService.ts @@ -105,8 +105,6 @@ export default class KonnectorStatusService { async getKonnectorAccountStatus(): Promise<FluidType[]> { try { const fluidConfig = new FluidConfigService().getFluidConfig() - // Create Index if not exists - await AccountService.createIndexAccount(this._client) const [elecData, gasData, waterData] = await Promise.all([ AccountService.getAccountByType( this._client,