diff --git a/.changeset/thread-items-sort-order.md b/.changeset/thread-items-sort-order.md
new file mode 100644
index 000000000..7a6f50b7a
--- /dev/null
+++ b/.changeset/thread-items-sort-order.md
@@ -0,0 +1,6 @@
+---
+"github.com/livekit/protocol": patch
+"@livekit/protocol": patch
+---
+
+`AgentThread.GetItemsRequest.sort_order` (`AgentThread.SortOrder`): `DESC` lists a thread's items from the latest back, so a chat view can load its last page first and page up through older items. Thread listings page like the other lists: `page_token`, `limit` and `next_page_token` (strings: `livekit.agent` cannot use `TokenPagination`) replace `before`/`after`, and `GetTasks` pages too. In `thread_schema_v1.sql`, `items` and `tasks` gain `pos INTEGER PRIMARY KEY AUTOINCREMENT` (insertion order, never reused, so a page token never skips a row), `items` an index on `(lane, pos)`; `id` and `task_id` stay the upsert keys as `TEXT NOT NULL UNIQUE`.
diff --git a/livekit/agent/livekit_agent_thread.pb.go b/livekit/agent/livekit_agent_thread.pb.go
index 4b4b7a670..fe44aba38 100644
--- a/livekit/agent/livekit_agent_thread.pb.go
+++ b/livekit/agent/livekit_agent_thread.pb.go
@@ -44,6 +44,56 @@ const (
 	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
 )
 
+// Direction of a listing. Each request documents what unset means.
+type AgentThread_SortOrder int32
+
+const (
+	AgentThread_SORT_ORDER_UNSPECIFIED AgentThread_SortOrder = 0
+	AgentThread_SORT_ORDER_ASC         AgentThread_SortOrder = 1
+	AgentThread_SORT_ORDER_DESC        AgentThread_SortOrder = 2
+)
+
+// Enum value maps for AgentThread_SortOrder.
+var (
+	AgentThread_SortOrder_name = map[int32]string{
+		0: "SORT_ORDER_UNSPECIFIED",
+		1: "SORT_ORDER_ASC",
+		2: "SORT_ORDER_DESC",
+	}
+	AgentThread_SortOrder_value = map[string]int32{
+		"SORT_ORDER_UNSPECIFIED": 0,
+		"SORT_ORDER_ASC":         1,
+		"SORT_ORDER_DESC":        2,
+	}
+)
+
+func (x AgentThread_SortOrder) Enum() *AgentThread_SortOrder {
+	p := new(AgentThread_SortOrder)
+	*p = x
+	return p
+}
+
+func (x AgentThread_SortOrder) String() string {
+	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
+}
+
+func (AgentThread_SortOrder) Descriptor() protoreflect.EnumDescriptor {
+	return file_agent_livekit_agent_thread_proto_enumTypes[0].Descriptor()
+}
+
+func (AgentThread_SortOrder) Type() protoreflect.EnumType {
+	return &file_agent_livekit_agent_thread_proto_enumTypes[0]
+}
+
+func (x AgentThread_SortOrder) Number() protoreflect.EnumNumber {
+	return protoreflect.EnumNumber(x)
+}
+
+// Deprecated: Use AgentThread_SortOrder.Descriptor instead.
+func (AgentThread_SortOrder) EnumDescriptor() ([]byte, []int) {
+	return file_agent_livekit_agent_thread_proto_rawDescGZIP(), []int{0, 0}
+}
+
 // A task is never UNSPECIFIED.
 type AgentTask_Status int32
 
