Add endpoints for fetching ETF data

Sources/MarketKit/Classes/Kit.swift

@@ -312,6 +312,16 @@ public extension Kit {
         )
     }
 
+    // Etf
+
+    func etfs(currencyCode: String) async throws -> [Etf] {
+        try await hsProvider.etfs(currencyCode: currencyCode)
+    }
+
+    func etfPoints(currencyCode: String) async throws -> [EtfPoint] {
+        try await hsProvider.etfPoints(currencyCode: currencyCode)
+    }
+
     // Pro Data
 
     func analytics(coinUid: String, currencyCode: String) async throws -> Analytics {

Sources/MarketKit/Classes/Models/Etf.swift

@@ -0,0 +1,49 @@
+import Foundation
+import ObjectMapper
+
+public struct Etf: ImmutableMappable {
+    public let ticker: String
+    public let name: String
+    public let date: Date?
+    public let totalAssets: Decimal?
+    public let totalInflow: Decimal?
+    public let inflows: [HsTimePeriod: Decimal]
+
+    public init(map: Map) throws {
+        ticker = try map.value("ticker")
+        name = try map.value("name")
+        date = try? map.value("date", using: Self.dateTransform)
+        totalAssets = try? map.value("total_assets", using: Transform.stringToDecimalTransform)
+        totalInflow = try? map.value("total_inflow", using: Transform.stringToDecimalTransform)
+
+        var inflows = [HsTimePeriod: Decimal]()
+
+        inflows[.day1] = try? map.value("inflow_1d", using: Transform.stringToDecimalTransform)
+        inflows[.week1] = try? map.value("inflow_1w", using: Transform.stringToDecimalTransform)
+        inflows[.month1] = try? map.value("inflow_1m", using: Transform.stringToDecimalTransform)
+        inflows[.month3] = try? map.value("inflow_3m", using: Transform.stringToDecimalTransform)
+
+        self.inflows = inflows
+    }
+}
+
+extension Etf {
+    private static let dateFormatter: DateFormatter = {
+        let dateFormatter = DateFormatter()
+        dateFormatter.dateFormat = "yyyy-MM-dd"
+        dateFormatter.timeZone = TimeZone(abbreviation: "GMT")!
+        dateFormatter.locale = Locale(identifier: "en_US_POSIX")
+        return dateFormatter
+    }()
+
+    static let dateTransform: TransformOf<Date, String> = TransformOf(
+        fromJSON: { string -> Date? in
+            guard let string else { return nil }
+            return dateFormatter.date(from: string)
+        },
+        toJSON: { (value: Date?) in
+            guard let value else { return nil }
+            return dateFormatter.string(from: value)
+        }
+    )
+}

Sources/MarketKit/Classes/Models/EtfPoint.swift

@@ -0,0 +1,16 @@
+import Foundation
+import ObjectMapper
+
+public struct EtfPoint: ImmutableMappable {
+    public let date: Date
+    public let totalAssets: Decimal
+    public let totalInflow: Decimal
+    public let dailyInflow: Decimal
+
+    public init(map: Map) throws {
+        date = try map.value("date", using: Etf.dateTransform)
+        totalAssets = try map.value("total_assets", using: Transform.stringToDecimalTransform)
+        totalInflow = try map.value("total_inflow", using: Transform.stringToDecimalTransform)
+        dailyInflow = try map.value("daily_inflow", using: Transform.stringToDecimalTransform)
+    }
+}

Sources/MarketKit/Classes/Providers/HsProvider.swift

@@ -335,6 +335,24 @@ extension HsProvider {
         return try await networkManager.fetch(url: "\(baseUrl)/v1/top-platforms/\(platform)/market_chart", method: .get, parameters: parameters, headers: headers)
     }
 
+    // Etf
+
+    func etfs(currencyCode: String) async throws -> [Etf] {
+        let parameters: Parameters = [
+            "currency": currencyCode.lowercased(),
+        ]
+
+        return try await networkManager.fetch(url: "\(baseUrl)/v1/etfs", method: .get, parameters: parameters, headers: headers)
+    }
+
+    func etfPoints(currencyCode: String) async throws -> [EtfPoint] {
+        let parameters: Parameters = [
+            "currency": currencyCode.lowercased(),
+        ]
+
+        return try await networkManager.fetch(url: "\(baseUrl)/v1/etfs/total", method: .get, parameters: parameters, headers: headers)
+    }
+
     // Pro Charts
 
     private func proData<T: ImmutableMappable>(path: String, currencyCode: String, timePeriod: HsTimePeriod) async throws -> [T] {