feat(transaction-recurring): #100 generate transactions

service/transaction_recurring.go

@@ -33,19 +33,23 @@ type TransactionRecurring interface {
 	GetAllByAccount(user *types.User, accountId string) ([]*types.TransactionRecurring, error)
 	GetAllByTreasureChest(user *types.User, treasureChestId string) ([]*types.TransactionRecurring, error)
 	Delete(user *types.User, id string) error
+
+	GenerateTransactions(user *types.User) error
 }
 
 type TransactionRecurringImpl struct {
-	db     *sqlx.DB
-	clock  Clock
-	random Random
+	db          *sqlx.DB
+	clock       Clock
+	random      Random
+	transaction Transaction
 }
 
-func NewTransactionRecurring(db *sqlx.DB, random Random, clock Clock) TransactionRecurring {
+func NewTransactionRecurring(db *sqlx.DB, random Random, clock Clock, transaction Transaction) TransactionRecurring {
 	return TransactionRecurringImpl{
-		db:     db,
-		clock:  clock,
-		random: random,
+		db:          db,
+		clock:       clock,
+		random:      random,
+		transaction: transaction,
 	}
 }
 
@@ -326,6 +330,62 @@ func (s TransactionRecurringImpl) Delete(user *types.User, id string) error {
 	return nil
 }
 
+func (s TransactionRecurringImpl) GenerateTransactions(user *types.User) error {
+	if user == nil {
+		return ErrUnauthorized
+	}
+	now := s.clock.Now()
+
+	tx, err := s.db.Beginx()
+	err = db.TransformAndLogDbError("transactionRecurring GenerateTransactions", nil, err)
+	if err != nil {
+		return err
+	}
+	defer func() {
+		_ = tx.Rollback()
+	}()
+
+	recurringTransactions := make([]*types.TransactionRecurring, 0)
+	err = tx.Select(&recurringTransactions, `
+		SELECT * FROM transaction_recurring WHERE user_id = ? AND next_execution <= ?`,
+		user.Id, now)
+	err = db.TransformAndLogDbError("transactionRecurring GenerateTransactions", nil, err)
+	if err != nil {
+		return err
+	}
+
+	for _, transactionRecurring := range recurringTransactions {
+		transaction := types.Transaction{
+			Timestamp:   *transactionRecurring.NextExecution,
+			Party:       transactionRecurring.Party,
+			Description: transactionRecurring.Description,
+
+			TreasureChestId: transactionRecurring.TreasureChestId,
+			Value:           transactionRecurring.Value,
+		}
+
+		_, err = s.transaction.Add(user, transaction)
+		if err != nil {
+			return err
+		}
+
+		nextExecution := transactionRecurring.NextExecution.AddDate(0, int(transactionRecurring.IntervalMonths), 0)
+		r, err := tx.Exec(`UPDATE transaction_recurring SET next_execution = ? WHERE id = ? AND user_id = ?`,
+			nextExecution, transactionRecurring.Id, user.Id)
+		err = db.TransformAndLogDbError("transactionRecurring GenerateTransactions", r, err)
+		if err != nil {
+			return err
+		}
+	}
+
+	err = tx.Commit()
+	err = db.TransformAndLogDbError("transactionRecurring GenerateTransactions", nil, err)
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
 func (s TransactionRecurringImpl) validateAndEnrichTransactionRecurring(
 	tx *sqlx.Tx,
 	oldTransactionRecurring *types.TransactionRecurring,