chore: allow different file extensions (#47)

Co-authored-by: DominicGBauer <dominic@nomanini.com>

Author: DominicGBauer

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

@@ -53,7 +53,7 @@ class PhotoAttachmentQueue extends AbstractAttachmentQueue {
   }
 
   @override
-  StreamSubscription<void> watchIds() {
+  StreamSubscription<void> watchIds({String fileExtension = 'jpg'}) {
     log.info('Watching photos in $todosTable...');
     return db.watch('''
       SELECT photo_id FROM $todosTable
@@ -63,7 +63,7 @@ class PhotoAttachmentQueue extends AbstractAttachmentQueue {
     }).listen((ids) async {
       List<String> idsInQueue = await attachmentsService.getAttachmentIds();
       for (String id in ids) {
-        await syncingService.reconcileId(id, idsInQueue);
+        await syncingService.reconcileId(id, idsInQueue, fileExtension);
       }
     });
   }

packages/powersync_attachments_helper/example/getting_started.dart

@@ -44,7 +44,7 @@ class PhotoAttachmentQueue extends AbstractAttachmentQueue {
   }
 
   @override
-  StreamSubscription<void> watchIds() {
+  StreamSubscription<void> watchIds({String fileExtension = 'jpg'}) {
     return db.watch('''
       SELECT photo_id FROM users
       WHERE photo_id IS NOT NULL
@@ -53,7 +53,7 @@ class PhotoAttachmentQueue extends AbstractAttachmentQueue {
     }).listen((ids) async {
       List<String> idsInQueue = await attachmentsService.getAttachmentIds();
       for (String id in ids) {
-        await syncingService.reconcileId(id, idsInQueue);
+        await syncingService.reconcileId(id, idsInQueue, fileExtension);
       }
     });
   }

packages/powersync_attachments_helper/lib/src/attachments_queue.dart

@@ -34,8 +34,9 @@ abstract class AbstractAttachmentQueue {
         db, remoteStorage, localStorage, attachmentsService, getLocalUri);
   }
 
-  /// Create watcher to get list of ID's from a table to be used for syncing in the attachment queue
-  StreamSubscription<void> watchIds();
+  /// 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'});
 
   /// Create a function to save photos using the attachment queue
   Future<Attachment> savePhoto(String photoId, int size);

packages/powersync_attachments_helper/lib/src/syncing_service.dart

@@ -196,22 +196,22 @@ class SyncingService {
   /// in local and remote storage.
   /// If the ID is in the queue, but the file does not exist locally then it is
   /// marked for download.
-  reconcileId(String id, List<String> idsInQueue) async {
+  reconcileId(String id, List<String> idsInQueue, String fileExtension) async {
     bool idIsInQueue = idsInQueue.contains(id);
 
-    String imagePath = await getLocalUri('$id.jpg');
-    File file = File(imagePath);
+    String path = await getLocalUri('$id.$fileExtension');
+    File file = File(path);
     bool fileExists = await file.exists();
 
     if (!idIsInQueue) {
       if (fileExists) {
-        log.info('ignore file $id.jpg as it already exists');
+        log.info('ignore file $id.$fileExtension as it already exists');
         return;
       }
       log.info('Adding $id to queue');
       return await attachmentsService.saveAttachment(Attachment(
         id: id,
-        filename: '$id.jpg',
+        filename: '$id.$fileExtension',
         state: AttachmentState.queuedDownload.index,
       ));
     }