-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
8 changed files
with
100 additions
and
6 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -56,9 +56,13 @@ | |
| isEnabled = "NO"> | ||
| </CommandLineArgument> | ||
| <CommandLineArgument | ||
| argument = "ScheduleSample /Users/akosylo/test_ipf/schedule.zip /Users/akosylo/test_ipf/sample.ipf.zip AAPL 2012-05-26-14:15:00" | ||
| argument = "DXFeedIpfConnect Quote https://demo:[email protected]/ipf" | ||
| isEnabled = "YES"> | ||
| </CommandLineArgument> | ||
| <CommandLineArgument | ||
| argument = "ScheduleSample /Users/akosylo/test_ipf/schedule.zip /Users/akosylo/test_ipf/sample.ipf.zip AAPL 2012-05-26-14:15:00" | ||
| isEnabled = "NO"> | ||
| </CommandLineArgument> | ||
| <CommandLineArgument | ||
| argument = "DXFeedLiveIpfSample https://demo:[email protected]/ipf" | ||
| isEnabled = "NO"> | ||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,79 @@ | ||
| // | ||
| // IpfConnectCommand.swift | ||
| // DXFeedFramework | ||
| // | ||
| // Created by Aleksey Kosylo on 10.10.23. | ||
| // | ||
|
|
||
| import Foundation | ||
| import DXFeedFramework | ||
|
|
||
| class IpfConnectCommand: ToolsCommand { | ||
| lazy var name = { | ||
| stringReference(self) | ||
| }() | ||
| var cmd = "DXFeedIpfConnect" | ||
|
|
||
| var shortDescription = "A sample program that demonstrates IPF Connection" | ||
|
|
||
| var fullDescription: String = | ||
| """ | ||
| A sample program that demonstrates IPF Connection | ||
| usage: DXFeedIpfConnect <type> <ipf-file> | ||
| Where: | ||
| <type> is dxfeed event type (" + eventTypeNames + ")" | ||
| <ipf-file> is name of instrument profiles file | ||
| sample: DXFeedIpfConnect TimeAndSale sample.ipf.zip | ||
| """ | ||
|
|
||
| func execute() { | ||
| var arguments: [String]! | ||
| do { | ||
| arguments = try ArgumentParser().parse(ProcessInfo.processInfo.arguments, requiredNumberOfArguments: 2) | ||
| } catch { | ||
| print(fullDescription) | ||
| } | ||
| let eventType = arguments[1] | ||
| let ipfFile = arguments[2] | ||
| try? SystemProperty.setProperty(DXEndpoint.Property.address.rawValue, "demo.dxfeed.com:7300") | ||
| let subscription = try? DXEndpoint.getInstance().getFeed()?.createSubscription([EventCode(string: eventType)]) | ||
| try? subscription?.add(observer: self) | ||
| let symbols = getSymbols(fileName: ipfFile) | ||
| try? subscription?.addSymbols(symbols) | ||
| // Print till input new line | ||
| _ = readLine() | ||
| } | ||
|
|
||
| private func getSymbols(fileName: String) -> [String] { | ||
| print("Reading instruments from \(fileName)") | ||
| let profiles = try? DXInstrumentProfileReader().readFromFile(address: fileName) | ||
| print("Selected symbols are:") | ||
| let result = profiles?.compactMap({ profile in | ||
| if profile.type == "STOCK" { | ||
| print("\(profile.symbol) (\(profile.descriptionStr))") | ||
| return profile.symbol | ||
| } else { | ||
| return nil | ||
| } | ||
| }) | ||
| return result ?? [String]() | ||
| } | ||
| } | ||
| extension IpfConnectCommand: Hashable { | ||
| static func == (lhs: IpfConnectCommand, rhs: IpfConnectCommand) -> Bool { | ||
| return lhs === rhs || lhs.name == rhs.name | ||
| } | ||
|
|
||
| func hash(into hasher: inout Hasher) { | ||
| hasher.combine(name) | ||
| } | ||
| } | ||
| extension IpfConnectCommand: DXEventListener { | ||
| func receiveEvents(_ events: [DXFeedFramework.MarketEvent]) { | ||
| events.forEach { mEvent in | ||
| print("\(mEvent.eventSymbol): \(mEvent.quote.toString())") | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters