add parsing ipf symbols

dxFeed · Oct 16, 2023 · 4d6f6ec · 4d6f6ec
1 parent d577cba
commit 4d6f6ec
Show file tree

Hide file tree

Showing 3 changed files with 49 additions and 3 deletions.
diff --git a/DXFeedFramework.xcodeproj/xcshareddata/xcschemes/Tools.xcscheme b/DXFeedFramework.xcodeproj/xcshareddata/xcschemes/Tools.xcscheme
@@ -72,7 +72,7 @@
             isEnabled = "NO">
          </CommandLineArgument>
          <CommandLineArgument
-            argument = "Connect mddqa.in.devexperts.com:7400 OptionSale AAPL"
+            argument = "Connect demo.dxfeed.com:7300 Quote &quot;ipf[https://demo:[email protected]/ipf?TYPE=STOCK&amp;compression=zip],APPL&quot;"
             isEnabled = "YES">
          </CommandLineArgument>
          <CommandLineArgument

diff --git a/DXFeedFramework/Utils/String+Range.swift b/DXFeedFramework/Utils/String+Range.swift
@@ -97,3 +97,11 @@ extension Collection {
 extension String.Index {
     func distance<S: StringProtocol>(in string: S) -> Int { string.distance(to: self) }
 }
+
+extension String {
+    public func slice(from: String, to: String) -> String? {
+        guard let rangeFrom = range(of: from)?.upperBound else { return nil }
+        guard let rangeTo = self[rangeFrom...].range(of: to)?.lowerBound else { return nil }
+        return String(self[rangeFrom..<rangeTo])
+    }
+}
diff --git a/Samples/PerfTestCL/ConnectCommand.swift b/Samples/PerfTestCL/ConnectCommand.swift
@@ -52,16 +52,54 @@ Where:
         }
         let address = arguments[1]
         let types = arguments[2]
-        let symbols = arguments[3].components(separatedBy: ",")
 
+        let symbols = arguments[3]
+        var symbolsList = [String]()
+        func addSymbol(str: String) {
+            if str.hasPrefix("ipf[") && str.hasSuffix("]") {
+                if let address = str.slice(from: "[", to: "]") {
+                    let profiles = try? DXInstrumentProfileReader().readFromFile(address: address)
+                    profiles?.forEach({ profile in
+                        symbolsList.append(profile.symbol)
+                    })
+                }
+            } else {
+                symbolsList.append(str)
+            }
+        }
+        var parentheses = 0
+        var tempSrting = ""
+        symbols.forEach { character in
+            switch character {
+            case "{", "(", "[":
+                parentheses += 1
+                tempSrting.append(character)
+            case "}", ")", "]":
+                if parentheses > 0 {
+                    parentheses -= 1
+                }
+                tempSrting.append(character)
+            case ",":
+                if parentheses == 0 {
+                    addSymbol(str: tempSrting)
+                    tempSrting = ""
+                } else {
+                    tempSrting.append(character)
+                }
+            default:
+                tempSrting.append(character)
+            }
+        }
+
+        addSymbol(str: tempSrting)
         var time: String?
         if arguments.count > 4 {
             time = arguments[4]
         }
 
         let listener = ConnectEventListener()
         subscription.createSubscription(address: address,
-                                        symbols: symbols,
+                                        symbols: symbolsList,
                                         types: types,
                                         listener: listener,
                                         time: time)