support second aggs (#115)

* unserialize currencies second aggs

* support subscribing to indices fx and crypto second aggs

Author: aitzkovitz

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()
     }
-}
+}

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)
-}
+}