wip

1 files changed, 46 insertions, 3 deletions

diff --git a/modules/remote/c++/transfer_loopback.hpp b/modules/remote/c++/transfer_loopback.hpp
index 9e3c7f6..3eb6922 100644
--- a/modules/remote/c++/transfer_loopback.hpp
+++ b/modules/remote/c++/transfer_loopback.hpp
@@ -54,6 +54,49 @@ public:
 		}
 		return void_t{};
 	}
+
+	error_or<void> allocate(data<typename meta_schema<Schema>::MetaSchema, Encoding> meta, id<Schema> store_id){
+		try{
+			auto insert_res = values_.emplace(std::make_pair(store_id.get_value(), data<typename meta_schema<Schema>::MetaSchema, Encoding>{std::move(meta)}));
+			if(!insert_res.second){
+				return make_error<err::already_exists>();
+			}
+		}catch(const std::exception&){
+			return make_error<err::out_of_memory>();
+		}
+
+		return make_void();
+	}
+
+	error_or<data<Schema, Encoding>> receive(id<Schema> store_id){
+		auto find_res = values_.find(store_id.get_value());
+		if(find_res == values_.end()){
+			return make_error<err::not_found>();
+		}
+
+		auto& dat = find_res->second;
+		// here
+		return dat;// boy
+	}
+
+	error_or<void> erase(id<Schema> store_id){
+		auto erase_res = values_.erase(store_id.get_value());
+		if(erase_res == 0u){
+			return make_error<err::not_found>();
+		}
+
+		return make_void();
+	}
+
+	error_or<ptr<data<Schema, Encoding>>> find(id<Schema> store_id){
+		auto find_res = values_.find(store_id.get_value());
+		if(find_res == values_.end()){
+			return make_error<err::not_found>();
+		}
+
+		auto& dat = find_res->second;
+		return ptr<data<Schema,Encoding>>{dat};
+	}
 };
 
 template<typename... Schema, typename Encoding>
@@ -142,7 +185,7 @@ public:
 		if(erase_op == 0u){
 			return make_error<err::not_found>();
 		}
-		return void_t{};
+		return make_void();
 	}
 
 	template<typename Sch>
@@ -224,7 +267,7 @@ public:
 	 * An exception for the Loopback backend. Here we can safely use find from
 	 * the client side.
 	 */
-	error_or<ref<data<Schema, Encoding>>> find(id<Schema> dat_id){
+	error_or<ptr<data<Schema, Encoding>>> find(id<Schema> dat_id){
 		auto eov = srv_().find(dat_id);
 		if(eov.is_error()){
 			auto& err = eov.get_error();
@@ -232,7 +275,7 @@ public:
 		}
 
 		auto val = eov.get_value();
-		return {*val};
+		return val;
 	}
 };