feat: add market community tags

Signed-off-by: Jeremy Letang <me@jeremyletang.com>

commands/errors.go

@@ -55,6 +55,7 @@ var (
 	ErrInvalidSignature                                = errors.New("invalid signature")
 	ErrUnsupportedAlgorithm                            = errors.New("unsupported algorithm")
 	ErrEmptyBatchMarketInstructions                    = errors.New("empty batch market instructions")
+	ErrIsNotValidVegaID                                = errors.New("is not a valid vega id")
 	ErrIsNotValidVegaPubkey                            = errors.New("is not a valid vega public key")
 	ErrIsNotValidEthereumAddress                       = errors.New("is not a valid ethereum address")
 	ErrEmptyEthereumCallSpec                           = errors.New("ethereum call spec is required")

commands/proposal_submission.go

@@ -211,13 +211,35 @@ func checkProposalChanges(terms *protoTypes.ProposalTerms) Errors {
 		errs.Merge(checkUpdateReferralProgram(terms, c))
 	case *protoTypes.ProposalTerms_UpdateVolumeDiscountProgram:
 		errs.Merge(checkVolumeDiscountProgram(terms, c))
+	case *protoTypes.ProposalTerms_UpdateMarketCommunityTags:
+		errs.Merge(checkUpdateMarketCommunityTagsChanges(c))
 	default:
 		return errs.FinalAddForProperty("proposal_submission.terms.change", ErrIsNotValid)
 	}
 
 	return errs
 }
 
