syntax = "proto3";

package centrifugal.centrifugo.api;

option go_package = "./;apiproto";

import "google/api/annotations.proto";
import "protoc-gen-openapiv2/options/annotations.proto";

option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_swagger) = {
  info: {
    title: "Centrifugo server HTTP API";
    version: "6.0";
    description: "";
  };
  external_docs: {
    url: "https://centrifugal.dev/docs/server/server_api";
    description: "More about Centrifugo HTTP API";
  }
  consumes: "application/json";
  produces: "application/json";
  base_path: "/api";
  tags: [
    {
      name: "publication"
    },
    {
      name: "connection management"
    },
    {
      name: "history"
    },
    {
      name: "presence"
    },
    {
      name: "stats"
    },
    {
      name: "user status"
    },
    {
      name: "user block"
    },
    {
      name: "token"
    },
    {
      name: "push notification"
    },
    {
      name: "batch"
    },
    {
      name: "rpc"
    },
    {
      name: "map"
    },
    {
      name: "shared poll"
    }
  ];
  responses: {
    key: "400";
    value: {
      description: "Returned in case of invalid request."
    }
  }
  responses: {
    key: "401";
    value: {
      description: "Returned in case of missing auth."
    }
  }
  responses: {
    key: "500";
    value: {
      description: "Returned in case of internal server error."
    }
  }
  security_definitions: {
    security: {
      key: "ApiKeyAuth";
      value: {
        type: TYPE_API_KEY;
        in: IN_HEADER;
        name: "X-API-Key";
      }
    }
  }
  security: {
    security_requirement: {
      key: "ApiKeyAuth";
      value: {};
    }
  }
};

