diff options
author | Dico <dico.karssiens@gmail.com> | 2018-08-02 18:22:36 +0100 |
---|---|---|
committer | Dico <dico.karssiens@gmail.com> | 2018-08-02 18:22:36 +0100 |
commit | 0af2e615d3fa1d8509be46e14f99d40dc9cdb342 (patch) | |
tree | 3864043218969a67b5df17784a05c6af424e3617 /src/main/kotlin/io/dico/parcels2/storage/exposed/ListTables.kt | |
parent | 6513ad9237dbda0244a52608ae639fee5822b3ee (diff) |
Refactor and improve a lot of the API. Move default implementations into a package. Reformatting.
Diffstat (limited to 'src/main/kotlin/io/dico/parcels2/storage/exposed/ListTables.kt')
-rw-r--r-- | src/main/kotlin/io/dico/parcels2/storage/exposed/ListTables.kt | 15 |
1 files changed, 7 insertions, 8 deletions
diff --git a/src/main/kotlin/io/dico/parcels2/storage/exposed/ListTables.kt b/src/main/kotlin/io/dico/parcels2/storage/exposed/ListTables.kt index 3e1438a..20b36b1 100644 --- a/src/main/kotlin/io/dico/parcels2/storage/exposed/ListTables.kt +++ b/src/main/kotlin/io/dico/parcels2/storage/exposed/ListTables.kt @@ -3,17 +3,16 @@ package io.dico.parcels2.storage.exposed import io.dico.parcels2.AddedStatus -import io.dico.parcels2.Parcel +import io.dico.parcels2.ParcelId import io.dico.parcels2.ParcelOwner -import io.dico.parcels2.storage.SerializableParcel import io.dico.parcels2.util.toByteArray import io.dico.parcels2.util.toUUID import kotlinx.coroutines.experimental.channels.SendChannel import org.jetbrains.exposed.sql.* -import java.util.* +import java.util.UUID -object AddedLocalT : AddedTable<Parcel, SerializableParcel>("parcels_added_local", ParcelsT) -object AddedGlobalT : AddedTable<ParcelOwner, ParcelOwner>("parcels_added_global", OwnersT) +object AddedLocalT : AddedTable<ParcelId>("parcels_added_local", ParcelsT) +object AddedGlobalT : AddedTable<ParcelOwner>("parcels_added_global", OwnersT) object ParcelOptionsT : Table("parcel_options") { val parcel_id = integer("parcel_id").primaryKey().references(ParcelsT.id, ReferenceOption.CASCADE) @@ -23,7 +22,7 @@ object ParcelOptionsT : Table("parcel_options") { typealias AddedStatusSendChannel<AttachT> = SendChannel<Pair<AttachT, MutableMap<UUID, AddedStatus>>> -sealed class AddedTable<AttachT, SerializableT>(name: String, val idTable: IdTransactionsTable<*, AttachT, SerializableT>) : Table(name) { +sealed class AddedTable<AttachT>(name: String, val idTable: IdTransactionsTable<*, AttachT>) : Table(name) { val attach_id = integer("attach_id").references(idTable.id, ReferenceOption.CASCADE) val player_uuid = binary("player_uuid", 16) val allowed_flag = bool("allowed_flag") @@ -52,7 +51,7 @@ sealed class AddedTable<AttachT, SerializableT>(name: String, val idTable: IdTra .associateByTo(hashMapOf(), { it[player_uuid].toUUID() }, { it[allowed_flag].asAddedStatus() }) } - suspend fun sendAllAddedData(channel: AddedStatusSendChannel<SerializableT>) { + suspend fun sendAllAddedData(channel: AddedStatusSendChannel<AttachT>) { /* val iterator = selectAll().orderBy(attach_id).iterator() @@ -63,7 +62,7 @@ sealed class AddedTable<AttachT, SerializableT>(name: String, val idTable: IdTra var map: MutableMap<UUID, AddedStatus>? = null fun initAttachAndMap() { - attach = idTable.getSerializable(id) + attach = idTable.getId(id) map = attach?.let { mutableMapOf() } } |