Moving code into kissme framework

This commit is contained in:
2023-08-26 19:17:29 +09:00
parent aababdae8e
commit 4890896c0a
4 changed files with 756 additions and 734 deletions

View File

@@ -8,12 +8,6 @@
import Foundation
enum KissWebSocketSubscription: String, Codable {
case subscribed = "1"
case unsubscribed = "2"
}
// MARK: ContractPriceWebSocket
extension Domestic {
@@ -66,98 +60,3 @@ extension Domestic.ContractPriceWebSocket.Event: URLSessionWebSocketDelegate {
print("disconnected...")
}
}
extension Domestic {
struct TypeResponse: Codable {
let header: Header
struct Header: Codable {
let trId: String
/// yyyyMMddHHmmss
let dateTime: String?
private enum CodingKeys: String, CodingKey {
case trId = "tr_id"
case dateTime = "datetime"
}
}
}
struct SubscriptionRequest: Codable {
let header: Header
let body: Body
struct Header: Codable {
let approvalKey: String
let customerType: CustomerType
let trType: KissWebSocketSubscription
let contentType: String
private enum CodingKeys: String, CodingKey {
case approvalKey = "approval_key"
case customerType = "custtype"
case trType = "tr_type"
case contentType = "content-type"
}
}
struct Body: Codable {
let input: Input
}
struct Input: Codable {
let trId: String
let trKey: String
private enum CodingKeys: String, CodingKey {
case trId = "tr_id"
case trKey = "tr_key"
}
}
init(approvalKey: String, type: KissWebSocketSubscription, trId: String, trKey: String) {
header = Header(approvalKey: approvalKey, customerType: .personal, trType: type, contentType: "utf-8")
body = Body(input: Input(trId: trId, trKey: trKey))
}
}
struct SubscriptionResult: Codable {
let header: Header
let body: Body
struct Header: Codable {
let trId: String
let trKey: String
let encrypted: YesNo
private enum CodingKeys: String, CodingKey {
case trId = "tr_id"
case trKey = "tr_key"
case encrypted = "encrypt"
}
}
struct Body: Codable {
let resultCode: String
let messageCode: String
let message: String
let output: Output?
private enum CodingKeys: String, CodingKey {
case resultCode = "rt_cd"
case messageCode = "msg_cd"
case message = "msg1"
case output
}
}
struct Output: Codable {
let iv: String
let key: String
}
}
}

View File