service CentrifugoApi {
  rpc Batch(BatchRequest) returns (BatchResponse) {
    option (google.api.http) = {
      post: "/batch",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Batch request (send many commands in one request)";
      tags: ["batch"];
    };
  }
  rpc Publish (PublishRequest) returns (PublishResponse) {
    option (google.api.http) = {
      post: "/publish",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Publish data into channel";
      tags: ["publication"];
    };
  }
  rpc Broadcast (BroadcastRequest) returns (BroadcastResponse) {
    option (google.api.http) = {
      post: "/broadcast",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Broadcast allows publishing same data into many channels";
      tags: ["publication"];
    };
  }
  rpc Subscribe (SubscribeRequest) returns (SubscribeResponse) {
    option (google.api.http) = {
      post: "/subscribe",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Subscribe connection(s) to a channel";
      tags: ["connection management"];
    };
  }
  rpc Unsubscribe (UnsubscribeRequest) returns (UnsubscribeResponse) {
    option (google.api.http) = {
      post: "/unsubscribe",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Unsubscribe connection(s) from channel";
      tags: ["connection management"];
    };
  }
  rpc Disconnect (DisconnectRequest) returns (DisconnectResponse) {
    option (google.api.http) = {
      post: "/disconnect",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Disconnect client(s) from server";
      tags: ["connection management"];
    };
  }
  rpc Presence (PresenceRequest) returns (PresenceResponse) {
    option (google.api.http) = {
      post: "/presence",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Presence information for a channel";
      tags: ["presence"];
    };
  }
  rpc PresenceStats (PresenceStatsRequest) returns (PresenceStatsResponse) {
    option (google.api.http) = {
      post: "/presence_stats",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Presence stats information for a channel";
      tags: ["presence"];
    };
  }
  rpc History (HistoryRequest) returns (HistoryResponse) {
    option (google.api.http) = {
      post: "/history",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "History for a channel";
      tags: ["history"];
    };
  }
  rpc HistoryRemove (HistoryRemoveRequest) returns (HistoryRemoveResponse) {
    option (google.api.http) = {
      post: "/history_remove",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Remove history for a channel";
      tags: ["history"];
    };
  }
  rpc Info (InfoRequest) returns (InfoResponse) {
    option (google.api.http) = {
      post: "/info",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Info shows details about server nodes";
      tags: ["stats"];
    };
  }
  rpc RPC (RPCRequest) returns (RPCResponse) {
    option (google.api.http) = {
      post: "/rpc",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Execute RPC";
      tags: ["rpc"];
    };
  }
  rpc Refresh (RefreshRequest) returns (RefreshResponse) {
    option (google.api.http) = {
      post: "/refresh",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Refresh connection(s) by server-side call";
      tags: ["connection management"];
    };
  }
  rpc Channels (ChannelsRequest) returns (ChannelsResponse) {
    option (google.api.http) = {
      post: "/channels",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Channels request";
      tags: ["stats"];
    };
  }
  rpc Connections (ConnectionsRequest) returns (ConnectionsResponse) {
    option (google.api.http) = {
      post: "/connections",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Connections request";
      tags: ["stats"];
    };
  }
  rpc UpdateUserStatus (UpdateUserStatusRequest) returns (UpdateUserStatusResponse) {
    option (google.api.http) = {
      post: "/update_user_status",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Updated user status request";
      tags: ["user status"];
    };
  }
  rpc GetUserStatus (GetUserStatusRequest) returns (GetUserStatusResponse) {
    option (google.api.http) = {
      post: "/get_user_status",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Get user status request";
      tags: ["user status"];
    };
  }
  rpc DeleteUserStatus (DeleteUserStatusRequest) returns (DeleteUserStatusResponse) {
    option (google.api.http) = {
      post: "/delete_user_status",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Delete user status request";
      tags: ["user status"];
    };
  }
  rpc BlockUser (BlockUserRequest) returns (BlockUserResponse) {
    option (google.api.http) = {
      post: "/block_user",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Block user request";
      tags: ["user block"];
    };
  }
  rpc UnblockUser (UnblockUserRequest) returns (UnblockUserResponse) {
    option (google.api.http) = {
      post: "/unblock_user",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Unblock user request";
      tags: ["user block"];
    };
  }
  rpc RevokeToken (RevokeTokenRequest) returns (RevokeTokenResponse) {
    option (google.api.http) = {
      post: "/revoke_token",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Revoke token request";
      tags: ["token"];
    };
  }
  rpc InvalidateUserTokens (InvalidateUserTokensRequest) returns (InvalidateUserTokensResponse) {
    option (google.api.http) = {
      post: "/invalidate_user_tokens",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Invalidate user tokens request";
      tags: ["token"];
    };
  }
  rpc DeviceRegister (DeviceRegisterRequest) returns (DeviceRegisterResponse) {
    option (google.api.http) = {
      post: "/device_register",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Device register request";
      tags: ["push notification"];
    };
  }
  rpc DeviceUpdate (DeviceUpdateRequest) returns (DeviceUpdateResponse) {
    option (google.api.http) = {
      post: "/device_update",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Device update request";
      tags: ["push notification"];
    };
  }
  rpc DeviceRemove (DeviceRemoveRequest) returns (DeviceRemoveResponse) {
    option (google.api.http) = {
      post: "/device_remove",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Device remove request";
      tags: ["push notification"];
    };
  }
  rpc DeviceList (DeviceListRequest) returns (DeviceListResponse) {
    option (google.api.http) = {
      post: "/device_list",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "List devices";
      tags: ["push notification"];
    };
  }
  rpc DeviceTopicList (DeviceTopicListRequest) returns (DeviceTopicListResponse) {
    option (google.api.http) = {
      post: "/device_topic_list",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "List device topics";
      tags: ["push notification"];
    };
  }
  rpc DeviceTopicUpdate (DeviceTopicUpdateRequest) returns (DeviceTopicUpdateResponse) {
    option (google.api.http) = {
      post: "/device_topic_update",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Update device topic model";
      tags: ["push notification"];
    };
  }
  rpc UserTopicList (UserTopicListRequest) returns (UserTopicListResponse) {
    option (google.api.http) = {
      post: "/user_topic_list",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "List user topics";
      tags: ["push notification"];
    };
  }
  rpc UserTopicUpdate (UserTopicUpdateRequest) returns (UserTopicUpdateResponse) {
    option (google.api.http) = {
      post: "/user_topic_update",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Update user topic model";
      tags: ["push notification"];
    };
  }
  rpc SendPushNotification (SendPushNotificationRequest) returns (SendPushNotificationResponse) {
    option (google.api.http) = {
      post: "/send_push_notification",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Send push notification";
      tags: ["push notification"];
    };
  }
  rpc UpdatePushStatus (UpdatePushStatusRequest) returns (UpdatePushStatusResponse) {
    option (google.api.http) = {
      post: "/update_push_status",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Update push notification status";
      tags: ["push notification"];
    };
  }
  rpc CancelPush (CancelPushRequest) returns (CancelPushResponse) {
    option (google.api.http) = {
      post: "/cancel_push",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Cancel delayed push notification";
      tags: ["push notification"];
    };
  }
  rpc MapPublish (MapPublishRequest) returns (MapPublishResponse) {
    option (google.api.http) = {
      post: "/map_publish",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Publish a key into a map channel";
      tags: ["map"];
    };
  }
  rpc MapRemove (MapRemoveRequest) returns (MapRemoveResponse) {
    option (google.api.http) = {
      post: "/map_remove",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Remove a key from a map channel";
      tags: ["map"];
    };
  }
  rpc MapReadState (MapReadStateRequest) returns (MapReadStateResponse) {
    option (google.api.http) = {
      post: "/map_read_state",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Read current state of a map channel";
      tags: ["map"];
    };
  }
  rpc MapReadStream (MapReadStreamRequest) returns (MapReadStreamResponse) {
    option (google.api.http) = {
      post: "/map_read_stream",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Read the stream of a map channel";
      tags: ["map"];
    };
  }
  rpc MapStats (MapStatsRequest) returns (MapStatsResponse) {
    option (google.api.http) = {
      post: "/map_stats",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Stats for a map channel";
      tags: ["map"];
    };
  }
  rpc MapClear (MapClearRequest) returns (MapClearResponse) {
    option (google.api.http) = {
      post: "/map_clear",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Clear a map channel";
      tags: ["map"];
    };
  }
  rpc SharedPollPublish (SharedPollPublishRequest) returns (SharedPollPublishResponse) {
    option (google.api.http) = {
      post: "/shared_poll_publish",
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      summary: "Publish into a shared poll channel";
      tags: ["shared poll"];
    };
  }
}

