diff --git a/src/pages/process/process.ts b/src/pages/process/process.ts index 5dca5ce..8ccbbfe 100755 --- a/src/pages/process/process.ts +++ b/src/pages/process/process.ts @@ -55,7 +55,9 @@ export async function init() { if (!hasMessaging) { console.log('No existing processes - creating new messaging process'); - await createMessagingProcess(); + setTimeout(async () => { + await createMessagingProcess(); + }, 0); const updatedProcesses = await getProcesses(); for (const {key, value} of updatedProcesses) { @@ -523,8 +525,21 @@ async function createMessagingProcess(): Promise { throw new Error('Empty relay address list'); } const feeRate = 1; - const apiReturn = await service.createMessagingProcess(otherMembers, relayAddress.spAddress, feeRate); - await service.handleApiReturn(apiReturn); + setTimeout(async () => { + const createProcessReturn = await service.createMessagingProcess(otherMembers, relayAddress.spAddress, feeRate); + const updatedProcess = createProcessReturn.updated_process.current_process; + if (!updatedProcess) { + console.error('Failed to retrieved new messaging process'); + return; + } + const processId = updatedProcess.states[0].commited_in; + const stateId = updatedProcess.states[0].state_id; + await service.handleApiReturn(createProcessReturn); + const createPrdReturn = await service.createPrdUpdate(processId, stateId); + await service.handleApiReturn(createPrdReturn); + const approveChangeReturn = service.approveChange(processId, stateId); + await service.handleApiReturn(approveChangeReturn); + }, 500) } async function getDescription(processId: string, process: Process): Promise {