Merge pull request #429 from aibtcdev/new-update-at-column

add updated at column in queue

Author: human058382928

app/backend/models.py

@@ -195,6 +195,7 @@ class QueueMessageCreate(QueueMessageBase):
 class QueueMessage(QueueMessageBase):
     id: UUID
     created_at: datetime
+    updated_at: datetime
 
 
 #

app/backend/supabase.py

@@ -707,6 +707,7 @@ def update_queue_message(
         payload = update_data.model_dump(exclude_unset=True, mode="json")
         if not payload:
             return self.get_queue_message(queue_message_id)
+
         response = (
             self.client.table("queue")
             .update(payload)

supabase/migrations/20250906000000_add_updated_at_to_queue.sql

@@ -0,0 +1,28 @@
+-- Add updated_at column to queue table
+-- This column will track when a queue message was last modified
+
+-- Add the updated_at column
+ALTER TABLE public.queue
+ADD COLUMN IF NOT EXISTS updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() NOT NULL;
+
+-- Create an index for efficient querying
+CREATE INDEX IF NOT EXISTS idx_queue_updated_at ON public.queue(updated_at);
+
+-- Add trigger to automatically update the updated_at column when row is modified
+-- First create the trigger function if it doesn't exist
+CREATE OR REPLACE FUNCTION public.handle_updated_at()
+RETURNS TRIGGER AS $$
+BEGIN
+    NEW.updated_at = NOW();
+    RETURN NEW;
+END;
+$$ LANGUAGE plpgsql;
+
+-- Create trigger for the queue table
+CREATE TRIGGER handle_queue_updated_at
+    BEFORE UPDATE ON public.queue
+    FOR EACH ROW
+    EXECUTE FUNCTION public.handle_updated_at();
+
+-- Add comment for documentation
+COMMENT ON COLUMN public.queue.updated_at IS 'Timestamp of when the queue message was last updated';