Method TestStream

pkg/serve/controller/test_controller.go:157–177

TestStream handles simple SSE streaming test endpoint @Router /api/v1/test/testStream [post]

(c *gin.Context)

// TestStream handles simple SSE streaming test endpoint
// @Router /api/v1/test/testStream [post]
func (tc *TestController) TestStream(c *gin.Context) {
	req := &dto.TestStreamRequest{}
	if err := c.ShouldBindJSON(req); err != nil {
		c.JSON(http.StatusBadRequest, vo.Fail(c, err, errorx.New(errno.ErrInvalidParams, errorx.KV("msg", "bind JSON failed"))))
		return
	}

	errors := validator.Validate(req)
	if errors != nil {
		c.JSON(http.StatusBadRequest, vo.Fail(c, errors, errorx.New(errno.ErrInvalidParams, errorx.KV("msg", "validation failed"))))
		return
	}

	events, err := tc.testService.TestStream(c, req)
	if err != nil {
		c.JSON(http.StatusInternalServerError, vo.Fail(c, err, errorx.New(errno.ErrInternalServer)))
		return
	}

	_ = tc.sseManager.StreamToClient(c, events)
}