Method execWSRead

tests/contract/contract_test.go:472–513

(t *testing.T, s *step)

}

func (r *runner) execWSRead(t *testing.T, s *step) {
	t.Helper()
	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
	defer cancel()

	_, data, err := r.wsConn.Read(ctx)
	if err != nil {
		t.Fatalf("step %s: ws read: %v", s.ID, err)
	}

	var notif map[string]interface{}
	if err := json.Unmarshal(data, &notif); err != nil {
		t.Fatalf("step %s: unmarshal notification: %v", s.ID, err)
	}

	if s.Expect == nil {
		return
	}
	for _, field := range s.Expect.FieldsPresent {
		resolvedField := r.resolve(field)
		if _, ok := notif[resolvedField]; !ok {
			t.Fatalf("step %s: expected field %q in notification", s.ID, resolvedField)
		}
	}
	for _, field := range s.Expect.FieldsAbsent {
		resolvedField := r.resolve(field)
		if _, ok := notif[resolvedField]; ok {
			t.Fatalf("step %s: unexpected field %q in notification", s.ID, resolvedField)
		}
	}
	for key, expected := range s.Expect.FieldMatch {
		resolvedKey := r.resolve(key)
		actual, ok := notif[resolvedKey]
		if !ok {
			t.Fatalf("step %s: field %q not found in notification", s.ID, resolvedKey)
		}
		resolvedExpected := r.resolveValue(expected)
		if !valuesEqual(actual, resolvedExpected) {
			t.Fatalf("step %s: field %q = %v, want %v", s.ID, resolvedKey, actual, resolvedExpected)
		}
	}
}

func (r *runner) execVerifyAndRetry(t *testing.T, s *step) {
	t.Helper()