vastRiver.py

import random
import string
import requests
import webbrowser
# import database
# import solana
# from solana.rpc.api import Client
from os import listdir
from os.path import isfile, join
import csv
import json

# from userAuth import UAT
from flask import request, render_template, flash, Markup, jsonify
from userAuth import UAT
from database import db_login_get_wallet, db_get_balance, db_search_userid, db_new_sid, db_new_login, db_create_user_wallet, \
    SidEntry, UserEntry, send_json, the_db, app
from forms import FundTransferForm, UserSettingsForm, OneWalletAddUser, OneWalletFindUser
from oneWallet import valid_cancel, valid_credit, valid_debit
from valid import valid_token_id, valid_user, match_userid_sid, valid_check_user, valid_uuid, valid_sid, \
    valid_channel, valid_game, valid_currency, valid_transaction, valid_amount

uaform = None
ftform = None
theSession = None
iframe_game_toggle = False
stream = ''
datastream = {}
icon_placement = {}
evo_game_titles = {}
icon_path = 'static/icons/thumbnails/'
price_array = []
wallet = ''


def reload_evo_game_titles():
    global evo_game_titles
    # print('reloading csv:' + path)
    # icon_files = [f for f in listdir(path) if isfile(join(path, f)) and not f.endswith('.DS_Store')]
    reader = csv.DictReader(open('static/csv/evo_game_list.csv', mode='r', encoding='utf-8-sig'))

    for row in reader:
        for category in icon_placement:
            for game_placed in icon_placement[category]:
                if row['table_ID'].lower() == game_placed.split('.')[0].lower():
                    evo_game_titles[row['table_ID']] = row
                    break
    print('done: reload_evo_game_titles')


def reload_icon_placement():

    global icon_placement
    print('reloading csv:' + icon_path)
    icon_files = [f for f in listdir(icon_path) if isfile(join(icon_path, f)) and not f.endswith('.DS_Store')]
    reader = csv.DictReader(open('static/csv/icon_placement.csv', mode='r', encoding='utf-8-sig'))
    icon_placement = {name: [] for name in reader.fieldnames}
    for row in reader:
        for name in reader.fieldnames:
            if len(row[name]) > 0:
                icon_filename = [string for string in icon_files if row[name] in string]
                if len(icon_filename) > 0:
                    icon_placement[name].append(icon_filename[0])
    print('done: reload_icon_placement')


def load_crypto_prices():
    URL = "https://api.binance.com/api/v3/ticker/price?symbol="
    keys = ['BTCUSDT', 'SOLUSDT', 'ETHUSDT', 'ADAUSDT']

    for key in keys:
        API_URL = URL + key
        # requesting data from url
        data = requests.get(API_URL)
        global price_array
        price_array.append(json.loads(data.text))

    print('done: load_crypto_prices')
    return price_array


@app.route('/', methods=['GET', 'POST'])
def home():

    # icon_files = [f for f in listdir(current_path) if isfile(join(current_path, f)) and not f.endswith('.DS_Store')]
    # icon_files = sorted([current_path + sub for sub in icon_files])
    reload_icon_placement()
    crypto_prices = load_crypto_prices()

    icon_files = icon_placement['top_games']
    # print(icon_files)

    if request.method == 'POST':
        if 'launch' in request.form:
            game_id = request.form['launch'].rsplit('/', 1)[1].split('.')[0]
            # UA2().launch_game(game_id)

    return render_template('gallery.html', which_tab=request.url.rsplit('/', 1)[1], icon_files=icon_files,
                           game_titles=evo_game_titles, icon_path=icon_path)


@app.route('/login', methods=['GET', 'POST'])
def login():
    # current_path = 'static/icons/games/slots/'
    # icon_files = [f for f in listdir(current_path) if isfile(join(current_path, f)) and not f.endswith('.DS_Store')]
    # icon_files = sorted(current_path + sub for sub in icon_files)
    icon_files = icon_placement['top_games']
    global wallet
    # first check if their wallet exists in our DB
    if len(request.values) > 0:
        wallet = db_login_get_wallet(request.values['walletID'][0:-1])
        db_new_login(request.values['walletID'], 'No NFT')
        if len(wallet) == 0:
            wallet = db_create_user_wallet(request.values['walletID'])
            return render_template('settings.html', wallet=wallet, icon_files=icon_files)

    return render_template('settings.html', wallet=wallet, icon_files=icon_files)


