Limit the consume events endpoint to v8

integration/test/Test/Events.hs

@@ -346,9 +346,15 @@ createEventsWebSocket user cid = do
   eventsChan <- liftIO newChan
   ackChan <- liftIO newEmptyMVar
   serviceMap <- lift $ getServiceMap =<< objDomain user
+  apiVersion <- lift $ getAPIVersionFor $ objDomain user
+  let minAPIVersion = 8
+  lift
+    . when (apiVersion < minAPIVersion)
+    $ assertFailure ("Events websocket can only be created when APIVersion is at least " <> show minAPIVersion)
+
   uid <- lift $ objId =<< objQidObject user
   let HostPort caHost caPort = serviceHostPort serviceMap Cannon
-      path = "/events?client=" <> cid
+      path = "/v" <> show apiVersion <> "/events?client=" <> cid
       caHdrs = [(fromString "Z-User", toByteString' uid)]
       app conn =
         race_

libs/wire-api/src/Wire/API/Routes/Public/Cannon.hs

@@ -22,6 +22,7 @@ import Servant
 import Wire.API.Routes.API
 import Wire.API.Routes.Named
 import Wire.API.Routes.Public (ZConn, ZUser)
+import Wire.API.Routes.Version
 import Wire.API.Routes.WebSocket
 
 type CannonAPI =
@@ -46,7 +47,7 @@ type CannonAPI =
            "consume-events"
            ( Summary "Consume events over a websocket connection"
                :> Description "This is the rabbitMQ-based variant of \"await-notifications\""
-               -- :> From 'V8 -- cannon is not versioned yet
+               :> From 'V8
                :> "events"
                :> ZUser
                :> QueryParam'