message Command {
  reserved 1,2,3;

  PublishRequest publish = 4;
  BroadcastRequest broadcast = 5;
  SubscribeRequest subscribe = 6;
  UnsubscribeRequest unsubscribe = 7;
  DisconnectRequest disconnect = 8;
  PresenceRequest presence = 9;
  PresenceStatsRequest presence_stats = 10;
  HistoryRequest history = 11;
  HistoryRemoveRequest history_remove = 12;
  InfoRequest info = 13;
  RPCRequest rpc = 14;
  RefreshRequest refresh = 15;
  ChannelsRequest channels = 16;
  ConnectionsRequest connections = 17;
  UpdateUserStatusRequest update_user_status = 18;
  GetUserStatusRequest get_user_status = 19;
  DeleteUserStatusRequest delete_user_status = 20;
  BlockUserRequest block_user = 21;
  UnblockUserRequest unblock_user = 22;
  RevokeTokenRequest revoke_token = 23;
  InvalidateUserTokensRequest invalidate_user_tokens = 24;
  DeviceRegisterRequest device_register = 25;
  DeviceUpdateRequest device_update = 26;
  DeviceRemoveRequest device_remove = 27;
  DeviceListRequest device_list = 28;
  DeviceTopicListRequest device_topic_list = 29;
  DeviceTopicUpdateRequest device_topic_update = 30;
  UserTopicListRequest user_topic_list = 31;
  UserTopicUpdateRequest user_topic_update = 32;
  SendPushNotificationRequest send_push_notification = 33;
  UpdatePushStatusRequest update_push_status = 34;
  CancelPushRequest cancel_push = 35;
  MapPublishRequest map_publish = 36;
  MapRemoveRequest map_remove = 37;
  MapReadStateRequest map_read_state = 38;
  MapReadStreamRequest map_read_stream = 39;
  MapStatsRequest map_stats = 40;
  MapClearRequest map_clear = 41;
  SharedPollPublishRequest shared_poll_publish = 42;
}

message Error {
  uint32 code = 1;
  string message = 2;
}

