(baseURL string, app *models.App, t *models.Trigger)
| 16 | type requestBasedTriggerAnnotator struct{} |
| 17 | |
| 18 | func annotateTriggerWithBaseURL(baseURL string, app *models.App, t *models.Trigger) (*models.Trigger, error) { |
| 19 | if t.Type != models.TriggerTypeHTTP { |
| 20 | return t, nil |
| 21 | } |
| 22 | |
| 23 | baseURL = strings.TrimSuffix(baseURL, "/") |
| 24 | src := strings.TrimPrefix(t.Source, "/") |
| 25 | triggerPath := fmt.Sprintf("%s/t/%s/%s", baseURL, app.Name, src) |
| 26 | |
| 27 | newT := t.Clone() |
| 28 | newAnnotations, err := newT.Annotations.With(models.TriggerHTTPEndpointAnnotation, triggerPath) |
| 29 | if err != nil { |
| 30 | return nil, err |
| 31 | } |
| 32 | newT.Annotations = newAnnotations |
| 33 | return newT, nil |
| 34 | } |
| 35 | |
| 36 | func (tp *requestBasedTriggerAnnotator) AnnotateTrigger(ctx *gin.Context, app *models.App, t *models.Trigger) (*models.Trigger, error) { |
| 37 |
no test coverage detected