tasks

var Emit = delay.Func("webhook-emit", func(ctx context.Context, org string, event string, data interface{}) {
	log.JSON(fmt.Sprintf("Emit webhook '%s' for '%s'", event, org), data, ctx)

	db := datastore.New(ctx)
	db.SetNamespace(org)

	hooks := make([]*webhook.Webhook, 0)
	_, err := webhook.Query(db).GetAll(&hooks)
	if err != nil {
		log.Warn("Failed to retrieve webhooks for organization '%s': %v", org, err, ctx)
	}

	if len(hooks) == 0 {
		log.Debug("No webhooks defined for organization '%s'", org, ctx)
		return
	}

	client := createClient(ctx)

	for _, hook := range hooks {

		if hook.All {
			client.Post(hook.Url, Payload{
				Data:        data,
				AccessToken: hook.AccessToken,
			})
			continue
		}

		if enabled, ok := hook.Events[event]; ok && enabled {
			client.Post(hook.Url, Payload{
				Data:        data,
				AccessToken: hook.AccessToken,
			})
		}
	}
})