gtk: fix attachment download race condition

* wip/local_ids:
  first attempt at trying to keep track of locally send id

.gitignore

@@ -1,17 +1 @@
-*.iml
+target/
-.gradle
-/local.properties
-/.idea/caches
-/.idea/libraries
-/.idea/modules.xml
-/.idea/workspace.xml
-/.idea/navEditor.xml
-/.idea/assetWizardSettings.xml
-.DS_Store
-/build
-/captures
-.externalNativeBuild
-.cxx
-local.properties
-
-.idea/

README.md

@@ -0,0 +1,66 @@
+# Kordophone Monorepo
+
+Kordophone is an iMessage bridge: a lightweight server runs on a Mac and exposes an HTTP API so non‑Apple devices can send/receive iMessages. A set of clients (Android, Linux GTK, macOS Cocoa) talk to that API. A shared Rust library powers most clients, and a mock server helps local testing.
+
+> Important: Interfacing with iMessage on macOS involves private APIs and restricted entitlements. See `server/README.md` for details and safety notes.
+
+## Repository Layout
+
+Top‑level projects in this monorepo:
+
+- `server/` — macOS daemon that bridges to iMessage and exposes an HTTP REST API. Written in Objective‑C/Cocoa. See `server/README.md`.
+- `core/` — Rust workspace with the shared Kordophone client library and related tooling. Used by `gtk/` and `osx/`.
+- `gtk/` — GTK4/Libadwaita Linux desktop client built on the Rust `core` library.
+- `osx/` — macOS Cocoa client that uses the Rust `core` library and talks to the local Kordophone client daemon via XPC.
+- `android/` — Android client. Currently implements its own API client (does not use the Rust library yet).
+- `mock/` — Go‑based mock server that emulates a Mac running the Kordophone server, for local development and tests.
+
+Quick links:
+
+- Server (mac daemon): `server/`
+- Core (Rust workspace): `core/`
+- GTK client (Linux): `gtk/`
+- macOS client (Cocoa): `osx/`
+- Android client: `android/`
+- Mock server (Go): `mock/`
+
+## How It Works
+
+1. The macOS Kordophone Server (`server/`) runs on a Mac with iMessage and exposes an HTTP/JSON API and a WebSocket/updates channel.
+2. Clients connect to that server to list conversations, fetch/send messages, upload/download attachments, and receive live updates.
+3. A Rust library in `core/kordophone` implements the wire protocol and client behaviors. Linux/macOS clients use this library directly; Android currently ships a native Kotlin client.
+4. The Rust client daemon (`core/kordophoned`) provides local caching and IPC (D‑Bus on Linux, XPC on macOS) for GUI apps.
+5. The `mock/` server simulates the server API for local development without a Mac.
+
+## Getting Started
+
+You can try the clients quickly against the mock server.
+
+1) Run the mock server (no auth):
+
+```bash
+cd mock
+go run ./...               # or: make; ./kordophone-mock
+```
+
+The mock server listens on `http://localhost:5738`.
+
+2) Point a client at the mock server:
+
+- Android: open Settings in the app and set the server host to `http://10.0.2.2:5738` (Android emulator) or `http://<your-host-ip>:5738` if running on device. Disable auth unless you started the mock with `--auth`.
+- GTK (Linux): build and run the GTK app from `gtk/` (see its README) and configure it to use the local daemon backed by the server URL.
+- macOS (Cocoa): build the app in `osx/` (see `osx/README.md`).
+
+To use a real Mac server instead, set your client’s server URL to the host running `server/` with the correct scheme/port and authentication.
+
+## Building
+
+Below are brief notes. Each subproject’s README has more detail.
+
+- Server (macOS): open `server/MessagesBridge.xcodeproj` in Xcode. See `server/README.md` for entitlements, SSL, and running.
+- Core (Rust): install Rust (stable) and run `cargo build` inside `core/`. See `core/README.md`.
+- GTK (Linux): see `gtk/README.md` for RPM build via `rpmbuild -ba dist/rpm/kordophone.spec`.
+- macOS (Cocoa): open `osx/kordophone2.xcodeproj` in Xcode. See `osx/README.md`.
+- Android: open `android/` in Android Studio and build. See `android/README.md` for configuration.
+- Mock server (Go): `cd mock && go run ./...` or `make`.
+

