| 339 | } |
| 340 | |
| 341 | func (service *WebhookService) getAuthToken(webhook *entities.Webhook) (string, error) { |
| 342 | token := jwt.NewWithClaims(jwt.SigningMethodHS256, jwt.RegisteredClaims{ |
| 343 | Audience: []string{webhook.URL}, |
| 344 | ExpiresAt: jwt.NewNumericDate(time.Now().UTC().Add(10 * time.Minute)), |
| 345 | IssuedAt: jwt.NewNumericDate(time.Now().UTC()), |
| 346 | Issuer: "api.httpsms.com", |
| 347 | NotBefore: jwt.NewNumericDate(time.Now().UTC().Add(-10 * time.Minute)), |
| 348 | Subject: string(webhook.UserID), |
| 349 | }) |
| 350 | return token.SignedString([]byte(webhook.SigningKey)) |
| 351 | } |
| 352 | |
| 353 | func (service *WebhookService) handleWebhookSendFailed(ctx context.Context, event cloudevents.Event, webhook *entities.Webhook, owner string, err error, response *http.Response) { |
| 354 | ctx, span, ctxLogger := service.tracer.StartWithLogger(ctx, service.logger) |