feat: update clean storage api logic

client/modules/chat/components/cards/message/message.tsx

@@ -10,23 +10,17 @@ interface IMessageCardProps {
   sentByUser: boolean
   createdAt: string // datetime string
   document?: any
+  isDocumentExpired: boolean
 }
 const MessageCard: React.FunctionComponent<IMessageCardProps> = ({
   text,
   sentByUser,
   createdAt,
   document,
+  isDocumentExpired,
 }) => {
   const { data: formattedDate } = useCreatedAt({ createdAt })
 
-  const dayDiff = compareDateDifferenceHelper({
-    oldDate: createdAt,
-    newDate: new Date().toISOString(),
-    unit: "day",
-  })
-
-  const isDocumentExpired = dayDiff > 7
-
   const linkify = (text: string | null) => {
     if (!text) return ""
     var urlRegex =

client/modules/chat/components/lists/conversation/conversation.tsx

@@ -37,6 +37,7 @@ const ConversationList = () => {
             body: last_message_uuid.body,
             createdByUuid: last_message_uuid.sender_uuid,
             createdAt: last_message_uuid.created_at,
+            isDocumentExpired: last_message_uuid.is_document_expired,
           }
         : null
 

client/modules/chat/components/lists/message/message.tsx

@@ -16,6 +16,7 @@ interface IMessageListProps {
     body?: string
     createdAt?: string
     document?: IMediaResponse
+    isDocumentExpired?: boolean
   }
 }
 const MessageList: React.FunctionComponent<IMessageListProps> = ({
@@ -91,6 +92,7 @@ const MessageList: React.FunctionComponent<IMessageListProps> = ({
                   key={data.uuid}
                   createdAt={data.created_at}
                   document={data.document}
+                  isDocumentExpired={data.is_document_expired}
                 />
               )
             })}
@@ -103,6 +105,7 @@ const MessageList: React.FunctionComponent<IMessageListProps> = ({
           sentByUser={lastMessage.sentByUser}
           createdAt={lastMessage.createdAt || ""}
           document={lastMessage.document}
+          isDocumentExpired={lastMessage.isDocumentExpired ?? false}
         />
       )}
     </div>

client/modules/chat/components/sections/right/right.tsx

@@ -92,6 +92,7 @@ const ChatRightSection = () => {
           sentByUser:
             currentConversation.lastMessage?.createdByUuid === userUuid,
           createdAt: currentConversation.lastMessage?.createdAt,
+          isDocumentExpired: currentConversation.lastMessage?.isDocumentExpired,
         }}
       />
       <SendMessageForm

client/modules/chat/state/conversations.tsx

@@ -21,6 +21,7 @@ export interface IConversation {
     createdByUuid: string
     body: string
     createdAt: string
+    isDocumentExpired: boolean
   } | null
 }
 

client/types/api/response/chat/message-list.ts

@@ -7,4 +7,5 @@ export interface IMessageListResponse {
   status: "active" | "inactive"
   uuid: string
   document: any //IMediaResponse
+  is_document_expired: boolean
 }

client/types/api/response/conversation-list.ts

@@ -25,6 +25,7 @@ export interface IGetConversationListByUserUuidResponse {
     body: string
     created_at: string
     document: IMediaResponse | null
+    is_document_expired: boolean
   } | null
   last_updated_at: string //datetime string withe time zone
 }

client/types/supabase.ts

@@ -198,6 +198,7 @@ export interface Database {
           created_at: string
           document: Json | null
           id: number
+          is_document_expired: boolean
           sender_uuid: string
           status: Database["public"]["Enums"]["message_status"]
           uuid: string
@@ -208,6 +209,7 @@ export interface Database {
           created_at?: string
           document?: Json | null
           id?: number
+          is_document_expired?: boolean
           sender_uuid?: string
           status?: Database["public"]["Enums"]["message_status"]
           uuid?: string
@@ -218,6 +220,7 @@ export interface Database {
           created_at?: string
           document?: Json | null
           id?: number
+          is_document_expired?: boolean
           sender_uuid?: string
           status?: Database["public"]["Enums"]["message_status"]
           uuid?: string

client/utils/common/api/index.tsx

@@ -722,7 +722,8 @@ export const getConversationListByUserUuid = async ({
         uuid,
         sender_uuid,
         body,
-        document
+        document,
+        is_document_expired
       )
       `
       )

supabase/functions/clean-conversation-storage/index.ts

@@ -37,14 +37,27 @@ serve(async (req: any) => {
       .select("*")
       .not("document", "is", null)
       .lte("created_at", date.toISOString())
+      .eq("is_document_expired", false)
 
+    const uuids = data.map((d) => d.uuid)
     const paths = data.map((d) => d.document.internalPath)
 
     const { data: removeRes } = await server.storage
       .from("conversation_documents")
       .remove(paths)
 
-    return new Response(JSON.stringify(removeRes), {
+    const updateRes = await Promise.all(
+      uuids.map(async (uuid) => {
+        const { data, error } = await server
+          .from("message")
+          .update({ is_document_expired: true })
+          .eq("uuid", uuid)
+          .select("uuid")
+        return data
+      }),
+    )
+
+    return new Response(JSON.stringify(updateRes), {
       headers: { ...corsHeaders, "Content-Type": "application/json" }, // Be sure to add CORS headers here too
       status: 200,
     })

supabase/migrations/20240330174617_add_is_document_expired_for_message_table.sql

@@ -0,0 +1,3 @@
+alter table "public"."message" add column "is_document_expired" boolean not null default false;
+
+