util

Documentation

Index

• Variables
• func FireWebhooks(m *nats.Msg)
• func PostWebhook(wh model.Webhook, event string, whData model.WebhookData)

Variables

var ConnectNats = func() {
	var err error
	nc, err := nats.Connect(viper.GetString("nats_url"), nats.UserInfo(viper.GetString("nats_user_name"), viper.GetString("nats_user_password")))
	if err != nil {
		log.Fatal(err)
	}
	NC, _ = nats.NewEncodedConn(nc, nats.JSON_ENCODER)
}

ConnectNats connect to nats server

var NC *nats.EncodedConn

NC nats connection object

var SubscribeEvents = func(events ...string) error {
	for _, event := range events {
		_, err := NC.QueueSubscribe(event, viper.GetString("queue_group"), FireWebhooks)
		if err != nil {
			return err
		}
	}
	return nil
}

SubscribeEvents subscribe one or more events

var SubscribeExistingEvents = func() error {
	events := make([]model.Event, 0)

	config.DB.Model(&model.Event{}).Find(&events)

	eventNames := make([]string, 0)
	if len(events) > 0 {
		for _, event := range events {
			eventNames = append(eventNames, event.Event)
		}
	}

	return SubscribeEvents(eventNames...)
}

SubscribeExistingEvents subscribe existing events

Functions

func FireWebhooks

func FireWebhooks(m *nats.Msg)

FireWebhooks fires webhook for a event

func PostWebhook

func PostWebhook(wh model.Webhook, event string, whData model.WebhookData)

PostWebhook does POST request to given URL