(rust) prost: added simple protobuf sample for testing

rust/Cargo.toml

@@ -12,4 +12,6 @@ dirs = "5.0.1"
 sqlx = { version = "0.8", features = [ "runtime-tokio", "sqlite", "chrono" ] }
 thiserror = "2.0.12"
 tokio = { version = "1.42.0", features = ["full", "rt"] }
+prost = "0.13"
+proto = { path = "proto" }
 

rust/proto/Cargo.toml

@@ -0,0 +1,11 @@
+[package]
+name = "proto"
+build = "build.rs"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+prost = "0.13"
+
+[build-dependencies]
+prost-build = "0.13"

rust/proto/build.rs

@@ -0,0 +1,6 @@
+use std::io::Result;
+
+fn main() -> Result<()> {
+    prost_build::compile_protos(&["src/protest.proto"], &["src/"])?;
+    Ok(())
+}

rust/proto/src/lib.rs

@@ -0,0 +1,5 @@
+// pub mod protest;
+
+pub mod protest {
+    include!(concat!(env!("OUT_DIR"), "/protest.rs"));
+}

rust/proto/src/protest.proto

@@ -0,0 +1,19 @@
+syntax = "proto3";
+
+package protest;
+
+message Payload {
+  /*
+   * The package index of the given message, so which part of the message is
+   * currently being loaded.
+   */
+  uint64 index = 1;
+  /*
+   * The total block count.
+   */
+  uint64 blocks = 2;
+  /*
+   * The resulting payload to be loaded
+   */
+  bytes payload = 3;
+}

rust/src/main.rs

@@ -4,22 +4,6 @@ use chrono::{
     DateTime,
     Local,
 };
-use clap::{
-    Args,
-    Parser,
-    Subcommand
-};
-use sqlx::{
-    migrate::MigrateDatabase,
-    query,
-    query_as, 
-    Row,
-    sqlite::{
-        SqlitePool,
-        SqlitePoolOptions,
-    },
-    Sqlite,
-};
 use tokio::{
     fs,
     io::{
@@ -35,6 +19,7 @@ use tokio::{
         sleep,
     },
 };
+use proto::protest::Payload;
 
 #[tokio::main]
 async fn main() -> anyhow::Result<()> {