Adds Binance L5 (#231)

* Adds Binance L5

.version

@@ -1 +1 @@
-4.1.1
+4.2.0

CHANGELOG.md

@@ -1,14 +1,18 @@
 # Changelog
 
-## 4.1.1
+## 4.2.0
 
 - **Feature:**
   - Add performance improvements when creating transactions and processing L1 blocks
+  - Add interchain support for binance
 - **Packaging:**
   - Update redisearch, boto3 dependencies
+  - Add bnb-tx, pycoin, and mnemonic dependencies for binance
 - **Development:**
   - Revert manual redisearch fixes with dependency fixes
   - Change the way that transaction 404 stubbing is handled for pending transactions
+- **Bugs:**
+  - Change L5 block redisearch insert to upsert to prevent an occasional edge-case error which could cause an L5 to get stuck
 
 ## 4.1.0
 

docs/deployment/deploying.md

@@ -72,7 +72,7 @@ Once the values are set, install the helm chart with:
 ```sh
 helm repo add dragonchain https://dragonchain-charts.s3.amazonaws.com
 helm repo update
-helm upgrade --install my-dragonchain --values opensource-config.yaml --namespace dragonchain dragonchain/dragonchain-k8s --version 1.0.2
+helm upgrade --install my-dragonchain --values opensource-config.yaml --namespace dragonchain dragonchain/dragonchain-k8s --version 1.0.3
 ```
 
 If you need to change any values AFTER the helm chart has already been

dragonchain/exceptions.py

@@ -151,11 +151,11 @@ class SanityCheckFailure(DragonchainException):
     """Exception raised when sanity check fails"""
 
 
-class RPCError(DragonchainException):
-    """Exception raise when RPC has an error"""
+class InterchainConnectionError(DragonchainException):
+    """Exception raise when RPC / API call has an error"""
 
 
-class RPCTransactionNotFound(DragonchainException):
+class TransactionNotFound(DragonchainException):
     """Exception raised when a transaction is not found on an interchain network"""
 
 

dragonchain/lib/crypto.py

@@ -374,7 +374,18 @@ def encrypt_message(encryption_type: SupportedEncryption, priv_key: Union["Priva
         sig_bytes = priv_key.ecdsa_serialize(priv_key.ecdsa_signature_normalize(priv_key.ecdsa_sign(msg=message_bytes, raw=True))[1])
     else:
         raise NotImplementedError("Unsupported encryption type")
+    return base64.b64encode(sig_bytes).decode("ascii")
+
 
+def encrypt_secp256k1_message_compact(priv_key: "PrivateKey", message_bytes: bytes) -> str:
+    """Encrypt a 32byte message (typically a hash, to use as a signature) (in its compact form)
+    Args:
+        priv_key: private key object of encryption type secp256k1
+        message_bytes: 32 byte python bytes object to encrypt
+    Returns:
+        Base 64 encoded signature string
+    """
+    sig_bytes = priv_key.ecdsa_serialize_compact(priv_key.ecdsa_signature_normalize(priv_key.ecdsa_sign(msg=message_bytes, raw=True))[1])
     return base64.b64encode(sig_bytes).decode("ascii")
 
 

dragonchain/lib/crypto_utest.py

@@ -799,6 +799,12 @@ def test_generic_signature(self):
         sig = crypto.make_generic_signature(secp256k1, sha256, key, content)
         self.assertTrue(crypto.check_generic_signature(secp256k1, sha256, key.pubkey, content, b64decode(sig)))
 
+    def test_encrypt_secp256k1_message_compact(self):
+        content = b"Ndj\x8e`tH\x06\x9f\xe2=\xb7\xc0\x85K\xcf4{;,Wn\x7fi\xba=A\x1b\xee<d\xbb"
+        encrypted = crypto.encrypt_secp256k1_message_compact(key, content)
+        expected_result = "ozzVHgADaCfxa2jO+nfwmpeaw836dKutXvtOVngkS6U2kimcFC3JRng4Dta0d+JMOSbEhZ8dX59epnaQmxrNHQ=="
+        self.assertEqual(encrypted, expected_result)
+
     def test_unsupported_crypto(self):
         l1block = make_l1_block()
         l1block.proof = "sig="

dragonchain/lib/dao/interchain_dao.py

@@ -20,6 +20,7 @@
 from dragonchain import exceptions
 from dragonchain.lib.dto import eth
 from dragonchain.lib.dto import btc
+from dragonchain.lib.dto import bnb
 from dragonchain.lib.interfaces import storage
 
 if TYPE_CHECKING:
@@ -43,6 +44,8 @@ def does_interchain_exist(blockchain: str, name: str) -> bool:
         return storage.does_object_exist(f"{FOLDER}/bitcoin/{name}")
     elif blockchain == "ethereum":
         return storage.does_object_exist(f"{FOLDER}/ethereum/{name}")
+    elif blockchain == "binance":
+        return storage.does_object_exist(f"{FOLDER}/binance/{name}")
     else:
         return False
 
@@ -59,6 +62,8 @@ def get_interchain_client(blockchain: str, name: str) -> "model.InterchainModel"
         return btc.new_from_at_rest(storage.get_json_from_object(f"{FOLDER}/bitcoin/{name}"))
     elif blockchain == "ethereum":
         return eth.new_from_at_rest(storage.get_json_from_object(f"{FOLDER}/ethereum/{name}"))
+    elif blockchain == "binance":
+        return bnb.new_from_at_rest(storage.get_json_from_object(f"{FOLDER}/binance/{name}"))
     else:
         raise exceptions.NotFound(f"Blockchain network {blockchain} is not supported")
 
@@ -75,6 +80,8 @@ def list_interchain_clients(blockchain: str) -> List["model.InterchainModel"]:
         from_rest_function = btc.new_from_at_rest
     elif blockchain == "ethereum":
         from_rest_function = eth.new_from_at_rest
+    elif blockchain == "binance":
+        from_rest_function = bnb.new_from_at_rest
     else:
         raise exceptions.NotFound(f"Blockchain network {blockchain} is not supported")