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

Add getMyProcesses api

Browse Source
This commit is contained in:
Sosthene 2025-06-11 20:35:17 +02:00 committed by NicolasCantu
parent b52ff937f0
commit 00bc3d8ad2
2 changed files with 39 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/models/process.model.ts
View File

@ -30,6 +30,7 @@ export enum MessageType {
CREATE_PROFILE = 'CREATE_PROFILE', CREATE_PROFILE = 'CREATE_PROFILE',
PROFILE_CREATED = 'PROFILE_CREATED', PROFILE_CREATED = 'PROFILE_CREATED',
GET_PROCESSES = 'GET_PROCESSES', GET_PROCESSES = 'GET_PROCESSES',
GET_MY_PROCESSES = 'GET_MY_PROCESSES',
PROCESSES_RETRIEVED = 'PROCESSES_RETRIEVED', PROCESSES_RETRIEVED = 'PROCESSES_RETRIEVED',
CREATE_FOLDER = 'CREATE_FOLDER', CREATE_FOLDER = 'CREATE_FOLDER',
FOLDER_CREATED = 'FOLDER_CREATED', FOLDER_CREATED = 'FOLDER_CREATED',

38
src/router.ts
View File

@ -269,6 +269,42 @@ export async function registerAllListeners() {
} }
} }
const handleGetMyProcesses = async (event: MessageEvent) => {
if (event.data.type !== MessageType.GET_MY_PROCESSES) {
return;
}
const tokenService = await TokenService.getInstance();
if (!services.isPaired()) {
const errorMsg = 'Device not paired';
errorResponse(errorMsg, event.origin);
return;
}
try {
const { accessToken } = event.data;
// Validate the session token
if (!accessToken || await !tokenService.validateToken(accessToken, event.origin)) {
throw new Error('Invalid or expired session token');
}
const myProcesses = await services.getMyProcesses();
window.parent.postMessage(
{
type: MessageType.GET_MY_PROCESSES,
myProcesses
},
event.origin
);
} catch (e) {
const errorMsg = `Failed to get processes: ${e}`;
errorResponse(errorMsg, event.origin);
}
}
const handleGetProcesses = async (event: MessageEvent) => { const handleGetProcesses = async (event: MessageEvent) => {
if (event.data.type !== MessageType.GET_PROCESSES) { if (event.data.type !== MessageType.GET_PROCESSES) {
return; return;
@ -484,6 +520,7 @@ export async function registerAllListeners() {
window.removeEventListener('message', handleRequestLink); window.removeEventListener('message', handleRequestLink);
window.removeEventListener('message', handleAddProfile); window.removeEventListener('message', handleAddProfile);
window.removeEventListener('message', handleGetProcesses); window.removeEventListener('message', handleGetProcesses);
window.removeEventListener('message', handleGetMyProcesses);
window.removeEventListener('message', handleAddFolder); window.removeEventListener('message', handleAddFolder);
window.removeEventListener('message', handleDecryptState); window.removeEventListener('message', handleDecryptState);
window.removeEventListener('message', handleValidateToken); window.removeEventListener('message', handleValidateToken);
@ -493,6 +530,7 @@ export async function registerAllListeners() {
window.addEventListener('message', handleRequestLink); window.addEventListener('message', handleRequestLink);
window.addEventListener('message', handleAddProfile); window.addEventListener('message', handleAddProfile);
window.addEventListener('message', handleGetProcesses); window.addEventListener('message', handleGetProcesses);
window.addEventListener('message', handleGetMyProcesses);
window.addEventListener('message', handleAddFolder); window.addEventListener('message', handleAddFolder);
window.addEventListener('message', handleDecryptState); window.addEventListener('message', handleDecryptState);
window.addEventListener('message', handleValidateToken); window.addEventListener('message', handleValidateToken);