package sanitize

import (
	sdk "git.cw.tr/mukan-network/mukan-sdk/types"
	govtypesv1 "git.cw.tr/mukan-network/mukan-sdk/x/gov/types/v1"
	grouptypes "git.cw.tr/mukan-network/mukan-sdk/x/group"

	"github.com/cosmos/ibc-go/e2e/semverutil"
	icacontrollertypes "git.cw.tr/mukan-network/mukan-ibc/modules/apps/27-interchain-accounts/controller/types"
	channeltypes "git.cw.tr/mukan-network/mukan-ibc/modules/core/04-channel/types"
)

var (
	// groupsv1ProposalTitleAndSummary represents the releases that support the new title and summary fields.
	groupsv1ProposalTitleAndSummary = semverutil.FeatureReleases{
		MajorVersion: "v7",
	}
	// govv1ProposalTitleAndSummary represents the releases that support the new title and summary fields.
	govv1ProposalTitleAndSummary = semverutil.FeatureReleases{
		MajorVersion: "v7",
	}
	// icaUnorderedChannelFeatureReleases represents the releasees that support the new ordering field.
	icaUnorderedChannelFeatureReleases = semverutil.FeatureReleases{
		MajorVersion: "v9",
		MinorVersions: []string{
			"v7.5",
			"v8.1",
		},
	}
)

// Messages removes any fields that are not supported by the chain version.
// For example, any fields that have been added in later sdk releases.
func Messages(tag string, msgs ...sdk.Msg) []sdk.Msg {
	sanitizedMsgs := make([]sdk.Msg, len(msgs))
	for i := range msgs {
		sanitizedMsgs[i] = removeUnknownFields(tag, msgs[i])
	}
	return sanitizedMsgs
}

// removeUnknownFields removes any fields that are not supported by the chain version.
// The input message is returned if no changes are made.
func removeUnknownFields(tag string, msg sdk.Msg) sdk.Msg {
	switch msg := msg.(type) {
	case *govtypesv1.MsgSubmitProposal:
		if !govv1ProposalTitleAndSummary.IsSupported(tag) {
			msg.Title = ""
			msg.Summary = ""
		}
		// sanitize messages contained in the x/gov proposal
		msgs, err := msg.GetMsgs()
		if err != nil {
			panic(err)
		}
		sanitizedMsgs := Messages(tag, msgs...)
		if err := msg.SetMsgs(sanitizedMsgs); err != nil {
			panic(err)
		}
		return msg
	case *grouptypes.MsgSubmitProposal:
		if !groupsv1ProposalTitleAndSummary.IsSupported(tag) {
			msg.Title = ""
			msg.Summary = ""
		}
		// sanitize messages contained in the x/group proposal
		msgs, err := msg.GetMsgs()
		if err != nil {
			panic(err)
		}
		sanitizedMsgs := Messages(tag, msgs...)
		if err := msg.SetMsgs(sanitizedMsgs); err != nil {
			panic(err)
		}
		return msg
	case *icacontrollertypes.MsgRegisterInterchainAccount:
		if !icaUnorderedChannelFeatureReleases.IsSupported(tag) {
			msg.Ordering = channeltypes.NONE
		}
	}
	return msg
}