Compare commits

...

2 Commits

View File

@ -261,8 +261,7 @@ export default class Services {
* 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> {
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'})`);
console.info(`[ConnectionCheck] 🔄 Démarrage de la vérification des connexions pour le processus (StateID: ${stateId || 'par défaut'})`);
if (!process) {
console.error(`[ConnectionCheck] 💥 ERREUR CRITIQUE: ensureConnections a été appelée avec un processus nul ou undefined.`);
@ -272,7 +271,7 @@ export default class Services {
// 1. Déterminer quel état analyser
const state = this.getStateToCheck(process, stateId);
if (!state) {
console.warn(`[ConnectionCheck] ⚠️ Aucun état valide trouvé pour le processus ${processId}. (States: ${process.states.length}, StateID demandé: ${stateId}). Abandon.`);
console.warn(`[ConnectionCheck] ⚠️ Aucun état valide trouvé pour le processus. (States: ${process.states.length}, StateID demandé: ${stateId}). Abandon.`);
return;
}
@ -661,7 +660,6 @@ export default class Services {
}
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) {
roles = this.getRoles(process);
@ -681,7 +679,7 @@ export default class Services {
try {
const result = this.sdkClient.update_process(process, encodedPrivateData, roles, encodedPublicData, this.getAllMembers());
if (result.updated_process) {
console.log(`[Services:updateProcess] ✅ Processus ${process.process_id} mis à jour. Vérification des connexions...`);
console.log(`[Services:updateProcess] ✅ Processus mis à jour. Vérification des connexions...`, process);
await this.ensureConnections(result.updated_process.current_process);
return result;
} else {
@ -843,7 +841,7 @@ export default class Services {
for (const process of Object.values(this.processesCache)) {
const tip = process.states[process.states.length - 1].commited_in;
if (prevouts.includes(tip)) {
const processId = process.process_id; // Utilisation de l'ID stocké
const processId = process.states[0].commited_in;
const newTip = this.sdkClient.get_txid(transaction);
console.log(`[Services:updateProcessesFromNewTx] 🔗 La Tx ${newTip} dépense le tip du processus ${processId}`);