nick/amethyst
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

Normalizes logs for the DataSources

Browse Source
This commit is contained in:
Vitor Pamplona
2024-08-02 12:35:25 -04:00
parent 63e036a9bb
commit 7fdf38d17b
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
ammolite/src/main/java/com/vitorpamplona/ammolite/relays/NostrDataSource.kt
+6 -6
View File
@@ -138,13 +138,13 @@ abstract class NostrDataSource(
} }
init { init {
Log.d(this.javaClass.simpleName, "${this.javaClass.simpleName} Subscribe") Log.d("DataSource", "${this.javaClass.simpleName} Subscribe")
Client.subscribe(clientListener) Client.subscribe(clientListener)
} }
fun destroy() { fun destroy() {
// makes sure to run // makes sure to run
Log.d(this.javaClass.simpleName, "${this.javaClass.simpleName} Unsubscribe") Log.d("DataSource", "${this.javaClass.simpleName} Unsubscribe")
stop() stop()
Client.unsubscribe(clientListener) Client.unsubscribe(clientListener)
scope.cancel() scope.cancel()
@@ -152,7 +152,7 @@ abstract class NostrDataSource(
} }
open fun start() { open fun start() {
println("DataSource: ${this.javaClass.simpleName} Start") Log.d("DataSource", "${this.javaClass.simpleName} Start")
active = true active = true
resetFilters() resetFilters()
} }
@@ -160,7 +160,7 @@ abstract class NostrDataSource(
@OptIn(DelicateCoroutinesApi::class) @OptIn(DelicateCoroutinesApi::class)
open fun stop() { open fun stop() {
active = false active = false
println("DataSource: ${this.javaClass.simpleName} Stop") Log.d("DataSource", "${this.javaClass.simpleName} Stop")
GlobalScope.launch(Dispatchers.IO) { GlobalScope.launch(Dispatchers.IO) {
subscriptions.values.forEach { subscription -> subscriptions.values.forEach { subscription ->
@@ -172,7 +172,7 @@ abstract class NostrDataSource(
open fun stopSync() { open fun stopSync() {
active = false active = false
println("DataSource: ${this.javaClass.simpleName} Stop") Log.d("DataSource", "${this.javaClass.simpleName} Stop")
subscriptions.values.forEach { subscription -> subscriptions.values.forEach { subscription ->
Client.close(subscription.id) Client.close(subscription.id)
@@ -209,7 +209,7 @@ abstract class NostrDataSource(
} }
private fun resetFiltersSuspend() { private fun resetFiltersSuspend() {
println("DataSource: ${this.javaClass.simpleName} resetFiltersSuspend $active") Log.d("DataSource", "${this.javaClass.simpleName} resetFiltersSuspend $active")
checkNotInMainThread() checkNotInMainThread()
// saves the channels that are currently active // saves the channels that are currently active