Function TestUnavailableWebhook

db/event_manager_test.go:890–932

(t *testing.T)

}

func TestUnavailableWebhook(t *testing.T) {
	ts, wr := InitWebhookTest()
	defer ts.Close()

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

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

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

	// Test unreachable webhook

	em := NewEventManager(terminator)
	ctx := base.TestCtx(t)
	em.Start(ctx, 0, -1)
	webhookHandler, _ := NewWebhook(ctx, "http://badhost:1000/echo", "", nil, nil)
	em.RegisterEventHandler(ctx, webhookHandler, DocumentChange)
	for i := 0; i < 10; i++ {
		body, docId, channels := eventForTest(strconv.Itoa(-i), i)
		bodyBytes := base.MustJSONMarshal(t, body)
		err := em.RaiseDocumentChangeEvent(ctx, bodyBytes, docId, "", channels, false)
		assert.NoError(t, err)
	}
	time.Sleep(50 * time.Millisecond)
	assert.Equal(t, 0, wr.GetCount())

}

// asserts that the number of items seen in the channel within the specified time limit is the same as the expected value.
// WARNING: This function will drain the channel of items!