fixed server message handle
This commit is contained in:
@@ -5,7 +5,7 @@
|
|||||||
use crate::models::ServerMessage;
|
use crate::models::ServerMessage;
|
||||||
|
|
||||||
use super::container::{restart_container, update_docker_image};
|
use super::container::{restart_container, update_docker_image};
|
||||||
use bollard::query_parameters::{CreateImageOptions, RestartContainerOptions};
|
//use bollard::query_parameters::{CreateImageOptions, RestartContainerOptions};
|
||||||
use bollard::Docker;
|
use bollard::Docker;
|
||||||
use std::error::Error;
|
use std::error::Error;
|
||||||
|
|
||||||
@@ -40,7 +40,7 @@ pub async fn handle_server_message(
|
|||||||
if let Some(image_name) = msg.data.get("image").and_then(|v| v.as_str()) {
|
if let Some(image_name) = msg.data.get("image").and_then(|v| v.as_str()) {
|
||||||
println!("Received restart command for image: {}", image_name);
|
println!("Received restart command for image: {}", image_name);
|
||||||
// Call your update_docker_image function here
|
// Call your update_docker_image function here
|
||||||
update_docker_image(docker, image_name).await?;
|
restart_container(docker, image_name).await?;
|
||||||
Ok(())
|
Ok(())
|
||||||
} else {
|
} else {
|
||||||
Err("Missing image name in update message".into())
|
Err("Missing image name in update message".into())
|
||||||
|
Reference in New Issue
Block a user