1 files changed, 59 insertions, 3 deletions
diff --git a/c++/codec-netcdf/netcdf.h b/c++/codec-netcdf/netcdf.h
index 72e7614..cc9aedb 100644
--- a/c++/codec-netcdf/netcdf.h
+++ b/c++/codec-netcdf/netcdf.h
@@ -23,6 +23,8 @@ class data<Schema, encode::Netcdf> {
 private:
 		std::vector<uint8_t> buff_;
 public:
+		data() = default;
+
 		data(std::vector<uint8_t> buff):
 				buff_{std::move(buff)}
 		{}
@@ -67,8 +69,62 @@ public:
 		 * Encoder function
 		 */
 		template<typename FromEncoding>
-		error_or<void> encode() {
-				return make_error<err::not_implemented>();
+		error_or<void> encode(const data<Schema, FromEncoding>& from, data<Schema,encode::Netcdf>& to) {
+			int rc{};
+			int ncid{};
+
+			rc = nc_create_mem("forstio_internal_write_memory", 0,/*NC_NETCDF4, */0, &ncid);
+			if(rc != NC_NOERR){
+				return make_error<err::critical>();
+			}
+
+			{
+				auto eov = impl::netcdf_encode<Schema,FromEncoding>::encode_meta(from, ncid);
+				if(eov.is_error()){
+					nc_close(ncid);
+					return eov;
+				}
+			}
+
+			rc = nc_enddef(ncid);
+			if(rc != NC_NOERR){
+				nc_close(ncid);
+				return make_error<err::critical>();
+			}
+
+			{
+				auto eov = impl::netcdf_encode<Schema,FromEncoding>::encode(from, ncid);
+				if(eov.is_error()){
+					nc_close(ncid);
+					return eov;
+				}
+			}
+
+			NC_memio nc_memio;
+			rc = nc_close_memio(ncid, &nc_memio);
+			if(rc != NC_NOERR){
+				return make_error<err::critical>();
+			}
+
+			if(!nc_memio.memory || nc_memio.size == 0){
+				return make_error<err::critical>();
+			}
+
+			try {
+				to.get_data().resize(nc_memio.size);
+			}catch(const std::exception& e){
+				(void) e;
+				return make_error<err::out_of_memory>();
+			}
+
+			for(std::size_t i = 0; i < nc_memio.size; ++i){
+				to.get_data().at(i) = static_cast<uint8_t*>(nc_memio.memory)[i];
+			}
+
+			free(nc_memio.memory);
+			nc_memio.memory = nullptr;
+
+			return void_t{};
 		}
 
 		/**
@@ -79,7 +135,7 @@ public:
 				int ncid{};
 				int rc{};
 
-				rc = nc_open_mem("forstio_internal_memory", NC_NOWRITE, from_decode.get_data().size(), &from_decode.get_data()[0], &ncid);
+				rc = nc_open_mem("forstio_internal_read_memory", NC_NOWRITE, from_decode.get_data().size(), &from_decode.get_data()[0], &ncid);
 				if(rc != NC_NOERR){
 						// Don't know how to get the error, so fail critically.
 						return make_error<err::critical>();