dev@locazia: add debug try-except
This commit is contained in:
user
parent
63b5607d1b
commit
7479e442e7
|
|
@ -1,5 +1,6 @@
|
|||
from base64 import b64encode
|
||||
from datetime import datetime
|
||||
import traceback
|
||||
|
||||
from sanic import response
|
||||
from tonsdk.boc import begin_cell, begin_dict
|
||||
|
|
@ -8,6 +9,7 @@ from tonsdk.utils import Address
|
|||
from app.core._blockchain.ton.connect import TonConnect
|
||||
from app.core._blockchain.ton.platform import platform
|
||||
from app.core._config import PROJECT_HOST
|
||||
from app.core.logger import make_log
|
||||
from app.core._utils.resolve_content import resolve_content
|
||||
from app.core.content.utils import create_metadata_for_item
|
||||
from app.core.models.node_storage import StoredContent
|
||||
|
|
@ -26,111 +28,115 @@ def valid_royalty_params(royalty_params):
|
|||
|
||||
|
||||
async def s_api_v1_blockchain_send_new_content_message(request):
|
||||
assert request.json, "No data provided"
|
||||
assert request.ctx.user, "No authorized user provided"
|
||||
try:
|
||||
assert request.json, "No data provided"
|
||||
assert request.ctx.user, "No authorized user provided"
|
||||
|
||||
for field_key, field_value in {
|
||||
'title': lambda x: isinstance(x, str),
|
||||
'authors': lambda x: isinstance(x, list),
|
||||
'content': lambda x: isinstance(x, str),
|
||||
'image': lambda x: isinstance(x, str),
|
||||
'description': lambda x: isinstance(x, str),
|
||||
'price': lambda x: (isinstance(x, str) and x.isdigit()),
|
||||
'allowResale': lambda x: isinstance(x, bool),
|
||||
'royaltyParams': lambda x: (isinstance(x, list) and valid_royalty_params(x)),
|
||||
for field_key, field_value in {
|
||||
'title': lambda x: isinstance(x, str),
|
||||
'authors': lambda x: isinstance(x, list),
|
||||
'content': lambda x: isinstance(x, str),
|
||||
'image': lambda x: isinstance(x, str),
|
||||
'description': lambda x: isinstance(x, str),
|
||||
'price': lambda x: (isinstance(x, str) and x.isdigit()),
|
||||
'allowResale': lambda x: isinstance(x, bool),
|
||||
'royaltyParams': lambda x: (isinstance(x, list) and valid_royalty_params(x)),
|
||||
|
||||
}.items():
|
||||
assert field_key in request.json, f"No {field_key} provided"
|
||||
assert field_value(request.json[field_key]), f"Invalid {field_key} provided"
|
||||
}.items():
|
||||
assert field_key in request.json, f"No {field_key} provided"
|
||||
assert field_value(request.json[field_key]), f"Invalid {field_key} provided"
|
||||
|
||||
ton_connect, ton_connection = TonConnect.by_user(request.ctx.db_session, request.ctx.user, callback_fn=())
|
||||
await ton_connect.restore_connection()
|
||||
assert ton_connect.connected, "No connected wallet"
|
||||
ton_connect, ton_connection = TonConnect.by_user(request.ctx.db_session, request.ctx.user, callback_fn=())
|
||||
await ton_connect.restore_connection()
|
||||
assert ton_connect.connected, "No connected wallet"
|
||||
|
||||
encrypted_content_cid, err = resolve_content(request.json['content'])
|
||||
assert not err, f"Invalid content CID"
|
||||
encrypted_content = request.ctx.db_session.query(StoredContent).filter(
|
||||
StoredContent.hash == encrypted_content_cid.content_hash_b58
|
||||
).first()
|
||||
assert encrypted_content, "No content locally found"
|
||||
assert encrypted_content.type == "local/content_bin", "Invalid content type"
|
||||
|
||||
if request.json['image']:
|
||||
image_content_cid, err = resolve_content(request.json['image'])
|
||||
assert not err, f"Invalid image CID"
|
||||
image_content = request.ctx.db_session.query(StoredContent).filter(
|
||||
StoredContent.hash == image_content_cid.content_hash_b58
|
||||
encrypted_content_cid, err = resolve_content(request.json['content'])
|
||||
assert not err, f"Invalid content CID"
|
||||
encrypted_content = request.ctx.db_session.query(StoredContent).filter(
|
||||
StoredContent.hash == encrypted_content_cid.content_hash_b58
|
||||
).first()
|
||||
assert image_content, "No image locally found"
|
||||
else:
|
||||
image_content_cid = None
|
||||
image_content = None
|
||||
assert encrypted_content, "No content locally found"
|
||||
assert encrypted_content.type == "local/content_bin", "Invalid content type"
|
||||
|
||||
metadata_content = await create_metadata_for_item(
|
||||
request.ctx.db_session,
|
||||
title=request.json['title'],
|
||||
cover_url=request.json['image'],
|
||||
authors=request.json['authors']
|
||||
)
|
||||
if request.json['image']:
|
||||
image_content_cid, err = resolve_content(request.json['image'])
|
||||
assert not err, f"Invalid image CID"
|
||||
image_content = request.ctx.db_session.query(StoredContent).filter(
|
||||
StoredContent.hash == image_content_cid.content_hash_b58
|
||||
).first()
|
||||
assert image_content, "No image locally found"
|
||||
else:
|
||||
image_content_cid = None
|
||||
image_content = None
|
||||
|
||||
royalties_dict = begin_dict(8)
|
||||
i = 0
|
||||
for royalty_param in request.json['royaltyParams']:
|
||||
royalties_dict.store_ref(
|
||||
i, begin_cell()
|
||||
.store_address(Address(royalty_param['address']))
|
||||
.store_uint(royalty_param['value'], 16)
|
||||
.end_cell()
|
||||
metadata_content = await create_metadata_for_item(
|
||||
request.ctx.db_session,
|
||||
title=request.json['title'],
|
||||
cover_url=request.json['image'],
|
||||
authors=request.json['authors']
|
||||
)
|
||||
i += 1
|
||||
|
||||
await ton_connect._sdk_client.send_transaction({
|
||||
'valid_until': int(datetime.now().timestamp() + 120),
|
||||
'messages': [
|
||||
{
|
||||
'address': platform.address.to_string(1, 1, 1),
|
||||
'amount': str(int(0.15 * 10 ** 9)),
|
||||
'payload': b64encode(
|
||||
begin_cell()
|
||||
.store_uint(0x5491d08c, 32)
|
||||
.store_uint(int(encrypted_content_cid.content_hash.hex()[2:], 16), 256)
|
||||
.store_ref(
|
||||
begin_cell()
|
||||
.store_ref(
|
||||
begin_cell()
|
||||
.store_coins(int(request.json['price']))
|
||||
.store_coins(int(1000000 * 10 ** 9))
|
||||
.store_coins(int(5000000 * 10 ** 9))
|
||||
.end_cell()
|
||||
)
|
||||
.store_maybe_ref(royalties_dict.end_dict())
|
||||
.store_uint(0, 1)
|
||||
.end_cell()
|
||||
)
|
||||
.store_ref(
|
||||
begin_cell()
|
||||
.store_ref(
|
||||
begin_cell()
|
||||
.store_uint(1, 8)
|
||||
.store_bytes(f"{PROJECT_HOST}/api/v1/storage/{metadata_content.hash}".encode())
|
||||
.end_cell()
|
||||
)
|
||||
.store_ref(
|
||||
begin_cell()
|
||||
.store_ref(begin_cell().store_bytes(f"{encrypted_content_cid.serialize_v1()}".encode()).end_cell())
|
||||
.store_ref(begin_cell().store_bytes(f"{image_content_cid.serialize_v1() if image_content_cid else ''}".encode()).end_cell())
|
||||
.store_ref(begin_cell().store_bytes(f"{metadata_content.serialize_v1()}".encode()).end_cell())
|
||||
.end_cell()
|
||||
)
|
||||
.end_cell()
|
||||
)
|
||||
.end_cell().to_boc(False)
|
||||
).decode()
|
||||
}
|
||||
]
|
||||
})
|
||||
royalties_dict = begin_dict(8)
|
||||
i = 0
|
||||
for royalty_param in request.json['royaltyParams']:
|
||||
royalties_dict.store_ref(
|
||||
i, begin_cell()
|
||||
.store_address(Address(royalty_param['address']))
|
||||
.store_uint(royalty_param['value'], 16)
|
||||
.end_cell()
|
||||
)
|
||||
i += 1
|
||||
|
||||
return response.json({"message": "Transaction requested"})
|
||||
await ton_connect._sdk_client.send_transaction({
|
||||
'valid_until': int(datetime.now().timestamp() + 120),
|
||||
'messages': [
|
||||
{
|
||||
'address': platform.address.to_string(1, 1, 1),
|
||||
'amount': str(int(0.15 * 10 ** 9)),
|
||||
'payload': b64encode(
|
||||
begin_cell()
|
||||
.store_uint(0x5491d08c, 32)
|
||||
.store_uint(int(encrypted_content_cid.content_hash.hex()[2:], 16), 256)
|
||||
.store_ref(
|
||||
begin_cell()
|
||||
.store_ref(
|
||||
begin_cell()
|
||||
.store_coins(int(request.json['price']))
|
||||
.store_coins(int(1000000 * 10 ** 9))
|
||||
.store_coins(int(5000000 * 10 ** 9))
|
||||
.end_cell()
|
||||
)
|
||||
.store_maybe_ref(royalties_dict.end_dict())
|
||||
.store_uint(0, 1)
|
||||
.end_cell()
|
||||
)
|
||||
.store_ref(
|
||||
begin_cell()
|
||||
.store_ref(
|
||||
begin_cell()
|
||||
.store_uint(1, 8)
|
||||
.store_bytes(f"{PROJECT_HOST}/api/v1/storage/{metadata_content.hash}".encode())
|
||||
.end_cell()
|
||||
)
|
||||
.store_ref(
|
||||
begin_cell()
|
||||
.store_ref(begin_cell().store_bytes(f"{encrypted_content_cid.serialize_v1()}".encode()).end_cell())
|
||||
.store_ref(begin_cell().store_bytes(f"{image_content_cid.serialize_v1() if image_content_cid else ''}".encode()).end_cell())
|
||||
.store_ref(begin_cell().store_bytes(f"{metadata_content.serialize_v1()}".encode()).end_cell())
|
||||
.end_cell()
|
||||
)
|
||||
.end_cell()
|
||||
)
|
||||
.end_cell().to_boc(False)
|
||||
).decode()
|
||||
}
|
||||
]
|
||||
})
|
||||
|
||||
return response.json({"message": "Transaction requested"})
|
||||
except BaseException as e:
|
||||
make_log("Blockchain", f"Error while sending new content message: {e}" + '\n' + traceback.format_exc(), level='error')
|
||||
return response.json({"error": str(e)}, status=400)
|
||||
|
||||
|
||||
async def s_api_v1_blockchain_send_purchase_content_message(request):
|
||||
|
|
|
|||
Loading…
Reference in New Issue