Implement Express Lane Timeboost

Dockerfile

@@ -297,6 +297,8 @@ FROM nitro-node-slim AS nitro-node
 USER root
 COPY --from=prover-export /bin/jit                        /usr/local/bin/
 COPY --from=node-builder  /workspace/target/bin/daserver  /usr/local/bin/
+COPY --from=node-builder  /workspace/target/bin/autonomous-auctioneer  /usr/local/bin/
+COPY --from=node-builder  /workspace/target/bin/bidder-client  /usr/local/bin/
 COPY --from=node-builder  /workspace/target/bin/datool    /usr/local/bin/
 COPY --from=nitro-legacy /home/user/target/machines /home/user/nitro-legacy/machines
 RUN rm -rf /workspace/target/legacy-machines/latest

Makefile

@@ -169,7 +169,7 @@ all: build build-replay-env test-gen-proofs
 	@touch .make/all
 
 .PHONY: build
-build: $(patsubst %,$(output_root)/bin/%, nitro deploy relay daserver datool seq-coordinator-invalidate nitro-val seq-coordinator-manager dbconv)
+build: $(patsubst %,$(output_root)/bin/%, nitro deploy relay daserver autonomous-auctioneer bidder-client datool seq-coordinator-invalidate nitro-val seq-coordinator-manager dbconv)
 	@printf $(done)
 
 .PHONY: build-node-deps
@@ -311,6 +311,12 @@ $(output_root)/bin/relay: $(DEP_PREDICATE) build-node-deps
 $(output_root)/bin/daserver: $(DEP_PREDICATE) build-node-deps
 	go build $(GOLANG_PARAMS) -o $@ "$(CURDIR)/cmd/daserver"
 
+$(output_root)/bin/autonomous-auctioneer: $(DEP_PREDICATE) build-node-deps
+	go build $(GOLANG_PARAMS) -o $@ "$(CURDIR)/cmd/autonomous-auctioneer"
+
+$(output_root)/bin/bidder-client: $(DEP_PREDICATE) build-node-deps
+	go build $(GOLANG_PARAMS) -o $@ "$(CURDIR)/cmd/bidder-client"
+
 $(output_root)/bin/datool: $(DEP_PREDICATE) build-node-deps
 	go build $(GOLANG_PARAMS) -o $@ "$(CURDIR)/cmd/datool"
 

cmd/autonomous-auctioneer/config.go

