将数据类及枚举类定义抽离到独立类库 KTrader-Datatype 中

将 MESSAGE 事件改名为 LOG 事件

Author: RationalityFrontline

lib/build.gradle.kts

@@ -20,6 +20,8 @@ repositories {
 dependencies {
     compileOnly("org.rationalityfrontline.workaround:pf4j:3.7.0")
     api("org.rationalityfrontline:kevent:2.0.1")
+    api("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.5.1")
+    api("org.rationalityfrontline.ktrader:ktrader-datatype:1.0.0")
 }
 
 sourceSets.main {

lib/src/main/kotlin/module-info.java

@@ -1,6 +1,8 @@
+@SuppressWarnings("requires-transitive-automatic")
 module ktrader.broker.api {
-    requires transitive kotlin.stdlib;
+    requires transitive kotlinx.coroutines.core.jvm;
     requires transitive kevent;
+    requires transitive ktrader.datatype;
     requires static org.pf4j;
 
     exports org.rationalityfrontline.ktrader.broker.api;

lib/src/main/kotlin/org/rationalityfrontline/ktrader/broker/api/Broker.kt

@@ -1,3 +1,5 @@
+@file:Suppress("unused")
+
 package org.rationalityfrontline.ktrader.broker.api
 
 import org.pf4j.ExtensionPoint
@@ -45,7 +47,7 @@ abstract class Broker : ExtensionPoint {
     /**
      * 创建 [BrokerApi] 实例
      * @param config 参见 [configKeys]
-     * @param kEvent 会通过该 [KEvent] 实例推送 [BrokerEvent]，如 [Tick]、成交回报等
+     * @param kEvent 会通过该 [KEvent] 实例推送 [BrokerEvent]，如 Tick、成交回报等
      */
     abstract fun createApi(config: Map<String, Any>, kEvent: KEvent): BrokerApi
 

lib/src/main/kotlin/org/rationalityfrontline/ktrader/broker/api/BrokerApi.kt

@@ -1,6 +1,9 @@
+@file:Suppress("MemberVisibilityCanBePrivate", "unused")
+
 package org.rationalityfrontline.ktrader.broker.api
 
 import org.rationalityfrontline.kevent.KEvent
+import org.rationalityfrontline.ktrader.datatype.*
 import java.time.LocalDate
 import java.time.LocalDateTime
 

lib/src/main/kotlin/org/rationalityfrontline/ktrader/broker/api/BrokerEvent.kt

@@ -2,6 +2,11 @@
 
 package org.rationalityfrontline.ktrader.broker.api
 
+import org.rationalityfrontline.ktrader.datatype.Order
+import org.rationalityfrontline.ktrader.datatype.OrderStatus
+import org.rationalityfrontline.ktrader.datatype.Tick
+import org.rationalityfrontline.ktrader.datatype.Trade
+
 /**
  * 推送事件类型
  */
@@ -13,9 +18,9 @@ enum class BrokerEventType {
     CUSTOM_EVENT,
 
     /**
-     * 消息通知事件。[BrokerEvent.data]: [MessageEvent]
+     * 日志事件。[BrokerEvent.data]: [LogEvent]
      */
-    MESSAGE,
+    LOG,
 
     /**
      * 网络连接状态变更。[BrokerEvent.data]: [ConnectionEvent]
@@ -71,9 +76,9 @@ data class CustomEvent(
 )
 
 /**
- * 消息事件类型
+ * 日志等级
  */
-enum class MessageEventType {
+enum class LogLevel {
     /**
      * 普通信息，用于通知状态变化、执行进度等。
      */
@@ -91,12 +96,12 @@ enum class MessageEventType {
 }
 
 /**
- * 消息通知事件。
- * @param type 消息类型
+ * 日志事件。
+ * @param level 日志等级
  * @param msg 消息内容
  */
-data class MessageEvent(
-    val type: MessageEventType,
+data class LogEvent(
+    val level: LogLevel,
     val msg: String,
 )