support second aggs (#115)

* unserialize currencies second aggs * support subscribing to indices fx and crypto second aggs
polygon-io · Jul 25, 2023 · 0fac1d6 · 0fac1d6
1 parent 75bd92d
commit 0fac1d6
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git a/src/main/kotlin/io/polygon/kotlin/sdk/websocket/PolygonWebSocketClient.kt b/src/main/kotlin/io/polygon/kotlin/sdk/websocket/PolygonWebSocketClient.kt
@@ -220,10 +220,10 @@ constructor(
                 "Q" -> serializer.decodeFromJsonElement(StocksMessage.Quote.serializer(), frame)
                 "A", "AM" -> serializer.decodeFromJsonElement(StocksMessage.Aggregate.serializer(), frame)
                 "C" -> serializer.decodeFromJsonElement(ForexMessage.Quote.serializer(), frame)
-                "CA" -> serializer.decodeFromJsonElement(ForexMessage.Aggregate.serializer(), frame)
+                "CA", "CAS" -> serializer.decodeFromJsonElement(ForexMessage.Aggregate.serializer(), frame)
                 "XQ" -> serializer.decodeFromJsonElement(CryptoMessage.Quote.serializer(), frame)
                 "XT" -> serializer.decodeFromJsonElement(CryptoMessage.Trade.serializer(), frame)
-                "XA" -> serializer.decodeFromJsonElement(CryptoMessage.Aggregate.serializer(), frame)
+                "XA", "XAS" -> serializer.decodeFromJsonElement(CryptoMessage.Aggregate.serializer(), frame)
                 "XS" -> serializer.decodeFromJsonElement(CryptoMessage.ConsolidatedQuote.serializer(), frame)
                 "XL2" -> serializer.decodeFromJsonElement(CryptoMessage.Level2Tick.serializer(), frame)
                 "V" -> serializer.decodeFromJsonElement(IndicesMessage.Value.serializer(), frame)
@@ -282,4 +282,4 @@ private class WebSocketConnection(
         webSocketSession.close()
         httpClient.close()
     }
-}
+}
diff --git a/src/main/kotlin/io/polygon/kotlin/sdk/websocket/PolygonWebSocketSubscription.kt b/src/main/kotlin/io/polygon/kotlin/sdk/websocket/PolygonWebSocketSubscription.kt
@@ -32,6 +32,7 @@ sealed class PolygonWebSocketChannel(val prefix: String) {
      */
     sealed class Forex(channelPrefix: String) : PolygonWebSocketChannel(channelPrefix) {
         object Quotes: Forex("C")
+        object AggPerSecond: Forex("CAS")
         object AggPerMinute: Forex("CA")
         object Bonds: Forex("BONDS")
         object Commodities: Forex("COMMODITIES")
@@ -47,12 +48,14 @@ sealed class PolygonWebSocketChannel(val prefix: String) {
         object Trades : Crypto("XT")
         object Quotes : Crypto("XQ")
         object Aggregates : Crypto("XA")
+        object AggPerSecond : Crypto("XAS")
         object ConsolidatedQuotes : Crypto("XS")
         object Level2Books : Crypto("XL2")
     }
 
     sealed class Indices(channelPrefix: String) : PolygonWebSocketChannel(channelPrefix) {
         object Aggregates : Stocks("AM")
+        object AggPerSecond : Stocks("A")
         object Value : Indices("V")
     }
 
@@ -65,4 +68,4 @@ sealed class PolygonWebSocketChannel(val prefix: String) {
      * Use this if there's a new channel that this SDK doesn't fully support yet
      */
     class Other(channelPrefix: String) : PolygonWebSocketChannel(channelPrefix)
-}
+}