Merge pull request #14 from runetopic/development

Development

Author: ultraviolet-jordan

README.md

@@ -29,8 +29,8 @@ A cache library written in Kotlin.
 # Implementation
 Just use cache if you do not require any of the revision specific loaders.
 ```
-cache = { module = "com.runetopic.cache:cache", version.ref "1.4.6-SNAPSHOT" }
-loader = { module = "com.runetopic.cache:loader", version.ref "647.6.0-SNAPSHOT" }
+cache = { module = "com.runetopic.cache:cache", version.ref "1.4.7-SNAPSHOT" }
+loader = { module = "com.runetopic.cache:loader", version.ref "647.6.1-SNAPSHOT" }
 
 //For the SNAPSHOTS
 maven {
@@ -41,9 +41,9 @@ maven {
 # Usage
 Index -> Group -> File
 
-### Creating a new store
+### Creating a new JS5 store
 ```
-val store = Store(File("/filepath/"))
+val store = Js5Store(Path.of("/path/"))
 ```
 
 ### Getting an index
@@ -101,6 +101,13 @@ val file = group.getFile(fileId = 1000)
 ### Getting 255, 255 checksums without RSA/Whirlpool
 ```val checksums = store.checksumsWithoutRSA()```
 
+### Decompressing a group
+```
+val index = store.index(indexId = 5)
+val group = index.getGroup(groupName = "m50_50")
+val decompressed = group.getData().decompress()
+```
+
 ### An example of a single thread loading providers
 ```
 objs().load(store)

cache/build.gradle.kts

@@ -4,7 +4,7 @@ plugins {
     signing
 }
 
