Leonardo/users relationship impl

CHANGELOG.md

@@ -2,6 +2,7 @@
 ##Changes
 - Allowed the possibility to edit a post's attachments and poll data using the `MsgEditPost` type (#202)
 - Removed the `Open` field from within the `PollData` object. Now you should rely on the `CloseDate` field to determine whether a poll is closed or open. (#252)
+- Implemented users `Relationships` (#168)
 
 # Version 0.10.0
 ## Changes

app/params/weights.go

@@ -2,13 +2,15 @@ package params
 
 // Default simulation operation weights for messages
 const (
-	DefaultWeightMsgCreatePost       int = 100
-	DefaultWeightMsgEditPost         int = 100
-	DefaultWeightMsgAddReaction      int = 100
-	DefaultWeightMsgRemoveReaction   int = 100
-	DefaultWeightMsgAnswerPoll       int = 100
-	DefaultWeightMsgRegisterReaction int = 100
-	DefaultWeightMsgSaveAccount      int = 100
-	DefaultWeightMsgDeleteAccount    int = 100
-	DefaultWeightMsgReportPost       int = 100
+	DefaultWeightMsgCreatePost         int = 100
+	DefaultWeightMsgEditPost           int = 100
+	DefaultWeightMsgAddReaction        int = 100
+	DefaultWeightMsgRemoveReaction     int = 100
+	DefaultWeightMsgAnswerPoll         int = 100
+	DefaultWeightMsgRegisterReaction   int = 100
+	DefaultWeightMsgSaveAccount        int = 100
+	DefaultWeightMsgDeleteAccount      int = 100
+	DefaultWeightMsgReportPost         int = 100
+	DefaultWeightMsgCreateRelationship int = 100
+	DefaultWeightMsgDeleteRelationship int = 100
 )

cli_test/cli_profile_test.go

@@ -4,6 +4,7 @@
 package clitest
 
 import (
+	"github.com/desmos-labs/desmos/x/profiles/types"
 	"testing"
 
 	"github.com/cosmos/cosmos-sdk/tests"
@@ -327,3 +328,114 @@ func TestDesmosCLIProfileDelete(t *testing.T) {
 
 	f.Cleanup()
 }
+
+func TestDesmosCLICreateMonoDirectionalRelationship(t *testing.T) {
+	t.Parallel()
+	f := InitFixtures(t)
+
+	// Start Desmosd server
+	proc := f.GDStart()
+	defer proc.Stop(false)
+
+	// Save key addresses for later use
+	fooAddr := f.KeyAddress(keyFoo)
+
+	// Later usage variables
+	fooAcc := f.QueryAccount(fooAddr)
+	startTokens := sdk.TokensFromConsensusPower(140)
+	require.Equal(t, startTokens, fooAcc.GetCoins().AmountOf(denom))
+	receiver, err := sdk.AccAddressFromBech32("desmos15ux5mc98jlhsg30dzwwv06ftjs82uy4g3t99ru")
+	require.NoError(t, err)
+
+	// Create mono directional relationship
+	success, _, sterr := f.TxCreateMonoDirectionalRelationship(receiver, fooAddr, "-y")
+	require.True(t, success)
+	require.Empty(t, sterr)
+	tests.WaitForNextNBlocksTM(1, f.Port)
+
+	// Make sure relationship is created
+	storedRelationships := f.QueryRelationships(fooAddr)
+	require.NotEmpty(t, storedRelationships)
+	expRelationship := types.NewRelationshipResponse([]sdk.AccAddress{receiver})
+	require.Equal(t, expRelationship, storedRelationships)
+
+	// Delete the relationship to perform other tests
+	success, _, sterr = f.TxDeleteUserRelationship(receiver, fooAddr, "-y")
+	require.True(t, success)
+	require.Empty(t, sterr)
+	tests.WaitForNextNBlocksTM(1, f.Port)
+
+	// Test --dry-tun
+	success, _, _ = f.TxCreateMonoDirectionalRelationship(receiver, fooAddr, "--dry-run")
+	require.True(t, success)
+
+	// Test --generate-only
+	success, stdout, stderr := f.TxCreateMonoDirectionalRelationship(receiver, fooAddr, "--generate-only=true")
+	require.Empty(t, stderr)
+	require.True(t, success)
+	msg := unmarshalStdTx(f.T, stdout)
+	require.NotZero(t, msg.Fee.Gas)
+	require.Len(t, msg.Msgs, 1)
+	require.Len(t, msg.GetSignatures(), 0)
+
+	f.Cleanup()
+}
+
+func TestDesmosCLIDeleteRelationship(t *testing.T) {
+	t.Parallel()
+	f := InitFixtures(t)
+
+	// Start Desmosd server
+	proc := f.GDStart()
+	defer proc.Stop(false)
+
+	// Save key addresses for later use
+	fooAddr := f.KeyAddress(keyFoo)
+
+	// Later usage variables
+	fooAcc := f.QueryAccount(fooAddr)
+	startTokens := sdk.TokensFromConsensusPower(140)
+	require.Equal(t, startTokens, fooAcc.GetCoins().AmountOf(denom))
+	receiver, err := sdk.AccAddressFromBech32("desmos15ux5mc98jlhsg30dzwwv06ftjs82uy4g3t99ru")
+	require.NoError(t, err)
+
+	// Create mono directional relationship
+	success, _, sterr := f.TxCreateMonoDirectionalRelationship(receiver, fooAddr, "-y")
+	require.True(t, success)
+	require.Empty(t, sterr)
+	tests.WaitForNextNBlocksTM(1, f.Port)
+
+	// Make sure relationship is created
+	storedRelationships := f.QueryRelationships(fooAddr)
+	require.NotEmpty(t, storedRelationships)
+	expRelationship := types.NewRelationshipResponse([]sdk.AccAddress{receiver})
+	require.Equal(t, expRelationship, storedRelationships)
+
+	// Delete the relationship to perform other tests
+	success, _, sterr = f.TxDeleteUserRelationship(receiver, fooAddr, "-y")
+	require.True(t, success)
+	require.Empty(t, sterr)
+	tests.WaitForNextNBlocksTM(1, f.Port)
+
+	// Make sure relationship is deleted
+	storedRelationships = f.QueryRelationships(fooAddr)
+	require.Empty(t, storedRelationships)
+
+	// Create mono directional relationship
+	success, _, sterr = f.TxCreateMonoDirectionalRelationship(receiver, fooAddr, "-y")
+
+	// Test --dry-tun
+	success, _, _ = f.TxDeleteUserRelationship(receiver, fooAddr, "--dry-run")
+	require.True(t, success)
+
+	// Test --generate-only
+	success, stdout, stderr := f.TxDeleteUserRelationship(receiver, fooAddr, "--generate-only=true")
+	require.Empty(t, stderr)
+	require.True(t, success)
+	msg := unmarshalStdTx(f.T, stdout)
+	require.NotZero(t, msg.Fee.Gas)
+	require.Len(t, msg.Msgs, 1)
+	require.Len(t, msg.GetSignatures(), 0)
+
+	f.Cleanup()
+}

cli_test/test_helpers.go

@@ -28,7 +28,7 @@ import (
 
 	"github.com/desmos-labs/desmos/app"
 	postsTypes "github.com/desmos-labs/desmos/x/posts/types"
-	profileTypes "github.com/desmos-labs/desmos/x/profiles/types"
+	profilesTypes "github.com/desmos-labs/desmos/x/profiles/types"
 	reportsTypes "github.com/desmos-labs/desmos/x/reports/types"
 )
 
@@ -467,6 +467,18 @@ func (f *Fixtures) TxProfileDelete(from sdk.AccAddress, flags ...string) (bool,
 	return executeWriteRetStdStreams(f.T, addFlags(cmd, flags), clientkeys.DefaultKeyPass)
 }
 
+func (f *Fixtures) TxCreateMonoDirectionalRelationship(receiver, from sdk.AccAddress, flags ...string) (bool, string, string) {
+	cmd := fmt.Sprintf(`%s tx profiles create-relationship %s --keyring-backend=test --from=%s %v`,
+		f.DesmoscliBinary, receiver, from, f.Flags())
+	return executeWriteRetStdStreams(f.T, addFlags(cmd, flags), clientkeys.DefaultKeyPass)
+}
+
+func (f *Fixtures) TxDeleteUserRelationship(receiver, from sdk.AccAddress, flags ...string) (bool, string, string) {
+	cmd := fmt.Sprintf(`%s tx profiles delete-relationship %s --keyring-backend=test --from=%s %v`,
+		f.DesmoscliBinary, receiver, from, f.Flags())
+	return executeWriteRetStdStreams(f.T, addFlags(cmd, flags), clientkeys.DefaultKeyPass)
+}
+
 //___________________________________________________________________________________
 // desmoscli tx reports
 
@@ -791,17 +803,29 @@ func (f *Fixtures) QueryReactions(flags ...string) postsTypes.Reactions {
 // query profile
 
 // QueryProfile returns stored profiles
-func (f *Fixtures) QueryProfiles(flags ...string) profileTypes.Profiles {
+func (f *Fixtures) QueryProfiles(flags ...string) profilesTypes.Profiles {
 	cmd := fmt.Sprintf("%s query profiles all --output=json %s", f.DesmoscliBinary, f.Flags())
 	res, errStr := tests.ExecuteT(f.T, addFlags(cmd, flags), "")
 	require.Empty(f.T, errStr)
 	cdc := app.MakeCodec()
-	var storedProfile profileTypes.Profiles
+	var storedProfile profilesTypes.Profiles
 	err := cdc.UnmarshalJSON([]byte(res), &storedProfile)
 	require.NoError(f.T, err)
 	return storedProfile
 }
 
+// QueryRelationships returns stored relationships
+func (f *Fixtures) QueryRelationships(user sdk.AccAddress, flags ...string) profilesTypes.RelationshipsResponse {
+	cmd := fmt.Sprintf("%s query profiles relationships %s --output=json %s", f.DesmoscliBinary, user, f.Flags())
+	res, errStr := tests.ExecuteT(f.T, addFlags(cmd, flags), "")
+	require.Empty(f.T, errStr)
+	cdc := app.MakeCodec()
+	var storedRelationships profilesTypes.RelationshipsResponse
+	err := cdc.UnmarshalJSON([]byte(res), &storedRelationships)
+	require.NoError(f.T, err)
+	return storedRelationships
+}
+
 //___________________________________________________________________________________
 // query reports
 

x/posts/types/alias.go

@@ -35,6 +35,22 @@ const (
 
 var (
 	// functions aliases
+	ParsePostID                = models.ParsePostID
+	NewPost                    = models.NewPost
+	NewPostResponse            = models.NewPostResponse
+	PostStoreKey               = models.PostStoreKey
+	PostIndexedIDStoreKey      = models.PostIndexedIDStoreKey
+	PostCommentsStoreKey       = models.PostCommentsStoreKey
+	PostReactionsStoreKey      = models.PostReactionsStoreKey
+	ReactionsStoreKey          = models.ReactionsStoreKey
+	PollAnswersStoreKey        = models.PollAnswersStoreKey
+	RegisterModelsCodec        = models.RegisterModelsCodec
+	IsValidPostID              = common.IsValidPostID
+	IsValidSubspace            = common.IsValidSubspace
+	IsValidReactionCode        = common.IsValidReactionCode
+	GetEmojiByShortCodeOrValue = common.GetEmojiByShortCodeOrValue
+	NewAttachment              = common.NewAttachment
+	NewAttachments             = common.NewAttachments
 	ParseAnswerID              = polls.ParseAnswerID
 	NewPollAnswer              = polls.NewPollAnswer
 	NewPollAnswers             = polls.NewPollAnswers
@@ -47,29 +63,13 @@ var (
 	NewReaction                = reactions.NewReaction
 	IsEmoji                    = reactions.IsEmoji
 	NewReactions               = reactions.NewReactions
+	RegisterMessagesCodec      = msgs.RegisterMessagesCodec
+	NewMsgAddPostReaction      = msgs.NewMsgAddPostReaction
+	NewMsgRemovePostReaction   = msgs.NewMsgRemovePostReaction
 	NewMsgAnswerPoll           = msgs.NewMsgAnswerPoll
 	NewMsgCreatePost           = msgs.NewMsgCreatePost
 	NewMsgEditPost             = msgs.NewMsgEditPost
 	NewMsgRegisterReaction     = msgs.NewMsgRegisterReaction
-	RegisterMessagesCodec      = msgs.RegisterMessagesCodec
-	NewMsgAddPostReaction      = msgs.NewMsgAddPostReaction
-	NewMsgRemovePostReaction   = msgs.NewMsgRemovePostReaction
-	ParsePostID                = models.ParsePostID
-	NewPost                    = models.NewPost
-	NewPostResponse            = models.NewPostResponse
-	PostStoreKey               = models.PostStoreKey
-	PostIndexedIDStoreKey      = models.PostIndexedIDStoreKey
-	PostCommentsStoreKey       = models.PostCommentsStoreKey
-	PostReactionsStoreKey      = models.PostReactionsStoreKey
-	ReactionsStoreKey          = models.ReactionsStoreKey
-	PollAnswersStoreKey        = models.PollAnswersStoreKey
-	RegisterModelsCodec        = models.RegisterModelsCodec
-	NewAttachment              = common.NewAttachment
-	NewAttachments             = common.NewAttachments
-	IsValidPostID              = common.IsValidPostID
-	IsValidSubspace            = common.IsValidSubspace
-	IsValidReactionCode        = common.IsValidReactionCode
-	GetEmojiByShortCodeOrValue = common.GetEmojiByShortCodeOrValue
 
 	// variable aliases
 	MsgsCodec                = msgs.MsgsCodec
@@ -85,12 +85,6 @@ var (
 )
 
 type (
-	MsgAnswerPoll            = msgs.MsgAnswerPoll
-	MsgCreatePost            = msgs.MsgCreatePost
-	MsgEditPost              = msgs.MsgEditPost
-	MsgRegisterReaction      = msgs.MsgRegisterReaction
-	MsgAddPostReaction       = msgs.MsgAddPostReaction
-	MsgRemovePostReaction    = msgs.MsgRemovePostReaction
 	PostID                   = models.PostID
 	PostIDs                  = models.PostIDs
 	Post                     = models.Post
@@ -111,4 +105,10 @@ type (
 	PostReactions            = reactions.PostReactions
 	Reaction                 = reactions.Reaction
 	Reactions                = reactions.Reactions
+	MsgAddPostReaction       = msgs.MsgAddPostReaction
+	MsgRemovePostReaction    = msgs.MsgRemovePostReaction
+	MsgAnswerPoll            = msgs.MsgAnswerPoll
+	MsgCreatePost            = msgs.MsgCreatePost
+	MsgEditPost              = msgs.MsgEditPost
+	MsgRegisterReaction      = msgs.MsgRegisterReaction
 )

x/posts/types/models/alias.go

@@ -39,13 +39,13 @@ var (
 	GetEmojiByShortCodeOrValue = common.GetEmojiByShortCodeOrValue
 	NewAttachment              = common.NewAttachment
 	NewAttachments             = common.NewAttachments
-	ParseAnswerID              = polls.ParseAnswerID
-	NewPollAnswer              = polls.NewPollAnswer
-	NewPollAnswers             = polls.NewPollAnswers
 	NewPollData                = polls.NewPollData
 	ArePollDataEquals          = polls.ArePollDataEquals
 	NewUserAnswer              = polls.NewUserAnswer
 	NewUserAnswers             = polls.NewUserAnswers
+	ParseAnswerID              = polls.ParseAnswerID
+	NewPollAnswer              = polls.NewPollAnswer
+	NewPollAnswers             = polls.NewPollAnswers
 	NewPostReaction            = reactions.NewPostReaction
 	NewPostReactions           = reactions.NewPostReactions
 	NewReaction                = reactions.NewReaction
@@ -68,12 +68,12 @@ type (
 	KeyValue      = common.KeyValue
 	Attachment    = common.Attachment
 	Attachments   = common.Attachments
-	AnswerID      = polls.AnswerID
-	PollAnswer    = polls.PollAnswer
-	PollAnswers   = polls.PollAnswers
 	PollData      = polls.PollData
 	UserAnswer    = polls.UserAnswer
 	UserAnswers   = polls.UserAnswers
+	AnswerID      = polls.AnswerID
+	PollAnswer    = polls.PollAnswer
+	PollAnswers   = polls.PollAnswers
 	PostReaction  = reactions.PostReaction
 	PostReactions = reactions.PostReactions
 	Reaction      = reactions.Reaction

x/profiles/client/cli/query.go

@@ -7,9 +7,8 @@ import (
 	"github.com/cosmos/cosmos-sdk/client/context"
 	"github.com/cosmos/cosmos-sdk/client/flags"
 	"github.com/cosmos/cosmos-sdk/codec"
-	"github.com/spf13/cobra"
-
 	"github.com/desmos-labs/desmos/x/profiles/types"
+	"github.com/spf13/cobra"
 )
 
 // GetQueryCmd adds the query commands
@@ -25,6 +24,7 @@ func GetQueryCmd(cdc *codec.Codec) *cobra.Command {
 		GetCmdQueryProfile(cdc),
 		GetCmdQueryProfiles(cdc),
 		GetCmdQueryProfileParams(cdc),
+		GetCmdQueryUserRelationships(cdc),
 	)...)
 	return profileQueryCmd
 }
@@ -57,7 +57,7 @@ func GetCmdQueryProfiles(cdc *codec.Codec) *cobra.Command {
 	return &cobra.Command{
 		Use:   "all",
 		Short: "Retrieve all the registered profiles.",
-		Args:  cobra.ExactArgs(0),
+		Args:  cobra.NoArgs,
 		RunE: func(cmd *cobra.Command, args []string) error {
 			cliCtx := context.NewCLIContext().WithCodec(cdc)
 
@@ -80,7 +80,7 @@ func GetCmdQueryProfileParams(cdc *codec.Codec) *cobra.Command {
 	return &cobra.Command{
 		Use:   "parameters",
 		Short: "Retrieve all the profile module parameters",
-		Args:  cobra.ExactArgs(0),
+		Args:  cobra.NoArgs,
 		RunE: func(cmd *cobra.Command, args []string) error {
 			cliCtx := context.NewCLIContext().WithCodec(cdc)
 
@@ -97,3 +97,26 @@ func GetCmdQueryProfileParams(cdc *codec.Codec) *cobra.Command {
 		},
 	}
 }
+
+// GetCmdQueryUserRelationships queries all the profiles' users' relationships
+func GetCmdQueryUserRelationships(cdc *codec.Codec) *cobra.Command {
+	return &cobra.Command{
+		Use:   "relationships [address]",
+		Short: "Retrieve all the user's relationships",
+		Args:  cobra.ExactArgs(1),
+		RunE: func(cmd *cobra.Command, args []string) error {
+			cliCtx := context.NewCLIContext().WithCodec(cdc)
+
+			route := fmt.Sprintf("custom/%s/%s/%s", types.QuerierRoute, types.QueryRelationships, args[0])
+			res, _, err := cliCtx.QueryWithData(route, nil)
+			if err != nil {
+				fmt.Printf("Could not find any relationship associated with the given address %s", args[0])
+				return nil
+			}
+
+			var out types.RelationshipsResponse
+			cdc.MustUnmarshalJSON(res, &out)
+			return cliCtx.PrintOutput(out)
+		},
+	}
+}