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

create_in_local_process_ok

Browse Source
This commit is contained in:
Pascal 2025-01-14 01:05:58 +01:00
parent c521d34504
commit 59d7c94971
1 changed files with 38 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
src/pages/chat/chat.ts
View File

@ -522,34 +522,54 @@ class ChatElement extends HTMLElement {
memberItem.onclick = async (event) => { memberItem.onclick = async (event) => {
event.stopPropagation(); event.stopPropagation();
try { try {
console.log('🔍 Début création process message');
const parentProcessId = this.getAttribute('process-id'); const parentProcessId = this.getAttribute('process-id');
console.log('🔍 Parent Process ID:', parentProcessId); const roleName = roleElement.querySelector('.role-name')?.textContent || 'default';
console.log('📝 Parent Process ID:', parentProcessId);
console.log('👑 Role Name:', roleName);
console.log('👤 Member:', member);
const myAddresses = await this.getMemberFromDevice();
if (!myAddresses) throw new Error('No paired member found');
if (!parentProcessId) { if (!parentProcessId) {
throw new Error('No parent process ID found'); throw new Error('No parent process ID found');
} }
const messageProcess = {
value_commitment: parentProcessId,
parent_id: parentProcessId,
description: "process_message",
messages: {
object: {
content: {
sender: myAddresses[0],
recipient: member.sp_addresses[0],
role: roleName
}
}
}
};
console.log('📋 Message Process à sauvegarder:', messageProcess);
const db = await Database.getInstance(); const db = await Database.getInstance();
const processes = await db.getObject('processes', parentProcessId); console.log('💾 Base de données obtenue');
console.log('💾 Processus trouvé:', processes);
if (processes) { await db.addObject({
console.log('✅ Processus existant trouvé, chargement de la conversation'); storeName: 'diffs',
this.loadMemberChat(member.sp_addresses[0]); object: messageProcess,
} else { key: messageProcess.value_commitment
console.log('🆕 Création d\'un nouveau processus de message'); });
const roleName = roleElement.querySelector('.role-name')?.textContent || 'default';
const result = await this.createMessagingProcess( if (messageProcess.value_commitment) {
[member], console.log('✅ Process message créé dans diffs avec clé:', messageProcess.value_commitment);
'relay_address', const savedProcess = await db.getObject('diffs', messageProcess.value_commitment);
1, console.log('🔍 Vérification du process sauvegardé:', savedProcess);
parentProcessId,
roleName
);
this.loadMemberChat(member.sp_addresses[0]);
} }
console.log('Process message créé dans diffs:', messageProcess);
this.loadMemberChat(member.sp_addresses[0]);
} catch (error) { } catch (error) {
console.error('❌ Erreur lors du clic:', error); console.error('❌ Erreur lors du clic:', error);
console.error('Details:', error);
} }
}; };
@ -1118,7 +1138,7 @@ class ChatElement extends HTMLElement {
// Chercher le processus message dans les rôles // Chercher le processus message dans les rôles
for (const role in roles) { for (const role in roles) {
console.log(`🔍 Vérification du rôle: ${role}`); console.log(`Vérification du rôle: ${role}`);
const members = roles[role].members; const members = roles[role].members;
if (members?.some((member: any) => if (members?.some((member: any) =>
spAddresses.includes(member.sp_addresses[0]) spAddresses.includes(member.sp_addresses[0])