@@ -0,0 +1,751 @@
//
// Domestic.WebSocketResponse.swift
// KissMe
//
// Created by ened-book-m1 on 2023/08/26.
//
import Foundation
extension Domestic {
enum KissWebSocketSubscription: String, Codable {
case subscribed = "1"
case unsubscribed = "2"
}
struct SubscriptionRequest: Codable {
let header: Header
let body: Body
struct Header: Codable {
let approvalKey: String
let customerType: CustomerType
let trType: KissWebSocketSubscription
let contentType: String
private enum CodingKeys: String, CodingKey {
case approvalKey = "approval_key"
case customerType = "custtype"
case trType = "tr_type"
case contentType = "content-type"
}
}
struct Body: Codable {
let input: Input
}
struct Input: Codable {
let trId: String
let trKey: String
private enum CodingKeys: String, CodingKey {
case trId = "tr_id"
case trKey = "tr_key"
}
}
init(approvalKey: String, type: KissWebSocketSubscription, trId: String, trKey: String) {
header = Header(approvalKey: approvalKey, customerType: .personal, trType: type, contentType: "utf-8")
body = Body(input: Input(trId: trId, trKey: trKey))
}
}
struct GeneralResult: Codable {
let header: Header
struct Header: Codable {
let trId: String
/// yyyyMMddHHmmss
let dateTime: String?
private enum CodingKeys: String, CodingKey {
case trId = "tr_id"
case dateTime = "datetime"
}
}
}
struct SubscriptionResult: Codable {
let header: Header
let body: Body
struct Header: Codable {
let trId: String
let trKey: String
let encrypted: YesNo
private enum CodingKeys: String, CodingKey {
case trId = "tr_id"
case trKey = "tr_key"
case encrypted = "encrypt"
}
}
struct Body: Codable {
let resultCode: String
let messageCode: String
let message: String
let output: Output?
private enum CodingKeys: String, CodingKey {
case resultCode = "rt_cd"
case messageCode = "msg_cd"
case message = "msg1"
case output
}
}
struct Output: Codable {
let iv: String
let key: String
}
}
}
extension Domestic {
public enum VariableRatioSignType: UInt8 {
///
case upLimit = 1
///
case up = 2
///
case noChange = 3
///
case downLimit = 4
///
case down = 5
}
public enum ConclusionType: UInt8 {
/// (+)
case buying = 1
///
case load = 3
/// (-)
case selling = 5
}
public enum HourClassCode: Character {
///
case onMarket = "0"
///
case afterMarket = "A"
///
case beforeMarket = "B"
/// 9 , VI
case viInvoking = "C"
///
case overTime_SinglePrice = "D"
}
public typealias MarketOperationCode = String
public enum ContractClass: String {
///
case selling = "01"
///
case buying = "02"
}
public enum OrderClass: String {
///
case limits = "00"
///
case marketPrice = "01"
///
case conditionalLimits = "02"
///
case mostFavorLimits = "03"
///
case mostPriorLimits = "04"
///
case overTime_BeforeMarket = "05"
///
case overTime_AfterMarket = "06"
///
case overTime_SinglePrice = "07"
///
case treasury = "08"
/// S-Option
case treasury_SOption = "09"
///
case treasury_MoneyTrust = "10"
/// IOC (,)
case iocLimits_Conclusion_CancelResidualQuantity = "11"
/// FOK (,)
case fokLimits_Conclusion_CancelEntireQuantity = "12"
/// IOC (,)
case iocMarketPrice_Conclusion_CancelResidualQuantity = "13"
/// FOK (,)
case fokMarketPrice_Conclusion_CancelEntireQuantity = "14"
/// IOC (,)
case iocMostFavor_Conclusion_CancelResidualQuantity = "15"
/// FOK (,)
case fokMostFavor_Conclusion_CancelEntireQuantity = "16"
}
public enum RefuseYesNo: Int {
///
case approval = 0
///
case refuse = 1
}
public enum ConclusionYesNo: Int {
/// ,,,,
case unconclused = 1
/// ( 2 )
case conclused = 2
}
public enum AcceptYesNo: Int {
///
case orderAccept = 1
///
case confirm = 2
/// (FOK/IOC)
case cancel = 3
}
public struct ContractPrice {
///
public let shortCode: String
/// (HHmmss)
public let conclusionTime: String
///
public let currentPrice: Int
///
public let previousDayVariableRatioSign: VariableRatioSignType
///
public let previousDayVariableRatio: Double
///
public let previousDayDiffRatio: Double
///
public let weightedAveragePrice: Int
///
public let openningPrice: Int
///
public let highestPrice: Int
///
public let lowestPrice: Int
/// 1
public let askingPrice: Int
/// 1
public let biddingPrice: Int
///
public let conclusionVolume: Int
///
public let accumulatedVolume: Int
///
public let accumulatedTradingAmount: Int
///
public let sellingConclusionCount: Int
///
public let buyingConclusionCount: Int
///
public let netBuyingConclusionCount: Int
///
public let conclusionStrength: Double
///
public let totalSellingQuantity: Int
///
public let totalBuyingQuantity: Int
///
public let conclusionType: ConclusionType
///
public let buyingRatio: Double
///
public let previousDay_VolumeDiff_FluctuationRate: Double
///
public let openningPriceHour: String
///
public let openningPrice_VariableRatioSign: VariableRatioSignType
///
public let openningPrice_VariableRatio: Int
///
public let highestPriceHour: String
///
public let highPrice_VariableRatioSign: VariableRatioSignType
///
public let highPrice_VariableRatio: Int
///
public let lowestPriceHour: String
///
public let lowPrice_VariableRatioSign: VariableRatioSignType
///
public let lowPrice_VariableRatio: Int
///
public let businessDate: String
///
public let marketOperationCode: MarketOperationCode
///
public let tradeStopped: Bool
/// 1
public let askingPrice_ResidualQuantity: Int
/// 1
public let biddingPrice_ResidualQuantity: Int
///
public let askingPrice_TotalResidualQuantity: Int
///
public let biddingPrice_TotalResidualQuantity: Int
///
public let volumeTurnoverRate: Double
///
public let previousDaySameTime_AccumulatedTradingQuantity: Int
///
public let previousDaySameTime_AccumulatedTradingQuantityRatio: Double
///
public let hourClassCode: HourClassCode
///
public let marketTerminationCode: String
/// VI
public let viStandardPrice: Int
static let propertiesCount = 46
public init(array: [Substring], source: Substring) throws {
guard array.count == ContractPrice.propertiesCount else {
throw GeneralError.incorrectArrayItems(String(source), array.count, ContractPrice.propertiesCount)
}
self.shortCode = String(array[0])
self.conclusionTime = String(array[1])
self.currentPrice = Int(array[2]) ?? 0
self.previousDayVariableRatioSign = VariableRatioSignType(rawValue: UInt8(array[3])!)!
self.previousDayVariableRatio = Double(array[4]) ?? 0
self.previousDayDiffRatio = Double(array[5]) ?? 0
self.weightedAveragePrice = Int(array[6]) ?? 0
self.openningPrice = Int(array[7]) ?? 0
self.highestPrice = Int(array[8]) ?? 0
self.lowestPrice = Int(array[9]) ?? 0
self.askingPrice = Int(array[10]) ?? 0
self.biddingPrice = Int(array[11]) ?? 0
self.conclusionVolume = Int(array[12]) ?? 0
self.accumulatedVolume = Int(array[13]) ?? 0
self.accumulatedTradingAmount = Int(array[14]) ?? 0
self.sellingConclusionCount = Int(array[15]) ?? 0
self.buyingConclusionCount = Int(array[16]) ?? 0
self.netBuyingConclusionCount = Int(array[17]) ?? 0
self.conclusionStrength = Double(array[18]) ?? 0
self.totalSellingQuantity = Int(array[19]) ?? 0
self.totalBuyingQuantity = Int(array[20]) ?? 0
self.conclusionType = ConclusionType(rawValue: UInt8(array[21])!)!
self.buyingRatio = Double(array[22]) ?? 0
self.previousDay_VolumeDiff_FluctuationRate = Double(array[23]) ?? 0
self.openningPriceHour = String(array[24])
self.openningPrice_VariableRatioSign = VariableRatioSignType(rawValue: UInt8(array[25])!)!
self.openningPrice_VariableRatio = Int(array[26]) ?? 0
self.highestPriceHour = String(array[27])
self.highPrice_VariableRatioSign = VariableRatioSignType(rawValue: UInt8(array[28])!)!
self.highPrice_VariableRatio = Int(array[29]) ?? 0
self.lowestPriceHour = String(array[30])
self.lowPrice_VariableRatioSign = VariableRatioSignType(rawValue: UInt8(array[31])!)!
self.lowPrice_VariableRatio = Int(array[32]) ?? 0
self.businessDate = String(array[33])
self.marketOperationCode = String(array[34])
self.tradeStopped = String(array[35]) == "Y"
self.askingPrice_ResidualQuantity = Int(array[36]) ?? 0
self.biddingPrice_ResidualQuantity = Int(array[37]) ?? 0
self.askingPrice_TotalResidualQuantity = Int(array[38]) ?? 0
self.biddingPrice_TotalResidualQuantity = Int(array[39]) ?? 0
self.volumeTurnoverRate = Double(array[40]) ?? 0
self.previousDaySameTime_AccumulatedTradingQuantity = Int(array[41]) ?? 0
self.previousDaySameTime_AccumulatedTradingQuantityRatio = Double(array[42]) ?? 0
self.hourClassCode = HourClassCode(rawValue: String(array[43]).first!)!
self.marketTerminationCode = String(array[44])
self.viStandardPrice = Int(array[45]) ?? 0
}
}
public struct AskingPrice {
///
public let shortCode: String
///
public let businessTime: String
///
public let hourClassCode: HourClassCode
/// 1 ~ 10
public let askingPrices: [Int]
/// 1 ~ 10
public let biddingPrices: [Int]
/// 1 ~ 4
public let askingPriceVolumes: [Int]
/// 1 ~ 10
public let biddingPriceVolumes: [Int]
///
public let askingPrice_TotalResidualQuantity: Int
///
public let biddingPrice_TotalResidualQuantity: Int
///
public let askingPrice_Overtime_TotalResidualQuantity: Int
///
public let biddingPrice_Overtime_TotalResidualQuantity: Int
///
public let expectedConclusionPrice: Int
///
public let expectedConclusionQuantity: Int
///
public let expectedVolume: Int
///
public let expectedConclusion_VariableRatio: Double
///
public let expectedConclusion_VariableRatioSign: VariableRatioSignType
///
public let expectedConclusion_PreviousDayDiffRatio: Double
///
public let accumulatedVolume: Int
///
public let askingPrice_TotalResidualQuantity_IncreaseDecrease: Int
///
public let biddingPrice_TotalResidualQuantity_IncreaseDecrease: Int
///
public let askingPrice_Overtime_TotalResidualQuantity_IncreaseDecrease: Int
///
public let biddingPrice_Overtime_TotalResidualQuantity_IncreaseDecrease: Int
///
public let tradeCode: String
static let propertiesCount = 59
public init(array: [Substring], source: Substring) throws {
guard array.count == AskingPrice.propertiesCount else {
throw GeneralError.incorrectArrayItems(String(source), array.count, AskingPrice.propertiesCount)
}
func getIntArray(_ fromIndex: Int, _ toIndex: Int) -> [Int] {
var array = [Int]()
for i in fromIndex ..< toIndex {
let value = Int(array[i])
array.append(value)
}
return array
}
self.shortCode = String(array[0])
self.businessTime = String(array[1])
self.hourClassCode = HourClassCode(rawValue: String(array[2]).first!)!
self.askingPrices = getIntArray(3, 3+10)
self.biddingPrices = getIntArray(13, 13+10)
self.askingPriceVolumes = getIntArray(23, 23+10)
self.biddingPriceVolumes = getIntArray(33, 33+10)
self.askingPrice_TotalResidualQuantity = Int(array[43]) ?? 0
self.biddingPrice_TotalResidualQuantity = Int(array[44]) ?? 0
self.askingPrice_Overtime_TotalResidualQuantity = Int(array[45]) ?? 0
self.biddingPrice_Overtime_TotalResidualQuantity = Int(array[46]) ?? 0
self.expectedConclusionPrice = Int(array[47]) ?? 0
self.expectedConclusionQuantity = Int(array[48]) ?? 0
self.expectedVolume = Int(array[49]) ?? 0
self.expectedConclusion_VariableRatio = Double(array[50]) ?? 0
self.expectedConclusion_VariableRatioSign = VariableRatioSignType(rawValue: UInt8(array[51])!)!
self.expectedConclusion_PreviousDayDiffRatio = Double(array[52]) ?? 0
self.accumulatedVolume = Int(array[53]) ?? 0
self.askingPrice_TotalResidualQuantity_IncreaseDecrease = Int(array[54]) ?? 0
self.biddingPrice_TotalResidualQuantity_IncreaseDecrease = Int(array[55]) ?? 0
self.askingPrice_Overtime_TotalResidualQuantity_IncreaseDecrease = Int(array[56]) ?? 0
self.biddingPrice_Overtime_TotalResidualQuantity_IncreaseDecrease = Int(array[57]) ?? 0
self.tradeCode = String(array[58])
}
}
public struct ContractNotice {
/// ID
public let customerID: String
///
public let accountNo: String
///
public let orderNo: String
///
public let originalOrderNo: String
///
public let contractClass: ContractClass
///
public let revisionType: String
///
public let orderClass: OrderClass
///
public let orderCondition: String
///
public let shortCode: String
///
public let conclusionQuantity: Int
///
public let conclusionPrice: Int
///
public let conclusionTime: String
///
public let refused: RefuseYesNo
///
public let conclused: ConclusionYesNo
///
public let accepted: AcceptYesNo
///
public let branchNo: String
///
public let orderQuantity: Int
///
public let accountName: String
///
public let productName: String
///
public let creditClass: String
///
public let creditLoanDate: String
/// 40
public let productName40: String
///
public let orderPrice: Int
static let propertiesCount = 23
public init(array: [Substring], source: Substring) throws {
guard array.count == ContractNotice.propertiesCount else {
throw GeneralError.incorrectArrayItems(String(source), array.count, ContractNotice.propertiesCount)
}
self.customerID = String(array[0])
self.accountNo = String(array[1])
self.orderNo = String(array[2])
self.originalOrderNo = String(array[3])
self.contractClass = ContractClass(rawValue: String(array[4]))!
self.revisionType = String(array[5])
self.orderClass = OrderClass(rawValue: String(array[6]))!
self.orderCondition = String(array[7])
self.shortCode = String(array[8])
self.conclusionQuantity = Int(array[9]) ?? 0
self.conclusionPrice = Int(array[10]) ?? 0
self.conclusionTime = String(array[11])
self.refused = RefuseYesNo(rawValue: Int(array[12])!)!
self.conclused = ConclusionYesNo(rawValue: Int(array[13])!)!
self.accepted = AcceptYesNo(rawValue: Int(array[14])!)!
self.branchNo = String(array[15])
self.orderQuantity = Int(array[16]) ?? 0
self.accountName = String(array[17])
self.productName = String(array[18])
self.creditClass = String(array[19])
self.creditLoanDate = String(array[20])
self.productName40 = String(array[21])
self.orderPrice = Int(array[22]) ?? 0
}
}
public enum WebSocketResult {
case json(String)
case contractPrice(ContractPrice)
case askingPrice(AskingPrice)
case contractNotice(ContractNotice)
}
}
extension Domestic.MarketOperationCode {
// MARK:
///
public var isBeforeMarket: Bool { first == "1" }
///
public var isOnMarket: Bool { first == "2" }
///
public var isAfterMarket: Bool { first == "3" }
///
public var isOverTime_SinglePrice: Bool { first == "4" }
/// Buy-in
public var isGeneralBuyIn: Bool { first == "5" }
/// Buy-in
public var isTheDayBuyIn: Bool { first == "6" }
// MARK:
///
public var isGeneral: Bool { second == "0" }
///
public var isClosingPrice: Bool { second == "1" }
///
public var isBulk: Bool { second == "2" }
///
public var isBasket: Bool { second == "3" }
///
public var isClearanceSale: Bool { second == "7" }
/// Buy-in
public var isBuyIn: Bool { second == "8" }
private var first: Character { self[startIndex] }
private var second: Character { self[index(startIndex, offsetBy: 1)] }
}
extension Domestic.WebSocketResult {
static public func parse(_ str: String) throws -> [Domestic.WebSocketResult] {
var dataArray = [Domestic.WebSocketResult]()
var nextAt = str.startIndex
let charset = CharacterSet(charactersIn: "{}")
while nextAt < str.endIndex {
print("nextAt... \(nextAt.utf16Offset(in: str))")
switch str[nextAt] {
case "{":
/// Scan end of json data
var openedCount = 1
let startAt = nextAt
nextAt = str.index(nextAt, offsetBy: 1)
while openedCount > 0 {
guard let r = str.rangeOfCharacter(from: charset, options: [], range: nextAt ..< str.endIndex) else {
break
}
switch str[r.lowerBound] {
case "{":
openedCount += 1
case "}":
openedCount -= 1
if openedCount == 0 {
/// end of json data
let jsonString = String(str[startAt ..< r.upperBound])
dataArray.append(.json(jsonString))
nextAt = r.upperBound
break
}
default:
throw GeneralError.impossibleJsonCharacter
}
nextAt = r.upperBound
}
case "0":
let (data, endAt) = try parseTrData(false, str: str, startAt: nextAt)
dataArray.append(contentsOf: data)
nextAt = endAt
case "1":
let (data, endAt) = try parseTrData(true, str: str, startAt: nextAt)
dataArray.append(contentsOf: data)
nextAt = endAt
default:
print(str[nextAt ..< str.endIndex])
throw GeneralError.invalidWebSocketData
}
}
return dataArray
}
private static func parseTrData(_ encrypted: Bool, str: String, startAt: String.Index) throws -> ([Domestic.WebSocketResult], String.Index) {
var dataArray = [Domestic.WebSocketResult]()
var nextAt = startAt
let charset = CharacterSet(charactersIn: "|")
guard let i1 = str.rangeOfCharacter(from: charset, options: [], range: nextAt ..< str.endIndex) else {
throw GeneralError.notEnoughWebSocketData
}
/// Get encryption field
let encryption = String(str[nextAt ..< i1.lowerBound])
guard encryption == "0" || encryption == "1" else {
throw GeneralError.invalidWebSocketData_EncryptionField
}
nextAt = i1.upperBound
guard let i2 = str.rangeOfCharacter(from: charset, options: [], range: nextAt ..< str.endIndex) else {
throw GeneralError.notEnoughWebSocketData
}
/// Get trId field
let trId = String(str[nextAt ..< i2.lowerBound])
nextAt = i2.upperBound
guard let i3 = str.rangeOfCharacter(from: charset, options: [], range: nextAt ..< str.endIndex) else {
throw GeneralError.notEnoughWebSocketData
}
/// Get data count field
let dataCountString = String(str[nextAt ..< i3.lowerBound])
guard let dataCount = Int(dataCountString) else {
throw GeneralError.notEnoughWebSocketData
}
nextAt = i3.upperBound
/// Retrieve multiple data
switch trId {
case "H0STCNT0":
for _ in 0 ..< dataCount {
let (stringArray, string, endAt) = try getTrDataString(str, startAt: nextAt, seperatorCount: Domestic.ContractPrice.propertiesCount-1)
let price = try Domestic.ContractPrice(array: stringArray, source: string)
dataArray.append(.contractPrice(price))
nextAt = endAt
}
case "H0STASP0":
for _ in 0 ..< dataCount {
let (stringArray, string, endAt) = try getTrDataString(str, startAt: nextAt, seperatorCount: Domestic.AskingPrice.propertiesCount-1)
let price = try Domestic.ContractPrice(array: stringArray, source: string)
dataArray.append(.contractPrice(price))
nextAt = endAt
}
case "H0STCNI0":
for _ in 0 ..< dataCount {
let (stringArray, string, endAt) = try getTrDataString(str, startAt: startAt, seperatorCount: Domestic.ContractNotice.propertiesCount-1)
let notice = try Domestic.ContractNotice(array: stringArray, source: string)
dataArray.append(.contractNotice(notice))
nextAt = endAt
}
default:
throw GeneralError.invalidWebSocketData_TrIdField
}
return (dataArray, nextAt)
}
private static func getTrDataString(_ str: String, startAt: String.Index, seperatorCount: Int) throws -> ([Substring], Substring, String.Index) {
var currentSeperator = 0
var nextAt = startAt
var array = [Substring]()
/// Find last seperator
while currentSeperator < seperatorCount {
guard let last = str.range(of: "^", options: [], range: nextAt ..< str.endIndex) else {
throw GeneralError.notEnoughWebSocketData
}
currentSeperator += 1
array.append(str[nextAt ..< last.lowerBound])
nextAt = last.upperBound
}
/// Look forward to find final field
if let end = str.rangeOfCharacter(from: .alphanumerics.inverted, options: [], range: nextAt ..< str.endIndex) {
array.append(str[nextAt ..< end.lowerBound])
let string = str[startAt ..< end.lowerBound]
return (array, string, end.lowerBound)
}
else {
array.append(str[nextAt ..< str.endIndex])
let string = str[startAt ..< str.endIndex]
return (array, string, str.endIndex)
}
}
}

