refactor: move StreamDirection to a shared module

blurite · Jul 31, 2024 · 796905a · 796905a
1 parent 22ef0c1
commit 796905a
Show file tree

Hide file tree

Showing 11 changed files with 11 additions and 8 deletions.
diff --git a/proxy/src/main/kotlin/net/rsprox/proxy/binary/BinaryBlob.kt b/proxy/src/main/kotlin/net/rsprox/proxy/binary/BinaryBlob.kt
@@ -20,6 +20,7 @@ import net.rsprox.proxy.plugin.PluginLoader
 import net.rsprox.proxy.transcriber.LiveTranscriberSession
 import net.rsprox.proxy.util.NopSessionMonitor
 import net.rsprox.shared.SessionMonitor
+import net.rsprox.shared.StreamDirection
 import net.rsprox.transcriber.BaseMessageConsumerContainer
 import net.rsprox.transcriber.MessageConsumer
 import java.net.URL

diff --git a/proxy/src/main/kotlin/net/rsprox/proxy/binary/BinaryPacket.kt b/proxy/src/main/kotlin/net/rsprox/proxy/binary/BinaryPacket.kt
@@ -2,6 +2,7 @@ package net.rsprox.proxy.binary
 
 import io.netty.buffer.ByteBuf
 import net.rsprot.protocol.Prot
