Add SIP

lib/api/apis/investment_api.dart

@@ -32,6 +32,19 @@ class InvestmentApi {
     }
   }
 
+  Future<List<SipDO>> getSips({final int? investmentId}) async {
+    if (investmentId == null) {
+      return (_db.select(_db.sipTable)
+            ..orderBy([(t) => OrderingTerm.desc(t.startDate)]))
+          .get();
+    } else {
+      return (_db.select(_db.sipTable)
+            ..where((t) => t.investmentId.equals(investmentId))
+            ..orderBy([(t) => OrderingTerm.desc(t.startDate)]))
+          .get();
+    }
+  }
+
   Future<int> createInvestment({
     required final String name,
     required final String? description,

lib/api/db/app_database.dart

@@ -48,6 +48,24 @@ class TransactionTable extends Table {
       dateTime().named('AMOUNT_INVESTED_ON')();
 }
 
+@DataClassName('SipDO')
+class SipTable extends Table {
+  IntColumn get id => integer().named('ID').autoIncrement()();
+
+  IntColumn get investmentId =>
+      integer().named('INVESTMENT_ID').references(InvestmentTable, #id)();
+
+  RealColumn get amount => real().named('AMOUNT')();
+
+  TextColumn get description => text().nullable().named('DESCRIPTION')();
+
+  DateTimeColumn get startDate => dateTime().named('START_DATE')();
+
+  DateTimeColumn get endDate => dateTime().named('END_DATE')();
+
+  RealColumn get frequency => real().named('FREQUENCY')();
+}
+
 @DataClassName('GoalDO')
 class GoalTable extends Table {
   IntColumn get id => integer().named('ID').autoIncrement()();
@@ -142,6 +160,7 @@ abstract class GoalInvestmentEnrichedMappingView extends View {
   InvestmentTable,
   TransactionTable,
   GoalTable,
+  SipTable,
   GoalInvestmentTable,
 ], views: [
   InvestmentEnrichedView,
@@ -169,13 +188,15 @@ class AppDatabase extends _$AppDatabase {
     final goalBackup = await executor.runSelect('SELECT * FROM goal_table', []);
     final goalInvestmentBackup =
         await executor.runSelect('SELECT * FROM goal_investment_table', []);
+    final sipBackup = await executor.runSelect('SELECT * FROM sip_table', []);
 
     return {
       'basket_table': basketBackup,
       'investment_table': investmentBackup,
       'transaction_table': transactionBackup,
       'goal_table': goalBackup,
       'goal_investment_table': goalInvestmentBackup,
+      'sip_table': sipBackup,
     };
   }
 

lib/domain/models/investment.dart

@@ -3,6 +3,7 @@ import 'dart:math';
 import 'package:wealth_wave/api/db/app_database.dart';
 import 'package:wealth_wave/contract/risk_level.dart';
 import 'package:wealth_wave/domain/irr_calculator.dart';
+import 'package:wealth_wave/domain/models/sip.dart';
 import 'package:wealth_wave/domain/models/transaction.dart';
 
 class Investment {
@@ -17,6 +18,7 @@ class Investment {
   final double totalInvestedAmount;
   final int totalTransactions;
   final List<Transaction> transactions;
+  final List<SIP> sips;
   final List<GoalInvestmentEnrichedMappingDO> taggedGoals;
 
   Investment(
@@ -31,6 +33,7 @@ class Investment {
       required this.totalInvestedAmount,
       required this.totalTransactions,
       required this.transactions,
+      required this.sips,
       required this.taggedGoals});
 
   double? getIrr() {
@@ -52,6 +55,7 @@ class Investment {
   static Investment from(
       {required final InvestmentEnrichedDO investment,
       required final List<TransactionDO> transactions,
+      required final List<SipDO> sips,
       required final List<GoalInvestmentEnrichedMappingDO>
           goalInvestmentMappings}) {
     return Investment(
@@ -68,6 +72,7 @@ class Investment {
         transactions: transactions
             .map((transaction) => Transaction.from(transaction: transaction))
             .toList(),
+        sips: sips.map((sip) => SIP.from(sip: sip)).toList(),
         taggedGoals: goalInvestmentMappings);
   }
 }

lib/domain/models/sip.dart

@@ -0,0 +1,28 @@
+import 'package:wealth_wave/api/db/app_database.dart';
+
+class SIP {
+  final int id;
+  final String? description;
+  final double amount;
+  final DateTime startDate;
+  final DateTime endDate;
+  final double frequency;
+
+  SIP(
+      {required this.id,
+      required this.description,
+      required this.amount,
+      required this.startDate,
+      required this.endDate,
+      required this.frequency});
+
+  static SIP from({required final SipDO sip}) {
+    return SIP(
+        id: sip.id,
+        description: sip.description,
+        amount: sip.amount,
+        startDate: sip.startDate,
+        endDate: sip.endDate,
+        frequency: sip.frequency);
+  }
+}

lib/domain/usecases/fetch_investments_use_case.dart

@@ -12,12 +12,16 @@ class FetchInvestmentsUseCase {
     List<InvestmentEnrichedDO> investments =
         await _investmentApi.getEnrichedInvestments();
     List<TransactionDO> transactions = await _investmentApi.getTransactions();
+    List<SipDO> sips = await _investmentApi.getSips();
     List<GoalInvestmentEnrichedMappingDO> goalInvestmentMappings =
         await _investmentApi.getGoalInvestmentMappings();
 
     return investments
         .map((investment) => Investment.from(
             investment: investment,
+            sips: sips
+                .where((sip) => sip.investmentId == investment.id)
+                .toList(),
             transactions: transactions
                 .where(
                     (transaction) => transaction.investmentId == investment.id)