Websocket Ping (#27)

jshier · web-flow · commit e8d725cfde2c · 2023-02-21T15:34:17.000-05:00
* Add ping endpoint.

* Formatting.

* Update Xcode in actions.
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
@@ -25,7 +25,7 @@ jobs:
     name: macOS
     runs-on: firebreak
     env:
-      DEVELOPER_DIR: /Applications/Xcode_14.1.app/Contents/Developer
+      DEVELOPER_DIR: /Applications/Xcode_14.2.app/Contents/Developer
     timeout-minutes: 10
     steps:
       - uses: actions/checkout@v3
diff --git a/.github/workflows/release.yml b/.github/workflows/release.yml
@@ -9,7 +9,7 @@ jobs:
     name: Upload Release Artifact
     runs-on: firebreak
     env:
-      DEVELOPER_DIR: /Applications/Xcode_14.1.app/Contents/Developer
+      DEVELOPER_DIR: /Applications/Xcode_14.2.app/Contents/Developer
     steps:
       - name: Checkout
         uses: actions/checkout@v3
diff --git a/Package.resolved b/Package.resolved
diff --git a/Sources/WebSocket.swift b/Sources/WebSocket.swift
@@ -86,6 +86,16 @@ func createWebSocketRoutes(for app: Application) throws {
             socket.send(string)
         }
     }
+
+    app.webSocket("websocket", "ping", ":count") { request, socket in
+        var remainingPings = request.parameters["count", as: Int.self] ?? 1
+        socket.onPing { _ in
+            remainingPings -= 1
+            if remainingPings == 0 {
+                _ = socket.close()
+            }
+        }
+    }
 }
 
 struct WebSocketOptions: Decodable {

Original file line number	Diff line number	Diff line change
`@@ -86,6 +86,16 @@ func createWebSocketRoutes(for app: Application) throws {`
`86`	`86`	`socket.send(string)`
`87`	`87`	`}`
`88`	`88`	`}`
	`89`	`+`
	`90`	`+ app.webSocket("websocket", "ping", ":count") { request, socket in`
	`91`	`+ var remainingPings = request.parameters["count", as: Int.self] ?? 1`
	`92`	`+ socket.onPing { _ in`
	`93`	`+ remainingPings -= 1`
	`94`	`+ if remainingPings == 0 {`
	`95`	`+ _ = socket.close()`
	`96`	`+ }`
	`97`	`+ }`
	`98`	`+ }`
`89`	`99`	`}`
`90`	`100`
`91`	`101`	`struct WebSocketOptions: Decodable {`