Initial commit

* Conforms to did:mydata method spec
* Admin route to perform CRUD on did registry transactions
* Admin route to initiate did:mydata method operations (create, read, delete)
* MyData registry admin route to view verified did(s)

Signed-off-by: George J Padayatti <[email protected]>

Author: georgepadayatti

.gitignore

@@ -0,0 +1,8 @@
+# IDE
+.vscode/
+
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+*$py.class
+.DS_Store

README.md

@@ -0,0 +1,67 @@
+# Aries Cloud Agent - Python Plugin for MyData DID DIDComm protcol
+
+## ACA-Py Version Compatibility
+
+To avoid a confusing pseudo-lock-step release, this plugin is
+versioned independent of ACA-Py. Plugin releases will follow standard
+[semver](semver.org) but each release will also be tagged with a mapping to an
+ACA-Py version with the format `acapy-X.Y.Z-J` where `X.Y.Z` corresponds to the
+ACA-Py version supported and `J` is an incrementing number for each new plugin
+release that targets the same version of ACA-Py.
+
+You should look for the most recent release tagged with the version of ACA-Py
+you are using (with the highest value for `J`).
+
+## Installation
+
+Requirements:
+- Python 3.6 or higher
+- ACA-Py
+
+### Setup Aries Cloud Agent - Python
+
+If you already have an existing installation of ACA-Py, you can skip these steps
+and move on to [plugin installation](#plugin-installation). It is also worth
+noting that this is not the only way to setup an ACA-Py instance. For more setup
+configurations, see the [Aries Cloud Agent - Python
+repository](https://github.com/hyperledger/aries-cloudagent-python).
+
+First, clone
+[ACA-Py](https://github.com/hyperledger/aries-cloudagent-python) and prepare a
+virtual environment:
+```sh
+$ git clone https://github.com/hyperledger/aries-cloudagent-python
+$ cd aries-cloudagent-python
+$ python3 -m venv env
+$ source env/bin/activate
+```
+
+Install ACA-Py into the virtual environment:
+```sh
+$ pip install -e .
+```
+**Or** include the `indy` feature if you want to use Indy ledgers or wallets:
+```sh
+$ pip install -e .[indy]
+```
+
+### Plugin Installation
+
+Install this plugin into the virtual environment:
+
+```sh
+$ pip install git+https://github.com/decentralised-dataexchange/acapy-mydata-did-protocol.git@master#egg=mydata_did
+```
+
+**Note:** Depending on your version of `pip`, you may need to drop the
+`#egg=...` to install the plugin with the above command.
+
+### Plugin Loading
+Start up ACA-Py with the plugin parameter:
+```sh
+$ aca-py start \
+    -it http localhost 3000 -it ws localhost 3001 \
+    -ot http \
+    -e http://localhost:3000 ws://localhost:3001 \
+    --plugin "mydata_did"
+```

manifest.in

@@ -0,0 +1,2 @@
+include requirements.txt
+recursive-include mydata_did *

mydata_did/__init__.py

@@ -0,0 +1,10 @@
+"""Version definitions for this protocol."""
+
+versions = [
+    {
+        "major_version": 1,
+        "minimum_minor_version": 0,
+        "current_minor_version": 0,
+        "path": "v1_0",
+    }
+]

mydata_did/definition.py

@@ -0,0 +1,32 @@
+from aries_cloudagent.messaging.base_handler import BaseHandler, BaseResponder, RequestContext
+
+from ..messages.create_did import CreateDID
+from ..manager import MyDataDIDManager
+
+import json
+
+
+class CreateDIDHandler(BaseHandler):
+
+    async def handle(self, context: RequestContext, responder: BaseResponder):
+        self._logger.info(
+            f"CreateDIDHandler called with context {context}")
+        assert isinstance(context.message, CreateDID)
+
+        self._logger.info(
+            "Received create-did message: \n%s",
+            json.dumps(context.message.serialize(), indent=4)
+        )
+
+        if not context.connection_ready:
+            self._logger.info(
+                "Connection not active, skipping create-did handler: %s",
+                context.message_receipt.sender_did,
+            )
+            return
+
+        mgr = MyDataDIDManager(context)
+        await mgr.process_create_did_message(context.message, context.message_receipt)
+
+
+

mydata_did/v1_0/__init__.py

@@ -0,0 +1,32 @@
+from aries_cloudagent.messaging.base_handler import BaseHandler, BaseResponder, RequestContext
+
+from ..messages.create_did_response import CreateDIDResponse
+from ..manager import MyDataDIDManager
+
+import json
+
+
+class CreateDIDResponseHandler(BaseHandler):
+
+    async def handle(self, context: RequestContext, responder: BaseResponder):
+        self._logger.info(
+            f"CreateDIDHandler called with context {context}")
+        assert isinstance(context.message, CreateDIDResponse)
+
+        self._logger.info(
+            "Received create-did-response message: \n%s",
+            json.dumps(context.message.serialize(), indent=4)
+        )
+
+        if not context.connection_ready:
+            self._logger.info(
+                "Connection not active, skipping create-did-response handler: %s",
+                context.message_receipt.sender_did,
+            )
+            return
+
+        mgr = MyDataDIDManager(context)
+        await mgr.process_create_did_response_message(context.message, context.message_receipt)
+
+
+

mydata_did/v1_0/handlers/__init__.py

@@ -0,0 +1,32 @@
+from aries_cloudagent.messaging.base_handler import BaseHandler, BaseResponder, RequestContext
+
+from ..messages.delete_did import DeleteDID
+from ..manager import MyDataDIDManager
+
+import json
+
+
+class DeleteDIDHandler(BaseHandler):
+
+    async def handle(self, context: RequestContext, responder: BaseResponder):
+        self._logger.info(
+            f"DeleteDIDHandler called with context {context}")
+        assert isinstance(context.message, DeleteDID)
+
+        self._logger.info(
+            "Received delete-did message: \n%s",
+            json.dumps(context.message.serialize(), indent=4)
+        )
+
+        if not context.connection_ready:
+            self._logger.info(
+                "Connection not active, skipping create-did handler: %s",
+                context.message_receipt.sender_did,
+            )
+            return
+
+        mgr = MyDataDIDManager(context)
+        await mgr.process_delete_did_message(context.message, context.message_receipt)
+
+
+