Initial Commit

Author: chgaowei

.gitignore

@@ -0,0 +1,9 @@
+dist/
+myenv/
+*/__pycache__/
+*.pyc
+*.pyo
+*.venv
+examples/*.json
+*.egg-info/
+build/

LICENSE

@@ -1,6 +1,6 @@
 MIT License
 
-Copyright (c) 2024 HeiYa
+Copyright (c) 2024 GaoWei Chang
 
 Permission is hereby granted, free of charge, to any person obtaining a copy
 of this software and associated documentation files (the "Software"), to deal

README.en.md

@@ -0,0 +1,60 @@
+# Cross-Platform Identity Authentication and End-to-End Encrypted Communication Technology Based on DID
+
+**Author**: Chang Gaowei  
+**Email**: chgaowei@gmail.com  
+**Website**: [pi-unlimited.com](http://pi-unlimited.com)  
+
+## Abstract
+
+This project is an open-source SDK implementation based on Decentralized Identifier (DID) and end-to-end encrypted communication technology. For technical details, refer to the [Technical White Paper: A Cross-Platform Identity Authentication and End-to-End Encrypted Communication Technology Based on DID](https://egp0uc2jnx.feishu.cn/wiki/JyaIwTwngiWi9qkJjjycI4XcnXe?from=from_copylink). With the didall open-source project, any intelligent agent or server can connect to the DID server, register its DID, accept connections from other users, connect to other users, and engage in end-to-end encrypted communication.
+
+## Features
+
+- **Cross-Platform Identity Authentication**: Achieves identity interoperability across different platforms using DID.
+- **End-to-End Encrypted Communication**: Uses ECDHE for short-term key agreement to ensure communication security.
+- **Efficient and Secure**: Simplifies the identity verification process, ensuring data confidentiality and integrity.
+
+### Installation
+
+The latest version has been removed from PyPI, so install directly:
+
+```bash
+pip install didall
+```
+
+### Usage
+
+After installing the didall library, you can run the sample code in the examples directory to generate DID files for Alice and Bob, save Alice's DID file to the DID server, and then have Bob connect to Alice's DID for end-to-end encrypted communication.
+
+1. Generate two DID documents, alice.json and bob.json, save them to the specified files, and register them with the DID server:
+```bash
+python sample_did.py alice.json
+python sample_did.py bob.json
+```
+
+2. Start Alice's demo:
+```bash
+python sample_alice.py alice.json
+```
+
+3. Start Bob's demo:
+```bash
+python sample_bob.py bob.json
+```
+
+By checking the logs, you can see that Alice and Bob have successfully connected and engaged in end-to-end encrypted communication.
+
+## Contributing
+
+Contributions to this project are welcome. Please read the contribution guidelines before submitting a pull request.
+
+## License
+    
+This project is open-sourced under the MIT License. For more details, please refer to the LICENSE file.
+
+## Packaging and Uploading (update the version number in setup.py first)
+
+```bash
+python setup.py sdist bdist_wheel 
+twine upload dist/*        
+```

README.md

@@ -1,2 +1,62 @@
-# didall
-Technical White Paper: A Cross-Platform Identity Authentication and End-to-End Encrypted Communication Technology Based on DID
+# 基于DID的跨平台身份认证和端到端加密通信技术
+
+**作者**: 常高伟  
+**邮箱**: chgaowei@gmail.com  
+**官网**: [pi-unlimited.com](http://pi-unlimited.com)  
+
+## 摘要
+
+本项目是基于去中心化标识符（DID）和端到端加密通信技术的开源SDK实现，技术细节详见[技术白皮书：一种基于DID的跨平台身份认证和端到端加密通信技术](https://egp0uc2jnx.feishu.cn/wiki/JyaIwTwngiWi9qkJjjycI4XcnXe?from=from_copylink)。
+借助didall开源项目，任意一个智能体或者服务端都可以连接到did server，注册自己的did，接收其他用户连接，也可以连接其他用户，并且相互之间进行端到端的加密通信。
+
+## 特点
+
+- **跨平台身份认证**：通过DID实现不同平台间的身份互操作性。
+- **端到端加密通信**：使用ECDHE进行短期密钥协商，保证通信的安全性。
+- **高效和安全**：简化身份验证过程，确保数据的保密性和完整性。
+
+### 安装
+
+最新版本已删除pypi，直接安装即可：
+
+```bash
+pip install didall
+```
+
+### 运行
+
+在安装完didall库后，可以运行examples目录下的sample代码，可以生成alice和bob的did文件，并且将alice的did文件保存到did server，然后bob可以连接alice的did，进行端到端的加密通信。
+
+1. 生成两个did文档alice.json和bob.json，保存到指定文件中，并注册到did server
+```bash
+python sample_did.py alice.json
+python sample_did.py bob.json
+```
+
+2. 启动alice的demo
+```bash
+python sample_alice.py alice.json
+```
+
+3. 启动bob的demo
+```bash
+python sample_bob.py bob.json
+```
+
+可以通过日志看到，alice和bob成功连接，并且进行端到端的加密通信。
+
+## 贡献
+
+欢迎对本项目进行贡献。请在提交Pull Request之前阅读贡献指南。
+
+## 许可证
+    
+本项目基于MIT许可证开源。详细信息请参阅LICENSE文件。
+
+
+## 打包上传（先更改setup.py中版本号）
+
+```bash
+python setup.py sdist bdist_wheel 
+twine upload dist/*        
+```

didall/__init__.py

@@ -0,0 +1,134 @@
+# Cross-Platform Identity Authentication and End-to-End Encrypted Communication Technology Based on DID
+# Author: GaoWei Chang
+# Email: chgaowei@gmail.com
+# Website: http://pi-unlimited.com
+#
+# This project is open-sourced under the MIT License. For details, please see the LICENSE file.
+
+
+import logging
+from typing import Tuple
+import aiohttp
+from didall.utils.crypto_tool import get_pem_from_private_key
+from didall.utils.did_generate import did_generate
+import requests
+
+class DIDAllClient:
+    def __init__(self, did_service_url: str, api_key: str):
+        self.api_key = api_key
+        self.did_service_url = did_service_url
+
+    def generate_did_document(self, communication_service_endpoint: str, router_did: str = "") -> Tuple[str, str, str]:
+        """
+        Generate DID document without registering to DID service
+
+        Args:
+            communication_service_endpoint (str): Communication service endpoint for DID document.
+            router (str, optional): Router's DID, default is empty string.
+
+        Returns:
+            Tuple[str, str, str]: A tuple containing private key in PEM format, DID string, and DID document JSON string.
+        """
+        private_key, _, did, did_document_json = did_generate(communication_service_endpoint, router_did)
+
+        # Convert private key to PEM format
+        private_key_pem = get_pem_from_private_key(private_key)
+
+        return private_key_pem, did, did_document_json
+
+    async def generate_register_did_document(self, communication_service_endpoint: str, router_did: str = "") -> Tuple[str, str, str]:
+        """
+        Register DID document to DID service.
+
+        This function asynchronously generates DID and corresponding DID document, and registers it to the configured DID service.
+        It uses the aiohttp library to send asynchronous HTTP requests.
+
+        Args:
+            communication_service_endpoint (str): Communication service endpoint for DID document.
+            router_did (str, optional): Router's DID, default is empty string.
+
+        Returns:
+            Tuple[str, str, str]: A tuple containing private key in PEM format, DID string, and DID document JSON string.
+            If registration fails, it will return three None values.
+        """
+
+        # Generate private key, public key, DID and DID document
+        private_key, _, did, did_document_json = did_generate(communication_service_endpoint, router_did)
+
+        # Convert private key to PEM format
+        private_key_pem = get_pem_from_private_key(private_key)
+
+        # Prepare request headers
+        headers = {
+            "Content-Type": "application/text",
+            "Authorization": f"Bearer {self.api_key}"
+        }
+
+        # Ensure correct request URL
+        request_url = f"{self.did_service_url}/v1/did"  # Make sure the URL is correct
+
+        # Use aiohttp to send asynchronous POST request
+        async with aiohttp.ClientSession() as session:
+            async with session.post(request_url, headers=headers, data=did_document_json) as response:
+                if response.status == 200:
+                    return private_key_pem, did, did_document_json
+                else:
+                    response_text = await response.text()
+                    logging.error(f"Failed to create DID document: {response.status} {response_text}")
+                    return None, None, None
+
+    async def get_did_document(self, did: str):
+        # Prepare request headers
+        headers = {
+            "Accept": "application/text",
+            "Authorization": f"Bearer {self.api_key}"
+        }
+
+        # Construct complete request URL
+        request_url = f"{self.did_service_url}/v1/did/{did}"
+
+        # Use aiohttp to send asynchronous GET request
+        async with aiohttp.ClientSession() as session:
+            async with session.get(request_url, headers=headers) as response:
+                if response.status == 200:
+                    return await response.text()
+                else:
+                    response_text = await response.text()
+                    logging.error(f"Failed to retrieve DID document: {response.status} {response_text}")
+                    return None
+
+    def register_did_document_sync(self, communication_service_endpoint: str, router: str = ""):
+        # Generate private key, public key, DID and DID document
+        private_key, _, did, did_document_json = did_generate(communication_service_endpoint, router)
+
+        # Convert private key to PEM format
+        private_key_pem = get_pem_from_private_key(private_key)
+
+        # Prepare request headers
+        headers = {
+            "Content-Type": "application/text",
+            "Authorization": f"Bearer {self.api_key}"
+        }
+
+        # Use requests to send synchronous POST request
+        response = requests.post(f"{self.did_service_url}/v1/did", headers=headers, data=did_document_json)
+        if response.status_code == 200:
+            return private_key_pem, did, did_document_json
+        else:
+            logging.error(f"Failed to create DID document: {response.status_code} {response.text}")
+            return None, None, None
+
+    def get_did_document_sync(self, did: str):
+        # Prepare request headers
+        headers = {
+            "Accept": "application/text",
+            "Authorization": f"Bearer {self.api_key}"
+        }
+
+        # Send synchronous GET request
+        response = requests.get(f"{self.did_service_url}/v1/did/{did}", headers=headers)
+        if response.status_code == 200:
+            return response.text
+        else:
+            logging.error(f"Failed to retrieve DID document: {response.status_code} {response.text}")
+            return None