createMessagingProcess also commits first state
This commit is contained in:
parent
da64e76779
commit
38425bbb08
@ -55,7 +55,9 @@ export async function init() {
|
|||||||
|
|
||||||
if (!hasMessaging) {
|
if (!hasMessaging) {
|
||||||
console.log('No existing processes - creating new messaging process');
|
console.log('No existing processes - creating new messaging process');
|
||||||
await createMessagingProcess();
|
setTimeout(async () => {
|
||||||
|
await createMessagingProcess();
|
||||||
|
}, 0);
|
||||||
|
|
||||||
const updatedProcesses = await getProcesses();
|
const updatedProcesses = await getProcesses();
|
||||||
for (const {key, value} of updatedProcesses) {
|
for (const {key, value} of updatedProcesses) {
|
||||||
@ -523,8 +525,21 @@ async function createMessagingProcess(): Promise<void> {
|
|||||||
throw new Error('Empty relay address list');
|
throw new Error('Empty relay address list');
|
||||||
}
|
}
|
||||||
const feeRate = 1;
|
const feeRate = 1;
|
||||||
const apiReturn = await service.createMessagingProcess(otherMembers, relayAddress.spAddress, feeRate);
|
setTimeout(async () => {
|
||||||
await service.handleApiReturn(apiReturn);
|
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<string | null> {
|
async function getDescription(processId: string, process: Process): Promise<string | null> {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user