requirements

This commit is contained in:
Eriks Karls 2019-07-22 11:03:14 +03:00
parent 2d246cbf4b
commit f12bd0ed57
19 changed files with 27 additions and 16355 deletions

View File

@ -6,21 +6,12 @@ eRepublik script
.. image:: https://img.shields.io/pypi/v/erepublik_script.svg .. image:: https://img.shields.io/pypi/v/erepublik_script.svg
:target: https://pypi.python.org/pypi/erepublik_script :target: https://pypi.python.org/pypi/erepublik_script
.. image:: https://img.shields.io/travis/eeriks/erepublik_script.svg
:target: https://travis-ci.org/eeriks/erepublik_script
.. image:: https://readthedocs.org/projects/erepublik-script/badge/?version=latest .. image:: https://readthedocs.org/projects/erepublik-script/badge/?version=latest
:target: https://erepublik-script.readthedocs.io/en/latest/?badge=latest :target: https://erepublik-script.readthedocs.io/en/latest/?badge=latest
:alt: Documentation Status :alt: Documentation Status
.. image:: https://pyup.io/repos/github/eeriks/erepublik_script/shield.svg Python package for automated eRepublik playing
:target: https://pyup.io/repos/github/eeriks/erepublik_script/
:alt: Updates
Python package for eRepublik automated playing
* Free software: MIT license * Free software: MIT license

File diff suppressed because one or more lines are too long

File diff suppressed because one or more lines are too long

View File

@ -1 +0,0 @@
<html><head><meta http-equiv="refresh" content="0;url=https://www.erepublik.com/en"/></head></html>

File diff suppressed because one or more lines are too long

File diff suppressed because one or more lines are too long

File diff suppressed because one or more lines are too long

File diff suppressed because one or more lines are too long

File diff suppressed because one or more lines are too long

File diff suppressed because one or more lines are too long

File diff suppressed because one or more lines are too long

View File

@ -1 +0,0 @@
{"error":false,"enabled":true,"type":{"anniversary":false,"flavorPacks":false,"springChallenge":false,"summerChallenge":false,"halloweenChallenge":false},"timeLeft":346765,"nextReward":{"maxReward":false,"type":"icon_energy_booster","text":"+1 Energy recovery until the end of Day 4,262"},"maxRewardId":0,"player":{"avatar":"//cdnt.erepublik.net/7efiav4XZ4SMvXAtgEk1NciUmAg=/55x55/smart/avatars/Citizens/2009/07/08/4b57b9ebb0232f0d6c3f6f2c21b8ab95.jpg?c022b6df6f643263dba839cb35b7a9ab","name":"inpoc1","prestigePoints":14170},"progress":0.9141935483871,"rewards":{"normal":[{"id":59,"collectedBefore":58,"percent":0.74193548387097,"label":"You have already collected this reward","tooltip":"","status":"rewarded","icon":"energy_bars"},{"id":60,"collectedBefore":0,"percent":0.016129032258065,"label":"You have already collected this reward","tooltip":"","status":"rewarded","icon":"energy_booster"},{"id":61,"collectedBefore":0,"percent":0.016129032258065,"label":"You have already collected this reward","tooltip":"","status":"rewarded","icon":"energy_bars"},{"id":62,"collectedBefore":0,"percent":0.016129032258065,"label":"You have already collected this reward","tooltip":"","status":"rewarded","icon":"energy_booster"},{"id":63,"collectedBefore":0,"percent":0.016129032258065,"label":"You have already collected this reward","tooltip":"","status":"rewarded","icon":"energy_bars"},{"id":64,"collectedBefore":0,"percent":0.016129032258065,"label":"You have already collected this reward","tooltip":"","status":"rewarded","icon":"energy_booster"},{"id":65,"collectedBefore":0,"percent":0.016129032258065,"label":"You have already collected this reward","tooltip":"","status":"rewarded","icon":"energy_bars"},{"id":66,"collectedBefore":0,"percent":0.016129032258065,"label":"You have already collected this reward","tooltip":"","status":"rewarded","icon":"energy_booster"},{"id":67,"collectedBefore":0,"percent":0.016129032258065,"label":"You have already collected this reward","tooltip":"","status":"rewarded","icon":"energy_bars"},{"id":68,"collectedBefore":0,"percent":0.016129032258065,"label":"You have already collected this reward","tooltip":"","status":"rewarded","icon":"energy_booster"},{"id":69,"collectedBefore":0,"percent":0.016129032258065,"label":"You have already collected this reward","tooltip":"","status":"rewarded","icon":"energy_bars"},{"id":70,"collectedBefore":0,"percent":0.016129032258065,"label":"Reach 14,250 Prestige Points to unlock the following reward: +1 Energy recovery until the end of Day 4,262","tooltip":"Reach 14250 Prestige Points to unlock the following reward: +1 Energy recovery until the end of Day 4,262","status":"","icon":"energy_booster"},{"id":71,"collectedBefore":0,"percent":0.016129032258065,"label":"Reach 14,500 Prestige Points to unlock the following reward: 10 Energy Bars","tooltip":"Reach 14500 Prestige Points to unlock the following reward: 10 Energy Bars","status":"","icon":"energy_bars"},{"id":72,"collectedBefore":0,"percent":0.032258064516129,"label":"Reach 15,000 Prestige Points to unlock the following reward: +1 Energy recovery until the end of Day 4,262","tooltip":"Reach 15000 Prestige Points to unlock the following reward: +1 Energy recovery until the end of Day 4,262","status":"","icon":"energy_booster"},{"id":73,"collectedBefore":0,"percent":0.016129032258065,"label":"Reach 15,250 Prestige Points to unlock the following reward: +1 Energy recovery until the end of Day 4,262","tooltip":"Reach 15250 Prestige Points to unlock the following reward: +1 Energy recovery until the end of Day 4,262","status":"","icon":"energy_booster"},{"id":74,"collectedBefore":0,"percent":0.016129032258065,"label":"Reach 15,500 Prestige Points to unlock the following reward: 15 Energy Bars","tooltip":"Reach 15500 Prestige Points to unlock the following reward: 15 Energy Bars","status":"","icon":"energy_bars"}],"extra":[]}}

