Function TestWebhookOverflows

db/event_manager_test.go:528–621

(t *testing.T)

}

func TestWebhookOverflows(t *testing.T) {
	if true { // Modify conditions or re-enable once CBG-2281 is fixed
		t.Skip("Test skipped")
	}
	base.LongRunningTest(t)

	terminator := make(chan bool)
	defer close(terminator)

	ts, wr := InitWebhookTest()
	defer ts.Close()
	url := ts.URL

	ids := make([]string, 200)
	for i := 0; i < 200; i++ {
		ids[i] = fmt.Sprintf("%d", i)
	}

	eventForTest := func(i int) (Body, string, base.Set) {
		testBody := Body{
			BodyId:  ids[i],
			"value": i,
		}
		var channelSet base.Set
		if i%2 == 0 {
			channelSet = base.SetFromArray([]string{"Even"})
		} else {
			channelSet = base.SetFromArray([]string{"Odd"})
		}
		return testBody, ids[i], channelSet
	}

	// Test fast fill, fast webhook
	log.Println("Test fast fill, fast webhook")
	wr.Clear()
	em := NewEventManager(terminator)
	ctx := base.TestCtx(t)
	em.Start(ctx, 5, -1)
	timeout := uint64(60)
	webhookHandler, _ := NewWebhook(ctx, fmt.Sprintf("%s/echo", url), "", &timeout, nil)
	em.RegisterEventHandler(ctx, webhookHandler, DocumentChange)
	for i := 0; i < 100; i++ {
		body, docId, channels := eventForTest(i % 10)
		bodyBytes := base.MustJSONMarshal(t, body)
		err := em.RaiseDocumentChangeEvent(ctx, bodyBytes, docId, "", channels, false)
		assert.NoError(t, err)
	}
	err := em.waitForProcessedTotal(ctx, 100, DefaultWaitForWebhook)
	assert.NoError(t, err)
	assert.Equal(t, int64(100), em.GetEventsProcessedSuccess())

	// CBG-2281 skip test temporarily under windows
	// if runtime.GOOS != "windows" {
	// Test queue full, slow webhook.  Drops events
	log.Println("Test queue full, slow webhook")
	wr.Clear()
	errCount := 0
	em = NewEventManager(terminator)