Formatting fixes

Author: dean-journeyapps

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

@@ -9,7 +9,8 @@ class TakePhotoWidget extends StatefulWidget {
   final String todoId;
   final CameraDescription camera;
 
-  const TakePhotoWidget({super.key, required this.todoId, required this.camera});
+  const TakePhotoWidget(
+      {super.key, required this.todoId, required this.camera});
 
   @override
   State<StatefulWidget> createState() {
@@ -45,19 +46,19 @@ class _TakePhotoWidgetState extends State<TakePhotoWidget> {
       log.info('Taking photo for todo: ${widget.todoId}');
       await _initializeControllerFuture;
       final XFile photo = await _cameraController.takePicture();
-      
+
       // Read the photo data as bytes
       final photoFile = File(photo.path);
       if (!await photoFile.exists()) {
         log.warning('Photo file does not exist: ${photo.path}');
         return;
       }
-      
+
       final photoData = await photoFile.readAsBytes();
-      
+
       // Save the photo attachment with the byte data
       final attachment = await savePhotoAttachment(photoData, widget.todoId);
-      
+
       log.info('Photo attachment saved with ID: ${attachment.id}');
     } catch (e) {
       log.severe('Error taking photo: $e');

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

@@ -33,8 +33,7 @@ Future<void> initializeAttachmentQueue(PowerSyncDatabase db) async {
   await attachmentQueue.startSync();
 }
 
-Future<Attachment> savePhotoAttachment(
-    List<int> photoData, String todoId,
+Future<Attachment> savePhotoAttachment(List<int> photoData, String todoId,
     {String mediaType = 'image/jpeg'}) async {
   // Save the file using the AttachmentQueue API
   return await attachmentQueue.saveFile(

demos/supabase-todolist/lib/widgets/todo_item_widget.dart

@@ -23,11 +23,11 @@ class TodoItemWidget extends StatelessWidget {
 
   Future<void> deleteTodo(TodoItem todo) async {
     if (todo.photoId != null) {
-      
       await attachmentQueue.deleteFile(
         attachmentId: todo.photoId!,
         updateHook: (context, attachment) async {
-          await context.execute("UPDATE todos SET photo_id = NULL WHERE id = ?", [todo.id]);
+          await context.execute(
+              "UPDATE todos SET photo_id = NULL WHERE id = ?", [todo.id]);
         },
       );
     }

demos/supabase-todolist/test/widget_test.dart

@@ -13,7 +13,9 @@ import 'package:powersync_flutter_demo/main.dart';
 void main() {
   testWidgets('Counter increments smoke test', (WidgetTester tester) async {
     // Build our app and trigger a frame.
-    await tester.pumpWidget(const MyApp(loggedIn: true,));
+    await tester.pumpWidget(const MyApp(
+      loggedIn: true,
+    ));
 
     // Verify that our counter starts at 0.
     expect(find.text('0'), findsOneWidget);

packages/powersync_attachments_stream/lib/common.dart

@@ -5,4 +5,4 @@ export 'src/abstractions/attachment_service.dart';
 export 'src/abstractions/attachment_context.dart';
 export 'src/abstractions/local_storage.dart';
 export 'src/abstractions/remote_storage.dart';
-export 'src/attachment_queue_service.dart';
+export 'src/attachment_queue_service.dart';

packages/powersync_attachments_stream/lib/src/attachment_queue_service.dart

@@ -8,7 +8,6 @@ import 'dart:async';
 
 import 'package:logging/logging.dart';
 import 'package:powersync_core/powersync_core.dart';
-import 'package:sqlite_async/mutex.dart';
 import 'package:sqlite_async/sqlite_async.dart';
 
 import 'attachment.dart';
@@ -108,11 +107,10 @@ class AttachmentQueue {
   }) : logger = logger ?? Logger('AttachmentQueue') {
     attachmentsService = AttachmentServiceImpl(
       db: db,
-      logger: logger ?? Logger('AttachmentQueue'),
+      logger: this.logger,
       maxArchivedCount: archivedCacheLimit,
       attachmentsQueueTableName: attachmentsQueueTableName,
     );
-
     syncingService = SyncingService(
       remoteStorage: remoteStorage,
       localStorage: localStorage,

packages/powersync_attachments_stream/lib/src/sync/syncing_service.dart

@@ -56,11 +56,7 @@ class SyncingService {
   }) : logger = logger ?? Logger('SyncingService');
 
   /// Starts the syncing process, including periodic and event-driven sync operations.
-  ///
-  /// [period] is the interval at which periodic sync operations are triggered.
-  Future<void> startSync({
-    Duration period = const Duration(seconds: 30),
-  }) async {
+  Future<void> startSync() async {
     if (_isClosed) return;
 
     _syncSubscription?.cancel();
@@ -99,8 +95,8 @@ class SyncingService {
 
     _syncSubscription = mergedStream;
 
-    // Start periodic sync
-    _periodicSubscription = Stream<void>.periodic(period, (_) => null).listen((
+    // Start periodic sync using instance period
+    _periodicSubscription = Stream<void>.periodic(period, (_) {}).listen((
       _,
     ) {
       logger.info('Periodically syncing attachments');
@@ -257,7 +253,8 @@ class SyncingService {
   ///
   /// [attachment]: The attachment to delete.
   /// Returns the updated attachment with its new state.
-  Future<Attachment> deleteAttachment(Attachment attachment, AbstractAttachmentContext context) async {
+  Future<Attachment> deleteAttachment(
+      Attachment attachment, AbstractAttachmentContext context) async {
     try {
       logger.info('Deleting attachment ${attachment.id} from remote storage');
       await remoteStorage.deleteFile(attachment);