diff --git a/src/dlt/gateway/legacy/Dockerfile b/src/dlt/gateway/legacy/Dockerfile
new file mode 100644
index 0000000000000000000000000000000000000000..5b888b410360330cdf044c88f5832d1738d546e8
--- /dev/null
+++ b/src/dlt/gateway/legacy/Dockerfile
@@ -0,0 +1,41 @@
+# Copyright 2022-2024 ETSI OSG/SDG TeraFlowSDN (TFS) (https://tfs.etsi.org/)
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+FROM zenika/kotlin:1.4-jdk12
+
+# Make working directory move to it and copy DLT Gateway code
+RUN mkdir -p /var/teraflow/dlt/gateway
+WORKDIR /var/teraflow/dlt/gateway
+COPY src/dlt/gateway/. ./
+
+# Make directory for proto files and copy them
+RUN mkdir proto
+COPY proto/*.proto ./proto/
+
+# Build DLT Gateway
+RUN ./gradlew build
+
+EXPOSE 50051
+
+# Create entrypoint.sh script
+RUN echo "#!/bin/sh" > /entrypoint.sh
+RUN echo "echo 195.37.154.24 peer0.org1.example.com >> /etc/hosts" >> /entrypoint.sh
+RUN echo "echo 195.37.154.24 peer0.org2.example.com >> /etc/hosts" >> /entrypoint.sh
+RUN echo "echo 195.37.154.24 orderer0.example.com   >> /etc/hosts" >> /entrypoint.sh
+RUN echo "cd /var/teraflow/dlt/gateway" >> /entrypoint.sh
+RUN echo "./gradlew runServer" >> /entrypoint.sh
+RUN chmod +x /entrypoint.sh
+
+# Gateway entry point
+ENTRYPOINT ["sh", "/entrypoint.sh"]
diff --git a/src/dlt/gateway/legacy/README.md b/src/dlt/gateway/legacy/README.md
new file mode 100644
index 0000000000000000000000000000000000000000..2cf6cfeb1682ade5a77f53fe13c96daed6dc33fd
--- /dev/null
+++ b/src/dlt/gateway/legacy/README.md
@@ -0,0 +1,134 @@
+```
+     NEC Laboratories Europe GmbH
+
+     PROPRIETARY INFORMATION
+
+ The software and its source code contain valuable trade secrets and
+ shall be maintained in confidence and treated as confidential
+ information. The software may only be used for evaluation and/or
+ testing purposes, unless otherwise explicitly stated in a written
+ agreement with NEC Laboratories Europe GmbH.
+
+ Any unauthorized publication, transfer to third parties or
+ duplication of the object or source code - either totally or in
+ part - is strictly prohibited.
+
+          Copyright (c) 2022 NEC Laboratories Europe GmbH
+          All Rights Reserved.
+
+ Authors: Konstantin Munichev <konstantin.munichev@neclab.eu>
+
+
+ NEC Laboratories Europe GmbH DISCLAIMS ALL WARRANTIES, EITHER
+ EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO IMPLIED WARRANTIES
+ OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE AND THE
+ WARRANTY AGAINST LATENT DEFECTS, WITH RESPECT TO THE PROGRAM AND
+ THE ACCOMPANYING DOCUMENTATION.
+
+ NO LIABILITIES FOR CONSEQUENTIAL DAMAGES: IN NO EVENT SHALL NEC
+ Laboratories Europe GmbH or ANY OF ITS SUBSIDIARIES BE LIABLE FOR
+ ANY DAMAGES WHATSOEVER (INCLUDING, WITHOUT LIMITATION, DAMAGES FOR
+ LOSS OF BUSINESS PROFITS, BUSINESS INTERRUPTION, LOSS OF
+ INFORMATION, OR OTHER PECUNIARY LOSS AND INDIRECT, CONSEQUENTIAL,
+ INCIDENTAL, ECONOMIC OR PUNITIVE DAMAGES) ARISING OUT OF THE USE OF
+ OR INABILITY TO USE THIS PROGRAM, EVEN IF NEC Laboratories Europe
+ GmbH HAS BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGES.
+
+ THIS HEADER MAY NOT BE EXTRACTED OR MODIFIED IN ANY WAY.
+ ```
+
+# DLT module guide
+
+## General information
+The DLT module is used to provide access to the underlying Fabric deployment. It allows clients
+to add, retrieve, modify and delete blockchain-backed data, essentially working as a key-value
+database. External clients should use gRPC API to communicate with this service, its detailed
+description available below.
+
+## Code structure
+The whole DLT module consists of several packages:
+- fabric package
+- http package
+- proto package
+- client example
+
+### Fabric package
+The most important class in this package is `FabricConnector`. First, it establishes connection
+with the underlying Fabric network using Java Gateway SDK. After that, it could be used as a
+CRUD interface.
+Other files contain auxiliary code for `FabricConnector` which allows it to register/enroll
+users and to obtain smart contract instances.
+
+### Grpc package
+Contains server side gRPC handler. It accepts requests from the outside and performs the
+requested operation. For the more detailed description see Proto package description right below.
+
+### Proto package
+The proto package contains `dlt.proto` file which defines gRPC service `DltService` API and messages
+it uses. There are 3 main functions: `RecordToDlt` which allows to create/modify/delete data,
+`GetFromDlt` which returns already written data and `SubscribeToDlt` which allows clients subscribe
+for future create/modify/delete events with provided filters.
+Other proto files don't play any significant role and could be safely ignored by end users.
+
+### Client example
+This code is not necessary to the service, but it could be used to test the service. It contains
+a sample gRPC client which connects the service and perform all the CRUD operations. 
+
+# Fabric deployment notes
+
+## General notes
+Current Fabric deployment uses Fabric test network with some additional helping scripts on top of it.
+To start the network just run the `raft.sh` from `blockchain/scripts` directory. Use `stop.sh`
+when you need to stop the network.
+
+## Server start preparations
+To run the server it's necessary to copy certificate file
+`fabric-samples/test-network/organizations/peerOrganizations/org1.example.com/ca/ca.org1.example.com-cert.pem`
+to the config folder (replacing the existing one). Also, it's necessary to copy `scripts/connection-org1.json`
+file (again, replacing the old one). After copying, it must be edited. First, all `localhost` entrances
+should be replaced with `teraflow.nlehd.de`. Second, `channel` section at the end of the file should be removed.
+This should be done after every restart of the Fabric network.
+
+## Fabric configuration
+Even though a test network is easy to deploy and use it's better to perform a custom configuration
+for a production deployment. In practice every participating organization will likely prefer to have
+its own Peer/Orderer/CA instances to prevent possible dependency on any other participants. This leads
+not only to a better privacy/availability/security in general but also to the more complicated
+deployment process as a side effect. Here we provide a very brief description of the most important points.
+
+### Organizations
+Organization represents a network participant, which can be an individual, a large corporation or any other
+entity. Each organization has its own CAs, orderers and peers. The recommendation here is to create an
+organization entity for every independent participant and then decide how many CAs/peers/orderers does
+every organization need and which channels should it has access to based on the exact project's goals. 
+
+### Channels
+Each channel represents an independent ledger with its own genesis block. Each transaction is executed
+on a specific channel, and it's possible to define which organization has access to a given channel.
+As a result channels are a pretty powerful privacy mechanism which allows to limit access to the private
+data between organization.
+
+### Certificate authorities, peers and orderers
+Certificate authorities (CA) are used to generate crypto materials for each organization. Two types of CA
+exist: one is used to generate the certificates of the admin, the MSP and certificates of non-admin users.
+Another type of CA is used to generate TLS certificates. As a result it's preferable to have at least two
+CAs for every organization.
+
+Peers are entities which host ledgers and smart contracts. They communicate with applications and orderers,
+receiving chaincode invocations (proposals), invoking chaincode, updating ledger when necessary and
+returning result of execution. Peers can handle one or many ledgers, depending on the configuration. It's
+very use case specific how many peers are necessary to the exact deployment.
+
+Orderers are used to execute a consensus in a distributing network making sure that every channel participant
+has the same blocks with the same data. The default consensus algorithm is Raft which provides only a crash
+fault tolerance.
+
+### Conclusion
+As you can see, configuration procedure for Fabric is pretty tricky and includes quite a lot of entities.
+In real world it will very likely involve participants from multiple organizations each of them performing
+its own part of configuration.
+
+As a further reading it's recommended to start with the
+[official deployment guide](https://hyperledger-fabric.readthedocs.io/en/release-2.2/deployment_guide_overview.html).
+It contains a high level overview of a deployment process as well as links to the detailed descriptions to
+CA/Peer/Orderer configuration descriptions.
\ No newline at end of file
diff --git a/src/dlt/gateway/legacy/build.gradle.kts b/src/dlt/gateway/legacy/build.gradle.kts
new file mode 100644
index 0000000000000000000000000000000000000000..b65aff89e18077ffaff37ea732293f585ca7920d
--- /dev/null
+++ b/src/dlt/gateway/legacy/build.gradle.kts
@@ -0,0 +1,147 @@
+//     NEC Laboratories Europe GmbH
+//
+//     PROPRIETARY INFORMATION
+//
+// The software and its source code contain valuable trade secrets and
+// shall be maintained in confidence and treated as confidential
+// information. The software may only be used for evaluation and/or
+// testing purposes, unless otherwise explicitly stated in a written
+// agreement with NEC Laboratories Europe GmbH.
+//
+// Any unauthorized publication, transfer to third parties or
+// duplication of the object or source code - either totally or in
+// part - is strictly prohibited.
+//
+//          Copyright (c) 2021 NEC Laboratories Europe GmbH
+//          All Rights Reserved.
+//
+// Authors: Konstantin Munichev <konstantin.munichev@neclab.eu>
+//
+//
+// NEC Laboratories Europe GmbH DISCLAIMS ALL WARRANTIES, EITHER
+// EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO IMPLIED WARRANTIES
+// OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE AND THE
+// WARRANTY AGAINST LATENT DEFECTS, WITH RESPECT TO THE PROGRAM AND
+// THE ACCOMPANYING DOCUMENTATION.
+//
+// NO LIABILITIES FOR CONSEQUENTIAL DAMAGES: IN NO EVENT SHALL NEC
+// Laboratories Europe GmbH or ANY OF ITS SUBSIDIARIES BE LIABLE FOR
+// ANY DAMAGES WHATSOEVER (INCLUDING, WITHOUT LIMITATION, DAMAGES FOR
+// LOSS OF BUSINESS PROFITS, BUSINESS INTERRUPTION, LOSS OF
+// INFORMATION, OR OTHER PECUNIARY LOSS AND INDIRECT, CONSEQUENTIAL,
+// INCIDENTAL, ECONOMIC OR PUNITIVE DAMAGES) ARISING OUT OF THE USE OF
+// OR INABILITY TO USE THIS PROGRAM, EVEN IF NEC Laboratories Europe
+// GmbH HAS BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGES.
+//
+// THIS HEADER MAY NOT BE EXTRACTED OR MODIFIED IN ANY WAY.
+
+import org.jetbrains.kotlin.gradle.tasks.KotlinCompile
+
+import com.google.protobuf.gradle.generateProtoTasks
+import com.google.protobuf.gradle.id
+import com.google.protobuf.gradle.plugins
+import com.google.protobuf.gradle.protobuf
+import com.google.protobuf.gradle.protoc
+
+ext["grpcVersion"] = "1.47.0"
+ext["grpcKotlinVersion"] = "1.3.0" // CURRENT_GRPC_KOTLIN_VERSION
+ext["protobufVersion"] = "3.20.1"
+ext["ktorVersion"] = "1.6.5"
+
+plugins {
+    kotlin("jvm") version "1.6.21"
+    kotlin("plugin.serialization") version "1.4.21"
+    id("com.google.protobuf") version "0.8.18"
+    application
+}
+
+group = "eu.neclab"
+version = "1.0-SNAPSHOT"
+
+repositories {
+    mavenLocal()
+    google()
+    mavenCentral()
+}
+
+dependencies {
+    implementation(kotlin("stdlib-jdk8"))
+    testImplementation("org.jetbrains.kotlin:kotlin-test:1.6.21")
+    implementation("javax.annotation:javax.annotation-api:1.3.2")
+    implementation("io.grpc:grpc-kotlin-stub:1.3.0")
+    implementation("io.grpc:grpc-protobuf:1.47.0")
+    implementation("com.google.protobuf:protobuf-kotlin:3.21.1")
+    implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.6.3")
+    implementation("org.hyperledger.fabric:fabric-gateway-java:2.2.5")
+    implementation("ch.qos.logback:logback-classic:1.2.11")
+    implementation("org.jetbrains.kotlinx:kotlinx-serialization-json:1.3.1")
+    implementation("org.jetbrains.kotlinx:kotlinx-serialization-protobuf:1.3.1")
+    runtimeOnly("io.grpc:grpc-netty:${rootProject.ext["grpcVersion"]}")
+}
+
+tasks.test {
+    useJUnitPlatform()
+}
+
+tasks.withType<KotlinCompile> {
+    kotlinOptions.jvmTarget = "11"
+}
+
+tasks.withType<KotlinCompile>().all {
+    kotlinOptions {
+        freeCompilerArgs = listOf("-Xopt-in=kotlin.RequiresOptIn")
+    }
+}
+
+
+application {
+    mainClass.set("MainKt")
+}
+
+task("runServer", JavaExec::class) {
+    main = "grpc.FabricServerKt"
+    classpath = sourceSets["main"].runtimeClasspath
+}
+
+
+sourceSets {
+    main {
+        proto {
+            srcDir("proto")
+            srcDir("src/main/kotlin/proto")
+        }
+    }
+}
+
+sourceSets {
+    val main by getting { }
+    main.java.srcDirs("build/generated/source/proto/main/grpc")
+    main.java.srcDirs("build/generated/source/proto/main/grpckt")
+    main.java.srcDirs("build/generated/source/proto/main/java")
+    main.java.srcDirs("build/generated/source/proto/main/kotlin")
+}
+
+protobuf {
+    protoc {
+        artifact = "com.google.protobuf:protoc:${rootProject.ext["protobufVersion"]}"
+    }
+    plugins {
+        id("grpc") {
+            artifact = "io.grpc:protoc-gen-grpc-java:${rootProject.ext["grpcVersion"]}"
+        }
+        id("grpckt") {
+            artifact = "io.grpc:protoc-gen-grpc-kotlin:${rootProject.ext["grpcKotlinVersion"]}:jdk8@jar"
+        }
+    }
+    generateProtoTasks {
+        all().forEach {
+            it.plugins {
+                id("grpc")
+                id("grpckt")
+            }
+            it.builtins {
+                id("kotlin")
+            }
+        }
+    }
+}
diff --git a/src/dlt/gateway/legacy/config/ca.org1.example.com-cert.pem b/src/dlt/gateway/legacy/config/ca.org1.example.com-cert.pem
new file mode 100644
index 0000000000000000000000000000000000000000..d7fdf63cc3f745d13edc8394bca67a1b41011ed2
--- /dev/null
+++ b/src/dlt/gateway/legacy/config/ca.org1.example.com-cert.pem
@@ -0,0 +1,14 @@
+-----BEGIN CERTIFICATE-----
+MIICJzCCAc2gAwIBAgIUb5gDMfVeVdQjFkK3uC8LtlogN+gwCgYIKoZIzj0EAwIw
+cDELMAkGA1UEBhMCVVMxFzAVBgNVBAgTDk5vcnRoIENhcm9saW5hMQ8wDQYDVQQH
+EwZEdXJoYW0xGTAXBgNVBAoTEG9yZzEuZXhhbXBsZS5jb20xHDAaBgNVBAMTE2Nh
+Lm9yZzEuZXhhbXBsZS5jb20wHhcNMjIwOTI3MDgzMDAwWhcNMzcwOTIzMDgzMDAw
+WjBwMQswCQYDVQQGEwJVUzEXMBUGA1UECBMOTm9ydGggQ2Fyb2xpbmExDzANBgNV
+BAcTBkR1cmhhbTEZMBcGA1UEChMQb3JnMS5leGFtcGxlLmNvbTEcMBoGA1UEAxMT
+Y2Eub3JnMS5leGFtcGxlLmNvbTBZMBMGByqGSM49AgEGCCqGSM49AwEHA0IABDC3
+spCTT3pjfFXxkX/SFuBgWRiceR8rSoCNQOnIPeNGZK8xl2Zr7VuY06gqy9c+ecSU
+PUWaXiCQxiLgZuS6TOWjRTBDMA4GA1UdDwEB/wQEAwIBBjASBgNVHRMBAf8ECDAG
+AQH/AgEBMB0GA1UdDgQWBBRFWSc7GZqcJJyJjXSEspzgAYInGzAKBggqhkjOPQQD
+AgNIADBFAiEAodqc+adkiMuU6iv1IF8uJ/nMQbvMGoP3pb2827QzDosCICOw6W+y
+uH03H3RO6KhOcS1ZzPjspyjrcC+dwzYX4DpW
+-----END CERTIFICATE-----
diff --git a/src/dlt/gateway/legacy/config/connection-org1.json b/src/dlt/gateway/legacy/config/connection-org1.json
new file mode 100644
index 0000000000000000000000000000000000000000..6f6f3f08d65c495bb57551f6d0bfac38c9a2f8cc
--- /dev/null
+++ b/src/dlt/gateway/legacy/config/connection-org1.json
@@ -0,0 +1,73 @@
+{
+    "name": "test-network-org1",
+    "version": "1.0.0",
+    "client": {
+        "organization": "Org1",
+        "connection": {
+            "timeout": {
+                "peer": {
+                    "endorser": "300"
+                }
+            }
+        }
+    },
+    "organizations": {
+        "Org1": {
+            "mspid": "Org1MSP",
+            "peers": [
+                "peer0.org1.example.com"
+            ],
+            "certificateAuthorities": [
+                "ca.org1.example.com"
+            ]
+        }
+    },
+    "peers": {
+        "peer0.org1.example.com": {
+            "url": "grpcs://teraflow.nlehd.de:7051",
+            "tlsCACerts": {
+                "pem": "-----BEGIN CERTIFICATE-----\nMIICJzCCAc2gAwIBAgIUb5gDMfVeVdQjFkK3uC8LtlogN+gwCgYIKoZIzj0EAwIw\ncDELMAkGA1UEBhMCVVMxFzAVBgNVBAgTDk5vcnRoIENhcm9saW5hMQ8wDQYDVQQH\nEwZEdXJoYW0xGTAXBgNVBAoTEG9yZzEuZXhhbXBsZS5jb20xHDAaBgNVBAMTE2Nh\nLm9yZzEuZXhhbXBsZS5jb20wHhcNMjIwOTI3MDgzMDAwWhcNMzcwOTIzMDgzMDAw\nWjBwMQswCQYDVQQGEwJVUzEXMBUGA1UECBMOTm9ydGggQ2Fyb2xpbmExDzANBgNV\nBAcTBkR1cmhhbTEZMBcGA1UEChMQb3JnMS5leGFtcGxlLmNvbTEcMBoGA1UEAxMT\nY2Eub3JnMS5leGFtcGxlLmNvbTBZMBMGByqGSM49AgEGCCqGSM49AwEHA0IABDC3\nspCTT3pjfFXxkX/SFuBgWRiceR8rSoCNQOnIPeNGZK8xl2Zr7VuY06gqy9c+ecSU\nPUWaXiCQxiLgZuS6TOWjRTBDMA4GA1UdDwEB/wQEAwIBBjASBgNVHRMBAf8ECDAG\nAQH/AgEBMB0GA1UdDgQWBBRFWSc7GZqcJJyJjXSEspzgAYInGzAKBggqhkjOPQQD\nAgNIADBFAiEAodqc+adkiMuU6iv1IF8uJ/nMQbvMGoP3pb2827QzDosCICOw6W+y\nuH03H3RO6KhOcS1ZzPjspyjrcC+dwzYX4DpW\n-----END CERTIFICATE-----\n"
+            },
+            "grpcOptions": {
+                "ssl-target-name-override": "peer0.org1.example.com",
+                "hostnameOverride": "peer0.org1.example.com"
+            }
+        },
+        "peer0.org2.example.com": {
+            "url": "grpcs://teraflow.nlehd.de:9051",
+            "tlsCACerts": {
+                "pem": "-----BEGIN CERTIFICATE-----\nMIICHjCCAcWgAwIBAgIUL48scgv9ItATkBjSNhzYDjLUDsAwCgYIKoZIzj0EAwIw\nbDELMAkGA1UEBhMCVUsxEjAQBgNVBAgTCUhhbXBzaGlyZTEQMA4GA1UEBxMHSHVy\nc2xleTEZMBcGA1UEChMQb3JnMi5leGFtcGxlLmNvbTEcMBoGA1UEAxMTY2Eub3Jn\nMi5leGFtcGxlLmNvbTAeFw0yMjA5MjcwODMwMDBaFw0zNzA5MjMwODMwMDBaMGwx\nCzAJBgNVBAYTAlVLMRIwEAYDVQQIEwlIYW1wc2hpcmUxEDAOBgNVBAcTB0h1cnNs\nZXkxGTAXBgNVBAoTEG9yZzIuZXhhbXBsZS5jb20xHDAaBgNVBAMTE2NhLm9yZzIu\nZXhhbXBsZS5jb20wWTATBgcqhkjOPQIBBggqhkjOPQMBBwNCAAQ5qz8FfrEQ5S08\nr/avPyTrF2grXj5L4DnbvF4YEZ5Usnbm8Svovu7PO8uiVcwT5vrt6ssOdpBFZYu3\nNndpojnYo0UwQzAOBgNVHQ8BAf8EBAMCAQYwEgYDVR0TAQH/BAgwBgEB/wIBATAd\nBgNVHQ4EFgQUYcp7axYV9AaIptYQqhiCL0VDmXQwCgYIKoZIzj0EAwIDRwAwRAIg\nWT1V8/6flUPNcBkmbtEEKf83k7+6sR9k1a2wtVeJFnQCIE0ZSIL3k0dKQydQBpiz\nPcZZUULvQivcMlIsw5+mjIGc\n-----END CERTIFICATE-----\n"
+            },
+            "grpcOptions": {
+                "ssl-target-name-override": "peer0.org2.example.com",
+                "hostnameOverride": "peer0.org2.example.com"
+            }
+        }
+    },
+    "certificateAuthorities": {
+        "ca.org1.example.com": {
+            "url": "https://teraflow.nlehd.de:7054",
+            "caName": "ca-org1",
+            "tlsCACerts": {
+                "pem": [
+                    "-----BEGIN CERTIFICATE-----\nMIICJzCCAc2gAwIBAgIUb5gDMfVeVdQjFkK3uC8LtlogN+gwCgYIKoZIzj0EAwIw\ncDELMAkGA1UEBhMCVVMxFzAVBgNVBAgTDk5vcnRoIENhcm9saW5hMQ8wDQYDVQQH\nEwZEdXJoYW0xGTAXBgNVBAoTEG9yZzEuZXhhbXBsZS5jb20xHDAaBgNVBAMTE2Nh\nLm9yZzEuZXhhbXBsZS5jb20wHhcNMjIwOTI3MDgzMDAwWhcNMzcwOTIzMDgzMDAw\nWjBwMQswCQYDVQQGEwJVUzEXMBUGA1UECBMOTm9ydGggQ2Fyb2xpbmExDzANBgNV\nBAcTBkR1cmhhbTEZMBcGA1UEChMQb3JnMS5leGFtcGxlLmNvbTEcMBoGA1UEAxMT\nY2Eub3JnMS5leGFtcGxlLmNvbTBZMBMGByqGSM49AgEGCCqGSM49AwEHA0IABDC3\nspCTT3pjfFXxkX/SFuBgWRiceR8rSoCNQOnIPeNGZK8xl2Zr7VuY06gqy9c+ecSU\nPUWaXiCQxiLgZuS6TOWjRTBDMA4GA1UdDwEB/wQEAwIBBjASBgNVHRMBAf8ECDAG\nAQH/AgEBMB0GA1UdDgQWBBRFWSc7GZqcJJyJjXSEspzgAYInGzAKBggqhkjOPQQD\nAgNIADBFAiEAodqc+adkiMuU6iv1IF8uJ/nMQbvMGoP3pb2827QzDosCICOw6W+y\nuH03H3RO6KhOcS1ZzPjspyjrcC+dwzYX4DpW\n-----END CERTIFICATE-----\n"
+                ]
+            },
+            "httpOptions": {
+                "verify": false
+            }
+        }
+    },
+    "orderers": {
+        "orderer0.example.com": {
+            "url": "grpcs://teraflow.nlehd.de:7050",
+            "tlsCACerts": {
+                "pem": "-----BEGIN CERTIFICATE-----\nMIICCzCCAbGgAwIBAgIUdZQo3q4OqyxIkidmAV4QkewCylIwCgYIKoZIzj0EAwIw\nYjELMAkGA1UEBhMCVVMxETAPBgNVBAgTCE5ldyBZb3JrMREwDwYDVQQHEwhOZXcg\nWW9yazEUMBIGA1UEChMLZXhhbXBsZS5jb20xFzAVBgNVBAMTDmNhLmV4YW1wbGUu\nY29tMB4XDTIyMDkyNzA4MzAwMFoXDTM3MDkyMzA4MzAwMFowYjELMAkGA1UEBhMC\nVVMxETAPBgNVBAgTCE5ldyBZb3JrMREwDwYDVQQHEwhOZXcgWW9yazEUMBIGA1UE\nChMLZXhhbXBsZS5jb20xFzAVBgNVBAMTDmNhLmV4YW1wbGUuY29tMFkwEwYHKoZI\nzj0CAQYIKoZIzj0DAQcDQgAERR0UzsHSFoyON+9Noxmk1IhnTvSdLWGgEpEwrqVr\n5DwitkeJwRWq134JBTmXuZzsUG87oN6Hr94XAEe4j9Zq8qNFMEMwDgYDVR0PAQH/\nBAQDAgEGMBIGA1UdEwEB/wQIMAYBAf8CAQEwHQYDVR0OBBYEFN8XsELp/X0akrlJ\nY3/BWo2jZS3cMAoGCCqGSM49BAMCA0gAMEUCIQCZYYXW/0h3Kq4BmROpOHfrondg\nopf5LndeujYlH3i8tQIgCtpTQiDXZd+IAUduRmn7a46CwJSbjYbXFVX5vumIbE4=\n-----END CERTIFICATE-----\n"
+            },
+            "grpcOptions": {
+                "ssl-target-name-override": "orderer0.example.com",
+                "hostnameOverride": "orderer0.example.com"
+            }
+        }
+    }
+}
diff --git a/src/dlt/gateway/legacy/gradle.properties b/src/dlt/gateway/legacy/gradle.properties
new file mode 100644
index 0000000000000000000000000000000000000000..7fc6f1ff272ee12d8be9694acdaa36b4284eefdb
--- /dev/null
+++ b/src/dlt/gateway/legacy/gradle.properties
@@ -0,0 +1 @@
+kotlin.code.style=official
diff --git a/src/dlt/gateway/legacy/gradle/wrapper/gradle-wrapper.jar b/src/dlt/gateway/legacy/gradle/wrapper/gradle-wrapper.jar
new file mode 100644
index 0000000000000000000000000000000000000000..7454180f2ae8848c63b8b4dea2cb829da983f2fa
Binary files /dev/null and b/src/dlt/gateway/legacy/gradle/wrapper/gradle-wrapper.jar differ
diff --git a/src/dlt/gateway/legacy/gradle/wrapper/gradle-wrapper.properties b/src/dlt/gateway/legacy/gradle/wrapper/gradle-wrapper.properties
new file mode 100644
index 0000000000000000000000000000000000000000..69a9715077f4fe68764b2e50867736b0c7f015a2
--- /dev/null
+++ b/src/dlt/gateway/legacy/gradle/wrapper/gradle-wrapper.properties
@@ -0,0 +1,5 @@
+distributionBase=GRADLE_USER_HOME
+distributionPath=wrapper/dists
+distributionUrl=https\://services.gradle.org/distributions/gradle-7.1-bin.zip
+zipStoreBase=GRADLE_USER_HOME
+zipStorePath=wrapper/dists
diff --git a/src/dlt/gateway/legacy/gradlew b/src/dlt/gateway/legacy/gradlew
new file mode 100755
index 0000000000000000000000000000000000000000..744e882ed57263a19bf3a504977da292d009345f
--- /dev/null
+++ b/src/dlt/gateway/legacy/gradlew
@@ -0,0 +1,185 @@
+#!/usr/bin/env sh
+
+#
+# Copyright 2015 the original author or authors.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+##############################################################################
+##
+##  Gradle start up script for UN*X
+##
+##############################################################################
+
+# Attempt to set APP_HOME
+# Resolve links: $0 may be a link
+PRG="$0"
+# Need this for relative symlinks.
+while [ -h "$PRG" ] ; do
+    ls=`ls -ld "$PRG"`
+    link=`expr "$ls" : '.*-> \(.*\)$'`
+    if expr "$link" : '/.*' > /dev/null; then
+        PRG="$link"
+    else
+        PRG=`dirname "$PRG"`"/$link"
+    fi
+done
+SAVED="`pwd`"
+cd "`dirname \"$PRG\"`/" >/dev/null
+APP_HOME="`pwd -P`"
+cd "$SAVED" >/dev/null
+
+APP_NAME="Gradle"
+APP_BASE_NAME=`basename "$0"`
+
+# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
+
+# Use the maximum available, or set MAX_FD != -1 to use that value.
+MAX_FD="maximum"
+
+warn () {
+    echo "$*"
+}
+
+die () {
+    echo
+    echo "$*"
+    echo
+    exit 1
+}
+
+# OS specific support (must be 'true' or 'false').
+cygwin=false
+msys=false
+darwin=false
+nonstop=false
+case "`uname`" in
+  CYGWIN* )
+    cygwin=true
+    ;;
+  Darwin* )
+    darwin=true
+    ;;
+  MSYS* | MINGW* )
+    msys=true
+    ;;
+  NONSTOP* )
+    nonstop=true
+    ;;
+esac
+
+CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
+
+
+# Determine the Java command to use to start the JVM.
+if [ -n "$JAVA_HOME" ] ; then
+    if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
+        # IBM's JDK on AIX uses strange locations for the executables
+        JAVACMD="$JAVA_HOME/jre/sh/java"
+    else
+        JAVACMD="$JAVA_HOME/bin/java"
+    fi
+    if [ ! -x "$JAVACMD" ] ; then
+        die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+    fi
+else
+    JAVACMD="java"
+    which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+fi
+
+# Increase the maximum file descriptors if we can.
+if [ "$cygwin" = "false" -a "$darwin" = "false" -a "$nonstop" = "false" ] ; then
+    MAX_FD_LIMIT=`ulimit -H -n`
+    if [ $? -eq 0 ] ; then
+        if [ "$MAX_FD" = "maximum" -o "$MAX_FD" = "max" ] ; then
+            MAX_FD="$MAX_FD_LIMIT"
+        fi
+        ulimit -n $MAX_FD
+        if [ $? -ne 0 ] ; then
+            warn "Could not set maximum file descriptor limit: $MAX_FD"
+        fi
+    else
+        warn "Could not query maximum file descriptor limit: $MAX_FD_LIMIT"
+    fi
+fi
+
+# For Darwin, add options to specify how the application appears in the dock
+if $darwin; then
+    GRADLE_OPTS="$GRADLE_OPTS \"-Xdock:name=$APP_NAME\" \"-Xdock:icon=$APP_HOME/media/gradle.icns\""
+fi
+
+# For Cygwin or MSYS, switch paths to Windows format before running java
+if [ "$cygwin" = "true" -o "$msys" = "true" ] ; then
+    APP_HOME=`cygpath --path --mixed "$APP_HOME"`
+    CLASSPATH=`cygpath --path --mixed "$CLASSPATH"`
+
+    JAVACMD=`cygpath --unix "$JAVACMD"`
+
+    # We build the pattern for arguments to be converted via cygpath
+    ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null`
+    SEP=""
+    for dir in $ROOTDIRSRAW ; do
+        ROOTDIRS="$ROOTDIRS$SEP$dir"
+        SEP="|"
+    done
+    OURCYGPATTERN="(^($ROOTDIRS))"
+    # Add a user-defined pattern to the cygpath arguments
+    if [ "$GRADLE_CYGPATTERN" != "" ] ; then
+        OURCYGPATTERN="$OURCYGPATTERN|($GRADLE_CYGPATTERN)"
+    fi
+    # Now convert the arguments - kludge to limit ourselves to /bin/sh
+    i=0
+    for arg in "$@" ; do
+        CHECK=`echo "$arg"|egrep -c "$OURCYGPATTERN" -`
+        CHECK2=`echo "$arg"|egrep -c "^-"`                                 ### Determine if an option
+
+        if [ $CHECK -ne 0 ] && [ $CHECK2 -eq 0 ] ; then                    ### Added a condition
+            eval `echo args$i`=`cygpath --path --ignore --mixed "$arg"`
+        else
+            eval `echo args$i`="\"$arg\""
+        fi
+        i=`expr $i + 1`
+    done
+    case $i in
+        0) set -- ;;
+        1) set -- "$args0" ;;
+        2) set -- "$args0" "$args1" ;;
+        3) set -- "$args0" "$args1" "$args2" ;;
+        4) set -- "$args0" "$args1" "$args2" "$args3" ;;
+        5) set -- "$args0" "$args1" "$args2" "$args3" "$args4" ;;
+        6) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" ;;
+        7) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" ;;
+        8) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" ;;
+        9) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" "$args8" ;;
+    esac
+fi
+
+# Escape application args
+save () {
+    for i do printf %s\\n "$i" | sed "s/'/'\\\\''/g;1s/^/'/;\$s/\$/' \\\\/" ; done
+    echo " "
+}
+APP_ARGS=`save "$@"`
+
+# Collect all arguments for the java command, following the shell quoting and substitution rules
+eval set -- $DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS "\"-Dorg.gradle.appname=$APP_BASE_NAME\"" -classpath "\"$CLASSPATH\"" org.gradle.wrapper.GradleWrapperMain "$APP_ARGS"
+
+exec "$JAVACMD" "$@"
diff --git a/src/dlt/gateway/legacy/gradlew.bat b/src/dlt/gateway/legacy/gradlew.bat
new file mode 100644
index 0000000000000000000000000000000000000000..ac1b06f93825db68fb0c0b5150917f340eaa5d02
--- /dev/null
+++ b/src/dlt/gateway/legacy/gradlew.bat
@@ -0,0 +1,89 @@
+@rem
+@rem Copyright 2015 the original author or authors.
+@rem
+@rem Licensed under the Apache License, Version 2.0 (the "License");
+@rem you may not use this file except in compliance with the License.
+@rem You may obtain a copy of the License at
+@rem
+@rem      https://www.apache.org/licenses/LICENSE-2.0
+@rem
+@rem Unless required by applicable law or agreed to in writing, software
+@rem distributed under the License is distributed on an "AS IS" BASIS,
+@rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+@rem See the License for the specific language governing permissions and
+@rem limitations under the License.
+@rem
+
+@if "%DEBUG%" == "" @echo off
+@rem ##########################################################################
+@rem
+@rem  Gradle startup script for Windows
+@rem
+@rem ##########################################################################
+
+@rem Set local scope for the variables with windows NT shell
+if "%OS%"=="Windows_NT" setlocal
+
+set DIRNAME=%~dp0
+if "%DIRNAME%" == "" set DIRNAME=.
+set APP_BASE_NAME=%~n0
+set APP_HOME=%DIRNAME%
+
+@rem Resolve any "." and ".." in APP_HOME to make it shorter.
+for %%i in ("%APP_HOME%") do set APP_HOME=%%~fi
+
+@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+set DEFAULT_JVM_OPTS="-Xmx64m" "-Xms64m"
+
+@rem Find java.exe
+if defined JAVA_HOME goto findJavaFromJavaHome
+
+set JAVA_EXE=java.exe
+%JAVA_EXE% -version >NUL 2>&1
+if "%ERRORLEVEL%" == "0" goto execute
+
+echo.
+echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:findJavaFromJavaHome
+set JAVA_HOME=%JAVA_HOME:"=%
+set JAVA_EXE=%JAVA_HOME%/bin/java.exe
+
+if exist "%JAVA_EXE%" goto execute
+
+echo.
+echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME%
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:execute
+@rem Setup the command line
+
+set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
+
+
+@rem Execute Gradle
+"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %*
+
+:end
+@rem End local scope for the variables with windows NT shell
+if "%ERRORLEVEL%"=="0" goto mainEnd
+
+:fail
+rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
+rem the _cmd.exe /c_ return code!
+if  not "" == "%GRADLE_EXIT_CONSOLE%" exit 1
+exit /b 1
+
+:mainEnd
+if "%OS%"=="Windows_NT" endlocal
+
+:omega
diff --git a/src/dlt/gateway/legacy/settings.gradle.kts b/src/dlt/gateway/legacy/settings.gradle.kts
new file mode 100644
index 0000000000000000000000000000000000000000..77fa0f0b22918cf306f0e5f07506a35e492142b4
--- /dev/null
+++ b/src/dlt/gateway/legacy/settings.gradle.kts
@@ -0,0 +1,19 @@
+/*
+ * Copyright 2022-2023 ETSI TeraFlowSDN - TFS OSG (https://tfs.etsi.org/)
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+
+rootProject.name = "gateway"
+
diff --git a/src/dlt/gateway/legacy/src/main/kotlin/Main.kt b/src/dlt/gateway/legacy/src/main/kotlin/Main.kt
new file mode 100644
index 0000000000000000000000000000000000000000..c57c9e980853e84d3c10551588dc8d94c14ad40e
--- /dev/null
+++ b/src/dlt/gateway/legacy/src/main/kotlin/Main.kt
@@ -0,0 +1,161 @@
+//     NEC Laboratories Europe GmbH
+//
+//     PROPRIETARY INFORMATION
+//
+// The software and its source code contain valuable trade secrets and
+// shall be maintained in confidence and treated as confidential
+// information. The software may only be used for evaluation and/or
+// testing purposes, unless otherwise explicitly stated in a written
+// agreement with NEC Laboratories Europe GmbH.
+//
+// Any unauthorized publication, transfer to third parties or
+// duplication of the object or source code - either totally or in
+// part - is strictly prohibited.
+//
+//          Copyright (c) 2022 NEC Laboratories Europe GmbH
+//          All Rights Reserved.
+//
+// Authors: Konstantin Munichev <konstantin.munichev@neclab.eu>
+//
+//
+// NEC Laboratories Europe GmbH DISCLAIMS ALL WARRANTIES, EITHER
+// EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO IMPLIED WARRANTIES
+// OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE AND THE
+// WARRANTY AGAINST LATENT DEFECTS, WITH RESPECT TO THE PROGRAM AND
+// THE ACCOMPANYING DOCUMENTATION.
+//
+// NO LIABILITIES FOR CONSEQUENTIAL DAMAGES: IN NO EVENT SHALL NEC
+// Laboratories Europe GmbH or ANY OF ITS SUBSIDIARIES BE LIABLE FOR
+// ANY DAMAGES WHATSOEVER (INCLUDING, WITHOUT LIMITATION, DAMAGES FOR
+// LOSS OF BUSINESS PROFITS, BUSINESS INTERRUPTION, LOSS OF
+// INFORMATION, OR OTHER PECUNIARY LOSS AND INDIRECT, CONSEQUENTIAL,
+// INCIDENTAL, ECONOMIC OR PUNITIVE DAMAGES) ARISING OUT OF THE USE OF
+// OR INABILITY TO USE THIS PROGRAM, EVEN IF NEC Laboratories Europe
+// GmbH HAS BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGES.
+//
+// THIS HEADER MAY NOT BE EXTRACTED OR MODIFIED IN ANY WAY.
+
+import context.ContextOuterClass
+import io.grpc.ManagedChannel
+import io.grpc.ManagedChannelBuilder
+import kotlinx.coroutines.GlobalScope
+import kotlinx.coroutines.launch
+import kotlinx.coroutines.runBlocking
+import dlt.DltGateway
+import dlt.DltGatewayServiceGrpcKt
+import java.io.Closeable
+import java.util.*
+import java.util.concurrent.TimeUnit
+
+class DltServiceClient(private val channel: ManagedChannel) : Closeable {
+    private val stub: DltGatewayServiceGrpcKt.DltGatewayServiceCoroutineStub =
+        DltGatewayServiceGrpcKt.DltGatewayServiceCoroutineStub(channel)
+
+    suspend fun putData(data: DltGateway.DltRecord) {
+        println("Sending record ${data.recordId}...")
+        val response = stub.recordToDlt(data)
+        println("Response: ${response.recordId}")
+    }
+
+    suspend fun getData(id: DltGateway.DltRecordId) {
+        println("Requesting record $id...")
+        val response = stub.getFromDlt(id)
+        println("Got data: $response")
+    }
+
+    fun subscribe(filter: DltGateway.DltRecordSubscription) {
+        val subscription = stub.subscribeToDlt(filter)
+        GlobalScope.launch {
+            subscription.collect {
+                println("Got subscription event")
+                println(it)
+            }
+        }
+    }
+
+    override fun close() {
+        channel.shutdown().awaitTermination(5, TimeUnit.SECONDS)
+    }
+}
+
+
+fun main() = runBlocking {
+    val port = 50051
+    val channel = ManagedChannelBuilder.forAddress("localhost", port).usePlaintext().build()
+
+    val client = DltServiceClient(channel)
+
+    val domainUuid = UUID.randomUUID().toString()
+    val recordUuid = UUID.randomUUID().toString()
+    println("New domain uuid $domainUuid")
+    println("New record uuid $recordUuid")
+
+    val id = DltGateway.DltRecordId.newBuilder()
+        .setDomainUuid(
+            ContextOuterClass.Uuid.newBuilder()
+                .setUuid(domainUuid)
+        )
+        .setRecordUuid(
+            ContextOuterClass.Uuid.newBuilder()
+                .setUuid(recordUuid)
+        )
+        .setType(DltGateway.DltRecordTypeEnum.DLTRECORDTYPE_SERVICE)
+        .build()
+
+    val subscription = DltGateway.DltRecordSubscription.newBuilder()
+        .addType(DltGateway.DltRecordTypeEnum.DLTRECORDTYPE_CONTEXT)
+        .addType(DltGateway.DltRecordTypeEnum.DLTRECORDTYPE_LINK)
+        .addType(DltGateway.DltRecordTypeEnum.DLTRECORDTYPE_SERVICE)
+        .addOperation(DltGateway.DltRecordOperationEnum.DLTRECORDOPERATION_ADD)
+        .addOperation(DltGateway.DltRecordOperationEnum.DLTRECORDOPERATION_UPDATE)
+        .addOperation(DltGateway.DltRecordOperationEnum.DLTRECORDOPERATION_DELETE)
+        .build()
+
+    client.subscribe(subscription)
+
+    Thread.sleep(5000)
+
+    val data = DltGateway.DltRecord.newBuilder()
+        .setRecordId(id)
+        .setOperation(DltGateway.DltRecordOperationEnum.DLTRECORDOPERATION_ADD)
+        .setDataJson("\"{\"device_config\": {\"config_rules\": []}, \"device_drivers\": []," +
+                "\"device_endpoints\": [], \"device_id\": {\"device_uuid\": {\"uuid\": \"dev-12345\"}}," +
+                "\"device_operational_status\": \"DEVICEOPERATIONALSTATUS_ENABLED\"," +
+                "\"device_type\": \"packet-router\"}\", \"operation\": \"DLTRECORDOPERATION_ADD\"," +
+                "\"record_id\": {\"domain_uuid\": {\"uuid\": \"tfs-a\"}, \"record_uuid\": {\"uuid\": \"dev-12345\"}," +
+                "\"type\": \"DLTRECORDTYPE_DEVICE\"}")
+        .build()
+
+    println("sending new record")
+    client.putData(data)
+    client.getData(id)
+
+    Thread.sleep(5000)
+
+    val updateData = DltGateway.DltRecord.newBuilder()
+        .setRecordId(id)
+        .setOperation(DltGateway.DltRecordOperationEnum.DLTRECORDOPERATION_UPDATE)
+        .setDataJson("{\"name\": \"test\"}")
+        .build()
+
+    println("updating record")
+    client.putData(updateData)
+    client.getData(id)
+
+    Thread.sleep(5000)
+
+    val removeData = DltGateway.DltRecord.newBuilder()
+        .setRecordId(id)
+        .setOperation(DltGateway.DltRecordOperationEnum.DLTRECORDOPERATION_DELETE)
+        .setDataJson("{\"name\": \"test\"}")
+        .build()
+
+    println("removing record")
+    client.putData(removeData)
+    try {
+        client.getData(id)
+    } catch (e: Exception) {
+        println(e.toString())
+    }
+    Thread.sleep(5000)
+}
diff --git a/src/dlt/gateway/legacy/src/main/kotlin/fabric/ConnectGateway.kt b/src/dlt/gateway/legacy/src/main/kotlin/fabric/ConnectGateway.kt
new file mode 100644
index 0000000000000000000000000000000000000000..00ec40d57dcd8bc4da18f30a6bed6f1d2a032b48
--- /dev/null
+++ b/src/dlt/gateway/legacy/src/main/kotlin/fabric/ConnectGateway.kt
@@ -0,0 +1,54 @@
+//     NEC Laboratories Europe GmbH
+//
+//     PROPRIETARY INFORMATION
+//
+// The software and its source code contain valuable trade secrets and
+// shall be maintained in confidence and treated as confidential
+// information. The software may only be used for evaluation and/or
+// testing purposes, unless otherwise explicitly stated in a written
+// agreement with NEC Laboratories Europe GmbH.
+//
+// Any unauthorized publication, transfer to third parties or
+// duplication of the object or source code - either totally or in
+// part - is strictly prohibited.
+//
+//          Copyright (c) 2022 NEC Laboratories Europe GmbH
+//          All Rights Reserved.
+//
+// Authors: Konstantin Munichev <konstantin.munichev@neclab.eu>
+//
+//
+// NEC Laboratories Europe GmbH DISCLAIMS ALL WARRANTIES, EITHER
+// EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO IMPLIED WARRANTIES
+// OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE AND THE
+// WARRANTY AGAINST LATENT DEFECTS, WITH RESPECT TO THE PROGRAM AND
+// THE ACCOMPANYING DOCUMENTATION.
+//
+// NO LIABILITIES FOR CONSEQUENTIAL DAMAGES: IN NO EVENT SHALL NEC
+// Laboratories Europe GmbH or ANY OF ITS SUBSIDIARIES BE LIABLE FOR
+// ANY DAMAGES WHATSOEVER (INCLUDING, WITHOUT LIMITATION, DAMAGES FOR
+// LOSS OF BUSINESS PROFITS, BUSINESS INTERRUPTION, LOSS OF
+// INFORMATION, OR OTHER PECUNIARY LOSS AND INDIRECT, CONSEQUENTIAL,
+// INCIDENTAL, ECONOMIC OR PUNITIVE DAMAGES) ARISING OUT OF THE USE OF
+// OR INABILITY TO USE THIS PROGRAM, EVEN IF NEC Laboratories Europe
+// GmbH HAS BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGES.
+//
+// THIS HEADER MAY NOT BE EXTRACTED OR MODIFIED IN ANY WAY.
+
+package fabric
+
+import org.hyperledger.fabric.gateway.Contract
+import org.hyperledger.fabric.gateway.Gateway
+import org.hyperledger.fabric.gateway.Wallet
+import java.nio.file.Paths
+
+// helper function for getting connected to the gateway
+fun getContract(config: proto.Config.DltConfig, wallet: Wallet): Contract {
+    // load a CCP
+    val networkConfigPath = Paths.get(config.connectionFile)
+    val builder = Gateway.createBuilder()
+    builder.identity(wallet, config.user).networkConfig(networkConfigPath).discovery(true)
+    val gateway = builder.connect()
+    val network = gateway.getNetwork(config.channel)
+    return network.getContract(config.contract)
+}
\ No newline at end of file
diff --git a/src/dlt/gateway/legacy/src/main/kotlin/fabric/EnrollAdmin.kt b/src/dlt/gateway/legacy/src/main/kotlin/fabric/EnrollAdmin.kt
new file mode 100644
index 0000000000000000000000000000000000000000..b4420271961f659149392614ec2e89b8c10a7da9
--- /dev/null
+++ b/src/dlt/gateway/legacy/src/main/kotlin/fabric/EnrollAdmin.kt
@@ -0,0 +1,29 @@
+/*
+ * Copyright IBM Corp. All Rights Reserved.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package fabric
+
+import org.hyperledger.fabric.gateway.Identities
+import org.hyperledger.fabric.gateway.Wallet
+import org.hyperledger.fabric_ca.sdk.EnrollmentRequest
+import org.hyperledger.fabric_ca.sdk.HFCAClient
+
+fun enrollAdmin(config: proto.Config.DltConfig, caClient: HFCAClient, wallet: Wallet) {
+    // Check to see if we've already enrolled the admin user.
+    if (wallet.get(config.caAdmin) != null) {
+        println("An identity for the admin user ${config.caAdmin} already exists in the wallet")
+        return
+    }
+
+    // Enroll the admin user, and import the new identity into the wallet.
+    val enrollmentRequestTLS = EnrollmentRequest()
+    enrollmentRequestTLS.addHost(config.caUrl)
+    enrollmentRequestTLS.profile = "tls"
+    val enrollment = caClient.enroll(config.caAdmin, config.caAdminSecret, enrollmentRequestTLS)
+    val user = Identities.newX509Identity(config.msp, enrollment)
+    wallet.put(config.caAdmin, user)
+    println("Successfully enrolled user ${config.caAdmin} and imported it into the wallet")
+}
diff --git a/src/dlt/gateway/legacy/src/main/kotlin/fabric/FabricConnector.kt b/src/dlt/gateway/legacy/src/main/kotlin/fabric/FabricConnector.kt
new file mode 100644
index 0000000000000000000000000000000000000000..af6592be93c86e316a64cd23edd46bbbdc240cfd
--- /dev/null
+++ b/src/dlt/gateway/legacy/src/main/kotlin/fabric/FabricConnector.kt
@@ -0,0 +1,178 @@
+//     NEC Laboratories Europe GmbH
+//
+//     PROPRIETARY INFORMATION
+//
+// The software and its source code contain valuable trade secrets and
+// shall be maintained in confidence and treated as confidential
+// information. The software may only be used for evaluation and/or
+// testing purposes, unless otherwise explicitly stated in a written
+// agreement with NEC Laboratories Europe GmbH.
+//
+// Any unauthorized publication, transfer to third parties or
+// duplication of the object or source code - either totally or in
+// part - is strictly prohibited.
+//
+//          Copyright (c) 2022 NEC Laboratories Europe GmbH
+//          All Rights Reserved.
+//
+// Authors: Konstantin Munichev <konstantin.munichev@neclab.eu>
+//
+//
+// NEC Laboratories Europe GmbH DISCLAIMS ALL WARRANTIES, EITHER
+// EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO IMPLIED WARRANTIES
+// OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE AND THE
+// WARRANTY AGAINST LATENT DEFECTS, WITH RESPECT TO THE PROGRAM AND
+// THE ACCOMPANYING DOCUMENTATION.
+//
+// NO LIABILITIES FOR CONSEQUENTIAL DAMAGES: IN NO EVENT SHALL NEC
+// Laboratories Europe GmbH or ANY OF ITS SUBSIDIARIES BE LIABLE FOR
+// ANY DAMAGES WHATSOEVER (INCLUDING, WITHOUT LIMITATION, DAMAGES FOR
+// LOSS OF BUSINESS PROFITS, BUSINESS INTERRUPTION, LOSS OF
+// INFORMATION, OR OTHER PECUNIARY LOSS AND INDIRECT, CONSEQUENTIAL,
+// INCIDENTAL, ECONOMIC OR PUNITIVE DAMAGES) ARISING OUT OF THE USE OF
+// OR INABILITY TO USE THIS PROGRAM, EVEN IF NEC Laboratories Europe
+// GmbH HAS BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGES.
+//
+// THIS HEADER MAY NOT BE EXTRACTED OR MODIFIED IN ANY WAY.
+
+package fabric
+
+import context.ContextOuterClass
+import dlt.DltGateway.DltRecord
+import dlt.DltGateway.DltRecordEvent
+import kotlinx.coroutines.channels.Channel
+import kotlinx.coroutines.runBlocking
+import org.hyperledger.fabric.gateway.Contract
+import org.hyperledger.fabric.gateway.ContractEvent
+import org.hyperledger.fabric.gateway.Wallet
+import org.hyperledger.fabric.gateway.Wallets
+import org.hyperledger.fabric.sdk.security.CryptoSuiteFactory
+import org.hyperledger.fabric_ca.sdk.HFCAClient
+import proto.Config
+import java.nio.file.Paths
+import java.util.*
+import java.util.function.Consumer
+
+class FabricConnector(val config: Config.DltConfig) {
+    private val caClient: HFCAClient
+    private val wallet: Wallet
+    private val contract: Contract
+
+    private val channels: MutableList<Channel<DltRecordEvent>> = mutableListOf()
+
+    private val encoder: Base64.Encoder = Base64.getEncoder()
+    private val decoder: Base64.Decoder = Base64.getDecoder()
+
+    init {
+        // Create a CA client for interacting with the CA.
+        val props = Properties()
+        props["pemFile"] = config.caCertFile
+        props["allowAllHostNames"] = "true"
+        caClient = HFCAClient.createNewInstance(config.caUrl, props)
+        val cryptoSuite = CryptoSuiteFactory.getDefault().cryptoSuite
+        caClient.cryptoSuite = cryptoSuite
+
+        // Create a wallet for managing identities
+        wallet = Wallets.newFileSystemWallet(Paths.get(config.wallet))
+        contract = connect()
+
+        fabricSubscribe()
+    }
+
+    private fun fabricSubscribe() {
+        val consumer = Consumer { event: ContractEvent? ->
+            run {
+                println("new event detected")
+                val record = DltRecord.parseFrom(decoder.decode(event?.payload?.get()))
+                println(record.recordId.recordUuid)
+                val eventType: ContextOuterClass.EventTypeEnum = when (event?.name) {
+                    "Add" -> ContextOuterClass.EventTypeEnum.EVENTTYPE_CREATE
+                    "Update" -> ContextOuterClass.EventTypeEnum.EVENTTYPE_UPDATE
+                    "Remove" -> ContextOuterClass.EventTypeEnum.EVENTTYPE_REMOVE
+                    else -> ContextOuterClass.EventTypeEnum.EVENTTYPE_UNDEFINED
+                }
+                val pbEvent = DltRecordEvent.newBuilder()
+                    .setEvent(
+                        ContextOuterClass.Event.newBuilder()
+                            .setTimestamp(
+                                ContextOuterClass.Timestamp.newBuilder()
+                                    .setTimestamp(System.currentTimeMillis().toDouble())
+                            )
+                            .setEventType(eventType)
+                    )
+                    .setRecordId(record.recordId)
+                    .build()
+
+                runBlocking {
+                    channels.forEach {
+                        it.trySend(pbEvent)
+                    }
+                }
+            }
+        }
+        contract.addContractListener(consumer)
+    }
+
+    fun connect(): Contract {
+        enrollAdmin(config, caClient, wallet)
+        registerUser(config, caClient, wallet)
+        return getContract(config, wallet)
+    }
+
+    fun putData(record: DltRecord): String {
+        println(record.toString())
+
+        try {
+            contract.submitTransaction(
+                "AddRecord",
+                record.recordId.recordUuid.uuid,
+                encoder.encodeToString(record.toByteArray())
+            )
+        } catch (e: Exception) {
+            println(e.toString())
+            return e.toString()
+        }
+        return ""
+    }
+
+    fun getData(uuid: String): DltRecord {
+        return try {
+            val result = contract.evaluateTransaction("GetRecord", uuid)
+            DltRecord.parseFrom(decoder.decode(result))
+        } catch (e: Exception) {
+            println(e.toString())
+            DltRecord.getDefaultInstance()
+        }
+    }
+
+    fun updateData(record: DltRecord): String {
+        try {
+            contract.submitTransaction(
+                "UpdateRecord",
+                record.recordId.recordUuid.uuid,
+                encoder.encodeToString(record.toByteArray())
+            )
+        } catch (e: Exception) {
+            return e.toString()
+        }
+        return ""
+    }
+
+    fun deleteData(record: DltRecord): String {
+        try {
+            contract.submitTransaction(
+                "DeleteRecord",
+                record.recordId.recordUuid.uuid,
+            )
+        } catch (e: Exception) {
+            return e.toString()
+        }
+        return ""
+    }
+
+    fun subscribeForEvents(): Channel<DltRecordEvent> {
+        val produceCh = Channel<DltRecordEvent>()
+        channels.add(produceCh)
+        return produceCh
+    }
+}
\ No newline at end of file
diff --git a/src/dlt/gateway/legacy/src/main/kotlin/fabric/RegisterUser.kt b/src/dlt/gateway/legacy/src/main/kotlin/fabric/RegisterUser.kt
new file mode 100644
index 0000000000000000000000000000000000000000..fb5cc29695427d54ad1350ee92c99b3d31c8ab4c
--- /dev/null
+++ b/src/dlt/gateway/legacy/src/main/kotlin/fabric/RegisterUser.kt
@@ -0,0 +1,65 @@
+/*
+SPDX-License-Identifier: Apache-2.0
+*/
+package fabric
+
+import org.hyperledger.fabric.gateway.Identities
+import org.hyperledger.fabric.gateway.Wallet
+import org.hyperledger.fabric.gateway.X509Identity
+import org.hyperledger.fabric.sdk.Enrollment
+import org.hyperledger.fabric.sdk.User
+import org.hyperledger.fabric_ca.sdk.HFCAClient
+import org.hyperledger.fabric_ca.sdk.RegistrationRequest
+import java.security.PrivateKey
+
+fun registerUser(config: proto.Config.DltConfig, caClient: HFCAClient, wallet: Wallet) {
+    // Check to see if we've already enrolled the user.
+    if (wallet[config.user] != null) {
+        println("An identity for the user ${config.user} already exists in the wallet")
+        return
+    }
+    val adminIdentity = wallet[config.caAdmin] as X509Identity
+    val admin = object : User {
+        override fun getName(): String {
+            return config.caAdmin
+        }
+
+        override fun getRoles(): Set<String>? {
+            return null
+        }
+
+        override fun getAccount(): String? {
+            return null
+        }
+
+        override fun getAffiliation(): String {
+            return config.affiliation
+        }
+
+        override fun getEnrollment(): Enrollment {
+            return object : Enrollment {
+                override fun getKey(): PrivateKey {
+                    return adminIdentity.privateKey
+                }
+
+                override fun getCert(): String {
+                    return Identities.toPemString(adminIdentity.certificate)
+                }
+            }
+        }
+
+        override fun getMspId(): String {
+            return config.msp
+        }
+    }
+
+    // Register the user, enroll the user, and import the new identity into the wallet.
+    val registrationRequest = RegistrationRequest(config.user)
+    registrationRequest.affiliation = config.affiliation
+    registrationRequest.enrollmentID = config.user
+    val enrollmentSecret = caClient.register(registrationRequest, admin)
+    val enrollment = caClient.enroll(config.user, enrollmentSecret)
+    val user = Identities.newX509Identity(config.msp, enrollment)
+    wallet.put(config.user, user)
+    println("Successfully enrolled user ${config.user} and imported it into the wallet")
+}
diff --git a/src/dlt/gateway/legacy/src/main/kotlin/grpc/FabricServer.kt b/src/dlt/gateway/legacy/src/main/kotlin/grpc/FabricServer.kt
new file mode 100644
index 0000000000000000000000000000000000000000..9b4e1f4dc38d80c22847ae213053119b301bdf3d
--- /dev/null
+++ b/src/dlt/gateway/legacy/src/main/kotlin/grpc/FabricServer.kt
@@ -0,0 +1,94 @@
+//     NEC Laboratories Europe GmbH
+//
+//     PROPRIETARY INFORMATION
+//
+// The software and its source code contain valuable trade secrets and
+// shall be maintained in confidence and treated as confidential
+// information. The software may only be used for evaluation and/or
+// testing purposes, unless otherwise explicitly stated in a written
+// agreement with NEC Laboratories Europe GmbH.
+//
+// Any unauthorized publication, transfer to third parties or
+// duplication of the object or source code - either totally or in
+// part - is strictly prohibited.
+//
+//          Copyright (c) 2022 NEC Laboratories Europe GmbH
+//          All Rights Reserved.
+//
+// Authors: Konstantin Munichev <konstantin.munichev@neclab.eu>
+//
+//
+// NEC Laboratories Europe GmbH DISCLAIMS ALL WARRANTIES, EITHER
+// EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO IMPLIED WARRANTIES
+// OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE AND THE
+// WARRANTY AGAINST LATENT DEFECTS, WITH RESPECT TO THE PROGRAM AND
+// THE ACCOMPANYING DOCUMENTATION.
+//
+// NO LIABILITIES FOR CONSEQUENTIAL DAMAGES: IN NO EVENT SHALL NEC
+// Laboratories Europe GmbH or ANY OF ITS SUBSIDIARIES BE LIABLE FOR
+// ANY DAMAGES WHATSOEVER (INCLUDING, WITHOUT LIMITATION, DAMAGES FOR
+// LOSS OF BUSINESS PROFITS, BUSINESS INTERRUPTION, LOSS OF
+// INFORMATION, OR OTHER PECUNIARY LOSS AND INDIRECT, CONSEQUENTIAL,
+// INCIDENTAL, ECONOMIC OR PUNITIVE DAMAGES) ARISING OUT OF THE USE OF
+// OR INABILITY TO USE THIS PROGRAM, EVEN IF NEC Laboratories Europe
+// GmbH HAS BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGES.
+//
+// THIS HEADER MAY NOT BE EXTRACTED OR MODIFIED IN ANY WAY.
+
+package grpc
+
+import fabric.FabricConnector
+import io.grpc.Server
+import io.grpc.ServerBuilder
+import proto.Config
+import kotlin.random.Random
+import kotlin.random.nextUInt
+
+class FabricServer(val port: Int) {
+    private val server: Server
+
+    init {
+        val id = Random.nextUInt()
+        val cfg = Config.DltConfig.newBuilder().setWallet("wallet$id").setConnectionFile("config/connection-org1.json")
+            .setUser("appUser$id")
+            .setChannel("dlt")
+            .setContract("basic").setCaCertFile("config/ca.org1.example.com-cert.pem").setCaUrl("https://teraflow.nlehd.de:7054")
+            .setCaAdmin("admin").setCaAdminSecret("adminpw").setMsp("Org1MSP").setAffiliation("org1.department1")
+            .build()
+        val connector = FabricConnector(cfg)
+
+        val dltService = DLTService(connector)
+        server = ServerBuilder
+            .forPort(port)
+            .addService(dltService)
+            .build()
+
+    }
+
+    fun start() {
+        server.start()
+        println("Server started, listening on $port")
+        Runtime.getRuntime().addShutdownHook(
+            Thread {
+                println("Shutting down...")
+                this@FabricServer.stop()
+                println("Server shut down")
+            }
+        )
+    }
+
+    private fun stop() {
+        server.shutdown()
+    }
+
+    fun blockUntilShutdown() {
+        server.awaitTermination()
+    }
+}
+
+fun main() {
+    val port = 50051
+    val server = FabricServer(port)
+    server.start()
+    server.blockUntilShutdown()
+}
diff --git a/src/dlt/gateway/legacy/src/main/kotlin/grpc/GrpcHandler.kt b/src/dlt/gateway/legacy/src/main/kotlin/grpc/GrpcHandler.kt
new file mode 100644
index 0000000000000000000000000000000000000000..d39c24a1a87aacb32d828dcba8208b34312d7409
--- /dev/null
+++ b/src/dlt/gateway/legacy/src/main/kotlin/grpc/GrpcHandler.kt
@@ -0,0 +1,95 @@
+//     NEC Laboratories Europe GmbH
+//
+//     PROPRIETARY INFORMATION
+//
+// The software and its source code contain valuable trade secrets and
+// shall be maintained in confidence and treated as confidential
+// information. The software may only be used for evaluation and/or
+// testing purposes, unless otherwise explicitly stated in a written
+// agreement with NEC Laboratories Europe GmbH.
+//
+// Any unauthorized publication, transfer to third parties or
+// duplication of the object or source code - either totally or in
+// part - is strictly prohibited.
+//
+//          Copyright (c) 2022 NEC Laboratories Europe GmbH
+//          All Rights Reserved.
+//
+// Authors: Konstantin Munichev <konstantin.munichev@neclab.eu>
+//
+//
+// NEC Laboratories Europe GmbH DISCLAIMS ALL WARRANTIES, EITHER
+// EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO IMPLIED WARRANTIES
+// OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE AND THE
+// WARRANTY AGAINST LATENT DEFECTS, WITH RESPECT TO THE PROGRAM AND
+// THE ACCOMPANYING DOCUMENTATION.
+//
+// NO LIABILITIES FOR CONSEQUENTIAL DAMAGES: IN NO EVENT SHALL NEC
+// Laboratories Europe GmbH or ANY OF ITS SUBSIDIARIES BE LIABLE FOR
+// ANY DAMAGES WHATSOEVER (INCLUDING, WITHOUT LIMITATION, DAMAGES FOR
+// LOSS OF BUSINESS PROFITS, BUSINESS INTERRUPTION, LOSS OF
+// INFORMATION, OR OTHER PECUNIARY LOSS AND INDIRECT, CONSEQUENTIAL,
+// INCIDENTAL, ECONOMIC OR PUNITIVE DAMAGES) ARISING OUT OF THE USE OF
+// OR INABILITY TO USE THIS PROGRAM, EVEN IF NEC Laboratories Europe
+// GmbH HAS BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGES.
+//
+// THIS HEADER MAY NOT BE EXTRACTED OR MODIFIED IN ANY WAY.
+
+package grpc
+
+import fabric.FabricConnector
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.consumeAsFlow
+import context.ContextOuterClass
+import dlt.DltGateway
+import dlt.DltGatewayServiceGrpcKt
+
+class DLTService(private val connector: FabricConnector) :
+    DltGatewayServiceGrpcKt.DltGatewayServiceCoroutineImplBase() {
+    override suspend fun recordToDlt(request: DltGateway.DltRecord): DltGateway.DltRecordStatus {
+        println("Incoming request ${request.recordId.recordUuid}")
+        val error = when (request.operation) {
+            DltGateway.DltRecordOperationEnum.DLTRECORDOPERATION_ADD -> {
+                println("Adding new record")
+                connector.putData(request)
+            }
+            DltGateway.DltRecordOperationEnum.DLTRECORDOPERATION_UPDATE -> {
+                println("Updating record")
+                connector.updateData(request)
+            }
+            DltGateway.DltRecordOperationEnum.DLTRECORDOPERATION_DELETE -> {
+                println("Deleting record")
+                connector.deleteData(request)
+            }
+            else -> "Undefined or unknown operation"
+        }
+
+        val dltStatusEnum: DltGateway.DltRecordStatusEnum = if (error == "") {
+            DltGateway.DltRecordStatusEnum.DLTRECORDSTATUS_SUCCEEDED
+        } else {
+            DltGateway.DltRecordStatusEnum.DLTRECORDSTATUS_FAILED
+        }
+        return DltGateway.DltRecordStatus.newBuilder()
+            .setRecordId(request.recordId)
+            .setStatus(dltStatusEnum)
+            .setErrorMessage(error)
+            .build()
+    }
+
+    override suspend fun getFromDlt(request: DltGateway.DltRecordId): DltGateway.DltRecord {
+        return connector.getData(request.recordUuid.uuid)
+    }
+
+    override fun subscribeToDlt(request: DltGateway.DltRecordSubscription): Flow<DltGateway.DltRecordEvent> {
+        println("Subscription request: $request")
+        return connector.subscribeForEvents().consumeAsFlow()
+    }
+
+    override suspend fun getDltStatus(request: ContextOuterClass.TeraFlowController): DltGateway.DltPeerStatus {
+        return super.getDltStatus(request)
+    }
+
+    override suspend fun getDltPeers(request: ContextOuterClass.Empty): DltGateway.DltPeerStatusList {
+        return super.getDltPeers(request)
+    }
+}
\ No newline at end of file
diff --git a/src/dlt/gateway/legacy/src/main/kotlin/proto/Config.proto b/src/dlt/gateway/legacy/src/main/kotlin/proto/Config.proto
new file mode 100644
index 0000000000000000000000000000000000000000..b6d4c5614dca4b7784b96ebdb1d002f85c4fd0e2
--- /dev/null
+++ b/src/dlt/gateway/legacy/src/main/kotlin/proto/Config.proto
@@ -0,0 +1,54 @@
+//     NEC Laboratories Europe GmbH
+//
+//     PROPRIETARY INFORMATION
+//
+// The software and its source code contain valuable trade secrets and
+// shall be maintained in confidence and treated as confidential
+// information. The software may only be used for evaluation and/or
+// testing purposes, unless otherwise explicitly stated in a written
+// agreement with NEC Laboratories Europe GmbH.
+//
+// Any unauthorized publication, transfer to third parties or
+// duplication of the object or source code - either totally or in
+// part - is strictly prohibited.
+//
+//          Copyright (c) 2022 NEC Laboratories Europe GmbH
+//          All Rights Reserved.
+//
+// Authors: Konstantin Munichev <konstantin.munichev@neclab.eu>
+//
+//
+// NEC Laboratories Europe GmbH DISCLAIMS ALL WARRANTIES, EITHER
+// EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO IMPLIED WARRANTIES
+// OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE AND THE
+// WARRANTY AGAINST LATENT DEFECTS, WITH RESPECT TO THE PROGRAM AND
+// THE ACCOMPANYING DOCUMENTATION.
+//
+// NO LIABILITIES FOR CONSEQUENTIAL DAMAGES: IN NO EVENT SHALL NEC
+// Laboratories Europe GmbH or ANY OF ITS SUBSIDIARIES BE LIABLE FOR
+// ANY DAMAGES WHATSOEVER (INCLUDING, WITHOUT LIMITATION, DAMAGES FOR
+// LOSS OF BUSINESS PROFITS, BUSINESS INTERRUPTION, LOSS OF
+// INFORMATION, OR OTHER PECUNIARY LOSS AND INDIRECT, CONSEQUENTIAL,
+// INCIDENTAL, ECONOMIC OR PUNITIVE DAMAGES) ARISING OUT OF THE USE OF
+// OR INABILITY TO USE THIS PROGRAM, EVEN IF NEC Laboratories Europe
+// GmbH HAS BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGES.
+//
+// THIS HEADER MAY NOT BE EXTRACTED OR MODIFIED IN ANY WAY.
+
+syntax = "proto3";
+
+package proto;
+
+message DltConfig {
+  string wallet = 1;
+  string connectionFile = 2;
+  string user = 3;
+  string channel = 4;
+  string contract = 5;
+  string caCertFile = 6;
+  string caUrl = 7;
+  string caAdmin = 8;
+  string caAdminSecret = 9;
+  string msp = 10;
+  string affiliation = 11;
+}