-version = "1.4.6-SNAPSHOT"
+version = "1.4.7-SNAPSHOT"
 
 java {
     withJavadocJar()

cache/src/main/kotlin/com/runetopic/cache/codec/CodecType.kt

@@ -0,0 +1,20 @@
+package com.runetopic.cache.codec
+
+import com.runetopic.cache.codec.impl.BZip2Codec
+import com.runetopic.cache.codec.impl.GZipCodec
+import com.runetopic.cache.codec.impl.NoFileCodec
+
+/**
+ * @author Tyler Telis
+ * @email <[email protected]>
+ *
+ * @author Jordan Abraham
+ */
+internal sealed class CodecType(
+    val codec: IFileCodec
+) {
+    object BadCodec: CodecType(NoFileCodec())
+    object NoCodec: CodecType(NoFileCodec())
+    object BZipCodec: CodecType(BZip2Codec())
+    object GZipCodec: CodecType(GZipCodec())
+}

cache/src/main/kotlin/com/runetopic/cache/compression/Container.kt renamed to cache/src/main/kotlin/com/runetopic/cache/codec/Container.kt

@@ -1,10 +1,10 @@
-package com.runetopic.cache.compression
+package com.runetopic.cache.codec
 
 /**
  * @author Tyler Telis
  * @email <[email protected]>
  */
-data class Container(
+internal data class Container(
     val data: ByteArray,
     val compression: Int,
     val revision: Int,

cache/src/main/kotlin/com/runetopic/cache/compression/Compression.kt renamed to cache/src/main/kotlin/com/runetopic/cache/codec/ContainerCodec.kt

@@ -1,6 +1,6 @@
-package com.runetopic.cache.compression
+package com.runetopic.cache.codec
 
-import com.runetopic.cache.compression.CompressionType.*
+import com.runetopic.cache.codec.CodecType.*
 import com.runetopic.cache.exception.CompressionException
 import com.runetopic.cache.extension.readUnsignedShort
 import com.runetopic.cache.extension.remainingBytes
@@ -14,9 +14,9 @@ import java.util.zip.CRC32
  *
  * @author Jordan Abraham
  */
-object Compression {
+internal object ContainerCodec {
 
-    fun decompress(data: ByteArray, keys: Array<Int>): Container {
+    fun decompress(data: ByteArray, keys: IntArray = intArrayOf()): Container {
         val buffer = ByteBuffer.wrap(data)
 
         val compression = buffer.get().toInt() and 0xFF
@@ -30,22 +30,22 @@ object Compression {
         crc32.update(data, 0, 5)
 
         return when (val type = compressionType(compression)) {
-            BadCompression -> throw CompressionException("Compression type not found with a compression opcode of $compression.")
-            is NoCompression -> {
+            BadCodec -> throw CompressionException("Compression type not found with a compression opcode of $compression.")
+            is NoCodec -> {
                 val encrypted = ByteArray(length)
                 buffer.get(encrypted, 0, length)
                 crc32.update(encrypted, 0, length)
-                val decrypted = if (keys.isEmpty()) encrypted else encrypted.fromXTEA(32, keys.toIntArray())
+                val decrypted = if (keys.isEmpty()) encrypted else encrypted.fromXTEA(32, keys)
 
                 val revision = -1 /*buffer.short.toInt() and 0xFFFF*/
 
                 Container(decrypted, compression, revision, crc32.value.toInt())
             }
-            GZipCompression, BZipCompression-> {
+            GZipCodec, BZipCodec-> {
                 val encrypted = ByteArray(length + 4)
                 buffer.get(encrypted)
                 crc32.update(encrypted, 0, encrypted.size)
-                val decrypted = if (keys.isEmpty()) encrypted else encrypted.fromXTEA(32, keys.toIntArray())
+                val decrypted = if (keys.isEmpty()) encrypted else encrypted.fromXTEA(32, keys)
 
                 var revision = -1
 
@@ -66,12 +66,12 @@ object Compression {
         }
     }
 
-    private fun compressionType(compression: Int): CompressionType {
+    private fun compressionType(compression: Int): CodecType {
         return when (compression) {
-            0 -> NoCompression
-            1 -> BZipCompression
-            2 -> GZipCompression
-            else -> BadCompression
+            0 -> NoCodec
+            1 -> BZipCodec
+            2 -> GZipCodec
+            else -> BadCodec
         }
     }
 }

cache/src/main/kotlin/com/runetopic/cache/codec/Decompression.kt

@@ -0,0 +1,13 @@
+@file:JvmName("Decompression")
+package com.runetopic.cache.codec
+
+/**
+ * @author Jordan Abraham
+ */
+fun ByteArray.decompress(keys: IntArray = intArrayOf()): ByteArray {
+    return ContainerCodec.decompress(this, keys).data
+}
+
+fun ByteArray.decompress(): ByteArray {
+    return ContainerCodec.decompress(this, intArrayOf()).data
+}

cache/src/main/kotlin/com/runetopic/cache/codec/IFileCodec.kt

@@ -0,0 +1,10 @@
+package com.runetopic.cache.codec
+
+/**
+ * @author Tyler Telis
+ * @email <[email protected]>
+ */
+internal interface IFileCodec {
+    fun compress(data: ByteArray, length: Int, keys: IntArray): ByteArray
+    fun decompress(data: ByteArray, length: Int, keys: IntArray): ByteArray
+}

cache/src/main/kotlin/com/runetopic/cache/compression/impl/BZip2Codec.kt renamed to cache/src/main/kotlin/com/runetopic/cache/codec/impl/BZip2Codec.kt

@@ -1,6 +1,6 @@
-package com.runetopic.cache.compression.impl
+package com.runetopic.cache.codec.impl
 
-import com.runetopic.cache.compression.IFileCodec
+import com.runetopic.cache.codec.IFileCodec
 import com.runetopic.cache.store.Constants.BZIP_HEADER
 import org.apache.commons.compress.compressors.bzip2.BZip2CompressorInputStream
 import org.apache.commons.compress.compressors.bzip2.BZip2CompressorOutputStream
@@ -15,7 +15,7 @@ import java.util.*
  * @email <[email protected]>
  */
 internal class BZip2Codec: IFileCodec {
-    override fun compress(data: ByteArray, length: Int, keys: Array<Int>): ByteArray {
+    override fun compress(data: ByteArray, length: Int, keys: IntArray): ByteArray {
         val stream: InputStream = ByteArrayInputStream(data)
         val bout = ByteArrayOutputStream()
         BZip2CompressorOutputStream(bout, 1).use { os -> IOUtils.copy(stream, os) }
@@ -30,7 +30,7 @@ internal class BZip2Codec: IFileCodec {
         return Arrays.copyOfRange(buffer, BZIP_HEADER.size, buffer.size)
     }
 
-    override fun decompress(data: ByteArray, length: Int, keys: Array<Int>): ByteArray {
+    override fun decompress(data: ByteArray, length: Int, keys: IntArray): ByteArray {
         val buffer = ByteArray(length + BZIP_HEADER.size)
 
         System.arraycopy(BZIP_HEADER, 0, buffer,0, BZIP_HEADER.size)

cache/src/main/kotlin/com/runetopic/cache/compression/impl/GZipCodec.kt renamed to cache/src/main/kotlin/com/runetopic/cache/codec/impl/GZipCodec.kt

@@ -1,6 +1,6 @@
-package com.runetopic.cache.compression.impl
+package com.runetopic.cache.codec.impl
 
-import com.runetopic.cache.compression.IFileCodec
+import com.runetopic.cache.codec.IFileCodec
 import org.apache.commons.compress.utils.IOUtils
 import java.io.ByteArrayInputStream
 import java.io.ByteArrayOutputStream
@@ -12,14 +12,14 @@ import java.util.zip.GZIPOutputStream
  * @email <[email protected]>
  */
 internal class GZipCodec: IFileCodec {
-    override fun compress(data: ByteArray, length: Int, keys: Array<Int>): ByteArray {
+    override fun compress(data: ByteArray, length: Int, keys: IntArray): ByteArray {
         val inputStream = ByteArrayInputStream(data)
         val outputStream = ByteArrayOutputStream()
         GZIPOutputStream(outputStream).use { os -> IOUtils.copy(inputStream, os) }
         return outputStream.toByteArray()
     }
 
-    override fun decompress(data: ByteArray, length: Int, keys: Array<Int>): ByteArray {
+    override fun decompress(data: ByteArray, length: Int, keys: IntArray): ByteArray {
         val outputStream = ByteArrayOutputStream()
         GZIPInputStream(ByteArrayInputStream(data, 0, length)).use {
             IOUtils.copy(it, outputStream)

cache/src/main/kotlin/com/runetopic/cache/compression/impl/NoFileCodec.kt renamed to cache/src/main/kotlin/com/runetopic/cache/codec/impl/NoFileCodec.kt

@@ -1,17 +1,17 @@
-package com.runetopic.cache.compression.impl
+package com.runetopic.cache.codec.impl
 
-import com.runetopic.cache.compression.IFileCodec
+import com.runetopic.cache.codec.IFileCodec
 
 /**
  * @author Tyler Telis
  * @email <[email protected]>
  */
 internal class NoFileCodec: IFileCodec {
-    override fun compress(data: ByteArray, length: Int, keys: Array<Int>): ByteArray {
+    override fun compress(data: ByteArray, length: Int, keys: IntArray): ByteArray {
         throw NotImplementedError("No codec provided.")
     }
 
-    override fun decompress(data: ByteArray, length: Int, keys: Array<Int>): ByteArray {
+    override fun decompress(data: ByteArray, length: Int, keys: IntArray): ByteArray {
         throw NotImplementedError("No codec provided.")
     }
 }