-
Notifications
You must be signed in to change notification settings - Fork 71
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
5 changed files
with
272 additions
and
3 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
201 changes: 201 additions & 0 deletions
201
multiplatform-settings/src/linuxX64Main/kotlin/com/russhwolf/settings/DConfSettings.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,201 @@ | ||
| /* | ||
| * Copyright 2022 Russell Wolf | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| */ | ||
|
|
||
| package com.russhwolf.settings | ||
|
|
||
| import com.russhwolf.settings.cinterop.dconf.DConfClient | ||
| import com.russhwolf.settings.cinterop.dconf.FALSE | ||
| import com.russhwolf.settings.cinterop.dconf.GError | ||
| import com.russhwolf.settings.cinterop.dconf.GVariant | ||
| import com.russhwolf.settings.cinterop.dconf.dconf_client_list | ||
| import com.russhwolf.settings.cinterop.dconf.dconf_client_new | ||
| import com.russhwolf.settings.cinterop.dconf.dconf_client_read | ||
| import com.russhwolf.settings.cinterop.dconf.dconf_client_sync | ||
| import com.russhwolf.settings.cinterop.dconf.dconf_client_write_sync | ||
| import com.russhwolf.settings.cinterop.dconf.dconf_is_rel_key | ||
| import com.russhwolf.settings.cinterop.dconf.g_object_ref | ||
| import com.russhwolf.settings.cinterop.dconf.g_object_unref | ||
| import com.russhwolf.settings.cinterop.dconf.g_variant_get_boolean | ||
| import com.russhwolf.settings.cinterop.dconf.g_variant_get_double | ||
| import com.russhwolf.settings.cinterop.dconf.g_variant_get_int32 | ||
| import com.russhwolf.settings.cinterop.dconf.g_variant_get_int64 | ||
| import com.russhwolf.settings.cinterop.dconf.g_variant_get_string | ||
| import com.russhwolf.settings.cinterop.dconf.g_variant_new_boolean | ||
| import com.russhwolf.settings.cinterop.dconf.g_variant_new_double | ||
| import com.russhwolf.settings.cinterop.dconf.g_variant_new_int32 | ||
| import com.russhwolf.settings.cinterop.dconf.g_variant_new_int64 | ||
| import com.russhwolf.settings.cinterop.dconf.g_variant_new_string | ||
| import kotlinx.cinterop.CPointer | ||
| import kotlinx.cinterop.ExperimentalForeignApi | ||
| import kotlinx.cinterop.MemScope | ||
| import kotlinx.cinterop.allocPointerTo | ||
| import kotlinx.cinterop.get | ||
| import kotlinx.cinterop.memScoped | ||
| import kotlinx.cinterop.pointed | ||
| import kotlinx.cinterop.ptr | ||
| import kotlinx.cinterop.reinterpret | ||
| import kotlinx.cinterop.toKString | ||
| import platform.posix.NULL | ||
|
|
||
|
|
||
| @OptIn(ExperimentalForeignApi::class) | ||
| @ExperimentalSettingsImplementation | ||
| public class DConfSettings(private val dir: String) : Settings { | ||
| // TODO sanitize slashes on `dir` | ||
| public class Factory(private val rootDir: String) : Settings.Factory { | ||
| // TODO sanitize slashes on `rootDir` and `name` | ||
| override fun create(name: String?): Settings { | ||
| val dir = if (name != null) "/$rootDir/$name/" else "/$rootDir/" | ||
| return DConfSettings(dir) | ||
| } | ||
| } | ||
|
|
||
| override val keys: Set<String> | ||
| get() = dConfOperation { dConfClient -> | ||
| buildSet { dConfClient?.forEachKey { add(it) } } | ||
| } | ||
|
|
||
| override val size: Int | ||
| get() = dConfOperation { dConfClient -> | ||
| dConfClient?.foldKeys(0) { size, _ -> size + 1 } ?: 0 | ||
| } | ||
|
|
||
| override fun clear(): Unit = dConfOperation { dConfClient -> | ||
| // TODO can we do this without repeating remove internals? (nested dConfOperation causes problems) | ||
| dConfClient?.forEachKey { | ||
| val error = allocPointerTo<GError>() | ||
| val out = dconf_client_write_sync(dConfClient, "$dir$it", NULL?.reinterpret(), null, null, error.ptr) | ||
| if (out == FALSE) { | ||
| checkError(error.pointed) | ||
| } | ||
| } | ||
| } | ||
|
|
||
| override fun remove(key: String) { | ||
| removeGVariant(key) | ||
| } | ||
|
|
||
| override fun hasKey(key: String): Boolean = dConfOperation { dConfClient -> | ||
| dConfClient?.forEachKey { if (it == key) return@dConfOperation true } | ||
| false | ||
| } | ||
|
|
||
| override fun putInt(key: String, value: Int) { | ||
| writeGVariant(key, value) | ||
| } | ||
|
|
||
| override fun getInt(key: String, defaultValue: Int): Int = getIntOrNull(key) ?: defaultValue | ||
| override fun getIntOrNull(key: String): Int? = readGVariant(key)?.let { g_variant_get_int32(it) } | ||
|
|
||
|
|
||
| override fun putLong(key: String, value: Long) { | ||
| writeGVariant(key, value) | ||
| } | ||
|
|
||
| override fun getLong(key: String, defaultValue: Long): Long = getLongOrNull(key) ?: defaultValue | ||
| override fun getLongOrNull(key: String): Long? = readGVariant(key)?.let { g_variant_get_int64(it) } | ||
|
|
||
| override fun putString(key: String, value: String) { | ||
| writeGVariant(key, value) | ||
| } | ||
|
|
||
| override fun getString(key: String, defaultValue: String): String = getStringOrNull(key) ?: defaultValue | ||
| override fun getStringOrNull(key: String): String? = | ||
| readGVariant(key)?.let { g_variant_get_string(it, null)?.toKString() } | ||
|
|
||
| override fun putFloat(key: String, value: Float) { | ||
| writeGVariant(key, value) | ||
| } | ||
|
|
||
| override fun getFloat(key: String, defaultValue: Float): Float = getFloatOrNull(key) ?: defaultValue | ||
| override fun getFloatOrNull(key: String): Float? = readGVariant(key)?.let { g_variant_get_double(it).toFloat() } | ||
|
|
||
| override fun putDouble(key: String, value: Double) { | ||
| writeGVariant(key, value) | ||
| } | ||
|
|
||
| override fun getDouble(key: String, defaultValue: Double): Double = getDoubleOrNull(key) ?: defaultValue | ||
| override fun getDoubleOrNull(key: String): Double? = readGVariant(key)?.let { g_variant_get_double(it) } | ||
|
|
||
| override fun putBoolean(key: String, value: Boolean) { | ||
| writeGVariant(key, value) | ||
| } | ||
|
|
||
| override fun getBoolean(key: String, defaultValue: Boolean): Boolean = getBooleanOrNull(key) ?: defaultValue | ||
| override fun getBooleanOrNull(key: String): Boolean? = readGVariant(key)?.let { g_variant_get_boolean(it) == 1 } | ||
|
|
||
| private inline fun CPointer<DConfClient>.forEachKey(block: (key: String) -> Unit) { | ||
| val list = dconf_client_list(this, dir, null) ?: return | ||
|
|
||
| var index = 0 | ||
| var item = list[index] | ||
| while (item != null) { | ||
| val key = item.toKString() | ||
| if (dconf_is_rel_key(key, null) != 0) { | ||
| block(key) | ||
| } | ||
|
|
||
| item = list[++index] | ||
| } | ||
| } | ||
|
|
||
| private inline fun <A> CPointer<DConfClient>.foldKeys(initial: A, block: (accumulator: A, key: String) -> A): A { | ||
| var accumulator = initial | ||
| forEachKey { accumulator = block(accumulator, it) } | ||
| return accumulator | ||
| } | ||
|
|
||
| private inline fun readGVariant(key: String): CPointer<GVariant>? = dConfOperation { dConfClient -> | ||
| dconf_client_read(dConfClient, "$dir$key") | ||
| } | ||
|
|
||
| private inline fun <reified T> writeGVariant(key: String, value: T) = dConfOperation { dConfClient -> | ||
| val gVariant = gVariantOf(value) | ||
| val error = allocPointerTo<GError>() | ||
| val out = dconf_client_write_sync(dConfClient, "$dir$key", gVariant, null, null, error.ptr) | ||
| if (out == FALSE) { | ||
| checkError(error.pointed) | ||
| } | ||
| } | ||
|
|
||
| private inline fun removeGVariant(key: String) = writeGVariant<Unit?>(key, null) | ||
|
|
||
| private inline fun <reified T> gVariantOf(value: T): CPointer<GVariant>? { | ||
| return when (value) { | ||
| null -> NULL?.reinterpret() | ||
| is Int -> g_variant_new_int32(value) | ||
| is Long -> g_variant_new_int64(value) | ||
| is String -> g_variant_new_string(value) | ||
| is Float -> g_variant_new_double(value.toDouble()) | ||
| is Double -> g_variant_new_double(value) | ||
| is Boolean -> g_variant_new_boolean(if (value) 1 else 0) | ||
| else -> error("Invalid value type for gVariant! value=$value") | ||
| } | ||
| } | ||
|
|
||
| private inline fun <T> dConfOperation(action: MemScope.(dConfClient: CPointer<DConfClient>?) -> T): T = memScoped { | ||
| val dConfClient = dconf_client_new() | ||
| g_object_ref(dConfClient) | ||
| val out = action(dConfClient) | ||
| dconf_client_sync(dConfClient) | ||
| g_object_unref(dConfClient) | ||
| out | ||
| } | ||
|
|
||
| private fun checkError(error: GError?) { | ||
| // TODO process error val | ||
| } | ||
| } |
28 changes: 28 additions & 0 deletions
28
multiplatform-settings/src/linuxX64Test/kotlin/com/russhwolf/settings/DConfSettingsTest.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,28 @@ | ||
| /* | ||
| * Copyright 2022 Russell Wolf | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| */ | ||
|
|
||
| package com.russhwolf.settings | ||
|
|
||
| @OptIn(ExperimentalSettingsImplementation::class) | ||
| public class DConfSettingsTest : BaseSettingsTest( | ||
| platformFactory = DConfSettings.Factory("com/russhwolf/settings/test"), | ||
| hasListeners = false | ||
| ) { | ||
|
|
||
| // TODO add test cases to verify that we write to the files we think we do | ||
|
|
||
| // TODO add cleanup methods so we don't leave test DBs lying around | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,4 @@ | ||
| headers = dconf.h | ||
| package = com.russhwolf.settings.cinterop.dconf | ||
| compilerOpts = -I/usr/include/dconf -I/usr/include/glib-2.0 -I/usr/lib/x86_64-linux-gnu/glib-2.0/include | ||
| linkerOpts = -ldconf -lglib-2.0 -lgobject-2.0 -L/usr/lib -L/usr/lib/x86_64-linux-gnu/ |