XF/pluto
XF
/
pluto
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Libraries refactor and add some sinks #4

Closed
m wants to merge 136 commits from library-refactor into master
pull from: library-refactor
merge into: XF:master
Conversation 1 Commits 136 Files Changed 23 +4 -4
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit a639b32727 - Show all commits

4
handler/agora.py
View File

@ -514,7 +514,7 @@ class Agora(object):
iterations += 1 iterations += 1
if iterations == 0: if iterations == 0:
self.log.info("Slow ad update finished, no ads to update") self.log.info("Slow ad update finished, no ads to update")
self.irc.sendmsg("Slow ad update finished, no ads to update") # self.irc.sendmsg("Slow ad update finished, no ads to update")
else: else:
self.log.info( self.log.info(
"Slow ad update completed with {iterations} iterations: [{assets}] | [{currencies}]", "Slow ad update completed with {iterations} iterations: [{assets}] | [{currencies}]",
@ -522,7 +522,7 @@ class Agora(object):
assets=", ".join(assets), assets=", ".join(assets),
currencies=", ".join(currencies), currencies=", ".join(currencies),
) )
self.irc.sendmsg(f"Slow ad update completed with {iterations} iterations: [{', '.join(assets)}] | [{', '.join(currencies)}]") # self.irc.sendmsg(f"Slow ad update completed with {iterations} iterations: [{', '.join(assets)}] | [{', '.join(currencies)}]")
@handle_exceptions @handle_exceptions
def nuke_ads(self): def nuke_ads(self):

4
handler/markets.py
View File

@ -55,7 +55,7 @@ class Markets(object):
try: try:
public_ads_currency = public_ads[currency] public_ads_currency = public_ads[currency]
except KeyError: except KeyError:
self.log.error("Error getting public ads for currency {currency}", currency=currency) # self.log.error("Error getting public ads for currency {currency}", currency=currency)
if currency == "USD": if currency == "USD":
self.log.error("Error getting public ads for currency USD, aborting") self.log.error("Error getting public ads for currency USD, aborting")
break break
@ -71,7 +71,7 @@ class Markets(object):
if not our_ads: if not our_ads:
continue continue
new_margin = self.autoprice(public_ads_filtered, currency) new_margin = self.autoprice(public_ads_filtered, currency)
self.log.info("New rate for {currency}: {rate}", currency=currency, rate=new_margin) # self.log.info("New rate for {currency}: {rate}", currency=currency, rate=new_margin)
new_formula = f"coingecko{asset.lower()}usd*usd{currency.lower()}*{new_margin}" new_formula = f"coingecko{asset.lower()}usd*usd{currency.lower()}*{new_margin}"
for ad in our_ads: for ad in our_ads:
ad_id = ad[0] ad_id = ad[0]