client_test.go

// Copyright 2021 Matt Ho
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//    http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package ogmigo

//func TestClient_ReadNext(t *testing.T) {
//	endpoint := os.Getenv("OGMIOS")
//	if endpoint == "" {
//		t.SkipNow()
//	}
//
//	var (
//		ctx     = context.Background()
//		p       = message.NewPrinter(language.English)
//		counter int64
//		read    int64
//	)
//
//	client, err := New(ctx)
//	if err != nil {
//		t.Fatalf("got %v; want nil", err)
//	}
//	defer client.Close()
//
//	for {
//		data, err := client.ReadNextMessage(ctx)
//		if err != nil {
//			t.Fatalf("got %v; want nil", err)
//		}
//
//		var response chainsync.Response
//		decoder := json.NewDecoder(bytes.NewReader(data)) // use decoder to check for unknown fields
//		decoder.DisallowUnknownFields()
//		err = decoder.Decode(&response)
//		if err != nil {
//			fmt.Println(string(data))
//		}
//		if err != nil {
//			t.Fatalf("got %v; want nil", err)
//		}
//
//		read += int64(len(data))
//		if v := atomic.AddInt64(&counter, 1); v%1e3 == 0 {
//			var blockNo uint64
//			if response.Result != nil && response.Result.RollForward != nil {
//				if ps, ok := response.Result.RollForward.Tip.PointStruct(); ok {
//					blockNo = ps.BlockNo
//				}
//			}
//			log.Printf("read: block=%v, n=%v, read=%v", blockNo, p.Sprintf("%d", v), p.Sprintf("%d", read))
//		}
//	}
//}

//func TestLive(t *testing.T) {
//	var endpoint = os.Getenv("OGMIOS")
//
//	endpoint = "ws://100.99.230.19:11337"
//	if endpoint == "" {
//		t.SkipNow()
//	}
//
//	ctx := context.Background()
//	client, err := New(ctx, WithEndpoint(endpoint), WithStore(echoStore{}))
//	if err != nil {
//		t.Fatalf("got %v; want nil", err)
//	}
//	defer client.Close()
//
//	for {
//		child, cancel:= context.WithTimeout(ctx, time.Second)
//		_, err := client.ReadNext(child)
//		if err != nil {
//			t.Fatalf("got %v; want nil", err)
//		}
//		cancel()
//	}
//}