[#92]: added lib.rs file in identity component to use the identity functions in the agent api. added better error handling for attach_detach_veth function

Author: LorenzoTettamanti

core/src/components/identity/src/helpers.rs

@@ -5,30 +5,24 @@ use aya::{
     Bpf,
     maps::{
         MapData,
-        perf::{PerfEventArray, PerfEventArrayBuffer},
+        perf::{PerfEventArrayBuffer},
     },
     programs::{SchedClassifier, TcAttachType},
-    util::online_cpus,
 };
 use bytes::BytesMut;
 use nix::net::if_::if_nameindex;
 use std::collections::HashMap;
 use std::sync::Mutex;
 use std::{
-    ascii,
     borrow::BorrowMut,
     net::Ipv4Addr,
-    string,
     sync::{
         Arc,
         atomic::{AtomicBool, Ordering},
     },
 };
-use tracing::{error, event, info, warn};
+use tracing::{error, info, warn};
 
-use anyhow::Context;
-use std::path::Path;
-use tokio::{fs, signal};
 /*
  * decleare bpf path env variable
  */
@@ -142,13 +136,22 @@ pub async fn display_veth_events<T: BorrowMut<MapData>>(
                                         state,
                                         dev_addr
                                     );
-                                    attach_detach_veth(
+                                    match attach_detach_veth(
                                         bpf.clone(),
                                         vethlog.event_type,
                                         veth_name,
                                         link_ids.clone(),
                                     )
-                                    .await;
+                                    .await
+                                    {
+                                        std::result::Result::Ok(_) => {
+                                            info!("Attach/Detach veth function attached correctly")
+                                        }
+                                        Err(e) => error!(
+                                            "Error attaching Attach/Detach function. Error : {}",
+                                            e
+                                        ),
+                                    }
                                 }
                                 Err(_) => info!("Unknown name or corrupted field"),
                             }

core/src/components/identity/src/lib.rs

@@ -0,0 +1,4 @@
+pub mod helpers;
+pub mod structs;
+pub mod enums;
+pub mod map_handlers;

core/src/components/identity/src/map_handlers.rs

@@ -1,12 +1,12 @@
-use std::path::PathBuf;
-use std::sync::Mutex;
-use std::sync::Arc;
 use anyhow::Error;
-use aya::maps::Map;
+use anyhow::Ok;
 use aya::Bpf;
-use tracing::{error};
+use aya::maps::Map;
+use std::path::PathBuf;
+use std::sync::Arc;
+use std::sync::Mutex;
 use tokio::fs;
-
+use tracing::error;
 
 pub fn init_bpf_maps(bpf: Arc<Mutex<Bpf>>) -> Result<(Map, Map), anyhow::Error> {
     // this function init the bpfs maps used in the main program
@@ -45,8 +45,7 @@ pub fn init_bpf_maps(bpf: Arc<Mutex<Bpf>>) -> Result<(Map, Map), anyhow::Error>
 //TODO: chmod 700 <path> to setup the permissions to pin maps TODO:add this permission in the CLI
 //TODO: add bpf mounts during cli installation
 pub async fn map_pinner(maps: &(Map, Map), path: &PathBuf) -> Result<(), Error> {
-    
-    //FIXME: add exception for already pinned maps 
+    //FIXME: add exception for already pinned maps
     if !path.exists() {
         error!("Pin path {:?} does not exist. Creating it...", path);
         let _ = fs::create_dir_all(path)