From b9a42cc6d5aa22083d57d12bdd9d5523b45b7af3 Mon Sep 17 00:00:00 2001 From: Grisha Kruglov Date: Wed, 28 Feb 2018 18:37:40 -0500 Subject: [PATCH] Disable TLS support, add links to issues for TODOs --- tolstoy/Cargo.toml | 1 - tolstoy/src/lib.rs | 3 ++- tolstoy/src/syncer.rs | 27 +++++++++++++++++---------- 3 files changed, 19 insertions(+), 12 deletions(-) diff --git a/tolstoy/Cargo.toml b/tolstoy/Cargo.toml index 52c4eb22..119078e3 100644 --- a/tolstoy/Cargo.toml +++ b/tolstoy/Cargo.toml @@ -7,7 +7,6 @@ authors = ["Grisha Kruglov "] [dependencies] futures = "0.1" hyper = "0.11" -hyper-tls = "0.1.2" tokio-core = "0.1" serde = "1.0" serde_json = "1.0" diff --git a/tolstoy/src/lib.rs b/tolstoy/src/lib.rs index ce20aeed..51306f2b 100644 --- a/tolstoy/src/lib.rs +++ b/tolstoy/src/lib.rs @@ -21,7 +21,8 @@ extern crate lazy_static; extern crate serde_derive; extern crate hyper; -extern crate hyper_tls; +// TODO https://github.com/mozilla/mentat/issues/569 +// extern crate hyper_tls; extern crate tokio_core; extern crate futures; extern crate serde; diff --git a/tolstoy/src/syncer.rs b/tolstoy/src/syncer.rs index e423cf32..c4a77515 100644 --- a/tolstoy/src/syncer.rs +++ b/tolstoy/src/syncer.rs @@ -13,11 +13,13 @@ use std::collections::HashMap; use futures::{future, Future, Stream}; use hyper; -use hyper_tls; +// TODO: enable TLS support; hurdle is cross-compiling openssl for Android. +// See https://github.com/mozilla/mentat/issues/569 +// use hyper_tls; use hyper::{Method, Request, StatusCode, Error as HyperError}; use hyper::header::{ContentType}; use rusqlite; -// TODO: +// TODO: https://github.com/mozilla/mentat/issues/570 // use serde_cbor; use serde_json; use tokio_core::reactor::Core; @@ -44,6 +46,7 @@ use tx_mapper::TxMapper; // TODO it would be nice to be able to pass // in a logger into Syncer::flow; would allow for a "debug mode" // and getting useful logs out of clients. +// See https://github.com/mozilla/mentat/issues/571 // Below is some debug Android-friendly logging: // use std::os::raw::c_char; @@ -66,6 +69,7 @@ pub struct Syncer {} // TODO this is sub-optimal, we don't need to walk the table // to query the last thing in it w/ an index on tx!! // but it's the hammer at hand! +// See https://github.com/mozilla/mentat/issues/572 struct InquiringTxReceiver { pub last_tx: Option, pub is_done: bool, @@ -135,6 +139,7 @@ impl<'c> TxReceiver for UploadingTxReceiver<'c> { tx_chunks.push(datom_uuid); d(&format!("putting chunk: {:?}, {:?}", &datom_uuid, &datom)); // TODO switch over to CBOR once we're past debugging stuff. + // See https://github.com/mozilla/mentat/issues/570 // let cbor_val = serde_cbor::to_value(&datom)?; // self.remote_client.put_chunk(&datom_uuid, &serde_cbor::ser::to_vec_sd(&cbor_val)?)?; self.remote_client.put_chunk(&datom_uuid, &serde_json::to_string(&datom)?)?; @@ -305,10 +310,11 @@ impl RemoteClient { fn get_uuid(&self, uri: String) -> Result { let mut core = Core::new()?; - let client = hyper::Client::configure() - .connector(hyper_tls::HttpsConnector::new(4, &core.handle()).unwrap()) - .build(&core.handle()); - // let client = hyper::Client::new(&core.handle()); + // TODO enable TLS, see https://github.com/mozilla/mentat/issues/569 + // let client = hyper::Client::configure() + // .connector(hyper_tls::HttpsConnector::new(4, &core.handle()).unwrap()) + // .build(&core.handle()); + let client = hyper::Client::new(&core.handle()); d(&format!("client")); @@ -337,10 +343,11 @@ impl RemoteClient { fn put(&self, uri: String, payload: T, expected: StatusCode) -> Result<()> where hyper::Body: std::convert::From, { let mut core = Core::new()?; - let client = hyper::Client::configure() - .connector(hyper_tls::HttpsConnector::new(4, &core.handle()).unwrap()) - .build(&core.handle()); - // let client = hyper::Client::new(&core.handle()); + // TODO enable TLS, see https://github.com/mozilla/mentat/issues/569 + // let client = hyper::Client::configure() + // .connector(hyper_tls::HttpsConnector::new(4, &core.handle()).unwrap()) + // .build(&core.handle()); + let client = hyper::Client::new(&core.handle()); let uri = uri.parse()?;