Event API

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "yagna"
-version = "0.5.0"
+version = "0.6.0"
 description = "Open platform and marketplace for distributed computations"
 readme = "README.md"
 authors = ["Golem Factory <[email protected]>"]
@@ -51,6 +51,7 @@ actix-rt = "1.0"
 actix-service = "1.0"
 actix-web = "3.2"
 anyhow = "1.0"
+chrono = "0.4"
 directories = "2.0.2"
 dotenv = "0.15.0"
 futures = "0.3"
@@ -171,8 +172,11 @@ ya-sb-router = { path = "service-bus/router" }
 ya-sb-util = { path = "service-bus/util" }
 
 ## CLIENT
-ya-client = { git = "https://github.com/golemfactory/ya-client.git", rev = "e68bbd90c903c6f74f77fddb80a432d20e4e2b2a"}
-ya-client-model = { git = "https://github.com/golemfactory/ya-client.git", rev = "e68bbd90c903c6f74f77fddb80a432d20e4e2b2a"}
+ya-client = { git = "https://github.com/golemfactory/ya-client.git", rev = "87f106498a7a7b1519d82d0981fc21b260a89cf2"}
+ya-client-model = { git = "https://github.com/golemfactory/ya-client.git", rev = "87f106498a7a7b1519d82d0981fc21b260a89cf2"}
+
+#ya-client = { path = "../ya-client" }
+#ya-client-model = { path = "../ya-client/model" }
 
 ## OTHERS
 gftp = { path = "core/gftp" }

agent/provider/examples/mock_requestor.rs

@@ -28,7 +28,7 @@ async fn wait_for_approval(client: &MarketRequestorApi, proposal_id: &str) {
         let _ = match client.wait_for_approval(proposal_id, None).await {
             Err(Error::TimeoutError { .. }) => {
                 println!("Timeout waiting for Agreement approval...");
-                Ok("".into())
+                Ok(())
             }
             Ok(_) => {
                 println!("OK! Agreement {} approved by Provider.", proposal_id);