From 8c43611eb5bbaeb42f19da8d8ed521df208bfada Mon Sep 17 00:00:00 2001
From: Quentin Dufour <quentin@deuxfleurs.fr>
Date: Thu, 21 May 2020 22:25:33 +0200
Subject: Broken Diplonat

---
 src/igd_adapter.rs | 31 +++++++++++++++++++++++++------
 1 file changed, 25 insertions(+), 6 deletions(-)

(limited to 'src/igd_adapter.rs')

diff --git a/src/igd_adapter.rs b/src/igd_adapter.rs
index 3803d5f..6624ab3 100644
--- a/src/igd_adapter.rs
+++ b/src/igd_adapter.rs
@@ -1,11 +1,30 @@
-use crate::*;
-use anyhow::Result;
+use igd::aio::*;
+use log::*;
+use tokio::sync::broadcast;
+use anyhow::{Result, Context};
+use std::cell::Cell;
 
-pub struct IgdAdapter {}
-impl adapter::Adapter for IgdAdapter {
-  fn new(&self, parent: &diplonat::Diplonat) -> Result<()> {
-    return Ok(());
+use crate::diplonat::*;
+use crate::node_state::*;
+
+pub struct IgdAdapter<'a> {
+  state: &'a Cell<NodeState>,
+  gateway: Gateway,
+}
+impl<'a> IgdAdapter<'a> {
+  pub async fn new(ns: &'a Cell<NodeState>, send: &broadcast::Sender<()>) -> Result<IgdAdapter<'a>> {
+    let gw = search_gateway(Default::default())
+              .await
+              .context("Failed to find gateway")?;
+    info!("Gateway: {}", gw);
+
+    let ctx = Self { 
+      state: ns,
+      gateway: gw 
+    };
+    return Ok(ctx);
   }
+
   fn run(&self) -> Result<()> {
     return Ok(());
   }
-- 
cgit v1.2.3