message Reply {
  reserved 1, 3;

  Error error = 2;

  PublishResult publish = 4;
  BroadcastResult broadcast = 5;
  SubscribeResult subscribe = 6;
  UnsubscribeResult unsubscribe = 7;
  DisconnectResult disconnect = 8;
  PresenceResult presence = 9;
  PresenceStatsResult presence_stats = 10;
  HistoryResult history = 11;
  HistoryRemoveResult history_remove = 12;
  InfoResult info = 13;
  RPCResult rpc = 14;
  RefreshResult refresh = 15;
  ChannelsResult channels = 16;
  ConnectionsResult connections = 17;
  UpdateUserStatusResult update_user_status = 18;
  GetUserStatusResult get_user_status = 19;
  DeleteUserStatusResult delete_user_status = 20;
  BlockUserResult block_user = 21;
  UnblockUserResult unblock_user = 22;
  RevokeTokenResult revoke_token = 23;
  InvalidateUserTokensResult invalidate_user_tokens = 24;
  DeviceRegisterResult device_register = 25;
  DeviceUpdateResult device_update = 26;
  DeviceRemoveResult device_remove = 27;
  DeviceListResult device_list = 28;
  DeviceTopicListResult device_topic_list = 29;
  DeviceTopicUpdateResult device_topic_update = 30;
  UserTopicListResult user_topic_list = 31;
  UserTopicUpdateResult user_topic_update = 32;
  SendPushNotificationResult send_push_notification = 33;
  UpdatePushStatusResult update_push_status = 34;
  CancelPushResult cancel_push = 35;
  MapPublishResult map_publish = 36;
  MapRemoveResult map_remove = 37;
  MapReadStateResult map_read_state = 38;
  MapReadStreamResult map_read_stream = 39;
  MapStatsResult map_stats = 40;
  MapClearResult map_clear = 41;
  SharedPollPublishResult shared_poll_publish = 42;
}

message BatchRequest {
  repeated Command commands = 1;
  bool parallel = 2;
}

message BatchResponse {
  repeated Reply replies = 1;
}

message PublishRequest {
  string channel = 1;
  bytes data = 2;
  string b64data = 3;
  bool skip_history = 4;
  map<string, string> tags = 5;
  string idempotency_key = 6;
  bool delta = 7;
  uint64 version = 8;
  string version_epoch = 9;
}

message PublishResponse {
  Error error = 1;
  PublishResult result = 2;
}

message PublishResult {
  uint64 offset = 1;
  string epoch = 2;
}

message BroadcastRequest {
  repeated string channels = 1;
  bytes data = 2;
  string b64data = 3;
  bool skip_history = 4;
  map<string, string> tags = 5;
  string idempotency_key = 6;
  bool delta = 7;
  uint64 version = 8;
  string version_epoch = 9;
}

message BroadcastResponse {
  Error error = 1;
  BroadcastResult result = 2;
}

message BroadcastResult {
  repeated PublishResponse responses = 1;
}

// FilterNode is a tree describing a label predicate.
// Used as label_filter on Subscribe/Unsubscribe/Disconnect/Refresh/Connections requests.
// PRO only — defined in OSS api.proto for protocol-surface consistency; OSS handlers parse but do not act on it.
message FilterNode {
  string op = 1;
  string key = 2;
  string cmp = 3;
  string val = 4;
  repeated string vals = 5;
  repeated FilterNode nodes = 6;
}

message SubscribeRequest {
  string channel = 1;
  string user = 2;
  int64 expire_at = 3;
  bytes info = 4;
  string b64info = 5;
  string client = 6;
  bytes data = 7;
  string b64data = 8;
  StreamPosition recover_since = 9;
  SubscribeOptionOverride override = 10;
  string session = 11;
  // PRO only — restrict the call to clients whose labels match this filter.
  FilterNode label_filter = 12;
  // PRO only — when `user` is empty, target every connection on every node
  // instead of the anonymous-only bucket. No effect when `user` is non-empty.
  bool all_users = 13;
}

message SubscribeResponse {
  Error error = 1;
  SubscribeResult result = 2;
}

message BoolValue {
  bool value = 1;
}

message Int32Value {
  int32 value = 1;
}

message SubscribeOptionOverride {
  BoolValue presence = 1;
  BoolValue join_leave = 2;
  BoolValue force_recovery = 3;
  BoolValue force_positioning = 4;
  BoolValue force_push_join_leave = 5;
}

message SubscribeResult {}

message UnsubscribeRequest {
  string channel = 1;
  string user = 2;
  string client = 3;
  string session = 4;
  // PRO only — restrict the call to clients whose labels match this filter.
  FilterNode label_filter = 5;
  // PRO only — see SubscribeRequest.all_users.
  bool all_users = 6;
}

message UnsubscribeResponse {
  Error error = 1;
  UnsubscribeResult result = 2;
}

message UnsubscribeResult {}

message Disconnect {
  reserved 3;

  uint32 code = 1;
  string reason = 2;
}

