Compare commits
7 Commits
Author | SHA1 | Date | |
---|---|---|---|
6b7639d7fb | |||
3b1c1928fd | |||
2e26c2db79 | |||
78c055fee2 | |||
fe41c4cdc6 | |||
123b6cf4ed | |||
f652b02443 |
@ -4,7 +4,7 @@
|
||||
|
||||
__author__ = """Eriks Karls"""
|
||||
__email__ = 'eriks@72.lv'
|
||||
__version__ = '0.21.4.6'
|
||||
__version__ = '0.21.5'
|
||||
|
||||
from erepublik import classes, utils, constants
|
||||
from erepublik.citizen import Citizen
|
||||
|
@ -38,8 +38,10 @@ class SlowRequests(Session):
|
||||
]
|
||||
debug: bool = False
|
||||
|
||||
def __init__(self):
|
||||
def __init__(self, proxies: Dict[str, str] = None):
|
||||
super().__init__()
|
||||
if proxies:
|
||||
self.proxies = proxies
|
||||
self.request_log_name = utils.get_file(utils.now().strftime("debug/requests_%Y-%m-%d.log"))
|
||||
self.last_time = utils.now()
|
||||
self.headers.update({
|
||||
@ -132,6 +134,14 @@ class CitizenBaseAPI:
|
||||
def _get_main(self) -> Response:
|
||||
return self.get(self.url)
|
||||
|
||||
def set_socks_proxy(self, host: str, port: int, username: str = None, password: str = None):
|
||||
url = f'socks5://{username}:{password}@{host}:{port}' if username and password else f'socks5://{host}:{port}'
|
||||
self._req.proxies = dict(http=url, https=url)
|
||||
|
||||
def set_http_proxy(self, host: str, port: int, username: str = None, password: str = None):
|
||||
url = f'http://{username}:{password}@{host}:{port}' if username and password else f'socks5://{host}:{port}'
|
||||
self._req.proxies = dict(http=url)
|
||||
|
||||
|
||||
class ErepublikAnniversaryAPI(CitizenBaseAPI):
|
||||
def _post_main_collect_anniversary_reward(self) -> Response:
|
||||
|
@ -882,6 +882,8 @@ class CitizenCompanies(BaseCitizen):
|
||||
self.my_companies.prepare_holdings(utils.json.loads(have_holdings.group(1)))
|
||||
self.my_companies.prepare_companies(utils.json.loads(have_companies.group(1)))
|
||||
|
||||
self.reporter.report_action('COMPANIES', json_val=self.my_companies.as_dict)
|
||||
|
||||
def assign_company_to_holding(self, company: classes.Company, holding: classes.Holding) -> Response:
|
||||
"""
|
||||
Assigns factory to new holding
|
||||
@ -1146,7 +1148,6 @@ class CitizenEconomy(CitizenTravel):
|
||||
self.details.gold = float(response.json().get("gold").get("value"))
|
||||
if response.json().get('error'):
|
||||
self._report_action("BUY_GOLD", "Unable to buy gold!", kwargs=response.json())
|
||||
self.stop_threads.wait()
|
||||
return False
|
||||
else:
|
||||
self._report_action('BUY_GOLD', f'New amount {self.details.cc}cc, {self.details.gold}g',
|
||||
@ -1662,11 +1663,11 @@ class CitizenMilitary(CitizenTravel):
|
||||
self.write_log("Hits: {:>4} | Damage: {}".format(total_hits, total_damage))
|
||||
ok_to_fight = False
|
||||
if total_damage:
|
||||
self.reporter.report_action('FIGHT', dict(battle_id=battle.id, side=side, dmg=total_damage,
|
||||
air=battle.has_air, hits=total_hits,
|
||||
round=battle.zone_id))
|
||||
self.reporter.report_action("FIGHT", dict(battle=str(battle), side=str(side), dmg=total_damage,
|
||||
air=battle.has_air, hits=total_hits))
|
||||
self.reporter.report_fighting(battle, not side.is_defender, division, total_damage, total_hits)
|
||||
# self.reporter.report_action('FIGHT', dict(battle_id=battle.id, side=side, dmg=total_damage,
|
||||
# air=battle.has_air, hits=total_hits,
|
||||
# round=battle.zone_id,
|
||||
# extra=dict(battle=battle, side=side)))
|
||||
return error_count
|
||||
|
||||
def _shoot(self, battle: classes.Battle, division: classes.BattleDivision, side: classes.BattleSide):
|
||||
|
@ -618,6 +618,12 @@ class Reporter:
|
||||
else:
|
||||
self.__to_update.append(json_data)
|
||||
|
||||
def report_fighting(self, battle: "Battle", invader: bool, division: "BattleDivision", damage: float, hits: int):
|
||||
side = battle.invader if invader else battle.defender
|
||||
self.report_action('FIGHT', dict(battle_id=battle.id, side=side, dmg=damage,
|
||||
air=battle.has_air, hits=hits,
|
||||
round=battle.zone_id, extra=dict(battle=battle, side=side, division=division)))
|
||||
|
||||
def report_promo(self, kind: str, time_until: datetime.datetime):
|
||||
self._req.post(f"{self.url}/promos/add/", data=dict(kind=kind, time_untill=time_until))
|
||||
|
||||
|
@ -7,11 +7,11 @@ isort==5.5.3
|
||||
pip==20.2.3
|
||||
PyInstaller==4.0
|
||||
pytz==2020.1
|
||||
pytest==6.0.2
|
||||
pytest==6.1.0
|
||||
responses==0.12.0
|
||||
setuptools==50.3.0
|
||||
Sphinx==3.2.1
|
||||
requests==2.24.0
|
||||
requests[socks]==2.24.0
|
||||
tox==3.20.0
|
||||
twine==3.2.0
|
||||
watchdog==0.10.3
|
||||
|
@ -1,5 +1,5 @@
|
||||
[bumpversion]
|
||||
current_version = 0.21.4.6
|
||||
current_version = 0.21.5
|
||||
commit = True
|
||||
tag = True
|
||||
parse = (?P<major>\d+)\.(?P<minor>\d+)\.(?P<patch>\d+)\.?(?P<dev>\d+)?
|
||||
|
4
setup.py
4
setup.py
@ -11,7 +11,7 @@ with open('README.rst') as readme_file:
|
||||
with open('HISTORY.rst') as history_file:
|
||||
history = history_file.read()
|
||||
|
||||
requirements = ['pytz==2020.1', 'requests==2.24.0']
|
||||
requirements = ['pytz==2020.1', 'requests[socks]==2.24.0']
|
||||
|
||||
setup_requirements = []
|
||||
|
||||
@ -43,6 +43,6 @@ setup(
|
||||
test_suite='tests',
|
||||
tests_require=test_requirements,
|
||||
url='https://github.com/eeriks/erepublik/',
|
||||
version='0.21.4.6',
|
||||
version='0.21.5',
|
||||
zip_safe=False,
|
||||
)
|
||||
|
Reference in New Issue
Block a user