Re-introduce message sent on USDC swap (#87)

Author: jeffyanta

pkg/code/chat/message_kin_purchases.go

@@ -44,6 +44,26 @@ func ToUsdcDepositedMessage(signature string, ts time.Time) (*chatpb.ChatMessage
 	return newProtoChatMessage(signature, content, ts)
 }
 
+// NewUsdcBeingConvertedMessage generates a new message generated upon initiating
+// a USDC swap to be inserted into the Kin Purchases chat.
+func NewUsdcBeingConvertedMessage() (*chatpb.ChatMessage, error) {
+	messageId, err := common.NewRandomAccount()
+	if err != nil {
+		return nil, err
+	}
+
+	content := []*chatpb.Content{
+		{
+			Type: &chatpb.Content_Localized{
+				Localized: &chatpb.LocalizedContent{
+					KeyOrText: localization.ChatMessageUsdcBeingConverted,
+				},
+			},
+		},
+	}
+	return newProtoChatMessage(messageId.PublicKey().ToBase58(), content, time.Now())
+}
+
 // 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) {

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

@@ -16,8 +16,10 @@ import (
 	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"
+	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/grpc/client"
 	"github.com/code-payments/code-server/pkg/jupiter"
@@ -28,6 +30,10 @@ import (
 	"github.com/code-payments/code-server/pkg/usdc"
 )
 
+var (
+	swapNotificationTimeByOwner = make(map[string]time.Time)
+)
+
 func (s *transactionServer) Swap(streamer transactionpb.Transaction_SwapServer) error {
 	ctx, cancel := context.WithTimeout(streamer.Context(), s.conf.swapTimeout.Get(streamer.Context()))
 	defer cancel()
@@ -364,6 +370,8 @@ func (s *transactionServer) Swap(streamer transactionpb.Transaction_SwapServer)
 
 	log.Debug("submitted transaction")
 
+	s.bestEffortNotifyUserOfSwapInProgress(ctx, owner)
+
 	if !initiateReq.WaitForBlockchainStatus {
 		err = streamer.Send(&transactionpb.SwapResponse{
 			Response: &transactionpb.SwapResponse_Success_{
@@ -475,6 +483,38 @@ func (s *transactionServer) validateSwap(
 	return nil
 }
 
+func (s *transactionServer) bestEffortNotifyUserOfSwapInProgress(ctx context.Context, owner *common.Account) {
+	// Avoid spamming users chat messages due to retries of the Swap RPC within
+	// small periods of time. Implementation isn't perfect, but we'll be updating
+	// notifications later anyways.
+	lastNotificationTs, ok := swapNotificationTimeByOwner[owner.PublicKey().ToBase58()]
+	if ok && time.Since(lastNotificationTs) < time.Minute {
+		return
+	}
+	swapNotificationTimeByOwner[owner.PublicKey().ToBase58()] = time.Now()
+
+	chatMessage, err := chat_util.NewUsdcBeingConvertedMessage()
+	if err != nil {
+		return
+	}
+
+	canPush, err := chat_util.SendKinPurchasesMessage(ctx, s.data, owner, chatMessage)
+	if err != nil {
+		return
+	}
+
+	if canPush {
+		push_util.SendChatMessagePushNotification(
+			ctx,
+			s.data,
+			s.pusher,
+			chat_util.KinPurchasesName,
+			owner,
+			chatMessage,
+		)
+	}
+}
+
 func (s *transactionServer) mustLoadSwapSubsidizer(ctx context.Context) {
 	log := s.log.WithFields(logrus.Fields{
 		"method": "mustLoadSwapSubsidizer",