File diff suppressed because one or more lines are too long

View File

@ -778,57 +778,57 @@ class CitizenAPI:
def post_country_comment_retrieve(self, token: str, post_id: int): def post_country_comment_retrieve(self, token: str, post_id: int):
data = {"_token": token, "postId": post_id} data = {"_token": token, "postId": post_id}
return self.post("{}/main/country-comment/retrieve/".format(self.url), data=data) return self.post("{}/main/country-comment/retrieve/json".format(self.url), data=data)
def post_country_post_create(self, token: str, body: str, post_as: int): def post_country_post_create(self, token: str, body: str, post_as: int):
data = {"_token": token, "post_message": body, "post_as": post_as} data = {"_token": token, "post_message": body, "post_as": post_as}
return self.post("{}/main/country-post/create/".format(self.url), data=data) return self.post("{}/main/country-post/create/json".format(self.url), data=data)
def post_country_post_retrieve(self, token: str): def post_country_post_retrieve(self, token: str):
data = {"_token": token, "page": 1, "switchedFrom": False} data = {"_token": token, "page": 1, "switchedFrom": False}
return self.post("{}/main/country-post/retrieve/".format(self.url), data=data) return self.post("{}/main/country-post/retrieve/json".format(self.url), data=data)
# ## Military Unit # ## Military Unit
def post_military_unit_comment_retrieve(self, token: str, post_id: int): def post_military_unit_comment_retrieve(self, token: str, post_id: int):
data = {"_token": token, "postId": post_id} data = {"_token": token, "postId": post_id}
return self.post("{}/main/military-unit-comment/retrieve/".format(self.url), data=data) return self.post("{}/main/military-unit-comment/retrieve/json".format(self.url), data=data)
def post_military_unit_post_create(self, token: str, body: str, post_as: int): def post_military_unit_post_create(self, token: str, body: str, post_as: int):
data = {"_token": token, "post_message": body, "post_as": post_as} data = {"_token": token, "post_message": body, "post_as": post_as}
return self.post("{}/main/military-unit-post/create/".format(self.url), data=data) return self.post("{}/main/military-unit-post/create/json".format(self.url), data=data)
def post_military_unit_post_retrieve(self, token: str): def post_military_unit_post_retrieve(self, token: str):
data = {"_token": token, "page": 1, "switchedFrom": False} data = {"_token": token, "page": 1, "switchedFrom": False}
return self.post("{}/main/military-unit-post/retrieve/".format(self.url), data=data) return self.post("{}/main/military-unit-post/retrieve/json".format(self.url), data=data)
# ## Party # ## Party
def post_party_comment_retrieve(self, token: str, post_id: int): def post_party_comment_retrieve(self, token: str, post_id: int):
data = {"_token": token, "postId": post_id} data = {"_token": token, "postId": post_id}
return self.post("{}/main/party-comment/retrieve/".format(self.url), data=data) return self.post("{}/main/party-comment/retrieve/json".format(self.url), data=data)
def post_party_post_create(self, token: str, body: str): def post_party_post_create(self, token: str, body: str):
data = {"_token": token, "post_message": body} data = {"_token": token, "post_message": body}
return self.post("{}/main/party-post/create/".format(self.url), data=data) return self.post("{}/main/party-post/create/json".format(self.url), data=data)
def post_party_post_retrieve(self, token: str): def post_party_post_retrieve(self, token: str):
data = {"_token": token, "page": 1, "switchedFrom": False} data = {"_token": token, "page": 1, "switchedFrom": False}
return self.post("{}/main/party-post/retrieve/".format(self.url), data=data) return self.post("{}/main/party-post/retrieve/json".format(self.url), data=data)
# ## Friend's Wall # ## Friend's Wall
def post_wall_comment_retrieve(self, token: str, post_id: int): def post_wall_comment_retrieve(self, token: str, post_id: int):
data = {"_token": token, "postId": post_id} data = {"_token": token, "postId": post_id}
return self.post("{}/main/wall-comment/retrieve/".format(self.url), data=data) return self.post("{}/main/wall-comment/retrieve/json".format(self.url), data=data)
def post_wall_post_create(self, token: str, body: str): def post_wall_post_create(self, token: str, body: str):
data = {"_token": token, "post_message": body} data = {"_token": token, "post_message": body}
return self.post("{}/main/wall-post/create/".format(self.url), data=data) return self.post("{}/main/wall-post/create/json".format(self.url), data=data)
def post_wall_post_retrieve(self, token: str): def post_wall_post_retrieve(self, token: str):
data = {"_token": token, "page": 1, "switchedFrom": False} data = {"_token": token, "page": 1, "switchedFrom": False}
return self.post("{}/main/wall-post/retrieve/".format(self.url), data=data) return self.post("{}/main/wall-post/retrieve/json".format(self.url), data=data)
class Reporter: class Reporter:

