From 59d7c9497175660767ea4b62e32bbc91899a8d36 Mon Sep 17 00:00:00 2001 From: Pascal Date: Tue, 14 Jan 2025 01:05:58 +0100 Subject: [PATCH] create_in_local_process_ok --- src/pages/chat/chat.ts | 56 ++++++++++++++++++++++++++++-------------- 1 file changed, 38 insertions(+), 18 deletions(-) diff --git a/src/pages/chat/chat.ts b/src/pages/chat/chat.ts index 61d9f7e..52c7097 100755 --- a/src/pages/chat/chat.ts +++ b/src/pages/chat/chat.ts @@ -522,34 +522,54 @@ class ChatElement extends HTMLElement { memberItem.onclick = async (event) => { event.stopPropagation(); try { + console.log('🔍 Début création process message'); 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) { 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 processes = await db.getObject('processes', parentProcessId); - console.log('💾 Processus trouvé:', processes); + console.log('💾 Base de données obtenue'); - if (processes) { - console.log('✅ Processus existant trouvé, chargement de la conversation'); - this.loadMemberChat(member.sp_addresses[0]); - } else { - console.log('🆕 Création d\'un nouveau processus de message'); - const roleName = roleElement.querySelector('.role-name')?.textContent || 'default'; - const result = await this.createMessagingProcess( - [member], - 'relay_address', - 1, - parentProcessId, - roleName - ); - this.loadMemberChat(member.sp_addresses[0]); + await db.addObject({ + storeName: 'diffs', + object: messageProcess, + key: messageProcess.value_commitment + }); + + if (messageProcess.value_commitment) { + console.log('✅ Process message créé dans diffs avec clé:', messageProcess.value_commitment); + const savedProcess = await db.getObject('diffs', messageProcess.value_commitment); + console.log('🔍 Vérification du process sauvegardé:', savedProcess); } + + console.log('Process message créé dans diffs:', messageProcess); + this.loadMemberChat(member.sp_addresses[0]); } catch (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 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; if (members?.some((member: any) => spAddresses.includes(member.sp_addresses[0])