From b8f6a5850282700a3d2ea942dd8969ddc99e914b Mon Sep 17 00:00:00 2001 From: smehnov Date: Fri, 4 Oct 2024 23:29:44 +1100 Subject: [PATCH] bump version --- Cargo.toml | 6 +++--- src/store_.rs | 30 ++++++++++++++++++++++++++++++ 2 files changed, 33 insertions(+), 3 deletions(-) create mode 100644 src/store_.rs diff --git a/Cargo.toml b/Cargo.toml index 6189693..fe6a6ff 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -1,10 +1,10 @@ [package] name = "robot-agent" -version = "0.1.0" -edition = "2021" +version = "0.1.3" +edition = "2024" [[bin]] -edition = "2021" +edition = "2024" name = "robot-agent" path = "src/main.rs" diff --git a/src/store_.rs b/src/store_.rs new file mode 100644 index 0000000..bd9f594 --- /dev/null +++ b/src/store_.rs @@ -0,0 +1,30 @@ +use libp2p::{Multiaddr, PeerId}; +use libp2p_identity::ed25519; +use serde::{Deserialize, Serialize}; +use std::any::Any; +use std::collections::HashMap; +use std::error::Error; +use std::fs::{self}; +use std::hash::Hash; +use std::sync::{Arc, Mutex}; +use std::time::SystemTime; +use tokio::sync::broadcast; +use tracing::info; + +use base64::{engine::general_purpose, Engine as _}; + +use crate::commands::{RobotJob, RobotJobResult}; + + +/// Manages messages for the system +#[derive(Debug, Clone)] +pub struct MessageManager { + pub from_message_tx: broadcast::Sender, + pub to_message_tx: broadcast::Sender, +} + +impl MessageManager {} + + + +