powersync based nutrition

Author: Dieterbe

lib/models/muscle.dart

@@ -31,7 +31,6 @@ class Muscle {
   /// Watch all lists.
   static Stream<List<Muscle>> watchMuscles() {
     return db.watch('SELECT * FROM $tableMuscles ORDER BY id').map((results) {
-      print('watchMuscles triggered' + results.toString());
       return results.map(Muscle.fromRow).toList(growable: false);
     });
   }

lib/models/nutrition/log.dart

@@ -25,6 +25,7 @@ import 'package:wger/models/nutrition/meal_item.dart';
 import 'package:wger/models/nutrition/nutritional_values.dart';
 import 'package:wger/models/schema.dart';
 import 'package:wger/powersync.dart';
+import 'package:powersync/sqlite3.dart' as sqlite;
 
 part 'log.g.dart';
 
@@ -80,13 +81,13 @@ class Log {
 
   factory Log.fromRow(sqlite.Row row) {
     return Log(
-      id: row['id'],
-      mealId: row['meal_id'],
-      ingredientId: row['ingredient_id'],
-      weightUnitId: row['weight_unit_id'],
+      id: int.parse(row['id']),
+      mealId: int.parse(row['meal_id']),
+      ingredientId: int.parse(row['ingredient_id']),
+      weightUnitId: int.parse(row['weight_unit_id']),
       amount: row['amount'],
-      planId: row['plan_id'],
-      datetime: row['datetime'],
+      planId: int.parse(row['plan_id']),
+      datetime: DateTime.parse(row['datetime']),
       comment: row['comment'],
     );
   }
@@ -105,6 +106,12 @@ class Log {
 
     return ingredient.nutritionalValues / (100 / weight);
   }
+
+  static Future<List<Log>> readByPlanId(int planId) async {
+    final results = await db.getAll('SELECT * FROM $tableLogItems WHERE plan_id = ?', [planId]);
+    return results.map((r) => Log.fromRow(r)).toList();
+  }
+
 /*
   Future<void> delete() async {
     await db.execute('DELETE FROM $logItemsTable WHERE id = ?', [id]);

lib/models/nutrition/meal.dart

@@ -24,6 +24,9 @@ import 'package:wger/helpers/misc.dart';
 import 'package:wger/models/nutrition/log.dart';
 import 'package:wger/models/nutrition/meal_item.dart';
 import 'package:wger/models/nutrition/nutritional_values.dart';
+import 'package:powersync/sqlite3.dart' as sqlite;
+import 'package:wger/models/schema.dart';
+import 'package:wger/powersync.dart';
 
 part 'meal.g.dart';
 
@@ -87,6 +90,15 @@ class Meal {
   // Boilerplate
   factory Meal.fromJson(Map<String, dynamic> json) => _$MealFromJson(json);
 
+  factory Meal.fromRow(sqlite.Row row) {
+    return Meal(
+      id: int.parse(row['id']),
+      plan: int.parse(row['plan']),
+      time: stringToTime(row['time']),
+      name: row['name'],
+    );
+  }
+
   Map<String, dynamic> toJson() => _$MealToJson(this);
 
   Meal copyWith({
@@ -106,4 +118,14 @@ class Meal {
       diaryEntries: diaryEntries ?? this.diaryEntries,
     );
   }
+
+  static Future<Meal> read(int id) async {
+    final results = await db.get('SELECT * FROM $tableMeals WHERE id = ?', [id]);
+    return Meal.fromRow(results);
+  }
+
+  static Future<List<Meal>> readByPlanId(int planId) async {
+    final results = await db.getAll('SELECT * FROM $tableMeals WHERE plan_id = ?', [planId]);
+    return results.map((r) => Meal.fromRow(r)).toList();
+  }
 }

lib/models/nutrition/nutritional_plan.dart

@@ -20,13 +20,16 @@ import 'package:collection/collection.dart';
 import 'package:flutter/widgets.dart';
 import 'package:flutter_gen/gen_l10n/app_localizations.dart';
 import 'package:json_annotation/json_annotation.dart';
+import 'package:powersync/sqlite3.dart' as sqlite;
 import 'package:wger/helpers/consts.dart';
 import 'package:wger/helpers/json.dart';
 import 'package:wger/models/nutrition/log.dart';
 import 'package:wger/models/nutrition/meal.dart';
 import 'package:wger/models/nutrition/meal_item.dart';
 import 'package:wger/models/nutrition/nutritional_goals.dart';
 import 'package:wger/models/nutrition/nutritional_values.dart';
+import 'package:wger/models/schema.dart';
+import 'package:wger/powersync.dart';
 
 part 'nutritional_plan.g.dart';
 
@@ -82,6 +85,55 @@ class NutritionalPlan {
     this.diaryEntries = diaryEntries ?? [];
   }
 
+  factory NutritionalPlan.fromRow(sqlite.Row row) {
+    return NutritionalPlan(
+      id: int.parse(row['id']),
+      description: row['description'],
+      creationDate: DateTime.parse(row['creation_date']),
+      onlyLogging: row['only_logging'] == 1,
+      goalEnergy: row['goal_energy'],
+      goalProtein: row['goal_protein'],
+      goalCarbohydrates: row['goal_carbohydrates'],
+      goalFat: row['goal_fat'],
+      goalFiber: row['goal_fiber'],
+    );
+  }
+
+  NutritionalPlan copyWith({
+    int? id,
+    String? description,
+    DateTime? creationDate,
+    bool? onlyLogging,
+    num? goalEnergy,
+    num? goalProtein,
+    num? goalCarbohydrates,
+    num? goalFat,
+    num? goalFiber,
+    List<Meal>? meals,
+    List<Log>? diaryEntries,
+  }) {
+    return NutritionalPlan(
+      id: id ?? this.id,
+      description: description ?? this.description,
+      creationDate: creationDate ?? this.creationDate,
+      onlyLogging: onlyLogging ?? this.onlyLogging,
+      goalEnergy: goalEnergy ?? this.goalEnergy,
+      goalProtein: goalProtein ?? this.goalProtein,
+      goalCarbohydrates: goalCarbohydrates ?? this.goalCarbohydrates,
+      goalFat: goalFat ?? this.goalFat,
+      goalFiber: goalFiber ?? this.goalFiber,
+      meals: meals ?? this.meals,
+      diaryEntries: diaryEntries ?? this.diaryEntries,
+    );
+  }
+
+  Future<NutritionalPlan> loadChildren() async {
+    return copyWith(
+      diaryEntries: await Log.readByPlanId(id!),
+      meals: await Meal.readByPlanId(id!),
+    );
+  }
+
   NutritionalPlan.empty() {
     creationDate = DateTime.now();
     description = '';
@@ -246,4 +298,65 @@ class NutritionalPlan {
       diaryEntries: diaryEntries.where((e) => e.mealId == null).toList(),
     );
   }
+
+  static Future<NutritionalPlan> read(int id) async {
+    final row = await db.get('SELECT * FROM $tableNutritionPlans WHERE id = ?', [id]);
+    return NutritionalPlan.fromRow(row).loadChildren();
+  }
+
+// this is a bit complicated.
+// what we need at the end of the day, is a stream of List<NutritionPlan>, where
+// a new value is emitted any time a plan is changed. But the plan is not just the plan record
+// we need to load data for Logs and Meals corresponding to the plan also.
+// so our options are:
+// 1) db.watch with a select query on plans; and extra dart code to load the logs/meals stuff,
+//    but this only triggers for updates on the plans table, and misses logs/meals updates
+// 2) db.watch with a huge join query across all tables from which we need info,
+//    so we have all the data in our resultset to create the datastructures with, but:
+//    - this creates long rows with lots of duplicated data (e.g. all the plan data) for every row
+//       which would only differ for e.g. the meal or the log item
+//    - it would probably get a bit messy to parse the resultset into the datastructures
+// 3) the best of both worlds: load the data we need in dart at runtime, but explicitly
+//    trigger our code execution when *any* of the relevant tables changes
+//
+  static Stream<List<NutritionalPlan>> watchNutritionPlans() {
+    return db.onChange([tableNutritionPlans, tableLogItems, tableMeals]).asyncMap((event) async {
+      final data = await db.getAll('SELECT * FROM $tableNutritionPlans ORDER BY creation_date');
+      final futures = Future.wait(data.map((row) => NutritionalPlan.fromRow(row).loadChildren()));
+      return (await futures).toList(growable: false);
+    });
+  }
+
+  static Stream<NutritionalPlan> watchNutritionPlan(int id) {
+    return db.onChange([tableNutritionPlans, tableLogItems, tableMeals]).asyncMap((event) async {
+      final row = await db.get('SELECT * FROM $tableNutritionPlans WHERE id = ?', [id]);
+      return NutritionalPlan.fromRow(row).loadChildren();
+    });
+  }
+
+  static Stream<NutritionalPlan> watchNutritionPlanLast() {
+    return db.onChange([tableNutritionPlans, tableLogItems, tableMeals]).asyncMap((event) async {
+      final row =
+          await db.get('SELECT * FROM $tableNutritionPlans ORDER BY creation_date DESC LIMIT 1');
+      return NutritionalPlan.fromRow(row).loadChildren();
+    });
+  }
+/*
+  static Stream<List<NutritionalPlan>> watchNutritionPlan(int id) {
+    return db
+        .watch('SELECT * FROM $tableNutritionPlans WHERE id = ?', parameters: [id]).map((results) {
+      return results.map(NutritionalPlan.fromRow).toList(growable: false);
+    });
+  }
+
+  static Stream<List<NutritionalPlan>> watchNutritionPlans() {
+    return db.watch('SELECT * FROM $tableNutritionPlans ORDER BY creation_date').map((results) {
+      return results.map(NutritionalPlan.fromRow).toList(growable: false);
+    });
+  }
+  */
+
+  Future<void> delete() async {
+    await db.execute('DELETE FROM $tableNutritionPlans WHERE id = ?', [id]);
+  }
 }