message DisconnectRequest {
  string user = 1;
  Disconnect disconnect = 2;
  string client = 3;
  repeated string whitelist = 4;
  string session = 5;
  // PRO only — restrict the call to clients whose labels match this filter.
  FilterNode label_filter = 6;
  // PRO only — see SubscribeRequest.all_users.
  bool all_users = 7;
}

message DisconnectResponse {
  Error error = 1;
  DisconnectResult result = 2;
}

message DisconnectResult {}

message PresenceRequest {
  string channel = 1;
}

message PresenceResponse {
  Error error = 1;
  PresenceResult result = 2;
}

message ClientInfo {
  string user = 1;
  string client = 2;
  bytes conn_info = 3;
  bytes chan_info = 4;
}

message PresenceResult {
  map<string, ClientInfo> presence = 1;
}

message PresenceStatsRequest {
  string channel = 1;
}

message PresenceStatsResponse {
  Error error = 1;
  PresenceStatsResult result = 2;
}

message PresenceStatsResult {
  uint32 num_clients = 1;
  uint32 num_users = 2;
}

message StreamPosition {
  uint64 offset = 1;
  string epoch = 2;
}

message HistoryRequest {
  string channel = 1;
  int32 limit = 2;
  StreamPosition since = 3;
  bool reverse = 4;
}

message HistoryResponse {
  Error error = 1;
  HistoryResult result = 2;
}

message Publication {
  // Removed: string uid = 1;
  bytes data = 2;
  ClientInfo info = 3;
  uint64 offset = 4;
  map<string, string> tags = 5;
}

message HistoryResult {
  repeated Publication publications = 1;
  string epoch = 2;
  uint64 offset = 3;
}

message HistoryRemoveRequest {
  string channel = 1;
}

message HistoryRemoveResponse {
  Error error = 1;
  HistoryRemoveResult result = 2;
}

message HistoryRemoveResult {}

message InfoRequest {}

message InfoResponse {
  Error error = 1;
  InfoResult result = 2;
}

message InfoResult {
  repeated NodeResult nodes = 1;
}

message RPCRequest {
  string method = 1;
  bytes params = 2;
}

message RPCResponse {
  Error error = 1;
  RPCResult result = 2;
}

message RPCResult {
  bytes data = 1;
}

message RefreshRequest {
  string user = 1;
  string client = 2;
  bool expired = 3;
  int64 expire_at = 4;
  bytes info = 5;
  string session = 6;
  // PRO only — restrict the call to clients whose labels match this filter.
  FilterNode label_filter = 7;
  // PRO only — see SubscribeRequest.all_users.
  bool all_users = 8;
}

message RefreshResponse {
  Error error = 1;
  RefreshResult result = 2;
}

message RefreshResult {}

message NodeResult {
  string uid = 1;
  string name = 2;
  string version = 3;
  uint32 num_clients = 4;
  uint32 num_users = 5;
  uint32 num_channels = 6;
  uint32 uptime = 7;
  Metrics metrics = 8;
  Process process = 9;
  uint32 num_subs = 10;
}

message Metrics {
  double interval = 1;
  map<string, double> items = 2;
}

message Process {
  double cpu = 1;
  int64 rss = 2;
}

message ChannelsRequest {
  string pattern = 1;
}

message ChannelsResponse {
  Error error = 1;
  ChannelsResult result = 2;
}

message ChannelsResult {
  map<string, ChannelInfo> channels = 1;
}

message ChannelInfo {
  uint32 num_clients = 1;
}

message ConnectionsRequest {
  string user = 1;
  string expression = 2;
  // PRO only — restrict the listing to clients whose labels match this filter.
  FilterNode label_filter = 3;
}

message ConnectionsResponse {
  Error error = 1;
  ConnectionsResult result = 2;
}

message ConnectionsResult {
  map<string, ConnectionInfo> connections = 1;
}

message ConnectionInfo {
  reserved 5, 7;

  string app_name = 1;
  string app_version = 2;
  string transport = 3;
  string protocol = 4;
  string user = 8;
  ConnectionState state = 9;
  int64 connected_at_ms = 10;
  int64 ping_pong_latency_ms = 11; // can be -1 if not available.
  // PRO only — client labels attached to the centrifuge.Client by Centrifugo PRO.
  map<string, string> labels = 12;
}

