ch/Sesame-Server
1
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

Fix shutdown procedure

Browse Source
This commit is contained in:
Christoph Hagen 2023-11-10 15:08:33 +01:00
parent 621d2af22b
commit 9c85f955e4
1 changed files with 14 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
Sources/App/configure.swift
View File

@ -9,6 +9,13 @@ private var provider: VaporMetricProvider!
private var asyncScheduler: AsyncScheduler = MultiThreadedEventLoopGroup(numberOfThreads: 2) private var asyncScheduler: AsyncScheduler = MultiThreadedEventLoopGroup(numberOfThreads: 2)
private let df: DateFormatter = {
let df = DateFormatter()
df.dateStyle = .short
df.timeStyle = .short
return df
}()
enum ServerError: Error { enum ServerError: Error {
case invalidAuthenticationFileContent case invalidAuthenticationFileContent
case invalidAuthenticationToken case invalidAuthenticationToken
@ -48,20 +55,18 @@ public func configure(_ app: Application) throws {
await deviceManager.updateDeviceConnectionMetric() await deviceManager.updateDeviceConnectionMetric()
} }
let df = DateFormatter()
df.dateStyle = .short
df.timeStyle = .short
print("[\(df.string(from: Date()))] Server started") print("[\(df.string(from: Date()))] Server started")
// Gracefully shut down by closing potentially open socket // Gracefully shut down by closing potentially open socket
//DispatchQueue.global(qos: .utility).asyncAfter(deadline: .now() + .seconds(5)) { // Must be done after app is running, otherwise error is thrown
DispatchQueue.global(qos: .utility).asyncAfter(deadline: .now() + .seconds(5)) {
_ = app.server.onShutdown.always { _ in _ = app.server.onShutdown.always { _ in
print("[\(df.string(from: Date()))] Server shutdown") print("[\(df.string(from: Date()))] Server shutdown")
asyncScheduler.schedule { asyncScheduler.schedule {
await deviceManager.removeDeviceConnection() await deviceManager.removeDeviceConnection()
} }
} }
//} }
} }
private func loadKeys(at url: URL) throws -> (deviceKey: Data, remoteKey: Data) { private func loadKeys(at url: URL) throws -> (deviceKey: Data, remoteKey: Data) {