Initial commit

Author: Redrield

.gitignore

@@ -0,0 +1,2 @@
+target/
+.idea/

Cargo.lock

@@ -0,0 +1,2 @@
+[workspace]
+members = ["server", "client", "proto"]

Cargo.toml

@@ -0,0 +1 @@
+/target

client/.gitignore

@@ -0,0 +1,9 @@
+[package]
+name = "client"
+version = "0.1.0"
+authors = ["Redrield <[email protected]>"]
+edition = "2018"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]

client/Cargo.toml

@@ -0,0 +1,3 @@
+fn main() {
+    println!("Hello, world!");
+}

client/src/main.rs

@@ -0,0 +1,2 @@
+/target
+Cargo.lock

proto/.gitignore

@@ -0,0 +1,12 @@
+[package]
+name = "proto"
+version = "0.1.0"
+authors = ["Redrield <[email protected]>"]
+edition = "2018"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+serde = { version = "^1.0.115", features = ["derive"] }
+serde_json = "^1.0.57"
+serde_cbor = "^0.11.1"

proto/Cargo.toml

@@ -0,0 +1,2 @@
+
+mod text;

proto/src/lib.rs

@@ -0,0 +1,73 @@
+use serde::{Serialize, Deserialize};
+use serde_json::Value;
+
+macro_rules! impl_message {
+    ($($name:ident),+) => {
+        $(
+        impl MessageBody for $name {
+            fn into_message(self) -> $crate::text::NTMessage {
+                $crate::text::NTMessage {
+                    _type: $crate::text::MessageType::$name,
+                    data: serde_json::to_value(self).unwrap()
+                }
+            }
+        }
+        )+
+    }
+}
+
+mod publish;
+mod directory;
+mod subscription;
+
+pub trait MessageBody {
+    fn into_message(self) -> NTMessage;
+}
+
+#[derive(Serialize, Deserialize)]
+#[serde(rename_all = "lowercase")]
+pub enum MessageType {
+    #[serde(rename = "publish")]
+    PublishReq,
+    #[serde(rename = "puback")]
+    PublishAck,
+    #[serde(rename = "pubrel")]
+    PublishRel,
+    List,
+    Directory,
+    Listen,
+    Unlisten,
+    Announce,
+    Unannounce,
+    GetValues,
+    Subscribe,
+    Unsubscribe,
+}
+
+#[derive(Serialize, Deserialize)]
+#[serde(rename_all = "lowercase")]
+pub enum DataType {
+    Boolean,
+    Raw,
+    String,
+    Integer,
+    Float,
+    Double,
+    #[serde(rename = "boolean[]")]
+    BooleanArray,
+    #[serde(rename = "string[]")]
+    StringArray,
+    #[serde(rename = "integer[]")]
+    IntegerArray,
+    #[serde(rename = "float[]")]
+    FloatArray,
+    #[serde(rename = "double[]")]
+    DoubleArray,
+}
+
+#[derive(Serialize, Deserialize)]
+pub struct NTMessage {
+    #[serde(rename = "type")]
+    _type: MessageType,
+    data: Value,
+}

proto/src/text.rs

@@ -0,0 +1,50 @@
+use serde::{Serialize, Deserialize};
+use super::MessageBody;
+use crate::text::DataType;
+
+#[derive(Serialize, Deserialize)]
+pub struct List {
+    prefix: String,
+}
+
+#[derive(Serialize, Deserialize)]
+pub struct Directory {
+    items: Vec<DirectoryItem>,
+}
+
+#[derive(Serialize, Deserialize)]
+pub struct DirectoryItem {
+    name: String,
+    id: u32,
+    #[serde(rename = "type")]
+    _type: DataType,
+    persistent: bool,
+}
+
+#[derive(Serialize, Deserialize)]
+pub struct Listen {
+    prefix: String,
+    listenuid: u32,
+}
+
+#[derive(Serialize, Deserialize)]
+pub struct Unlisten {
+    listenuid: u32,
+}
+
+#[derive(Serialize, Deserialize)]
+pub struct Announce {
+    name: String,
+    id: u32,
+    #[serde(rename = "type")]
+    _type: DataType,
+    persistent: bool,
+}
+
+#[derive(Serialize, Deserialize)]
+pub struct Unannounce {
+    name: String,
+    id: u32,
+}
+
+impl_message!(List, Directory, Listen, Unlisten, Announce, Unannounce);

proto/src/text/directory.rs

@@ -0,0 +1,32 @@
+use serde::{Serialize, Deserialize};
+use super::{MessageBody, DataType};
+
+
+#[derive(Serialize, Deserialize)]
+pub struct PublishReq {
+    name: String,
+    #[serde(rename = "type")]
+    _type: DataType,
+    options: Option<PublishRequestOptions>
+}
+
+#[derive(Serialize, Deserialize)]
+pub struct PublishRequestOptions {
+    persistent: bool,
+}
+
+#[derive(Serialize, Deserialize)]
+pub struct PublishAck {
+    name: String,
+    #[serde(rename = "type")]
+    _type: String,
+    id: u32,
+}
+
+#[derive(Serialize, Deserialize)]
+pub struct PublishRel {
+    id: u32,
+    delete: bool,
+}
+
+impl_message!(PublishReq, PublishAck, PublishRel);

proto/src/text/publish.rs

@@ -0,0 +1,35 @@
+use serde::{Serialize, Deserialize};
+use super::MessageBody;
+
+#[derive(Serialize, Deserialize)]
+pub struct GetValues {
+    ids: Vec<u32>,
+    options: Option<GetValuesOptions>
+}
+
+#[derive(Serialize, Deserialize)]
+pub struct GetValuesOptions {
+    timestamped: bool
+}
+
+#[derive(Serialize, Deserialize)]
+pub struct Subscribe {
+    ids: Vec<u32>,
+    subuid: u32,
+    options: Option<SubscribeOptions>
+}
+
+#[derive(Serialize, Deserialize)]
+pub struct SubscribeOptions {
+    immediate: bool,
+    periodic: f64,
+    logging: bool,
+    timestamped: bool,
+}
+
+#[derive(Serialize, Deserialize)]
+pub struct Unsubscribe {
+    subuid: u32,
+}
+
+impl_message!(GetValues, Subscribe, Unsubscribe);

proto/src/text/subscription.rs

@@ -0,0 +1 @@
+/target

server/.gitignore

@@ -0,0 +1,9 @@
+[package]
+name = "server"
+version = "0.1.0"
+authors = ["Redrield <[email protected]>"]
+edition = "2018"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]

server/Cargo.toml

@@ -0,0 +1,3 @@
+fn main() {
+    println!("Hello, world!");
+}