+import net.rsprox.shared.StreamDirection
 
 public data class BinaryPacket(
     public val epochTimeMillis: Long,

diff --git a/proxy/src/main/kotlin/net/rsprox/proxy/binary/BinaryStream.kt b/proxy/src/main/kotlin/net/rsprox/proxy/binary/BinaryStream.kt
@@ -10,6 +10,7 @@ import net.rsprot.buffer.extensions.pdata
 import net.rsprot.protocol.ClientProt
 import net.rsprot.protocol.Prot
 import net.rsprox.protocol.ProtProvider
+import net.rsprox.shared.StreamDirection
 import kotlin.math.max
 import kotlin.math.min
 

diff --git a/proxy/src/main/kotlin/net/rsprox/proxy/cli/BinaryToStringCommand.kt b/proxy/src/main/kotlin/net/rsprox/proxy/cli/BinaryToStringCommand.kt
@@ -5,12 +5,12 @@ import com.github.ajalt.clikt.parameters.options.option
 import net.rsprox.cache.Js5MasterIndex
 import net.rsprox.cache.resolver.HistoricCacheResolver
 import net.rsprox.proxy.binary.BinaryBlob
-import net.rsprox.proxy.binary.StreamDirection
 import net.rsprox.proxy.cache.StatefulCacheProvider
 import net.rsprox.proxy.config.BINARY_PATH
 import net.rsprox.proxy.huffman.HuffmanProvider
 import net.rsprox.proxy.plugin.DecodingSession
 import net.rsprox.proxy.plugin.PluginLoader
+import net.rsprox.shared.StreamDirection
 import java.nio.file.Path
 import kotlin.io.path.bufferedWriter
 import kotlin.io.path.exists

diff --git a/proxy/src/main/kotlin/net/rsprox/proxy/cli/TranscribeCommand.kt b/proxy/src/main/kotlin/net/rsprox/proxy/cli/TranscribeCommand.kt
@@ -6,13 +6,13 @@ import com.github.michaelbull.logging.InlineLogger
 import net.rsprox.cache.Js5MasterIndex
 import net.rsprox.cache.resolver.HistoricCacheResolver
 import net.rsprox.proxy.binary.BinaryBlob
-import net.rsprox.proxy.binary.StreamDirection
 import net.rsprox.proxy.cache.StatefulCacheProvider
 import net.rsprox.proxy.config.BINARY_PATH
 import net.rsprox.proxy.huffman.HuffmanProvider
 import net.rsprox.proxy.plugin.DecodingSession
 import net.rsprox.proxy.plugin.PluginLoader
 import net.rsprox.proxy.util.NopSessionMonitor
+import net.rsprox.shared.StreamDirection
 import net.rsprox.shared.property.PropertyTreeFormatter
 import net.rsprox.shared.property.RootProperty
 import net.rsprox.transcriber.BaseMessageConsumerContainer

diff --git a/proxy/src/main/kotlin/net/rsprox/proxy/client/ClientGameHandler.kt b/proxy/src/main/kotlin/net/rsprox/proxy/client/ClientGameHandler.kt
@@ -8,8 +8,8 @@ import net.rsprot.buffer.extensions.p4
 import net.rsprot.buffer.extensions.toJagByteBuf
 import net.rsprox.protocol.game.incoming.decoder.prot.GameClientProt
 import net.rsprox.proxy.attributes.INCOMING_BANK_PIN
-import net.rsprox.proxy.binary.StreamDirection
 import net.rsprox.proxy.channel.getBinaryBlob
+import net.rsprox.shared.StreamDirection
 
 public class ClientGameHandler(
     private val serverChannel: Channel,

diff --git a/proxy/src/main/kotlin/net/rsprox/proxy/plugin/DecodingSession.kt b/proxy/src/main/kotlin/net/rsprox/proxy/plugin/DecodingSession.kt
@@ -7,7 +7,7 @@ import net.rsprox.protocol.session.AttributeMap
 import net.rsprox.protocol.session.Session
 import net.rsprox.proxy.binary.BinaryBlob
 import net.rsprox.proxy.binary.BinaryStream
-import net.rsprox.proxy.binary.StreamDirection
+import net.rsprox.shared.StreamDirection
 
 public class DecodingSession(
     private val blob: BinaryBlob,

diff --git a/proxy/src/main/kotlin/net/rsprox/proxy/plugin/DirectionalPacket.kt b/proxy/src/main/kotlin/net/rsprox/proxy/plugin/DirectionalPacket.kt
@@ -2,7 +2,7 @@ package net.rsprox.proxy.plugin
 
 import net.rsprot.protocol.Prot
 import net.rsprot.protocol.message.IncomingMessage
-import net.rsprox.proxy.binary.StreamDirection
+import net.rsprox.shared.StreamDirection
 
 public data class DirectionalPacket(
     public val direction: StreamDirection,

diff --git a/proxy/src/main/kotlin/net/rsprox/proxy/server/ServerGameHandler.kt b/proxy/src/main/kotlin/net/rsprox/proxy/server/ServerGameHandler.kt
@@ -20,11 +20,11 @@ import net.rsprot.protocol.util.CombinedId
 import net.rsprot.protocol.util.gCombinedId
 import net.rsprox.protocol.game.outgoing.decoder.prot.GameServerProt
 import net.rsprox.proxy.attributes.INCOMING_BANK_PIN
-import net.rsprox.proxy.binary.StreamDirection
 import net.rsprox.proxy.channel.getBinaryBlob
 import net.rsprox.proxy.channel.getServerToClientStreamCipher
 import net.rsprox.proxy.huffman.HuffmanProvider
 import net.rsprox.proxy.worlds.WorldListProvider
+import net.rsprox.shared.StreamDirection
 
 public class ServerGameHandler(
     private val clientChannel: Channel,

diff --git a/proxy/src/main/kotlin/net/rsprox/proxy/transcriber/LiveTranscriberSession.kt b/proxy/src/main/kotlin/net/rsprox/proxy/transcriber/LiveTranscriberSession.kt
@@ -5,8 +5,8 @@ import io.netty.buffer.ByteBuf
 import net.rsprot.buffer.extensions.toByteArray
 import net.rsprox.protocol.exceptions.DecodeError
 import net.rsprox.protocol.session.Session
-import net.rsprox.proxy.binary.StreamDirection
 import net.rsprox.proxy.plugin.DecodingSession
+import net.rsprox.shared.StreamDirection
 import net.rsprox.transcriber.TranscriberRunner
 import java.util.Queue
 import java.util.concurrent.ConcurrentLinkedQueue

diff --git a/...et/rsprox/proxy/binary/StreamDirection.kt → ...tlin/net/rsprox/shared/StreamDirection.kt b/...et/rsprox/proxy/binary/StreamDirection.kt → ...tlin/net/rsprox/shared/StreamDirection.kt
@@ -1,4 +1,4 @@
-package net.rsprox.proxy.binary
+package net.rsprox.shared
 
 public enum class StreamDirection {
     CLIENT_TO_SERVER,