@@ -84,11 +134,11 @@ func (x AgentTask_Status) String() string {
 }
 
 func (AgentTask_Status) Descriptor() protoreflect.EnumDescriptor {
-	return file_agent_livekit_agent_thread_proto_enumTypes[0].Descriptor()
+	return file_agent_livekit_agent_thread_proto_enumTypes[1].Descriptor()
 }
 
 func (AgentTask_Status) Type() protoreflect.EnumType {
-	return &file_agent_livekit_agent_thread_proto_enumTypes[0]
+	return &file_agent_livekit_agent_thread_proto_enumTypes[1]
 }
 
 func (x AgentTask_Status) Number() protoreflect.EnumNumber {
@@ -285,8 +335,8 @@ func (x *AgentThread_GetRequest) GetThreadId() string {
 type AgentThread_ListRequest struct {
 	state protoimpl.MessageState `protogen:"open.v1"`
 	Scope string                 `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
-	// Cursor from the previous ListResponse; empty for the first page.
-	Before        string `protobuf:"bytes,2,opt,name=before,proto3" json:"before,omitempty"`
+	// next_page_token of the previous ListResponse; empty for the first page.
+	PageToken     string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
 	Limit         int32  `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
 	unknownFields protoimpl.UnknownFields
 	sizeCache     protoimpl.SizeCache
@@ -329,9 +379,9 @@ func (x *AgentThread_ListRequest) GetScope() string {
 	return ""
 }
 
-func (x *AgentThread_ListRequest) GetBefore() string {
+func (x *AgentThread_ListRequest) GetPageToken() string {
 	if x != nil {
-		return x.Before
+		return x.PageToken
 	}
 	return ""
 }
@@ -346,8 +396,8 @@ func (x *AgentThread_ListRequest) GetLimit() int32 {
 type AgentThread_ListResponse struct {
 	state   protoimpl.MessageState `protogen:"open.v1"`
 	Threads []*AgentThread_Thread  `protobuf:"bytes,1,rep,name=threads,proto3" json:"threads,omitempty"`
-	// Empty at the end.
-	Before        string `protobuf:"bytes,2,opt,name=before,proto3" json:"before,omitempty"`
+	// Empty when exhausted.
+	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
 	unknownFields protoimpl.UnknownFields
 	sizeCache     protoimpl.SizeCache
 }
@@ -389,9 +439,9 @@ func (x *AgentThread_ListResponse) GetThreads() []*AgentThread_Thread {
 	return nil
 }
 
-func (x *AgentThread_ListResponse) GetBefore() string {
+func (x *AgentThread_ListResponse) GetNextPageToken() string {
 	if x != nil {
-		return x.Before
+		return x.NextPageToken
 	}
 	return ""
 }
@@ -537,15 +587,18 @@ func (*AgentThread_DeleteResponse) Descriptor() ([]byte, []int) {
 	return file_agent_livekit_agent_thread_proto_rawDescGZIP(), []int{0, 6}
 }
 
-// The thread's chat items, oldest first.
+// The thread's chat items, oldest first unless sort_order says otherwise.
 type AgentThread_GetItemsRequest struct {
 	state    protoimpl.MessageState `protogen:"open.v1"`
 	ThreadId string                 `protobuf:"bytes,1,opt,name=thread_id,json=threadId,proto3" json:"thread_id,omitempty"`
 	// One agent's items; empty for every agent's.
 	Agent string `protobuf:"bytes,2,opt,name=agent,proto3" json:"agent,omitempty"`
-	// Cursor from the previous GetItemsResponse; empty for the first page.
-	After         string `protobuf:"bytes,3,opt,name=after,proto3" json:"after,omitempty"`
-	Limit         int32  `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
+	// next_page_token of the previous GetItemsResponse; empty for the first page.
+	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
+	Limit     int32  `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
+	// Unset or ASC is oldest first. DESC starts from the latest item and each
+	// next_page_token walks back through older ones.
+	SortOrder     AgentThread_SortOrder `protobuf:"varint,5,opt,name=sort_order,json=sortOrder,proto3,enum=livekit.agent.AgentThread_SortOrder" json:"sort_order,omitempty"`
 	unknownFields protoimpl.UnknownFields
 	sizeCache     protoimpl.SizeCache
 }
@@ -594,9 +647,9 @@ func (x *AgentThread_GetItemsRequest) GetAgent() string {
 	return ""
 }
 
-func (x *AgentThread_GetItemsRequest) GetAfter() string {
+func (x *AgentThread_GetItemsRequest) GetPageToken() string {
 	if x != nil {
-		return x.After
+		return x.PageToken
 	}
 	return ""
 }
@@ -608,11 +661,18 @@ func (x *AgentThread_GetItemsRequest) GetLimit() int32 {
 	return 0
 }
 
+func (x *AgentThread_GetItemsRequest) GetSortOrder() AgentThread_SortOrder {
+	if x != nil {
+		return x.SortOrder
+	}
+	return AgentThread_SORT_ORDER_UNSPECIFIED
+}
+
 type AgentThread_GetItemsResponse struct {
 	state protoimpl.MessageState `protogen:"open.v1"`
 	Items []*AgentThread_Item    `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
-	// Empty at the end.
-	After         string `protobuf:"bytes,2,opt,name=after,proto3" json:"after,omitempty"`
+	// Empty when exhausted.
+	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
 	unknownFields protoimpl.UnknownFields
 	sizeCache     protoimpl.SizeCache
 }
@@ -654,9 +714,9 @@ func (x *AgentThread_GetItemsResponse) GetItems() []*AgentThread_Item {
 	return nil
 }
 
-func (x *AgentThread_GetItemsResponse) GetAfter() string {
+func (x *AgentThread_GetItemsResponse) GetNextPageToken() string {
 	if x != nil {
-		return x.After
+		return x.NextPageToken
 	}
 	return ""
 }
@@ -841,7 +901,10 @@ type AgentTask_GetTasksRequest struct {
 	state    protoimpl.MessageState `protogen:"open.v1"`
 	ThreadId string                 `protobuf:"bytes,1,opt,name=thread_id,json=threadId,proto3" json:"thread_id,omitempty"`
 	// Unset for every status.
-	Status        *AgentTask_Status `protobuf:"varint,2,opt,name=status,proto3,enum=livekit.agent.AgentTask_Status,oneof" json:"status,omitempty"`
+	Status *AgentTask_Status `protobuf:"varint,2,opt,name=status,proto3,enum=livekit.agent.AgentTask_Status,oneof" json:"status,omitempty"`
+	// next_page_token of the previous GetTasksResponse; empty for the first page.
+	PageToken     string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
+	Limit         int32  `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
 	unknownFields protoimpl.UnknownFields
 	sizeCache     protoimpl.SizeCache
 }
@@ -890,9 +953,25 @@ func (x *AgentTask_GetTasksRequest) GetStatus() AgentTask_Status {
 	return AgentTask_UNSPECIFIED
 }
 
+func (x *AgentTask_GetTasksRequest) GetPageToken() string {
+	if x != nil {
+		return x.PageToken
+	}
+	return ""
+}
+
+func (x *AgentTask_GetTasksRequest) GetLimit() int32 {
+	if x != nil {
+		return x.Limit
+	}
+	return 0
+}
+
 type AgentTask_GetTasksResponse struct {
-	state         protoimpl.MessageState `protogen:"open.v1"`
-	Tasks         []*AgentTask_Task      `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
+	state protoimpl.MessageState `protogen:"open.v1"`
+	Tasks []*AgentTask_Task      `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
+	// Empty when exhausted.
+	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
 	unknownFields protoimpl.UnknownFields
 	sizeCache     protoimpl.SizeCache
 }
@@ -934,6 +1013,13 @@ func (x *AgentTask_GetTasksResponse) GetTasks() []*AgentTask_Task {
 	return nil
 }
 
+func (x *AgentTask_GetTasksResponse) GetNextPageToken() string {
+	if x != nil {
+		return x.NextPageToken
+	}
+	return ""
+}
+
 type AgentTask_Task struct {
 	state    protoimpl.MessageState `protogen:"open.v1"`
 	TaskId   string                 `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
@@ -1015,7 +1101,7 @@ var File_agent_livekit_agent_thread_proto protoreflect.FileDescriptor
 
 const file_agent_livekit_agent_thread_proto_rawDesc = "" +
 	"\n" +
-	" agent/livekit_agent_thread.proto\x12\rlivekit.agent\x1a\x1egoogle/protobuf/duration.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a!agent/livekit_agent_session.proto\x1a\x14logger/options.proto\"\xbf\r\n" +
+	" agent/livekit_agent_thread.proto\x12\rlivekit.agent\x1a\x1egoogle/protobuf/duration.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a!agent/livekit_agent_session.proto\x1a\x14logger/options.proto\"\x89\x0f\n" +
 	"\vAgentThread\x1a\xfe\x01\n" +
 	"\rCreateRequest\x12\x19\n" +
 	"\x05scope\x18\x01 \x01(\tB\x03\xc0P\x01R\x05scope\x12]\n" +
@@ -1028,14 +1114,15 @@ const file_agent_livekit_agent_thread_proto_rawDesc = "" +
 	"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\x1a6\n" +
 	"\n" +
 	"GetRequest\x12(\n" +
-	"\tthread_id\x18\x01 \x01(\tB\v\xbaP\bthreadIDR\bthreadId\x1aV\n" +
+	"\tthread_id\x18\x01 \x01(\tB\v\xbaP\bthreadIDR\bthreadId\x1a]\n" +
 	"\vListRequest\x12\x19\n" +
-	"\x05scope\x18\x01 \x01(\tB\x03\xc0P\x01R\x05scope\x12\x16\n" +
-	"\x06before\x18\x02 \x01(\tR\x06before\x12\x14\n" +
-	"\x05limit\x18\x03 \x01(\x05R\x05limit\x1ac\n" +
+	"\x05scope\x18\x01 \x01(\tB\x03\xc0P\x01R\x05scope\x12\x1d\n" +
+	"\n" +
+	"page_token\x18\x02 \x01(\tR\tpageToken\x12\x14\n" +
+	"\x05limit\x18\x03 \x01(\x05R\x05limit\x1as\n" +
 	"\fListResponse\x12;\n" +
-	"\athreads\x18\x01 \x03(\v2!.livekit.agent.AgentThread.ThreadR\athreads\x12\x16\n" +
-	"\x06before\x18\x02 \x01(\tR\x06before\x1a\x8d\x02\n" +
+	"\athreads\x18\x01 \x03(\v2!.livekit.agent.AgentThread.ThreadR\athreads\x12&\n" +
+	"\x0fnext_page_token\x18\x02 \x01(\tR\rnextPageToken\x1a\x8d\x02\n" +
 	"\rUpdateRequest\x12(\n" +
 	"\tthread_id\x18\x01 \x01(\tB\v\xbaP\bthreadIDR\bthreadId\x12]\n" +
 	"\n" +
@@ -1047,15 +1134,18 @@ const file_agent_livekit_agent_thread_proto_rawDesc = "" +
 	"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\x1a9\n" +
 	"\rDeleteRequest\x12(\n" +
 	"\tthread_id\x18\x01 \x01(\tB\v\xbaP\bthreadIDR\bthreadId\x1a\x10\n" +
-	"\x0eDeleteResponse\x1a}\n" +
+	"\x0eDeleteResponse\x1a\xcb\x01\n" +
 	"\x0fGetItemsRequest\x12(\n" +
 	"\tthread_id\x18\x01 \x01(\tB\v\xbaP\bthreadIDR\bthreadId\x12\x14\n" +
-	"\x05agent\x18\x02 \x01(\tR\x05agent\x12\x14\n" +
-	"\x05after\x18\x03 \x01(\tR\x05after\x12\x14\n" +
-	"\x05limit\x18\x04 \x01(\x05R\x05limit\x1a_\n" +
+	"\x05agent\x18\x02 \x01(\tR\x05agent\x12\x1d\n" +
+	"\n" +
+	"page_token\x18\x03 \x01(\tR\tpageToken\x12\x14\n" +
+	"\x05limit\x18\x04 \x01(\x05R\x05limit\x12C\n" +
+	"\n" +
+	"sort_order\x18\x05 \x01(\x0e2$.livekit.agent.AgentThread.SortOrderR\tsortOrder\x1aq\n" +
 	"\x10GetItemsResponse\x125\n" +
-	"\x05items\x18\x01 \x03(\v2\x1f.livekit.agent.AgentThread.ItemR\x05items\x12\x14\n" +
-	"\x05after\x18\x02 \x01(\tR\x05after\x1a\x8b\x01\n" +
+	"\x05items\x18\x01 \x03(\v2\x1f.livekit.agent.AgentThread.ItemR\x05items\x12&\n" +
+	"\x0fnext_page_token\x18\x02 \x01(\tR\rnextPageToken\x1a\x8b\x01\n" +
 	"\x04Item\x12\x14\n" +
 	"\x05agent\x18\x01 \x01(\tR\x05agent\x12\x10\n" +
 	"\x03seq\x18\x02 \x01(\x03R\x03seq\x12\x1d\n" +
@@ -1079,14 +1169,22 @@ const file_agent_livekit_agent_thread_proto_rawDesc = "" +
 	"databaseId\x1a=\n" +
 	"\x0fAttributesEntry\x12\x10\n" +
 	"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
-	"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"\x80\x04\n" +
-	"\tAgentTask\x1a\x84\x01\n" +
+	"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"P\n" +
+	"\tSortOrder\x12\x1a\n" +
+	"\x16SORT_ORDER_UNSPECIFIED\x10\x00\x12\x12\n" +
+	"\x0eSORT_ORDER_ASC\x10\x01\x12\x13\n" +
+	"\x0fSORT_ORDER_DESC\x10\x02\"\xdd\x04\n" +
+	"\tAgentTask\x1a\xb9\x01\n" +
 	"\x0fGetTasksRequest\x12(\n" +
 	"\tthread_id\x18\x01 \x01(\tB\v\xbaP\bthreadIDR\bthreadId\x12<\n" +
-	"\x06status\x18\x02 \x01(\x0e2\x1f.livekit.agent.AgentTask.StatusH\x00R\x06status\x88\x01\x01B\t\n" +
-	"\a_status\x1aG\n" +
+	"\x06status\x18\x02 \x01(\x0e2\x1f.livekit.agent.AgentTask.StatusH\x00R\x06status\x88\x01\x01\x12\x1d\n" +
+	"\n" +
+	"page_token\x18\x03 \x01(\tR\tpageToken\x12\x14\n" +
+	"\x05limit\x18\x04 \x01(\x05R\x05limitB\t\n" +
+	"\a_status\x1ao\n" +
 	"\x10GetTasksResponse\x123\n" +
-	"\x05tasks\x18\x01 \x03(\v2\x1d.livekit.agent.AgentTask.TaskR\x05tasks\x1a\xd1\x01\n" +
+	"\x05tasks\x18\x01 \x03(\v2\x1d.livekit.agent.AgentTask.TaskR\x05tasks\x12&\n" +
+	"\x0fnext_page_token\x18\x02 \x01(\tR\rnextPageToken\x1a\xd1\x01\n" +
 	"\x04Task\x12\x17\n" +
 	"\atask_id\x18\x01 \x01(\tR\x06taskId\x12(\n" +
 	"\tthread_id\x18\x02 \x01(\tB\v\xbaP\bthreadIDR\bthreadId\x12\x12\n" +
@@ -1114,55 +1212,57 @@ func file_agent_livekit_agent_thread_proto_rawDescGZIP() []byte {
 	return file_agent_livekit_agent_thread_proto_rawDescData
 }
 
-var file_agent_livekit_agent_thread_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
+var file_agent_livekit_agent_thread_proto_enumTypes = make([]protoimpl.EnumInfo, 2)
 var file_agent_livekit_agent_thread_proto_msgTypes = make([]protoimpl.MessageInfo, 19)
 var file_agent_livekit_agent_thread_proto_goTypes = []any{
-	(AgentTask_Status)(0),                // 0: livekit.agent.AgentTask.Status
-	(*AgentThread)(nil),                  // 1: livekit.agent.AgentThread
-	(*AgentTask)(nil),                    // 2: livekit.agent.AgentTask
-	(*AgentThread_CreateRequest)(nil),    // 3: livekit.agent.AgentThread.CreateRequest
-	(*AgentThread_GetRequest)(nil),       // 4: livekit.agent.AgentThread.GetRequest
-	(*AgentThread_ListRequest)(nil),      // 5: livekit.agent.AgentThread.ListRequest
-	(*AgentThread_ListResponse)(nil),     // 6: livekit.agent.AgentThread.ListResponse
-	(*AgentThread_UpdateRequest)(nil),    // 7: livekit.agent.AgentThread.UpdateRequest
-	(*AgentThread_DeleteRequest)(nil),    // 8: livekit.agent.AgentThread.DeleteRequest
-	(*AgentThread_DeleteResponse)(nil),   // 9: livekit.agent.AgentThread.DeleteResponse
-	(*AgentThread_GetItemsRequest)(nil),  // 10: livekit.agent.AgentThread.GetItemsRequest
-	(*AgentThread_GetItemsResponse)(nil), // 11: livekit.agent.AgentThread.GetItemsResponse
-	(*AgentThread_Item)(nil),             // 12: livekit.agent.AgentThread.Item
-	(*AgentThread_Thread)(nil),           // 13: livekit.agent.AgentThread.Thread
-	nil,                                  // 14: livekit.agent.AgentThread.CreateRequest.AttributesEntry
-	nil,                                  // 15: livekit.agent.AgentThread.UpdateRequest.AttributesEntry
-	nil,                                  // 16: livekit.agent.AgentThread.Thread.AttributesEntry
-	(*AgentTask_GetTasksRequest)(nil),    // 17: livekit.agent.AgentTask.GetTasksRequest
-	(*AgentTask_GetTasksResponse)(nil),   // 18: livekit.agent.AgentTask.GetTasksResponse
-	(*AgentTask_Task)(nil),               // 19: livekit.agent.AgentTask.Task
-	(*durationpb.Duration)(nil),          // 20: google.protobuf.Duration
-	(*ChatContext_ChatItem)(nil),         // 21: livekit.agent.ChatContext.ChatItem
-	(*timestamppb.Timestamp)(nil),        // 22: google.protobuf.Timestamp
+	(AgentThread_SortOrder)(0),           // 0: livekit.agent.AgentThread.SortOrder
+	(AgentTask_Status)(0),                // 1: livekit.agent.AgentTask.Status
+	(*AgentThread)(nil),                  // 2: livekit.agent.AgentThread
+	(*AgentTask)(nil),                    // 3: livekit.agent.AgentTask
+	(*AgentThread_CreateRequest)(nil),    // 4: livekit.agent.AgentThread.CreateRequest
+	(*AgentThread_GetRequest)(nil),       // 5: livekit.agent.AgentThread.GetRequest
+	(*AgentThread_ListRequest)(nil),      // 6: livekit.agent.AgentThread.ListRequest
+	(*AgentThread_ListResponse)(nil),     // 7: livekit.agent.AgentThread.ListResponse
+	(*AgentThread_UpdateRequest)(nil),    // 8: livekit.agent.AgentThread.UpdateRequest
+	(*AgentThread_DeleteRequest)(nil),    // 9: livekit.agent.AgentThread.DeleteRequest
+	(*AgentThread_DeleteResponse)(nil),   // 10: livekit.agent.AgentThread.DeleteResponse
+	(*AgentThread_GetItemsRequest)(nil),  // 11: livekit.agent.AgentThread.GetItemsRequest
+	(*AgentThread_GetItemsResponse)(nil), // 12: livekit.agent.AgentThread.GetItemsResponse
+	(*AgentThread_Item)(nil),             // 13: livekit.agent.AgentThread.Item
+	(*AgentThread_Thread)(nil),           // 14: livekit.agent.AgentThread.Thread
+	nil,                                  // 15: livekit.agent.AgentThread.CreateRequest.AttributesEntry
+	nil,                                  // 16: livekit.agent.AgentThread.UpdateRequest.AttributesEntry
+	nil,                                  // 17: livekit.agent.AgentThread.Thread.AttributesEntry
+	(*AgentTask_GetTasksRequest)(nil),    // 18: livekit.agent.AgentTask.GetTasksRequest
+	(*AgentTask_GetTasksResponse)(nil),   // 19: livekit.agent.AgentTask.GetTasksResponse
+	(*AgentTask_Task)(nil),               // 20: livekit.agent.AgentTask.Task
+	(*durationpb.Duration)(nil),          // 21: google.protobuf.Duration
+	(*ChatContext_ChatItem)(nil),         // 22: livekit.agent.ChatContext.ChatItem
+	(*timestamppb.Timestamp)(nil),        // 23: google.protobuf.Timestamp
 }
 var file_agent_livekit_agent_thread_proto_depIdxs = []int32{
-	14, // 0: livekit.agent.AgentThread.CreateRequest.attributes:type_name -> livekit.agent.AgentThread.CreateRequest.AttributesEntry
-	20, // 1: livekit.agent.AgentThread.CreateRequest.idle_ttl:type_name -> google.protobuf.Duration
-	13, // 2: livekit.agent.AgentThread.ListResponse.threads:type_name -> livekit.agent.AgentThread.Thread
-	15, // 3: livekit.agent.AgentThread.UpdateRequest.attributes:type_name -> livekit.agent.AgentThread.UpdateRequest.AttributesEntry
-	20, // 4: livekit.agent.AgentThread.UpdateRequest.idle_ttl:type_name -> google.protobuf.Duration
-	12, // 5: livekit.agent.AgentThread.GetItemsResponse.items:type_name -> livekit.agent.AgentThread.Item
-	21, // 6: livekit.agent.AgentThread.Item.item:type_name -> livekit.agent.ChatContext.ChatItem
-	16, // 7: livekit.agent.AgentThread.Thread.attributes:type_name -> livekit.agent.AgentThread.Thread.AttributesEntry
-	22, // 8: livekit.agent.AgentThread.Thread.created_at:type_name -> google.protobuf.Timestamp
-	22, // 9: livekit.agent.AgentThread.Thread.last_active:type_name -> google.protobuf.Timestamp
-	22, // 10: livekit.agent.AgentThread.Thread.expires_at:type_name -> google.protobuf.Timestamp
-	20, // 11: livekit.agent.AgentThread.Thread.idle_ttl:type_name -> google.protobuf.Duration
-	0,  // 12: livekit.agent.AgentTask.GetTasksRequest.status:type_name -> livekit.agent.AgentTask.Status
-	19, // 13: livekit.agent.AgentTask.GetTasksResponse.tasks:type_name -> livekit.agent.AgentTask.Task
-	0,  // 14: livekit.agent.AgentTask.Task.status:type_name -> livekit.agent.AgentTask.Status
-	22, // 15: livekit.agent.AgentTask.Task.updated_at:type_name -> google.protobuf.Timestamp
-	16, // [16:16] is the sub-list for method output_type
-	16, // [16:16] is the sub-list for method input_type
-	16, // [16:16] is the sub-list for extension type_name
-	16, // [16:16] is the sub-list for extension extendee
-	0,  // [0:16] is the sub-list for field type_name
+	15, // 0: livekit.agent.AgentThread.CreateRequest.attributes:type_name -> livekit.agent.AgentThread.CreateRequest.AttributesEntry
+	21, // 1: livekit.agent.AgentThread.CreateRequest.idle_ttl:type_name -> google.protobuf.Duration
+	14, // 2: livekit.agent.AgentThread.ListResponse.threads:type_name -> livekit.agent.AgentThread.Thread
+	16, // 3: livekit.agent.AgentThread.UpdateRequest.attributes:type_name -> livekit.agent.AgentThread.UpdateRequest.AttributesEntry
+	21, // 4: livekit.agent.AgentThread.UpdateRequest.idle_ttl:type_name -> google.protobuf.Duration
+	0,  // 5: livekit.agent.AgentThread.GetItemsRequest.sort_order:type_name -> livekit.agent.AgentThread.SortOrder
+	13, // 6: livekit.agent.AgentThread.GetItemsResponse.items:type_name -> livekit.agent.AgentThread.Item
+	22, // 7: livekit.agent.AgentThread.Item.item:type_name -> livekit.agent.ChatContext.ChatItem
+	17, // 8: livekit.agent.AgentThread.Thread.attributes:type_name -> livekit.agent.AgentThread.Thread.AttributesEntry
+	23, // 9: livekit.agent.AgentThread.Thread.created_at:type_name -> google.protobuf.Timestamp
+	23, // 10: livekit.agent.AgentThread.Thread.last_active:type_name -> google.protobuf.Timestamp
+	23, // 11: livekit.agent.AgentThread.Thread.expires_at:type_name -> google.protobuf.Timestamp
+	21, // 12: livekit.agent.AgentThread.Thread.idle_ttl:type_name -> google.protobuf.Duration
+	1,  // 13: livekit.agent.AgentTask.GetTasksRequest.status:type_name -> livekit.agent.AgentTask.Status
+	20, // 14: livekit.agent.AgentTask.GetTasksResponse.tasks:type_name -> livekit.agent.AgentTask.Task
+	1,  // 15: livekit.agent.AgentTask.Task.status:type_name -> livekit.agent.AgentTask.Status
+	23, // 16: livekit.agent.AgentTask.Task.updated_at:type_name -> google.protobuf.Timestamp
+	17, // [17:17] is the sub-list for method output_type
+	17, // [17:17] is the sub-list for method input_type
+	17, // [17:17] is the sub-list for extension type_name
+	17, // [17:17] is the sub-list for extension extendee
+	0,  // [0:17] is the sub-list for field type_name
 }
 
 func init() { file_agent_livekit_agent_thread_proto_init() }
@@ -1177,7 +1277,7 @@ func file_agent_livekit_agent_thread_proto_init() {
 		File: protoimpl.DescBuilder{
 			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
 			RawDescriptor: unsafe.Slice(unsafe.StringData(file_agent_livekit_agent_thread_proto_rawDesc), len(file_agent_livekit_agent_thread_proto_rawDesc)),
-			NumEnums:      1,
+			NumEnums:      2,
 			NumMessages:   19,
 			NumExtensions: 0,
 			NumServices:   0,
diff --git a/livekit/agent/thread_schema_v1.sql b/livekit/agent/thread_schema_v1.sql
index 4f354d1b3..8980979d0 100644
--- a/livekit/agent/thread_schema_v1.sql
+++ b/livekit/agent/thread_schema_v1.sql
@@ -16,29 +16,32 @@ CREATE TABLE schema_version (
 
 -- One chat item per row.
 CREATE TABLE items (
-  id         TEXT PRIMARY KEY,  -- [framework] the item's id, its upsert key
-  lane       TEXT NOT NULL,     -- [platform, framework]
-  seq        INTEGER NOT NULL,  -- [platform, framework] position in the lane
-  message_id TEXT,              -- [platform, framework] the A2A messageId it came from, for idempotency
-  payload    JSONB NOT NULL     -- [platform, framework] livekit.agent.ChatContext.ChatItem as protobuf JSON
+  pos        INTEGER PRIMARY KEY AUTOINCREMENT,  -- [platform] insertion order, never reused: the page token's sort key
+  id         TEXT NOT NULL UNIQUE,               -- [framework] the item's id, its upsert key (ON CONFLICT DO UPDATE: a REPLACE would move pos)
+  lane       TEXT NOT NULL,                      -- [platform, framework]
+  seq        INTEGER NOT NULL,                   -- [platform, framework] position in the lane
+  message_id TEXT,                               -- [platform, framework] the A2A messageId it came from, for idempotency
+  payload    JSONB NOT NULL                      -- [platform, framework] livekit.agent.ChatContext.ChatItem as protobuf JSON
 );
 CREATE INDEX items_lane_seq ON items (lane, seq);
+CREATE INDEX items_lane_pos ON items (lane, pos);
 CREATE UNIQUE INDEX items_lane_message ON items (lane, message_id) WHERE message_id IS NOT NULL;
 
 -- One A2A task per row: the task of an incoming message, or a background
 -- AgentTask (name set). The A2A Task is id = task_id, contextId = the thread
 -- id, status = (status, status_message, updated_at), plus the fields of data.
 CREATE TABLE tasks (
-  task_id        TEXT PRIMARY KEY,  -- [platform, a2a, framework]
-  lane           TEXT NOT NULL,     -- [framework]
-  seq            INTEGER NOT NULL,  -- [framework] submission order in the lane
-  name           TEXT,              -- [platform, framework] the AgentTask class
-  message_id     TEXT,              -- [framework] the A2A messageId that created it, for idempotency
-  status         TEXT NOT NULL,     -- [platform, a2a, framework] A2A TaskState (agent.TaskStatus maps it), working when a new run finds it means its worker was lost
-  status_message JSONB,             -- [a2a] A2A Message
-  updated_at     INTEGER NOT NULL,  -- [platform, a2a, framework]
-  data           JSONB NOT NULL,    -- [a2a] A2A Task fields: history, artifacts, metadata
-  internal       JSONB              -- [framework] AgentTask arguments and pending question, to resume it
+  pos            INTEGER PRIMARY KEY AUTOINCREMENT,  -- [platform] insertion order, never reused: the page token's sort key
+  task_id        TEXT NOT NULL UNIQUE,               -- [platform, a2a, framework] its upsert key (ON CONFLICT DO UPDATE: a REPLACE would move pos)
+  lane           TEXT NOT NULL,                      -- [framework]
+  seq            INTEGER NOT NULL,                   -- [framework] submission order in the lane
+  name           TEXT,                               -- [platform, framework] the AgentTask class
+  message_id     TEXT,                               -- [framework] the A2A messageId that created it, for idempotency
+  status         TEXT NOT NULL,                      -- [platform, a2a, framework] A2A TaskState (agent.TaskStatus maps it), working when a new run finds it means its worker was lost
+  status_message JSONB,                              -- [a2a] A2A Message
+  updated_at     INTEGER NOT NULL,                   -- [platform, a2a, framework]
+  data           JSONB NOT NULL,                     -- [a2a] A2A Task fields: history, artifacts, metadata
+  internal       JSONB                               -- [framework] AgentTask arguments and pending question, to resume it
 );
 CREATE INDEX tasks_lane_seq ON tasks (lane, seq);
 CREATE INDEX tasks_lane_status ON tasks (lane, status, seq);
diff --git a/protobufs/agent/livekit_agent_thread.proto b/protobufs/agent/livekit_agent_thread.proto
index 971765e2a..646e7428e 100644
--- a/protobufs/agent/livekit_agent_thread.proto
+++ b/protobufs/agent/livekit_agent_thread.proto
@@ -30,6 +30,13 @@ import "agent/livekit_agent_session.proto";
 import "logger/options.proto";
 
 message AgentThread {
+  // Direction of a listing. Each request documents what unset means.
+  enum SortOrder {
+    SORT_ORDER_UNSPECIFIED = 0;
+    SORT_ORDER_ASC = 1;
+    SORT_ORDER_DESC = 2;
+  }
+
   message CreateRequest {
     // Groups threads, e.g. by user: an application-defined value, typically the
     // user's identity. An AgentThreadGrant is scoped by it.
@@ -46,15 +53,15 @@ message AgentThread {
   // The threads of one scope, newest first.
   message ListRequest {
     string scope = 1 [(logger.sensitivity) = SENSITIVITY_PII];
-    // Cursor from the previous ListResponse; empty for the first page.
-    string before = 2;
+    // next_page_token of the previous ListResponse; empty for the first page.
+    string page_token = 2;
     int32 limit = 3;
   }
 
   message ListResponse {
     repeated Thread threads = 1;
-    // Empty at the end.
-    string before = 2;
+    // Empty when exhausted.
+    string next_page_token = 2;
   }
 
   message UpdateRequest {
@@ -71,20 +78,23 @@ message AgentThread {
 
   message DeleteResponse {}
 
-  // The thread's chat items, oldest first.
+  // The thread's chat items, oldest first unless sort_order says otherwise.
   message GetItemsRequest {
     string thread_id = 1 [(logger.name) = "threadID"];
     // One agent's items; empty for every agent's.
     string agent = 2;
-    // Cursor from the previous GetItemsResponse; empty for the first page.
-    string after = 3;
+    // next_page_token of the previous GetItemsResponse; empty for the first page.
+    string page_token = 3;
     int32 limit = 4;
+    // Unset or ASC is oldest first. DESC starts from the latest item and each
+    // next_page_token walks back through older ones.
+    SortOrder sort_order = 5;
   }
 
   message GetItemsResponse {
     repeated Item items = 1;
-    // Empty at the end.
-    string after = 2;
+    // Empty when exhausted.
+    string next_page_token = 2;
   }
 
   // One chat item of an agent. Stored as the JSON of
@@ -130,10 +140,15 @@ message AgentTask {
     string thread_id = 1 [(logger.name) = "threadID"];
     // Unset for every status.
     optional Status status = 2;
+    // next_page_token of the previous GetTasksResponse; empty for the first page.
+    string page_token = 3;
+    int32 limit = 4;
   }
 
   message GetTasksResponse {
     repeated Task tasks = 1;
+    // Empty when exhausted.
+    string next_page_token = 2;
   }
 
   message Task {