From fac207e791b607f4451468c993a47365a4e7a8de Mon Sep 17 00:00:00 2001 From: lza_menace Date: Thu, 10 Mar 2022 21:55:47 -0800 Subject: [PATCH] fix err, bad include --- tubbymemes/cli/cli.py | 67 +------------------------------------------ 1 file changed, 1 insertion(+), 66 deletions(-) diff --git a/tubbymemes/cli/cli.py b/tubbymemes/cli/cli.py index 4f15733..8e85bd5 100644 --- a/tubbymemes/cli/cli.py +++ b/tubbymemes/cli/cli.py @@ -4,7 +4,6 @@ from secrets import token_urlsafe from datetime import datetime from tubbymemes.factory import db -from tubbymemes.helpers import get_eth_contract from tubbymemes.models import Meme, User, Remote from tubbymemes import config @@ -16,64 +15,6 @@ bp = Blueprint('cli', 'cli', cli_group=None) def init(): db.create_all() -@bp.cli.command('sync-avax') -def sync_avax(): - """ - Synchronize your local database with the tokens minted on Avalanche blockchain. - """ - contract = get_eth_contract() - total_supply = contract.functions.totalSupply().call() - # walk backwards through all tokens at top of supply - # until you've accounted for the last known - for i in range(total_supply, 0, -1): - # first get metadata ipfs hash - deets = contract.functions.tokenMeme(i).call() - try: - meme_exists = Meme.query.filter(Meme.meta_ipfs_hash == deets[8]).first() # noqa - user_exists = User.query.filter(User.public_address == deets[6].lower()).first() # noqa - if meme_exists: - if not meme_exists.minted: - meme_exists.minted = True - db.session.commit() - print(f'[+] Marked existing meme {meme_exists.id} as minted') - else: - print(deets) - if not user_exists: - user_exists = User( - public_address=deets[4].lower() - ) - db.session.add(user_exists) - db.session.commit() - user_exists.handle = f'anon{user_exists.id}-{token_urlsafe(6)}' - db.session.commit() - print(f'[+] Created user {user_exists.handle}') - res = requests.get(f'{config.IPFS_SERVER}/ipfs/{deets[5]}', timeout=30).json() - if not 'image' in res: - print('No image IPFS hash, skipping') - continue - meme_ipfs_hash = res['image'].split('ipfs://')[1] - filename = token_urlsafe(24) - print(f'[+] Downloading image hash {meme_ipfs_hash} as {filename}') - r = requests.get(f'{config.IPFS_SERVER}/ipfs/{meme_ipfs_hash}', stream=True) - with open(f'{config.DATA_FOLDER}/uploads/{filename}', 'wb') as f: - for chunk in r.iter_content(chunk_size = 16*1024): - f.write(chunk) - meme = Meme( - title=res['name'], - file_name=filename, - description=res['description'], - user_id=user_exists.id, - meta_ipfs_hash=deets[5], - meme_ipfs_hash=meme_ipfs_hash, - minted=True, - synced=True - ) - db.session.add(meme) - db.session.commit() - print(f'[+] Added new meme {meme.id}') - except Exception as e: - print(e) - @bp.cli.command('sync-remotes') def sync_remotes(): @@ -94,16 +35,10 @@ def sync_remotes(): if not user_exists: user_exists = User( public_address=user['public_address'].lower(), - bio=user['bio'], - ipfs_hash=user['ipfs_hash'], - profile_image=user['profile_image'], - website_url=user['website_url'], - wownero_address=user['wownero_address'], - handle=user['handle'] ) db.session.add(user_exists) db.session.commit() - print(f'[+] Created user {user_exists.handle}') + print(f'[+] Created user {user_exists.public_address}') print(f'[+] Downloading image hash {meme["meme_ipfs_hash"]} as {meme["file_name"]}') r = requests.get(f'{config.IPFS_SERVER}/ipfs/{meme["meme_ipfs_hash"]}', stream=True) with open(f'{config.DATA_FOLDER}/uploads/{meme["file_name"]}', 'wb') as f: