Commitcb6cbca

committed

pausing & unpausing

1 parent1798317 commitcb6cbcaCopy full SHA for cb6cbca

File tree

+49

-1

lines changed

+49

-1

lines changed

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -21,4 +21,8 @@ final class PreviewFileSync: FileSyncDaemon {`
`21`	`21`	`func createSession(localPath _:String, agentHost _:String, remotePath _:String)asyncthrows(DaemonError){}`
`22`	`22`
`23`	`23`	`func deleteSessions(ids _:[String])asyncthrows(VPNLib.DaemonError){}`
	`24`	`+`
	`25`	`+func pauseSessions(ids _:[String])asyncthrows(VPNLib.DaemonError){}`
	`26`	`+`
	`27`	`+func resumeSessions(ids _:[String])asyncthrows(VPNLib.DaemonError){}`
`24`	`28`	`}`

Lines changed: 9 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -65,7 +65,15 @@ struct FileSyncConfig<VPN: VPNService, FS: FileSyncDaemon>: View {`
`65`	`65`	`iflet selectedSession= fileSync.sessionState.first(where:{ $0.id== selection}){`
`66`	`66`	`Divider()`
`67`	`67`	`Button{`
`68`		`- // TODO: Pause & Unpause`
	`68`	`+Task{`
	`69`	`+ // TODO: Support pausing & resuming multiple selections`
	`70`	`+switch selectedSession.status{`
	`71`	`+case.paused:`
	`72`	`+tryawait fileSync.resumeSessions(ids:[selectedSession.id])`
	`73`	`+default:`
	`74`	`+tryawait fileSync.pauseSessions(ids:[selectedSession.id])`
	`75`	`+}`
	`76`	`+}`
`69`	`77`	`} label:{`
`70`	`78`	`switch selectedSession.status{`
`71`	`79`	`case.paused:`

Lines changed: 2 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -15,6 +15,8 @@ public protocol FileSyncDaemon: ObservableObject {`
`15`	`15`	`func refreshSessions()async`
`16`	`16`	`func createSession(localPath:String, agentHost:String, remotePath:String)asyncthrows(DaemonError)`
`17`	`17`	`func deleteSessions(ids:[String])asyncthrows(DaemonError)`
	`18`	`+func pauseSessions(ids:[String])asyncthrows(DaemonError)`
	`19`	`+func resumeSessions(ids:[String])asyncthrows(DaemonError)`
`18`	`20`	`}`
`19`	`21`
`20`	`22`	`@MainActor`

Lines changed: 34 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -77,4 +77,38 @@ public extension MutagenDaemon {`
`77`	`77`	`}`
`78`	`78`	`awaitrefreshSessions()`
`79`	`79`	`}`
	`80`	`+`
	`81`	`+func pauseSessions(ids:[String])asyncthrows(DaemonError){`
	`82`	`+let(stream, promptID)=tryawaithost()`
	`83`	`+defer{ stream.cancel()}`
	`84`	`+guard case.running= stateelse{return}`
	`85`	`+do{`
	`86`	`+ _=tryawait client!.sync.pause(Synchronization_PauseRequest.with{ reqin`
	`87`	`+ req.prompter= promptID`
	`88`	`+ req.selection=.with{ selectionin`
	`89`	`+ selection.specifications= ids`
	`90`	`+}`
	`91`	`+})`
	`92`	`+}catch{`
	`93`	`+throw.grpcFailure(error)`
	`94`	`+}`
	`95`	`+awaitrefreshSessions()`
	`96`	`+}`
	`97`	`+`
	`98`	`+func resumeSessions(ids:[String])asyncthrows(DaemonError){`
	`99`	`+let(stream, promptID)=tryawaithost()`
	`100`	`+defer{ stream.cancel()}`
	`101`	`+guard case.running= stateelse{return}`
	`102`	`+do{`
	`103`	`+ _=tryawait client!.sync.resume(Synchronization_ResumeRequest.with{ reqin`
	`104`	`+ req.prompter= promptID`
	`105`	`+ req.selection=.with{ selectionin`
	`106`	`+ selection.specifications= ids`
	`107`	`+}`
	`108`	`+})`
	`109`	`+}catch{`
	`110`	`+throw.grpcFailure(error)`
	`111`	`+}`
	`112`	`+awaitrefreshSessions()`
	`113`	`+}`
`80`	`114`	`}`

Comments

(0)