RocketChat/Rocket.Chat

import { Apps } from '@rocket.chat/apps';
import type { AppSignatureManager } from '@rocket.chat/apps-engine/server/managers/AppSignatureManager';
import type { IAppStorageItem } from '@rocket.chat/apps-engine/server/storage';

import type { AppRealStorage } from '../../../ee/server/apps/storage';
import { addMigration } from '../../lib/migrations';

addMigration({
    version: 292,
    name: 'Add checksum signature to existing apps',
    async up() {
        if (!Apps.self) {
            throw new Error('Apps Orchestrator not registered.');
        }

        Apps.initialize();

        const sigMan = Apps.getManager()?.getSignatureManager() as AppSignatureManager;
        const appsStorage = Apps.getStorage() as AppRealStorage;

        const apps = await appsStorage.retrieveAll();

        const promises: Promise<IAppStorageItem>[] = [];

        for await (const app of apps.values()) {
            promises.push(
                appsStorage.update({
                    ...app,
                    signature: await sigMan.signApp(app),
                }),
            );
        }

        await Promise.all(promises);
    },
});