@app.route('/settings', methods=['GET', 'POST'])
def settings():
    user_settings = UserSettingsForm()
    global wallet

    if 'walletID' in request.values:
        db_new_login(request.values['walletID'], 'No NFT')
        wallet = db_login_get_wallet(request.values['walletID'])
    else:
        # manually selected
        print("no request from post")

    if user_settings.validate_on_submit():
        if user_settings.update.data:
            theSession.update_user_info(user_settings)
            flash('User Info Updated!', 'success')

    return render_template('settings.html', wallet=wallet[0], form=user_settings)


@app.route('/xyz', methods=['GET', 'POST'])
def xyz():
    # reloadForm = ReloadPlacement()
    reload_icon_placement(icon_path)
    load_crypto_prices()

    return render_template('loadPlacement.html')


@app.route('/sports', methods=['GET', 'POST'])
def sports():
    # current_path = 'static/icons/games/sports/'
    # icon_files = [f for f in listdir(current_path) if isfile(join(current_path, f)) and not f.endswith('.DS_Store')]
    # icon_files = [current_path + sub for sub in icon_files]

    return render_template('sports.html', which_tab=request.url.rsplit('/', 1)[1], form=uaform)


@app.route('/favorites', methods=['GET', 'POST'])
def favorites():
    # current_path = 'static/icons/games/sports/'
    # icon_files = [f for f in listdir(current_path) if isfile(join(current_path, f)) and not f.endswith('.DS_Store')]
    # icon_files = [current_path + sub for sub in icon_files]

    return render_template('favorites.html', which_tab=request.url.rsplit('/', 1)[1], form=uaform)


@app.route('/deposit', methods=['GET', 'POST'])
def deposit():

    return render_template('deposit.html')


@app.route('/slots', methods=['GET', 'POST'])
def slots():
    # current_path = 'static/icons/games/slots/'
    # icon_files = [f for f in listdir(current_path) if isfile(join(current_path, f)) and not f.endswith('.DS_Store')]
    # icon_files = sorted(current_path + sub for sub in icon_files)
    icon_files = icon_placement['slots']

    if request.method == 'POST':
        if 'launch' in request.form:
            game_id = request.form['launch'].rsplit('/', 1)[1].split('.')[0].split('_')[1]
            UA2().launch_game(game_id)

    return render_template('gallery.html', which_tab=request.url.rsplit('/', 1)[1], form=uaform, icon_files=icon_files,
                           game_titles=evo_game_titles, icon_path=icon_path)


@app.route('/baccarat', methods=['GET', 'POST'])
def baccarat():
    # current_path = 'static/icons/games/live/'
    # icon_files = [f for f in listdir(current_path) if isfile(join(current_path, f)) and not f.endswith('.DS_Store')]
    # icon_files = sorted(current_path + sub for sub in icon_files)
    icon_files = icon_placement['baccarat']

    if request.method == 'POST':
        if 'launch' in request.form:
            game_id = request.form['launch'].split('.')[0]

            # requests.close()
            UAT().launch_game(game_id)

    return render_template('gallery.html', which_tab=request.url.rsplit('/', 1)[1], form=uaform, icon_files=icon_files,
                           game_titles=evo_game_titles, icon_path=icon_path)


@app.route('/blackjack', methods=['GET', 'POST'])
def blackjack():
    # current_path = 'static/icons/games/live/'
    # icon_files = [f for f in listdir(current_path) if isfile(join(current_path, f)) and not f.endswith('.DS_Store')]
    # icon_files = sorted(current_path + sub for sub in icon_files)
    icon_files = icon_placement['blackjack']

    if request.method == 'POST':
        if 'launch' in request.form:
            game_id = request.form['launch'].rsplit('/', 1)[1].split('.')[0].split('_')[1]
            UA2().launch_game(game_id)

    return render_template('gallery.html', which_tab=request.url.rsplit('/', 1)[1], form=uaform, icon_files=icon_files,
                           game_titles=evo_game_titles, icon_path=icon_path)


@app.route('/roulette', methods=['GET', 'POST'])
def roulette():
    # current_path = 'static/icons/games/live/'
    # icon_files = [f for f in listdir(current_path) if isfile(join(current_path, f)) and not f.endswith('.DS_Store')]
    # icon_files = sorted(current_path + sub for sub in icon_files)
    icon_files = icon_placement['roulette']

    if request.method == 'POST':
        if 'launch' in request.form:
            game_id = request.form['launch'].rsplit('/', 1)[1].split('.')[0].split('_')[1]
            UA2().launch_game(game_id)

    return render_template('gallery.html', which_tab=request.url.rsplit('/', 1)[1], form=uaform, icon_files=icon_files,
                           game_titles=evo_game_titles, icon_path=icon_path)


