Struct ScaleService 

pub struct ScaleService { /* private fields */ }

ScaleService struct to manage scale operations, including capturing data and interacting with WebSocket connections.

Implementations

impl ScaleService

pub fn new() -> Self

Creates a new ScaleService instance.

pub fn stop(&self)

Stops the current data capturing process.

pub async fn read_serial( &self, port: String, write: WebSocketWrite, uuid: String, )

Reads data from a serial port and sends parsed values to a WebSocket.

Arguments

• port: The name of the serial port to read from.
• write: The WebSocket connection for sending messages.
• uuid: A unique identifier for the capture session.

pub async fn generate_incremental_weight( &self, write: WebSocketWrite, uuid: String, )

Simulates incremental weight generation for testing purposes.

Arguments

• write: The WebSocket connection for sending messages.
• uuid: A unique identifier for the session.

Trait Implementations

impl Service for ScaleService

fn run<'life0, 'async_trait>( &'life0 self, action: Value, write: WebSocketWrite, ) -> Pin<Box<dyn Future<Output = (i32, String)> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Executes an action for the scale service.

Supported actions:

• “START”: Starts data capturing from the scale. Can handle a test mode or real serial input.
• “STOP”: Stops data capturing.

Arguments

• action - A JSON value containing details of the action. Includes command, device, port, and UUIDV4.
• write - A WebSocketWrite object to communicate results back via WebSocket.

Returns

A tuple containing:

• i32 - Status code (0 for success, 1 for failure).
• String - A descriptive message or UUID related to the action result.

fn as_any(&self) -> &dyn Any

Converts the service instance into a dyn Any reference.

Returns

A reference to dyn Any for dynamic type checks.

fn stop_service(&self)

Stops the scale service and halts data capturing.

Ensures the following:

• Stops any ongoing capturing tasks.
• Resets internal states as needed.

fn get_version(&self) -> String

Retrieves the current version of the scale service.

Returns

A String containing the version of the scale service.