Method SetPipeWebhook

controllers/pipe.go:167–198

SetPipeWebhook calls the pipe's chat platform API to register the webhook URL. @Title SetPipeWebhook @Tag Pipe API @Description set webhook for a pipe @Param id query string true "The id of the pipe (owner/name)" @Success 200 {object} controllers.Response The Response object @router /api/set-pipe-we

()

// @Success 200 {object} controllers.Response The Response object
// @router /api/set-pipe-webhook [post]
func (c *ApiController) SetPipeWebhook() {
	id := c.Input().Get("id")

	pipe, err := object.GetPipe(id)
	if err != nil {
		c.ResponseError(err.Error())
		return
	}
	if pipe == nil {
		c.ResponseError("pipe not found")
		return
	}

	pipeObj, err := pipe.GetProvider(c.GetAcceptLanguage())
	if err != nil {
		c.ResponseError(err.Error())
		return
	}

	if pipe.Domain == "" {
		c.ResponseError("Domain is not set on this pipe")
		return
	}

	webhookUrl := fmt.Sprintf("%s/api/chat-webhook/%s/%s", pipe.Domain, pipepkg.NormalizeType(pipe.Type), pipe.Name)
	if err = pipeObj.SetWebhook(webhookUrl); err != nil {
		c.ResponseError(err.Error())
		return
	}

	c.ResponseOk(webhookUrl)
}

// ChatTest sends a test message through the pipe to verify the full pipeline.
// @Title ChatTest