@@ -0,0 +1,156 @@
+package main
+
+import (
+	"fmt"
+	"reflect"
+	"time"
+
+	flag "github.com/spf13/pflag"
+
+	"github.com/ethereum/go-ethereum/node"
+	"github.com/ethereum/go-ethereum/p2p"
+	"github.com/ethereum/go-ethereum/rpc"
+
+	"github.com/offchainlabs/nitro/cmd/conf"
+	"github.com/offchainlabs/nitro/cmd/genericconf"
+	"github.com/offchainlabs/nitro/timeboost"
+	"github.com/offchainlabs/nitro/util/colors"
+)
+
+type AutonomousAuctioneerConfig struct {
+	AuctioneerServer timeboost.AuctioneerServerConfig `koanf:"auctioneer-server"`
+	BidValidator     timeboost.BidValidatorConfig     `koanf:"bid-validator"`
+	Persistent       conf.PersistentConfig            `koanf:"persistent"`
+	Conf             genericconf.ConfConfig           `koanf:"conf" reload:"hot"`
+	LogLevel         string                           `koanf:"log-level" reload:"hot"`
+	LogType          string                           `koanf:"log-type" reload:"hot"`
+	FileLogging      genericconf.FileLoggingConfig    `koanf:"file-logging" reload:"hot"`
+	HTTP             genericconf.HTTPConfig           `koanf:"http"`
+	WS               genericconf.WSConfig             `koanf:"ws"`
+	IPC              genericconf.IPCConfig            `koanf:"ipc"`
+	Metrics          bool                             `koanf:"metrics"`
+	MetricsServer    genericconf.MetricsServerConfig  `koanf:"metrics-server"`
+	PProf            bool                             `koanf:"pprof"`
+	PprofCfg         genericconf.PProf                `koanf:"pprof-cfg"`
+}
+
+var HTTPConfigDefault = genericconf.HTTPConfig{
+	Addr:           "",
+	Port:           genericconf.HTTPConfigDefault.Port,
+	API:            []string{},
+	RPCPrefix:      genericconf.HTTPConfigDefault.RPCPrefix,
+	CORSDomain:     genericconf.HTTPConfigDefault.CORSDomain,
+	VHosts:         genericconf.HTTPConfigDefault.VHosts,
+	ServerTimeouts: genericconf.HTTPConfigDefault.ServerTimeouts,
+}
+
+var WSConfigDefault = genericconf.WSConfig{
+	Addr:      "",
+	Port:      genericconf.WSConfigDefault.Port,
+	API:       []string{},
+	RPCPrefix: genericconf.WSConfigDefault.RPCPrefix,
+	Origins:   genericconf.WSConfigDefault.Origins,
+	ExposeAll: genericconf.WSConfigDefault.ExposeAll,
+}
+
+var IPCConfigDefault = genericconf.IPCConfig{
+	Path: "",
+}
+
+var AutonomousAuctioneerConfigDefault = AutonomousAuctioneerConfig{
+	Conf:          genericconf.ConfConfigDefault,
+	LogLevel:      "INFO",
+	LogType:       "plaintext",
+	HTTP:          HTTPConfigDefault,
+	WS:            WSConfigDefault,
+	IPC:           IPCConfigDefault,
+	Metrics:       false,
+	MetricsServer: genericconf.MetricsServerConfigDefault,
+	PProf:         false,
+	Persistent:    conf.PersistentConfigDefault,
+	PprofCfg:      genericconf.PProfDefault,
+}
+
+func AuctioneerConfigAddOptions(f *flag.FlagSet) {
+	timeboost.AuctioneerServerConfigAddOptions("auctioneer-server", f)
+	timeboost.BidValidatorConfigAddOptions("bid-validator", f)
+	conf.PersistentConfigAddOptions("persistent", f)
+	genericconf.ConfConfigAddOptions("conf", f)
+	f.String("log-level", AutonomousAuctioneerConfigDefault.LogLevel, "log level, valid values are CRIT, ERROR, WARN, INFO, DEBUG, TRACE")
+	f.String("log-type", AutonomousAuctioneerConfigDefault.LogType, "log type (plaintext or json)")
+	genericconf.FileLoggingConfigAddOptions("file-logging", f)
+	genericconf.HTTPConfigAddOptions("http", f)
+	genericconf.WSConfigAddOptions("ws", f)
+	genericconf.IPCConfigAddOptions("ipc", f)
+	f.Bool("metrics", AutonomousAuctioneerConfigDefault.Metrics, "enable metrics")
+	genericconf.MetricsServerAddOptions("metrics-server", f)
+	f.Bool("pprof", AutonomousAuctioneerConfigDefault.PProf, "enable pprof")
+	genericconf.PProfAddOptions("pprof-cfg", f)
+}
+
+func (c *AutonomousAuctioneerConfig) ShallowClone() *AutonomousAuctioneerConfig {
+	config := &AutonomousAuctioneerConfig{}
+	*config = *c
+	return config
+}
+
+func (c *AutonomousAuctioneerConfig) CanReload(new *AutonomousAuctioneerConfig) error {
+	var check func(node, other reflect.Value, path string)
+	var err error
+
+	check = func(node, value reflect.Value, path string) {
+		if node.Kind() != reflect.Struct {
+			return
+		}
+
+		for i := 0; i < node.NumField(); i++ {
+			fieldTy := node.Type().Field(i)
+			if !fieldTy.IsExported() {
+				continue
+			}
+			hot := fieldTy.Tag.Get("reload") == "hot"
+			dot := path + "." + fieldTy.Name
+
+			first := node.Field(i).Interface()
+			other := value.Field(i).Interface()
+
+			if !hot && !reflect.DeepEqual(first, other) {
+				err = fmt.Errorf("illegal change to %v%v%v", colors.Red, dot, colors.Clear)
+			} else {
+				check(node.Field(i), value.Field(i), dot)
+			}
+		}
+	}
+
+	check(reflect.ValueOf(c).Elem(), reflect.ValueOf(new).Elem(), "config")
+	return err
+}
+
+func (c *AutonomousAuctioneerConfig) GetReloadInterval() time.Duration {
+	return c.Conf.ReloadInterval
+}
+
+func (c *AutonomousAuctioneerConfig) Validate() error {
+	return nil
+}
+
+var DefaultAuctioneerStackConfig = node.Config{
+	DataDir:             node.DefaultDataDir(),
+	HTTPPort:            node.DefaultHTTPPort,
+	AuthAddr:            node.DefaultAuthHost,
+	AuthPort:            node.DefaultAuthPort,
+	AuthVirtualHosts:    node.DefaultAuthVhosts,
+	HTTPModules:         []string{timeboost.AuctioneerNamespace},
+	HTTPHost:            "localhost",
+	HTTPVirtualHosts:    []string{"localhost"},
+	HTTPTimeouts:        rpc.DefaultHTTPTimeouts,
+	WSHost:              "localhost",
+	WSPort:              node.DefaultWSPort,
+	WSModules:           []string{timeboost.AuctioneerNamespace},
+	GraphQLVirtualHosts: []string{"localhost"},
+	P2P: p2p.Config{
+		ListenAddr:  "",
+		NoDiscovery: true,
+		NoDial:      true,
+	},
+}