From ff91b0ac81488e910690abf8271b50e6378261e9 Mon Sep 17 00:00:00 2001 From: Mark Veidemanis Date: Fri, 24 Dec 2021 17:26:31 +0000 Subject: [PATCH] Begin implementing Agora ad calls --- handler/agora.py | 116 ++++++++++++++++++++++++++--------------------- 1 file changed, 64 insertions(+), 52 deletions(-) diff --git a/handler/agora.py b/handler/agora.py index 405e3f1..141477a 100644 --- a/handler/agora.py +++ b/handler/agora.py @@ -2,9 +2,11 @@ from twisted.logger import Logger # Other library imports +from json import dumps, loads +from simplejson.errors import JSONDecodeError import requests -from json import loads from forex_python.converter import CurrencyRates +from agoradesk_py.agoradesk import AgoraDesk # Project imports from settings import settings @@ -15,81 +17,91 @@ class Agora(object): AgoraDesk API handler. """ - def __init__(self): + def __init__(self, irc): self.log = Logger("agora") + self.agora = AgoraDesk(settings.Agora.Token) self.cr = CurrencyRates() + self.irc = irc - def get_active_trades(self): - headers = {"Content-Type": "application/json", "User-Agent": "Agora-Py", "Authorization": settings.Agora.Token} - # data = {"username": "topmonero"} - r = requests.get(f"{settings.Agora.Base}/dashboard", headers=headers) - parsed = r.json()["data"] - - count = parsed["contact_count"] - if not count: - return False - # for contact in parsed["contact_list"]: - # contact_id = contact["data"]["contact_id"] - # buyer = contact["data"]["buyer"]["username"] - # seller = contact["data"]["seller"]["username"] - # amount = contact["data"]["amount"] - # amount_xmr = contact["data"]["amount_xmr"] - # fee_xmr = contact["data"]["fee_xmr"] - # currency = contact["data"]["currency"] - # if not contact["data"]["is_selling"]: - # continue + def try_json(self, data): + try: + parsed = data.json() + return parsed + except JSONDecodeError: + self.log.error("Cannot parse {content}", content=data.content) + return str(data.content) - return parsed + def get_active_trades(self): + rtrn = self.agora.dashboard() + return rtrn def get_messages(self, contact_id): - headers = {"Content-Type": "application/json", "User-Agent": "Agora-Py", "Authorization": settings.Agora.Token} + headers = {"Authorization": settings.Agora.Token, "Content-Type": "application/json", "User-Agent": "Agora-Py"} r = requests.get(f"{settings.Agora.Base}/contact_messages/{contact_id}", headers=headers) - parsed = r.json() + parsed = self.try_json(r) return parsed def get_ads(self): - headers = {"Content-Type": "application/json", "User-Agent": "Agora-Py", "Authorization": settings.Agora.Token} + headers = {"Authorization": settings.Agora.Token, "Content-Type": "application/json", "User-Agent": "Agora-Py"} r = requests.get(f"{settings.Agora.Base}/ads", headers=headers) - parsed = r.json() + parsed = self.try_json(r) return parsed - def create_ad(self, countrycode, currency, price): - headers = { - "Content-Type": "application/json", - "User-Agent": "Mozilla/5.0 (X11; Linux x86_64; rv:95.0) Gecko/20100101 Firefox/95.0", - "Authorization": settings.Agora.Token, - } + def get_rates_all(self): + rates = self.cr.get_rates("USD") + return rates + def create_ad(self, countrycode, currency): + headers = {"Authorization": settings.Agora.Token, "Content-Type": "application/json"} + print(dumps(headers)) + # data = { + # "price_equation": f"coingeckoxmrusd*{settings.Agora.Margin}", + # "countrycode": countrycode, + # "currency": currency, + # "msg": settings.Agora.Ad, + # "track_max_amount": "false", + # "online_provider": "REVOLUT", + # "trade_type": "ONLINE_SELL", + # "min_amount": price * float(settings.Agora.Margin), + # # "max_amount": maxAmount, + # "asset": "XMR", + # "payment_method_detail": settings.Agora.PaymentMethodDetail, + # "require_feedback_score": 0, + # "account_info": settings.Agora.PaymentDetails, + # } + + priceformula = f"coingeckoxmrusdusd{currency.lower()}*{settings.Agora.Margin}" + rates = self.get_rates_all() + minamount = rates[currency] * float(settings.Agora.MinUSD) + maxamount = rates[currency] * float(settings.Agora.MaxUSD) data = { + "price_equation": priceformula, "countrycode": countrycode, "currency": currency, + # "account_info": "My WeChat ID is XXXXX.", + "msg": settings.Agora.Ad, + # "account_info": settings.Agora.PaymentDetails, + "track_max_amount": 0, + "online_provider": "REVOLUT", "trade_type": "ONLINE_SELL", + "min_amount": minamount, + "max_amount": maxamount, "asset": "XMR", - "price_equation": f"coingeckoxmrusd*{settings.Agora.Margin}", - "track_max_amount": False, - "require_trusted_by_advertiser": False, - "online_provider": "REVOLUT", - "verified_email_required": False, - "msg": settings.Agora.Ad, - "min_amount": price * float(settings.Agora.Margin), - # "max_amount": a, - # "limit_to_fiat_amounts": a, - "payment_method_detail": settings.Agora.PaymentMethodDetail, - # "first_time_limit_asset": a, - "require_feedback_score": settings.Agora.FeedbackScore, - "account_info": settings.Agora.PaymentDetails, + "payment_method_details": settings.Agora.PaymentMethodDetails, + # "firsttimelimit_xmr": "0.5", + # "require_feedback_score": 0, + "require_trusted_by_advertiser": 0, + "verified_email_required": 0, } - r = requests.post(f"{settings.Agora.WebBase}/ad-create", data=data, headers=headers) - self.log.info(r.content) - parsed = r.json() + print(dumps(data)) + r = requests.post(f"{settings.Agora.Base}/ad-create", json=dumps(data), headers=headers) + # self.log.info(str(r.content)) + parsed = self.try_json(r) return parsed def dist_countries(self): - prices = {} - rates = self.cr.get_rates("USD") for currency, countrycode in loads(settings.Agora.DistList): - prices[currency] = rates[currency] - rtrn = self.create_ad(countrycode, currency, prices[currency]) + rtrn = self.create_ad(countrycode, currency) if not rtrn: return False return True