4nk/ihm_client
5
0
Fork 0
Code Issues 6 Pull Requests Actions Packages Projects Releases Wiki Activity

Update more aggressively processes on relay notifications

Browse Source
This commit is contained in:
NicolasCantu 2025-03-03 23:24:41 +01:00
parent bde2ed0e44
commit b6c2d211e5
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/services/service.ts
View File

@ -1059,10 +1059,21 @@ export default class Services {
for (const [processId, process] of Object.entries(newProcesses)) { for (const [processId, process] of Object.entries(newProcesses)) {
const existing = await this.getProcess(processId); const existing = await this.getProcess(processId);
if (existing) { if (existing) {
// We check if we have public_data on the first state
if (Object.keys(process.states[0].public_data).length != 0) {
await this.saveProcessToDb(processId, process as Process);
const event = new CustomEvent('process-updated', {
detail: { processId }
});
window.dispatchEvent(event);
continue;
}
const lastKnownCommitment = this.getLastCommitedState(existing); const lastKnownCommitment = this.getLastCommitedState(existing);
const newLastCommitment = this.getLastCommitedState(process); const newLastCommitment = this.getLastCommitedState(process);
if (!lastKnownCommitment || !newLastCommitment) { continue } if (!lastKnownCommitment || !newLastCommitment) { continue }
if (lastKnownCommitment.commited_in !== newLastCommitment.commited_in) { if (lastKnownCommitment.commited_in !== newLastCommitment.commited_in) {
// Update the process in db with the new one
await this.saveProcessToDb(processId, process as Process);
console.log('Dispatching process-updated event'); console.log('Dispatching process-updated event');
const event = new CustomEvent('process-updated', { const event = new CustomEvent('process-updated', {
detail: { processId } detail: { processId }