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

Add handleInitMsg

Browse Source
This commit is contained in:
NicolasCantu 2025-01-02 22:47:15 +01:00
parent 5a5ae4ada3
commit fa3eaeb511
2 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/services/service.ts
View File

@ -3,7 +3,7 @@ import { INotification } from '~/models/notification.model';
import { IProcess } from '~/models/process.model'; import { IProcess } from '~/models/process.model';
// import Database from './database'; // import Database from './database';
import { initWebsocket, sendMessage } from '../websockets'; import { initWebsocket, sendMessage } from '../websockets';
import { ApiReturn, Device, Member, Process, RoleDefinition, SecretsStore, UserDiff } from '../../pkg/sdk_client'; import { ApiReturn, Device, InitMessage, Member, Process, RoleDefinition, SecretsStore, UserDiff } from '../../pkg/sdk_client';
import ModalService from './modal.service'; import ModalService from './modal.service';
import Database from './database.service'; import Database from './database.service';
import { storeData, retrieveData } from './storage.service'; import { storeData, retrieveData } from './storage.service';
@ -800,4 +800,15 @@ export default class Services {
this.device1 = false; this.device1 = false;
this.device2Ready = false; this.device2Ready = false;
} }
public async handleInitMsg(url: string, parsedMsg: any) {
try {
const initMsg: InitMessage = JSON.parse(parsedMsg);
this.updateRelay(url, initMsg.sp_address);
const processes: [string, Process][] = JSON.parse(initMsg.processes_list!);
} catch (e) {
console.error('Failed to parse init message:', parsedMsg);
}
}
} }

2
src/websockets.ts
View File

@ -30,7 +30,7 @@ export async function initWebsocket(url: string) {
const services = await Services.getInstance(); const services = await Services.getInstance();
switch (parsedMessage.flag) { switch (parsedMessage.flag) {
case 'Init': case 'Init':
services.updateRelay(url, parsedMessage.content); services.handleInitMsg(url, parsedMessage.content);
break; break;
case 'NewTx': case 'NewTx':
await services.parseNewTx(parsedMessage.content); await services.parseNewTx(parsedMessage.content);