1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68

extern crate clap;
extern crate iron;
extern crate router;

mod handler;

// use iron::prelude::*;
// use iron::status;
// use router::Router;

// use std::sync::mpsc::channel;
// use std::sync::mpsc;
//
// use self::handler::bucket::doc;
use super::client::Client;
// use super::couchbase::types::response;

// Bucket REST Interface
//
// GET  /bucket/<BUCKET_NAME>/doc - list
// POST /bucket/<BUCKET_NAME>/flush - flush
//
// DELETE  /bucket/<BUCKET_NAME>/doc/<ID>            - delete *
// GET     /bucket/<BUCKET_NAME>/doc/<ID>            - get *
// POST    /bucket/<BUCKET_NAME>/doc/<ID>            - upsert *
// POST    /bucket/<BUCKET_NAME>/doc/<ID>/add        - add *
// POST    /bucket/<BUCKET_NAME>/doc/<ID>/append     - append *
// POST    /bucket/<BUCKET_NAME>/doc/<ID>/prepend    - prepend *
// POST    /bucket/<BUCKET_NAME>/doc/<ID>/replace    - replace *
// POST    /bucket/<BUCKET_NAME>/doc/<ID>/set        - set *
// POST    /bucket/<BUCKET_NAME>/doc/<ID>/upsert     - upsert (explitcit) *

#[allow(unused_mut)]
#[allow(unused_must_use)]
#[allow(unused_variables)]
pub fn start_web(args: &clap::ArgMatches, client: &mut Client) {
//    let port: u16 = args.value_of("rest-port").unwrap().to_string().parse::<u16>().unwrap();
//    println!("Starting REST Interface on port {}.", port);
//
//    let mut router = Router::new();
//
//    type Msg = Option<response::Store>;
//
//    let get_handler = move |req: &mut Request| -> IronResult<Response> {
//        // let (tx, rx) = mpsc::channel::<Msg>();
//        let (tx, rx) = mpsc::channel::<i32>();
//        client.upsert("abc", "def", |result| {
//            // tx.send(Some(result.unwrap()))
//            tx.send(42);
//        });
//        let my_result = rx.recv().unwrap();
//        Ok(Response::with((status::Ok, "ok\n")))
//    };
//
//    router.get("/bucket/:bucketid/doc/:docid", get_handler, "doc_get");
//    router.get("/bucket/:bucketid/doc/:docid", doc::get::get_handler, "doc_get");
//    router.delete("/bucket/:bucketid/doc/:docid", doc::delete::delete_handler, "doc_delete");
//    router.post("/bucket/:bucketid/doc/:docid", doc::upsert::upsert_handler, "doc_insert");
//    router.post("/bucket/:bucketid/doc/:docid/add", doc::add::add_handler, "doc_add");
//    router.post("/bucket/:bucketid/doc/:docid/append", doc::append::append_handler, "doc_append");
//    router.post("/bucket/:bucketid/doc/:docid/prepend", doc::prepend::prepend_handler, "doc_prepend");
//    router.post("/bucket/:bucketid/doc/:docid/replace", doc::replace::replace_handler, "doc_replace");
//    router.post("/bucket/:bucketid/doc/:docid/set", doc::set::set_handler, "doc_set");
//    router.post("/bucket/:bucketid/doc/:docid/upsert", doc::upsert::upsert_handler, "doc_upsert");
//
//    let address = format!("localhost:{}", port);
//    Iron::new(router).http(&address[..]).unwrap();
}