+func checkUpdateMarketCommunityTagsChanges(change *protoTypes.ProposalTerms_UpdateMarketCommunityTags) Errors {
+	errs := NewErrors()
+
+	if change.UpdateMarketCommunityTags == nil {
+		return errs.FinalAddForProperty("proposal_submission.terms.change.update_market_community_tags", ErrIsRequired)
+	}
+
+	if change.UpdateMarketCommunityTags.Changes == nil {
+		return errs.FinalAddForProperty("proposal_submission.terms.change.update_market_community_tags.changes", ErrIsRequired)
+	}
+
+	c := change.UpdateMarketCommunityTags.Changes
+
+	if !crypto.IsValidVegaID(c.MarketId) {
+		errs.AddForProperty("proposal_submission.terms.change.update_market_community_tags.changes", ErrIsNotValidVegaID)
+	}
+
+	return errs
+}
+
 func checkNetworkParameterUpdateChanges(change *protoTypes.ProposalTerms_UpdateNetworkParameter) Errors {
 	errs := NewErrors()
 

core/events/bus.go

@@ -174,6 +174,7 @@ const (
 	CancelledOrdersEvent
 	GameScoresEvent
 	AMMPoolEvent
+	MarketCommunityTagsEvent
 )
 
 var (
@@ -277,6 +278,7 @@ var (
 		eventspb.BusEventType_BUS_EVENT_TYPE_CANCELLED_ORDERS:                        CancelledOrdersEvent,
 		eventspb.BusEventType_BUS_EVENT_TYPE_GAME_SCORES:                             GameScoresEvent,
 		eventspb.BusEventType_BUS_EVENT_TYPE_AMM:                                     AMMPoolEvent,
+		eventspb.BusEventType_BUS_EVENT_TYPE_MARKET_COMMUNITY_TAG:                    MarketCommunityTagsEvent,
 		// If adding a type here, please also add it to datanode/broker/convert.go
 	}
 
@@ -371,6 +373,7 @@ var (
 		CancelledOrdersEvent:                     eventspb.BusEventType_BUS_EVENT_TYPE_CANCELLED_ORDERS,
 		GameScoresEvent:                          eventspb.BusEventType_BUS_EVENT_TYPE_GAME_SCORES,
 		AMMPoolEvent:                             eventspb.BusEventType_BUS_EVENT_TYPE_AMM,
+		MarketCommunityTagsEvent:                 eventspb.BusEventType_BUS_EVENT_TYPE_MARKET_COMMUNITY_TAG,
 		// If adding a type here, please also add it to datanode/broker/convert.go
 	}
 
@@ -464,6 +467,7 @@ var (
 		CancelledOrdersEvent:                     "CancelledOrdersEvent",
 		GameScoresEvent:                          "GameScoresEvent",
 		AMMPoolEvent:                             "AMMPoolEvent",
+		MarketCommunityTagsEvent:                 "MarketCommunityTagsEvent",
 	}
 )
 

core/events/market_community_tags.go

@@ -0,0 +1,57 @@
+// Copyright (C) 2023 Gobalsky Labs Limited
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU Affero General Public License as
+// published by the Free Software Foundation, either version 3 of the
+// License, or (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU Affero General Public License for more details.
+//
+// You should have received a copy of the GNU Affero General Public License
+// along with this program.  If not, see <http://www.gnu.org/licenses/>.
+
+package events
+
+import (
+	"context"
+
+	eventspb "code.vegaprotocol.io/vega/protos/vega/events/v1"
+)
+
+type MarketCommunityTags struct {
+	*Base
+	a eventspb.MarketCommunityTags
+}
+
+func NewMarketCommunityTagsEvent(ctx context.Context, e eventspb.MarketCommunityTags) *MarketCommunityTags {
+	return &MarketCommunityTags{
+		Base: newBase(ctx, MarketCommunityTagsEvent),
+		a:    e,
+	}
+}
+
+func (a *MarketCommunityTags) MarketCommunityTags() eventspb.MarketCommunityTags {
+	return a.a
+}
+
+func (a MarketCommunityTags) Proto() eventspb.MarketCommunityTags {
+	return a.a
+}
+
+func (a MarketCommunityTags) StreamMessage() *eventspb.BusEvent {
+	busEvent := newBusEventFromBase(a.Base)
+	busEvent.Event = &eventspb.BusEvent_MarketCommunityTags{
+		MarketCommunityTags: &a.a,
+	}
+	return busEvent
+}
+
+func MarketCommunityTagsEventFromStream(ctx context.Context, be *eventspb.BusEvent) *MarketCommunityTags {
+	return &MarketCommunityTags{
+		Base: newBaseFromBusEvent(ctx, MarketCommunityTagsEvent, be),
+		a:    *be.GetMarketCommunityTags(),
+	}
+}

core/execution/engine.go

@@ -82,6 +82,7 @@ type Engine struct {
 	allMarkets    map[string]common.CommonMarket
 	allMarketsCpy []common.CommonMarket
 
+	communityTags                 *MarketCommunityTags
 	collateral                    common.Collateral
 	assets                        common.Assets
 	referralDiscountRewardService fee.ReferralDiscountRewardService
@@ -168,6 +169,7 @@ func NewEngine(
 		banking:                       banking,
 		parties:                       parties,
 		delayTransactionsTarget:       delayTransactionsTarget,
+		communityTags:                 NewMarketCommunityTags(broker),
 	}
 
 	// set the eligibility for proposer bonus checker

core/execution/engine_snapshot.go

@@ -315,14 +315,17 @@ func (e *Engine) serialise() (snapshot []byte, providers []types.StateProvider,
 		allMarketIDs = append(allMarketIDs, cm.GetID())
 	}
 
+	tags := e.communityTags.serialize()
+
 	pl := types.Payload{
 		Data: &types.PayloadExecutionMarkets{
 			ExecutionMarkets: &types.ExecutionMarkets{
-				Markets:        mkts,
-				SpotMarkets:    spotMkts,
-				SettledMarkets: cpStates,
-				Successors:     successors,
-				AllMarketIDs:   allMarketIDs,
+				Markets:             mkts,
+				SpotMarkets:         spotMkts,
+				SettledMarkets:      cpStates,
+				Successors:          successors,
+				AllMarketIDs:        allMarketIDs,
+				MarketCommunityTags: tags,
 			},
 		},
 	}
@@ -381,6 +384,9 @@ func (e *Engine) LoadState(ctx context.Context, payload *types.Payload) ([]types
 				e.allMarketsCpy = append(e.allMarketsCpy, mkt)
 			}
 		}
+
+		e.communityTags = NewMarketCommunityTagFromProto(e.broker, pl.ExecutionMarkets.MarketCommunityTags)
+
 		return append(providers, spotProviders...), err
 	default:
 		return nil, types.ErrUnknownSnapshotType

core/execution/market_community_tags.go

@@ -0,0 +1,107 @@
+// Copyright (C) 2023 Gobalsky Labs Limited
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU Affero General Public License as
+// published by the Free Software Foundation, either version 3 of the
+// License, or (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU Affero General Public License for more details.
+//
+// You should have received a copy of the GNU Affero General Public License
+// along with this program.  If not, see <http://www.gnu.org/licenses/>.
+
+package execution
+
+import (
+	"context"
+	"sort"
+
+	"code.vegaprotocol.io/vega/core/events"
+	"code.vegaprotocol.io/vega/core/execution/common"
+	eventspb "code.vegaprotocol.io/vega/protos/vega/events/v1"
+
+	"golang.org/x/exp/maps"
+)
+
+type MarketCommunityTags struct {
+	// market id -> set of tags
+	tags   map[string]map[string]struct{}
+	broker common.Broker
+}
+
+func NewMarketCommunityTags(broker common.Broker) *MarketCommunityTags {
+	return &MarketCommunityTags{
+		tags:   map[string]map[string]struct{}{},
+		broker: broker,
+	}
+}
+
+func NewMarketCommunityTagFromProto(
+	broker common.Broker,
+	state []*eventspb.MarketCommunityTags,
+) *MarketCommunityTags {
+	m := NewMarketCommunityTags(broker)
+
+	for _, v := range state {
+		m.tags[v.MarketId] = map[string]struct{}{}
+		for _, t := range v.Tags {
+			m.tags[v.MarketId][t] = struct{}{}
+		}
+	}
+
+	return m
+}
+
+func (m *MarketCommunityTags) serialize() []*eventspb.MarketCommunityTags {
+	out := make([]*eventspb.MarketCommunityTags, 0, len(m.tags))
+
+	for mkt, tags := range m.tags {
+		mct := &eventspb.MarketCommunityTags{
+			MarketId: mkt,
+			Tags:     make([]string, 0, len(tags)),
+		}
+
+		for tag := range tags {
+			mct.Tags = append(mct.Tags, tag)
+		}
+
+		sort.Strings(mct.Tags)
+	}
+
+	sort.Slice(out, func(i, j int) bool { return out[i].MarketId < out[j].MarketId })
+
+	return out
+}
+
+// UpdateTags by that point the tags have been validated in length,
+// so no need to do that again.
+func (m *MarketCommunityTags) UpdateTags(
+	ctx context.Context,
+	market string,
+	addTags []string,
+	removeTags []string,
+) {
+	tags, ok := m.tags[market]
+	if !ok {
+		tags = map[string]struct{}{}
+	}
+
+	for _, t := range addTags {
+		tags[t] = struct{}{}
+	}
+
+	for _, t := range removeTags {
+		delete(tags, t)
+	}
+
+	evt := eventspb.MarketCommunityTags{
+		MarketId: market,
+		Tags:     maps.Keys(tags),
+	}
+
+	sort.Strings(evt.Tags)
+	m.broker.Send(events.NewMarketCommunityTagsEvent(ctx, evt))
+}

core/governance/engine.go

@@ -53,6 +53,9 @@ var (
 	ErrParentMarketAlreadySucceeded              = errors.New("the parent market was already succeeded by a prior proposal")
 	ErrParentMarketSucceededByCompeting          = errors.New("the parent market has been succeeded by a competing propsal")
 	ErrSettlementDataOutOfRange                  = errors.New("the settlement data is invalid")
+	ErrUnknownMarketID                           = func(id string) error {
+		return fmt.Errorf("unknown market id %v", id)
+	}
 )
 
 //go:generate go run github.com/golang/mock/mockgen -destination mocks/mocks.go -package mocks code.vegaprotocol.io/vega/core/governance Markets,StakingAccounts,Assets,TimeService,Witness,NetParams,Banking
@@ -741,6 +744,8 @@ func (e *Engine) getProposalParams(proposalTerm types.ProposalTerm) (*types.Prop
 		return e.getReferralProgramNetworkParameters(), nil
 	case types.ProposalTermsTypeUpdateVolumeDiscountProgram:
 		return e.getVolumeDiscountProgramNetworkParameters(), nil
+	case types.ProposalTermsTypeUpdateMarketCommunityTags:
+		return e.getUpdateMarketCommunityTagsParameters(), nil
 	default:
 		return nil, ErrUnsupportedProposalType
 	}
@@ -1091,11 +1096,21 @@ func (e *Engine) validateChange(terms *types.ProposalTerms) (types.ProposalError
 		return validateUpdateReferralProgram(e.netp, terms.GetUpdateReferralProgram(), terms.EnactmentTimestamp)
 	case types.ProposalTermsTypeUpdateVolumeDiscountProgram:
 		return validateUpdateVolumeDiscountProgram(e.netp, terms.GetUpdateVolumeDiscountProgram())
+	case types.ProposalTermsTypeUpdateMarketCommunityTags:
+		return validateUpdateMarketCommunityTags(terms.GetUpdateMarketCommunityTags(), e.markets)
 	default:
 		return types.ProposalErrorUnspecified, nil
 	}
 }
 