View File

@@ -16,486 +16,13 @@ import KissMe
test_parse_contact_price_response()
enum VariableRatioSignType: UInt8 {
///
case upLimit = 1
///
case up = 2
///
case noChange = 3
///
case downLimit = 4
///
case down = 5
}
enum ConclusionType: UInt8 {
/// (+)
case buying = 1
///
case load = 3
/// (-)
case selling = 5
}
enum HourClassCode: Character {
///
case onMarket = "0"
///
case afterMarket = "A"
///
case beforeMarket = "B"
/// 9 , VI
case viInvoking = "C"
///
case overTime_SinglePrice = "D"
}
typealias MarketOperationCode = String
extension MarketOperationCode {
// MARK:
///
public var isBeforeMarket: Bool { first == "1" }
///
public var isOnMarket: Bool { first == "2" }
///
public var isAfterMarket: Bool { first == "3" }
///
public var isOverTime_SinglePrice: Bool { first == "4" }
/// Buy-in
public var isGeneralBuyIn: Bool { first == "5" }
/// Buy-in
public var isTheDayBuyIn: Bool { first == "6" }
// MARK:
///
public var isGeneral: Bool { second == "0" }
///
public var isClosingPrice: Bool { second == "1" }
///
public var isBulk: Bool { second == "2" }
///
public var isBasket: Bool { second == "3" }
///
public var isClearanceSale: Bool { second == "7" }
/// Buy-in
public var isBuyIn: Bool { second == "8" }
var first: Character { self[startIndex] }
var second: Character { self[index(startIndex, offsetBy: 1)] }
}
struct ContractPrice {
///
public let shortCode: String
/// (HHmmss)
public let conclusionTime: String
///
public let currentPrice: Int
///
public let previousDayVariableRatioSign: VariableRatioSignType
///
public let previousDayVariableRatio: Double
///
public let previousDayDiffRatio: Double
///
public let weightedAveragePrice: Int
///
public let openningPrice: Int
///
public let highestPrice: Int
///
public let lowestPrice: Int
/// 1
public let askingPrice: Int
/// 1
public let biddingPrice: Int
///
public let conclusionVolume: Int
///
public let accumulatedVolume: Int
///
public let accumulatedTradingAmount: Int
///
public let sellingConclusionCount: Int
///
public let buyingConclusionCount: Int
///
public let netBuyingConclusionCount: Int
///
public let conclusionStrength: Double
///
public let totalSellingQuantity: Int
///
public let totalBuyingQuantity: Int
///
public let conclusionType: ConclusionType
///
public let buyingRatio: Double
///
public let previousDay_VolumeDiff_FluctuationRate: Double
///
public let openningPriceHour: String
///
public let openningPrice_VariableRatioSign: VariableRatioSignType
///
public let openningPrice_VariableRatio: Int
///
public let highestPriceHour: String
///
public let highPrice_VariableRatioSign: VariableRatioSignType
///
public let highPrice_VariableRatio: Int
///
public let lowestPriceHour: String
///
public let lowPrice_VariableRatioSign: VariableRatioSignType
///
public let lowPrice_VariableRatio: Int
///
public let businessDate: String
///
public let marketOperationCode: MarketOperationCode
///
public let tradeStopped: Bool
/// 1
public let askingPrice_ResidualQuantity: Int
/// 1
public let biddingPrice_ResidualQuantity: Int
///
public let askingPrice_TotalResidualQuantity: Int
///
public let biddingPrice_TotalResidualQuantity: Int
///
public let volumeTurnoverRate: Double
///
public let previousDaySameTime_AccumulatedTradingQuantity: Int
///
public let previousDaySameTime_AccumulatedTradingQuantityRatio: Double
///
public let hourClassCode: HourClassCode
///
public let marketTerminationCode: String
/// VI
public let viStandardPrice: Int
static let propertiesCount = 46
public init(array: [Substring], source: Substring) throws {
guard array.count == ContractPrice.propertiesCount else {
throw GeneralError.incorrectArrayItems(String(source), array.count, ContractPrice.propertiesCount)
}
self.shortCode = String(array[0])
self.conclusionTime = String(array[1])
self.currentPrice = Int(array[2]) ?? 0
self.previousDayVariableRatioSign = VariableRatioSignType(rawValue: UInt8(array[3])!)!
self.previousDayVariableRatio = Double(array[4]) ?? 0
self.previousDayDiffRatio = Double(array[5]) ?? 0
self.weightedAveragePrice = Int(array[6]) ?? 0
self.openningPrice = Int(array[7]) ?? 0
self.highestPrice = Int(array[8]) ?? 0
self.lowestPrice = Int(array[9]) ?? 0
self.askingPrice = Int(array[10]) ?? 0
self.biddingPrice = Int(array[11]) ?? 0
self.conclusionVolume = Int(array[12]) ?? 0
self.accumulatedVolume = Int(array[13]) ?? 0
self.accumulatedTradingAmount = Int(array[14]) ?? 0
self.sellingConclusionCount = Int(array[15]) ?? 0
self.buyingConclusionCount = Int(array[16]) ?? 0
self.netBuyingConclusionCount = Int(array[17]) ?? 0
self.conclusionStrength = Double(array[18]) ?? 0
self.totalSellingQuantity = Int(array[19]) ?? 0
self.totalBuyingQuantity = Int(array[20]) ?? 0
self.conclusionType = ConclusionType(rawValue: UInt8(array[21])!)!
self.buyingRatio = Double(array[22]) ?? 0
self.previousDay_VolumeDiff_FluctuationRate = Double(array[23]) ?? 0
self.openningPriceHour = String(array[24])
self.openningPrice_VariableRatioSign = VariableRatioSignType(rawValue: UInt8(array[25])!)!
self.openningPrice_VariableRatio = Int(array[26]) ?? 0
self.highestPriceHour = String(array[27])
self.highPrice_VariableRatioSign = VariableRatioSignType(rawValue: UInt8(array[28])!)!
self.highPrice_VariableRatio = Int(array[29]) ?? 0
self.lowestPriceHour = String(array[30])
self.lowPrice_VariableRatioSign = VariableRatioSignType(rawValue: UInt8(array[31])!)!
self.lowPrice_VariableRatio = Int(array[32]) ?? 0
self.businessDate = String(array[33])
self.marketOperationCode = String(array[34])
self.tradeStopped = String(array[35]) == "Y"
self.askingPrice_ResidualQuantity = Int(array[36]) ?? 0
self.biddingPrice_ResidualQuantity = Int(array[37]) ?? 0
self.askingPrice_TotalResidualQuantity = Int(array[38]) ?? 0
self.biddingPrice_TotalResidualQuantity = Int(array[39]) ?? 0
self.volumeTurnoverRate = Double(array[40]) ?? 0
self.previousDaySameTime_AccumulatedTradingQuantity = Int(array[41]) ?? 0
self.previousDaySameTime_AccumulatedTradingQuantityRatio = Double(array[42]) ?? 0
self.hourClassCode = HourClassCode(rawValue: String(array[43]).first!)!
self.marketTerminationCode = String(array[44])
self.viStandardPrice = Int(array[45]) ?? 0
}
}
struct AskingPrice {
///
public let shortCode: String
///
public let businessTime: String
///
public let hourClassCode: HourClassCode
/// 1 ~ 10
public let askingPrices: [Int]
/// 1 ~ 10
public let biddingPrices: [Int]
/// 1 ~ 4
public let askingPriceVolumes: [Int]
/// 1 ~ 10
public let biddingPriceVolumes: [Int]
///
public let askingPrice_TotalResidualQuantity: Int
///
public let biddingPrice_TotalResidualQuantity: Int
///
public let askingPrice_Overtime_TotalResidualQuantity: Int
///
public let biddingPrice_Overtime_TotalResidualQuantity: Int
///
public let expectedConclusionPrice: Int
///
public let expectedConclusionQuantity: Int
///
public let expectedVolume: Int
///
public let expectedConclusion_VariableRatio: Double
///
public let expectedConclusion_VariableRatioSign: VariableRatioSignType
///
public let expectedConclusion_PreviousDayDiffRatio: Double
///
public let accumulatedVolume: Int
///
public let askingPrice_TotalResidualQuantity_IncreaseDecrease: Int
///
public let biddingPrice_TotalResidualQuantity_IncreaseDecrease: Int
///
public let askingPrice_Overtime_TotalResidualQuantity_IncreaseDecrease: Int
///
public let biddingPrice_Overtime_TotalResidualQuantity_IncreaseDecrease: Int
///
public let tradeCode: String
static let propertiesCount = 59
public init(array: [Substring], source: Substring) throws {
guard array.count == AskingPrice.propertiesCount else {
throw GeneralError.incorrectArrayItems(String(source), array.count, AskingPrice.propertiesCount)
}
func getIntArray(_ fromIndex: Int, _ toIndex: Int) -> [Int] {
var array = [Int]()
for i in fromIndex ..< toIndex {
let value = Int(array[i])
array.append(value)
}
return array
}
self.shortCode = String(array[0])
self.businessTime = String(array[1])
self.hourClassCode = HourClassCode(rawValue: String(array[2]).first!)!
self.askingPrices = getIntArray(3, 3+10)
self.biddingPrices = getIntArray(13, 13+10)
self.askingPriceVolumes = getIntArray(23, 23+10)
self.biddingPriceVolumes = getIntArray(33, 33+10)
self.askingPrice_TotalResidualQuantity = Int(array[43]) ?? 0
self.biddingPrice_TotalResidualQuantity = Int(array[44]) ?? 0
self.askingPrice_Overtime_TotalResidualQuantity = Int(array[45]) ?? 0
self.biddingPrice_Overtime_TotalResidualQuantity = Int(array[46]) ?? 0
self.expectedConclusionPrice = Int(array[47]) ?? 0
self.expectedConclusionQuantity = Int(array[48]) ?? 0
self.expectedVolume = Int(array[49]) ?? 0
self.expectedConclusion_VariableRatio = Double(array[50]) ?? 0
self.expectedConclusion_VariableRatioSign = VariableRatioSignType(rawValue: UInt8(array[51])!)!
self.expectedConclusion_PreviousDayDiffRatio = Double(array[52]) ?? 0
self.accumulatedVolume = Int(array[53]) ?? 0
self.askingPrice_TotalResidualQuantity_IncreaseDecrease = Int(array[54]) ?? 0
self.biddingPrice_TotalResidualQuantity_IncreaseDecrease = Int(array[55]) ?? 0
self.askingPrice_Overtime_TotalResidualQuantity_IncreaseDecrease = Int(array[56]) ?? 0
self.biddingPrice_Overtime_TotalResidualQuantity_IncreaseDecrease = Int(array[57]) ?? 0
self.tradeCode = String(array[58])
}
}
enum ContractType: String {
///
case selling = "01"
///
case buying = "02"
}
enum OrderType: String {
///
case limits = "00"
///
case marketPrice = "01"
///
case conditionalLimits = "02"
///
case mostFavorLimits = "03"
///
case mostPriorLimits = "04"
///
case overTime_BeforeMarket = "05"
///
case overTime_AfterMarket = "06"
///
case overTime_SinglePrice = "07"
///
case treasury = "08"
/// S-Option
case treasury_SOption = "09"
///
case treasury_MoneyTrust = "10"
/// IOC (,)
case iocLimits_Conclusion_CancelResidualQuantity = "11"
/// FOK (,)
case fokLimits_Conclusion_CancelEntireQuantity = "12"
/// IOC (,)
case iocMarketPrice_Conclusion_CancelResidualQuantity = "13"
/// FOK (,)
case fokMarketPrice_Conclusion_CancelEntireQuantity = "14"
/// IOC (,)
case iocMostFavor_Conclusion_CancelResidualQuantity = "15"
/// FOK (,)
case fokMostFavor_Conclusion_CancelEntireQuantity = "16"
}
enum RefuseYesNo: Int {
///
case approval = 0
///
case refuse = 1
}
enum ConclusionYesNo: Int {
/// ,,,,
case unconclused = 1
/// ( 2 )
case conclused = 2
}
enum AcceptYesNo: Int {
///
case orderAccept = 1
///
case confirm = 2
/// (FOK/IOC)
case cancel = 3
}
struct ContractNotice {
/// ID
public let customerID: String
///
public let accountNo: String
///
public let orderNo: String
///
public let originalOrderNo: String
///
public let contractType: ContractType
///
public let revisionType: String
///
public let orderType: OrderType
///
public let orderCondition: String
///
public let shortCode: String
///
public let conclusionQuantity: Int
///
public let conclusionPrice: Int
///
public let conclusionTime: String
///
public let refused: RefuseYesNo
///
public let conclused: ConclusionYesNo
///
public let accepted: AcceptYesNo
///
public let branchNo: String
///
public let orderQuantity: Int
///
public let accountName: String
///
public let productName: String
///
public let creditClass: String
///
public let creditLoanDate: String
/// 40
public let productName40: String
///
public let orderPrice: Int
static let propertiesCount = 23
public init(array: [Substring], source: Substring) throws {
guard array.count == ContractNotice.propertiesCount else {
throw GeneralError.incorrectArrayItems(String(source), array.count, ContractNotice.propertiesCount)
}
self.customerID = String(array[0])
self.accountNo = String(array[1])
self.orderNo = String(array[2])
self.originalOrderNo = String(array[3])
self.contractType = ContractType(rawValue: String(array[4]))!
self.revisionType = String(array[5])
self.orderType = OrderType(rawValue: String(array[6]))!
self.orderCondition = String(array[7])
self.shortCode = String(array[8])
self.conclusionQuantity = Int(array[9]) ?? 0
self.conclusionPrice = Int(array[10]) ?? 0
self.conclusionTime = String(array[11])
self.refused = RefuseYesNo(rawValue: Int(array[12])!)!
self.conclused = ConclusionYesNo(rawValue: Int(array[13])!)!
self.accepted = AcceptYesNo(rawValue: Int(array[14])!)!
self.branchNo = String(array[15])
self.orderQuantity = Int(array[16]) ?? 0
self.accountName = String(array[17])
self.productName = String(array[18])
self.creditClass = String(array[19])
self.creditLoanDate = String(array[20])
self.productName40 = String(array[21])
self.orderPrice = Int(array[22]) ?? 0
}
}
func test_parse_contact_price_response() {
let str = "{\"header\":{\"tr_id\":\"H0STCNT0\",\"tr_key\":\"005930\",\"encrypt\":\"N\"},\"body\":{\"rt_cd\":\"0\",\"msg_cd\":\"OPSP0000\",\"msg1\":\"SUBSCRIBE SUCCESS\",\"output\":{\"iv\":\"dcc3c442acfb8b9a\",\"key\":\"vcvxscahuklwkiawiuxbsfcmsulqjejf\"}}}0|H0STCNT0|001|005930^134305^68100^2^1000^1.49^68305.67^68300^68700^67900^68100^68000^1^11393808^778261604700^32559^26679^-5880^79.02^6084367^4807987^1^0.43^119.32^090027^5^-200^091809^5^-600^113615^2^200^20230824^20^N^309354^354766^2143494^2041321^0.19^6698642^170.09^0^^68300{\"header\":{\"tr_id\":\"PINGPONG\",\"datetime\":\"20230824212922\"}}"
do {
let dataArray = try parseJsonTrData(str)
let dataArray = try Domestic.WebSocketResult.parse(str)
for data in dataArray {
switch data {
case .json(let str):
@@ -514,165 +41,6 @@ func test_parse_contact_price_response() {
}
enum JsonTrDataType {
case json(String)
case contractPrice(ContractPrice)
case askingPrice(AskingPrice)
case contractNotice(ContractNotice)
}
func parseJsonTrData(_ str: String) throws -> [JsonTrDataType] {
var dataArray = [JsonTrDataType]()
var nextAt = str.startIndex
let charset = CharacterSet(charactersIn: "{}")
while nextAt < str.endIndex {
print("nextAt... \(nextAt.utf16Offset(in: str))")
switch str[nextAt] {
case "{":
/// Scan end of json data
var openedCount = 1
let startAt = nextAt
nextAt = str.index(nextAt, offsetBy: 1)
while openedCount > 0 {
guard let r = str.rangeOfCharacter(from: charset, options: [], range: nextAt ..< str.endIndex) else {
break
}
switch str[r.lowerBound] {
case "{":
openedCount += 1
case "}":
openedCount -= 1
if openedCount == 0 {
/// end of json data
let jsonString = String(str[startAt ..< r.upperBound])
dataArray.append(.json(jsonString))
nextAt = r.upperBound
break
}
default:
throw GeneralError.impossibleJsonCharacter
}
nextAt = r.upperBound
}
case "0":
let (data, endAt) = try parseTrData(false, str: str, startAt: nextAt)
dataArray.append(contentsOf: data)
nextAt = endAt
case "1":
let (data, endAt) = try parseTrData(true, str: str, startAt: nextAt)
dataArray.append(contentsOf: data)
nextAt = endAt
default:
print(str[nextAt ..< str.endIndex])
throw GeneralError.invalidWebSocketData
}
}
return dataArray
}
private func parseTrData(_ encrypted: Bool, str: String, startAt: String.Index) throws -> ([JsonTrDataType], String.Index) {
var dataArray = [JsonTrDataType]()
var nextAt = startAt
let charset = CharacterSet(charactersIn: "|")
guard let i1 = str.rangeOfCharacter(from: charset, options: [], range: nextAt ..< str.endIndex) else {
throw GeneralError.notEnoughWebSocketData
}
/// Get encryption field
let encryption = String(str[nextAt ..< i1.lowerBound])
guard encryption == "0" || encryption == "1" else {
throw GeneralError.invalidWebSocketData_EncryptionField
}
nextAt = i1.upperBound
guard let i2 = str.rangeOfCharacter(from: charset, options: [], range: nextAt ..< str.endIndex) else {
throw GeneralError.notEnoughWebSocketData
}
/// Get trId field
let trId = String(str[nextAt ..< i2.lowerBound])
nextAt = i2.upperBound
guard let i3 = str.rangeOfCharacter(from: charset, options: [], range: nextAt ..< str.endIndex) else {
throw GeneralError.notEnoughWebSocketData
}
/// Get data count field
let dataCountString = String(str[nextAt ..< i3.lowerBound])
guard let dataCount = Int(dataCountString) else {
throw GeneralError.notEnoughWebSocketData
}
nextAt = i3.upperBound
/// Retrieve multiple data
switch trId {
case "H0STCNT0":
for _ in 0 ..< dataCount {
let (stringArray, string, endAt) = try getTrDataString(str, startAt: nextAt, seperatorCount: ContractPrice.propertiesCount-1)
let price = try ContractPrice(array: stringArray, source: string)
dataArray.append(.contractPrice(price))
nextAt = endAt
}
case "H0STASP0":
for _ in 0 ..< dataCount {
let (stringArray, string, endAt) = try getTrDataString(str, startAt: nextAt, seperatorCount: AskingPrice.propertiesCount-1)
let price = try ContractPrice(array: stringArray, source: string)
dataArray.append(.contractPrice(price))
nextAt = endAt
}
case "H0STCNI0":
for _ in 0 ..< dataCount {
let (stringArray, string, endAt) = try getTrDataString(str, startAt: startAt, seperatorCount: ContractNotice.propertiesCount-1)
let notice = try ContractNotice(array: stringArray, source: string)
dataArray.append(.contractNotice(notice))
nextAt = endAt
}
default:
throw GeneralError.invalidWebSocketData_TrIdField
}
return (dataArray, nextAt)
}
private func getTrDataString(_ str: String, startAt: String.Index, seperatorCount: Int) throws -> ([Substring], Substring, String.Index) {
var currentSeperator = 0
var nextAt = startAt
var array = [Substring]()
/// Find last seperator
while currentSeperator < seperatorCount {
guard let last = str.range(of: "^", options: [], range: nextAt ..< str.endIndex) else {
throw GeneralError.notEnoughWebSocketData
}
currentSeperator += 1
array.append(str[nextAt ..< last.lowerBound])
nextAt = last.upperBound
}
/// Look forward to find final field
if let end = str.rangeOfCharacter(from: .alphanumerics.inverted, options: [], range: nextAt ..< str.endIndex) {
array.append(str[nextAt ..< end.lowerBound])
let string = str[startAt ..< end.lowerBound]
return (array, string, end.lowerBound)
}
else {
array.append(str[nextAt ..< str.endIndex])
let string = str[startAt ..< str.endIndex]
return (array, string, str.endIndex)
}
}
func test_get_websocket_key_and_asking_price() {
let isMock = false

View File

@@ -53,6 +53,7 @@
34C1BA8A2A5DA00A00423D64 /* DomesticDartMajorReport.swift in Sources */ = {isa = PBXBuildFile; fileRef = 34C1BA892A5DA00A00423D64 /* DomesticDartMajorReport.swift */; };
34C97D0B2A602A3D00ED8B33 /* DomesticDartSecuritiesReport.swift in Sources */ = {isa = PBXBuildFile; fileRef = 34C97D0A2A602A3D00ED8B33 /* DomesticDartSecuritiesReport.swift */; };
34D3680F2A2AA0BE005E6756 /* PropertyIterable.swift in Sources */ = {isa = PBXBuildFile; fileRef = 34D3680E2A2AA0BE005E6756 /* PropertyIterable.swift */; };
34DA3E9D2A9A028200BB3439 /* Domestic.WebSocketData.swift in Sources */ = {isa = PBXBuildFile; fileRef = 34DA3E9C2A9A028200BB3439 /* Domestic.WebSocketData.swift */; };
34E7B9112A49BD2800B3AB9F /* DomesticIndex.swift in Sources */ = {isa = PBXBuildFile; fileRef = 34E7B9102A49BD2800B3AB9F /* DomesticIndex.swift */; };
34EC4D212A7ACB07002F947C /* CompanyPartitionMergerDecisionResult.json in Resources */ = {isa = PBXBuildFile; fileRef = 34EC4D202A7ACB06002F947C /* CompanyPartitionMergerDecisionResult.json */; };
34EC4D242A7F27A8002F947C /* CompanyPartitionDecisionResult.json in Resources */ = {isa = PBXBuildFile; fileRef = 34EC4D232A7F27A8002F947C /* CompanyPartitionDecisionResult.json */; };
@@ -195,6 +196,7 @@
34C1BA892A5DA00A00423D64 /* DomesticDartMajorReport.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = DomesticDartMajorReport.swift; sourceTree = "<group>"; };
34C97D0A2A602A3D00ED8B33 /* DomesticDartSecuritiesReport.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = DomesticDartSecuritiesReport.swift; sourceTree = "<group>"; };
34D3680E2A2AA0BE005E6756 /* PropertyIterable.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = PropertyIterable.swift; sourceTree = "<group>"; };
34DA3E9C2A9A028200BB3439 /* Domestic.WebSocketData.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = Domestic.WebSocketData.swift; sourceTree = "<group>"; };
34E7B9102A49BD2800B3AB9F /* DomesticIndex.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = DomesticIndex.swift; sourceTree = "<group>"; };
34EC4D202A7ACB06002F947C /* CompanyPartitionMergerDecisionResult.json */ = {isa = PBXFileReference; lastKnownFileType = text.json; path = CompanyPartitionMergerDecisionResult.json; sourceTree = "<group>"; };
34EC4D232A7F27A8002F947C /* CompanyPartitionDecisionResult.json */ = {isa = PBXFileReference; lastKnownFileType = text.json; path = CompanyPartitionDecisionResult.json; sourceTree = "<group>"; };
@@ -408,6 +410,7 @@
34BC44742A8656250052D8EB /* Realtime */ = {
isa = PBXGroup;
children = (
34DA3E9C2A9A028200BB3439 /* Domestic.WebSocketData.swift */,
34BC447C2A86635A0052D8EB /* Domestic.ContractPriceWebSocket.swift */,
34BC447A2A8663430052D8EB /* Domestic.AskingPriceWebSocket.swift */,
34BC44752A8656570052D8EB /* Domestic.ContractNoticeWebSocket.swift */,
@@ -841,6 +844,7 @@
341F5EE12A0F373B00962D48 /* Login.swift in Sources */,
341F5EF52A0F891200962D48 /* KissAccount.swift in Sources */,
340A4DBD2A4C34BE005A1FBA /* IndexContext.swift in Sources */,
34DA3E9D2A9A028200BB3439 /* Domestic.WebSocketData.swift in Sources */,
34BC44762A8656570052D8EB /* Domestic.ContractNoticeWebSocket.swift in Sources */,
34E7B9112A49BD2800B3AB9F /* DomesticIndex.swift in Sources */,
341F5F0D2A15222E00962D48 /* AuthRequest.swift in Sources */,