Function NewWebhook

db/event_handler.go:53–85

Creates a new webhook handler based on the url and filter function.

(ctx context.Context, url string, filterFnString string, timeout *uint64, options map[string]interface{})

// Creates a new webhook handler based on the url and filter function.
func NewWebhook(ctx context.Context, url string, filterFnString string, timeout *uint64, options map[string]interface{}) (*Webhook, error) {

	var err error

	if url == "" {
		err = errors.New("url parameter must be defined for webhook events.")
		return nil, err
	}

	wh := &Webhook{
		url: url,
	}
	if filterFnString != "" {
		wh.filter = NewJSEventFunction(ctx, filterFnString)
	}

	if timeout != nil {
		wh.timeout = time.Duration(*timeout) * time.Second
	} else {
		wh.timeout = time.Duration(kDefaultWebhookTimeout) * time.Second
	}

	// Initialize transport and client
	transport := base.DefaultHTTPTransport()
	transport.DisableKeepAlives = false
	wh.client = &http.Client{Transport: transport, Timeout: wh.timeout}

	if options != nil {
		wh.options.DocumentChangedWinningRevOnly, _ = options[EventOptionDocumentChangedWinningRevOnly].(bool)
	}

	return wh, err
}

// Performs an HTTP POST to the url defined for the handler.  If a filter function is defined,
// calls it to determine whether to POST.  The payload for the POST is depends