feat: cron

conversation/conversation.go

@@ -217,3 +217,10 @@ func (x *GetFullOwnerConversationIDsResp) Format() any {
 	}
 	return x
 }
+
+func (x *ClearUserConversationMsgReq) Check() error {
+	if x.Limit <= 0 {
+		return errors.New("limit is invalid")
+	}
+	return nil
+}

conversation/conversation.proto

@@ -296,6 +296,14 @@ message GetPinnedConversationIDsResp {
   repeated string conversationIDs = 1;
 }
 
+message ClearUserConversationMsgReq {
+  int64 timestamp = 1;
+  int32 limit = 2;
+}
+message ClearUserConversationMsgResp {
+  int32 count = 1;
+}
+
 service conversation {
   rpc GetConversation(GetConversationReq) returns (GetConversationResp);
   rpc GetSortedConversationList(GetSortedConversationListReq) returns (GetSortedConversationListResp);
@@ -320,4 +328,5 @@ service conversation {
   rpc GetConversationsNeedClearMsg(GetConversationsNeedClearMsgReq) returns (GetConversationsNeedClearMsgResp);
   rpc GetNotNotifyConversationIDs(GetNotNotifyConversationIDsReq) returns (GetNotNotifyConversationIDsResp);
   rpc GetPinnedConversationIDs(GetPinnedConversationIDsReq) returns (GetPinnedConversationIDsResp);
+  rpc ClearUserConversationMsg(ClearUserConversationMsgReq) returns (ClearUserConversationMsgResp);
 }

msg/msg.go

@@ -17,6 +17,7 @@ package msg
 import (
 	"errors"
 	"fmt"
+	"time"
 )
 
 func (x *GetMaxAndMinSeqReq) Check() error {
@@ -239,3 +240,13 @@ func (x *SeqsInfoResp) Format() any {
 	}
 	return x
 }
+
+func (x *DestructMsgsReq) Check() error {
+	if x.Timestamp > time.Now().UnixMilli() {
+		return errors.New("request millisecond timestamp error")
+	}
+	if x.Limit <= 0 {
+		return errors.New("request limit error")
+	}
+	return nil
+}