Method ProcessWebhook

webhooks.go:162–181

ProcessWebhook processes a webhook notification task from the queue. Parameters: - _ context.Context: The context for the operation. - task *asynq.Task: The task containing the webhook notification data. Returns: - error: An error if the webhook processing fails.

(_ context.Context, task *asynq.Task)

// Returns:
// - error: An error if the webhook processing fails.
func (b *LedgerForge) ProcessWebhook(_ context.Context, task *asynq.Task) error {
	conf, err := config.Fetch()
	if err != nil {
		return err
	}

	if conf.Notification.Webhook.Url == "" {
		return nil
	}
	var payload NewWebhook
	if err := json.Unmarshal(task.Payload(), &payload); err != nil {
		logrus.Errorf("Error unmarshaling task payload: %v", err)
		return err
	}
	err = processHTTP(payload, b.httpClient)
	if err != nil {
		return err
	}
	return nil
}