message ConnectionState {
  map<string, ChannelContext> channels = 1;
  ConnectionTokenInfo connection_token = 2;
  map<string, SubscriptionTokenInfo> subscription_tokens = 3;
  bytes meta = 4;
}

message ChannelContext {
  uint32 source = 1;
}

message ConnectionTokenInfo {
  string uid = 1;
  int64 issued_at = 2;
}

message SubscriptionTokenInfo {
  string uid = 1;
  int64 issued_at = 2;
}

message UpdateUserStatusRequest {
  repeated string users = 1;
  string state = 2;
}

message UpdateUserStatusResponse {
  Error error = 1;
  UpdateUserStatusResult result = 2;
}

message UpdateUserStatusResult {}

message GetUserStatusRequest {
  repeated string users = 1;
}

message GetUserStatusResponse {
  Error error = 1;
  GetUserStatusResult result = 2;
}

message GetUserStatusResult {
  repeated UserStatus statuses = 1;
}

message UserStatus {
  string user = 1;
  int64 active = 2;
  int64 online = 3;
  string state = 4;
}

message DeleteUserStatusRequest {
  repeated string users = 1;
}

message DeleteUserStatusResponse {
  Error error = 1;
  DeleteUserStatusResult result = 2;
}

message DeleteUserStatusResult {
}

message BlockUserRequest {
  int64 expire_at = 1;
  string user = 2;
}

message BlockUserResult {}

message BlockUserResponse {
  Error error = 1;
  BlockUserResult result = 2;
}

message UnblockUserRequest {
  string user = 1;
}

message UnblockUserResult {}

message UnblockUserResponse {
  Error error = 1;
  UnblockUserResult result = 2;
}

message RevokeTokenRequest {
  int64 expire_at = 1;
  string uid = 2;
}

message RevokeTokenResult {}

message RevokeTokenResponse {
  Error error = 1;
  RevokeTokenResult result = 2;
}

message InvalidateUserTokensRequest {
  int64 expire_at = 1;
  string user = 2;
  int64 issued_before = 3;
  string channel = 4;
}

message InvalidateUserTokensResult {}

message InvalidateUserTokensResponse {
  Error error = 1;
  InvalidateUserTokensResult result = 2;
}

message DeviceRegisterRequest {
  string id = 1;
  string provider = 2;
  string token = 3;
  string platform = 4;
  string user = 5;
  map<string, string> meta = 6;
  repeated string topics = 7;
  string timezone = 8;
  string locale = 9;
}

message DeviceUpdateRequest {
  repeated string ids = 1;
  repeated string users = 2;

  DeviceUserUpdate user_update = 4;
  DeviceMetaUpdate meta_update = 5;
  DeviceTopicsUpdate topics_update = 6;
  DeviceTimezoneUpdate timezone_update = 7;
  DeviceLocaleUpdate locale_update = 8;
}

message DeviceRemoveRequest {
  repeated string ids = 1;
  repeated string users = 2;
}

message DeviceUserUpdate {
  string user = 1;
}

message DeviceTimezoneUpdate {
  string timezone = 1;
}

message DeviceLocaleUpdate {
  string locale = 1;
}

message DeviceMetaUpdate {
  map<string, string> meta = 1;
}

message DeviceTopicsUpdate {
  string op = 1; // add | remove | set
  repeated string topics = 2;
}

message DeviceFilter {
  repeated string ids = 1;
  repeated string users = 2;
  repeated string topics = 3;
  repeated string providers = 4;
  repeated string platforms = 5;
}

message DeviceListRequest {
  DeviceFilter filter = 1;

  bool include_total_count = 2;
  bool include_meta = 3;
  bool include_topics = 4;
  bool include_webpush_keys = 5;

  string cursor = 10;
  int32 limit = 11;
}

message DeviceTopicFilter {
  repeated string device_ids = 1;
  repeated string device_providers = 2;
  repeated string device_platforms = 3;
  repeated string device_users = 4;
  repeated string topics = 5;
  string topic_prefix = 6;
}

message DeviceTopicListRequest {
  DeviceTopicFilter filter = 1;

  bool include_total_count = 2;
  bool include_device = 3;

  string cursor = 10;
  int32 limit = 11;
}

message UserTopicFilter {
  repeated string users = 1;
  repeated string topics = 2;
  string topic_prefix = 3;
}

message UserTopicListRequest {
  UserTopicFilter filter = 1;

  bool include_total_count = 2;

  string cursor = 10;
  int32 limit = 11;
}