@app.route('/dice', methods=['GET', 'POST'])
def dice():
    # current_path = 'static/icons/games/live/'
    # icon_files = [f for f in listdir(current_path) if isfile(join(current_path, f)) and not f.endswith('.DS_Store')]
    # icon_files = sorted(current_path + sub for sub in icon_files)
    icon_files = icon_placement['dice']

    if request.method == 'POST':
        if 'launch' in request.form:
            game_id = request.form['launch'].rsplit('/', 1)[1].split('.')[0].split('_')[1]
            UA2().launch_game(game_id)

    return render_template('gallery.html', which_tab=request.url.rsplit('/', 1)[1], form=uaform, icon_files=icon_files,
                           game_titles=evo_game_titles, icon_path=icon_path)


@app.route('/poker', methods=['GET', 'POST'])
def poker():
    # current_path = 'static/icons/games/live/'
    # icon_files = [f for f in listdir(current_path) if isfile(join(current_path, f)) and not f.endswith('.DS_Store')]
    # icon_files = sorted(current_path + sub for sub in icon_files)
    icon_files = icon_placement['poker']

    if request.method == 'POST':
        if 'launch' in request.form:
            game_id = request.form['launch'].rsplit('/', 1)[1].split('.')[0].split('_')[1]
            UA2().launch_game(game_id)

    return render_template('gallery.html', which_tab=request.url.rsplit('/', 1)[1], form=uaform, icon_files=icon_files,
                           game_titles=evo_game_titles, icon_path=icon_path)


@app.route('/game_shows', methods=['GET', 'POST'])
def game_shows():
    # current_path = 'static/icons/games/live/'
    # icon_files = [f for f in listdir(current_path) if isfile(join(current_path, f)) and not f.endswith('.DS_Store')]
    # icon_files = sorted(current_path + sub for sub in icon_files)
    icon_files = icon_placement['game_shows']

    if request.method == 'POST':
        if 'launch' in request.form:
            game_id = request.form['launch'].rsplit('/', 1)[1].split('.')[0].split('_')[1]
            UA2().launch_game(game_id)

    return render_template('gallery.html', which_tab=request.url.rsplit('/', 1)[1], form=uaform, icon_files=icon_files,
                           game_titles=evo_game_titles, icon_path=icon_path)


@app.route('/ft', methods=['GET', 'POST'])
def ft():
    # which_tabs = request.url.rsplit('/', 1)[1]
    global theSession
    theSession.get_user_balance()
    form = FundTransferForm()

    if form.validate_on_submit():
        if form.subtract.data:
            flash(form.amount.data + ' funds subtracted', 'warning')
            theSession.ft_subtract(form.amount.data)
        elif form.add.data:
            flash(form.amount.data + ' funds added', 'success')
            theSession.ft_add(form.amount.data)
        else:
            flash('Error:' + form.amount.errors, 'error')

    return render_template('fundTransfer.html', which_tab=request.url.rsplit('/', 1)[1], ft_form=form, form=uaform,
                           UA_payload=theSession.UA_payload)


@app.route('/ow', methods=['GET', 'POST'])
def ow():
    # global which_tab
    # which_tab =
    find_form = OneWalletFindUser()
    add_form = OneWalletAddUser()

    # dataclass = UserEntry()
    if find_form.find_userid.data and find_form.validate_on_submit():
        if not db_search_userid(find_form.userID.data):
            flash(Markup('<strong>' + find_form.userID.data + '</strong> not found!'), 'danger')
        else:
            dataclass_sid = SidEntry()
            uuid = ''.join(random.choices(string.ascii_letters + string.digits, k=16))
            sid = str(len(dataclass_sid.query.all()) + 1)
            print("sid:" + sid)
            dataclass_sid = SidEntry(find_form.userID.data, sid, uuid)
            the_db.session.add(dataclass_sid)
            the_db.session.commit()
            userid = find_form.userID.data
            flash(Markup('SID Created for:' + userid + '<br><strong>sid:' + sid + '</strong><br>uuid:' + uuid),
                  'success')

    if add_form.add_userid.data and add_form.validate_on_submit():
        if not db_search_userid(find_form.userID.data):
            uuid = ''.join(random.choices(string.ascii_letters + string.digits, k=16))
            dataclass = UserEntry(add_form.userID_added.data, add_form.balance.data)
            the_db.session.add(dataclass)
            the_db.session.commit()
            flash(
                Markup('<strong>' + add_form.userID_added.data + '</strong> found!' + '<br>balance:'
                       + add_form.balance.data + '<br>uuid:' + uuid), 'success')
        else:
            flash(Markup('<strong>' + add_form.userID_added.data + '</strong> already exists!'), 'danger')

    return render_template('oneWallet.html', which_tab=request.url.rsplit('/', 1)[1], ow_findUser_form=find_form,
                           ow_addUser_form=add_form, form=uaform, UA_payload=theSession.UA_payload)


