added IP address to ping worker message (#36)

* added IP address to ping worker message

* clippy

* clippy

Author: CodeWarriorr

rabbitmq/src/messages.rs

@@ -62,6 +62,7 @@ pub struct PingResult {
     pub min: f64,
     pub max: f64,
     pub avg: f64,
+    pub ip_address: String,
 }
 
 #[derive(Serialize, Deserialize, Debug, Clone)]

scheduler/src/repository/job_repository.rs

@@ -59,6 +59,7 @@ pub struct SubJobWithData {
     pub worker_data: Vec<WorkerData>,
 }
 
+#[allow(dead_code)]
 #[derive(Serialize, Deserialize, FromRow, Debug, Type, ToSchema, Clone)]
 pub struct WorkerData {
     pub id: Uuid,
@@ -69,6 +70,7 @@ pub struct WorkerData {
     pub head: serde_json::Value,
 }
 
+#[allow(dead_code)]
 #[derive(Serialize, Deserialize, FromRow, Debug, Type)]
 pub struct WorkerDataDownload {
     end_time: DateTime<Utc>,
@@ -81,6 +83,7 @@ pub struct WorkerDataDownload {
     second_by_second_logs: Option<serde_json::Value>,
 }
 
+#[allow(dead_code)]
 #[derive(Serialize, Deserialize, FromRow, Debug, Type)]
 pub struct WorkerDataError {
     error: String,

scheduler/src/repository/sub_job_repository.rs

@@ -58,6 +58,7 @@ pub struct SubJobWithJob {
     pub job: Json<Job>,
 }
 
+#[allow(dead_code)]
 #[derive(Debug, Serialize, Deserialize, Type)]
 pub struct WorkerData {
     id: Uuid,

worker/src/handlers/ping.rs

@@ -97,5 +97,6 @@ pub async fn process(job_id: Uuid, payload: JobMessage) -> Result<PingResult, Pi
         avg: avg_latency,
         min: min_latency,
         max: max_latency,
+        ip_address: ip_address.to_string(),
     })
 }