View File

@ -1,422 +0,0 @@
# -*- coding: utf-8 -*-
"""Console script for erepublik_script."""
import json
import os
import random
import sys
import threading
from collections import defaultdict
from datetime import timedelta
from typing import List, Tuple
import click
from erepublik_script import classes, utils
from erepublik_script.citizen import Citizen
__all__ = ["Citizen"]
CONFIG = defaultdict(bool)
@click.command()
@click.option('--silent', help='Run silently', type=bool, is_flag=True)
def main(silent):
global CONFIG
assert sys.version_info >= (3, 7, 1)
if silent:
write_log = utils.write_silent_log
else:
write_log = utils.write_interactive_log
try:
with open('config.json', 'r') as f:
CONFIG = json.load(f)
write_log('Config file found. Checking...')
CONFIG = utils.parse_config(CONFIG)
except:
CONFIG = utils.parse_config()
with open('config.json', 'w') as f:
json.dump(CONFIG, f, indent=True, sort_keys=True)
if CONFIG['interactive']:
write_log = utils.write_interactive_log
else:
write_log = utils.write_silent_log
write_log('\nTo quit press [ctrl] + [c]', False)
os.chdir(os.path.dirname(os.path.realpath(__file__)))
write_log('Version: ' + utils.VERSION)
player = None
try: # If errors before player is initialized
while True:
player = Citizen(email=CONFIG['email'], password=CONFIG['password'])
if player.logged_in:
break
utils.silent_sleep(2)
player.config.work = CONFIG['work']
player.config.train = CONFIG['train']
player.config.ot = CONFIG['ot']
player.config.wam = bool(CONFIG['wam'])
player.config.employees = bool(CONFIG['employ'])
player.config.auto_sell = CONFIG.get('auto_sell', [])
player.config.auto_sell_all = CONFIG.get('auto_sell_all', False)
player.config.auto_buy_raw = CONFIG.get('auto_buy_raw', False)
player.config.force_wam = CONFIG.get('force_wam', False)
player.config.fight = CONFIG['fight']
player.config.air = CONFIG['air']
player.config.ground = CONFIG['ground']
player.config.all_in = CONFIG['all_in']
player.config.next_energy = CONFIG['next_energy']
player.config.boosters = CONFIG['boosters']
player.config.travel_to_fight = CONFIG['travel_to_fight']
player.config.always_travel = CONFIG.get('always_travel', False)
player.config.epic_hunt = CONFIG['epic_hunt']
player.config.epic_hunt_ebs = CONFIG['epic_hunt_ebs']
player.config.rw_def_side = CONFIG['rw_def_side']
player.config.random_sleep = CONFIG['random_sleep']
player.config.continuous_fighting = CONFIG['continuous_fighting']
player.config.interactive = CONFIG['interactive']
player.reporter.allowed = not CONFIG.get('reporting_is_not_allowed')
player.set_debug(CONFIG.get('debug', False))
while True:
try:
player.update_all()
break
except:
utils.silent_sleep(2)
now = utils.now()
dt_max = now.replace(year=9999)
tasks = {
'eat': now,
}
wam_hour = employ_hour = 14
if player.config.work:
tasks.update({'work': now})
if player.config.train:
tasks.update({'train': now})
if player.config.ot:
tasks.update({'ot': now})
if player.config.fight:
tasks.update({'fight': now})
if player.config.wam:
wam_hour = 14
if not isinstance(CONFIG['wam'], bool):
try:
wam_hour = abs(int(CONFIG['wam'])) % 24
except ValueError:
pass
tasks.update({'wam': now.replace(hour=wam_hour, minute=0, second=0, microsecond=0)})
if player.config.employees:
employ_hour = 8
if not isinstance(CONFIG['employ'], bool):
try:
employ_hour = abs(int(CONFIG['employ'])) % 24
except ValueError:
pass
tasks.update({'employ': now.replace(hour=employ_hour, minute=0, second=0, microsecond=0)})
if player.config.epic_hunt:
tasks['epic_hunt'] = now
if CONFIG.get("renew_houses", True):
tasks['renew_houses'] = now
if CONFIG.get('start_battles'):
""" {'start_battle': {war_id: {'regions': [region_id, ],
'timing': ['at', 'hh:mm' | 'before', 'hh:mm' (before autoattack) |
'auto' (after round for citizenship country's oldest battle or at 00:00)
'rw', (after first round of RW if you are occupying)]}} """
player.allowed_battles = CONFIG.get('start_battles', dict())
raise classes.ErepublikException("Battle starting is not implemented")
if player.reporter.allowed:
report = dict(CONFIG)
report.pop("email", None)
report.pop("password", None)
report.update(
VERSION=utils.VERSION,
COMMIT_ID=utils.COMMIT_ID
)
player.reporter.report_action("ACTIVE_CONFIG", json_val=report)
# -1 because main thread is counted in
name = "{}-state_updater-{}".format(player.name, threading.active_count() - 1)
state_thread = threading.Thread(target=player.state_update_repeater, name=name)
state_thread.start()
if CONFIG.get("congress", True):
tasks['congress'] = now.replace(hour=1, minute=30, second=0)
if CONFIG.get("party_president", False):
tasks['party_president'] = now.replace(hour=1, minute=30, second=0)
contribute_cc = int(CONFIG.get("contribute_cc", 0))
if contribute_cc:
tasks['contribute_cc'] = now.replace(hour=2, minute=0, second=0)
if CONFIG.get("gold_buy"):
tasks['gold_buy'] = now.replace(hour=23, minute=57, second=0, microsecond=0)
error_count = 0
while error_count < 3:
try:
now = utils.now()
player.update_all()
if tasks.get('work', dt_max) <= now:
player.write_log("Doing task: work")
player.update_citizen_info()
player.work()
if player.config.ot:
tasks['ot'] = now
player.collect_daily_task()
next_time = now.replace(hour=0, minute=0, second=0) + timedelta(days=1)
tasks.update({'work': next_time})
if tasks.get('train', dt_max) <= now:
player.write_log("Doing task: train")
player.update_citizen_info()
player.train()
player.collect_daily_task()
next_time = now.replace(hour=0, minute=0, second=0) + timedelta(days=1)
tasks.update({'train': next_time})
if tasks.get('wam', dt_max) <= now:
player.write_log("Doing task: Work as manager")
success = player.work_wam()
player.eat()
if success:
next_time = now.replace(hour=wam_hour, minute=0, second=0, microsecond=0) + timedelta(days=1)
else:
next_time = now.replace(second=0, microsecond=0) + timedelta(minutes=30)
tasks.update({'wam': next_time})
if tasks.get('eat', dt_max) <= now:
player.write_log("Doing task: eat")
player.eat()
if player.energy.food_fights > player.energy.limit // 10:
next_minutes = 12
else:
next_minutes = (player.energy.limit - 5 * player.energy.interval) // player.energy.interval * 6
next_time = player.energy.reference_time + timedelta(minutes=next_minutes)
tasks.update({'eat': next_time})
if tasks.get('fight', dt_max) <= now or player.energy.is_energy_full:
fight_energy_debug_log: List[Tuple[int, str]] = []
player.write_log("Doing task: fight")
player.write_log(player.health_info)
if player.should_fight():
player.find_battle_and_fight()
else:
player.collect_weekly_reward()
energy = classes.EnergyToFight(player.details.xp_till_level_up * 10 - player.energy.limit + 50)
fight_energy_debug_log.append((
energy.i,
f"Levelup reachable {player.details.xp_till_level_up} * 10 - {player.energy.limit} + 50"
))
# Do levelup
energy.check(player.details.xp_till_level_up * 10 + 50)
fight_energy_debug_log.append((
energy.i, f"Levelup {player.details.xp_till_level_up} * 10 + 50"
))
# if levelup is close stop queueing other fighting
if not player.is_levelup_close:
# Obligatory need 75pp
if player.details.pp < 75:
energy.check(75 - player.details.pp)
fight_energy_debug_log.append((energy.i, f"Obligatory need 75pp: 75 - {player.details.pp}"))
if player.config.continuous_fighting and player.has_battle_contribution:
energy.check(player.energy.interval)
fight_energy_debug_log.append((energy.i, f"continuous_fighting: {player.energy.interval}"))
# All-in
if player.config.all_in:
energy.check(player.energy.limit * 2 - 3 * player.energy.interval)
fight_energy_debug_log.append((
energy.i, f"All-in: {player.energy.limit} * 2 - 3 * {player.energy.interval}"
))
elif player.energy.limit * 2 - 3 * player.energy.interval >= player.energy.recovered:
# 1h worth of energy
energy.check(player.energy.limit * 2 - 3 * player.energy.interval)
fight_energy_debug_log.append(
(energy.i, f"1h worth of energy: {player.energy.interval} * 10"
))
# All-in for AIR battles
if all([player.config.air, player.config.all_in,
player.energy.available >= player.energy.limit]):
energy.check(player.energy.limit)
fight_energy_debug_log.append((
energy.i, f"All-in for AIR battles: {player.energy.limit}"
))
# Get to next Energy +1
if player.next_reachable_energy and player.config.next_energy:
energy.check(player.next_reachable_energy * 10)
fight_energy_debug_log.append((
energy.i, f"Get to next Energy +1: {player.next_reachable_energy} * 10"
))
energy = energy.i - player.energy.available
next_minutes = max([6, abs(energy) // player.energy.interval * 6])
# utils.write_silent_log("\n".join([f"{energy} {info}" for energy, info in fight_energy_debug_log]))
next_time = player.energy.reference_time + timedelta(minutes=next_minutes)
tasks.update({'fight': next_time})
if tasks.get('ot', dt_max) <= now:
player.write_log("Doing task: ot")
if now > player.my_companies.next_ot_time:
player.work_ot()
next_time = now + timedelta(minutes=60)
else:
next_time = player.my_companies.next_ot_time
tasks.update({'ot': next_time})
if tasks.get('employ', dt_max) <= now:
player.write_log("Doing task: Employee work")
next_time = utils.now().replace(hour=employ_hour, minute=0, second=0) + timedelta(days=1)
next_time = next_time if player.work_employees() else tasks.get('employ') + timedelta(minutes=30)
tasks.update({'employ': next_time})
if tasks.get('epic_hunt', dt_max) <= now:
player.write_log("Doing task: EPIC check")
player.check_epic_battles()
if player.active_fs:
next_time = now + timedelta(minutes=1)
else:
next_time = tasks.get('eat')
tasks.update({'epic_hunt': next_time})
if tasks.get('gold_buy', dt_max) <= now:
player.write_log("Doing task: auto buy 10g")
for offer in player.get_monetary_offers():
if offer['amount'] >= 10 and player.details.cc >= 20 * offer["price"]:
# TODO: check allowed amount to buy
if player.buy_monetary_market_offer(offer=offer['offer_id'], amount=10, currency=62):
break
next_time = tasks.get('gold_buy') + timedelta(days=1)
tasks.update({'gold_buy': next_time})
if tasks.get('congress', dt_max) <= now:
if 1 <= now.day < 16:
next_time = now.replace(day=16)
elif 16 <= now.day < 24:
player.write_log("Doing task: candidate for congress")
player.candidate_for_congress()
if not now.month == 12:
next_time = now.replace(month=now.month + 1, day=16)
else:
next_time = now.replace(year=now.year + 1, month=1, day=16)
else:
if not now.month == 12:
next_time = now.replace(month=now.month + 1, day=16)
else:
next_time = now.replace(year=now.year + 1, month=1, day=16)
tasks.update({'congress': next_time.replace(hour=1, minute=30, second=0, microsecond=0)})
if tasks.get('party_president', dt_max) <= now:
if not now.day == 15:
player.write_log("Doing task: candidate for party president")
player.candidate_for_party_presidency()
if not now.month == 12:
next_time = now.replace(month=now.month + 1)
else:
next_time = now.replace(year=now.year + 1, month=1)
else:
if not now.month == 12:
next_time = now.replace(month=now.month + 1)
else:
next_time = now.replace(year=now.year + 1, month=1)
tasks.update(party_president=next_time.replace(day=16, hour=0, minute=0, second=0, microsecond=0))
if tasks.get('contribute_cc', dt_max) <= now:
if not now.weekday():
player.update_money()
cc = (player.details.cc // contribute_cc) * contribute_cc
player.write_log("Doing task: Contribute {}cc to Latvia".format(cc))
player.contribute_cc_to_country(cc)
next_time = now + timedelta(days=7 - now.weekday())
next_time = next_time.replace(hour=2, minute=0, second=0)
tasks.update({'contribute_cc': next_time})
if tasks.get('renew_houses', dt_max) <= now:
player.write_log("Doing task: Renew houses")
end_times = player.renew_houses()
if end_times:
tasks.update(renew_houses=min(end_times.values()) - timedelta(hours=24))
else:
player.write_log("No houses found! Forcing q1 usage...")
end_times = player.buy_and_activate_house(1)
if not end_times:
tasks.update(renew_houses=now + timedelta(hours=6))
else:
tasks.update(renew_houses=min(end_times.values()) - timedelta(hours=24))
closest_next_time = dt_max
next_tasks = []
for task, next_time in sorted(tasks.items(), key=lambda s: s[1]):
next_tasks.append("{}: {}".format(next_time.strftime('%F %T'), task))
if next_time < closest_next_time:
closest_next_time = next_time
random_seconds = random.randint(0, 121) if player.config.random_sleep else 0
sleep_seconds = int(utils.get_sleep_seconds(closest_next_time))
if sleep_seconds <= 0:
raise classes.ErepublikException(f"Loop detected! Offending task: '{next_tasks[0]}'")
closest_next_time += timedelta(seconds=random_seconds)
player.write_log("My next Tasks and there time:\n" + "\n".join(sorted(next_tasks)))
player.write_log("Sleeping until (eRep): {} (sleeping for {}s + random {}s)".format(
closest_next_time.strftime("%F %T"), sleep_seconds, random_seconds))
seconds_to_sleep = sleep_seconds + random_seconds if sleep_seconds > 0 else 0
player.sleep(seconds_to_sleep)
except classes.ErepublikNetworkException:
player.write_log('Network ERROR detected. Sleeping for 1min...')
player.sleep(60)
except (KeyboardInterrupt, SystemExit):
sys.exit(1)
except classes.ErepublikException as e:
utils.process_error(f"Known error detected! {e}", player.name, sys.exc_info(), player, utils.COMMIT_ID)
except:
utils.process_error("Unknown error!", player.name, sys.exc_info(), player, utils.COMMIT_ID)
error_count += 1
if error_count < 3:
player.sleep(60)
finally:
if error_count >= 3:
player.stop_threads.set()
player.stop_threads.set()
player.write_log('Too many errors.')
except (KeyboardInterrupt, SystemExit):
sys.exit(1)
except classes.ErepublikException:
utils.process_error("[{}] To many errors.".format(utils.COMMIT_ID), player.name, sys.exc_info(), player,
utils.COMMIT_ID)
except:
if isinstance(player, Citizen):
name = player.name
elif CONFIG.get('email', None):
name = CONFIG['email']
else:
name = "Uninitialized"
utils.process_error("[{}] Fatal error.".format(utils.COMMIT_ID), name, sys.exc_info(), player, utils.COMMIT_ID)
sys.exit(1)
if __name__ == "__main__":
while True:
main()
utils.write_interactive_log("Restarting after 1h")
utils.interactive_sleep(60 * 60)

View File

@ -18,7 +18,7 @@ from requests import Response
from slugify import slugify from slugify import slugify
__all__ = ["FOOD_ENERGY", "VERSION", "COMMIT_ID", "COUNTRIES", "erep_tz", __all__ = ["FOOD_ENERGY", "COMMIT_ID", "COUNTRIES", "erep_tz",
"now", "localize_dt", "localize_timestamp", "good_timedelta", "eday_from_date", "date_from_eday", "now", "localize_dt", "localize_timestamp", "good_timedelta", "eday_from_date", "date_from_eday",
"get_sleep_seconds", "interactive_sleep", "silent_sleep", "get_sleep_seconds", "interactive_sleep", "silent_sleep",
"write_silent_log", "write_interactive_log", "get_file", "write_file", "write_silent_log", "write_interactive_log", "get_file", "write_file",
@ -26,7 +26,6 @@ __all__ = ["FOOD_ENERGY", "VERSION", "COMMIT_ID", "COUNTRIES", "erep_tz",
FOOD_ENERGY = dict(q1=2, q2=4, q3=6, q4=8, q5=10, q6=12, q7=20) FOOD_ENERGY = dict(q1=2, q2=4, q3=6, q4=8, q5=10, q6=12, q7=20)
VERSION = "v0.14.1"
COMMIT_ID = "7b92e19" COMMIT_ID = "7b92e19"
erep_tz = pytz.timezone('US/Pacific') erep_tz = pytz.timezone('US/Pacific')
@ -464,267 +463,3 @@ def process_error(log_info: str, name: str, exc_info: tuple, citizen=None, commi
else: else:
write_silent_log(log_info) write_silent_log(log_info)
send_email(name, bugtrace, citizen, local_vars=inspect.trace()[-1][0].f_locals) send_email(name, bugtrace, citizen, local_vars=inspect.trace()[-1][0].f_locals)
def aviator_support(citizen, send_food=False, free_food=None):
forbidden_ids = []
if free_food is None:
free_food = {} # {"q1": 0, "q2": 1000, ...}
context = {'PLAYER_COUNT': 0, 'TABLE': "",
'STARTING_ENERGY': sum([amount * FOOD_ENERGY[q] for q, amount in free_food.items()]),
'TOTAL_CC': 0, 'TOTAL_ENERGY': 0, 'END_ENERGY': 0}
from erepublik_script import Citizen
if not isinstance(citizen, Citizen):
from .classes import ErepublikException
raise ErepublikException("\"citizen\" must be instance of erepublik.Citizen")
citizen.config.interactive = True
aviators = dict()
time_string = "%Y-%m-%d %H:%M:%S"
latest_article = requests.get('https://erep.lv/aviator/latest_article/').json()
for quality, amount in latest_article.get('free_food', {}).items():
free_food[quality] = free_food.get(quality, 0) + amount
if not latest_article.get('status'):
from .classes import ErepublikException
raise ErepublikException('Article ID and week problem')
context.update(WEEK=latest_article.get('week', 0) + 1)
comments = citizen.post_article_comments(citizen.token, latest_article.get('article_id'), 1).json()
ranking = citizen.get_leaderboards_kills_aircraft_rankings(71, 1, 0).json()
if not comments.get("comments", {}):
from .classes import ErepublikException
raise ErepublikException("No comments found")
for comment_data in comments.get("comments", {}).values():
if comment_data.get('authorId') == 1954361:
start_dt = localize_dt(datetime.datetime.strptime(comment_data.get('createdAt'), time_string))
days_ahead = 1 - start_dt.weekday()
if days_ahead <= 0:
days_ahead += 7
end_dt = (good_timedelta(start_dt, datetime.timedelta(days_ahead))).replace(hour=0, minute=0, second=0)
if not comment_data.get('replies', {}):
from .classes import ErepublikException
raise ErepublikException("No replies found")
for reply_data in comment_data.get('replies').values():
if localize_dt(datetime.datetime.strptime(reply_data.get('createdAt'), time_string)) > end_dt:
continue
if re.search(r'piesakos', reply_data.get('message'), re.I):
aviators.update({int(reply_data.get('authorId')): dict(
id=reply_data.get('authorId'), name="", kills=0, rank=0, residency=None, health=0, extra=[],
factories=0
)})
context['PLAYER_COUNT'] = len(aviators)
write_interactive_log("{:^9} | {:<28} | {:4} | {:26} | {:6} | {}".format(
"ID", "Vārds", "Kili", "Gaisa rangs", "Energy", "Aktivizētās mājas"
))
for player_top_data in ranking.get('top'):
player_id = int(player_top_data.get('id'))
if player_id in aviators:
aviators[player_id]["kills"] = int(player_top_data['values'])
for aviator_id, aviator_data in aviators.items():
aviator_info = citizen.get_citizen_profile(aviator_id).json()
aviator_data.update({
'rank': aviator_info['military']['militaryData']['aircraft']['rankNumber'],
'name': aviator_info['citizen']['name'],
'residency': aviator_info['city']['residenceCityId']
})
if aviator_info.get("isBanned"):
aviator_data.update({'health': 0, 'extra': ["BANNED", ]})
else:
if aviator_data['rank'] < 44:
if aviator_data['rank'] < 38:
health = aviator_data['kills'] * 30
else:
health = aviator_data['kills'] * 20
has_pp = False
if aviator_info.get("activePacks"):
has_pp = bool(aviator_info.get("activePacks").get("power_pack"))
max_health = 7 * 24 * (500 if has_pp else 300)
if health < max_health:
aviator_data['health'] = health
else:
aviator_data['health'] = max_health
if not aviator_data["residency"]:
aviator_data['health'] = 0
aviator_data['extra'].append("No residency set")
else:
residency = citizen.get_city_data_residents(
aviator_data["residency"], params={"search": aviator_data['name']}
).json()
for resident in residency.get('widgets', {}).get('residents', {}).get('residents'):
if int(resident.get('citizenId')) == aviator_id:
if resident['numFactories']:
aviator_data['factories'] = resident['numFactories']
else:
aviator_data['factories'] = 0
if not resident.get('activeHouses'):
aviator_data['health'] = 0
if resident['numHouses']:
aviator_data['extra'].append(", ".join(resident['activeHouses']))
else:
aviator_data['extra'].append("Nav māja")
aviator_data['health'] = 0
else:
aviator_data['extra'].append("Rank")
write_interactive_log("{id:>9} | {name:<28} | {kills:4} | {:26} | {health:6} | {}".format(
AIR_RANKS[aviator_data['rank']],
", ".join(aviator_data["extra"]),
**aviator_data)
)
db_post_data = []
for aviator_id, aviator_data in aviators.items():
db_post_data.append(dict(id=aviator_id, name=aviator_data['name'],
rank=aviator_data['rank'], factory_count=aviator_data['factories']))
requests.post('https://erep.lv/aviator/set/', json=db_post_data)
for aviator_id, new in aviators.items():
resp = requests.get('https://erep.lv/aviator/check/{}/'.format(aviator_id))
if not resp.json()['status']:
aviators[aviator_id]['health'] = 0
aviators[aviator_id]['extra'] = ["Nav izmaiņas fabriku skaitā", ]
for player_id in forbidden_ids:
if player_id in aviators:
aviators[player_id]['health'] = 0
if "BANNED" not in aviators[player_id]['extra']:
aviators[player_id]['extra'] = ["Aizliegta pieteikšanās", ]
sent_data = []
if send_food:
for aviator_data in sorted(aviators.values(), key=lambda t: (-t["health"], -t['kills'])):
remaining = aviator_data['health']
if not remaining:
sent_data.append({
"player_id": aviator_data['id'], "name": aviator_data['name'], "quality": 0,
"amount": 0, "energy": 0, "price": 0, "cost": 0,
})
while remaining > 0:
o = []
if free_food:
# Reversed because need to start with higher qualities so that q1 stays available
for quality in reversed(list(free_food.keys())):
if free_food[quality]:
o.append((quality, {'price': 0., 'amount': free_food[quality]}))
else:
free_food.pop(quality)
if not free_food:
offers = citizen.get_market_offers(71, product="food")
o += sorted(offers.items(), key=lambda v: (v[1]['price'] / FOOD_ENERGY[v[0]],
-v[1]['amount'] * FOOD_ENERGY[v[0]]))
for _o in o:
q, q_data = _o
if FOOD_ENERGY[q] <= remaining:
break
else:
write_interactive_log(
"{name} needs to receive extra {remaining}hp".format(name=aviator_data['name'],
remaining=remaining))
break
if q_data['amount'] * FOOD_ENERGY[q] <= remaining:
amount = q_data['amount']
else:
amount = remaining // FOOD_ENERGY[q]
if q_data['price']:
# print(f"citizen._buy_market_offer(offer={q_data['offer_id']}, amount={amount})")
citizen.post_economy_marketplace_actions(citizen.token, amount=amount, buy=True,
offer=q_data["offer_id"])
else:
free_food[q] -= amount
# print(f"citizen.donate_items(citizen_id={aviator_data['id']},
# amount={amount}, industry_id=1, quality={int(q[1])})")
citizen.donate_items(citizen_id=aviator_data['id'], amount=amount, industry_id=1, quality=int(q[1]))
remaining -= amount * FOOD_ENERGY[q]
context['TOTAL_CC'] += q_data['price'] * amount
context['TOTAL_ENERGY'] += amount * FOOD_ENERGY[q]
sent_data.append(
{"player_id": aviator_data['id'], "name": aviator_data['name'], "quality": q, "amount": amount,
"energy": amount * FOOD_ENERGY[q], "price": q_data['price'],
"cost": q_data['price'] * amount, })
with open(get_file("{eday}.csv".format(eday=eday_from_date(now()))), 'a') as f:
f.write('PlayerID, Quality, Amount, Energy, Price, Cost\n')
for player_data in sent_data:
f.write('{player_id}, {quality}, {amount}, {energy}, {price}, {cost}\n'.format(**player_data))
columns = ('[columns][b]Spēlētajs[/b]\n'
'{players}[nextcol][b]Kili[/b]\n'
'{kills}\n'
'[nextcol][right][b]Enerģija[/b]\n'
'{health}\n'
'[/right][/columns]')
player_template = '[b][url=https://www.erepublik.com/en/citizen/profile/{id}]{name}[/url][/b]'
players = []
kills = []
health = []
write_interactive_log("\n".join(["{}: {}".format(q, a) for q, a in free_food.items()]))
context['TOTAL_CC'] = round(context['TOTAL_CC'], 2)
context["END_ENERGY"] = sum([amount * FOOD_ENERGY[q] for q, amount in free_food.items()])
data = {}
for row in sent_data:
pid = int(row['player_id'])
if pid not in data:
data.update({pid: dict(id=pid, name=row['name'], energy=0, cost=0, kills=aviators[pid]['kills'])})
data[pid]["energy"] += row['energy']
data[pid]["cost"] += row['cost']
for pid, player_data in sorted(aviators.items(), key=lambda t: (-t[1]["health"], -t[1]['kills'])):
players.append(player_template.format(id=pid, name=player_data['name']))
kills.append(str(player_data['kills']))
health.append(str(player_data['health'] or ", ".join(player_data['extra'])))
else:
context['TABLE'] = columns.format(
players="\n".join(players),
kills="\n".join(kills),
health="\n".join(health)
)
if os.path.isfile("scripts/KM_piloti.txt"):
with open("scripts/KM_piloti.txt") as f:
template = f.read()
article = template.format(**context)
with open(get_file("{eday}.txt".format(eday=eday_from_date(now()))), "w") as f:
f.write(article)
if send_food:
article_data = dict(
title="[KM] Gaisa maizītes [d{} {}]".format(citizen.eday, citizen.now.strftime("%H:%M")),
content=article,
kind=3
)
from_eday = eday_from_date(good_timedelta(now(), - datetime.timedelta(days=now().weekday() + 6)))
till_eday = eday_from_date(good_timedelta(now(), - datetime.timedelta(days=now().weekday())))
comment_data = dict(
message="★★★★ MAIZE PAR NEDĒĻU [DAY {}-{}] IZDALĪTA ★★★★\n★ Apgādei piesakāmies šī komentāra reply "
"komentāros ar saucienu - piesakos! ★".format(from_eday, till_eday))
total_cc = int(round(context['TOTAL_CC']))
wall_body = ("★★★ [ KONGRESA BALSOJUMS ] ★★★\n\nDotācija pilotiem par d{}-{} {}cc apmērā.\n\n"
"Balsot ar Par/Pret\nBalsošanas laiks 24h līdz d{} {}").format(
from_eday, till_eday, total_cc, citizen.eday + 1, citizen.now.strftime("%H:%M"))
citizen.write_log("Publishing info:\n\n### Article ###\n{}\n\n{}\n\n### Wall ###\n{}".format(
article_data['title'], comment_data['message'], wall_body
))
KM_account: Citizen = Citizen("kara-ministrija@erep.lv", "KMPar0le")
KM_account.set_debug(True)
KM_account.update_citizen_info()
resp = KM_account.publish_article(**article_data)
article_id = resp.history[1].url.split("/")[-3]
comment_data.update({"article_id": article_id})
KM_account.write_article_comment(**comment_data)
citizen.write_on_country_wall(wall_body)
requests.post('https://erep.lv/aviator/latest_article/',
data=dict(week=context["WEEK"], article_id=article_id))

View File

@ -1,7 +0,0 @@
ipython==7.3.0
pycryptodome==3.7.3
PyInstaller==3.4
python-slugify==2.0.1
pytz==2018.9
requests==2.21.0
Click>=6.0

View File

@ -2,9 +2,14 @@ pip==19.1.1
bumpversion==0.5.3 bumpversion==0.5.3
wheel==0.32.1 wheel==0.32.1
watchdog==0.9.0 watchdog==0.9.0
flake8==3.5.0 flake8==3.7.8
tox==3.5.2 tox==3.13.2
coverage==4.5.1 coverage==4.5.3
Sphinx==1.8.1 Sphinx==2.1.2
twine==1.12.1 twine==1.13.0
ipython==7.3.0 ipython==7.6.1
PyInstaller==3.5
pytz==2019.1
requests==2.22.0
pycryptodome==3.8.2
python-slugify==2.0.1

View File

@ -11,7 +11,7 @@ with open('README.rst') as readme_file:
with open('HISTORY.rst') as history_file: with open('HISTORY.rst') as history_file:
history = history_file.read() history = history_file.read()
requirements = ['Click>=6.0', 'pytz==2018.9', 'requests==2.21.0', 'python-slugify==2.0.1'] requirements = ['pytz==2019.1', 'requests==2.22.0', 'python-slugify<3.0.0']
setup_requirements = [ ] setup_requirements = [ ]
@ -29,11 +29,7 @@ setup(
'Programming Language :: Python :: 3.7', 'Programming Language :: Python :: 3.7',
], ],
description="Python package for eRepublik automated playing", description="Python package for eRepublik automated playing",
entry_points={ entry_points={},
'console_scripts': [
'erepublik_script=erepublik_script.cli:main',
],
},
install_requires=requirements, install_requires=requirements,
license="MIT license", license="MIT license",
long_description=readme + '\n\n' + history, long_description=readme + '\n\n' + history,