android/.gitignore

@@ -0,0 +1,17 @@
+*.iml
+.gradle
+/local.properties
+/.idea/caches
+/.idea/libraries
+/.idea/modules.xml
+/.idea/workspace.xml
+/.idea/navEditor.xml
+/.idea/assetWizardSettings.xml
+.DS_Store
+/build
+/captures
+.externalNativeBuild
+.cxx
+local.properties
+
+.idea/

android/README.md

@@ -0,0 +1,46 @@
+# Kordophone Android Client
+
+Android client for the Kordophone iMessage bridge. This app connects to a running Kordophone server over HTTP/JSON and streams updates.
+
+Note: This client currently implements its own API layer in Kotlin and does not yet use the shared Rust `core` library.
+
+## Build & Run
+
+Requirements:
+
+- Android Studio (AGP 8.x)
+- JDK 8+ toolchain (project uses Java 8 bytecode)
+
+Steps:
+
+1. Open `android/` in Android Studio.
+2. Sync Gradle and build the project.
+3. Run the `app` configuration on an emulator or device.
+
+The app targets `minSdk 30`, `targetSdk 33` and uses Jetpack Compose.
+
+## Configure Server
+
+Set the server host and optional Basic Auth from the app’s Settings screen.
+
+- Server URL for local mock (emulator): `http://10.0.2.2:5738`
+- Server URL for local mock (device): `http://<your-host-ip>:5738`
+- Credentials: match the server if auth is enabled (mock supports `--auth`).
+
+Settings are persisted using `EncryptedSharedPreferences`.
+
+## Modules
+
+- `app/` — UI (Compose), DI (Hilt), app wiring
+- `backend/` — Kotlin API client, DB/cache (Realm), models, tests
+
+## Testing with the Mock Server
+
+Start the mock server in the repo root:
+
+```bash
+cd mock
+go run ./...          # or: make; ./kordophone-mock
+```
+
+Set the app’s server URL to the mock address and run. The mock implements the Kordophone server API; see centralized API documentation (planned under `api/`).

android/app/src/main/AndroidManifest.xml

@@ -40,7 +40,10 @@
                 android:value="" />
         </activity>
 
-        <service android:name=".UpdateMonitorService" />
+        <service
+            android:name=".UpdateMonitorService"
+            android:foregroundServiceType="dataSync"
+            android:exported="false" />
     </application>
 
 </manifest>

android/app/src/main/java/net/buzzert/kordophonedroid/ui/attachments/AttachmentViewer.kt

@@ -1,6 +1,5 @@
 package net.buzzert.kordophonedroid.ui.attachments
 
-import androidx.compose.foundation.Indication
 import androidx.compose.foundation.clickable
 import androidx.compose.foundation.interaction.MutableInteractionSource
 import androidx.compose.foundation.layout.Box
@@ -8,16 +7,15 @@ import androidx.compose.foundation.layout.Column
 import androidx.compose.foundation.layout.Spacer
 import androidx.compose.foundation.layout.fillMaxWidth
 import androidx.compose.foundation.layout.padding
+import androidx.compose.material.CircularProgressIndicator
 import androidx.compose.material.Scaffold
-import androidx.compose.material.Text
 import androidx.compose.runtime.Composable
 import androidx.compose.runtime.mutableStateOf
 import androidx.compose.runtime.remember
 import androidx.compose.ui.Alignment
 import androidx.compose.ui.Modifier
 import androidx.compose.ui.platform.LocalContext
-import androidx.hilt.navigation.compose.hiltViewModel
+import coil.compose.SubcomposeAsyncImage
-import coil.compose.AsyncImage
 import coil.request.ImageRequest
 import net.buzzert.kordophonedroid.ui.LocalNavController
 import net.buzzert.kordophonedroid.ui.theme.KordophoneTopAppBar
