Skip to content

Commit

Permalink
Merge pull request #372 from blinklabs-io/feat/chain-tip-test-program
Browse files Browse the repository at this point in the history
feat: chain-tip test program
  • Loading branch information
agaffney authored Aug 17, 2023
2 parents 199fc0e + 2011637 commit 13fd829
Show file tree
Hide file tree
Showing 2 changed files with 67 additions and 0 deletions.
1 change: 1 addition & 0 deletions .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@
/block-fetch
/peer-sharing
/tx-submission
/chain-tip

# Test binary, built with `go test -c`
*.test
Expand Down
66 changes: 66 additions & 0 deletions cmd/chain-tip/main.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,66 @@
// Copyright 2023 Blink Labs, LLC.
//
// 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 main

import (
"fmt"
"os"

ouroboros "github.com/blinklabs-io/gouroboros"
"github.com/blinklabs-io/gouroboros/cmd/common"
)

type txSubmissionFlags struct {
*common.GlobalFlags
}

func main() {
// Parse commandline
f := txSubmissionFlags{
GlobalFlags: common.NewGlobalFlags(),
}
f.Parse()
// Create connection
conn := common.CreateClientConnection(f.GlobalFlags)
errorChan := make(chan error)
go func() {
for {
err := <-errorChan
fmt.Printf("ERROR(async): %s\n", err)
os.Exit(1)
}
}()
o, err := ouroboros.New(
ouroboros.WithConnection(conn),
ouroboros.WithNetworkMagic(uint32(f.NetworkMagic)),
ouroboros.WithErrorChan(errorChan),
ouroboros.WithNodeToNode(f.NtnProto),
ouroboros.WithKeepAlive(true),
)
if err != nil {
fmt.Printf("ERROR: %s\n", err)
os.Exit(1)
}

tip, err := o.ChainSync().Client.GetCurrentTip()
if err != nil {
fmt.Printf("ERROR: %s\n", err)
os.Exit(1)
}

fmt.Print("Current chain tip:\n\n")
fmt.Printf("Block hash: %x\n", tip.Point.Hash)
fmt.Printf("Slot number: %d\n", tip.Point.Slot)
}

0 comments on commit 13fd829

Please sign in to comment.