Start9/start-os
2
0
Fork 0
mirror of https://github.com/Start9Labs/start-os.git synced 2026-03-30 20:14:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

initial update progress commit

Browse Source
This commit is contained in:
Drew Ansbacher
2021-09-15 12:04:55 -06:00
committed by Aiden McClelland
parent 0f1e2f0c5b
commit baad108081
6 changed files with 234 additions and 167 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
ui/src/app/services/api/embassy-mock-api.service.ts
View File

@@ -101,14 +101,26 @@ export class MockApiService extends ApiService {
async updateServerRaw (params: RR.UpdateServerReq): Promise<RR.UpdateServerRes> {
await pauseFor(2000)
const initialProgress = {
size: 10000,
downloaded: 0,
}
const patch = [
{
op: PatchOp.REPLACE,
path: '/server-info/status',
value: ServerStatus.Updating,
},
{
op: PatchOp.REPLACE,
path: '/server-info/update-progress',
value: initialProgress,
},
]
const res = await this.http.rpcRequest<WithRevision<null>>({ method: 'db.patch', params: { patch } })
await this.updateOSProgress(initialProgress.size)
setTimeout(async () => {
const patch = [
{
@@ -121,6 +133,10 @@ export class MockApiService extends ApiService {
path: '/server-info/version',
value: '3.1.0',
},
{
op: PatchOp.REMOVE,
path: '/server-info/update-progress',
},
]
await this.http.rpcRequest<WithRevision<null>>({ method: 'db.patch', params: { patch } })
// quickly revert patch to proper version to prevent infinite refresh loop
@@ -132,7 +148,7 @@ export class MockApiService extends ApiService {
},
]
this.http.rpcRequest<WithRevision<null>>({ method: 'db.patch', params: { patch: patch2 } })
}, this.revertTime)
}, 10000)
return res
}
@@ -564,4 +580,29 @@ export class MockApiService extends ApiService {
this.http.rpcRequest<WithRevision<null>>({ method: 'db.patch', params: { patch } })
}, 1000)
}
private async updateOSProgress (size: number) {
let downloaded = 0
while (downloaded < size) {
await pauseFor(250)
downloaded += 500
const patch = [
{
op: PatchOp.REPLACE,
path: `/server-info/update-progress/downloaded`,
value: downloaded,
},
]
await this.http.rpcRequest<WithRevision<null>>({ method: 'db.patch', params: { patch } })
}
const patch = [
{
op: PatchOp.REPLACE,
path: `/server-info/update-progress/downloaded`,
value: size,
},
]
await this.http.rpcRequest<WithRevision<null>>({ method: 'db.patch', params: { patch } })
}
}