From 24d83f549a6fba7b23a0c048e1512d00ed704e0d Mon Sep 17 00:00:00 2001
From: "Claudius \"keldu\" Holeksa" <mail@keldu.de>
Date: Mon, 15 Apr 2024 15:24:40 +0200
Subject: codec, io_codec: Fixed some type issues with functions and moved rpc
 to io_codec due to dependency issues

---
 modules/codec/c++/interface.hpp |  43 ++++++++++-------
 modules/codec/c++/rpc.hpp       | 102 ----------------------------------------
 2 files changed, 25 insertions(+), 120 deletions(-)
 delete mode 100644 modules/codec/c++/rpc.hpp

(limited to 'modules/codec/c++')

diff --git a/modules/codec/c++/interface.hpp b/modules/codec/c++/interface.hpp
index 59401ca..19dc145 100644
--- a/modules/codec/c++/interface.hpp
+++ b/modules/codec/c++/interface.hpp
@@ -1,18 +1,21 @@
 #pragma once
 
+#include <functional>
+
 #include <forstio/error.hpp>
 #include "schema.hpp"
 #include "data.hpp"
 
 namespace saw {
-template<typename SchemaFunc, typename Encode, typename Func>
+template<typename SchemaFunc, typename Encode>
 class function;
 
-template<typename Request, typename Response, typename Encode, typename Func>
-class function<schema::Function<Request, Response>, Encode, Func> {
+template<typename Request, typename Response, typename Encode>
+class function<schema::Function<Request, Response>, Encode> {
 private:
-		Func func_;
+	std::function<data<Response, Encode>(data<Request, Encode>)> func_;
 public:
+	template<typename Func>
 		function(Func func):
 				func_{std::move(func)}
 		{}
@@ -22,15 +25,25 @@ public:
 		}
 };
 
+template<typename Iface, typename Encode>
+class i_interface {
+public:
+	virtual ~i_interface() = default;
+
+
+};
+
 template<typename T, typename Encode, typename... Funcs>
 class interface;
 
-template<typename... Requests, typename... Responses, string_literal... Names, typename Encode, typename... Funcs>
-class interface<schema::Interface<schema::Member<schema::Function<Requests, Responses>, Names>...>, Encode, Funcs...> {
+template<typename... Requests, typename... Responses, string_literal... Names, typename Encode>
+class interface<schema::Interface<schema::Member<schema::Function<Requests, Responses>, Names>...>, Encode> {
+public:
+	using Schema = schema::Interface<schema::Member<schema::Function<Requests, Responses>,Names>...>;
 private:
-		std::tuple<function<schema::Function<Requests, Responses>, Encode, Funcs>...> funcs_;
+		std::tuple<function<schema::Function<Requests, Responses>, Encode>...> funcs_;
 public:
-		interface(function<schema::Function<Requests, Responses>, Encode, Funcs>... funcs):
+		interface(function<schema::Function<Requests, Responses>, Encode>... funcs):
 				funcs_{std::move(funcs)...}
 		{}
 
@@ -54,12 +67,6 @@ public:
 				>
 		,
 				Encode
-		,
-				typename parameter_pack_type<
-						parameter_key_pack_index<
-								Lit, Names...
-						>::value
-				, Funcs...>::type
 		>& get(){
 				return std::get<parameter_key_pack_index<Lit, Names...>::value>(funcs_);
 		}
@@ -89,16 +96,16 @@ public:
 template<typename T, typename Encode>
 struct function_factory {
 		template<typename Func>
-		static function<T,Encode, Func> create(Func func){
-				return function<T,Encode,Func>{std::move(func)};
+		static function<T,Encode> create(Func func){
+				return function<T,Encode>{std::move(func)};
 		}
 };
 
 template<typename T, typename Encode>
 struct interface_factory {
 		template<typename... Func>
-		static interface<T,Encode, Func...> create(Func... func){
-				return interface<T,Encode, Func...>{std::move(func)...};
+		static interface<T,Encode> create(Func... func){
+				return interface<T,Encode>{std::move(func)...};
 		}
 };
 }
diff --git a/modules/codec/c++/rpc.hpp b/modules/codec/c++/rpc.hpp
deleted file mode 100644
index 5a24034..0000000
--- a/modules/codec/c++/rpc.hpp
+++ /dev/null
@@ -1,102 +0,0 @@
-#pragma once
-
-#include <forstio/id.hpp>
-#include <forstio/codec/data.hpp>
-#include <forstio/io/io.hpp>
-
-namespace saw {
-
-/**
- * Representing data on the remote
- */
-template<typename T, typename Remote>
-class remote_data {
-private:
-	id<T> id_;
-public:
-	remote_data(const id<T>& id):
-		id_{id}
-	{}
-
-	/**
-	 * Wait until data arrives
-	 */
-	error_or<data<T>> wait(wait_scope& wait);
-
-	/**
-	 * Asynchronously wait for a result
-	 */
-	conveyor<data<T>> on_receive();
-};
-
-/**
- * Client RPC reference structure
- */
-template<typename T, typename Iface>
-class rpc_client {
-	/**
-	 * request the data from the remote
-	 */
-	template<typename IdT>
-	remote_data<IdT> request_data(id<IdT> data);
-		
-	/**
-	 * Determine type based on Name
-	 */
-	template<string_literal Name>
-	error_or<
-		id<
-			typename schema_member_type<Name, Iface>::type
-		>
-	> call(data_or_id<Input> inp);
-};
-
-/**
- * Implementation of a remote server on the backend
- */
-template<typename T, typename Iface>
-class rpc_server {
-private:
-	interface<Iface> iface_;
-public:
-	rpc_server(interface<Iface> iface):
-		iface_{std::move(iface)}
-	{}
-};
-
-/**
- * Representation of a remote.
- * Partially similar to a network address
- */
-template<typename T>
-class remote_address {
-	static_assert(always_false<T>, "Type of remote not supported");
-
-
-};
-
-/**
- * Reference Backend structure
- */
-template<typename T>
-class remote {
-	static_assert(always_false<T>, "Type of backend not supported");
-
-	/**
-	 * Resolves an address for the remote
-	 */
-	conveyor<remote_address<T>> resolve_address();
-
-	/**
-	 * Connect to a remote
-	 */
-	template<typename Iface>
-	conveyor<rpc_client<T,Iface>> connect(const remote_address<T>& addr);
-
-	/**
-	 * Start listening
-	 */
-	template<typename Iface>
-	rpc_server<T,Iface> listen();
-};
-}
-- 
cgit v1.2.3