Method sendNotification

api/pkg/services/webhook_service.go:210–260

(ctx context.Context, event cloudevents.Event, owner string, webhook *entities.Webhook)

}

func (service *WebhookService) sendNotification(ctx context.Context, event cloudevents.Event, owner string, webhook *entities.Webhook) {
	ctx, span, ctxLogger := service.tracer.StartWithLogger(ctx, service.logger)
	defer span.End()

	attempts := 0
	err := retry.New(retry.Attempts(2)).Do(func() error {
		attempts++

		requestCtx, cancel := context.WithTimeout(ctx, 5*time.Second)
		defer cancel()

		request, err := service.createRequest(requestCtx, event, webhook)
		if err != nil {
			msg := fmt.Sprintf("cannot create [%s] event to webhook [%s] for user [%s] after [%d] attempts", event.Type(), webhook.URL, webhook.UserID, attempts)
			return service.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg))
		}

		response, err := service.client.Do(request)
		if err != nil {
			ctxLogger.Warn(stacktrace.Propagate(err, fmt.Sprintf("cannot send [%s] event to webhook [%s] for user [%s] after [%d] attempts", event.Type(), webhook.URL, webhook.UserID, attempts)))
			if attempts == 1 {
				return err
			}
			service.handleWebhookSendFailed(ctx, event, webhook, owner, err, response)
			return nil
		}

		defer func() {
			err = response.Body.Close()
			if err != nil {
				ctxLogger.Error(stacktrace.Propagate(err, fmt.Sprintf("cannot close response body for [%s] event with ID [%s] after [%d] attempts", event.Type(), event.ID(), attempts)))
			}
		}()

		if response.StatusCode >= 400 {
			ctxLogger.Info(fmt.Sprintf("cannot send [%s] event to webhook [%s] for user [%s] with response code [%d] after [%d] attempts", event.Type(), webhook.URL, webhook.UserID, response.StatusCode, attempts))
			if attempts == 1 {
				return stacktrace.NewError(http.StatusText(response.StatusCode))
			}
			service.handleWebhookSendFailed(ctx, event, webhook, owner, stacktrace.NewError(http.StatusText(response.StatusCode)), response)
			return nil
		}

		ctxLogger.Info(fmt.Sprintf("sent webhook to url [%s] for event [%s] with ID [%s] and response code [%d]", webhook.URL, event.Type(), event.ID(), response.StatusCode))
		return nil
	})
	if err != nil {
		msg := fmt.Sprintf("cannot handle [%s] event to webhook [%s] for user [%s] after [%d] attempts", event.Type(), webhook.URL, webhook.UserID, attempts)
		ctxLogger.Error(service.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg)))
	}
}

func (service *WebhookService) createRequest(ctx context.Context, event cloudevents.Event, webhook *entities.Webhook) (*http.Request, error) {
	ctx, span, ctxLogger := service.tracer.StartWithLogger(ctx, service.logger)