Support New Business Products (#132)

* merge master * increment version * add updated specs
polygon-io · Oct 25, 2023 · e154916 · e154916
1 parent 1dc4358
commit e154916
Show file tree

Hide file tree

Showing 10 changed files with 5,242 additions and 5,011 deletions.
diff --git a/.polygon/rest.json b/.polygon/rest.json
diff --git a/.polygon/websocket.json b/.polygon/websocket.json
diff --git a/src/main/kotlin/io/polygon/kotlin/sdk/Version.kt b/src/main/kotlin/io/polygon/kotlin/sdk/Version.kt
@@ -1,6 +1,6 @@
 package io.polygon.kotlin.sdk
 
 object Version {
-    const val name = "v4.4.0"
+    const val name = "v4.6.0"
     const val userAgent = "Polygon.io JVM Client/$name"
 }
diff --git a/src/main/kotlin/io/polygon/kotlin/sdk/rest/crypto/Snapshots.kt b/src/main/kotlin/io/polygon/kotlin/sdk/rest/crypto/Snapshots.kt
@@ -95,7 +95,8 @@ data class CryptoTickerSnapshotDTO(
     val day: CryptoSnapshotAggregateDTO = CryptoSnapshotAggregateDTO(),
     val lastTrade: CryptoTickDTO = CryptoTickDTO(),
     val min: CryptoSnapshotAggregateDTO = CryptoSnapshotAggregateDTO(),
-    val prevDay: CryptoSnapshotAggregateDTO = CryptoSnapshotAggregateDTO()
+    val prevDay: CryptoSnapshotAggregateDTO = CryptoSnapshotAggregateDTO(),
+    val fmv: Double? = null
 )
 
 @Serializable
@@ -122,4 +123,4 @@ data class CryptoSnapshotAggregateDTO(
 data class CryptoBidOrAskDTO(
     @SerialName("p") val price: Double? = null,
     @SerialName("x") val exchangeToSizeMap: Map<String, Double> = emptyMap()
-)
+)
diff --git a/src/main/kotlin/io/polygon/kotlin/sdk/rest/forex/Snapshots.kt b/src/main/kotlin/io/polygon/kotlin/sdk/rest/forex/Snapshots.kt
@@ -45,7 +45,8 @@ data class SnapshotForexTickerDTO(
     val day: SnapshotAggregateDTO = SnapshotAggregateDTO(),
     val min: SnapshotAggregateDTO = SnapshotAggregateDTO(),
     val prevDay: SnapshotAggregateDTO = SnapshotAggregateDTO(),
-    val lastQuote: SnapshotForexQuoteDTO = SnapshotForexQuoteDTO()
+    val lastQuote: SnapshotForexQuoteDTO = SnapshotForexQuoteDTO(),
+    val fmv: Double? = null
 )
 
 @Serializable
@@ -54,4 +55,4 @@ data class SnapshotForexQuoteDTO(
     @SerialName("b") val bid: Double? = null,
     @SerialName("x") val exchange: Long? = null,
     @SerialName("t") val timestamp: Long? = null
-)
+)
diff --git a/src/main/kotlin/io/polygon/kotlin/sdk/rest/options/Snapshots.kt b/src/main/kotlin/io/polygon/kotlin/sdk/rest/options/Snapshots.kt
@@ -96,6 +96,7 @@ data class Snapshot(
     @SerialName("last_quote") val lastQuote: SnapshotLastQuote? = null,
     @SerialName("open_interest") val openInterest: Double? = null,
     @SerialName("underlying_asset") val underlyingAsset: SnapshotUnderlyingAssetInfo? = null,
+    @SerialName("fmv") val fairMarketValue: Double? = null,
 )
 
 @Serializable

diff --git a/src/main/kotlin/io/polygon/kotlin/sdk/rest/stocks/Snapshots.kt b/src/main/kotlin/io/polygon/kotlin/sdk/rest/stocks/Snapshots.kt
@@ -62,7 +62,8 @@ data class SnapshotTickerDTO(
     val lastTrade: SnapshotLastTradeDTO = SnapshotLastTradeDTO(),
     val lastQuote: SnapshotLastQuoteDTO = SnapshotLastQuoteDTO(),
     val min: SnapshotAggregateDTO = SnapshotAggregateDTO(),
-    val prevDay: SnapshotAggregateDTO = SnapshotAggregateDTO()
+    val prevDay: SnapshotAggregateDTO = SnapshotAggregateDTO(),
+    val fmv: Double? = null
 )
 
 @Serializable
@@ -93,4 +94,4 @@ data class SnapshotLastTradeDTO(
     @SerialName("c3") val cond3: Long? = null,
     @SerialName("c4") val cond4: Long? = null,
     @SerialName("t") val timestamp: Long? = null
-)
+)
diff --git a/src/main/kotlin/io/polygon/kotlin/sdk/websocket/PolygonWebSocketClient.kt b/src/main/kotlin/io/polygon/kotlin/sdk/websocket/PolygonWebSocketClient.kt
diff --git a/src/main/kotlin/io/polygon/kotlin/sdk/websocket/PolygonWebSocketMessage.kt b/src/main/kotlin/io/polygon/kotlin/sdk/websocket/PolygonWebSocketMessage.kt
@@ -262,4 +262,15 @@ sealed class PolygonWebSocketMessage {
         ) : LaunchpadMessage()
 
     }
-}
+
+    sealed class BusinessMessage : PolygonWebSocketMessage() {
+
+        @Serializable
+        data class FairMarketValue(
+            @SerialName("ev") val eventType: String? = null,
+            @SerialName("fmv") val value: Double? = null,
+            @SerialName("sym") val symbol: String? = null,
+            @SerialName("t") val timestampMillis: Long? = null
+        ) : BusinessMessage()
+    }
+}
diff --git a/src/main/kotlin/io/polygon/kotlin/sdk/websocket/PolygonWebSocketSubscription.kt b/src/main/kotlin/io/polygon/kotlin/sdk/websocket/PolygonWebSocketSubscription.kt
@@ -98,6 +98,10 @@ sealed class PolygonWebSocketChannel(val prefix: String) {
         object Value : Indices("V")
     }
 
+    sealed class Business(channelPrefix: String) : PolygonWebSocketChannel(channelPrefix) {
+        object FairMarketValue : Business("FMV")
+    }
+
     /**
      * Use this if there's a new channel that this SDK doesn't fully support yet
      */