added boot strap operation

wealth-wave · Jan 18, 2024 · d976f40 · d976f40
1 parent a1d674b
commit d976f40
Show file tree

Hide file tree

Showing 6 changed files with 64 additions and 22 deletions.
diff --git a/lib/api/apis/sip_api.dart b/lib/api/apis/sip_api.dart
@@ -24,6 +24,12 @@ class SipApi {
         executedTill: const Value(null)));
   }
 
+  Future<List<SipDO>> getAll() async {
+    return (_db.select(_db.sipTable)
+          ..orderBy([(t) => OrderingTerm.desc(t.startDate)]))
+        .get();
+  }
+
   Future<List<SipDO>> getBy({final int? investmentId}) async {
     if (investmentId == null) {
       return (_db.select(_db.sipTable)

diff --git a/lib/domain/models/investment.dart b/lib/domain/models/investment.dart
@@ -122,9 +122,8 @@ class Investment {
   }
 
   Future<List<SIP>> getSips() async {
-    return _sipApi
-        .getBy(investmentId: id)
-        .then((sips) => sips.map((sipDO) => SIP.from(sipDO: sipDO)).toList());
+    return _sipApi.getBy(investmentId: id).then(
+        (sips) => Future.wait(sips.map((sipDO) => SIP.from(sipDO: sipDO))));
   }
 
   Future<SIP> createSip(
@@ -142,7 +141,8 @@ class Investment {
             endDate: endDate,
             frequency: frequency)
         .then((id) => _sipApi.getById(id: id))
-        .then((sipDO) => SIP.from(sipDO: sipDO));
+        .then((sipDO) => SIP.from(sipDO: sipDO))
+        .then((sip) => sip.performSipTransactions().then((_) => sip));
   }
 
   Future<SIP> updateSip(
@@ -162,7 +162,11 @@ class Investment {
             endDate: endDate,
             frequency: frequency)
         .then((count) => _sipApi.getById(id: sipId))
-        .then((sipDO) => SIP.from(sipDO: sipDO));
+        .then((sipDO) => SIP.from(sipDO: sipDO))
+        .then((sip) => sip
+            .deleteTransactions()
+            .then((_) => sip.performSipTransactions().then((_) => sip)));
+    ;
   }
 
   Future<void> deleteSIP({required final int sipId}) async {

diff --git a/lib/domain/models/sip.dart b/lib/domain/models/sip.dart
@@ -36,7 +36,7 @@ class SIP {
   Future<List<Payment>> getFuturePayment({required final DateTime till}) {
     return Future(() {
       List<Payment> payments = [];
-      for (var i = startDate;
+      for (var i = executedTill ?? startDate;
           i.isBefore(endDate ?? till);
           i = i.add(getDuration(frequency))) {
         payments.add(Payment(amount: amount, createdOn: i));
@@ -99,7 +99,15 @@ class SIP {
     return _transactionApi.deleteBy(sipId: id).then((count) => {});
   }
 
-  static SIP from({required final SipDO sipDO}) {
+  Future<void> performSipTransactions() {
+    return getFuturePayment(till: DateTime.now()).then((payments) =>
+        Future.wait(payments.map((payment) => createTransaction(
+            description: 'SIP',
+            amount: payment.amount,
+            createdOn: payment.createdOn))));
+  }
+
+  static Future<SIP> from({required final SipDO sipDO}) async {
     return SIP(
         id: sipDO.id,
         investmentId: sipDO.investmentId,

diff --git a/lib/domain/services/boot_strap_service.dart b/lib/domain/services/boot_strap_service.dart
@@ -0,0 +1,12 @@
+import 'package:wealth_wave/domain/services/sip_service.dart';
+
+class BootStrapService {
+  final SipService _sipService;
+
+  BootStrapService({final SipService? sipService})
+      : _sipService = sipService ?? SipService();
+
+  Future<void> performBootStrapOperations() {
+    return _sipService.performSipTransactions();
+  }
+}
diff --git a/lib/domain/services/sip_service.dart b/lib/domain/services/sip_service.dart
@@ -11,4 +11,13 @@ class SipService {
       return SIP.from(sipDO: sipDO);
     });
   }
+
+  Future<void> performSipTransactions() {
+    return _sipApi
+        .getAll()
+        .then((sipDOs) =>
+            Future.wait(sipDOs.map((sipDO) => SIP.from(sipDO: sipDO))))
+        .then((sips) => sips.map((sip) => sip.performSipTransactions()))
+        .then((_) => {});
+  }
 }
diff --git a/lib/main.dart b/lib/main.dart
@@ -2,6 +2,7 @@ import 'package:flutter/material.dart';
 import 'package:provider/provider.dart';
 import 'package:wealth_wave/api/db/app_database.dart';
 import 'package:wealth_wave/app_router.dart';
+import 'package:wealth_wave/domain/services/boot_strap_service.dart';
 
 void main() {
   runApp(Provider<AppDatabase>(
@@ -16,20 +17,22 @@ class WealthWaveApp extends StatelessWidget {
   // This widget is the root of your application.
   @override
   Widget build(BuildContext context) {
-    return MaterialApp(
-      title: 'Wealth Wave',
-      debugShowCheckedModeBanner: false,
-      theme: ThemeData(
-        colorScheme: ColorScheme.fromSeed(seedColor: Colors.deepPurple),
-        useMaterial3: true,
-      ),
-      onGenerateRoute: (settings) {
-        return MaterialPageRoute(
-            settings: RouteSettings(
-                name: settings.name, arguments: settings.arguments),
-            maintainState: true,
-            builder: (context) => AppRouter.route(settings.name!));
-      },
-    );
+    return FutureBuilder(
+        future: BootStrapService().performBootStrapOperations(),
+        builder: (context, snapshot) => MaterialApp(
+              title: 'Wealth Wave',
+              debugShowCheckedModeBanner: false,
+              theme: ThemeData(
+                colorScheme: ColorScheme.fromSeed(seedColor: Colors.deepPurple),
+                useMaterial3: true,
+              ),
+              onGenerateRoute: (settings) {
+                return MaterialPageRoute(
+                    settings: RouteSettings(
+                        name: settings.name, arguments: settings.arguments),
+                    maintainState: true,
+                    builder: (context) => AppRouter.route(settings.name!));
+              },
+            ));
   }
 }