//! Server implementation of openapi_client.

#![allow(unused_imports)]

use futures::{self, Future};
use chrono;
use std::collections::HashMap;
use std::marker::PhantomData;
use swagger;
use swagger::{Has, XSpanIdString};

use openapi_client::{Api, ApiError,
                      DataSourcesDataSourceIdEntitiesEntityIdChangesPostResponse,
                      DataSourcesDataSourceIdSynchronizationStateGetResponse,
                      DataSourcesGetResponse,
                      DataSourcesPostResponse
};
use openapi_client::models;

#[derive(Copy, Clone)]
pub struct Server<C> {
    marker: PhantomData<C>,
}

impl<C> Server<C> {
    pub fn new() -> Self {
        Server{marker: PhantomData}
    }
}

impl<C> Api<C> for Server<C> where C: Has<XSpanIdString>{

    /// Sync changes from data source
    fn data_sources_data_source_id_entities_entity_id_changes_post(&self, data_source_id: String, entity_id: String, data_source: Option<&Vec<models::DataSource>>, context: &C) -> Box<Future<Item=DataSourcesDataSourceIdEntitiesEntityIdChangesPostResponse, Error=ApiError>> {
        let context = context.clone();
        println!("data_sources_data_source_id_entities_entity_id_changes_post(\"{}\", \"{}\", {:?}) - X-Span-ID: {:?}", data_source_id, entity_id, data_source, context.get().0.clone());
        Box::new(futures::failed("Generic failure".into()))
    }

    /// Lists synchronization status for your data sources
    fn data_sources_data_source_id_synchronization_state_get(&self, data_source_id: String, context: &C) -> Box<Future<Item=DataSourcesDataSourceIdSynchronizationStateGetResponse, Error=ApiError>> {
        let context = context.clone();
        println!("data_sources_data_source_id_synchronization_state_get(\"{}\") - X-Span-ID: {:?}", data_source_id, context.get().0.clone());
        Box::new(futures::failed("Generic failure".into()))
    }

    /// List registered datasources
    fn data_sources_get(&self, context: &C) -> Box<Future<Item=DataSourcesGetResponse, Error=ApiError>> {
        let context = context.clone();
        println!("data_sources_get() - X-Span-ID: {:?}", context.get().0.clone());
        Box::new(futures::failed("Generic failure".into()))
    }

    /// Register a data source
    fn data_sources_post(&self, data_source: Option<models::DataSource>, context: &C) -> Box<Future<Item=DataSourcesPostResponse, Error=ApiError>> {
        let context = context.clone();
        println!("data_sources_post({:?}) - X-Span-ID: {:?}", data_source, context.get().0.clone());
        Box::new(futures::failed("Generic failure".into()))
    }

}