diff --git a/app/core/background/convert_service.py b/app/core/background/convert_service.py index 3fd6d1f..b41b181 100644 --- a/app/core/background/convert_service.py +++ b/app/core/background/convert_service.py @@ -4,13 +4,14 @@ import os import uuid import json import shutil -from base58 import b58encode +from base58 import b58decode, b58encode from sqlalchemy import and_, or_ from app.core.models.node_storage import StoredContent from app.core._utils.send_status import send_status from app.core.logger import make_log from app.core.storage import db_session from app.core._config import UPLOADS_DIR +from app.core.content.content_id import ContentId async def convert_loop(): @@ -181,6 +182,12 @@ async def convert_loop(): make_log("ConvertProcess", f"Content {unprocessed_encrypted_content.id} processed. Converted content: {converted_content}", level="info") + unprocessed_encrypted_content.btfs_cid = ContentId( + version=2, content_hash=b58decode(converted_content['high']) + ) + unprocessed_encrypted_content.ipfs_cid = ContentId( + version=2, content_hash=b58decode(converted_content['low']) + ) unprocessed_encrypted_content.meta = { **unprocessed_encrypted_content.meta, 'converted_content': converted_content