+func validateUpdateMarketCommunityTags(p *types.UpdateMarketCommunityTags, markets Markets) (types.ProposalError, error) {
+	if !markets.MarketExists(p.MarketID) {
+		return types.ProposalErrorUnknownMarketID, ErrUnknownMarketID(p.MarketID)
+	}
+
+	return types.ProposalErrorUnspecified, nil
+}
+
 func (e *Engine) validateGovernanceTransfer(newTransfer *types.NewTransfer) (types.ProposalError, error) {
 	if err := e.banking.VerifyGovernanceTransfer(newTransfer.Changes); err != nil {
 		return types.ProporsalErrorInvalidGovernanceTransfer, err

core/governance/netparams.go

@@ -139,6 +139,22 @@ func (e *Engine) getVolumeDiscountProgramNetworkParameters() *types.ProposalPara
 	)
 }
 
+func (e *Engine) getUpdateMarketCommunityTagsParameters() *types.ProposalParameters {
+	return e.getProposalParametersFromNetParams(
+		netparams.GovernanceProposalUpdateCommunityTagsMinClose,
+		netparams.GovernanceProposalUpdateCommunityTagsMaxClose,
+		netparams.GovernanceProposalUpdateCommunityTagsMinEnact,
+		netparams.GovernanceProposalUpdateCommunityTagsMaxEnact,
+		netparams.GovernanceProposalUpdateCommunityTagsRequiredParticipation,
+		netparams.GovernanceProposalUpdateCommunityTagsRequiredMajority,
+		netparams.GovernanceProposalUpdateCommunityTagsMinProposerBalance,
+		netparams.GovernanceProposalUpdateCommunityTagsMinVoterBalance,
+		"0",
+		"0",
+		"0",
+	)
+}
+
 func (e *Engine) getNewAssetProposalParameters() *types.ProposalParameters {
 	return e.getProposalParametersFromNetParams(
 		netparams.GovernanceProposalAssetMinClose,

core/netparams/defaults.go

@@ -112,6 +112,16 @@ func defaultNetParams() map[string]value {
 		MarketLiquidityProvidersFeeCalculationTimeStep:   NewDuration(gte1s, lte255h).Mutable(true).MustUpdate("1m"),
 		MarketLiquidityEquityLikeShareFeeFraction:        NewDecimal(gteD0, lteD1).Mutable(true).MustUpdate("0.5"),
 
+		// updateCommunityTags proposal parameters.
+		GovernanceProposalUpdateCommunityTagsMinClose:              NewDuration(gte1s, lte1y).Mutable(true).MustUpdate("24h0m0s"),
+		GovernanceProposalUpdateCommunityTagsMaxClose:              NewDuration(gte1s, lte1y).Mutable(true).MustUpdate("8760h0m0s"),
+		GovernanceProposalUpdateCommunityTagsMinEnact:              NewDuration(gte1s, lte1y).Mutable(true).MustUpdate("24h0m0s"),
+		GovernanceProposalUpdateCommunityTagsMaxEnact:              NewDuration(gte1s, lte1y).Mutable(true).MustUpdate("8760h0m0s"),
+		GovernanceProposalUpdateCommunityTagsRequiredParticipation: NewDecimal(gteD0, lteD1).Mutable(true).MustUpdate("0.025"),
+		GovernanceProposalUpdateCommunityTagsRequiredMajority:      NewDecimal(gteD0, lteD1).Mutable(true).MustUpdate("0.66"),
+		GovernanceProposalUpdateCommunityTagsMinProposerBalance:    NewUint(gteU1, ltMaxU).Mutable(true).MustUpdate("1000000000000000000"),
+		GovernanceProposalUpdateCommunityTagsMinVoterBalance:       NewUint(gteU1, ltMaxU).Mutable(true).MustUpdate("1000000000000000000"),
+
 		// governance market proposal
 		GovernanceProposalMarketMinClose:              NewDuration(gte1s, lte1y).Mutable(true).MustUpdate("48h0m0s"),
 		GovernanceProposalMarketMaxClose:              NewDuration(gte1s, lte1y).Mutable(true).MustUpdate("8760h0m0s"),