Generated with Hive: Create concept-network-query-hive and feature-network-query-hive modules for Hive authentication

settings.gradle

@@ -97,6 +97,8 @@ include ':sphinx:application:network:concepts:queries:concept-network-query-cryp
 include ':sphinx:application:network:features:queries:feature-network-query-crypter'
 include ':sphinx:application:network:concepts:queries:concept-network-query-discover-tribes'
 include ':sphinx:application:network:features:queries:feature-network-query-discover-tribes'
+include ':sphinx:application:network:concepts:queries:concept-network-query-hive'
+include ':sphinx:application:network:features:queries:feature-network-query-hive'
 include ':sphinx:application:network:concepts:queries:concept-network-query-feed-status'
 include ':sphinx:application:network:features:queries:feature-network-query-feed-status'
 

sphinx/application/network/concepts/queries/concept-network-query-hive/build.gradle

@@ -0,0 +1,16 @@
+plugins {
+    id 'java-library'
+    id 'kotlin'
+    id 'kotlin-kapt'
+}
+
+dependencies {
+    api project(path: ':sphinx:application:common:kotlin-response')
+
+    implementation deps.kotlin.coroutinesCore
+
+    // needed to override moshi's use of 1.4.31
+    implementation deps.kotlin.reflect
+    implementation deps.square.moshi
+    kapt kaptDeps.square.moshiCodegen
+}

sphinx/application/network/concepts/queries/concept-network-query-hive/src/main/java/chat/sphinx/concept_network_query_hive/NetworkQueryHive.kt

@@ -0,0 +1,14 @@
+package chat.sphinx.concept_network_query_hive
+
+import chat.sphinx.concept_network_query_hive.model.HiveAuthenticationTokenDto
+import chat.sphinx.kotlin_response.LoadResponse
+import chat.sphinx.kotlin_response.ResponseError
+import kotlinx.coroutines.flow.Flow
+
+abstract class NetworkQueryHive {
+    abstract fun postHiveAuthentication(
+        token: String,
+        pubkey: String,
+        timestamp: String,
+    ): Flow<LoadResponse<HiveAuthenticationTokenDto, ResponseError>>
+}

sphinx/application/network/concepts/queries/concept-network-query-hive/src/main/java/chat/sphinx/concept_network_query_hive/model/HiveAuthenticationTokenDto.kt

@@ -0,0 +1,8 @@
+package chat.sphinx.concept_network_query_hive.model
+
+import com.squareup.moshi.JsonClass
+
+@JsonClass(generateAdapter = true)
+data class HiveAuthenticationTokenDto(val token: String) {
+    init { require(token.isNotBlank()) { "Hive token must not be blank" } }
+}

sphinx/application/network/features/queries/feature-network-query-hive/build.gradle

@@ -0,0 +1,18 @@
+plugins {
+    id 'app.cash.exhaustive'
+    id 'java-library'
+    id 'kotlin'
+    id 'kotlin-kapt'
+}
+
+dependencies {
+    api project(path: ':sphinx:application:network:concepts:queries:concept-network-query-hive')
+    api project(path: ':sphinx:application:network:concepts:calls:concept-network-call')
+
+    implementation deps.kotlin.coroutinesCore
+
+    // needed to override moshi's use of 1.4.31
+    implementation deps.kotlin.reflect
+    implementation deps.square.moshi
+    kapt kaptDeps.square.moshiCodegen
+}

sphinx/application/network/features/queries/feature-network-query-hive/src/main/java/chat/sphinx/feature_network_query_hive/NetworkQueryHiveImpl.kt

@@ -0,0 +1,30 @@
+package chat.sphinx.feature_network_query_hive
+
+import chat.sphinx.concept_network_call.NetworkCall
+import chat.sphinx.concept_network_query_hive.NetworkQueryHive
+import chat.sphinx.concept_network_query_hive.model.HiveAuthenticationTokenDto
+import chat.sphinx.feature_network_query_hive.model.HiveAuthenticationRequestDto
+import chat.sphinx.kotlin_response.LoadResponse
+import chat.sphinx.kotlin_response.ResponseError
+import kotlinx.coroutines.flow.Flow
+
+class NetworkQueryHiveImpl(private val networkCall: NetworkCall) : NetworkQueryHive() {
+
+    companion object {
+        private const val HIVE_BASE_URL = "https://hive.sphinx.chat/api"
+        private const val ENDPOINT_HIVE_AUTH = "$HIVE_BASE_URL/auth/sphinx/token"
+    }
+
+    override fun postHiveAuthentication(
+        token: String,
+        pubkey: String,
+        timestamp: String,
+    ): Flow<LoadResponse<HiveAuthenticationTokenDto, ResponseError>> =
+        networkCall.post(
+            url = ENDPOINT_HIVE_AUTH,
+            responseJsonClass = HiveAuthenticationTokenDto::class.java,
+            requestBodyJsonClass = HiveAuthenticationRequestDto::class.java,
+            requestBody = HiveAuthenticationRequestDto(token, pubkey, timestamp),
+            headers = mapOf("Cache-Control" to "no-store, no-cache"),
+        )
+}

sphinx/application/network/features/queries/feature-network-query-hive/src/main/java/chat/sphinx/feature_network_query_hive/model/HiveAuthenticationRequestDto.kt

@@ -0,0 +1,10 @@
+package chat.sphinx.feature_network_query_hive.model
+
+import com.squareup.moshi.JsonClass
+
+@JsonClass(generateAdapter = true)
+data class HiveAuthenticationRequestDto(
+    val token: String,
+    val pubkey: String,
+    val timestamp: String,
+)