add controller v1.0 and change test

src/example/ctrl10.rs

+#![allow(unused)]
+#![allow(unused_variables)]
+use std::{collections::HashMap, net::TcpStream};
+
+use crate::{
+    etherparser::ether_type::EtherType,
+    openflow::ofp10::{
+        self,
+        events::{flow_mod::MatchFields, Action},
+        ofp_manager::Openflow10,
+        ControllerFrame10, FlowModEvent, OfpMsgEvent, PacketInEvent,
+    },
+};
+/**
+ * Here is Controller you can modify and write the process or more you need.
+ * In production please remove allow unused.
+ */
+
+pub struct Controller10 {
+    mac_to_port: HashMap<u64, u16>,
+}
+
+impl ControllerFrame10 for Controller10 {
+    fn new() -> Self {
+        Self {
+            mac_to_port: HashMap::new(),
+        }
+    }
+    /**
+     * Start here for handle packetIn message.
+     */
+    fn packet_in_handler(&mut self, xid: u32, packetin: PacketInEvent, stream: &mut TcpStream) {
+        let pkt = match packetin.ether_parse() {
+            Ok(pkt) => pkt,
+            Err(_) => return,
+        };
+        println!(
+            "packet in {} {} {}",
+            pkt.mac_src_string(),
+            pkt.mac_dst_string(),
+            packetin.in_port
+        );
+
+        self.mac_to_port.insert(pkt.mac_src, packetin.in_port);
+
+        let mac_dst = pkt.mac_dst;
+        let mac_src = pkt.mac_src;
+
+        if let EtherType::LLDP = pkt.ether_type {
+            return;
+        }
+
+        let out_port = match self.mac_to_port.get(&mac_dst) {
+            Some(p) => ofp10::PseudoPort::PhysicalPort(*p),
+            None => ofp10::PseudoPort::Flood,
+        };
+
+        let actions = vec![Action::Oputput(out_port.clone())];
+
+        if let ofp10::PseudoPort::PhysicalPort(_) = out_port {
+            let mut match_fields = MatchFields::match_all();
+            match_fields.in_port = Some(packetin.in_port);
+            match_fields.mac_dest = Some(mac_dst);
+            match_fields.mac_src = Some(mac_src);
+            if let Some(buf_id) = packetin.buf_id {
+                self.add_flow(xid, 1, match_fields, &actions, Some(buf_id as u32), stream);
+                return;
+            } else {
+                self.add_flow(xid, 1, match_fields, &actions, None, stream);
+            }
+        }
+        let packet_out = self
+            .ofp()
+            .packet_out(Some(packetin.in_port), packetin.payload, actions);
+        self.send_msg(packet_out, xid, stream);
+    }
+}
+
+impl Controller10 {
+    fn add_flow(
+        &self,
+        xid: u32,
+        priority: u16,
+        flow: MatchFields,
+        actions: &Vec<Action>,
+        buffer_id: Option<u32>,
+        stream: &mut TcpStream,
+    ) {
+        self.send_msg(
+            FlowModEvent::add_flow(10, flow, actions.clone(), buffer_id),
+            xid,
+            stream,
+        )
+    }
+}
\ No newline at end of file

src/example/mod.rs

-pub mod controller13;
-pub use controller13::Controller13;
\ No newline at end of file
+pub mod ctrl13;
+pub use ctrl13::Controller13;
+
+pub mod ctrl10;
+pub use ctrl10::Controller10;
\ No newline at end of file

tests/headers.rs

 #[cfg(test)]
 mod tests {
-    use tenjin::{
-        openflow::ofp13::{ControllerFrame13, Msg, OfpMsgEvent, OpenflowHeader},
-        Controller,
-    };
+    use tenjin::example::Controller10;
+    use tenjin::openflow::ofp10::ControllerFrame10;
+    use tenjin::openflow::ofp10::{Msg, OfpMsgEvent, OpenflowHeader};
 
     #[test]
     fn test_header_v1_0_parser() {
         let ofp_header_bytes: Vec<u8> = vec![1, 0, 0, 8, 0, 0, 0, 1];
 
-        let controller = Controller::new();
+        let controller = Controller10::new();
         let ofp = controller.ofp();
         let header = match ofp.header_parse(&ofp_header_bytes) {
             Ok(v) => v,
@@ -25,7 +24,7 @@ mod tests {
     fn test_header_v1_0_marshal() {
         let ofp_header_bytes: Vec<u8> = vec![1, 0, 0, 8, 0, 0, 0, 0];
 
-        let controller = Controller::new();
+        let controller = Controller10::new();
         let ofp = controller.ofp();
         let ofp_header = ofp.header(ofp.msg_usize(Msg::Hello) as u8, 0, 0);
         let mut bytes: Vec<u8> = Vec::new();