PRT tool WIP

Author: mpernambuco

.gitignore

@@ -19,3 +19,4 @@ machine-snapshot/**
 /applications
 /test/downloads
 /snapshots
+compose.override.yml

Makefile

@@ -55,11 +55,14 @@ DOCKER_PLATFORM=--platform $(BUILD_PLATFORM)
 endif
 
 # Go artifacts
-GO_ARTIFACTS := cartesi-rollups-node cartesi-rollups-cli cartesi-rollups-evm-reader cartesi-rollups-advancer cartesi-rollups-validator cartesi-rollups-claimer cartesi-rollups-jsonrpc-api
+GO_ARTIFACTS := cartesi-rollups-node cartesi-rollups-cli cartesi-rollups-evm-reader cartesi-rollups-advancer cartesi-rollups-validator cartesi-rollups-prt cartesi-rollups-claimer cartesi-rollups-jsonrpc-api
 
 # fixme(vfusco): path on all oses
-CGO_CFLAGS:= -I$(PREFIX)/include
-CGO_LDFLAGS:= -L$(PREFIX)/lib
+# /Users/mpernambuco/ctsi2/cartesi-install-dir
+CGO_CFLAGS:= -I/Users/mpernambuco/ctsi2/cartesi-install-dir/usr/include
+CGO_LDFLAGS:= -L/Users/mpernambuco/ctsi2/cartesi-install-dir/usr/lib
+# CGO_CFLAGS:= -I$(PREFIX)/include
+# CGO_LDFLAGS:= -L$(PREFIX)/lib
 export CGO_CFLAGS
 export CGO_LDFLAGS
 

cmd/cartesi-rollups-cli/root/deploy/application.go

@@ -150,8 +150,12 @@ func runDeployApplication(cmd *cobra.Command, args []string) {
 		}
 	}
 
+	application := model.Application{}
+	application.ConsensusType = model.ConsensusType_Authority
+
 	var deployment ethutil.IApplicationDeployment
 	if deploymentTypePRT {
+		application.ConsensusType = model.ConsensusType_Prt
 		deployment, err = buildPrtApplicationDeployment(cmd, args, client, txOpts)
 	} else if deploySelfhosted := !cmd.Flags().Changed("consensus"); deploySelfhosted {
 		deployment, err = buildSelfhostedApplicationDeployment(cmd, args, client, txOpts)
@@ -193,8 +197,6 @@ func runDeployApplication(cmd *cobra.Command, args []string) {
 		fmt.Fprint(os.Stderr, result)
 	}
 
-	application := model.Application{}
-
 	application.Name = applicationName
 	application.TemplateURI = templateURI
 	application.State = model.ApplicationState_Disabled
@@ -249,7 +251,6 @@ func runDeployApplication(cmd *cobra.Command, args []string) {
 			cobra.CheckErr(fmt.Errorf("failed to register application: %w", err))
 		}
 		defer repo.Close()
-
 		_, err = repo.CreateApplication(ctx, &application)
 		if err != nil {
 			cobra.CheckErr(fmt.Errorf("failed to register application: %w", err))

cmd/cartesi-rollups-node/root/root.go

@@ -32,6 +32,7 @@ var (
 	advancerPollInterval   string
 	validatorPollInterval  string
 	claimerPollInterval    string
+	prtPollInterval        string
 	maxStartupTime         string
 	enableInputReader      bool
 	enableInspect          bool

cmd/cartesi-rollups-prt/main.go

@@ -0,0 +1,17 @@
+// (c) Cartesi and individual authors (see AUTHORS)
+// SPDX-License-Identifier: Apache-2.0 (see LICENSE)
+
+package main
+
+import (
+	"os"
+
+	"github.com/cartesi/rollups-node/cmd/cartesi-rollups-prt/root"
+)
+
+func main() {
+	err := root.Cmd.Execute()
+	if err != nil {
+		os.Exit(1)
+	}
+}

cmd/cartesi-rollups-prt/root/root.go

@@ -0,0 +1,117 @@
+// (c) Cartesi and individual authors (see AUTHORS)
+// SPDX-License-Identifier: Apache-2.0 (see LICENSE)
+
+package root
+
+import (
+	"context"
+
+	"github.com/cartesi/rollups-node/internal/config"
+	"github.com/cartesi/rollups-node/internal/prt"
+	"github.com/cartesi/rollups-node/internal/repository/factory"
+	"github.com/cartesi/rollups-node/internal/version"
+	"github.com/cartesi/rollups-node/pkg/service"
+
+	"github.com/spf13/cobra"
+	"github.com/spf13/viper"
+)
+
+const serviceName = "prt"
+
+var (
+	logLevel               string
+	logColor               bool
+	databaseConnection     string
+	pollInterval           string
+	maxStartupTime         string
+	telemetryAddress       string
+	inspectAddress         string
+	machinelogLevel        string
+	enableMachineHashCheck bool
+	enableInspect          bool
+	// PRT-specific flags
+	cfg *config.PrtConfig
+)
+
+var Cmd = &cobra.Command{
+	Use:     "cartesi-rollups-" + serviceName,
+	Short:   "Runs cartesi-rollups-" + serviceName,
+	Long:    "Runs cartesi-rollups-" + serviceName + " - Permissionless Refereed Tournaments dispute resolution",
+	Run:     run,
+	Version: version.BuildVersion,
+}
+
+func init() {
+	// Standard service flags (inherited from advancer)
+	Cmd.Flags().StringVar(&inspectAddress, "inspect-address", ":10013", "Inspect service address and port")
+	cobra.CheckErr(viper.BindPFlag(config.INSPECT_ADDRESS, Cmd.Flags().Lookup("inspect-address")))
+
+	Cmd.Flags().StringVar(&telemetryAddress, "telemetry-address", ":10003", "Health check and metrics address and port")
+	cobra.CheckErr(viper.BindPFlag(config.TELEMETRY_ADDRESS, Cmd.Flags().Lookup("telemetry-address")))
+
+	Cmd.Flags().StringVar(&logLevel, "log-level", "info", "Log level: debug, info, warn or error")
+	cobra.CheckErr(viper.BindPFlag(config.LOG_LEVEL, Cmd.Flags().Lookup("log-level")))
+
+	Cmd.Flags().BoolVar(&logColor, "log-color", true, "Tint the logs (colored output)")
+	cobra.CheckErr(viper.BindPFlag(config.LOG_COLOR, Cmd.Flags().Lookup("log-color")))
+
+	Cmd.Flags().StringVar(&databaseConnection, "database-connection", "",
+		"Database connection string in the URL format\n(eg.: 'postgres://user:password@hostname:port/database') ")
+	cobra.CheckErr(viper.BindPFlag(config.DATABASE_CONNECTION, Cmd.Flags().Lookup("database-connection")))
+
+	Cmd.Flags().StringVar(&pollInterval, "poll-interval", "7", "Poll interval")
+	cobra.CheckErr(viper.BindPFlag(config.PRT_POLLING_INTERVAL, Cmd.Flags().Lookup("poll-interval")))
+
+	Cmd.Flags().StringVar(&maxStartupTime, "max-startup-time", "15", "Maximum startup time in seconds")
+	cobra.CheckErr(viper.BindPFlag(config.MAX_STARTUP_TIME, Cmd.Flags().Lookup("max-startup-time")))
+
+	Cmd.Flags().BoolVar(&enableInspect, "inspect-enabled", true, "Enable or disable the inspect service")
+	cobra.CheckErr(viper.BindPFlag(config.FEATURE_INSPECT_ENABLED, Cmd.Flags().Lookup("inspect-enabled")))
+
+	Cmd.Flags().BoolVar(&enableMachineHashCheck, "machine-hash-check", true,
+		"Enable or disable machine hash check (DO NOT USE IN PRODUCTION)")
+	cobra.CheckErr(viper.BindPFlag(config.FEATURE_MACHINE_HASH_CHECK_ENABLED, Cmd.Flags().Lookup("machine-hash-check")))
+
+	Cmd.Flags().StringVar(&machinelogLevel, "machine-log-level", "info",
+		"Remote Machine log level: trace, debug, info, warning, error, fatal")
+	cobra.CheckErr(viper.BindPFlag(config.REMOTE_MACHINE_LOG_LEVEL, Cmd.Flags().Lookup("machine-log-level")))
+
+	// PRT-specific flags
+
+	// TODO: validate on preRunE
+	Cmd.PreRunE = func(cmd *cobra.Command, args []string) error {
+		var err error
+		cfg, err = config.LoadPrtConfig()
+		if err != nil {
+			return err
+		}
+		return nil
+	}
+}
+
+func run(cmd *cobra.Command, args []string) {
+	ctx, cancel := context.WithTimeout(context.Background(), cfg.MaxStartupTime)
+	defer cancel()
+
+	createInfo := prt.CreateInfo{
+		CreateInfo: service.CreateInfo{
+			Name:                 serviceName,
+			LogLevel:             cfg.LogLevel,
+			LogColor:             cfg.LogColor,
+			EnableSignalHandling: true,
+			TelemetryCreate:      true,
+			TelemetryAddress:     cfg.TelemetryAddress,
+			PollInterval:         cfg.PrtPollingInterval,
+		},
+		Config: *cfg,
+	}
+	var err error
+	createInfo.Repository, err = factory.NewRepositoryFromConnectionString(ctx, cfg.DatabaseConnection.String())
+	cobra.CheckErr(err)
+	defer createInfo.Repository.Close()
+
+	prtService, err := prt.Create(ctx, &createInfo)
+	cobra.CheckErr(err)
+
+	cobra.CheckErr(prtService.Serve())
+}

internal/config/generate/Config.toml

@@ -8,14 +8,14 @@ default = "info"
 go-type = "LogLevel"
 description = """
 One of "debug", "info", "warn", "error"."""
-used-by = ["advancer", "claimer", "evmreader", "validator", "jsonrpc", "node"]
+used-by = ["advancer", "claimer", "evmreader", "validator", "jsonrpc", "node", "prt"]
 
 [logging.CARTESI_LOG_COLOR]
 default = "true"
 go-type = "bool"
 description = """
 If set to true, the node will add colors to its log output."""
-used-by = ["advancer", "claimer", "evmreader", "validator", "jsonrpc", "node"]
+used-by = ["advancer", "claimer", "evmreader", "validator", "jsonrpc", "node", "prt"]
 
 #
 # Features
@@ -40,7 +40,7 @@ default = "true"
 go-type = "bool"
 description = """
 If set to false, the node will not start the inspect service."""
-used-by = ["advancer", "node"]
+used-by = ["advancer", "node", "prt"]
 
 [features.CARTESI_FEATURE_JSONRPC_API_ENABLED]
 default = "true"
@@ -55,7 +55,7 @@ go-type = "bool"
 description = """
 If set to false, the node will *not* check whether the Cartesi machine hash from
 the snapshot matches the hash in the Application contract."""
-used-by = ["advancer", "node", "cli"]
+used-by = ["advancer", "node", "cli", "prt"]
 
 #
 # Rollups
@@ -87,7 +87,17 @@ default = "15"
 go-type = "Duration"
 description = """
 How many seconds the node expects services take initializing before aborting."""
-used-by = ["advancer", "claimer", "evmreader", "validator", "jsonrpc", "node"]
+used-by = ["advancer", "claimer", "evmreader", "validator", "jsonrpc", "node", "prt"]
+
+#
+# PRT (Permissionless Refereed Tournaments)
+
+[rollups.CARTESI_PRT_POLLING_INTERVAL]
+default = "7"
+go-type = "Duration"
+description = """
+How many seconds the PRT service will wait before checking for new tournaments or tournament state changes."""
+used-by = ["prt", "node"]
 
 #
 # Blockchain
@@ -194,7 +204,7 @@ Address of the SelfHostedApplicationFactory contract. Not required, used only by
 omit = true
 used-by = ["cli"]
 
-[contracts.CARTESI_CONTRACTS_PRT_CONSENSUS_FACTORY_ADDRESS]
+[contracts.CARTESI_CONTRACTS_PRT_FACTORY_ADDRESS]
 go-type = "Address"
 description = """
 Address of the PRT consensus contract. Not required, used only by the CLI and tests"""
@@ -210,7 +220,7 @@ default = "/var/lib/cartesi-rollups-node/snapshots"
 go-type = "string"
 description = """
 Path to the directory where the snapshots will be written."""
-used-by = ["advancer", "node"]
+used-by = ["advancer", "node", "prt"]
 
 #
 # Auth
@@ -298,7 +308,7 @@ See [this](https://www.postgresql.org/docs/current/libpq-envars.html) for more i
 It is also possible to set the endpoint without a password and load it from Postgres' passfile.
 See [this](https://www.postgresql.org/docs/current/libpq-connect.html#LIBPQ-CONNECT-PASSFILE)
 for more information."""
-used-by = ["advancer", "claimer", "evmreader", "validator", "jsonrpc", "node", "cli"]
+used-by = ["advancer", "claimer", "evmreader", "validator", "jsonrpc", "node", "cli", "prt"]
 
 #
 # Telemetry http address
@@ -308,7 +318,7 @@ used-by = ["advancer", "claimer", "evmreader", "validator", "jsonrpc", "node", "
 go-type = "string"
 description = """
 HTTP address for telemetry service."""
-used-by = ["advancer", "claimer", "evmreader", "validator", "jsonrpc", "node", "cli"]
+used-by = ["advancer", "claimer", "evmreader", "validator", "jsonrpc", "node", "cli", "prt"]
 
 #
 # HTTP
@@ -326,7 +336,7 @@ default = ":10012"
 go-type = "string"
 description = """
 HTTP address for inspect."""
-used-by = ["advancer", "node", "cli"]
+used-by = ["advancer", "node", "cli", "prt"]
 
 #
 # Remote Cartesi Machine
@@ -338,4 +348,4 @@ go-type = "MachineLogLevel"
 description = """
 Remote Cartesi Machine server log level.
 One of "trace", "debug", "info", "warning", "error", "fatal"."""
-used-by = ["advancer", "node"]
+used-by = ["advancer", "node", "prt"]