fix: account for both mainnet and fairground versions

Signed-off-by: Elias Van Ootegem <elias@vega.xyz>

core/execution/future/market.go

@@ -964,7 +964,7 @@ func (m *Market) PostRestore(ctx context.Context) error {
 	}
 
 	// Disposal slippage was set as part of this upgrade, send event to ensure datanode is updated.
-	if vegacontext.InProgressUpgradeFrom(ctx, "v0.75.8") {
+	if vegacontext.InProgressUpgradeFromMultiple(ctx, "v0.75.8", "v0.75.7") {
 		m.broker.Send(events.NewMarketUpdatedEvent(ctx, *m.mkt))
 	}
 

core/governance/snapshot.go

@@ -76,7 +76,7 @@ func (e *Engine) OnStateLoaded(ctx context.Context) error {
 	}
 
 	// update market events may require updating to set the liquidation strategy slippage
-	if vgcontext.InProgressUpgradeFrom(ctx, "v0.75.8") {
+	if vgcontext.InProgressUpgradeFromMultiple(ctx, "v0.75.8", "v0.75.7") {
 		evts := make([]events.Event, 0, len(e.activeProposals)/2)
 		for _, p := range e.activeProposals {
 			if !p.Proposal.IsMarketUpdate() {
@@ -277,7 +277,7 @@ func (e *Engine) restoreActiveProposals(ctx context.Context, active *types.Gover
 	vevts := []events.Event{}
 	e.log.Debug("restoring active proposals snapshot", logging.Int("nproposals", len(active.Proposals)))
 	for _, p := range active.Proposals {
-		if vgcontext.InProgressUpgradeFrom(ctx, "v0.75.8") {
+		if vgcontext.InProgressUpgradeFromMultiple(ctx, "v0.75.8", "v0.75.7") {
 			if p.Proposal.IsNewMarket() || p.Proposal.IsMarketUpdate() {
 				setLiquidationSlippage(p.Proposal)
 			}
@@ -350,7 +350,7 @@ func (e *Engine) restoreBatchActiveProposals(ctx context.Context, active *types.
 
 		evts = append(evts, events.NewProposalEventFromProto(ctx, bp.BatchProposal.ToProto()))
 		for _, p := range bp.BatchProposal.Proposals {
-			if vgcontext.InProgressUpgradeFrom(ctx, "v0.75.8") {
+			if vgcontext.InProgressUpgradeFromMultiple(ctx, "v0.75.8", "v0.75.7") {
 				if p.IsMarketUpdate() || p.IsNewMarket() {
 					setLiquidationSlippage(p)
 				}

libs/context/context.go

@@ -170,6 +170,26 @@ func InProgressUpgradeFrom(ctx context.Context, from string) bool {
 	return from == si.version && si.upgrade
 }
 
+// InProgressUpgradeFromMultiple returns whether the data in the contexts tells us that the
+// node is restoring from a snapshot taken for a protocol-upgrade by one of the given versions.
+// This can be useful in situations where mainnet and fairground are running different versions.
+func InProgressUpgradeFromMultiple(ctx context.Context, versions ...string) bool {
+	v := ctx.Value(snapshotKey)
+	if v == nil {
+		return false
+	}
+	si, ok := v.(snapshotInfo)
+	if !ok || !si.upgrade {
+		return false
+	}
+	for _, from := range versions {
+		if from == si.version {
+			return true
+		}
+	}
+	return false
+}
+
 // InProgressUpgrade returns whether the data in the contexts tells us that the
 // node is restoring from a snapshot taken for a protocol-upgrade.
 func InProgressUpgrade(ctx context.Context) bool {