apphostgae

var AddTaskToQueue = func(c context.Context, t *taskqueue.Task, queueName string) (task *taskqueue.Task, err error) {
	if queueName == "" {
		return nil, errors.New(failedToAddTaskToQueuePrefix + "queueName is empty")
	}
	if queueName == "default" {
		return nil, errors.New(failedToAddTaskToQueuePrefix + "queueName is 'default'")
	}
	if task, err = taskqueue.Add(c, t, queueName); err != nil {
		err = fmt.Errorf("%s: %w", failedToAddTaskToQueue, err)

	}
	return
}

var CallDelayFunc = func(c context.Context, queueName, subPath string, f *delay.Function, args ...interface{}) error {
	return CallDelayFuncWithDelay(c, 0, queueName, subPath, f, args...)
}

var CallDelayFuncWithDelay = func(c context.Context, delay time.Duration, queueName, subPath string, f *delay.Function, args ...interface{}) error {
	if task, err := CreateDelayTask(queueName, subPath, f, args...); err != nil {
		return err
	} else {
		task.Delay = delay
		_, err = AddTaskToQueue(c, task, queueName)
		return err
	}
}