Fix various issues with optimized media.

app/src/main/java/org/thoughtcrime/securesms/backup/v2/BackupRepository.kt

@@ -589,6 +589,10 @@ object BackupRepository {
 
   @JvmStatic
   fun maybeFixAnyDanglingUploadProgress() {
+    if (SignalStore.account.isLinkedDevice) {
+      return
+    }
+
     if (SignalStore.backup.archiveUploadState?.backupPhase == ArchiveUploadProgressState.BackupPhase.Message && AppDependencies.jobManager.find { it.factoryKey == BackupMessagesJob.KEY }.isEmpty()) {
       SignalStore.backup.archiveUploadState = null
       BackupMessagesJob.enqueue()

app/src/main/java/org/thoughtcrime/securesms/components/ThumbnailView.java

@@ -403,7 +403,7 @@ public class ThumbnailView extends FrameLayout {
     }
 
     if (hasSameContents(this.slide, slide)) {
-      Log.i(TAG, "Not re-loading slide " + slide.asAttachment().getUri());
+      Log.i(TAG, "Not re-loading slide " + slide.asAttachment().getDisplayUri());
       return new SettableFuture<>(false);
     }
 

app/src/main/java/org/thoughtcrime/securesms/database/AttachmentTable.kt

@@ -869,6 +869,7 @@ class AttachmentTable(
         """
         ${buildAttachmentsThatNeedUploadQuery("$ARCHIVE_THUMBNAIL_TRANSFER_STATE IN (${ArchiveTransferState.NONE.value}, ${ArchiveTransferState.TEMPORARY_FAILURE.value})")} AND
         $QUOTE = 0 AND
+        $STICKER_ID = -1 AND
         ($CONTENT_TYPE LIKE 'image/%' OR $CONTENT_TYPE LIKE 'video/%') AND
         $CONTENT_TYPE != 'image/svg+xml' AND
         $MESSAGE_ID != $WALLPAPER_MESSAGE_ID
@@ -888,6 +889,7 @@ class AttachmentTable(
         """
         ${buildAttachmentsThatNeedUploadQuery("$ARCHIVE_THUMBNAIL_TRANSFER_STATE IN (${ArchiveTransferState.NONE.value}, ${ArchiveTransferState.TEMPORARY_FAILURE.value})")} AND
         $QUOTE = 0 AND
+        $STICKER_ID = -1 AND
         ($CONTENT_TYPE LIKE 'image/%' OR $CONTENT_TYPE LIKE 'video/%') AND
         $CONTENT_TYPE != 'image/svg+xml' AND
         $MESSAGE_ID != $WALLPAPER_MESSAGE_ID
@@ -1122,11 +1124,15 @@ class AttachmentTable(
         $TABLE_NAME.$OFFLOAD_RESTORED_AT < ${now - 7.days.inWholeMilliseconds} AND
         $TABLE_NAME.$TRANSFER_STATE = $TRANSFER_PROGRESS_DONE AND
         $TABLE_NAME.$ARCHIVE_TRANSFER_STATE = ${ArchiveTransferState.FINISHED.value} AND
+        $TABLE_NAME.$DATA_FILE IS NOT NULL AND
+        $TABLE_NAME.$STICKER_ID = -1 AND
+        $TABLE_NAME.$REMOTE_KEY IS NOT NULL AND
+        $TABLE_NAME.$DATA_HASH_END IS NOT NULL AND
         (
           $TABLE_NAME.$THUMBNAIL_FILE IS NOT NULL OR 
-          NOT ($TABLE_NAME.$CONTENT_TYPE like 'image/%' OR $TABLE_NAME.$CONTENT_TYPE like 'video/%')
+          NOT ($TABLE_NAME.$CONTENT_TYPE LIKE 'image/%' OR $TABLE_NAME.$CONTENT_TYPE LIKE 'video/%') OR
-        ) AND
+          $TABLE_NAME.$CONTENT_TYPE = 'image/svg+xml'
-        $TABLE_NAME.$DATA_FILE IS NOT NULL
+        )
       )
       AND
       (
@@ -1134,7 +1140,7 @@ class AttachmentTable(
       )
     """
 
-    writableDatabase
+    val count = writableDatabase
       .update(TABLE_NAME)
       .values(
         TRANSFER_STATE to TRANSFER_RESTORE_OFFLOADED,
@@ -1142,11 +1148,12 @@ class AttachmentTable(
         DATA_RANDOM to null,
         TRANSFORM_PROPERTIES to null,
         DATA_HASH_START to null,
-        DATA_HASH_END to null,
         OFFLOAD_RESTORED_AT to 0
       )
       .where("$ID in ($subSelect)")
       .run()
+
+    Log.i(TAG, "Marked $count attachments as optimized")
   }
 
   /**

app/src/main/java/org/thoughtcrime/securesms/jobs/OptimizeMediaJob.kt

@@ -54,7 +54,8 @@ class OptimizeMediaJob private constructor(parameters: Parameters) : Job(paramet
     SignalDatabase.attachments.markEligibleAttachmentsAsOptimized()
 
     Log.i(TAG, "Deleting abandoned attachment files")
-    SignalDatabase.attachments.deleteAbandonedAttachmentFiles()
+    val count = SignalDatabase.attachments.deleteAbandonedAttachmentFiles()
+    Log.i(TAG, "Deleted $count attachments")
 
     return Result.success()
   }

app/src/main/java/org/thoughtcrime/securesms/jobs/RestoreAttachmentJob.kt

@@ -164,7 +164,7 @@ class RestoreAttachmentJob private constructor(
         messageId = attachment.mmsId,
         attachmentId = attachment.attachmentId,
         manual = true,
-        queue = Queues.MANUAL_RESTORE.random(),
+        queue = Queues.random(Queues.MANUAL_RESTORE, attachment.dataHash?.hashCode() ?: attachment.remoteKey?.hashCode()),
         priority = Parameters.PRIORITY_DEFAULT
       )
 
@@ -410,7 +410,7 @@ class RestoreAttachmentJob private constructor(
             inputStream = input,
             offloadRestoredAt = if (manual) System.currentTimeMillis().milliseconds else null,
             archiveRestore = true,
-            notify = false
+            notify = manual
           )
         ArchiveDatabaseExecutor.throttledNotifyAttachmentAndChatListObservers()
       }

app/src/main/java/org/thoughtcrime/securesms/mms/Slide.java

@@ -251,12 +251,13 @@ public abstract class Slide {
            this.hasImage() == that.hasImage()                        &&
            this.hasVideo() == that.hasVideo()                        &&
            this.getTransferState() == that.getTransferState()        &&
-           Util.equals(this.getUri(), that.getUri());
+           Util.equals(this.getUri(), that.getUri())                 &&
+           Util.equals(this.getThumbnailUri(), that.getThumbnailUri());
   }
 
   @Override
   public int hashCode() {
     return Util.hashCode(getContentType(), hasAudio(), hasImage(),
-                         hasVideo(), getUri(), getTransferState());
+                         hasVideo(), getUri(), getTransferState(), getThumbnailUri());
   }
 }

app/src/spinner/java/org/thoughtcrime/securesms/AttachmentPlugin.kt

@@ -0,0 +1,57 @@
+/*
+ * Copyright 2025 Signal Messenger, LLC
+ * SPDX-License-Identifier: AGPL-3.0-only
+ */
+
+package org.thoughtcrime.securesms
+
+import okio.IOException
+import org.signal.spinner.Plugin
+import org.signal.spinner.PluginResult
+import org.thoughtcrime.securesms.attachments.AttachmentId
+import org.thoughtcrime.securesms.database.AttachmentTable
+import org.thoughtcrime.securesms.database.SignalDatabase
+
+class AttachmentPlugin : Plugin {
+  companion object {
+    const val PATH = "/attachment"
+  }
+
+  override val name: String = "Attachment"
+  override val path: String = PATH
+
+  override fun get(parameters: Map<String, List<String>>): PluginResult {
+    var errorContent = ""
+
+    parameters["attachment_id"]?.firstOrNull()?.let { id ->
+      val attachmentId = id.toLongOrNull()?.let { AttachmentId(it) }
+      if (attachmentId != null) {
+        try {
+          val attachment = SignalDatabase.attachments.getAttachment(attachmentId)
+          if (attachment != null) {
+            val inputStream = if (attachment.transferState == AttachmentTable.TRANSFER_PROGRESS_DONE) {
+              SignalDatabase.attachments.getAttachmentStream(attachmentId, 0)
+            } else {
+              SignalDatabase.attachments.getAttachmentThumbnailStream(attachmentId, 0)
+            }
+            return PluginResult.RawFileResult(attachment.size, inputStream, attachment.contentType ?: "application/octet-stream")
+          } else {
+            throw IOException("Missing attachment, not found for: $attachmentId")
+          }
+        } catch (e: IOException) {
+          errorContent = "${e.javaClass}: ${e.message}"
+        }
+      }
+    }
+
+    val formContent = """
+      <form action="$PATH" method="GET">
+          <label for="number">Enter an attachment_id:</label>
+          <input type="number" id="attachment_id" name="attachment_id" required>
+          <button type="submit">Submit</button>
+      </form>
+    """.trimIndent()
+
+    return PluginResult.RawHtmlResult("$formContent<br>$errorContent")
+  }
+}

app/src/spinner/java/org/thoughtcrime/securesms/SpinnerApplicationContext.kt

@@ -85,7 +85,8 @@ class SpinnerApplicationContext : ApplicationContext() {
         )
       ),
       linkedMapOf(
-        StorageServicePlugin.PATH to StorageServicePlugin()
+        StorageServicePlugin.PATH to StorageServicePlugin(),
+        AttachmentPlugin.PATH to AttachmentPlugin()
       )
     )
 

app/src/spinner/java/org/thoughtcrime/securesms/StorageServicePlugin.kt

@@ -11,7 +11,7 @@ class StorageServicePlugin : Plugin {
   override val name: String = "Storage"
   override val path: String = PATH
 
-  override fun get(): PluginResult {
+  override fun get(parameters: Map<String, List<String>>): PluginResult {
     val columns = listOf("Type", "Id", "Data")
     val rows = mutableListOf<List<String>>()
 

spinner/lib/src/main/assets/plugin.hbs

@@ -26,6 +26,9 @@
     {{#if (eq "string" pluginResult.type)}}
       <p>{{pluginResult.text}}</p>
     {{/if}}
+    {{#if (eq "html" pluginResult.type)}}
+      {{{pluginResult.html}}}
+    {{/if}}
     {{> partials/suffix }}
   </body>
 </html>

spinner/lib/src/main/java/org/signal/spinner/Plugin.kt

@@ -1,7 +1,7 @@
 package org.signal.spinner
 
 interface Plugin {
-  fun get(): PluginResult
+  fun get(parameters: Map<String, List<String>>): PluginResult
   val name: String
   val path: String
 }

spinner/lib/src/main/java/org/signal/spinner/PluginResult.kt

@@ -1,5 +1,7 @@
 package org.signal.spinner
 
+import java.io.InputStream
+
 sealed class PluginResult(val type: String) {
   data class TableResult(
     val columns: List<String>,
@@ -10,4 +12,14 @@ sealed class PluginResult(val type: String) {
   data class StringResult(
     val text: String
   ) : PluginResult("string")
+
+  data class RawHtmlResult(
+    val html: String
+  ) : PluginResult("html")
+
+  data class RawFileResult(
+    val length: Long,
+    val data: InputStream,
+    val mimeType: String
+  ) : PluginResult("file")
 }

spinner/lib/src/main/java/org/signal/spinner/SpinnerServer.kt

@@ -15,7 +15,6 @@ import org.signal.core.util.logging.Log
 import org.signal.core.util.tracing.Tracer
 import org.signal.spinner.Spinner.DatabaseConfig
 import java.io.ByteArrayInputStream
-import java.lang.IllegalArgumentException
 import java.security.NoSuchAlgorithmException
 import java.text.SimpleDateFormat
 import java.util.Date
@@ -79,7 +78,7 @@ internal class SpinnerServer(
         else -> {
           val plugin = plugins[session.uri]
           if (plugin != null && session.method == Method.GET) {
-            getPlugin(dbParam, plugin)
+            getPlugin(dbParam, plugin, session.parameters)
           } else {
             newFixedLengthResponse(Response.Status.NOT_FOUND, MIME_HTML, "Not found")
           }
@@ -280,7 +279,14 @@ internal class SpinnerServer(
     )
   }
 
-  private fun getPlugin(dbName: String, plugin: Plugin): Response {
+  private fun getPlugin(dbName: String, plugin: Plugin, parameters: Map<String, List<String>>): Response {
+    val pluginResult = plugin.get(parameters)
+
+    when (pluginResult) {
+      is PluginResult.RawFileResult -> {
+        return newFixedLengthResponse(Response.Status.OK, pluginResult.mimeType, pluginResult.data, pluginResult.length)
+      }
+      else -> {
         return renderTemplate(
           "plugin",
           PluginPageModel(
@@ -290,10 +296,12 @@ internal class SpinnerServer(
             databases = databases.keys.toList(),
             plugins = plugins.values.toList(),
             activePlugin = plugin,
-        pluginResult = plugin.get()
+            pluginResult = plugin.get(parameters)
           )
         )
       }
+    }
+  }
 
   private fun internalError(throwable: Throwable): Response {
     val stackTrace = ExceptionUtil.convertThrowableToString(throwable)