@@ -41,12 +39,19 @@ fun AttachmentViewer(attachmentGuid: String) {
         Column(modifier = Modifier.padding(padding)) {
             Spacer(modifier = Modifier.weight(1f))
 
-            AsyncImage(
+            SubcomposeAsyncImage(
                 model = ImageRequest.Builder(LocalContext.current)
                     .data(data)
                     .crossfade(true)
                     .build(),
                 contentDescription = "",
+                loading = {
+                    Box {
+                        CircularProgressIndicator(
+                            modifier = Modifier.align(Alignment.Center)
+                        )
+                    }
+                },
                 modifier = Modifier
                     .zoomable(zoomState)
                     .fillMaxWidth()

android/app/src/main/res/drawable/ic_launcher_background.xml

@@ -0,0 +1,14 @@
+<?xml version="1.0" encoding="utf-8"?>
+
+<shape
+    xmlns:android="http://schemas.android.com/apk/res/android"
+    android:width="108dp"
+    android:height="108dp"
+    android:fillColor="@color/black"
+    >
+    <gradient
+        android:startColor="#000"
+        android:endColor="#333"
+        android:angle="1.0"
+    />
+</shape>

android/app/src/main/res/mipmap-anydpi-v26/ic_launcher.xml

@@ -1,5 +1,5 @@
 <?xml version="1.0" encoding="utf-8"?>
 <adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
-    <background android:drawable="@drawable/ic_launcher_background" />
+    <background android:drawable="@drawable/ic_launcher_background"/>
-    <foreground android:drawable="@drawable/ic_launcher_foreground" />
+    <foreground android:drawable="@mipmap/ic_launcher_foreground"/>
 </adaptive-icon>

android/app/src/main/res/mipmap-anydpi-v26/ic_launcher_round.xml

@@ -1,5 +1,5 @@
 <?xml version="1.0" encoding="utf-8"?>
 <adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
-    <background android:drawable="@drawable/ic_launcher_background" />
+    <background android:drawable="@drawable/ic_launcher_background"/>
-    <foreground android:drawable="@drawable/ic_launcher_foreground" />
+    <foreground android:drawable="@mipmap/ic_launcher_foreground"/>
 </adaptive-icon>

android/app/src/main/res/values/ic_launcher_background.xml

@@ -0,0 +1,4 @@
+<?xml version="1.0" encoding="utf-8"?>
+<resources>
+    <color name="ic_launcher_background">#3D3D3D</color>
+</resources>

android/backend/src/main/java/net/buzzert/kordophone/backend/db/CachedChatDatabase.kt

@@ -97,6 +97,7 @@ class CachedChatDatabase (private val realmConfig: RealmConfiguration) {
                     date = conversation.date
                     unreadCount = conversation.unreadCount
                     lastMessagePreview = conversation.lastMessagePreview
+                    lastMessageGUID = conversation.lastMessageGUID
                 }
             } catch (e: NoSuchElementException) {
                 // Conversation does not exist. Copy it to the realm.
@@ -121,6 +122,10 @@ class CachedChatDatabase (private val realmConfig: RealmConfiguration) {
     }
 
     fun writeMessages(messages: List<ModelMessage>, conversation: ModelConversation, outgoing: Boolean = false) {
+        if (messages.isEmpty()) {
+            return
+        }
+
         val dbConversation = getManagedConversationByGuid(conversation.guid)
         realm.writeBlocking {
             messages
@@ -128,8 +133,17 @@ class CachedChatDatabase (private val realmConfig: RealmConfiguration) {
                 .map { copyToRealm(it, updatePolicy = UpdatePolicy.ALL) }
 
             findLatest(dbConversation)?.let {
-                it.lastMessagePreview = messages.last().displayText
+                val lastMessage = messages.maxByOrNull { it.date }!!
-                it.date = messages.last().date.toInstant().toRealmInstant()
+
+                val lastMessageDate = lastMessage.date.toInstant().toRealmInstant()
+                if (lastMessageDate > it.date) {
+                    it.lastMessageGUID = lastMessage.guid
+                    it.lastMessagePreview = lastMessage.displayText
+
+                    // This will cause sort order to change. I think this ends
+                    // up getting updated whenever we get conversation changes anyway.
+                    // it.date = lastMessageDate
+                }
             }
         }
     }

android/backend/src/main/java/net/buzzert/kordophone/backend/db/model/Conversation.kt

@@ -1,17 +1,13 @@
 package net.buzzert.kordophone.backend.db.model
 
-import io.realm.kotlin.Realm
 import io.realm.kotlin.ext.realmListOf
-import io.realm.kotlin.ext.realmSetOf
 import io.realm.kotlin.ext.toRealmList
 import io.realm.kotlin.types.RealmInstant
 import io.realm.kotlin.types.RealmList
 import io.realm.kotlin.types.RealmObject
-import io.realm.kotlin.types.RealmSet
 import io.realm.kotlin.types.annotations.PrimaryKey
 import net.buzzert.kordophone.backend.model.GUID
 import org.mongodb.kbson.ObjectId
-import java.time.Instant
 import net.buzzert.kordophone.backend.model.Conversation as ModelConversation
 import java.util.Date
 
@@ -24,6 +20,7 @@ open class Conversation(
     var date: RealmInstant,
     var unreadCount: Int,
 
+    var lastMessageGUID: String?,
     var lastMessagePreview: String?,
 ): RealmObject
 {
@@ -35,10 +32,11 @@ open class Conversation(
         date = RealmInstant.now(),
         unreadCount = 0,
         lastMessagePreview = null,
+        lastMessageGUID = null,
     )
 
     fun toConversation(): ModelConversation {
-        val conversation = ModelConversation(
+        return ModelConversation(
             displayName = displayName,
             participants = participants.toList(),
             date = Date.from(date.toInstant()),
@@ -46,9 +44,8 @@ open class Conversation(
             guid = guid,
             lastMessagePreview = lastMessagePreview,
             lastMessage = null,
+            lastFetchedMessageGUID = lastMessageGUID
         )
-
-        return conversation
     }
 
     override fun equals(other: Any?): Boolean {
@@ -57,6 +54,10 @@ open class Conversation(
         val o = other as Conversation
         return guid == o.guid
     }
+
+    override fun hashCode(): Int {
+        return guid.hashCode()
+    }
 }
 
 fun ModelConversation.toDatabaseConversation(): Conversation {
@@ -67,6 +68,7 @@ fun ModelConversation.toDatabaseConversation(): Conversation {
         date = from.date.toInstant().toRealmInstant()
         unreadCount = from.unreadCount
         lastMessagePreview = from.lastMessagePreview
+        lastMessageGUID = from.lastFetchedMessageGUID
         guid = from.guid
     }
 }

android/backend/src/main/java/net/buzzert/kordophone/backend/model/Conversation.kt

@@ -27,6 +27,8 @@ data class Conversation(
 
     @SerializedName("lastMessage")
     var lastMessage: Message?,
+
+    var lastFetchedMessageGUID: String?,
 ) {
     companion object {
         fun generate(): Conversation {
@@ -38,6 +40,7 @@ data class Conversation(
                 unreadCount =  0,
                 lastMessagePreview = null,
                 lastMessage = null,
+                lastFetchedMessageGUID = null,
             )
         }
     }
@@ -59,7 +62,7 @@ data class Conversation(
             participants == o.participants &&
             displayName == o.displayName &&
             unreadCount == o.unreadCount &&
-            lastMessagePreview == o.lastMessagePreview
+            lastFetchedMessageGUID == o.lastFetchedMessageGUID
         )
     }
 
@@ -69,8 +72,8 @@ data class Conversation(
         result = 31 * result + participants.hashCode()
         result = 31 * result + (displayName?.hashCode() ?: 0)
         result = 31 * result + unreadCount
-        result = 31 * result + (lastMessagePreview?.hashCode() ?: 0)
         result = 31 * result + (lastMessage?.hashCode() ?: 0)
+        result = 31 * result + (lastFetchedMessageGUID?.hashCode() ?: 0)
         return result
     }
 }

android/backend/src/main/java/net/buzzert/kordophone/backend/server/ChatRepository.kt

@@ -182,9 +182,7 @@ class ChatRepository(
     }
 
     suspend fun synchronizeConversation(conversation: Conversation, limit: Int = 15) = withErrorChannelHandling {
-        // TODO: Should only fetch messages after the last GUID we know about.
+        val messages = fetchMessages(conversation, limit = limit, afterGUID = conversation.lastFetchedMessageGUID)
-        // But keep in mind that outgoing message GUIDs are fake...
-        val messages = fetchMessages(conversation, limit = limit)
         database.writeMessages(messages, conversation)
     }
 
@@ -233,10 +231,10 @@ class ChatRepository(
     private suspend fun fetchMessages(
         conversation: Conversation,
         limit: Int? = null,
-        before: Message? = null,
+        beforeGUID: String? = null,
-        after: Message? = null,
+        afterGUID: String? = null,
     ): List<Message> {
-        return apiInterface.getMessages(conversation.guid, limit, before?.guid, after?.guid)
+        return apiInterface.getMessages(conversation.guid, limit, beforeGUID, afterGUID)
             .bodyOnSuccessOrThrow()
             .onEach { it.conversation = conversation }
     }

android/backend/src/test/java/net/buzzert/kordophone/backend/BackendTests.kt

@@ -9,6 +9,7 @@ import kotlinx.coroutines.runBlocking
 import kotlinx.coroutines.withContext
 import net.buzzert.kordophone.backend.db.CachedChatDatabase
 import net.buzzert.kordophone.backend.model.Message
+import net.buzzert.kordophone.backend.model.OutgoingMessage
 import net.buzzert.kordophone.backend.server.APIClient
 import net.buzzert.kordophone.backend.server.APIInterface
 import net.buzzert.kordophone.backend.server.Authentication
@@ -85,13 +86,18 @@ class BackendTests {
         val (repository, mockServer) = mockRepository()
 
         val conversation = mockServer.addTestConversations(1).first()
-        val outgoingMessage = MockServer.generateMessage(conversation)
+        val generatedMessage = MockServer.generateMessage(conversation)
+        val outgoingMessage = OutgoingMessage(
+            body = generatedMessage.text,
+            conversation = conversation,
+            attachmentUris = setOf(),
+            attachmentDataSource = { null },
+        )
 
-        val guid = repository.enqueueOutgoingMessage(outgoingMessage, conversation)
+        repository.enqueueOutgoingMessage(outgoingMessage)
 
         val event = repository.messageDeliveredChannel.first()
-        assertEquals(event.requestGuid, guid)
+        assertEquals(event.message.text, outgoingMessage.body)
-        assertEquals(event.message.text, outgoingMessage.text)
 
         repository.close()
     }

android/backend/src/test/java/net/buzzert/kordophone/backend/MockServer.kt

@@ -18,18 +18,19 @@ import net.buzzert.kordophone.backend.server.AuthenticationRequest
 import net.buzzert.kordophone.backend.server.AuthenticationResponse
 import net.buzzert.kordophone.backend.server.SendMessageRequest
 import net.buzzert.kordophone.backend.server.SendMessageResponse
+import net.buzzert.kordophone.backend.server.UploadAttachmentResponse
 import net.buzzert.kordophone.backend.server.authenticatedWebSocketURL
 import okhttp3.HttpUrl
 import okhttp3.MediaType.Companion.toMediaType
 import okhttp3.OkHttpClient
 import okhttp3.Request
+import okhttp3.RequestBody
 import okhttp3.ResponseBody
 import okhttp3.ResponseBody.Companion.toResponseBody
 import okhttp3.WebSocket
 import okhttp3.WebSocketListener
 import okhttp3.mockwebserver.MockResponse
 import okhttp3.mockwebserver.MockWebServer
-import retrofit2.Call
 import retrofit2.Response
 import java.util.Date
 import java.util.UUID
@@ -66,7 +67,8 @@ class MockServer {
                 unreadCount = 0,
                 lastMessagePreview = null,
                 lastMessage = null,
-                guid = UUID.randomUUID().toString()
+                guid = UUID.randomUUID().toString(),
+                lastFetchedMessageGUID = null,
             )
         }
     }
@@ -166,6 +168,8 @@ class MockServerClient(private val server: MockServer): APIClient, WebSocketList
     private var updateWatchJob: Job? = null
     private val gson: Gson = Gson()
 
+    override val isConfigured: Boolean = true
+
     override fun getAPIInterface(): APIInterface {
         return MockServerInterface(server)
     }
@@ -268,6 +272,13 @@ class MockServerInterface(private val server: MockServer): APIInterface {
         TODO("Not yet implemented")
     }
 
+    override suspend fun uploadAttachment(
+        filename: String,
+        body: RequestBody
+    ): Response<UploadAttachmentResponse> {
+        TODO("Not yet implemented")
+    }
+
     override suspend fun authenticate(request: AuthenticationRequest): Response<AuthenticationResponse> {
         // Anything goes!
         val response = AuthenticationResponse(