@app.route('/api/credit', methods=['POST'])
def credit():
    # handle the POST request
    if request.method == 'POST':
        if valid_token_id():
            if valid_sid():
                userid = match_userid_sid()
                if userid:
                    if valid_game():
                        if valid_currency():
                            if valid_transaction():
                                uuid = valid_uuid()
                                if uuid:
                                    if valid_amount():
                                        return valid_credit(userid, uuid)
                                    else:
                                        return valid_amount(False)
                                else:
                                    return valid_uuid(False)
                            else:
                                return valid_transaction(False)
                        else:
                            return valid_currency(False)
                    else:
                        return valid_game(False)
                else:
                    return match_userid_sid(False)
            else:
                return valid_sid(False)
        else:
            return valid_token_id(False)


@app.route('/api/cancel', methods=['POST'])
def cancel():
    # handle the POST request
    if request.method == 'POST':
        if valid_token_id():
            if valid_sid():
                userid = match_userid_sid()
                if userid:
                    if valid_game():
                        if valid_currency():
                            if valid_transaction():
                                uuid = valid_uuid()
                                if uuid:
                                    if valid_amount():
                                        return valid_cancel(userid, uuid)
                                else:
                                    return valid_uuid(False)
                            else:
                                return valid_transaction(False)
                        else:
                            return valid_currency(False)
                    else:
                        return valid_game(False)
                else:
                    return match_userid_sid(False)
            else:
                return valid_sid(False)
        else:
            return valid_token_id(False)


@app.route('/api/debit', methods=['POST'])
def debit():
    # handle the POST request
    if request.method == 'POST':
        if valid_token_id():
            if valid_sid():
                userid = match_userid_sid()
                if userid:
                    if valid_game():
                        if valid_currency():
                            if valid_transaction():
                                uuid = valid_uuid()
                                if uuid:
                                    if valid_amount():
                                        return valid_debit(userid, uuid)
                                    else:
                                        return valid_amount(False)
                                else:
                                    return valid_uuid(False)
                            else:
                                return valid_transaction(False)
                        else:
                            return valid_currency(False)
                    else:
                        return valid_game(False)
                else:
                    return match_userid_sid(False)
            else:
                return valid_sid(False)
        else:
            return valid_token_id(False)


@app.route('/api/balance', methods=['POST'])
def get_balance():
    # handle the POST request
    if request.method == 'POST':
        if valid_token_id():
            if valid_sid():
                userid = match_userid_sid()
                if userid:
                    if valid_game():
                        if valid_currency():
                            uuid = valid_uuid()
                            if uuid:
                                return send_json("OK", False, uuid, db_get_balance(userid))
                            else:
                                return valid_uuid(False)
                        else:
                            return valid_currency(False)
                    else:
                        return valid_game(False)
                else:
                    return match_userid_sid(False)
            else:
                return valid_sid(False)
        else:
            return valid_token_id(False)


@app.route('/api/sid', methods=['POST'])
def sid_user():
    # handle the POST request
    if request.method == 'POST':
        if valid_token_id():

            userid = valid_user()
            if userid:
                if valid_channel():
                    uuid = valid_uuid()
                    if uuid:
                        if valid_sid():
                            sid = db_new_sid(userid, uuid)
                            return send_json("OK", sid, uuid)
                        else:
                            return valid_sid(False)
                    else:
                        return valid_uuid(False)
                else:
                    return valid_channel(False)
            else:
                return valid_user(False)

        else:
            return valid_token_id(False)


@app.route('/api/check', methods=['POST'])
def check_user():
    # handle the POST request
    if request.method == 'POST':
        if valid_token_id():
            if valid_sid():
                if valid_channel():
                    uuid = valid_uuid()
                    if uuid:
                        userid = valid_user()
                        if userid:
                            return valid_check_user(userid, uuid)
                        else:
                            return valid_user(False)
                    else:
                        return valid_uuid(False)
                else:
                    return valid_channel(False)
            else:
                return valid_sid(False)
        else:
            return valid_token_id(False)


