diff --git a/services/identity/src/constants.rs b/services/identity/src/constants.rs --- a/services/identity/src/constants.rs +++ b/services/identity/src/constants.rs @@ -170,6 +170,7 @@ "identity-search-domain.us-east-2.opensearch.localhost.local stack.cloud:4566"; pub const IDENTITY_SEARCH_INDEX: &str = "users"; +pub const IDENTITY_SEARCH_RESULT_SIZE: u32 = 20; // Tunnelbroker pub const TUNNELBROKER_GRPC_ENDPOINT: &str = "TUNNELBROKER_GRPC_ENDPOINT"; diff --git a/services/identity/src/websockets/mod.rs b/services/identity/src/websockets/mod.rs --- a/services/identity/src/websockets/mod.rs +++ b/services/identity/src/websockets/mod.rs @@ -23,14 +23,15 @@ use crate::config::CONFIG; use crate::constants::{ - IDENTITY_SEARCH_INDEX, IDENTITY_SERVICE_WEBSOCKET_ADDR, - SOCKET_HEARTBEAT_TIMEOUT, + IDENTITY_SEARCH_INDEX, IDENTITY_SEARCH_RESULT_SIZE, + IDENTITY_SERVICE_WEBSOCKET_ADDR, SOCKET_HEARTBEAT_TIMEOUT, }; use send::{send_message, WebsocketSink}; pub mod errors; #[derive(Serialize, Deserialize)] struct Query { + size: u32, query: Prefix, } @@ -148,6 +149,7 @@ prefix_request: identity_search_messages::IdentitySearchPrefix, ) -> Result { let prefix_query = Query { + size: IDENTITY_SEARCH_RESULT_SIZE, query: Prefix { prefix: Username { username: prefix_request.prefix.trim().to_string(),