Setup a temporary mock chat for testing

Author: Jeff Yanta

pkg/code/data/chat/v2/id.go

@@ -29,6 +29,16 @@ func GetChatIdFromBytes(buffer []byte) (ChatId, error) {
 	return typed, nil
 }
 
+// GetChatIdFromBytes gets a chat ID from the string representation
+func GetChatIdFromString(value string) (ChatId, error) {
+	decoded, err := hex.DecodeString(value)
+	if err != nil {
+		return ChatId{}, errors.Wrap(err, "value is not a hexadecimal string")
+	}
+
+	return GetChatIdFromBytes(decoded)
+}
+
 // GetChatIdFromProto gets a chat ID from the protobuf variant
 func GetChatIdFromProto(proto *chatpb.ChatId) (ChatId, error) {
 	if err := proto.Validate(); err != nil {
@@ -84,6 +94,16 @@ func GetMemberIdFromBytes(buffer []byte) (MemberId, error) {
 	return typed, nil
 }
 
+// GetMemberIdFromString gets a chat member ID from the string representation
+func GetMemberIdFromString(value string) (MemberId, error) {
+	decoded, err := uuid.Parse(value)
+	if err != nil {
+		return MemberId{}, errors.Wrap(err, "value is not a uuid string")
+	}
+
+	return GetMemberIdFromBytes(decoded[:])
+}
+
 // GetMemberIdFromProto gets a member ID from the protobuf variant
 func GetMemberIdFromProto(proto *chatpb.ChatMemberId) (MemberId, error) {
 	if err := proto.Validate(); err != nil {
@@ -171,6 +191,16 @@ func GetMessageIdFromBytes(buffer []byte) (MessageId, error) {
 	return typed, nil
 }
 
+// GetMessageIdFromString gets a chat message ID from the string representation
+func GetMessageIdFromString(value string) (MessageId, error) {
+	decoded, err := uuid.Parse(value)
+	if err != nil {
+		return MessageId{}, errors.Wrap(err, "value is not a uuid string")
+	}
+
+	return GetMessageIdFromBytes(decoded[:])
+}
+
 // GetMessageIdFromProto gets a message ID from the protobuf variant
 func GetMessageIdFromProto(proto *chatpb.ChatMessageId) (MessageId, error) {
 	if err := proto.Validate(); err != nil {

pkg/code/server/grpc/chat/v2/server.go

@@ -68,9 +68,45 @@ func NewChatServer(data code_data.Provider, auth *auth_util.RPCSignatureVerifier
 		go s.asyncChatEventStreamNotifier(i, channel)
 	}
 
+	// todo: Remove when testing is complete
+	s.setupMockChat()
+
 	return s
 }
 
+func (s *server) setupMockChat() {
+	ctx := context.Background()
+
+	chatId, _ := chat.GetChatIdFromString("c355fcec8c521e7937d45283d83bbfc63a0c688004f2386a535fc817218f917b")
+	chatRecord := &chat.ChatRecord{
+		ChatId:     chatId,
+		ChatType:   chat.ChatTypeTwoWay,
+		IsVerified: true,
+		CreatedAt:  time.Now(),
+	}
+	s.data.PutChatV2(ctx, chatRecord)
+
+	memberId1, _ := chat.GetMemberIdFromString("034dda45-b4c2-45db-b1da-181298898a16")
+	memberRecord1 := &chat.MemberRecord{
+		ChatId:     chatId,
+		MemberId:   memberId1,
+		Platform:   chat.PlatformCode,
+		PlatformId: "8bw4gaRQk91w7vtgTN4E12GnKecY2y6CjPai7WUvWBQ8",
+		JoinedAt:   time.Now(),
+	}
+	s.data.PutChatMemberV2(ctx, memberRecord1)
+
+	memberId2, _ := chat.GetMemberIdFromString("a9d27058-f2d8-4034-bf52-b20c09a670de")
+	memberRecord2 := &chat.MemberRecord{
+		ChatId:     chatId,
+		MemberId:   memberId2,
+		Platform:   chat.PlatformCode,
+		PlatformId: "EDknQfoUnj73L56vKtEc6Qqw5VoHaF32eHYdz3V4y27M",
+		JoinedAt:   time.Now(),
+	}
+	s.data.PutChatMemberV2(ctx, memberRecord2)
+}
+
 func (s *server) GetChats(ctx context.Context, req *chatpb.GetChatsRequest) (*chatpb.GetChatsResponse, error) {
 	log := s.log.WithField("method", "GetChats")
 	log = client.InjectLoggingMetadata(ctx, log)