Move buy module chat messages into a new Kin Purchases chat (#75)

Author: jeffyanta

pkg/code/async/geyser/external_deposit.go

@@ -273,15 +273,15 @@ func processPotentialExternalDeposit(ctx context.Context, conf *conf, data code_
 				return errors.Wrap(err, "error creating chat message")
 			}
 
-			canPush, err := chat_util.SendCodeTeamMessage(ctx, data, chatMessageReceiver, chatMessage)
+			canPush, err := chat_util.SendKinPurchasesMessage(ctx, data, chatMessageReceiver, chatMessage)
 			switch err {
 			case nil:
 				if canPush {
 					push.SendChatMessagePushNotification(
 						ctx,
 						data,
 						pusher,
-						chat_util.CodeTeamName,
+						chat_util.KinPurchasesName,
 						chatMessageReceiver,
 						chatMessage,
 					)
@@ -692,15 +692,15 @@ func delayedUsdcDepositProcessing(
 		return
 	}
 
-	canPush, err := chat_util.SendCodeTeamMessage(ctx, data, ownerAccount, chatMessage)
+	canPush, err := chat_util.SendKinPurchasesMessage(ctx, data, ownerAccount, chatMessage)
 	switch err {
 	case nil:
 		if canPush {
 			push.SendChatMessagePushNotification(
 				ctx,
 				data,
 				pusher,
-				chat_util.CodeTeamName,
+				chat_util.KinPurchasesName,
 				ownerAccount,
 				chatMessage,
 			)

pkg/code/chat/chat.go

@@ -5,6 +5,7 @@ import "github.com/code-payments/code-server/pkg/code/localization"
 const (
 	CashTransactionsName = "Cash Transactions" // Renamed to Cash Payments on client
 	CodeTeamName         = "Code Team"
+	KinPurchasesName     = "Kin Purchases"
 	PaymentsName         = "Payments" // Renamed to Web Payments on client
 
 	// Test chats used for unit/integration testing only
@@ -28,6 +29,11 @@ var (
 			CanMute:              true,
 			CanUnsubscribe:       false,
 		},
+		KinPurchasesName: {
+			TitleLocalizationKey: localization.ChatTitleKinPurchases,
+			CanMute:              true,
+			CanUnsubscribe:       false,
+		},
 		PaymentsName: {
 			TitleLocalizationKey: localization.ChatTitlePayments,
 			CanMute:              true,

pkg/code/chat/message_code_team.go

@@ -2,12 +2,10 @@ package chat
 
 import (
 	"context"
-	"time"
 
 	"github.com/pkg/errors"
 
 	chatpb "github.com/code-payments/code-protobuf-api/generated/go/chat/v1"
-	transactionpb "github.com/code-payments/code-protobuf-api/generated/go/transaction/v2"
 
 	"github.com/code-payments/code-server/pkg/code/common"
 	code_data "github.com/code-payments/code-server/pkg/code/data"
@@ -42,54 +40,6 @@ func ToReferralBonusMessage(intentRecord *intent.Record) (*chatpb.ChatMessage, e
 	return newIncentiveMessage(localization.ChatMessageReferralBonus, intentRecord)
 }
 
-// ToUsdcDepositedMessage turns details of a USDC deposit transaction into a chat
-// message to be inserted into the Code Team chat.
-func ToUsdcDepositedMessage(signature string, ts time.Time) (*chatpb.ChatMessage, error) {
-	// todo: Don't have a way of propagating quarks, but that's probably ok since
-	//       this is a temporary message for testing swaps.
-	content := []*chatpb.Content{
-		{
-			Type: &chatpb.Content_Localized{
-				Localized: &chatpb.LocalizedContent{
-					KeyOrText: localization.ChatMessageUsdcDeposited,
-				},
-			},
-		},
-	}
-	return newProtoChatMessage(signature, content, ts)
-}
-
-// ToKinAvailableForUseMessage turns details of a USDC swap transaction into a
-// chat message to be inserted into the Code Team chat.
-func ToKinAvailableForUseMessage(signature string, ts time.Time, purchases ...*transactionpb.ExchangeDataWithoutRate) (*chatpb.ChatMessage, error) {
-	if len(purchases) == 0 {
-		return nil, errors.New("no purchases for kin available chat message")
-	}
-
-	content := []*chatpb.Content{
-		{
-			Type: &chatpb.Content_Localized{
-				Localized: &chatpb.LocalizedContent{
-					KeyOrText: localization.ChatMessageKinAvailableForUse,
-				},
-			},
-		},
-	}
-	for _, purchase := range purchases {
-		content = append(content, &chatpb.Content{
-			Type: &chatpb.Content_ExchangeData{
-				ExchangeData: &chatpb.ExchangeDataContent{
-					Verb: chatpb.ExchangeDataContent_PURCHASED,
-					ExchangeData: &chatpb.ExchangeDataContent_Partial{
-						Partial: purchase,
-					},
-				},
-			},
-		})
-	}
-	return newProtoChatMessage(signature, content, ts)
-}
-
 func newIncentiveMessage(localizedTextKey string, intentRecord *intent.Record) (*chatpb.ChatMessage, error) {
 	exchangeData, ok := getExchangeDataFromIntent(intentRecord)
 	if !ok {

pkg/code/chat/message_kin_purchases.go

@@ -0,0 +1,76 @@
+package chat
+
+import (
+	"context"
+	"time"
+
+	"github.com/pkg/errors"
+
+	chatpb "github.com/code-payments/code-protobuf-api/generated/go/chat/v1"
+	transactionpb "github.com/code-payments/code-protobuf-api/generated/go/transaction/v2"
+
+	"github.com/code-payments/code-server/pkg/code/common"
+	code_data "github.com/code-payments/code-server/pkg/code/data"
+	"github.com/code-payments/code-server/pkg/code/data/chat"
+	"github.com/code-payments/code-server/pkg/code/localization"
+)
+
+// SendKinPurchasesMessage sends a message to the Kin Purchases chat.
+func SendKinPurchasesMessage(ctx context.Context, data code_data.Provider, receiver *common.Account, chatMessage *chatpb.ChatMessage) (bool, error) {
+	return SendChatMessage(
+		ctx,
+		data,
+		KinPurchasesName,
+		chat.ChatTypeInternal,
+		true,
+		receiver,
+		chatMessage,
+		false,
+	)
+}
+
+// ToUsdcDepositedMessage turns details of a USDC deposit transaction into a chat
+// message to be inserted into the Kin Purchases chat.
+func ToUsdcDepositedMessage(signature string, ts time.Time) (*chatpb.ChatMessage, error) {
+	content := []*chatpb.Content{
+		{
+			Type: &chatpb.Content_Localized{
+				Localized: &chatpb.LocalizedContent{
+					KeyOrText: localization.ChatMessageUsdcDeposited,
+				},
+			},
+		},
+	}
+	return newProtoChatMessage(signature, content, ts)
+}
+
+// ToKinAvailableForUseMessage turns details of a USDC swap transaction into a
+// chat message to be inserted into the Kin Purchases chat.
+func ToKinAvailableForUseMessage(signature string, ts time.Time, purchases ...*transactionpb.ExchangeDataWithoutRate) (*chatpb.ChatMessage, error) {
+	if len(purchases) == 0 {
+		return nil, errors.New("no purchases for kin available chat message")
+	}
+
+	content := []*chatpb.Content{
+		{
+			Type: &chatpb.Content_Localized{
+				Localized: &chatpb.LocalizedContent{
+					KeyOrText: localization.ChatMessageKinAvailableForUse,
+				},
+			},
+		},
+	}
+	for _, purchase := range purchases {
+		content = append(content, &chatpb.Content{
+			Type: &chatpb.Content_ExchangeData{
+				ExchangeData: &chatpb.ExchangeDataContent{
+					Verb: chatpb.ExchangeDataContent_PURCHASED,
+					ExchangeData: &chatpb.ExchangeDataContent_Partial{
+						Partial: purchase,
+					},
+				},
+			},
+		})
+	}
+	return newProtoChatMessage(signature, content, ts)
+}

pkg/code/localization/keys.go

@@ -36,6 +36,7 @@ const (
 
 	ChatTitleCashTransactions = "title.chat.cashTransactions"
 	ChatTitleCodeTeam         = "title.chat.codeTeam"
+	ChatTitleKinPurchases     = "title.chat.kinPurchases"
 	ChatTitlePayments         = "title.chat.payments"
 
 	// Message Bodies