Compare commits

..

No commits in common. "6419e4e1c964130ca313fc25ce6aab474bf5c5d7" and "bd0e3b9114e1261f2beed4f793f8b7d51b409f3f" have entirely different histories.

View File

@ -261,7 +261,8 @@ export default class Services {
* Tente d'établir des connexions (secrets partagés) avec les membres d'un état de processus. * Tente d'établir des connexions (secrets partagés) avec les membres d'un état de processus.
*/ */
public async ensureConnections(process: Process, stateId: string | null = null): Promise<void> { public async ensureConnections(process: Process, stateId: string | null = null): Promise<void> {
console.info(`[ConnectionCheck] 🔄 Démarrage de la vérification des connexions pour le processus (StateID: ${stateId || 'par défaut'})`); const processId = process?.process_id; // Utilisation de l'optional chaining au cas où process est null
console.info(`[ConnectionCheck] 🔄 Démarrage de la vérification des connexions pour le processus ${processId} (StateID: ${stateId || 'par défaut'})`);
if (!process) { if (!process) {
console.error(`[ConnectionCheck] 💥 ERREUR CRITIQUE: ensureConnections a été appelée avec un processus nul ou undefined.`); console.error(`[ConnectionCheck] 💥 ERREUR CRITIQUE: ensureConnections a été appelée avec un processus nul ou undefined.`);
@ -271,7 +272,7 @@ export default class Services {
// 1. Déterminer quel état analyser // 1. Déterminer quel état analyser
const state = this.getStateToCheck(process, stateId); const state = this.getStateToCheck(process, stateId);
if (!state) { if (!state) {
console.warn(`[ConnectionCheck] ⚠️ Aucun état valide trouvé pour le processus. (States: ${process.states.length}, StateID demandé: ${stateId}). Abandon.`); console.warn(`[ConnectionCheck] ⚠️ Aucun état valide trouvé pour le processus ${processId}. (States: ${process.states.length}, StateID demandé: ${stateId}). Abandon.`);
return; return;
} }
@ -660,6 +661,7 @@ export default class Services {
} }
public async updateProcess(process: Process, privateData: Record<string, any>, publicData: Record<string, any>, roles: Record<string, RoleDefinition> | null): Promise<ApiReturn> { public async updateProcess(process: Process, privateData: Record<string, any>, publicData: Record<string, any>, roles: Record<string, RoleDefinition> | null): Promise<ApiReturn> {
console.log(`[Services:updateProcess] 🔄 Mise à jour du processus ${process.process_id}...`);
// If roles is null, we just take the last commited state roles // If roles is null, we just take the last commited state roles
if (!roles) { if (!roles) {
roles = this.getRoles(process); roles = this.getRoles(process);
@ -679,7 +681,7 @@ export default class Services {
try { try {
const result = this.sdkClient.update_process(process, encodedPrivateData, roles, encodedPublicData, this.getAllMembers()); const result = this.sdkClient.update_process(process, encodedPrivateData, roles, encodedPublicData, this.getAllMembers());
if (result.updated_process) { if (result.updated_process) {
console.log(`[Services:updateProcess] ✅ Processus mis à jour. Vérification des connexions...`, process); console.log(`[Services:updateProcess] ✅ Processus ${process.process_id} mis à jour. Vérification des connexions...`);
await this.ensureConnections(result.updated_process.current_process); await this.ensureConnections(result.updated_process.current_process);
return result; return result;
} else { } else {
@ -841,7 +843,7 @@ export default class Services {
for (const process of Object.values(this.processesCache)) { for (const process of Object.values(this.processesCache)) {
const tip = process.states[process.states.length - 1].commited_in; const tip = process.states[process.states.length - 1].commited_in;
if (prevouts.includes(tip)) { if (prevouts.includes(tip)) {
const processId = process.states[0].commited_in; const processId = process.process_id; // Utilisation de l'ID stocké
const newTip = this.sdkClient.get_txid(transaction); const newTip = this.sdkClient.get_txid(transaction);
console.log(`[Services:updateProcessesFromNewTx] 🔗 La Tx ${newTip} dépense le tip du processus ${processId}`); console.log(`[Services:updateProcessesFromNewTx] 🔗 La Tx ${newTip} dépense le tip du processus ${processId}`);