message DeviceTopicUpdateRequest {
  string device_id = 1;
  string op = 2; // add | remove | set
  repeated string topics = 3;
  string user = 4; // optional ownership guard: apply only if the device currently belongs to this user
}

message UserTopicUpdateRequest {
  string user = 1;
  string op = 2; // add | remove | set
  repeated string topics = 3;
}

message DeviceRegisterResponse {
  Error error = 1;
  DeviceRegisterResult result = 2;
}

message DeviceUpdateResponse {
  Error error = 1;
  DeviceUpdateResult result = 2;
}

message DeviceRemoveResponse {
  Error error = 1;
  DeviceRemoveResult result = 2;
}

message DeviceListResponse {
  Error error = 1;
  DeviceListResult result = 2;
}

message DeviceTopicListResponse {
  Error error = 1;
  DeviceTopicListResult result = 2;
}

message UserTopicListResponse {
  Error error = 1;
  UserTopicListResult result = 2;
}

message DeviceTopicUpdateResponse {
  Error error = 1;
  DeviceTopicUpdateResult result = 2;
}

message UserTopicUpdateResponse {
  Error error = 1;
  UserTopicUpdateResult result = 2;
}

message DeviceRegisterResult {
  string id = 1;
}

message DeviceUpdateResult {
}

message DeviceRemoveResult {
}

message DeviceListResult {
  repeated Device items = 1;
  string next_cursor = 2;
  int64 total_count = 3;
}

message Device {
  string id = 1;
  string platform = 2;
  string provider = 3;
  string token = 4;
  string user = 5;
  int64 created_at = 6;
  int64 updated_at = 7;

  map<string, string> meta = 10;
  repeated string topics = 11;
  string timezone = 12;
  string locale = 13;
  string webpush_keys = 14;
}

message DeviceTopicListResult {
  repeated DeviceTopic items = 1;
  string next_cursor = 2;
  int64 total_count = 3;
}

message DeviceTopic {
  string id = 1;
  string topic = 2;
  Device device = 3;
}

message UserTopicListResult {
  repeated UserTopic items = 1;
  string next_cursor = 2;
  int64 total_count = 3;
}

message DeviceTopicUpdateResult {
}

message UserTopicUpdateResult {
}

message UserTopic {
  string id = 1;
  string user = 2;
  string topic = 3;
}

message PushRecipient {
  DeviceFilter filter = 1;

  repeated string fcm_tokens = 2;
  string fcm_topic = 3;
  string fcm_condition = 4;

  repeated string hms_tokens = 5;
  string hms_topic = 6;
  string hms_condition = 7;

  repeated string apns_tokens = 8;

  repeated string webpush_tokens = 9;
}

message PushNotification {
  FcmPushNotification fcm = 1;
  HmsPushNotification hms = 2;
  ApnsPushNotification apns = 3;
  WebPushPushNotification webpush = 4;

  int64 expire_at = 5; // timestamp in the future when Centrifugo should stop trying to send push notification.
}

message FcmPushNotification {
  bytes message = 1;
}

message HmsPushNotification {
  bytes message = 1;
}

message ApnsPushNotification {
  map<string, string> headers = 1;
  bytes payload = 2;
}

message WebPushPushNotification {
  map<string, string> headers = 1;
  bytes payload = 2;
}

message SendPushNotificationRequest {
  PushRecipient recipient = 1;
  PushNotification notification = 2;
  string uid = 3; // unique identifier for each push notification request, can be used to cancel push.
  int64 send_at = 4; // Unix seconds, if set - push will be sent at this time, if not set - immediately.
  bool optimize_for_reliability = 5; // makes processing heavier, but tolerates edge cases, like not losing inflight pushes due to temporary queue unavailability.
  PushLimitStrategy limit_strategy = 6; // strategy for sending push notifications. Applicable only for pushes with filter recipient. When using this field Centrifugo processes devices one by one.
  string analytics_uid = 7; // uid for push notification analytics, if not set - Centrifugo will use uid field.
  map<string, PushLocalization> localizations = 8; // optional per language/locale localizations for push notification.
  bool use_templating = 9; // if set - Centrifugo will use templating for push notification. Note that setting localizations enables templating automatically.
  bool use_meta = 10; // if set - Centrifugo will additionally load device meta during push sending, this meta becomes available in templating.
}

message PushLocalization {
  map<string, string> translations = 1; // variable name to value for the specific language/locale.
}

