Capture Alpaca errors in trade_order.notes + add POST /updateOrders endpoint

api/api.go

@@ -118,6 +118,7 @@ func (m ApiHandler) InitializeRouterEngine(ctx context.Context) *gin.Engine {
 	engine.GET("/publishedStrategies", m.getPublishedStrategies)
 
 	engine.POST("/rebalance", m.rebalance)
+	engine.POST("/updateOrders", m.updateOrders)
 	engine.POST("/sendSavedStrategySummaryEmails", m.sendSavedStrategySummaryEmails)
 
 	return engine
@@ -308,6 +309,14 @@ func (m ApiHandler) getGoogleAuthMiddleware(c *gin.Context) {
 	c.Next()
 }
 
+func (m ApiHandler) requireAuthenticatedUser(c *gin.Context) {
+	if _, ok := c.Get("userAccountID"); !ok {
+		returnErrorJsonCode(fmt.Errorf("authentication required"), c, 401)
+		return
+	}
+	c.Next()
+}
+
 func GetUserIDUrlParam(ctx *gin.Context) *uuid.UUID {
 	urlParams := ctx.Request.URL.Query()
 

api/update_orders.resolver.go

@@ -0,0 +1,14 @@
+package api
+
+import (
+	"github.com/gin-gonic/gin"
+)
+
+func (m ApiHandler) updateOrders(c *gin.Context) {
+	err := m.TradingService.UpdateAllPendingOrders(c.Request.Context())
+	if err != nil {
+		returnErrorJson(err, c)
+		return
+	}
+	c.JSON(200, gin.H{"success": "true"})
+}

internal/service/trade.service.go

@@ -109,6 +109,22 @@ func (h tradeServiceHandler) placeOrder(
 		LimitPrice:   &limit,
 	})
 	if err != nil {
+		// persist the error message in the trade order notes for debugging
+		prefix := ""
+		if insertedOrder.Notes != nil && *insertedOrder.Notes != "" {
+			prefix = *insertedOrder.Notes + " | "
+		}
+		errMsg := fmt.Sprintf("%sorder for trade request %s %s %s failed: %s", prefix, alpacaSide, symbol, quantity.String(), err.Error())
+		_, noteErr := h.TradeOrderRepository.Update(nil,
+			insertedOrder.TradeOrderID,
+			model.TradeOrder{
+				Notes: &errMsg,
+			}, postgres.ColumnList{
+				table.TradeOrder.Notes,
+			})
+		if noteErr != nil {
+			return nil, fmt.Errorf("failed to execute order for trade order %s: %w (also failed to persist notes: %v)", insertedOrder.TradeOrderID, err, noteErr)
+		}
 		return nil, fmt.Errorf("failed to execute order for trade order %s: %w", insertedOrder.TradeOrderID, err)
 	}