<html><head><meta name="color-scheme" content="light dark"></head><body><pre style="word-wrap: break-word; white-space: pre-wrap;">import psycopg2
from datetime import datetime
import pytz
import HelperFunctions
import json

def handleDBInsert(
    full_item_name,
    floatvalue,
    paintseed,
    inspect_link,
    price,
    page,
    stickertext,
    rank,
    steamid,
    queryid,
    result_json,
):
    # result_json = json.dumps(result_json)
    item_encoded = HelperFunctions.encodeItemName(str(full_item_name))
    all_market_params = str(inspect_link).split("%20")[1]
    m_param = str(str(all_market_params).split("A")[0])[1:]
    a_param = str(str(all_market_params).split("A")[1].split("D")[0])
    market_url = HelperFunctions.generateMarketLink(item_encoded, m_param, a_param)
    int_steamid = int(str(steamid).replace("'", ""))
    
    conn = psycopg2.connect(
        database="cs2snipe",  # enter your database name
        user="postgres",  # enter your postgres username
        password="Berufsorientierung1!",  # enter your password
        host="23.88.122.57",  # enter your host name
        port="5432",  # port number
    )
    cursor = conn.cursor()
    
    query = """ INSERT INTO sniper_cs2snipe_found (skin, price, inspect_link, market_url, steamid, page, pub_date, foundskins_id_id) VALUES (%s, %s, %s, %s, %s, %s, %s, %s) RETURNING id"""
    values = (full_item_name, price, inspect_link, market_url, steamid, page + 1, datetime.now(pytz.timezone("Europe/Vienna")), queryid)
    cursor.execute(query, values)
    current_pk = cursor.fetchone()[0]
    
    if (
        result_json["filter_options"] == "exact_float"
        or result_json["filter_options"] == "float_restrictions"
    ):
        query = """UPDATE sniper_cs2snipe_found SET float = %s WHERE id = %s"""
        cursor.execute(query, (floatvalue, current_pk))
    if "pattern" in result_json:
        query = """UPDATE sniper_cs2snipe_found SET pattern = %s WHERE id = %s"""
        cursor.execute(query, (paintseed, current_pk))
    if "more_filters" in result_json:
        if "rank" in result_json["more_filters"] and rank is not None:
            query = """UPDATE sniper_cs2snipe_found SET rank = %s WHERE id = %s"""
            cursor.execute(query, (rank, current_pk))
            query = """UPDATE sniper_cs2snipe_found SET float = %s WHERE id = %s"""
            cursor.execute(query, (floatvalue, current_pk))
    if "stickerpanel" in result_json:
        query = """UPDATE sniper_cs2snipe_found SET stickers = %s WHERE id = %s"""
        cursor.execute(query, (stickertext, current_pk))

    conn.commit()
    cursor.close()
    conn.close()
    return None


def updateQuery(queryid, query_failed, query_status, query_message):
    # model = apps.get_model("sniper", "cs2snipe_queries")
    try:
        conn = psycopg2.connect(
            database="cs2snipe",  # enter your database name
            user="postgres",  # enter your postgres username
            password="Berufsorientierung1!",  # enter your password
            host="23.88.122.57",  # enter your host name
            port="5432",  # port number
        )
        cursor = conn.cursor()
        query = """UPDATE sniper_cs2snipe_queries SET query_failed = %s, message = %s, query_status = %s WHERE id = %s"""
        cursor.execute(query, (query_failed, query_message, query_status, queryid))
        conn.commit()
        cursor.close()
        conn.close()
    except Exception as e:
        print(str(e))

def updateFreeSnipes(steamid, plus_or_minus):
    try:
        conn = psycopg2.connect(
            database="cs2snipe",  # enter your database name
            user="postgres",  # enter your postgres username
            password="Berufsorientierung1!",  # enter your password
            host="23.88.122.57",  # enter your host name
            port="5432",  # port number
        )
        cursor = conn.cursor()
        if plus_or_minus == "plus":
            query = """UPDATE sniper_cs2snipe_users SET free_snipes = free_snipes + 1 WHERE id = %s"""
        else:
            query = """UPDATE sniper_cs2snipe_users SET free_snipes = free_snipes - 1 WHERE id = %s"""
        cursor.execute(query, (steamid))
        conn.commit()
        cursor.close()
        conn.close()
    except Exception as e:
        print(str(e))

def getResultCount(queryid, steamid):
    try:
        conn = psycopg2.connect(
            database="cs2snipe",  # enter your database name
            user="postgres",  # enter your postgres username
            password="Berufsorientierung1!",  # enter your password
            host="23.88.122.57",  # enter your host name
            port="5432",  # port number
        )
        cursor = conn.cursor()
        query = """SELECT count(*) FROM sniper_cs2snipe_found WHERE foundskins_id_id = %s AND steamid = %s"""
        cursor.execute(query, (queryid, steamid))
        count = cursor.fetchone()[0]
        conn.commit()
        cursor.close()
        conn.close()
        return count
    except Exception as e:
        print(str(e))</pre></body></html>