Romain/rust_mosquitto
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

pass clippy

Browse Source
This commit is contained in:
Romulus21
2024-08-24 15:36:59 +02:00
parent adaf089f77
commit 2b0fe78b38
2 changed files with 17 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
Makefile
View File

@@ -1,4 +1,7 @@
deploy: deploy:
ssh raspiwork 'cd /home/pi/Scripts/rust_mosquitto && git pull && cargo build --release' ssh raspiwork 'cd /home/pi/Scripts/rust_mosquitto && git pull && make build'
ssh raspiwork 'sudo systemctl daemon-reload'
ssh raspiwork 'sudo systemctl restart rust_mosquitto.service' build:
cargo build --release
sudo systemctl daemon-reload
sudo systemctl restart rust_mosquitto.service

16
src/reccord.rs
View File

@@ -1,7 +1,7 @@
use dotenv::dotenv;
use mysql::prelude::*; use mysql::prelude::*;
use mysql::*; use mysql::*;
use std::env; use std::env;
use dotenv::dotenv;
#[derive(Debug, PartialEq, Eq)] #[derive(Debug, PartialEq, Eq)]
struct MosquittoMessage { struct MosquittoMessage {
@@ -16,10 +16,16 @@ pub fn message(message: paho_mqtt::Message) {
let db_user = env::var("DB_USER").expect("DB_USER must be set"); let db_user = env::var("DB_USER").expect("DB_USER must be set");
let db_password = env::var("DB_PASSWORD").expect("DB_PASSWORD must be set"); let db_password = env::var("DB_PASSWORD").expect("DB_PASSWORD must be set");
let db_host = env::var("DB_HOST").expect("DB_HOST must be set"); let db_host = env::var("DB_HOST").expect("DB_HOST must be set");
let db_port: u16 = env::var("DB_PORT").expect("DB_PORT must be set").parse().unwrap(); let db_port: u16 = env::var("DB_PORT")
.expect("DB_PORT must be set")
.parse()
.unwrap();
let db_name = env::var("DB_NAME").expect("DB_NAME must be set"); let db_name = env::var("DB_NAME").expect("DB_NAME must be set");
let url_builder = format!("mysql://{}:{}@{}:{}/{}", db_user, db_password, db_host, db_port, db_name); let url_builder = format!(
"mysql://{}:{}@{}:{}/{}",
db_user, db_password, db_host, db_port, db_name
);
let url = Opts::from_url(url_builder.as_str()).unwrap(); let url = Opts::from_url(url_builder.as_str()).unwrap();
let pool = Pool::new(url).unwrap(); let pool = Pool::new(url).unwrap();
let mut conn = pool.get_conn().unwrap(); let mut conn = pool.get_conn().unwrap();
@@ -27,7 +33,7 @@ pub fn message(message: paho_mqtt::Message) {
let split: Vec<&str> = message.topic().split("/").collect(); let split: Vec<&str> = message.topic().split("/").collect();
let data = message.payload_str(); let data = message.payload_str();
let message_received = vec![MosquittoMessage { let message_received = [MosquittoMessage {
service: split[0].to_string(), service: split[0].to_string(),
capteur: split[1].to_string(), capteur: split[1].to_string(),
type_donnee: split[2].to_string(), type_donnee: split[2].to_string(),
@@ -47,5 +53,5 @@ pub fn message(message: paho_mqtt::Message) {
}), }),
); );
println!("topic : {:?} data : {}", split, data.to_string()); //println!("topic : {:?} data : {}", split, data.to_string());
} }