progress in fix test

counterparty-core/counterpartycore/lib/api/apiv1.py

@@ -612,7 +612,10 @@ def create_method(**kwargs):
                 exceptions.BalanceError,
             ) as error:
                 # TypeError happens when unexpected keyword arguments are passed in
-                error_msg = f"Error composing {tx} transaction via API: {str(error)}"
+                import traceback
+
+                print(traceback.format_exc())
+                error_msg = f"Error composing {tx} transaction via API: {str(error)} {traceback.format_exc()}"
                 logger.trace(error_msg)
                 raise JSONRPCDispatchException(
                     code=JSON_RPC_ERROR_API_COMPOSE, message=error_msg

counterparty-core/counterpartycore/lib/messages/sweep.py

@@ -75,7 +75,7 @@ def compose(
         memo_bytes = bytes.fromhex(memo)
     else:
         memo_bytes = memo.encode("utf-8")
-        memo_bytes = struct.pack(f">{len(memo)}s", memo)
+        memo_bytes = struct.pack(f">{len(memo_bytes)}s", memo_bytes)
 
     block_index = CurrentState().current_block_index()
     problems, _total_fee = validate(db, source, destination, flags, memo_bytes, block_index)
@@ -98,7 +98,7 @@ def compose(
     else:
         data = messagetype.pack(ID)
         data += struct.pack(FORMAT, short_address_bytes, flags)
-        data += memo
+        data += memo_bytes
 
     return (source, [], data)
 

counterparty-core/counterpartycore/lib/messages/versions/enhancedsend.py

@@ -173,6 +173,7 @@ def compose(
         memo_bytes = bytes.fromhex(memo)
     else:
         memo_bytes = memo.encode("utf-8")
+        memo_bytes = struct.pack(f">{len(memo_bytes)}s", memo_bytes)
 
     problems = validate(db, destination, asset, quantity, memo_bytes)
     if problems and not skip_validation:
@@ -195,13 +196,13 @@ def compose(
                 memo_bytes,
             ]
         )
-        logger.warning(f"data_content: {data_content}")
         data += struct.pack(f">{len(data_content)}s", data_content)
+        logger.warning(f"data1: {data}")
     else:
-        memo_bytes = struct.pack(f">{len(memo)}s", memo)
         data = messagetype.pack(ID)
         data += struct.pack(FORMAT, asset_id, quantity, short_address_bytes)
         data += memo_bytes
+        logger.warning(f"data2: {data}")
 
     cursor.close()
     # return an empty array as the second argument because we don't need to send BTC dust to the recipient

counterparty-core/counterpartycore/lib/messages/versions/send1.py

@@ -88,6 +88,7 @@ def compose(
     skip_validation: bool = False,
     no_dispense: bool = False,
 ):
+    logger.warning("compose_send1")
     cursor = db.cursor()
 
     # Just send BTC?

counterparty-core/counterpartycore/lib/utils/address.py

@@ -100,6 +100,7 @@ def pack(address):
             try:
                 validate(address)  # This will check if the address is valid
                 short_address_bytes = bitcoin.base58.decode(address)[:-4]
+                print("short_address_bytes", short_address_bytes)
                 return short_address_bytes
             except Exception as e:  # pylint: disable=broad-except  # noqa: F841
                 raise exceptions.AddressError(  # noqa: B904

counterparty-core/counterpartycore/test/units/api/apiserver_test.py

@@ -116,8 +116,12 @@ def test_all_routes(
         tx,
         b"\x00\x00\x00\x00\x05\xf5\xe1\x00\x00\x00\x00\xa2[\xe3Kf\x00\x00\x00\x00\x00\x00\x00\x01",
     )
+
     tx = blockchain_mock.dummy_tx(ledger_db, defaults["addresses"][0])
-    message = b"o\x9c\x8d\x1fT\x05E\x1d\xe6\x07\x0b\xf1\xdb\x86\xabj\xcc\xb4\x95\xb6%\x01"
+    _source, _destination, data = sweep.compose(
+        ledger_db, defaults["addresses"][0], defaults["addresses"][1], 1, None, False
+    )
+    message = data[1:]
     sweep.parse(ledger_db, tx, message)
     apiwatcher.catch_up(ledger_db, state_db)