| Age | Commit message (Collapse) | Author |
|---|
|
✨ (ls_client.rs): add TLCP_VERSION constant for protocol version tracking
♻️ (ls_client.rs): remove commented-out code and unused println for cleaner codebase
♻️ (ls_client.rs): use TLCP_VERSION constant instead of hardcoded protocol string
✨ (ls_client.rs): handle 'reqok' server message for better server communication
♻️ (subscription.rs): change error type to Box<dyn Error> for more generic error handling
🐛 (subscription.rs): fix error message to be more descriptive when items or fields are missing
|
|
value
|
|
✨ (connection_details.rs): add user and password parameters to ConnectionDetails::new
♻️ (ls_client.rs): refactor user and password handling into ConnectionDetails
🐛 (ls_client.rs): downgrade TLCP protocol version from 2.5.0 to 2.4.0
✨ (main.rs): update LightstreamerClient::new call to include optional username and password parameters
|
|
♻️ (connection_details.rs): refactor `new` method to return Result for better error handling
✨ (connection_details.rs): set default adapter set to "DEFAULT" if none provided
✨ (ls_client.rs): update `new` method to handle Result from ConnectionDetails::new
🐛 (main.rs): fix subscription item list to include correct items
♻️ (main.rs): replace magic number with constant for max connection attempts
|
|
♻️ (ls_client.rs): streamline WebSocket 'wsok' message sending code
|
|
♻️ (ls_client.rs): Refactor message processing to handle multiple submessages
🐛 (ls_client.rs): Fix default instantiation of ConnectionOptions using default method
|
|
maintainability
♻️ (ls_client.rs): remove hardcoded base_params and use dynamic params for session creation
♻️ (ls_client.rs): remove commented-out subscription code for cleanup
✨ (ls_client.rs): handle new server messages for connection errors and subscription confirmations
🚚 (ls_client.rs): remove unnecessary println at the end of connect function
✨ (main.rs): change adapter set from "QUOTE_ADAPTER" to "DEMO" for client initialization
✨ (subscription.rs): add Default trait implementation for Snapshot enum
✨ (subscription.rs): implement ToString trait for Snapshot and SubscriptionMode enums
🐛 (subscription.rs): fix error message in set_item_group method to be more descriptive
|
|
✨ (ls_client.rs): add conditional adapter_set param to base_params
♻️ (ls_client.rs): remove redundant adapter_set insertion
♻️ (ls_client.rs): refactor message processing loop for clarity and extensibility
🔧 (main.rs): extract MAX_CONNECTION_ATTEMPTS as constant for better configurability
✨ (main.rs): change adapter_set from "DEMO" to "QUOTE_ADAPTER" for client initialization
|
|
IllegalArgumentException and IllegalStateException
♻️ (ls_client.rs): refactor connect method to accept shutdown signal and return generic error
✨ (ls_client.rs): add support for graceful shutdown using Notify
✨ (ls_client.rs): implement session creation and subscription logic in connect method
♻️ (main.rs): replace SharedState with Notify for handling shutdown signal
✨ (main.rs): add retry logic with a maximum of 5 retries for the client connection in main function
✨ (main.rs): ensure graceful client disconnect and orderly shutdown of the application
|
|
🔧 Update .gitignore to exclude .vscode directory
✨ Add futures-util and url dependencies to Cargo.toml
♻️ Refactor error handling into separate error module in Rust project
💡 Add get_password method documentation in connection_details.rs
♻️ Replace String with Transport enum for forced_transport in connection_options.rs
✨ Implement WebSocket connection logic in ls_client.rs with async support
✨ Add ClientStatus, ConnectionType, and DisconnectionType enums to manage client states in ls_client.rs
✨ (main.rs): add Transport enum to LightstreamerClient imports for WebSocket support
♻️ (main.rs): refactor signal handling to use SharedState struct for clean shutdown
✨ (main.rs): implement AtomicBool for graceful disconnect handling
📝 (main.rs): update comments to reflect new signal handling logic
✨ (main.rs): set forced transport to WebSocket streaming in Lightstreamer client options
✨ (util.rs): create new util module with clean_message function for message sanitization
|
|
♻️ (client_listener.rs): make ClientListener trait Send to allow cross-thread usage
✨ (main.rs): implement signal handling for graceful shutdown
♻️ (main.rs): refactor client creation to use Arc<Mutex> for shared state
♻️ (main.rs): add retry logic for persistent connection attempts
♻️ (subscription_listener.rs): make SubscriptionListener trait Send to allow cross-thread usage
|
|
|
|
before connecting
✨ (main.rs): rename subscription to my_subscription for clarity
✨ (main.rs): move subscription setup before client creation
✨ (main.rs): add client.subscribe and client.connect calls to main function
|
|
✨ (ls_client.rs): add `LightstreamerClient` struct and associated methods for managing communication with Lightstreamer Server
✨ (main.rs): update imports to use new `ls_client` module and add data adapter and snapshot configuration to subscription
♻️ (lib.rs): refactor `lightstreamer_client` to `ls_client` for consistency with new module name
📝 (ls_client.rs): add comprehensive documentation for `LightstreamerClient` and its methods
✨ (subscription.rs): add Snapshot enum to define snapshot delivery preferences
♻️ (subscription.rs): refactor requested_snapshot to use Snapshot enum for clarity
💡 (subscription.rs): update comments to reflect changes in snapshot handling
|
|
better logging
♻️ (connection_details.rs): Refactor ConnectionDetails to use Option for optional fields
♻️ (connection_details.rs): Change new constructor to accept &str and convert to String
✨ (connection_details.rs): Implement Debug trait for ConnectionDetails
♻️ (connection_options.rs): Implement Debug trait for ConnectionOptions
♻️ (lightstreamer_client.rs): Refactor LightstreamerClient to use Option for server_address and adapter_set
✨ (lightstreamer_client.rs): Implement Debug trait for LightstreamerClient
♻️ (main.rs): Update subscribe_to_channel function to use new control.txt URL and parameters
♻️ (main.rs): Update main function to use Option<&str> when creating LightstreamerClient
✨ (proxy.rs): Add Proxy struct and ProxyType enum to handle proxy configurations
|
|
|
|
|
|
using tokio for multithreading.
|
|
|
Daniel López Azaña