chore: remove old replay code

app/app.go

@@ -17,7 +17,6 @@ import (
 
  backendconfig "github.com/rudderlabs/rudder-server/backend-config"
  configenv "github.com/rudderlabs/rudder-server/enterprise/config-env"
- "github.com/rudderlabs/rudder-server/enterprise/replay"
  "github.com/rudderlabs/rudder-server/enterprise/reporting"
  suppression "github.com/rudderlabs/rudder-server/enterprise/suppress-user"
  "github.com/rudderlabs/rudder-server/jobsdb"
@@ -86,10 +85,6 @@ func (a *app) initFeatures() {
  EnterpriseToken: a.options.EnterpriseToken,
  Log: enterpriseLogger.Child("reporting"),
  },
- Replay: &replay.Factory{
- EnterpriseToken: a.options.EnterpriseToken,
- Log: enterpriseLogger.Child("replay"),
- },
  ConfigEnv: &configenv.Factory{
  EnterpriseToken: a.options.EnterpriseToken,
  Log: enterpriseLogger.Child("config-env"),

app/apphandlers/embeddedAppHandler.go

@@ -50,7 +50,6 @@ type embeddedApp struct {
  versionHandler func(w http.ResponseWriter, r *http.Request)
  log logger.Logger
  config struct {
- enableReplay bool
  processorDSLimit config.ValueLoader[int]
  routerDSLimit config.ValueLoader[int]
  batchRouterDSLimit config.ValueLoader[int]
@@ -59,7 +58,6 @@ type embeddedApp struct {
 }
 
 func (a *embeddedApp) Setup() error {
- a.config.enableReplay = config.GetBoolVar(types.DefaultReplayEnabled, "Replay.enabled")
  a.config.processorDSLimit = config.GetReloadableIntVar(0, 1, "Processor.jobsDB.dsLimit", "JobsDB.dsLimit")
  a.config.gatewayDSLimit = config.GetReloadableIntVar(0, 1, "Gateway.jobsDB.dsLimit", "JobsDB.dsLimit")
  a.config.routerDSLimit = config.GetReloadableIntVar(0, 1, "Router.jobsDB.dsLimit", "JobsDB.dsLimit")
@@ -378,23 +376,6 @@ func (a *embeddedApp) StartRudderCore(ctx context.Context, options *app.Options)
  g.Go(func() error {
  return gw.StartWebHandler(ctx)
  })
- if a.config.enableReplay {
- var replayDB jobsdb.Handle
- err := replayDB.Setup(
- jobsdb.ReadWrite, options.ClearDB, "replay",
- )
- if err != nil {
- return fmt.Errorf("could not setup replayDB: %w", err)
- }
- replay, err := a.app.Features().Replay.Setup(ctx, config, &replayDB, gatewayDB, routerDB, batchRouterDB)
- if err != nil {
- return err
- }
- if err := replay.Start(); err != nil {
- return fmt.Errorf("could not start replay: %w", err)
- }
- defer func() { _ = replay.Stop() }()
- }
 
  g.Go(func() error {
  // This should happen only after setupDatabaseTables() is called and journal table migrations are done

app/features.go

@@ -9,8 +9,6 @@ import (
 
  "github.com/rudderlabs/rudder-go-kit/config"
  backendconfig "github.com/rudderlabs/rudder-server/backend-config"
- "github.com/rudderlabs/rudder-server/enterprise/replay"
- "github.com/rudderlabs/rudder-server/jobsdb"
  "github.com/rudderlabs/rudder-server/utils/types"
 )
 
@@ -37,24 +35,11 @@ type ReportingFeature interface {
  Setup(cxt context.Context, backendConfig backendconfig.BackendConfig) types.Reporting
 }
 
-/*********************************
-Replay Feature
-*********************************/
-
-// ReplayFeature handles inserting of failed jobs into respective gw/rt jobsdb
-type ReplayFeature interface {
- Setup(ctx context.Context, config *config.Config, replayDB, gwDB, routerDB, batchRouterDB *jobsdb.Handle) (replay.Replay, error)
-}
-
-// ReplayFeatureSetup is a function that initializes a Replay feature
-type ReplayFeatureSetup func(App) ReplayFeature
-
 // Features contains optional implementations of Enterprise only features.
 type Features struct {
  SuppressUser SuppressUserFeature
  ConfigEnv ConfigEnvFeature
  Reporting ReportingFeature
- Replay ReplayFeature
  TrackedUsers TrackedUsersFeature
 }