Method Run

server/handlers/agent.go:320–400

Run runs an agent with a message

(c *gin.Context)

// Run runs an agent with a message
func (h *AgentHandler) Run(c *gin.Context) {
	ctx := c.Request.Context()
	id := c.Param("id")

	var req struct {
		Message string         `json:"message" binding:"required"`
		Context map[string]any `json:"context"`
	}

	if err := c.ShouldBindJSON(&req); err != nil {
		c.JSON(http.StatusBadRequest, gin.H{
			"success": false,
			"error": gin.H{
				"code":    "bad_request",
				"message": err.Error(),
			},
		})
		return
	}

	// Get agent record
	var agentRecord AgentRecord
	if err := (*h.store).Get(ctx, "agents", id, &agentRecord); err != nil {
		if errors.Is(err, store.ErrNotFound) {
			c.JSON(http.StatusNotFound, gin.H{
				"success": false,
				"error": gin.H{
					"code":    "not_found",
					"message": "Agent not found",
				},
			})
			return
		}
		c.JSON(http.StatusInternalServerError, gin.H{
			"success": false,
			"error": gin.H{
				"code":    "internal_error",
				"message": "Failed to get agent: " + err.Error(),
			},
		})
		return
	}

	// Create agent instance
	ag, err := agent.Create(ctx, agentRecord.Config, h.deps)
	if err != nil {
		c.JSON(http.StatusInternalServerError, gin.H{
			"success": false,
			"error": gin.H{
				"code":    "internal_error",
				"message": "Failed to create agent: " + err.Error(),
			},
		})
		return
	}
	defer func() { _ = ag.Close() }()

	// Send message