Compare commits
2 Commits
bd0e3b9114
...
6419e4e1c9
| Author | SHA1 | Date | |
|---|---|---|---|
| 6419e4e1c9 | |||
| f75c87bd09 |
@ -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}`);
|
||||
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user