@app.route('/api/rb', methods=['GET', 'POST'])
def rb():
    if not UserEntry().query.filter_by(player_id='walt').all():
        print('test')
        user = UserEntry('walt', '1000')
        the_db.session.add(user)
    if not UserEntry().query.filter_by(player_id='jim').all():
        user = UserEntry('jim', '1000')
        the_db.session.add(user)
    the_db.session.commit()
    return 'done'


# @app.route('/settings', methods=['GET', 'POST'])
# def start():
#     global which_tab
#     which_tab = 'home'
#     global theSession
#     theSession = userAuth.UA2(request.host_url)
#     global uaform
#     uaform = UserAuthenticationForm()
#     # requests.close()
#
#     if uaform.validate_on_submit():
#         if uaform.update.data:
#             theSession.update_user_info(uaform)
#             flash('User Info Updated!', 'success')
#
#     return render_template('editUser.html', which_tab=which_tab, form=uaform, UA_payload=theSession.UA_payload)


@app.route('/game_window')
def game_window():
    global theSession
    if 'table' in theSession.UA_payload['config']['game']:
        theSession.UA_payload['config']['game']['table']['id'] = ''
    ua_url = theSession.url + '/ua/v1/' + theSession.casino_id + '/' + theSession.auth_key
    x = requests.post(ua_url, json=theSession.UA_payload)
    webbrowser.open(theSession.url + x.json()['entry'])

    return render_template('editUser.html', form=uaform, UA_payload=theSession.UA_payload)


@app.route('/game_window_slots')
def game_window_slots():
    global theSession
    if 'table' in theSession.UA_payload['config']['game']:
        theSession.UA_payload['config']['game']['table']['id'] = 'streetfighter200'

    theSession.UA_payload['config']['game']['category'] = 'slots'
    ua_url = theSession.url + '/ua/v1/' + theSession.casino_id + '/' + theSession.auth_key
    x = requests.post(ua_url, json=theSession.UA_payload)
    webbrowser.open(theSession.url + x.json()['entry'])

    return render_template('editUser.html', form=uaform, UA_payload=theSession.UA_payload)


@app.route('/mini_roulette')
def mini_roulette():
    global theSession
    global iframe_game_toggle
    if iframe_game_toggle:
        iframe_game_toggle = False
    else:
        iframe_game_toggle = True

    theSession.mini_roulette()
    # mini_roulette_payload = theSession.UA_payload
    #
    # mini_roulette_payload['config']['game']['table'] = {'id': 'pegck3qfanmqbgbh'}
    #
    # x = requests.post('https://diyft4.uat1.evo-test.com/ua/v1/diyft40000000001/test123', json=mini_roulette_payload)
    # theSession.UA_payload['game_url'] = 'https://diyft4.uat1.evo-test.com' + x.json()['entry']

    return render_template('game_iframe.html', launch_game=iframe_game_toggle, form=uaform,
                           UA_payload=theSession.UA_payload)


@app.route('/daily_report', methods=['GET', 'POST'])
def daily_report():
    report = theSession.daily_report()

    return render_template('daily_report.html', len=len(report), daily_report=report,
                           which_tab=request.url.rsplit('/', 1)[1], form=uaform, UA_payload=theSession.UA_payload)


@app.route('/direct_game_launch', methods=['GET', 'POST'])
def direct_game_launch():
    game_launch_info = theSession.direct_game_launch()

    return render_template('direct_game_launch.html', len=len(game_launch_info), game_launch_info=game_launch_info,
                           which_tab=request.url.rsplit('/', 1)[1], form=uaform, UA_payload=theSession.UA_payload)


@app.route('/game_stream', methods=['GET', 'POST'])
def game_stream():
    global datastream
    datastream.clear()
    stream = 'Waiting for game data...'
    waiting = 'Waiting for game data...'

    return render_template('game_stream.html', datastream=stream, which_tab=request.url.rsplit('/', 1)[1], form=uaform,
                           UA_payload=theSession.UA_payload)


@app.route('/update_stream', methods=['POST'])
def update_stream():
    global datastream
    datastream[theSession.game_stream()['id']] = theSession.game_stream()
    # walt = ''.join(random.choices(string.ascii_letters + string.digits, k=16))

    return jsonify("", render_template('input_stream.html', datastream=datastream, count=len(datastream)))


if __name__ == '__main__':
    app.debug = True
    reload_icon_placement()
    reload_evo_game_titles()
    app.run()