Merge pull request #285 from AdExNetwork/multi-core-and-update-deps

update deps & multi core (tokio)

Author: samparsky

adapter/Cargo.toml

@@ -32,4 +32,4 @@ futures = { version = "0.3.1", features = ["compat"] }
 
 [dev-dependencies]
 byteorder = "1.3"
-tokio = { version = "0.2", features = ["macros", "rt-core"] }
+tokio = { version = "0.2", features = ["macros", "rt-threaded"] }

sentry/Cargo.toml

@@ -16,13 +16,13 @@ hex = "0.3.2"
 # CLI
 clap = "2.33.0"
 # Server
-tokio = { version = "0.2.9", features = ["macros", "rt-core"] }
+tokio = { version = "0.2.9", features = ["macros", "rt-threaded"] }
 hyper = { version = "0.13", features = ["stream"] }
 regex = "1"
 # Database
-redis = { version = "0.14", features = ["tokio-rt-core"] }
-bb8 = { git = "https://github.com/khuey/bb8" }
-bb8-postgres = { git = "https://github.com/khuey/bb8", features = ["with-chrono-0_4", "with-serde_json-1"] }
+redis = "0.15"
+bb8 = "0.4"
+bb8-postgres = { version = "0.4", features = ["with-chrono-0_4", "with-serde_json-1"] }
 
 # Migrations
 migrant_lib = { version = "0.27", features = ["d-postgres"] }

sentry/src/db.rs

@@ -36,7 +36,9 @@ lazy_static! {
 
 pub async fn redis_connection() -> Result<MultiplexedConnection, RedisError> {
     let client = redis::Client::open(REDIS_URL.as_str()).expect("Wrong redis connection url");
-    client.get_multiplexed_tokio_connection().await
+    let (connection, driver) = client.get_multiplexed_async_connection().await?;
+    tokio::spawn(driver);
+    Ok(connection)
 }
 
 pub async fn postgres_connection() -> Result<DbPool, bb8_postgres::tokio_postgres::Error> {