Avoid sending the swap in progress chat message if the USDC deposited message wasn't sent (#88)

Author: jeffyanta

pkg/code/chat/message_kin_purchases.go

@@ -15,6 +15,12 @@ import (
 	"github.com/code-payments/code-server/pkg/code/localization"
 )
 
+// GetKinPurchasesChatId returns the chat ID for the Kin Purchases chat for a
+// given owner account
+func GetKinPurchasesChatId(owner *common.Account) chat.ChatId {
+	return chat.GetChatId(KinPurchasesName, owner.PublicKey().ToBase58(), true)
+}
+
 // 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(

pkg/code/server/grpc/transaction/v2/swap.go

@@ -11,16 +11,21 @@ import (
 	"github.com/sirupsen/logrus"
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/status"
+	"google.golang.org/protobuf/proto"
 
+	chatpb "github.com/code-payments/code-protobuf-api/generated/go/chat/v1"
 	commonpb "github.com/code-payments/code-protobuf-api/generated/go/common/v1"
 	transactionpb "github.com/code-payments/code-protobuf-api/generated/go/transaction/v2"
 
 	"github.com/code-payments/code-server/pkg/code/balance"
 	chat_util "github.com/code-payments/code-server/pkg/code/chat"
 	"github.com/code-payments/code-server/pkg/code/common"
 	"github.com/code-payments/code-server/pkg/code/data/account"
+	"github.com/code-payments/code-server/pkg/code/data/chat"
+	"github.com/code-payments/code-server/pkg/code/localization"
 	push_util "github.com/code-payments/code-server/pkg/code/push"
 	currency_lib "github.com/code-payments/code-server/pkg/currency"
+	"github.com/code-payments/code-server/pkg/database/query"
 	"github.com/code-payments/code-server/pkg/grpc/client"
 	"github.com/code-payments/code-server/pkg/jupiter"
 	"github.com/code-payments/code-server/pkg/kin"
@@ -493,6 +498,31 @@ func (s *transactionServer) bestEffortNotifyUserOfSwapInProgress(ctx context.Con
 	}
 	swapNotificationTimeByOwner[owner.PublicKey().ToBase58()] = time.Now()
 
+	chatId := chat_util.GetKinPurchasesChatId(owner)
+
+	// Inspect the chat history for a USDC deposited message. If that message
+	// doesn't exist, then avoid sending the swap in progress chat message, since
+	// it can lead to user confusion.
+	chatMessageRecords, err := s.data.GetAllChatMessages(ctx, chatId, query.WithDirection(query.Descending), query.WithLimit(1))
+	switch err {
+	case nil:
+		var protoChatMessage chatpb.ChatMessage
+		err := proto.Unmarshal(chatMessageRecords[0].Data, &protoChatMessage)
+		if err != nil {
+			return
+		}
+
+		switch typed := protoChatMessage.Content[0].Type.(type) {
+		case *chatpb.Content_Localized:
+			if typed.Localized.KeyOrText != localization.ChatMessageUsdcDeposited {
+				return
+			}
+		}
+	case chat.ErrMessageNotFound:
+	default:
+		return
+	}
+
 	chatMessage, err := chat_util.NewUsdcBeingConvertedMessage()
 	if err != nil {
 		return