Function TestSubscribeOptions

tools/subscriptions/client_test.go:116–152

(t *testing.T)

}

func TestSubscribeOptions(t *testing.T) {
	c := subscriptions.NewDefaultClient()

	sub1 := "test1"
	sub2 := `test2?options={"query":{"name":123},"headers":{"X-Token":456}}`

	c.Subscribe(sub1, sub2)

	subs := c.Subscriptions()

	scenarios := []struct {
		name            string
		expectedOptions string
	}{
		{sub1, `{"query":{},"headers":{}}`},
		{sub2, `{"query":{"name":"123"},"headers":{"x_token":"456"}}`},
	}

	for _, s := range scenarios {
		t.Run(s.name, func(t *testing.T) {
			options, ok := subs[s.name]
			if !ok {
				t.Fatalf("Missing subscription \n%q \nin \n%v", s.name, subs)
			}

			rawBytes, err := json.Marshal(options)
			if err != nil {
				t.Fatal(err)
			}
			rawStr := string(rawBytes)

			if rawStr != s.expectedOptions {
				t.Fatalf("Expected options\n%v\ngot\n%v", s.expectedOptions, rawStr)
			}
		})
	}
}

func TestUnsubscribe(t *testing.T) {
	c := subscriptions.NewDefaultClient()