feat: calculate epoch length from pparams

state/eras/allegra.go

@@ -30,6 +30,7 @@ var AllegraEraDesc = EraDesc{
 	DecodePParamsUpdateFunc: DecodePParamsUpdateAllegra,
 	PParamsUpdateFunc:       PParamsUpdateAllegra,
 	HardForkFunc:            HardForkAllegra,
+	EpochLengthFunc:         EpochLengthShelley,
 }
 
 func DecodePParamsAllegra(data []byte) (any, error) {

state/eras/alonzo.go

@@ -30,6 +30,7 @@ var AlonzoEraDesc = EraDesc{
 	DecodePParamsUpdateFunc: DecodePParamsUpdateAlonzo,
 	PParamsUpdateFunc:       PParamsUpdateAlonzo,
 	HardForkFunc:            HardForkAlonzo,
+	EpochLengthFunc:         EpochLengthShelley,
 }
 
 func DecodePParamsAlonzo(data []byte) (any, error) {

state/eras/babbage.go

@@ -30,6 +30,7 @@ var BabbageEraDesc = EraDesc{
 	DecodePParamsUpdateFunc: DecodePParamsUpdateBabbage,
 	PParamsUpdateFunc:       PParamsUpdateBabbage,
 	HardForkFunc:            HardForkBabbage,
+	EpochLengthFunc:         EpochLengthShelley,
 }
 
 func DecodePParamsBabbage(data []byte) (any, error) {

state/eras/byron.go

@@ -14,9 +14,23 @@
 
 package eras
 
-import "github.com/blinklabs-io/gouroboros/ledger/byron"
+import (
+	"github.com/blinklabs-io/gouroboros/ledger/byron"
+	"github.com/blinklabs-io/node/config/cardano"
+)
 
 var ByronEraDesc = EraDesc{
-	Id:   byron.EraIdByron,
-	Name: byron.EraNameByron,
+	Id:              byron.EraIdByron,
+	Name:            byron.EraNameByron,
+	EpochLengthFunc: EpochLengthByron,
+}
+
+func EpochLengthByron(nodeConfig *cardano.CardanoNodeConfig) (uint, uint, error) {
+	byronGenesis, err := nodeConfig.ByronGenesis()
+	if err != nil {
+		return 0, 0, err
+	}
+	return uint(byronGenesis.BlockVersionData.SlotDuration),
+		uint(byronGenesis.ProtocolConsts.K * 10),
+		nil
 }

state/eras/conway.go

@@ -30,6 +30,7 @@ var ConwayEraDesc = EraDesc{
 	DecodePParamsUpdateFunc: DecodePParamsUpdateConway,
 	PParamsUpdateFunc:       PParamsUpdateConway,
 	HardForkFunc:            HardForkConway,
+	EpochLengthFunc:         EpochLengthShelley,
 }
 
 func DecodePParamsConway(data []byte) (any, error) {

state/eras/eras.go

@@ -23,6 +23,7 @@ type EraDesc struct {
 	DecodePParamsUpdateFunc func([]byte) (any, error)
 	PParamsUpdateFunc       func(any, any) (any, error)
 	HardForkFunc            func(*cardano.CardanoNodeConfig, any) (any, error)
+	EpochLengthFunc         func(*cardano.CardanoNodeConfig) (uint, uint, error)
 }
 
 var Eras = []EraDesc{

state/eras/mary.go

@@ -30,6 +30,7 @@ var MaryEraDesc = EraDesc{
 	DecodePParamsUpdateFunc: DecodePParamsUpdateMary,
 	PParamsUpdateFunc:       PParamsUpdateMary,
 	HardForkFunc:            HardForkMary,
+	EpochLengthFunc:         EpochLengthShelley,
 }
 
 func DecodePParamsMary(data []byte) (any, error) {

state/eras/shelley.go

@@ -29,6 +29,7 @@ var ShelleyEraDesc = EraDesc{
 	DecodePParamsUpdateFunc: DecodePParamsUpdateShelley,
 	PParamsUpdateFunc:       PParamsUpdateShelley,
 	HardForkFunc:            HardForkShelley,
+	EpochLengthFunc:         EpochLengthShelley,
 }
 
 func DecodePParamsShelley(data []byte) (any, error) {
@@ -80,3 +81,13 @@ func HardForkShelley(
 	ret.UpdateFromGenesis(shelleyGenesis)
 	return ret, nil
 }
+
+func EpochLengthShelley(nodeConfig *cardano.CardanoNodeConfig) (uint, uint, error) {
+	shelleyGenesis, err := nodeConfig.ShelleyGenesis()
+	if err != nil {
+		return 0, 0, err
+	}
+	return uint(shelleyGenesis.SlotLength * 1000),
+		uint(shelleyGenesis.EpochLength),
+		nil
+}

state/models/epoch.go

@@ -20,11 +20,11 @@ type Epoch struct {
 	ID uint `gorm:"primarykey"`
 	// NOTE: we would normally use this as the primary key, but GORM doesn't
 	// like a primary key value of 0
-	EpochId             uint `gorm:"uniqueIndex"`
-	EraId               uint8
-	StartSlot           uint64
-	SlotLengthInSeconds uint
-	LengthInSlots       uint
+	EpochId       uint `gorm:"uniqueIndex"`
+	EraId         uint
+	StartSlot     uint64
+	SlotLength    uint
+	LengthInSlots uint
 }
 
 func (Epoch) TableName() string {

state/models/models.go

@@ -18,7 +18,6 @@ package models
 var MigrateModels = []any{
 	&Block{},
 	&Epoch{},
-	&Era{},
 	&PoolRegistration{},
 	&PoolRegistrationOwner{},
 	&PoolRegistrationRelay{},