Method InstantReconciliation

api/reconciliation_api.go:108–145

InstantReconciliation initiates a reconciliation process with externally provided transactions without requiring a prior file upload. It processes the transactions directly and returns the reconciliation ID. Parameters: - c: The Gin context containing the request and response. Responses: - 400 Bad

(c *gin.Context)

// - 500 Internal Server Error: If there is an error starting the reconciliation process.
// - 200 OK: If the reconciliation process is successfully started.
func (a Api) InstantReconciliation(c *gin.Context) {
	var req struct {
		ExternalTransactions []model.ExternalTransaction `json:"external_transactions" binding:"required"`
		Strategy             string                      `json:"strategy" binding:"required"`
		GroupingCriteria     string                      `json:"grouping_criteria"`
		DryRun               bool                        `json:"dry_run"`
		MatchingRuleIDs      []string                    `json:"matching_rule_ids" binding:"required"`
	}

	if err := c.ShouldBindJSON(&req); err != nil {
		c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
		return
	}
	if len(req.ExternalTransactions) == 0 {
		c.JSON(http.StatusBadRequest, gin.H{"error": "external_transactions is required"})
		return
	}
	if len(req.MatchingRuleIDs) == 0 {
		c.JSON(http.StatusBadRequest, gin.H{"error": "matching_rule_ids is required"})
		return
	}

	reconciliationID, err := a.ledgerforge.StartInstantReconciliation(
		c.Request.Context(),
		req.ExternalTransactions,
		req.Strategy,
		req.GroupingCriteria,
		req.MatchingRuleIDs,
		req.DryRun,
	)
	if err != nil {
		logrus.Error(err)
		c.JSON(http.StatusInternalServerError, gin.H{"error": "Failed to start instant reconciliation"})
		return
	}

	c.JSON(http.StatusOK, gin.H{"reconciliation_id": reconciliationID})
}

// GetReconciliation retrieves details about a specific reconciliation by its ID.
//