feat(attachments): allow watchIds without fileExtension

Author: n0mad-d3v

demos/supabase-todolist-drift/lib/powersync/attachments/queue.dart

@@ -78,7 +78,7 @@ class PhotoAttachmentQueue extends AbstractAttachmentQueue {
   }
 
   @override
-  StreamSubscription<void> watchIds({String fileExtension = 'jpg'}) {
+  StreamSubscription<void> watchIds({String? fileExtension}) {
     log.info('Watching photos in $todosTable...');
     return db.watch('''
       SELECT photo_id FROM $todosTable

demos/supabase-todolist/lib/attachments/queue.dart

@@ -68,7 +68,7 @@ class PhotoAttachmentQueue extends AbstractAttachmentQueue {
   }
 
   @override
-  StreamSubscription<void> watchIds({String fileExtension = 'jpg'}) {
+  StreamSubscription<void> watchIds({String? fileExtension}) {
     log.info('Watching photos in $todosTable...');
     return db.watch('''
       SELECT photo_id FROM $todosTable

packages/powersync_attachments_helper/README.md

@@ -62,7 +62,7 @@ class PhotoAttachmentQueue extends AbstractAttachmentQueue {
   // This watcher will handle adding items to the queue based on
   // a users table element receiving a photoId
   @override
-  StreamSubscription<void> watchIds({String fileExtension = 'jpg'}) {
+  StreamSubscription<void> watchIds({String? fileExtension}) {
     return db.watch('''
       SELECT photo_id FROM users
       WHERE photo_id IS NOT NULL

packages/powersync_attachments_helper/example/getting_started.dart

@@ -46,7 +46,7 @@ class PhotoAttachmentQueue extends AbstractAttachmentQueue {
   }
 
   @override
-  StreamSubscription<void> watchIds({String fileExtension = 'jpg'}) {
+  StreamSubscription<void> watchIds({String? fileExtension}) {
     return db.watch('''
       SELECT photo_id FROM users
       WHERE photo_id IS NOT NULL

packages/powersync_attachments_helper/lib/src/attachments_queue.dart

@@ -59,7 +59,7 @@ abstract class AbstractAttachmentQueue {
 
   /// Create watcher to get list of ID's from a table to be used for syncing in the attachment queue.
   /// Set the file extension if you are using a different file type
-  StreamSubscription<void> watchIds({String fileExtension = 'jpg'});
+  StreamSubscription<void> watchIds({String? fileExtension});
 
   /// Create a function to save files using the attachment queue
   Future<Attachment> saveFile(String fileId, int size);
@@ -82,7 +82,7 @@ abstract class AbstractAttachmentQueue {
       }
     }
 
-    watchIds();
+    watchIds(fileExtension: 'jpg');
     syncingService.watchAttachments();
     syncingService.startPeriodicSync(intervalInMinutes);
 

packages/powersync_attachments_helper/lib/src/syncing_service.dart

@@ -165,11 +165,12 @@ class SyncingService {
   }
 
   /// Process ID's to be included in the attachment queue.
-  Future<void> processIds(List<String> ids, String fileExtension) async {
+  Future<void> processIds(List<String> ids, String? fileExtension) async {
     List<Attachment> attachments = List.empty(growable: true);
 
     for (String id in ids) {
-      String path = await getLocalUri('$id.$fileExtension');
+      String filename = fileExtension != null ? '$id.$fileExtension' : id;
+      String path = await getLocalUri(filename);
       File file = File(path);
       bool fileExists = await file.exists();
 
@@ -180,7 +181,7 @@ class SyncingService {
       log.info('Adding $id to queue');
       attachments.add(Attachment(
           id: id,
-          filename: '$id.$fileExtension',
+          filename: filename,
           state: AttachmentState.queuedDownload.index));
     }