Skip to content

feat(proto): update activity list protos #134

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
vitramir merged 1 commit into from
Apr 25, 2026
Merged

feat(proto): update activity list protos #134

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions proto/agynio/api/gateway/v1/threads.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,7 @@ service ThreadsGateway {
rpc AddParticipant(agynio.api.threads.v1.AddParticipantRequest) returns (agynio.api.threads.v1.AddParticipantResponse);
rpc SendMessage(agynio.api.threads.v1.SendMessageRequest) returns (agynio.api.threads.v1.SendMessageResponse);
rpc GetThreads(agynio.api.threads.v1.GetThreadsRequest) returns (agynio.api.threads.v1.GetThreadsResponse);
rpc ListOrganizationThreads(agynio.api.threads.v1.ListOrganizationThreadsRequest) returns (agynio.api.threads.v1.ListOrganizationThreadsResponse);
rpc GetOrganizationThreads(agynio.api.threads.v1.GetOrganizationThreadsRequest) returns (agynio.api.threads.v1.GetOrganizationThreadsResponse);
rpc GetThread(agynio.api.threads.v1.GetThreadRequest) returns (agynio.api.threads.v1.GetThreadResponse);
rpc GetMessages(agynio.api.threads.v1.GetMessagesRequest) returns (agynio.api.threads.v1.GetMessagesResponse);
Expand Down
17 changes: 17 additions & 0 deletions proto/agynio/api/identity/v1/identity.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,9 @@ service IdentityService {
rpc RemoveNickname(RemoveNicknameRequest) returns (RemoveNicknameResponse);
// ResolveNickname resolves an @nickname within an org to its identity.
rpc ResolveNickname(ResolveNicknameRequest) returns (ResolveNicknameResponse);
// BatchGetNicknames resolves identity IDs to nicknames within an org.
Comment thread
noa-lucent marked this conversation as resolved.
// Unknown or unset nicknames are omitted from the response.
rpc BatchGetNicknames(BatchGetNicknamesRequest) returns (BatchGetNicknamesResponse);
}

enum IdentityType {
Expand Down Expand Up @@ -91,3 +94,17 @@ message ResolveNicknameResponse {
IdentityType identity_type = 2;
optional string installation_id = 3;
}

message BatchGetNicknamesRequest {
string organization_id = 1;
repeated string identity_ids = 2;
}

message NicknameEntry {
string identity_id = 1;
string nickname = 2;
}

message BatchGetNicknamesResponse {
repeated NicknameEntry entries = 1;
}
105 changes: 99 additions & 6 deletions proto/agynio/api/runners/v1/runners.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -56,6 +56,12 @@ message SampledAtEntry {
google.protobuf.Timestamp sampled_at = 2;
}

enum SortDirection {
SORT_DIRECTION_UNSPECIFIED = 0;
SORT_DIRECTION_ASC = 1;
SORT_DIRECTION_DESC = 2;
}

// ===========================================================================
// Runner
// ===========================================================================
Expand Down Expand Up @@ -223,6 +229,10 @@ message Workload {
// programmatic parsing. When status is not FAILED, this value may be unset
// or stale.
optional string failure_message = 16;
// Denormalized display name for agent_id.
string agent_name = 17;
// Denormalized display name for runner_id.
string runner_name = 18;
}

message CreateWorkloadRequest {
Expand Down Expand Up @@ -291,6 +301,29 @@ message GetWorkloadResponse {
Workload workload = 1;
}

enum ListWorkloadsSortField {
LIST_WORKLOADS_SORT_FIELD_UNSPECIFIED = 0;
LIST_WORKLOADS_SORT_FIELD_STARTED = 1;
LIST_WORKLOADS_SORT_FIELD_AGENT = 2;
LIST_WORKLOADS_SORT_FIELD_RUNNER = 3;
LIST_WORKLOADS_SORT_FIELD_STATUS = 4;
LIST_WORKLOADS_SORT_FIELD_DURATION = 5;
}

message ListWorkloadsSort {
Comment thread
noa-lucent marked this conversation as resolved.
ListWorkloadsSortField field = 1;
SortDirection direction = 2;
}

message ListWorkloadsFilter {
repeated string agent_id_in = 1;
repeated string runner_id_in = 2;
repeated WorkloadStatus status_in = 3;
optional google.protobuf.Timestamp started_after = 4;
optional google.protobuf.Timestamp started_before = 5;
optional bool pending_sample = 6;
}

message ListWorkloadsByThreadRequest {
string thread_id = 1;
int32 page_size = 2;
Expand All @@ -308,11 +341,18 @@ message ListWorkloadsByThreadResponse {

message ListWorkloadsRequest {
int32 page_size = 1;
// Opaque cursor; reuse only with the same sort and filter.
string page_token = 2;
repeated WorkloadStatus statuses = 3;
// Deprecated: use filter.status_in instead.
repeated WorkloadStatus statuses = 3 [deprecated = true];
// Required organization scope; caller must hold can_view_workloads.
optional string organization_id = 4;
optional string runner_id = 5;
optional bool pending_sample = 6;
// Deprecated: use filter.runner_id_in instead.
optional string runner_id = 5 [deprecated = true];
// Deprecated: use filter.pending_sample instead.
optional bool pending_sample = 6 [deprecated = true];
ListWorkloadsFilter filter = 7;
ListWorkloadsSort sort = 8;
}

message ListWorkloadsResponse {
Expand Down Expand Up @@ -351,6 +391,31 @@ message Volume {
VolumeStatus status = 9;
optional google.protobuf.Timestamp removed_at = 10;
optional google.protobuf.Timestamp last_metering_sampled_at = 11;
// Denormalized display name for volume_id.
string volume_name = 12;
// Current attachments for this volume; empty when unattached.
repeated Attachment attachments = 13;
}

enum AttachmentKind {
ATTACHMENT_KIND_UNSPECIFIED = 0;
ATTACHMENT_KIND_AGENT = 1;
ATTACHMENT_KIND_MCP = 2;
ATTACHMENT_KIND_HOOK = 3;
}

message Attachment {
AttachmentKind kind = 1;
string id = 2;
string name = 3;
}

enum VolumeAttachmentFilterKind {
VOLUME_ATTACHMENT_FILTER_KIND_UNSPECIFIED = 0;
VOLUME_ATTACHMENT_FILTER_KIND_AGENT = 1;
VOLUME_ATTACHMENT_FILTER_KIND_MCP = 2;
VOLUME_ATTACHMENT_FILTER_KIND_HOOK = 3;
VOLUME_ATTACHMENT_FILTER_KIND_UNATTACHED = 4;
}

message CreateVolumeRequest {
Expand Down Expand Up @@ -388,13 +453,41 @@ message GetVolumeResponse {
Volume volume = 1;
}

enum ListVolumesSortField {
LIST_VOLUMES_SORT_FIELD_UNSPECIFIED = 0;
LIST_VOLUMES_SORT_FIELD_NAME = 1;
LIST_VOLUMES_SORT_FIELD_SIZE = 2;
LIST_VOLUMES_SORT_FIELD_STATUS = 3;
LIST_VOLUMES_SORT_FIELD_CREATED = 4;
}

message ListVolumesSort {
ListVolumesSortField field = 1;
SortDirection direction = 2;
}

message ListVolumesFilter {
repeated VolumeStatus status_in = 1;
repeated string runner_id_in = 2;
repeated VolumeAttachmentFilterKind attached_to_kind_in = 3;
optional bool pending_sample = 4;
optional string volume_name_substring = 5;
Comment thread
noa-lucent marked this conversation as resolved.
Comment thread
noa-lucent marked this conversation as resolved.
}

message ListVolumesRequest {
int32 page_size = 1;
// Opaque cursor; reuse only with the same sort and filter.
string page_token = 2;
repeated VolumeStatus statuses = 3;
// Deprecated: use filter.status_in instead.
repeated VolumeStatus statuses = 3 [deprecated = true];
// Required organization scope; caller must hold can_view_volumes.
optional string organization_id = 4;
optional string runner_id = 5;
optional bool pending_sample = 6;
// Deprecated: use filter.runner_id_in instead.
optional string runner_id = 5 [deprecated = true];
// Deprecated: use filter.pending_sample instead.
optional bool pending_sample = 6 [deprecated = true];
ListVolumesFilter filter = 7;
ListVolumesSort sort = 8;
}

message ListVolumesResponse {
Expand Down
50 changes: 50 additions & 0 deletions proto/agynio/api/threads/v1/threads.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,11 @@ service ThreadsService {
// List threads for a participant with pagination.
rpc GetThreads(GetThreadsRequest) returns (GetThreadsResponse);

// List threads for an organization with pagination.
rpc ListOrganizationThreads(ListOrganizationThreadsRequest) returns (ListOrganizationThreadsResponse);

// Get threads for an organization with pagination.
// Deprecated: use ListOrganizationThreads.
rpc GetOrganizationThreads(GetOrganizationThreadsRequest) returns (GetOrganizationThreadsResponse);
Comment thread
noa-lucent marked this conversation as resolved.

// Get a thread by ID.
Expand Down Expand Up @@ -64,6 +68,12 @@ enum MessageOrder {
MESSAGE_ORDER_NEWEST_FIRST = 2;
}

enum SortDirection {
SORT_DIRECTION_UNSPECIFIED = 0;
SORT_DIRECTION_ASC = 1;
SORT_DIRECTION_DESC = 2;
}

// ===========================================================================
// Entities
// ===========================================================================
Expand All @@ -88,6 +98,8 @@ message Participant {
google.protobuf.Timestamp joined_at = 2;
// When true, the participant receives messages but does not trigger workload starts.
bool passive = 3;
// Resolved @nickname for this participant in the organization context.
string nickname = 4;
Comment thread
noa-lucent marked this conversation as resolved.
}

// A message within a thread.
Expand Down Expand Up @@ -223,6 +235,44 @@ message GetThreadsResponse {
string next_page_token = 2;
}

// ===========================================================================
// ListOrganizationThreads
// ===========================================================================

enum ListOrganizationThreadsSortField {
LIST_ORGANIZATION_THREADS_SORT_FIELD_UNSPECIFIED = 0;
LIST_ORGANIZATION_THREADS_SORT_FIELD_CREATED = 1;
LIST_ORGANIZATION_THREADS_SORT_FIELD_UPDATED = 2;
LIST_ORGANIZATION_THREADS_SORT_FIELD_MESSAGE_COUNT = 3;
LIST_ORGANIZATION_THREADS_SORT_FIELD_STATUS = 4;
}

message ListOrganizationThreadsFilter {
repeated ThreadStatus status_in = 1;
repeated string participant_id_in = 2;
optional google.protobuf.Timestamp created_after = 3;
optional google.protobuf.Timestamp created_before = 4;
}

message ListOrganizationThreadsSort {
ListOrganizationThreadsSortField field = 1;
SortDirection direction = 2;
}

message ListOrganizationThreadsRequest {
string organization_id = 1; // UUID
Comment thread
noa-lucent marked this conversation as resolved.
ListOrganizationThreadsFilter filter = 2;
ListOrganizationThreadsSort sort = 3;
int32 page_size = 4;
// Opaque cursor; reuse only with the same sort and filter.
string page_token = 5;
}

message ListOrganizationThreadsResponse {
repeated Thread threads = 1;
string next_page_token = 2;
}

// ===========================================================================
// GetOrganizationThreads
// ===========================================================================
Expand Down
Loading