// Copyright 2018 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#![feature(async_await, await_macro, futures_api)]
#![deny(warnings)]

#[macro_use]
extern crate failure;

use failure::Error;
use fuchsia_async as fasync;
use futures::channel::mpsc;
use parking_lot::RwLock;
use std::sync::Arc;
use std::thread;

mod audio;
mod auth;
mod bluetooth;
mod netstack;
mod scenic;
mod server;
mod wlan;

use fuchsia_syslog::macros::*;

use crate::server::sl4f::{serve, Sl4f};
use crate::server::sl4f_executor::run_fidl_loop;

// Config, flexible for any ip/port combination
const SERVER_IP: &str = "0.0.0.0";
const SERVER_PORT: &str = "80";

// HTTP Server using Rouille
fn main() -> Result<(), Error> {
    fuchsia_syslog::init_with_tags(&["sl4f"]).expect("Can't init logger");
    fx_log_info!("Starting sl4f server");
    let mut executor = fasync::Executor::new().expect("Failed to create an executor!");

    let address = format!("{}:{}", SERVER_IP, SERVER_PORT);
    fx_log_info!("Now listening on: {:?}", address);

    // Session storing all information about state
    // Currently supported: Bluetooth, wlan
    // Add other stacks to sl4f.rs
    let sl4f_session: Arc<RwLock<Sl4f>> = Sl4f::new()?;

    // Create channel for communication: rouille sync side -> async exec side
    let (rouille_sender, async_receiver) = mpsc::unbounded();
    let sl4f_session_async = sl4f_session.clone();

    // Create thread for listening to test commands
    thread::spawn(move || {
        // Start listening on address
        rouille::start_server(address, move |request| {
            serve(&request, sl4f_session.clone(), rouille_sender.clone())
        });
    });

    executor.run_singlethreaded(run_fidl_loop(sl4f_session_async, async_receiver));

    Ok(())
}