chore: add golines to makefile and execute (#177)

Signed-off-by: Chris Gianelloni <[email protected]>

Makefile

@@ -28,6 +28,9 @@ clean:
 format: mod-tidy
 	go fmt ./...
 
+golines:
+	golines -w --ignore-generated --chain-split-dots --max-len=80 --reformat-tags .
+
 test:
 	go test -v -race ./...
 

cmd/cardano-node-api/main.go

@@ -70,7 +70,10 @@ func main() {
 		oConn.Close()
 	}
 
-	logger.Infof("starting cardano-node-api version %s", version.GetVersionString())
+	logger.Infof(
+		"starting cardano-node-api version %s",
+		version.GetVersionString(),
+	)
 
 	// Start debug listener
 	if cfg.Debug.ListenPort > 0 {

internal/api/api.go

@@ -30,18 +30,18 @@ import (
 	ginSwagger "github.com/swaggo/gin-swagger"        // gin-swagger middleware
 )
 
-//	@title			cardano-node-api
-//	@version		1.0
-//	@description	Cardano Node API
-//	@host			localhost
-//	@Schemes		http
-//	@BasePath		/api
-//	@contact.name	Blink Labs
-//	@contact.url	https://blinklabs.io
-//	@contact.email	[email protected]
+// @title			cardano-node-api
+// @version		1.0
+// @description	Cardano Node API
+// @host			localhost
+// @Schemes		http
+// @BasePath		/api
+// @contact.name	Blink Labs
+// @contact.url	https://blinklabs.io
+// @contact.email	[email protected]
 //
-//	@license.name	Apache 2.0
-//	@license.url	http://www.apache.org/licenses/LICENSE-2.0.html
+// @license.name	Apache 2.0
+// @license.url	http://www.apache.org/licenses/LICENSE-2.0.html
 func Start(cfg *config.Config) error {
 	// Disable gin debug and color output
 	gin.SetMode(gin.ReleaseMode)

internal/api/chainsync.go

@@ -61,7 +61,12 @@ func handleChainSyncSync(c *gin.Context) {
 		return
 	}
 	if !req.Tip && (req.Slot == 0 || req.Hash == "") {
-		c.JSON(http.StatusBadRequest, apiError("you must provide the 'slot' and 'hash' parameters or set 'tip' to True"))
+		c.JSON(
+			http.StatusBadRequest,
+			apiError(
+				"you must provide the 'slot' and 'hash' parameters or set 'tip' to True",
+			),
+		)
 		return
 	}
 	// Setup event channel

internal/utxorpc/api.go

@@ -30,10 +30,18 @@ import (
 
 func Start(cfg *config.Config) error {
 	mux := http.NewServeMux()
-	queryPath, queryHandler := queryconnect.NewQueryServiceHandler(&queryServiceServer{})
-	submitPath, submitHandler := submitconnect.NewSubmitServiceHandler(&submitServiceServer{})
-	syncPath, syncHandler := syncconnect.NewChainSyncServiceHandler(&chainSyncServiceServer{})
-	watchPath, watchHandler := watchconnect.NewWatchServiceHandler(&watchServiceServer{})
+	queryPath, queryHandler := queryconnect.NewQueryServiceHandler(
+		&queryServiceServer{},
+	)
+	submitPath, submitHandler := submitconnect.NewSubmitServiceHandler(
+		&submitServiceServer{},
+	)
+	syncPath, syncHandler := syncconnect.NewChainSyncServiceHandler(
+		&chainSyncServiceServer{},
+	)
+	watchPath, watchHandler := watchconnect.NewWatchServiceHandler(
+		&watchServiceServer{},
+	)
 	mux.Handle(queryPath, queryHandler)
 	mux.Handle(submitPath, submitHandler)
 	mux.Handle(syncPath, syncHandler)

internal/utxorpc/query.go

@@ -111,7 +111,7 @@ func (s *queryServiceServer) ReadUtxos(
 	for _, txo := range keys {
 		// txo.Hash, txo.Index
 		tmpTxIn := ledger.ShelleyTransactionInput{
-			TxId: ledger.Blake2b256(txo.Hash),
+			TxId:        ledger.Blake2b256(txo.Hash),
 			OutputIndex: uint32(txo.Index),
 		}
 		tmpTxIns = append(tmpTxIns, tmpTxIn)
@@ -137,7 +137,8 @@ func (s *queryServiceServer) ReadUtxos(
 			var audc query.AnyUtxoData_Cardano
 			aud.TxoRef = txo
 			txHash := hex.EncodeToString(txo.Hash)
-			if utxoId.Hash.String() == txHash && uint32(utxoId.Idx) == txo.Index {
+			if utxoId.Hash.String() == txHash &&
+				uint32(utxoId.Idx) == txo.Index {
 				aud.NativeBytes = utxo.Cbor()
 				audc.Cardano = utxo.Utxorpc()
 				aud.ParsedState = &audc

internal/utxorpc/submit.go

@@ -75,7 +75,10 @@ func (s *submitServiceServer) SubmitTx(
 			continue
 		}
 		// Submit the transaction
-		err = oConn.LocalTxSubmission().Client.SubmitTx(uint16(txType), txRawBytes)
+		err = oConn.LocalTxSubmission().Client.SubmitTx(
+			uint16(txType),
+			txRawBytes,
+		)
 		if err != nil {
 			resp.Ref = append(resp.Ref, placeholderRef)
 			errorList[i] = fmt.Errorf("%s", err.Error())

internal/utxorpc/sync.go

@@ -42,7 +42,11 @@ func (s *chainSyncServiceServer) FetchBlock(
 ) (*connect.Response[sync.FetchBlockResponse], error) {
 	ref := req.Msg.GetRef() // BlockRef
 	fieldMask := req.Msg.GetFieldMask()
-	log.Printf("Got a FetchBlock request with ref %v and fieldMask %v", ref, fieldMask)
+	log.Printf(
+		"Got a FetchBlock request with ref %v and fieldMask %v",
+		ref,
+		fieldMask,
+	)
 
 	// Connect to node
 	oConn, err := node.GetConnection(nil)
@@ -103,7 +107,12 @@ func (s *chainSyncServiceServer) DumpHistory(
 	startToken := req.Msg.GetStartToken() // BlockRef
 	maxItems := req.Msg.GetMaxItems()
 	fieldMask := req.Msg.GetFieldMask()
-	log.Printf("Got a DumpHistory request with token %v and maxItems %d and fieldMask %v", startToken, maxItems, fieldMask)
+	log.Printf(
+		"Got a DumpHistory request with token %v and maxItems %d and fieldMask %v",
+		startToken,
+		maxItems,
+		fieldMask,
+	)
 
 	// Connect to node
 	oConn, err := node.GetConnection(nil)
@@ -135,7 +144,11 @@ func (s *chainSyncServiceServer) DumpHistory(
 		}
 		startPoint = tip.Point
 	}
-	log.Printf("startPoint slot %d, hash %x\n", startPoint.Slot, startPoint.Hash)
+	log.Printf(
+		"startPoint slot %d, hash %x\n",
+		startPoint.Slot,
+		startPoint.Hash,
+	)
 	// TODO: why is this giving us 0?
 	start, end, err := oConn.ChainSync().Client.GetAvailableBlockRange(
 		[]ocommon.Point{startPoint},

internal/utxorpc/watch.go

@@ -42,7 +42,11 @@ func (s *watchServiceServer) WatchTx(
 ) error {
 	predicate := req.Msg.GetPredicate() // Predicate
 	fieldMask := req.Msg.GetFieldMask()
-	log.Printf("Got a WatchTx request with predicate %v and fieldMask %v", predicate, fieldMask)
+	log.Printf(
+		"Got a WatchTx request with predicate %v and fieldMask %v",
+		predicate,
+		fieldMask,
+	)
 
 	// Setup event channel
 	eventChan := make(chan event.Event, 10)