Method ProcessHookTask

internal/hooks/worker.go:39–55

ProcessHookTask processes a hook execution task from the queue. It unmarshals the task payload, creates a context with timeout based on hook configuration, and executes the hook. Parameters: - ctx: The context for the operation. - task: The Asynq task containing the hook execution details. Returns

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

// Returns:
// - error: An error if hook execution fails.
func (m *redisHookManager) ProcessHookTask(ctx context.Context, task *asynq.Task) error {
	var taskPayload HookTaskPayload
	if err := json.Unmarshal(task.Payload(), &taskPayload); err != nil {
		return fmt.Errorf("failed to unmarshal hook task payload: %w", err)
	}

	// Add timeout to context based on hook configuration
	hookCtx, cancel := context.WithTimeout(ctx, time.Duration(taskPayload.Hook.Timeout)*time.Second)
	defer cancel()

	logrus.WithFields(logrus.Fields{
		"hook_id":   taskPayload.Hook.ID,
		"hook_type": taskPayload.Hook.Type,
	}).Info("Processing queued hook task")

	return m.executeHook(hookCtx, taskPayload.Hook, taskPayload.Payload)
}