Compare commits
No commits in common. "6419e4e1c964130ca313fc25ce6aab474bf5c5d7" and "bd0e3b9114e1261f2beed4f793f8b7d51b409f3f" have entirely different histories.
6419e4e1c9
...
bd0e3b9114
@ -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}`);
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user