POC for /block

.gitignore

@@ -0,0 +1 @@
+.idea

README.md

@@ -1,5 +1,25 @@
-# RPC Companion 
-
-### WIP (Work In Progress)
+# RPC Companion (Work In Progress)
 
 This is the repository for the RPC Companion solution based on the Data Companion ADR
+
+## Starting the Postgres Database
+
+Access the Docker folder:
+
+`cd ./database/docker`
+
+Run the services
+
+`docker-compose -f docker-compose.yml up`
+
+## Accessing the database with pgAdmin
+
+Open a browser and navigate to
+http://127.0.0.1:5050
+
+Use the following credentials:
+
+```
+User: [email protected]
+Password: pgadmin123
+```

commands/ingest/ingest.go

@@ -0,0 +1,21 @@
+package ingest
+
+import (
+	"github.com/spf13/cobra"
+)
+
+// IngestCmd ingest service commands
+var IngestCmd = &cobra.Command{
+	Use:   "ingest",
+	Short: "Ingest Service commands",
+	Long: `The Ingest Service pulls data from a CometBFT full node and store the information in a database. 
+
+There should be just one running instance of the Ingest Service targeting a full node.`,
+	Run: func(cmd *cobra.Command, args []string) {
+		cmd.Help()
+	},
+}
+
+func init() {
+	IngestCmd.AddCommand(StartCmd)
+}

commands/ingest/start.go

@@ -0,0 +1,52 @@
+package ingest
+
+import (
+	"fmt"
+	"github.com/cometbft/rpc-companion/ingest"
+	"github.com/spf13/cobra"
+	"log"
+	"os"
+	"strconv"
+)
+
+// TODO: make this configurable via a config or parameter
+const connString = "postgres://postgres:[email protected]:15432/postgres?sslmode=disable"
+
+// StartCmd start ingest service
+var StartCmd = &cobra.Command{
+	Use:   "start",
+	Short: "Start Ingest Service",
+	Long:  `The start command runs an instance of the Ingest Service`,
+	Run: func(cmd *cobra.Command, args []string) {
+
+		//Instantiate a new Ingest Service
+		ingestSvc := ingest.NewService(connString)
+
+		//Insert some blocks
+		numberHeights := int64(10)
+		initialHeightParameter := os.Getenv("COMPANION_INITIAL_HEIGHT")
+		initialHeight, err := strconv.ParseInt(initialHeightParameter, 10, 64)
+		if err != nil {
+			fmt.Printf("Invalid initial height %s: %s\n", initialHeightParameter, err)
+		}
+
+		for height := initialHeight; height <= initialHeight+numberHeights; height++ {
+
+			blockFetched, err := ingestSvc.Fetcher.FetchBlock(int64(height))
+			if err != nil {
+				log.Fatalf("Error fetching block at height %d: %s\n", height, err)
+			}
+
+			inserted, err := ingestSvc.Storage.InsertBlock(*blockFetched)
+			if err != nil {
+				fmt.Printf("Error inserting block at height %d: %s\n", height, err)
+			}
+			if inserted {
+				fmt.Printf("Inserted height %d\n", height)
+			}
+		}
+	},
+}
+
+func init() {
+}

commands/root.go

@@ -0,0 +1,39 @@
+package commands
+
+import (
+	ingest "github.com/cometbft/rpc-companion/commands/ingest"
+	rpc "github.com/cometbft/rpc-companion/commands/rpc"
+	"github.com/spf13/cobra"
+)
+
+// RootCmd represents the base command when called without any subcommands
+var RootCmd = &cobra.Command{
+	Use:   "rpc-companion",
+	Short: "RPC Companion - CometBFT",
+	Long:  `RPC Companion is an implementation of a Data Companion for CometBFT based chains`,
+}
+
+// Execute adds all child commands to the root command and sets flags appropriately.
+// This is called by main.main(). It only needs to happen once to the rootCmd.
+func Execute() {
+	cobra.CheckErr(RootCmd.Execute())
+}
+
+func init() {
+
+	options := cobra.CompletionOptions{
+		DisableDefaultCmd:   true,
+		DisableNoDescFlag:   true,
+		DisableDescriptions: false,
+	}
+	RootCmd.CompletionOptions = options
+
+	cobra.EnableCommandSorting = true
+
+	RootCmd.AddCommand(ingest.IngestCmd)
+	RootCmd.AddCommand(rpc.RpcCmd)
+}
+
+func initConfig() {
+
+}

commands/rpc/rpc.go

@@ -0,0 +1,19 @@
+package rpc
+
+import (
+	"github.com/spf13/cobra"
+)
+
+// RpcCmd RPC service commands
+var RpcCmd = &cobra.Command{
+	Use:   "rpc",
+	Short: "RPC Service commands",
+	Long:  `The RPC Service expose a RPC endpoint compatible with the CometBFT RPC endpoint.`,
+	Run: func(cmd *cobra.Command, args []string) {
+		cmd.Help()
+	},
+}
+
+func init() {
+	RpcCmd.AddCommand(StartCmd)
+}

commands/rpc/start.go

@@ -0,0 +1,27 @@
+package rpc
+
+import (
+	"github.com/cometbft/rpc-companion/rpc"
+	"github.com/spf13/cobra"
+)
+
+// TODO: make this configurable via a config or parameter
+const connString = "postgres://postgres:[email protected]:15432/postgres?sslmode=disable"
+
+// StartCmd start RPC service
+var StartCmd = &cobra.Command{
+	Use:   "start",
+	Short: "Start RPC Service",
+	Long:  `The start command runs an instance of the RPC Service`,
+	Run: func(cmd *cobra.Command, args []string) {
+
+		//Instantiate a new Ingest Service
+		rpcSvc := rpc.NewService(connString)
+
+		//Start the service
+		rpcSvc.Serve()
+	},
+}
+
+func init() {
+}

database/docker/docker-compose.yml

@@ -1,7 +1,7 @@
 version: '3.9'
 services:
   docker_postgres:
-    image: postgres:15.2-alpine
+    image: postgres:15.3-alpine
     restart: always
     environment:
       - POSTGRES_DB=postgres