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

Add some decoding logic in service

Browse Source
This commit is contained in:
NicolasCantu 2025-06-04 09:13:07 +02:00
parent 8eb6f36b64
commit 8260c6c5da
1 changed files with 25 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
src/services/service.ts
View File

@ -1001,8 +1001,17 @@ export default class Services {
console.error('Unknown process'); console.error('Unknown process');
return; return;
} }
const spAddressList = process.states[0].public_data['pairedAddresses'];
console.log(spAddressList); let spAddressList: string[] = [];
try {
const encodedSpAddressList = process.states[0].public_data['pairedAddresses'];
spAddressList = this.sdkClient.decode_value(encodedSpAddressList);
if (!spAddressList || spAddressList.length == 0) {
throw new Error('Empty pairedAddresses');
}
} catch (e) {
throw new Error(`Failed to get pairedAddresses from process: ${e}`);
}
try { try {
this.sdkClient.pair_device(this.processId, spAddressList); this.sdkClient.pair_device(this.processId, spAddressList);
} catch (e) { } catch (e) {
@ -1301,7 +1310,7 @@ export default class Services {
const processes: Record<string, Process> = await db.dumpStore('processes'); const processes: Record<string, Process> = await db.dumpStore('processes');
if (processes && Object.keys(processes).length != 0) { if (processes && Object.keys(processes).length != 0) {
console.log(`Restoring ${Object.keys(processes).length} processes`); console.log(`Restoring ${Object.keys(processes).length} processes`);
this.sdkClient.set_process_cache(JSON.stringify(processes)); this.sdkClient.set_process_cache(processes);
} else { } else {
console.log('No processes to restore!'); console.log('No processes to restore!');
} }
@ -1358,7 +1367,7 @@ export default class Services {
} }
} }
async decryptAttribute(processId: string, state: ProcessState, attribute: string): Promise<string | null> { async decryptAttribute(processId: string, state: ProcessState, attribute: string): Promise<any | null> {
let hash = state.pcd_commitment[attribute]; let hash = state.pcd_commitment[attribute];
if (!hash) { if (!hash) {
// attribute doesn't exist // attribute doesn't exist
@ -1392,10 +1401,18 @@ export default class Services {
const keyBlob = this.hexToBlob(key); const keyBlob = this.hexToBlob(key);
const keyBuf = await keyBlob.arrayBuffer(); const keyBuf = await keyBlob.arrayBuffer();
try {
const clear = this.sdkClient.decrypt_data(new Uint8Array(keyBuf), cipher); const clear = this.sdkClient.decrypt_data(new Uint8Array(keyBuf), cipher);
if (clear) { if (clear) {
// Parse the stringified JSON // deserialize the result to get the actual data
return JSON.parse(clear); const decoded = this.sdkClient.decode_value(clear);
console.log('Decoded value:', JSON.stringify(decoded));
return decoded;
} else {
throw new Error('decrypt_data returned null');
}
} catch (e) {
console.error('Failed to decrypt data:', e.toString());
} }
} }
} }