Implement transfer creation

server/transaction.go

@@ -1,6 +1,7 @@
 package server
 
 import (
+	"context"
 	"fmt"
 	"net/http"
 	"time"
@@ -14,8 +15,9 @@ import (
 type NewTransactionPayload struct {
 	Date  JSONDate `json:"date"`
 	Payee struct {
-		ID   uuid.NullUUID
-		Name string
+		ID        uuid.NullUUID
+		Name      string
+		IsAccount bool
 	} `json:"payee"`
 	Category struct {
 		ID   uuid.NullUUID
@@ -36,39 +38,40 @@ func (h *Handler) newTransaction(c *gin.Context) {
 		return
 	}
 
-	amount := numeric.Numeric{}
-	err = amount.Set(payload.Amount)
+	amount, err := numeric.Parse(payload.Amount)
 	if err != nil {
 		c.AbortWithError(http.StatusBadRequest, fmt.Errorf("amount: %w", err))
 		return
 	}
 
-	payeeID := payload.Payee.ID
-	if !payeeID.Valid && payload.Payee.Name != "" {
-		newPayee := postgres.CreatePayeeParams{
-			Name:     payload.Payee.Name,
-			BudgetID: payload.BudgetID,
+	newTransaction := postgres.CreateTransactionParams{
+		Memo:   payload.Memo,
+		Date:   time.Time(payload.Date),
+		Amount: amount,
+		Status: postgres.TransactionStatus(payload.State),
+	}
+
+	if payload.Payee.IsAccount {
+		newTransaction.GroupID = uuid.NullUUID{UUID: uuid.New(), Valid: true}
+		newTransaction.Amount = amount.Neg()
+		newTransaction.AccountID = payload.Payee.ID.UUID
+		newTransaction.CategoryID = uuid.NullUUID{}
+
+		_, err = h.Service.CreateTransaction(c.Request.Context(), newTransaction)
+		if err != nil {
+			c.AbortWithError(http.StatusInternalServerError, fmt.Errorf("create transfer transaction: %w", err))
+			return
 		}
-		payee, err := h.Service.CreatePayee(c.Request.Context(), newPayee)
+	} else {
+		payeeID, err := GetPayeeID(c.Request.Context(), payload, h)
 		if err != nil {
 			c.AbortWithError(http.StatusInternalServerError, fmt.Errorf("create payee: %w", err))
 		}
-
-		payeeID = uuid.NullUUID{
-			UUID:  payee.ID,
-			Valid: true,
-		}
+		newTransaction.PayeeID = payeeID
 	}
 
-	newTransaction := postgres.CreateTransactionParams{
-		Memo:       payload.Memo,
-		Date:       time.Time(payload.Date),
-		Amount:     amount,
-		AccountID:  payload.AccountID,
-		PayeeID:    payeeID,
-		CategoryID: payload.Category.ID,
-		Status:     postgres.TransactionStatus(payload.State),
-	}
+	newTransaction.CategoryID = payload.Category.ID
+	newTransaction.AccountID = payload.AccountID
 	transaction, err := h.Service.CreateTransaction(c.Request.Context(), newTransaction)
 	if err != nil {
 		c.AbortWithError(http.StatusInternalServerError, fmt.Errorf("create transaction: %w", err))
@@ -77,3 +80,25 @@ func (h *Handler) newTransaction(c *gin.Context) {
 
 	c.JSON(http.StatusOK, transaction)
 }
+
+func GetPayeeID(context context.Context, payload NewTransactionPayload, h *Handler) (uuid.NullUUID, error) {
+	payeeID := payload.Payee.ID
+	if payeeID.Valid {
+		return payeeID, nil
+	}
+
+	if payload.Payee.Name == "" {
+		return uuid.NullUUID{}, nil
+	}
+
+	newPayee := postgres.CreatePayeeParams{
+		Name:     payload.Payee.Name,
+		BudgetID: payload.BudgetID,
+	}
+	payee, err := h.Service.CreatePayee(context, newPayee)
+	if err != nil {
+		return uuid.NullUUID{}, fmt.Errorf("create payee: %w", err)
+	}
+
+	return uuid.NullUUID{UUID: payee.ID, Valid: true}, nil
+}