changing approach to storage

7 files changed, 268 insertions, 810 deletions

diff --git a/forstio/codec-json/.nix/derivation.nix b/forstio/codec-json/.nix/derivation.nix
new file mode 100644
index 0000000..fcc276d
--- /dev/null
+++ b/forstio/codec-json/.nix/derivation.nix
@@ -0,0 +1,34 @@
+{ lib
+, stdenvNoCC
+, scons
+, clang
+, clang-tools
+, version
+, forstio
+, gnutls
+}:
+
+let
+
+in stdenvNoCC.mkDerivation {
+  pname = "forstio-codec-json";
+  inherit version;
+
+  src = ./..;
+
+  enableParallelBuilding = true;
+
+  nativeBuildInputs = [
+    scons
+    clang
+    clang-tools
+  ];
+
+  buildInputs = [
+    forstio.core
+    forstio.async
+    forstio.codec
+  ];
+
+  outputs = ["out" "dev"];
+}
diff --git a/forstio/codec-json/SConscript b/forstio/codec-json/SConscript
new file mode 100644
index 0000000..772ac0b
--- /dev/null
+++ b/forstio/codec-json/SConscript
@@ -0,0 +1,38 @@
+#!/bin/false
+
+import os
+import os.path
+import glob
+
+
+Import('env')
+
+dir_path = Dir('.').abspath
+
+# Environment for base library
+codec_json_env = env.Clone();
+
+codec_json_env.sources = sorted(glob.glob(dir_path + "/*.cpp"))
+codec_json_env.headers = sorted(glob.glob(dir_path + "/*.h"))
+
+env.sources += codec_json_env.sources;
+env.headers += codec_json_env.headers;
+
+## Shared lib
+objects_shared = []
+codec_json_env.add_source_files(objects_shared, codec_json_env.sources, shared=True);
+codec_json_env.library_shared = codec_json_env.SharedLibrary('#build/forstio-codec-json', [objects_shared]);
+
+## Static lib
+objects_static = []
+codec_json_env.add_source_files(objects_static, codec_json_env.sources, shared=False);
+codec_json_env.library_static = codec_json_env.StaticLibrary('#build/forstio-codec-json', [objects_static]);
+
+# Set Alias
+env.Alias('library_codec_json', [codec_json_env.library_shared, codec_json_env.library_static]);
+
+env.targets += ['library_codec_json'];
+
+# Install
+env.Install('$prefix/lib/', [codec_json_env.library_shared, codec_json_env.library_static]);
+env.Install('$prefix/include/forstio/codec/json/', [codec_json_env.headers]);
diff --git a/forstio/codec-json/SConstruct b/forstio/codec-json/SConstruct
new file mode 100644
index 0000000..edd5f57
--- /dev/null
+++ b/forstio/codec-json/SConstruct
@@ -0,0 +1,66 @@
+#!/usr/bin/env python3
+
+import sys
+import os
+import os.path
+import glob
+import re
+
+
+if sys.version_info < (3,):
+    def isbasestring(s):
+        return isinstance(s,basestring)
+else:
+    def isbasestring(s):
+        return isinstance(s, (str,bytes))
+
+def add_kel_source_files(self, sources, filetype, lib_env=None, shared=False, target_post=""):
+
+    if isbasestring(filetype):
+        dir_path = self.Dir('.').abspath
+        filetype = sorted(glob.glob(dir_path+"/"+filetype))
+
+    for path in filetype:
+        target_name = re.sub( r'(.*?)(\.cpp|\.c\+\+)', r'\1' + target_post, path )
+        if shared:
+            target_name+='.os'
+            sources.append( self.SharedObject( target=target_name, source=path ) )
+        else:
+            target_name+='.o'
+            sources.append( self.StaticObject( target=target_name, source=path ) )
+    pass
+
+def isAbsolutePath(key, dirname, env):
+	assert os.path.isabs(dirname), "%r must have absolute path syntax" % (key,)
+
+env_vars = Variables(
+	args=ARGUMENTS
+)
+
+env_vars.Add('prefix',
+	help='Installation target location of build results and headers',
+	default='/usr/local/',
+	validator=isAbsolutePath
+)
+
+env=Environment(ENV=os.environ, variables=env_vars, CPPPATH=[],
+    CPPDEFINES=['SAW_UNIX'],
+    CXXFLAGS=['-std=c++20','-g','-Wall','-Wextra'],
+    LIBS=['forstio-codec'])
+env.__class__.add_source_files = add_kel_source_files
+env.Tool('compilation_db');
+env.cdb = env.CompilationDatabase('compile_commands.json');
+
+env.objects = [];
+env.sources = [];
+env.headers = [];
+env.targets = [];
+
+Export('env')
+SConscript('SConscript')
+
+env.Alias('cdb', env.cdb);
+env.Alias('all', [env.targets]);
+env.Default('all');
+
+env.Alias('install', '$prefix')
diff --git a/forstio/codec/data.h b/forstio/codec/data.h
new file mode 100644
index 0000000..1682ae7
--- /dev/null
+++ b/forstio/codec/data.h
@@ -0,0 +1,89 @@
+#pragma once
+
+#include <forstio/core/common.h>
+#include "schema.h"
+
+namespace saw {
+namespace encode {
+struct Native {};
+}
+/*
+ * Helper for the basic message container, so the class doesn't have to be
+ * specialized 10 times.
+ */
+template <class T> struct native_data_type;
+
+template <>
+struct native_data_type<schema::Primitive<schema::SignedInteger, 1>> {
+	using type = int8_t;
+};
+
+template <>
+struct native_data_type<schema::Primitive<schema::SignedInteger, 2>> {
+	using type = int16_t;
+};
+
+template <>
+struct native_data_type<schema::Primitive<schema::SignedInteger, 4>> {
+	using type = int32_t;
+};
+
+template <>
+struct native_data_type<schema::Primitive<schema::SignedInteger, 8>> {
+	using type = int64_t;
+};
+
+template <>
+struct native_data_type<schema::Primitive<schema::UnsignedInteger, 1>> {
+	using type = uint8_t;
+};
+
+template <>
+struct native_data_type<schema::Primitive<schema::UnsignedInteger, 2>> {
+	using type = uint16_t;
+};
+
+template <>
+struct native_data_type<schema::Primitive<schema::UnsignedInteger, 4>> {
+	using type = uint32_t;
+};
+
+template <>
+struct native_data_type<schema::Primitive<schema::UnsignedInteger, 8>> {
+	using type = uint64_t;
+};
+
+template <>
+struct native_data_type<schema::Primitive<schema::FloatingPoint, 4>> {
+	using type = float;
+};
+
+template<typename T, typename Encoding = encode::Native>
+class data {
+private:
+	static_assert(always_false<T>, "Type not supported");
+};
+
+template<>
+class data<schema::String, encode::Native> {
+private:
+	std::string value_;
+public:
+	SAW_FORBID_COPY(data);
+
+	data(std::string&& value__):value_{std::move(value__)}{}
+
+	std::size_t size() const {
+		return value_.size();
+	}
+
+	bool operator==(const data<schema::String, encode::Native>& data){
+		return value_ == data.value_;
+	}
+};
+
+template<typename T, size_t N>
+class data<schema::Primitive<T,N>, encode::Native> {
+private:
+};
+}
diff --git a/forstio/codec/message.h b/forstio/codec/message.h
deleted file mode 100644
index f0cadfd..0000000
--- a/forstio/codec/message.h
+++ /dev/null
@@ -1,564 +0,0 @@
-#pragma once
-
-#include <cstdint>
-#include <tuple>
-#include <type_traits>
-#include <variant>
-#include <vector>
-
-#include <cassert>
-
-#include <forstio/common.h>
-#include <forstio/string_literal.h>
-
-#include "message_container.h"
-#include "schema.h"
-
-namespace saw {
-class message_base {
-protected:
-	bool set_explicitly_ = false;
-
-public:
-	template <class T> T &as() {
-		static_assert(std::is_base_of<message_base, T>());
-		return dynamic_cast<T &>(*this);
-	}
-
-	template <class T> const T &as() const {
-		static_assert(std::is_base_of<message_base, T>());
-		return dynamic_cast<const T &>(*this);
-	}
-};
-/*
- * Representing all message types
- * Description which type to use happens through the use of the schema classes
- * in schema.h The message classes are wrapper classes which store the data
- * according to the specified container class.
- *
- * The reader and builder classe exist to create some clarity while implementing
- * parsers. Also minor guarantess are provided if the message is used as a
- * template parameter.
- */
-
-/*
- * Struct Message
- */
-template <class... V, string_literal... Keys, class Container>
-class message<schema::Struct<schema::NamedMember<V, Keys>...>, Container> final
-	: public message_base {
-private:
-	using SchemaType = schema::Struct<schema::NamedMember<V, Keys>...>;
-	using MessageType = message<SchemaType, Container>;
-	Container container_;
-
-	static_assert(std::is_same_v<SchemaType, typename Container::SchemaType>,
-				  "Container should have same the schema as Message");
-
-	friend class builder;
-	friend class reader;
-
-public:
-	class reader;
-	class builder {
-	private:
-		MessageType &message_;
-
-	public:
-		builder(MessageType &msg) : message_{msg} {}
-
-		reader as_reader() { return reader{message_}; }
-
-		/*
-		 * Initialize a member by index
-		 */
-		template <size_t i>
-		typename std::enable_if<
-			!schema_is_array<
-				typename message_parameter_pack_type<i, V...>::Type>::Value,
-			typename Container::template ElementType<i>::builder>::type
-		init() {
-			return typename Container::template ElementType<i>::builder{
-				message_.container_.template get<i>()};
-		}
-
-		/*
-		 * Initialize a member by their name
-		 * This is the preferred method for schema::Struct messages
-		 */
-		template <string_literal Literal>
-		typename std::enable_if<
-			!schema_is_array<typename message_parameter_pack_type<
-				message_parameter_key_pack_index<Literal, Keys...>::Value,
-				V...>::Type>::Value,
-			typename Container::template ElementType<
-				message_parameter_key_pack_index<Literal, Keys...>::Value>::
-				builder>::type
-		init() {
-			constexpr size_t i =
-				message_parameter_key_pack_index<Literal, Keys...>::Value;
-
-			return init<i>();
-		}
-
-		template <size_t i>
-		typename std::enable_if<
-			schema_is_array<
-				typename message_parameter_pack_type<i, V...>::Type>::Value,
-			typename Container::template ElementType<i>::builder>::type
-		init(size_t size = 0) {
-			auto array_builder =
-				typename Container::template ElementType<i>::builder{
-					message_.container_.template get<i>(), size};
-			return array_builder;
-		}
-
-		/*
-		 * Version for array schema type
-		 */
-		template <string_literal Literal>
-		typename std::enable_if<
-			schema_is_array<typename message_parameter_pack_type<
-				message_parameter_key_pack_index<Literal, Keys...>::Value,
-				V...>::Type>::Value,
-			typename Container::template ElementType<
-				message_parameter_key_pack_index<Literal, Keys...>::Value>::
-				builder>::type
-		init(size_t size) {
-			constexpr size_t i =
-				message_parameter_key_pack_index<Literal, Keys...>::Value;
-
-			return init<i>(size);
-		}
-	};
-
-	class reader {
-	private:
-		MessageType &message_;
-
-	public:
-		reader(MessageType &msg) : message_{msg} {}
-
-		builder as_builder() { return builder{message_}; }
-
-		/*
-		 * Get member by index
-		 */
-		template <size_t i>
-		typename Container::template ElementType<i>::reader get() {
-			return typename Container::template ElementType<i>::reader{
-				message_.container_.template get<i>()};
-		}
-
-		/*
-		 * Get member by name
-		 * This is the preferred method for schema::Struct messages
-		 */
-		template <string_literal Literal>
-		typename Container::template ElementType<
-			message_parameter_key_pack_index<Literal, Keys...>::Value>::reader
-		get() {
-			// The index of the first match
-			constexpr size_t i =
-				message_parameter_key_pack_index<Literal, Keys...>::Value;
-
-			return get<i>();
-		}
-	};
-
-	builder build() { return builder{*this}; }
-
-	reader read() { return reader{*this}; }
-};
-
-/*
- * Union message class. Wrapper object
- */
-template <class... V, string_literal... Keys, class Container>
-class message<schema::Union<schema::NamedMember<V, Keys>...>, Container> final
-	: public message_base {
-private:
-	using SchemaType = schema::Union<schema::NamedMember<V, Keys>...>;
-	using MessageType = message<SchemaType, Container>;
-
-	Container container_;
-
-	static_assert(std::is_same_v<SchemaType, typename Container::SchemaType>,
-				  "Container should have same the schema as Message");
-
-	friend class builder;
-	friend class reader;
-
-public:
-	class reader;
-	class builder {
-	private:
-		MessageType &message_;
-
-	public:
-		builder(MessageType &msg) : message_{msg} {}
-
-		reader as_reader() { return reader{message_}; }
-
-		template <size_t i>
-		typename std::enable_if<
-			!schema_is_array<
-				typename message_parameter_pack_type<i, V...>::Type>::Value,
-			typename Container::template ElementType<i>::builder>::type
-
-		init() {
-			return typename Container::template ElementType<i>::builder{
-				message_.container_.template get<i>()};
-		}
-
-		template <string_literal Literal>
-		typename std::enable_if<
-			!schema_is_array<typename message_parameter_pack_type<
-				message_parameter_key_pack_index<Literal, Keys...>::Value,
-				V...>::Type>::Value,
-			typename Container::template ElementType<
-				message_parameter_key_pack_index<Literal, Keys...>::Value>::
-				builder>::type
-		init() {
-			constexpr size_t i =
-				message_parameter_key_pack_index<Literal, Keys...>::Value;
-
-			return init<i>();
-		}
-
-		/*
-		 * If Schema is Array
-		 */
-		template <size_t i>
-		typename std::enable_if<
-			schema_is_array<
-				typename message_parameter_pack_type<i, V...>::Type>::Value,
-			typename Container::template ElementType<i>::builder>::type
-		init(size_t size = 0) {
-			return typename Container::template ElementType<i>::builder{
-				message_.container_.template get<i>(), size};
-		}
-
-		template <string_literal Literal>
-		typename std::enable_if<
-			schema_is_array<typename message_parameter_pack_type<
-				message_parameter_key_pack_index<Literal, Keys...>::Value,
-				V...>::Type>::Value,
-			typename Container::template ElementType<
-				message_parameter_key_pack_index<Literal, Keys...>::Value>::
-				builder>::type
-		init(size_t size) {
-			constexpr size_t i =
-				message_parameter_key_pack_index<Literal, Keys...>::Value;
-
-			return init<i>(size);
-		}
-	};
-
-	class reader {
-	private:
-		MessageType &message_;
-
-	public:
-		reader(MessageType &msg) : message_{msg} {}
-
-		builder as_builder() { return builder{message_}; }
-
-		template <size_t i>
-		typename Container::template ElementType<i>::reader get() {
-			return typename Container::template ElementType<i>::reader{
-				message_.container_.template get<i>()};
-		}
-
-		template <string_literal Literal>
-		typename Container::template ElementType<
-			message_parameter_key_pack_index<Literal, Keys...>::Value>::reader
-		get() {
-			// The index of the first match
-			constexpr size_t i =
-				message_parameter_key_pack_index<Literal, Keys...>::Value;
-
-			return get<i>();
-		}
-
-		template <string_literal Literal>
-		static constexpr size_t to_index() noexcept {
-			return message_parameter_key_pack_index<Literal, Keys...>::Value;
-		}
-
-		size_t index() const noexcept { return message_.container_.index(); }
-
-		template <string_literal Literal> bool has_alternative() const {
-			return index() == to_index<Literal>();
-		}
-	};
-};
-
-/*
- * Array message class. Wrapper around an array schema element
- */
-template <class T, class Container>
-class message<schema::Array<T>, Container> final : public message_base {
-private:
-	using SchemaType = schema::Array<T>;
-	using MessageType = message<SchemaType, Container>;
-
-	Container container_;
-
-	static_assert(std::is_same_v<SchemaType, typename Container::SchemaType>,
-				  "Container should have same Schema as Message");
-
-	friend class builder;
-	friend class reader;
-
-public:
-	class reader;
-	class builder {
-	private:
-		MessageType &message_;
-
-	public:
-		builder(MessageType &msg, size_t size) : message_{msg} {
-			if (size > 0) {
-				message_.container_.resize(size);
-			}
-		}
-
-		reader as_reader() { return reader{message_}; }
-
-		typename Container::ElementType::builder init(size_t i) {
-			return typename Container::ElementType::builder{
-				message_.container_.get(i)};
-		}
-
-		size_t size() const { return message_.container_.size(); }
-
-		void resize(size_t size) { message_.container_.resize(size); }
-	};
-
-	class reader {
-	private:
-		MessageType &message_;
-
-	public:
-		reader(MessageType &msg) : message_{msg} {}
-
-		builder as_builder() { return builder{message_, 0}; }
-
-		typename Container::ElementType::reader get(size_t i) {
-			return typename Container::ElementType::reader{
-				message_.container_.get(i)};
-		}
-
-		size_t size() const { return message_.container_.size(); }
-	};
-};
-
-/*
- * Tuple message class. Wrapper around a tuple schema
- */
-template <class... T, class Container>
-class message<schema::Tuple<T...>, Container> final : public message_base {
-private:
-	using SchemaType = schema::Tuple<T...>;
-	using MessageType = message<SchemaType, Container>;
-
-	Container container_;
-
-	static_assert(std::is_same_v<SchemaType, typename Container::SchemaType>,
-				  "Container should have same the schema as Message");
-
-	friend class builder;
-	friend class reader;
-
-public:
-	class reader;
-	class builder {
-		MessageType &message_;
-
-	public:
-		builder(MessageType &msg) : message_{msg} {}
-
-		reader as_reader() { return reader{message_}; }
-
-		template <size_t i>
-		typename std::enable_if<
-			!schema_is_array<
-				typename message_parameter_pack_type<i, T...>::Type>::Value,
-			typename Container::template ElementType<i>::builder>::type
-		init() {
-			return typename Container::template ElementType<i>::builder{
-				message_.container_.template get<i>()};
-		}
-
-		template <size_t i>
-		typename std::enable_if<
-			schema_is_array<
-				typename message_parameter_pack_type<i, T...>::Type>::Value,
-			typename Container::template ElementType<i>::builder>::type
-		init(size_t size = 0) {
-			return typename Container::template ElementType<i>::builder{
-				message_.container_.template get<i>(), size};
-		}
-	};
-	class reader {
-	private:
-		MessageType &message_;
-
-	public:
-		reader(MessageType &msg) : message_{msg} {}
-
-		builder as_builder() { return builder{message_}; }
-
-		template <size_t i>
-		typename Container::template ElementType<i>::reader get() {
-			return typename Container::template ElementType<i>::reader{
-				message_.container_.template get<i>()};
-		}
-	};
-};
-
-/*
- * Primitive type (float, double, uint8_t, uint16_t, uint32_t, uint64_t, int8_t,
- * int16_t, int32_t, int64_t) message class
- */
-template <class T, size_t N, class Container>
-class message<schema::Primitive<T, N>, Container> final : public message_base {
-private:
-	using SchemaType = schema::Primitive<T, N>;
-	using MessageType = message<SchemaType, Container>;
-
-	Container container_;
-
-	static_assert(std::is_same_v<SchemaType, typename Container::SchemaType>,
-				  "Container should have same the schema as Message");
-
-	friend class builder;
-	friend class reader;
-
-public:
-	class reader;
-	class builder {
-	private:
-		MessageType &message_;
-
-	public:
-		builder(MessageType &msg) : message_{msg} {}
-
-		reader as_reader() { return reader{message_}; }
-
-		void set(const typename Container::ValueType &value) {
-			message_.container_.set(value);
-		}
-	};
-
-	class reader {
-	private:
-		MessageType &message_;
-
-	public:
-		reader(message &msg) : message_{msg} {}
-
-		builder as_builder() { return builder{message_}; }
-
-		const typename Container::ValueType &get() const {
-			return message_.container_.get();
-		}
-	};
-};
-
-template <class Container>
-class message<schema::String, Container> final : public message_base {
-private:
-	using SchemaType = schema::String;
-	using MessageType = message<SchemaType, Container>;
-
-	Container container_;
-
-	static_assert(std::is_same_v<SchemaType, typename Container::SchemaType>,
-				  "Container should have same the schema as Message");
-
-	friend class builder;
-	friend class reader;
-
-public:
-	class reader;
-	class builder {
-	private:
-		MessageType &message_;
-
-	public:
-		builder(MessageType &msg) : message_{msg} {}
-
-		reader as_reader() { return reader{message_}; }
-
-		void set(std::string &&str) { message_.container_.set(std::move(str)); }
-		void set(const std::string_view str) { message_.container_.set(str); }
-		void set(const char *str) { set(std::string_view{str}); }
-	};
-
-	class reader {
-	private:
-		MessageType &message_;
-
-	public:
-		reader(MessageType &msg) : message_{msg} {}
-
-		builder as_builder() { return builder{message_}; }
-
-		const std::string_view get() const { return message_.container_.get(); }
-	};
-};
-
-template <class Schema, class Container = message_container<Schema>>
-class heap_message_root {
-private:
-	own<message<Schema, Container>> root_;
-
-public:
-	heap_message_root(own<message<Schema, Container>> r)
-		: root_{std::move(r)} {}
-
-	typename message<Schema, Container>::builder build() {
-		assert(root_);
-		return typename message<Schema, Container>::builder{*root_};
-	}
-
-	typename message<Schema, Container>::reader read() {
-		assert(root_);
-		return typename message<Schema, Container>::reader{*root_};
-	}
-};
-
-template <class T, class Container>
-class heap_message_root<schema::Array<T>, Container> {
-public:
-	using Schema = schema::Array<T>;
-
-private:
-	own<message<Schema, Container>> root_;
-
-public:
-	heap_message_root(own<message<Schema, Container>> r)
-		: root_{std::move(r)} {}
-
-	typename message<Schema, Container>::builder build(size_t size) {
-		assert(root_);
-		return typename message<Schema, Container>::builder{*root_, size};
-	}
-
-	typename message<Schema, Container>::reader read() {
-		assert(root_);
-		return typename message<Schema, Container>::reader{*root_};
-	}
-};
-
-/*
- * Minor helper for creating a message root
- */
-template <class Schema, class Container = message_container<Schema>>
-inline heap_message_root<Schema, Container> new_heap_message_root() {
-	own<message<Schema, Container>> root = heap<message<Schema, Container>>();
-	return heap_message_root<Schema, Container>{std::move(root)};
-}
-} // namespace saw
diff --git a/forstio/codec/message_container.h b/forstio/codec/message_container.h
deleted file mode 100644
index 191052a..0000000
--- a/forstio/codec/message_container.h
+++ /dev/null
@@ -1,246 +0,0 @@
-#pragma once
-
-#include "schema.h"
-
-#include <variant>
-#include <vector>
-
-namespace saw {
-template <class T> class message_container;
-
-template <class T, class Container = message_container<T>> class message;
-
-template <size_t N, class... T> struct message_parameter_pack_type;
-
-template <class TN, class... T>
-struct message_parameter_pack_type<0, TN, T...> {
-	using Type = TN;
-};
-
-template <size_t N, class TN, class... T>
-struct message_parameter_pack_type<N, TN, T...> {
-	static_assert(sizeof...(T) > 0, "Exhausted parameters");
-	using Type = typename message_parameter_pack_type<N - 1, T...>::Type;
-};
-
-template <class T, class... TL> struct MessageParameterPackIndex;
-
-template <class T, class... TL> struct MessageParameterPackIndex<T, T, TL...> {
-	static constexpr size_t Value = 0u;
-};
-
-template <class T, class TL0, class... TL>
-struct MessageParameterPackIndex<T, TL0, TL...> {
-	static constexpr size_t Value =
-		1u + MessageParameterPackIndex<T, TL...>::Value;
-};
-
-/*
- * Nightmare inducing compiler problems found here. Somehow non-type
- * StringLiterals cannot be resolved as non-type primitive template values can.
- * This is the workaround
- */
-template <string_literal V, string_literal Key0, string_literal... Keys>
-struct message_parameter_key_pack_index_helper {
-	static constexpr size_t Value =
-		(V == Key0)
-			? (0u)
-			: (1u + message_parameter_key_pack_index_helper<V, Keys...>::Value);
-};
-
-template <string_literal V, string_literal Key0>
-struct message_parameter_key_pack_index_helper<V, Key0> {
-	static constexpr size_t Value = (V == Key0) ? (0u) : (1u);
-};
-
-template <string_literal V, string_literal... Keys>
-struct message_parameter_key_pack_index {
-	static constexpr size_t Value =
-		message_parameter_key_pack_index_helper<V, Keys...>::Value;
-	static_assert(Value < sizeof...(Keys),
-				  "Provided StringLiteral doesn't exist in searched list");
-};
-
-template <class T> struct schema_is_array {
-	constexpr static bool Value = false;
-};
-
-template <class T> struct schema_is_array<schema::Array<T>> {
-	constexpr static bool Value = true;
-};
-
-template <class... V, string_literal... Keys>
-class message_container<schema::Struct<schema::NamedMember<V, Keys>...>> {
-private:
-	using ValueType = std::tuple<message<V, message_container<V>>...>;
-	ValueType values_;
-
-public:
-	using SchemaType = schema::Struct<schema::NamedMember<V, Keys>...>;
-
-	template <size_t i>
-	using ElementType = typename message_parameter_pack_type<
-		i, message<V, message_container<V>>...>::Type;
-
-	template <size_t i> ElementType<i> &get() { return std::get<i>(values_); }
-};
-
-/*
- * Union storage
- */
-template <class... V, string_literal... Keys>
-class message_container<schema::Union<schema::NamedMember<V, Keys>...>> {
-private:
-	using ValueType = std::variant<message<V, message_container<V>>...>;
-	ValueType value_;
-
-public:
-	using SchemaType = schema::Union<schema::NamedMember<V, Keys>...>;
-
-	template <size_t i>
-	using ElementType = typename message_parameter_pack_type<
-		i, message<V, message_container<V>>...>::Type;
-
-	template <size_t i> ElementType<i> &get() {
-		if (i != value_.index()) {
-			using MessageIV =
-				typename message_parameter_pack_type<i, V...>::Type;
-			value_ = message<MessageIV, message_container<MessageIV>>{};
-		}
-		return std::get<i>(value_);
-	}
-
-	size_t index() const noexcept { return value_.index(); }
-};
-
-/*
- * Array storage
- */
-
-template <class T> class message_container<schema::Array<T>> {
-private:
-	using ValueType = std::vector<message<T, message_container<T>>>;
-	ValueType values_;
-
-public:
-	using SchemaType = schema::Array<T>;
-
-	using ElementType = message<T, message_container<T>>;
-
-	message<T, message_container<T>> &get(size_t index) {
-		return values_.at(index);
-	}
-
-	void resize(size_t size) { values_.resize(size); }
-
-	size_t size() const { return values_.size(); }
-};
-
-/*
- * Tuple storage
- */
-template <class... T> class message_container<schema::Tuple<T...>> {
-private:
-	using ValueType = std::tuple<message<T, message_container<T>>...>;
-	ValueType values_;
-
-public:
-	using SchemaType = schema::Tuple<T...>;
-
-	template <size_t i>
-	using ElementType = typename message_parameter_pack_type<
-		i, message<T, message_container<T>>...>::Type;
-
-	template <size_t i> ElementType<i> &get() { return std::get<i>(values_); }
-};
-
-/*
- * Helper for the basic message container, so the class doesn't have to be
- * specialized 10 times.
- */
-template <class T> struct PrimitiveTypeHelper;
-
-template <>
-struct PrimitiveTypeHelper<schema::Primitive<schema::SignedInteger, 1>> {
-	using Type = int8_t;
-};
-
-template <>
-struct PrimitiveTypeHelper<schema::Primitive<schema::SignedInteger, 2>> {
-	using Type = int16_t;
-};
-
-template <>
-struct PrimitiveTypeHelper<schema::Primitive<schema::SignedInteger, 4>> {
-	using Type = int32_t;
-};
-
-template <>
-struct PrimitiveTypeHelper<schema::Primitive<schema::SignedInteger, 8>> {
-	using Type = int64_t;
-};
-
-template <>
-struct PrimitiveTypeHelper<schema::Primitive<schema::UnsignedInteger, 1>> {
-	using Type = uint8_t;
-};
-
-template <>
-struct PrimitiveTypeHelper<schema::Primitive<schema::UnsignedInteger, 2>> {
-	using Type = uint16_t;
-};
-
-template <>
-struct PrimitiveTypeHelper<schema::Primitive<schema::UnsignedInteger, 4>> {
-	using Type = uint32_t;
-};
-
-template <>
-struct PrimitiveTypeHelper<schema::Primitive<schema::UnsignedInteger, 8>> {
-	using Type = uint64_t;
-};
-
-template <>
-struct PrimitiveTypeHelper<schema::Primitive<schema::FloatingPoint, 4>> {
-	using Type = float;
-};
-
-template <>
-struct PrimitiveTypeHelper<schema::Primitive<schema::FloatingPoint, 8>> {
-	using Type = double;
-};
-
-template <class T, size_t N> class message_container<schema::Primitive<T, N>> {
-public:
-	using SchemaType = schema::Primitive<T, N>;
-	using ValueType =
-		typename PrimitiveTypeHelper<schema::Primitive<T, N>>::Type;
-
-private:
-	ValueType value_;
-
-public:
-	message_container() : value_{0} {}
-
-	void set(const ValueType &v) { value_ = v; }
-
-	const ValueType &get() const { return value_; }
-};
-
-template <> class message_container<schema::String> {
-public:
-	using SchemaType = schema::String;
-	using ValueType = std::string;
-	using ValueViewType = std::string_view;
-
-private:
-	ValueType value_;
-
-public:
-	void set(ValueType &&v) { value_ = std::move(v); }
-	void set(const ValueType &v) { value_ = v; }
-	void set(const ValueViewType v) { value_ = std::string{v}; }
-
-	const ValueType &get() const { return value_; }
-};
-} // namespace saw
diff --git a/forstio/codec/proto_kel.h b/forstio/codec/proto_kel.h
new file mode 100644
index 0000000..c28f7d6
--- /dev/null
+++ b/forstio/codec/proto_kel.h
@@ -0,0 +1,41 @@
+#pragma once
+
+#include "data.h"
+
+#include <forstio/core/error.h>
+
+namespace saw {
+namespace encode {
+struct ProtoKel {};
+}
+
+template<typename Schema>
+class data<Schema, encode::ProtoKel> {
+private:
+	own<buffer> buffer_;
+public:
+	data(own<buffer>&& buffer__):buffer_{std::move(buffer__)}{}
+
+	buffer& get_buffer(){
+		return *buffer_;
+	}
+
+	const buffer& get_buffer() const {
+		return *buffer_;
+	}
+};
+
+template<typename Schema>
+class codec<Schema, encode::ProtoKel> {
+private:
+public:
+	error_or<data<Schema, encode::Native>> decode(const data<Schema, encode::ProtoKel>& encoded){
+		return make_error<err::critical>();
+	}
+
+	error_or<data<Schema, encode::ProtoKel>> encode(const data<Schema, encode::Native>& native){
+		return make_error<err::critical>();
+	}
+};
+}
+}