[sqlite] implement processing integrity store ops on worker
d27ead6e8d4c
Actions

Description

[sqlite] implement processing integrity store ops on worker

Summary:
Introduces integrity store ops to web worker

Depends on D11307

Test Plan:
Ran the following code on web and confirmed results:

await databaseModule.schedule({
  type: workerRequestMessageTypes.PROCESS_STORE_OPERATIONS,
  storeOperations: {
    integrityStoreOperations: [
      {
        type: 'remove_all_integrity_thread_hashes',
      },
    ],
  },
});

console.log(data?.store?.integrityThreadHashes);

const TEST_THREAD_HASHES_1 = [{ id: '256|2202182', threadHash: 2304934 }];

const TEST_THREAD_HASHES_2 = [
  { id: '256|2204191', threadHash: 1029853 },
  { id: '256|2205980', threadHash: 3119392 },
  { id: '256|2208693', threadHash: 4157082 },
  { id: '256|2210486', threadHash: 3425604 },
  { id: '256|2212631', threadHash: 8951764 },
];

await databaseModule.schedule({
  type: workerRequestMessageTypes.PROCESS_STORE_OPERATIONS,
  storeOperations: {
    integrityStoreOperations: [
      {
        type: 'replace_integrity_thread_hashes',
        payload: {
          threadHashes: TEST_THREAD_HASHES_1,
        },
      },
      {
        type: 'remove_all_integrity_thread_hashes',
      },
      {
        type: 'replace_integrity_thread_hashes',
        payload: {
          threadHashes: TEST_THREAD_HASHES_2,
        },
      },
      {
        type: 'remove_integrity_thread_hashes',
        payload: {
          ids: ['256|2205980', '256|2212631'],
        },
      },
    ],
  },
});

data = await databaseModule.schedule({
  type: workerRequestMessageTypes.GET_CLIENT_STORE,
});

console.log(data?.store?.integrityThreadHashes);