message PushLimitStrategy {
  PushRateLimitStrategy rate_limit = 1;
  PushTimeLimitStrategy time_limit = 2;
}

message PushTimeLimitStrategy {
  string send_after_time = 1;  // HH:MM:SS
  string send_before_time = 2; // HH:MM:SS
  bool no_tz_send_now = 3; // If device timezone is not set - send push now, by default will be dropped.
}

message PushRateLimitStrategy {
  string key = 1; // optional key for rate limit policy, supports variables.
  repeated RateLimitPolicy policies = 2;
  bool drop_if_rate_limited = 3;
}

message RateLimitPolicy {
  int64 rate = 1;
  int32 interval_ms = 2;
}

message SendPushNotificationResponse {
  Error error = 1;
  SendPushNotificationResult result = 2;
}

message SendPushNotificationResult {
  string uid = 1;  // Unique identifier of notification send request (it's not a FCM message id).
}

message UpdatePushStatusRequest {
  string analytics_uid = 1; // analytics uid of push notification (should match SendPushNotificationRequest.analytics_uid)
  string status = 2;        // delivered | interacted
  string device_id = 3;     // Centrifugo device id.
  string msg_id = 4;        // Provider issued message id.
}

message UpdatePushStatusResponse {
  Error error = 1;
  UpdatePushStatusResult result = 2;
}

message UpdatePushStatusResult {}

message CancelPushRequest {
  string uid = 1;
}

message CancelPushResponse {
  Error error = 1;
  CancelPushResult result = 2;
}

message CancelPushResult {}

message MapPublishRequest {
  string channel = 1;
  string key = 2;
  bytes data = 3;
  string b64data = 4;
  bytes stream_data = 5;
  string b64stream_data = 6;
  map<string, string> tags = 7;
  string idempotency_key = 8;
  bool delta = 9;
  uint64 version = 10;
  string version_epoch = 11;
  int64 score = 12;
  string key_mode = 13;
}

message MapPublishResponse {
  Error error = 1;
  MapPublishResult result = 2;
}

message MapPublishResult {
  uint64 offset = 1;
  string epoch = 2;
  bool suppressed = 3;
  string suppress_reason = 4;
}

message MapRemoveRequest {
  string channel = 1;
  string key = 2;
  string idempotency_key = 3;
}

message MapRemoveResponse {
  Error error = 1;
  MapRemoveResult result = 2;
}

message MapRemoveResult {
  uint64 offset = 1;
  string epoch = 2;
  bool suppressed = 3;
  string suppress_reason = 4;
}

message MapReadStateRequest {
  string channel = 1;
  string cursor = 2;
  int32 limit = 3;
  string key = 4;
  bool asc = 5;
  uint64 revision_offset = 6;
  string revision_epoch = 7;
}

message MapReadStateResponse {
  Error error = 1;
  MapReadStateResult result = 2;
}

message MapReadStateResult {
  repeated MapEntry entries = 1;
  uint64 offset = 2;
  string epoch = 3;
  string cursor = 4;
}

message MapEntry {
  string key = 1;
  bytes data = 2;
  map<string, string> tags = 3;
  uint64 offset = 4;
  int64 score = 5;
  bool removed = 6;
  int64 time = 7;
}

message MapReadStreamRequest {
  string channel = 1;
  uint64 since_offset = 2;
  string since_epoch = 3;
  int32 limit = 4;
  bool reverse = 5;
}

message MapReadStreamResponse {
  Error error = 1;
  MapReadStreamResult result = 2;
}

message MapReadStreamResult {
  repeated MapEntry entries = 1;
  uint64 offset = 2;
  string epoch = 3;
}

message MapStatsRequest {
  string channel = 1;
}

message MapStatsResponse {
  Error error = 1;
  MapStatsResult result = 2;
}

message MapStatsResult {
  int32 num_keys = 1;
}

message MapClearRequest {
  string channel = 1;
}

message MapClearResponse {
  Error error = 1;
  MapClearResult result = 2;
}

message MapClearResult {}

message SharedPollPublishRequest {
  string channel = 1;
  string key = 2;
  bytes data = 3;
  string b64data = 4;
  uint64 version = 5;
  string epoch = 6;
}

message SharedPollPublishResponse {
  Error error = 1;
  SharedPollPublishResult result = 2;
}

message SharedPollPublishResult {}