Compare commits
16 Commits
Author | SHA1 | Date | |
---|---|---|---|
e5b7cde044 | |||
6bbc7a1f64 | |||
4eccb339bb | |||
dbeb6e9ba5 | |||
9c9bb5ae40 | |||
d8eb69f82a | |||
42c430213f | |||
39dbcaa27d | |||
8911adb81c | |||
7927c162f8 | |||
92b7c45a7d | |||
53257487d8 | |||
8690c4d3f2 | |||
43c6bce160 | |||
c4f598c1ba | |||
c48d90dec3 |
15
HISTORY.rst
15
HISTORY.rst
@ -2,13 +2,20 @@
|
||||
History
|
||||
=======
|
||||
|
||||
0.1.0 (2019-07-19)
|
||||
------------------
|
||||
|
||||
* First release on PyPI.
|
||||
0.15.0 (2019-07-30)
|
||||
-------------------
|
||||
|
||||
* CitizenAPI class methods renamed to "private", they are intended to be used internally.
|
||||
* TODO: None of the Citizen class's methods should return Response object - CitizenAPI is meant for that.
|
||||
|
||||
|
||||
0.14.4 (2019-07-23)
|
||||
-------------------
|
||||
|
||||
* Wall post comment endpoints updated with comment create endpoints
|
||||
* Wall post comment endpoints updated with comment create endpoints.
|
||||
|
||||
0.1.0 (2019-07-19)
|
||||
------------------
|
||||
|
||||
* First release on PyPI.
|
||||
|
@ -6,8 +6,8 @@ eRepublik script
|
||||
.. image:: https://img.shields.io/pypi/v/erepublik.svg
|
||||
:target: https://pypi.python.org/pypi/erepublik
|
||||
|
||||
.. image:: https://readthedocs.org/projects/erepublik/badge/?version=latest
|
||||
:target: https://erepublik.readthedocs.io/en/latest/?badge=latest
|
||||
.. image:: https://readthedocs.org/projects/erepublik_script/badge/?version=latest
|
||||
:target: https://erepublik_script.readthedocs.io/en/latest/?badge=latest
|
||||
:alt: Documentation Status
|
||||
|
||||
|
||||
|
@ -4,7 +4,7 @@
|
||||
|
||||
__author__ = """Eriks Karls"""
|
||||
__email__ = 'eriks@72.lv'
|
||||
__version__ = '__version__ = '0.14.7''
|
||||
__version__ = '0.15.1'
|
||||
|
||||
from erepublik import classes, utils
|
||||
from erepublik.citizen import Citizen
|
||||
|
@ -1,10 +1,11 @@
|
||||
import datetime
|
||||
import itertools
|
||||
import re
|
||||
import sys
|
||||
import threading
|
||||
import time
|
||||
from json import loads, dumps
|
||||
from typing import Dict, List, Tuple, Any, Union
|
||||
from typing import Dict, List, Tuple, Any, Union, Mapping
|
||||
|
||||
import requests
|
||||
from requests import Response, RequestException
|
||||
@ -20,9 +21,9 @@ class Citizen(classes.CitizenAPI):
|
||||
all_battles: Dict[int, classes.Battle] = dict()
|
||||
countries: Dict[int, Dict[str, Union[str, List[int]]]] = dict()
|
||||
__last_war_update_data = {}
|
||||
__last_full_update: datetime.datetime
|
||||
__last_full_update: datetime.datetime = utils.now().min
|
||||
|
||||
active_fs = False
|
||||
active_fs: bool = False
|
||||
|
||||
food = {"q1": 0, "q2": 0, "q3": 0, "q4": 0, "q5": 0, "q6": 0, "q7": 0, "total": 0}
|
||||
inventory = {"used": 0, "total": 0}
|
||||
@ -136,7 +137,7 @@ class Citizen(classes.CitizenAPI):
|
||||
|
||||
def _login(self):
|
||||
# MUST BE CALLED TROUGH self.get_csrf_token()
|
||||
r = self.post_login(self.config.email, self.config.password)
|
||||
r = self._post_login(self.config.email, self.config.password)
|
||||
self.r = r
|
||||
|
||||
if r.url == "{}/login".format(self.url):
|
||||
@ -288,7 +289,7 @@ class Citizen(classes.CitizenAPI):
|
||||
Gets main page and updates most information about player
|
||||
"""
|
||||
if html is None:
|
||||
self.get_main()
|
||||
self._get_main()
|
||||
html = self.r.text
|
||||
ugly_js = re.search(r"promotions: (\[{?.*}?]),\s+", html).group(1)
|
||||
promos = loads(utils.normalize_html_json(ugly_js))
|
||||
@ -311,7 +312,10 @@ class Citizen(classes.CitizenAPI):
|
||||
self.details.gold, self.details.cc
|
||||
))
|
||||
if send_mail:
|
||||
active_promos = ["{} active until {}".format(k, v.strftime("%F %T")) for k, v in self.promos.items()]
|
||||
active_promos = []
|
||||
for kind, time_until in self.promos.items():
|
||||
active_promos.append(f"{kind} active until {time_until}")
|
||||
utils.report_promo(kind, time_until)
|
||||
utils.send_email(self.name, active_promos, player=self, promo=True)
|
||||
|
||||
new_date = re.search(r"var new_date = '(\d*)';", html)
|
||||
@ -356,25 +360,26 @@ class Citizen(classes.CitizenAPI):
|
||||
self.politics.is_party_president = bool(party.get('is_party_president'))
|
||||
self.politics.party_slug = "{}-{}".format(party.get("stripped_title"), party.get('party_id'))
|
||||
|
||||
def update_money(self, page: int = 0, currency: int = 62) -> Response:
|
||||
def update_money(self, page: int = 0, currency: int = 62) -> Dict[str, Any]:
|
||||
"""
|
||||
Gets monetary market offers to get exact amount of CC and Gold available
|
||||
"""
|
||||
if currency not in [1, 62]:
|
||||
currency = 62
|
||||
resp = self.post_economy_exchange_retrieve(False, page, currency)
|
||||
self.details.cc = float(resp.json().get("ecash").get("value"))
|
||||
self.details.gold = float(resp.json().get("gold").get("value"))
|
||||
return resp
|
||||
resp = self._post_economy_exchange_retrieve(False, page, currency)
|
||||
resp_data = resp.json()
|
||||
self.details.cc = float(resp_data.get("ecash").get("value"))
|
||||
self.details.gold = float(resp_data.get("gold").get("value"))
|
||||
return resp_data
|
||||
|
||||
def update_job_info(self):
|
||||
ot = self.get_job_data().json().get("overTime", {})
|
||||
ot = self._get_job_data().json().get("overTime", {})
|
||||
if ot:
|
||||
self.my_companies.next_ot_time = utils.localize_timestamp(int(ot.get("nextOverTime", 0)))
|
||||
self.ot_points = ot.get("points", 0)
|
||||
|
||||
def update_companies(self):
|
||||
html = self.get_economy_my_companies().text
|
||||
html = self._get_economy_my_companies().text
|
||||
page_details = loads(re.search(r"var pageDetails\s+= ({.*});", html).group(1))
|
||||
self.my_companies.work_units = int(page_details.get("total_works", 0))
|
||||
|
||||
@ -386,7 +391,7 @@ class Citizen(classes.CitizenAPI):
|
||||
self.my_companies.update_holding_companies()
|
||||
|
||||
def update_inventory(self) -> dict:
|
||||
j = self.get_economy_inventory_items().json()
|
||||
j = self._get_economy_inventory_items().json()
|
||||
|
||||
self.inventory.update({"used": j.get("inventoryStatus").get("usedStorage"),
|
||||
"total": j.get("inventoryStatus").get("totalStorage")})
|
||||
@ -418,7 +423,7 @@ class Citizen(classes.CitizenAPI):
|
||||
return j
|
||||
|
||||
def update_weekly_challenge(self):
|
||||
data = self.get_weekly_challenge_data().json()
|
||||
data = self._get_weekly_challenge_data().json()
|
||||
self.details.pp = data.get("player", {}).get("prestigePoints", 0)
|
||||
self.details.next_pp = []
|
||||
for reward in data.get("rewards", {}).get("normal", {}):
|
||||
@ -426,18 +431,18 @@ class Citizen(classes.CitizenAPI):
|
||||
if status == "rewarded":
|
||||
continue
|
||||
elif status == "completed":
|
||||
self.post_weekly_challenge_reward(reward.get("id", 0))
|
||||
self._post_weekly_challenge_reward(reward.get("id", 0))
|
||||
elif reward.get("icon", "") == "energy_booster":
|
||||
pps = re.search(r"Reach (\d+) Prestige Points to unlock the following reward: \+1 Energy",
|
||||
reward.get("tooltip", ""))
|
||||
if pps:
|
||||
self.details.next_pp.append(int(pps.group(1)))
|
||||
|
||||
def update_war_info(self) -> Dict[Any, Any]:
|
||||
def update_war_info(self):
|
||||
if not self.details.current_country:
|
||||
self.update_citizen_info()
|
||||
|
||||
resp_json = self.get_military_campaigns().json()
|
||||
resp_json = self._get_military_campaigns().json()
|
||||
self.all_battles = {}
|
||||
if resp_json.get("countries"):
|
||||
for c_id, c_data in resp_json.get("countries").items():
|
||||
@ -451,7 +456,6 @@ class Citizen(classes.CitizenAPI):
|
||||
if resp_json.get("battles"):
|
||||
for battle_id, battle_data in resp_json.get("battles", {}).items():
|
||||
self.all_battles.update({int(battle_id): classes.Battle(battle_data)})
|
||||
return self.__last_war_update_data
|
||||
|
||||
def eat(self):
|
||||
"""
|
||||
@ -486,7 +490,7 @@ class Citizen(classes.CitizenAPI):
|
||||
self.write_log(self.health_info)
|
||||
|
||||
def _eat(self, colour: str = "blue") -> Response:
|
||||
response = self.post_eat(colour)
|
||||
response = self._post_eat(colour)
|
||||
r_json = response.json()
|
||||
next_recovery = r_json.get("food_remaining_reset").split(":")
|
||||
self.energy.set_reference_time(
|
||||
@ -538,8 +542,15 @@ class Citizen(classes.CitizenAPI):
|
||||
def_allies = battle.defender.deployed + [battle.defender.id]
|
||||
all_allies = inv_allies + def_allies
|
||||
if self.details.current_country not in all_allies:
|
||||
self._travel(battle.defender.id, self.get_country_travel_region(battle.defender.id))
|
||||
side = battle.defender.id
|
||||
if self.details.current_country in battle.invader.allies:
|
||||
allies = battle.invader.deployed
|
||||
side = battle.invader.id
|
||||
else:
|
||||
allies = battle.defender.deployed
|
||||
side = battle.defender.id
|
||||
|
||||
self.travel_to_battle(battle.id, allies)
|
||||
|
||||
else:
|
||||
if self.details.current_country in inv_allies:
|
||||
side = battle.invader.id
|
||||
@ -567,7 +578,6 @@ class Citizen(classes.CitizenAPI):
|
||||
self.active_fs = active_fs
|
||||
|
||||
def sorted_battles(self, sort_by_time: bool = False) -> List[int]:
|
||||
r = self.update_war_info()
|
||||
cs_battles_air: List[int] = []
|
||||
cs_battles_ground: List[int] = []
|
||||
deployed_battles_air: List[int] = []
|
||||
@ -614,17 +624,19 @@ class Citizen(classes.CitizenAPI):
|
||||
other_battles_air.append(battle.id)
|
||||
|
||||
ret_battles = []
|
||||
if r.get("citizen_contribution"):
|
||||
battle_id = r.get("citizen_contribution")[0].get("battle_id", 0)
|
||||
if self.__last_war_update_data.get("citizen_contribution"):
|
||||
battle_id = self.__last_war_update_data.get("citizen_contribution")[0].get("battle_id", 0)
|
||||
ret_battles.append(battle_id)
|
||||
|
||||
ret_battles += cs_battles_air + cs_battles_ground + deployed_battles_air + deployed_battles_ground + \
|
||||
ally_battles_air + ally_battles_ground + other_battles_air + other_battles_ground
|
||||
ret_battles += (cs_battles_air + cs_battles_ground +
|
||||
deployed_battles_air + deployed_battles_ground +
|
||||
ally_battles_air + ally_battles_ground +
|
||||
other_battles_air + other_battles_ground)
|
||||
return ret_battles
|
||||
|
||||
@property
|
||||
def has_battle_contribution(self):
|
||||
return bool(self.update_war_info().get("citizen_contribution", []))
|
||||
return bool(self.__last_war_update_data.get("citizen_contribution", []))
|
||||
|
||||
def find_battle_and_fight(self):
|
||||
if self.should_fight(False):
|
||||
@ -672,14 +684,16 @@ class Citizen(classes.CitizenAPI):
|
||||
|
||||
if travel_needed:
|
||||
if battle.is_rw:
|
||||
self._travel(battle.defender.id, self.get_country_travel_region(battle.defender.id))
|
||||
elif self.details.current_country not in battle.invader.allies:
|
||||
self.travel(battle_id=battle.id)
|
||||
country_ids_to_travel = [battle.defender.id]
|
||||
elif self.details.current_country in battle.invader.allies:
|
||||
country_ids_to_travel = battle.invader.deployed + [battle.invader.id]
|
||||
side_id = battle.invader.id
|
||||
else:
|
||||
self._travel(battle.defender.id, self.get_country_travel_region(battle.defender.id))
|
||||
country_ids_to_travel = battle.defender.deployed + [battle.defender.id]
|
||||
side_id = battle.defender.id
|
||||
|
||||
if not self.travel_to_battle(battle_id, country_ids_to_travel):
|
||||
break
|
||||
self.fight(battle_id, side_id, battle.is_air)
|
||||
self.travel_to_residence()
|
||||
self.collect_weekly_reward()
|
||||
@ -715,9 +729,9 @@ class Citizen(classes.CitizenAPI):
|
||||
|
||||
def _shoot(self, air: bool, data: dict):
|
||||
if air:
|
||||
response = self.post_military_fight_air(data['battleId'], data['sideId'])
|
||||
response = self._post_military_fight_air(data['battleId'], data['sideId'])
|
||||
else:
|
||||
response = self.post_military_fight_ground(data['battleId'], data['sideId'])
|
||||
response = self._post_military_fight_ground(data['battleId'], data['sideId'])
|
||||
|
||||
if "Zone is not meant for " in response.text:
|
||||
self.sleep(5)
|
||||
@ -745,11 +759,15 @@ class Citizen(classes.CitizenAPI):
|
||||
|
||||
return hits, err, damage
|
||||
|
||||
def deploy_bomb(self, battle_id: int, bomb_id: int):
|
||||
r = self._post_military_deploy_bomb(battle_id, bomb_id).json()
|
||||
return not r.get('error')
|
||||
|
||||
def work_ot(self):
|
||||
# I"m not checking for 1h cooldown. Beware of nightshift work, if calling more than once every 60min
|
||||
self.update_job_info()
|
||||
if self.ot_points >= 24 and self.energy.food_fights > 1:
|
||||
r = self.post_economy_work_overtime()
|
||||
r = self._post_economy_work_overtime()
|
||||
if not r.json().get("status") and r.json().get("message") == "money":
|
||||
self.resign()
|
||||
self.find_new_job()
|
||||
@ -767,7 +785,7 @@ class Citizen(classes.CitizenAPI):
|
||||
|
||||
def work(self):
|
||||
if self.energy.food_fights >= 1:
|
||||
response = self.post_economy_work("work")
|
||||
response = self._post_economy_work("work")
|
||||
js = response.json()
|
||||
good_msg = ["already_worked", "captcha"]
|
||||
if not js.get("status") and not js.get("message") in good_msg:
|
||||
@ -786,7 +804,7 @@ class Citizen(classes.CitizenAPI):
|
||||
self.work()
|
||||
|
||||
def train(self):
|
||||
r = self.get_training_grounds_json()
|
||||
r = self._get_training_grounds_json()
|
||||
tg_json = r.json()
|
||||
self.details.gold = tg_json["page_details"]["gold"]
|
||||
self.tg_contract.update({"free_train": tg_json["hasFreeTrain"]})
|
||||
@ -799,7 +817,7 @@ class Citizen(classes.CitizenAPI):
|
||||
tgs.append(data["id"])
|
||||
if tgs:
|
||||
if self.energy.food_fights >= len(tgs):
|
||||
response = self.post_economy_train(tgs)
|
||||
response = self._post_economy_train(tgs)
|
||||
if not response.json().get("status"):
|
||||
self.update_citizen_info()
|
||||
self.train()
|
||||
@ -900,8 +918,9 @@ class Citizen(classes.CitizenAPI):
|
||||
if wam_list:
|
||||
wam_holding = self.my_companies.holdings.get(wam_holding_id)
|
||||
if not self.details.current_region == wam_holding['region_id']:
|
||||
self.travel(holding_id=wam_holding_id, region_id=wam_holding['region_id'])
|
||||
response = self.post_economy_work("production", wam=wam_list, employ=employee_companies).json()
|
||||
if not self.travel_to_region(wam_holding['region_id']):
|
||||
return False
|
||||
response = self._post_economy_work("production", wam=wam_list, employ=employee_companies).json()
|
||||
self.reporter.report_action("WORK_WAM_EMPLOYEES", response)
|
||||
if response.get("status"):
|
||||
if self.config.auto_sell:
|
||||
@ -927,7 +946,7 @@ class Citizen(classes.CitizenAPI):
|
||||
amount = amount_remaining
|
||||
best_offer = self.get_market_offers(self.details.citizenship, industry, 1)
|
||||
amount = best_offer['amount'] if amount >= best_offer['amount'] else amount
|
||||
rj = self.buy_from_market(amount=best_offer['amount'], offer=best_offer['offer_id']).json()
|
||||
rj = self.buy_from_market(amount=best_offer['amount'], offer=best_offer['offer_id'])
|
||||
if not rj.get('error'):
|
||||
amount_remaining -= amount
|
||||
else:
|
||||
@ -963,15 +982,8 @@ class Citizen(classes.CitizenAPI):
|
||||
self.post_market_offer(industry=self.available_industries[kind], amount=int(amount),
|
||||
quality=int(quality), price=price)
|
||||
|
||||
def travel_to_residence(self):
|
||||
self.update_citizen_info()
|
||||
res_r = self.details.residence_region
|
||||
if self.details.residence_country and res_r and not res_r == self.details.current_region:
|
||||
self._travel(self.details.residence_country, self.details.residence_region)
|
||||
|
||||
def get_country_travel_region(self, country_id: int) -> int:
|
||||
r = self.get_travel_regions(country_id=country_id).json()
|
||||
regions = r.get("regions")
|
||||
regions = self.get_travel_regions(country_id=country_id)
|
||||
regs = []
|
||||
if regions:
|
||||
for region in regions.values():
|
||||
@ -982,50 +994,112 @@ class Citizen(classes.CitizenAPI):
|
||||
else:
|
||||
return 0
|
||||
|
||||
def travel(self, holding_id=0, battle_id=0, region_id=0):
|
||||
r = self.get_travel_regions(holding_id, battle_id, region_id)
|
||||
regions = r.json()["regions"]
|
||||
closest_region = 99999
|
||||
country_id = int(r.json()["preselectCountryId"])
|
||||
region_id = int(r.json()["preselectRegionId"])
|
||||
if not any((region_id, country_id)):
|
||||
for rid, info in regions.items():
|
||||
if info.get("distanceInKm", 99999) < closest_region:
|
||||
closest_region = info.get("distanceInKm")
|
||||
country_id = info.get("countryId")
|
||||
region_id = rid
|
||||
self._travel(country_id, region_id)
|
||||
def _update_citizen_location(self, country_id: int, region_id: int):
|
||||
self.details.current_region = region_id
|
||||
self.details.current_country = country_id
|
||||
|
||||
def travel_to_residence(self) -> bool:
|
||||
self.update_citizen_info()
|
||||
res_r = self.details.residence_region
|
||||
if self.details.residence_country and res_r and not res_r == self.details.current_region:
|
||||
r = self._travel(self.details.residence_country, self.details.residence_region)
|
||||
if r.json().get('message', '') == 'success':
|
||||
self._update_citizen_location(self.details.residence_country, self.details.current_region)
|
||||
return True
|
||||
return False
|
||||
return True
|
||||
|
||||
def travel_to_region(self, region_id: int) -> bool:
|
||||
data = self._post_travel_data(region_id=region_id).json()
|
||||
if data.get('alreadyInRegion'):
|
||||
return True
|
||||
else:
|
||||
r = self._travel(data.get('preselectCountryId'), region_id).json()
|
||||
if r.get('message', '') == 'success':
|
||||
self._update_citizen_location(data.get('preselectCountryId'), region_id)
|
||||
return True
|
||||
return False
|
||||
|
||||
def travel_to_country(self, country_id: int) -> bool:
|
||||
data = self._post_travel_data(countryId=country_id, check="getCountryRegions").json()
|
||||
|
||||
regs = []
|
||||
if data.get('regions'):
|
||||
for region in data.get('regions').values():
|
||||
if region['countryId'] == country_id: # Is not occupied by other country
|
||||
regs.append((region['id'], region['distanceInKm']))
|
||||
if regs:
|
||||
region_id = min(regs, key=lambda _: int(_[1]))[0]
|
||||
r = self._travel(country_id, region_id).json()
|
||||
if r.get('message', '') == 'success':
|
||||
self._update_citizen_location(country_id, region_id)
|
||||
return True
|
||||
return False
|
||||
|
||||
def travel_to_holding(self, holding_id: int) -> bool:
|
||||
data = self._post_travel_data(holdingId=holding_id).json()
|
||||
if data.get('alreadyInRegion'):
|
||||
return True
|
||||
else:
|
||||
r = self._travel(data.get('preselectCountryId'), data.get('preselectRegionId')).json()
|
||||
if r.get('message', '') == 'success':
|
||||
self._update_citizen_location(data.get('preselectCountryId'), data.get('preselectRegionId'))
|
||||
return True
|
||||
return False
|
||||
|
||||
def travel_to_battle(self, battle_id: int, *allowed_countries: List[int]) -> bool:
|
||||
data = self.get_travel_regions(battle_id=battle_id)
|
||||
|
||||
regs = []
|
||||
if data:
|
||||
for region in data.values():
|
||||
if region['countryId'] in allowed_countries: # Is not occupied by other country
|
||||
regs.append((region['distanceInKm'], region['id'], region['countryId']))
|
||||
if regs:
|
||||
reg = min(regs, key=lambda _: int(_[0]))
|
||||
region_id = reg[1]
|
||||
country_id = reg[2]
|
||||
r = self._travel(country_id, region_id).json()
|
||||
if r.get('message', '') == 'success':
|
||||
self._update_citizen_location(country_id, region_id)
|
||||
return True
|
||||
return False
|
||||
|
||||
def _travel(self, country_id: int, region_id: int = 0) -> Response:
|
||||
data = {
|
||||
"toCountryId": country_id,
|
||||
"inRegionId": region_id,
|
||||
"battleId": 0,
|
||||
}
|
||||
return self.post_travel("moveAction", **data)
|
||||
return self._post_travel("moveAction", **data)
|
||||
|
||||
def get_travel_regions(self, holding_id: int = 0, battle_id: int = 0, region_id: int = 0,
|
||||
country_id: int = 0) -> Response:
|
||||
data = {
|
||||
"holdingId": holding_id,
|
||||
"battleId": battle_id,
|
||||
"regionId": region_id,
|
||||
}
|
||||
data.update(countryId=country_id)
|
||||
return self.post_travel_data(**data)
|
||||
def get_travel_regions(self, holding_id: int = 0, battle_id: int = 0, country_id: int = 0
|
||||
) -> Union[List[Any], Dict[str, Dict[str, Any]]]:
|
||||
d = self._post_travel_data(holdingId=holding_id, battleId=battle_id, countryId=country_id).json()
|
||||
return d.get('regions', [])
|
||||
|
||||
def get_travel_countries(self) -> List[int]:
|
||||
response_json = self._post_travel_data().json()
|
||||
return_list = []
|
||||
for country_data in response_json['countries'].values():
|
||||
if country_data['currentRegions']:
|
||||
return_list.append(country_data['id'])
|
||||
return return_list
|
||||
|
||||
def parse_notifications(self, page: int = 1) -> list:
|
||||
response = self.get_message_alerts(page)
|
||||
notifications = re.findall(r"<p class=\"smallpadded\">(.*?)</p>", response.text, re.M | re.I | re.S)
|
||||
return notifications
|
||||
community = self._get_notifications_ajax_community(page).json()
|
||||
system = self._get_notifications_ajax_system(page).json()
|
||||
return community['alertsList'] + system['alertsList']
|
||||
|
||||
def delete_notifications(self):
|
||||
def notification_ids(html):
|
||||
return re.findall(r"id=\"delete_alert_(\d+)\"", html)
|
||||
response = self._get_notifications_ajax_community().json()
|
||||
while response['totalAlerts']:
|
||||
self._post_messages_alert([_['id'] for _ in response['alertList']])
|
||||
response = self._get_notifications_ajax_community().json()
|
||||
|
||||
response = self.get_message_alerts()
|
||||
while notification_ids(response.text):
|
||||
response = self.post_messages_alert(notification_ids(response.text))
|
||||
response = self._get_notifications_ajax_system().json()
|
||||
while response['totalAlerts']:
|
||||
self._post_messages_alert([_['id'] for _ in response['alertList']])
|
||||
response = self._get_notifications_ajax_system().json()
|
||||
|
||||
def collect_weekly_reward(self):
|
||||
self.update_weekly_challenge()
|
||||
@ -1033,7 +1107,7 @@ class Citizen(classes.CitizenAPI):
|
||||
def collect_daily_task(self) -> None:
|
||||
self.update_citizen_info()
|
||||
if self.details.daily_task_done and not self.details.daily_task_reward:
|
||||
self.post_daily_task_reward()
|
||||
self._post_daily_task_reward()
|
||||
|
||||
def send_mail_to_owner(self) -> None:
|
||||
if not self.details.citizen_id == 1620414:
|
||||
@ -1041,16 +1115,21 @@ class Citizen(classes.CitizenAPI):
|
||||
self.sleep(1)
|
||||
msg_id = re.search(r"<input type=\"hidden\" value=\"(\d+)\" "
|
||||
r"id=\"delete_message_(\d+)\" name=\"delete_message\[]\">", self.r.text).group(1)
|
||||
self.post_delete_message([msg_id])
|
||||
None
|
||||
self._post_delete_message([msg_id])
|
||||
|
||||
def get_market_offers(self, country_id: int = None, product: str = None, quality: int = None) -> dict:
|
||||
ret = dict()
|
||||
raw_short_names = dict(frm="foodRaw", wrm="weaponRaw", hrm="houseRaw", arm="airplaneRaw")
|
||||
q1_industries = ["aircraft"] + list(raw_short_names.values())
|
||||
if product in raw_short_names:
|
||||
quality = 1
|
||||
product = raw_short_names.get(product)
|
||||
if product:
|
||||
if product not in self.available_industries and product not in raw_short_names:
|
||||
self.write_log("Industry '{}' not implemented".format(product))
|
||||
raise classes.ErepublikException("Industry '{}' not implemented".format(product))
|
||||
elif product in raw_short_names:
|
||||
quality = 1
|
||||
product = raw_short_names.get(product)
|
||||
product = [product]
|
||||
elif quality:
|
||||
raise classes.ErepublikException("Quality without product not allowed")
|
||||
|
||||
item_data = dict(price=999999., country=0, amount=0, offer_id=0, citizen_id=0)
|
||||
|
||||
@ -1063,48 +1142,43 @@ class Citizen(classes.CitizenAPI):
|
||||
"foodRaw": dict(q1=item_data.copy()), "weaponRaw": dict(q1=item_data.copy()),
|
||||
"houseRaw": dict(q1=item_data.copy()), "airplaneRaw": dict(q1=item_data.copy())}
|
||||
|
||||
countries = [country_id] if country_id else self.countries
|
||||
if product not in self.available_industries:
|
||||
self.write_log("Industry '{}' not implemented".format(product))
|
||||
return ret
|
||||
if country_id:
|
||||
countries = [country_id]
|
||||
else:
|
||||
good_countries = self.get_travel_countries()
|
||||
countries = {cid for cid in self.countries.keys() if cid in good_countries}
|
||||
|
||||
start_dt = self.now
|
||||
for country in countries:
|
||||
if not country_id and not self.get_country_travel_region(country):
|
||||
iterable = [countries, product or items, [quality] if quality else range(1, 8)]
|
||||
for country, industry, q in itertools.product(*iterable):
|
||||
if (q > 1 and industry in q1_industries) or (q > 5 and industry == "house"):
|
||||
continue
|
||||
for industry in [product] or items:
|
||||
for q in [quality] if quality else range(1, 8):
|
||||
if (q > 1 and industry in q1_industries) or (q > 5 and industry == "house"):
|
||||
break
|
||||
|
||||
str_q = "q%i" % q
|
||||
str_q = "q%i" % q
|
||||
|
||||
data = {'country': country, 'industry': self.available_industries[industry], 'quality': q}
|
||||
r = self.post_economy_marketplace(**data)
|
||||
rjson = r.json()
|
||||
obj = items[industry][str_q]
|
||||
if not rjson.get("error", False):
|
||||
for offer in rjson["offers"]:
|
||||
if obj["price"] > float(offer["priceWithTaxes"]):
|
||||
obj["price"] = float(offer["priceWithTaxes"])
|
||||
obj["country"] = int(offer["country_id"])
|
||||
obj["amount"] = int(offer["amount"])
|
||||
obj["offer_id"] = int(offer["id"])
|
||||
obj["citizen_id"] = int(offer["citizen_id"])
|
||||
elif obj["price"] == float(offer["priceWithTaxes"]) \
|
||||
and obj["amount"] < int(offer["amount"]):
|
||||
obj["country"] = int(offer["country_id"])
|
||||
obj["amount"] = int(offer["amount"])
|
||||
obj["offer_id"] = int(offer["id"])
|
||||
r = self._post_economy_marketplace(country, self.available_industries[industry], q).json()
|
||||
obj = items[industry][str_q]
|
||||
if not r.get("error", False):
|
||||
for offer in r["offers"]:
|
||||
if obj["price"] > float(offer["priceWithTaxes"]):
|
||||
obj["price"] = float(offer["priceWithTaxes"])
|
||||
obj["country"] = int(offer["country_id"])
|
||||
obj["amount"] = int(offer["amount"])
|
||||
obj["offer_id"] = int(offer["id"])
|
||||
obj["citizen_id"] = int(offer["citizen_id"])
|
||||
elif obj["price"] == float(offer["priceWithTaxes"]) and obj["amount"] < int(offer["amount"]):
|
||||
obj["country"] = int(offer["country_id"])
|
||||
obj["amount"] = int(offer["amount"])
|
||||
obj["offer_id"] = int(offer["id"])
|
||||
self.write_log("Scraped market in {}!".format(self.now - start_dt))
|
||||
|
||||
if quality:
|
||||
ret = items[product]["q%i" % quality]
|
||||
ret = items[product[0]]["q%i" % quality]
|
||||
elif product:
|
||||
if product in raw_short_names.values():
|
||||
ret = items[product]["q1"]
|
||||
if product[0] in raw_short_names.values():
|
||||
ret = items[product[0]]["q1"]
|
||||
else:
|
||||
ret = items[product]
|
||||
ret = items[product[0]]
|
||||
else:
|
||||
ret = items
|
||||
return ret
|
||||
@ -1135,7 +1209,7 @@ class Citizen(classes.CitizenAPI):
|
||||
def get_monetary_offers(self, currency: int = 62) -> List[Dict[str, Union[int, float]]]:
|
||||
if currency not in [1, 62]:
|
||||
currency = 62
|
||||
resp = self.update_money(0, currency).json()
|
||||
resp = self._post_economy_exchange_retrieve(False, 0, currency).json()
|
||||
ret = []
|
||||
offers = re.findall(r"id='purchase_(\d+)' data-i18n='Buy for' data-currency='GOLD' "
|
||||
r"data-price='(\d+\.\d+)' data-max='(\d+\.\d+)' trigger='purchase'",
|
||||
@ -1147,14 +1221,14 @@ class Citizen(classes.CitizenAPI):
|
||||
return sorted(ret, key=lambda o: (o["price"], -o["amount"]))
|
||||
|
||||
def buy_monetary_market_offer(self, offer: int, amount: float, currency: int) -> bool:
|
||||
response = self.post_economy_exchange_purchase(amount, currency, offer)
|
||||
response = self._post_economy_exchange_purchase(amount, currency, offer)
|
||||
self.details.cc = float(response.json().get("ecash").get("value"))
|
||||
self.details.gold = float(response.json().get("gold").get("value"))
|
||||
self.reporter.report_action("BUY_GOLD", json_val=response.json(),
|
||||
value="New amount {o.cc}cc, {o.gold}g".format(o=self.details))
|
||||
return not response.json().get("error", False)
|
||||
|
||||
def activate_dmg_booster(self, battle_id: int) -> None:
|
||||
def activate_dmg_booster(self, battle_id: int):
|
||||
if self.config.boosters:
|
||||
duration = 0
|
||||
if self.boosters.get("100_damageBoosters_5_600", 0) > 0:
|
||||
@ -1165,52 +1239,52 @@ class Citizen(classes.CitizenAPI):
|
||||
duration = 28800
|
||||
elif self.boosters.get("100_damageBoosters_5_86400", 0) > 2:
|
||||
duration = 86400
|
||||
self.post_fight_activate_booster(battle_id, 5, duration, "damage")
|
||||
self._post_fight_activate_booster(battle_id, 5, duration, "damage")
|
||||
|
||||
def activate_battle_effect(self, battle_id: int, kind: str) -> Response:
|
||||
return self.post_activate_battle_effect(battle_id, kind, self.details.citizen_id)
|
||||
return self._post_activate_battle_effect(battle_id, kind, self.details.citizen_id)
|
||||
|
||||
def activate_pp_booster(self, battle_id: int) -> Response:
|
||||
return self.post_fight_activate_booster(battle_id, 1, 180, "prestige_points")
|
||||
return self._post_fight_activate_booster(battle_id, 1, 180, "prestige_points")
|
||||
|
||||
def donate_money(self, citizen_id: int = 1620414, amount: float = 0.0, currency: int = 62) -> Response:
|
||||
""" currency: gold = 62, cc = 1 """
|
||||
return self.post_economy_donate_money_action(citizen_id, amount, currency)
|
||||
return self._post_economy_donate_money_action(citizen_id, amount, currency)
|
||||
|
||||
def donate_items(self, citizen_id: int = 1620414, amount: int = 0, industry_id: int = 1,
|
||||
quality: int = 1) -> Response:
|
||||
ind = {v: k for k, v in self.available_industries.items()}
|
||||
self.write_log("D,{},q{},{},{}".format(amount, quality, ind[industry_id], citizen_id))
|
||||
return self.post_economy_donate_items_action(citizen_id, amount, industry_id, quality)
|
||||
return self._post_economy_donate_items_action(citizen_id, amount, industry_id, quality)
|
||||
|
||||
def candidate_for_congress(self, presentation: str = "") -> Response:
|
||||
return self.post_candidate_for_congress(presentation)
|
||||
return self._post_candidate_for_congress(presentation)
|
||||
|
||||
def candidate_for_party_presidency(self) -> Response:
|
||||
return self.get_candidate_party(self.politics.party_slug)
|
||||
return self._get_candidate_party(self.politics.party_slug)
|
||||
|
||||
def accept_money_donations(self):
|
||||
for notification in self.parse_notifications():
|
||||
don_id = re.search(r"erepublik.functions.acceptRejectDonation\(\"accept\", (\d+)\)", notification)
|
||||
if don_id:
|
||||
self.get_money_donation_accept(int(don_id.group(1)))
|
||||
self._get_money_donation_accept(int(don_id.group(1)))
|
||||
self.sleep(5)
|
||||
|
||||
def reject_money_donations(self) -> int:
|
||||
r = self.get_message_alerts()
|
||||
r = self._get_notifications_ajax_system()
|
||||
count = 0
|
||||
donation_ids = re.findall(r"erepublik.functions.acceptRejectDonation\(\"reject\", (\d+)\)", r.text)
|
||||
while donation_ids:
|
||||
for don_id in donation_ids:
|
||||
self.get_money_donation_reject(int(don_id))
|
||||
self._get_money_donation_reject(int(don_id))
|
||||
count += 1
|
||||
self.sleep(5)
|
||||
r = self.get_message_alerts()
|
||||
r = self._get_notifications_ajax_system()
|
||||
donation_ids = re.findall(r"erepublik.functions.acceptRejectDonation\(\"reject\", (\d+)\)", r.text)
|
||||
return count
|
||||
|
||||
def _rw_choose_side(self, battle_id: int, side_id: int) -> Response:
|
||||
return self.get_battlefield_choose_side(battle_id, side_id)
|
||||
return self._get_battlefield_choose_side(battle_id, side_id)
|
||||
|
||||
def should_travel_to_fight(self) -> bool:
|
||||
ret = False
|
||||
@ -1372,7 +1446,7 @@ class Citizen(classes.CitizenAPI):
|
||||
return False
|
||||
|
||||
def get_article_comments(self, article_id: int = 2645676, page_id: int = 1) -> Response:
|
||||
return self.post_article_comments(article_id, page_id)
|
||||
return self._post_article_comments(article_id, page_id)
|
||||
|
||||
def comment_article(self, article_id: int = 2645676, msg: str = None) -> Response:
|
||||
if msg is None:
|
||||
@ -1385,14 +1459,14 @@ class Citizen(classes.CitizenAPI):
|
||||
return r
|
||||
|
||||
def write_article_comment(self, message: str, article_id: int, parent_id: int = None) -> Response:
|
||||
return self.post_article_comments_create(message, article_id, parent_id)
|
||||
return self._post_article_comments_create(message, article_id, parent_id)
|
||||
|
||||
def publish_article(self, title: str, content: str, kind: int) -> Response:
|
||||
kinds = {1: "First steps in eRepublik", 2: "Battle orders", 3: "Warfare analysis",
|
||||
4: "Political debates and analysis", 5: "Financial business",
|
||||
6: "Social interactions and entertainment"}
|
||||
if kind in kinds:
|
||||
return self.post_write_article(title, content, self.details.citizenship, kind)
|
||||
return self._post_write_article(title, content, self.details.citizenship, kind)
|
||||
else:
|
||||
raise classes.ErepublikException(
|
||||
"Article kind must be one of:\n{}\n'{}' is not supported".format(
|
||||
@ -1413,22 +1487,22 @@ class Citizen(classes.CitizenAPI):
|
||||
"price": price,
|
||||
"buy": False,
|
||||
}
|
||||
ret = self.post_economy_marketplace_actions(**data)
|
||||
ret = self._post_economy_marketplace_actions(**data)
|
||||
self.reporter.report_action("SELL_PRODUCT", ret.json())
|
||||
return ret
|
||||
|
||||
def buy_from_market(self, offer: int, amount: int) -> Response:
|
||||
ret = self.post_economy_marketplace_actions(amount, True, offer=offer)
|
||||
def buy_from_market(self, offer: int, amount: int) -> dict:
|
||||
ret = self._post_economy_marketplace_actions(amount, True, offer=offer)
|
||||
json_ret = ret.json()
|
||||
if json_ret.get('error'):
|
||||
return ret
|
||||
return json_ret
|
||||
else:
|
||||
self.details.cc = ret.json()['currency']
|
||||
self.details.gold = ret.json()['gold']
|
||||
r_json = ret.json()
|
||||
r_json.pop("offerUpdate", None)
|
||||
self.reporter.report_action("BUY_PRODUCT", ret.json())
|
||||
return ret
|
||||
return json_ret
|
||||
|
||||
def get_raw_surplus(self) -> (float, float):
|
||||
frm = 0.00
|
||||
@ -1457,10 +1531,10 @@ class Citizen(classes.CitizenAPI):
|
||||
"""
|
||||
Assigns factory to new holding
|
||||
"""
|
||||
return self.post_economy_assign_to_holding(factory_id, holding_id)
|
||||
return self._post_economy_assign_to_holding(factory_id, holding_id)
|
||||
|
||||
def upgrade_factory(self, factory_id: int, level: int) -> Response:
|
||||
return self.post_economy_upgrade_company(factory_id, level, self.details.pin)
|
||||
return self._post_economy_upgrade_company(factory_id, level, self.details.pin)
|
||||
|
||||
def create_factory(self, industry_id: int, building_type: int = 1) -> Response:
|
||||
"""
|
||||
@ -1470,10 +1544,10 @@ class Citizen(classes.CitizenAPI):
|
||||
|
||||
Storage={1000: 1, 2000: 2} <- Building_type 2
|
||||
"""
|
||||
return self.post_economy_create_company(industry_id, building_type)
|
||||
return self._post_economy_create_company(industry_id, building_type)
|
||||
|
||||
def dissolve_factory(self, factory_id: int) -> Response:
|
||||
return self.post_economy_sell_company(factory_id, self.details.pin, sell=False)
|
||||
return self._post_economy_sell_company(factory_id, self.details.pin, sell=False)
|
||||
|
||||
@property
|
||||
def available_industries(self) -> Dict[str, int]:
|
||||
@ -1493,7 +1567,7 @@ class Citizen(classes.CitizenAPI):
|
||||
return self.available_industries.get(industry_name, 0)
|
||||
|
||||
def buy_tg_contract(self) -> Response:
|
||||
ret = self.post_buy_gold_items('gold', "TrainingContract2", 1)
|
||||
ret = self._post_buy_gold_items('gold', "TrainingContract2", 1)
|
||||
self.reporter.report_action("BUY_TG_CONTRACT", ret.json())
|
||||
return ret
|
||||
|
||||
@ -1501,12 +1575,12 @@ class Citizen(classes.CitizenAPI):
|
||||
self.update_job_info()
|
||||
if self.r.json().get("isEmployee"):
|
||||
self.reporter.report_action("RESIGN", self.r.json())
|
||||
self.post_economy_resign()
|
||||
self._post_economy_resign()
|
||||
return True
|
||||
return False
|
||||
|
||||
def find_new_job(self) -> Response:
|
||||
r = self.get_economy_job_market_json(self.details.current_country)
|
||||
r = self._get_economy_job_market_json(self.details.current_country)
|
||||
jobs = r.json().get("jobs")
|
||||
data = dict(citizen=0, salary=10)
|
||||
for posting in jobs:
|
||||
@ -1517,13 +1591,13 @@ class Citizen(classes.CitizenAPI):
|
||||
if (not limit or salary * 3 < limit) and salary > data["salary"]:
|
||||
data.update({"citizen": userid, "salary": salary})
|
||||
self.reporter.report_action("APPLYING_FOR_JOB", jobs, str(data['citizen']))
|
||||
return self.post_economy_job_market_apply(**data)
|
||||
return self._post_economy_job_market_apply(**data)
|
||||
|
||||
def add_friend(self, player_id: int) -> Response:
|
||||
resp = self.get_citizen_hovercard(player_id)
|
||||
resp = self._get_citizen_hovercard(player_id)
|
||||
rjson = resp.json()
|
||||
if not any([rjson["isBanned"], rjson["isDead"], rjson["isFriend"], rjson["isOrg"], rjson["isSelf"]]):
|
||||
r = self.post_citizen_add_remove_friend(int(player_id), True)
|
||||
r = self._post_citizen_add_remove_friend(int(player_id), True)
|
||||
self.write_log("{:<64} (id:{:>11}) added as friend".format(rjson["name"], player_id))
|
||||
return r
|
||||
return resp
|
||||
@ -1531,15 +1605,15 @@ class Citizen(classes.CitizenAPI):
|
||||
def get_country_parties(self, country_id: int = None) -> dict:
|
||||
if country_id is None:
|
||||
country_id = self.details.citizenship
|
||||
r = self.get_rankings_parties(country_id)
|
||||
r = self._get_rankings_parties(country_id)
|
||||
ret = {}
|
||||
for name, id_ in re.findall(r'<a class="dotted" title="([^"]+)" href="/en/party/[\w\d-]+-(\d+)/1">', r.text):
|
||||
ret.update({int(id_): name})
|
||||
return ret
|
||||
|
||||
def get_party_members(self, party_id: int) -> Dict[int, str]:
|
||||
def _get_party_members(self, party_id: int) -> Dict[int, str]:
|
||||
ret = {}
|
||||
r = super().get_party_members(party_id)
|
||||
r = super()._get_party_members(party_id)
|
||||
for id_, name in re.findall(r'<a href="//www.erepublik.com/en/main/messages-compose/(\d+)" '
|
||||
r'title="([\w\d_ .]+)">', r.text):
|
||||
ret.update({id_: name})
|
||||
@ -1547,11 +1621,11 @@ class Citizen(classes.CitizenAPI):
|
||||
|
||||
def get_country_mus(self, country_id: int) -> Dict[int, str]:
|
||||
ret = {}
|
||||
r = self.get_leaderboards_damage_rankings(country_id)
|
||||
r = self._get_leaderboards_damage_rankings(country_id)
|
||||
for data in r.json()["mu_filter"]:
|
||||
if data["id"]:
|
||||
ret.update({data["id"]: data["name"]})
|
||||
r = self.get_leaderboards_damage_aircraft_rankings(country_id)
|
||||
r = self._get_leaderboards_damage_aircraft_rankings(country_id)
|
||||
for data in r.json()["mu_filter"]:
|
||||
if data["id"]:
|
||||
ret.update({data["id"]: data["name"]})
|
||||
@ -1559,10 +1633,10 @@ class Citizen(classes.CitizenAPI):
|
||||
|
||||
def get_mu_members(self, mu_id: int) -> Dict[int, str]:
|
||||
ret = {}
|
||||
r = self.get_military_unit_data(mu_id)
|
||||
r = self._get_military_unit_data(mu_id)
|
||||
|
||||
for page in range(1, int(r.json()["panelContents"]["pages"]) + 1):
|
||||
r = self.get_military_unit_data(mu_id, page)
|
||||
for page in range(int(r.json()["panelContents"]["pages"])):
|
||||
r = self._get_military_unit_data(mu_id, currentPage=page + 1)
|
||||
for user in r.json()["panelContents"]["members"]:
|
||||
if not user["isDead"]:
|
||||
ret.update({user["citizenId"]: user["name"]})
|
||||
@ -1572,13 +1646,13 @@ class Citizen(classes.CitizenAPI):
|
||||
if ids is None:
|
||||
ids = [1620414, ]
|
||||
for player_id in ids:
|
||||
self.post_messages_compose(subject, msg, [player_id])
|
||||
self._post_messages_compose(subject, msg, [player_id])
|
||||
|
||||
def add_every_player_as_friend(self):
|
||||
cities = []
|
||||
cities_dict = {}
|
||||
self.write_log("WARNING! This will take a lot of time.")
|
||||
rj = self.post_travel_data(regionId=662, check="getCountryRegions").json()
|
||||
rj = self._post_travel_data(regionId=662, check="getCountryRegions").json()
|
||||
for region_data in rj.get("regions", {}).values():
|
||||
cities.append(region_data['cityId'])
|
||||
cities_dict.update({region_data['cityId']: region_data['cityName']})
|
||||
@ -1586,27 +1660,54 @@ class Citizen(classes.CitizenAPI):
|
||||
cities.sort(key=int)
|
||||
for city_id in cities:
|
||||
self.write_log("Adding friends from {} (id: {})".format(cities_dict[city_id], city_id))
|
||||
resp = self.get_city_data_residents(city_id).json()
|
||||
resp = self._get_city_data_residents(city_id).json()
|
||||
for resident in resp["widgets"]["residents"]["residents"]:
|
||||
self.add_friend(resident["citizenId"])
|
||||
for page in range(2, resp["widgets"]["residents"]["numResults"] // 10 + 2):
|
||||
r = self.get_city_data_residents(city_id, page)
|
||||
r = self._get_city_data_residents(city_id, page)
|
||||
resp = r.json()
|
||||
for resident in resp["widgets"]["residents"]["residents"]:
|
||||
self.add_friend(resident["citizenId"])
|
||||
|
||||
def schedule_attack(self, war_id: int, region_id: int, at_time: datetime) -> None:
|
||||
def schedule_attack(self, war_id: int, region_id: int, region_name: str, at_time: datetime) -> None:
|
||||
if at_time:
|
||||
self.sleep(utils.get_sleep_seconds(at_time))
|
||||
self.get_csrf_token()
|
||||
self._launch_battle(war_id, region_id)
|
||||
self.launch_attack(war_id, region_id, region_name)
|
||||
|
||||
def get_active_wars_with_regions(self):
|
||||
self.get_country_military(self.countries.get(self.details.citizen_id)["name"])
|
||||
raise NotImplementedError
|
||||
def get_active_wars(self, country_id: int = None) -> List[int]:
|
||||
r = self._get_country_military(utils.COUNTRY_LINK.get(country_id or self.details.citizenship))
|
||||
all_war_ids = re.findall(r'//www\.erepublik\.com/en/wars/show/(\d+)"', r.text)
|
||||
return [int(wid) for wid in all_war_ids]
|
||||
|
||||
def _launch_battle(self, war_id: int, region_id: int) -> Response:
|
||||
return self.post_wars_attack_region(war_id, region_id)
|
||||
def get_war_status(self, war_id: int) -> Dict[str, Union[bool, Dict[int, str]]]:
|
||||
r = self._get_wars_show(war_id)
|
||||
html = r.text
|
||||
ret = {}
|
||||
reg_re = re.compile(fr'data-war-id="{war_id}" data-region-id="(\d+)" data-region-name="([- \w]+)"')
|
||||
if reg_re.findall(html):
|
||||
ret.update(regions={}, can_attack=True)
|
||||
for reg in reg_re.findall(html):
|
||||
ret["regions"].update({str(reg[0]): reg[1]})
|
||||
elif re.search(r'<a href="//www.erepublik.com/en/military/battlefield/(\d+)" '
|
||||
r'class="join" title="Join"><span>Join</span></a>', html):
|
||||
battle_id = re.search(r'<a href="//www.erepublik.com/en/military/battlefield/(\d+)" '
|
||||
r'class="join" title="Join"><span>Join</span></a>', html).group(1)
|
||||
ret.update(can_attack=False, battle_id=battle_id)
|
||||
else:
|
||||
ret.update(can_attack=False)
|
||||
return ret
|
||||
|
||||
def get_last_battle_of_war_end_time(self, war_id: int) -> datetime:
|
||||
r = self._get_wars_show(war_id)
|
||||
html = r.text
|
||||
last_battle_id = int(re.search(r'<a href="//www.erepublik.com/en/military/battlefield/(\d+)">', html).group(1))
|
||||
console = self._post_military_battle_console(last_battle_id, 'warList', 1).json()
|
||||
battle = console.get('list')[0]
|
||||
return utils.localize_dt(datetime.datetime.strptime(battle.get('result').get('end'), "%Y-%m-%d %H:%M:%S"))
|
||||
|
||||
def launch_attack(self, war_id: int, region_id: int, region_name: str):
|
||||
self._post_wars_attack_region(war_id, region_id, region_name)
|
||||
|
||||
def state_update_repeater(self):
|
||||
try:
|
||||
@ -1692,8 +1793,8 @@ class Citizen(classes.CitizenAPI):
|
||||
buy = self.buy_from_market(global_cheapest['offer_id'], 1)
|
||||
else:
|
||||
buy = self.buy_from_market(cheapest_offer['offer_id'], 1)
|
||||
if buy.json()["error"]:
|
||||
msg = "Unable to buy q{} house! \n{}".format(q, buy.json()['message'])
|
||||
if buy["error"]:
|
||||
msg = "Unable to buy q{} house! \n{}".format(q, buy['message'])
|
||||
self.write_log(msg)
|
||||
else:
|
||||
ok_to_activate = True
|
||||
@ -1718,20 +1819,20 @@ class Citizen(classes.CitizenAPI):
|
||||
|
||||
def activate_house(self, quality: int) -> datetime.datetime:
|
||||
active_until = self.now
|
||||
r = self.post_economy_activate_house(quality)
|
||||
r = self._post_economy_activate_house(quality)
|
||||
if r.json().get("status") and not r.json().get("error"):
|
||||
house = r.json()["inventoryItems"]["activeEnhancements"]["items"]["4_%i_active" % quality]
|
||||
active_until = utils.good_timedelta(active_until, datetime.timedelta(seconds=house["active"]["time_left"]))
|
||||
return active_until
|
||||
|
||||
def collect_anniversary_reward(self) -> Response:
|
||||
return self.post_collect_anniversary_reward()
|
||||
return self._post_collect_anniversary_reward()
|
||||
|
||||
def get_battle_round_data(self, battle_id: int, round_id: int, division: int = None) -> dict:
|
||||
battle = self.all_battles.get(battle_id)
|
||||
if not battle:
|
||||
return {}
|
||||
r = self.post_battle_console(battle_id, battle.zone_id, round_id, division, 1, True)
|
||||
r = self._post_battle_console(battle_id, battle.zone_id, round_id, division, 1, True)
|
||||
return {battle.invader.id: r.json().get(str(battle.invader.id)).get("fighterData"),
|
||||
battle.defender.id: r.json().get(str(battle.defender.id)).get("fighterData")}
|
||||
|
||||
@ -1740,9 +1841,9 @@ class Citizen(classes.CitizenAPI):
|
||||
amount = int(amount)
|
||||
if self.details.cc < amount or amount < 20:
|
||||
return False
|
||||
json = dict(country=71, action='currency', value=amount)
|
||||
self.reporter.report_action("CONTRIBUTE_CC", json)
|
||||
r = self.post_country_donate(**json)
|
||||
data = dict(country=71, action='currency', value=amount)
|
||||
self.reporter.report_action("CONTRIBUTE_CC", data)
|
||||
r = self._post_country_donate(**data)
|
||||
return r.json().get('status') or not r.json().get('error')
|
||||
|
||||
def contribute_food_to_country(self, amount: int = 0, quality: int = 1) -> bool:
|
||||
@ -1750,9 +1851,9 @@ class Citizen(classes.CitizenAPI):
|
||||
amount = amount // 1
|
||||
if self.food["q" + str(quality)] < amount or amount < 10:
|
||||
return False
|
||||
json = dict(country=71, action='food', value=amount, quality=quality)
|
||||
self.reporter.report_action("CONTRIBUTE_FOOD", json)
|
||||
r = self.post_country_donate(**json)
|
||||
data = dict(country=71, action='food', value=amount, quality=quality)
|
||||
self.reporter.report_action("CONTRIBUTE_FOOD", data)
|
||||
r = self._post_country_donate(**data)
|
||||
return r.json().get('status') or not r.json().get('error')
|
||||
|
||||
def contribute_gold_to_country(self, amount: int) -> bool:
|
||||
@ -1760,19 +1861,17 @@ class Citizen(classes.CitizenAPI):
|
||||
|
||||
if self.details.cc < amount:
|
||||
return False
|
||||
json = dict(country=71, action='gold', value=amount)
|
||||
self.reporter.report_action("CONTRIBUTE_GOLD", json)
|
||||
r = self.post_country_donate(**json)
|
||||
data = dict(country=71, action='gold', value=amount)
|
||||
self.reporter.report_action("CONTRIBUTE_GOLD", data)
|
||||
r = self._post_country_donate(**data)
|
||||
return r.json().get('status') or not r.json().get('error')
|
||||
|
||||
def write_on_country_wall(self, message: str) -> bool:
|
||||
self.get_main()
|
||||
post_to_wall_as = re.findall(r"""id="post_to_country_as".*?<option value="(.*?)">.*?</option>.*</select>""",
|
||||
self._get_main()
|
||||
post_to_wall_as = re.findall(r"""id="post_to_country_as".*?<option value="(\d?)">.*?</option>.*</select>""",
|
||||
self.r.text, re.S | re.M)
|
||||
if post_to_wall_as:
|
||||
self.post_country_post_create(message, max(post_to_wall_as))
|
||||
return True
|
||||
return False
|
||||
r = self._post_country_post_create(message, max(post_to_wall_as, key=int) if post_to_wall_as else 0)
|
||||
return r.json()
|
||||
|
||||
def report_error(self, msg: str = ""):
|
||||
utils.process_error(msg, self.name, sys.exc_info(), self, self.commit_id, False)
|
||||
@ -1782,7 +1881,7 @@ class Citizen(classes.CitizenAPI):
|
||||
round_id = battle.get('zone_id')
|
||||
division = self.division if round_id % 4 else 11
|
||||
|
||||
resp = self.post_military_battle_console(battle_id, round_id, division).json()
|
||||
resp = self._post_military_battle_console(battle_id, round_id, division).json()
|
||||
resp.pop('rounds', None)
|
||||
ret = dict()
|
||||
for country_id, data in resp.items():
|
||||
|
@ -5,7 +5,7 @@ import random
|
||||
import time
|
||||
from collections import deque
|
||||
from json import JSONDecodeError, loads, JSONEncoder
|
||||
from typing import Any, Dict, List, Union
|
||||
from typing import Any, Dict, List, Union, Mapping, Iterable
|
||||
|
||||
from requests import Response, Session
|
||||
|
||||
@ -41,7 +41,7 @@ class MyCompanies:
|
||||
template = dict(id=0, num_factories=0, region_id=0, companies=[])
|
||||
|
||||
for holding_id, holding in holdings.items():
|
||||
tmp: Dict[str, Union[List[Any], Any]] = {}
|
||||
tmp: Dict[str, Union[Iterable[Any], Any]] = {}
|
||||
for key in template:
|
||||
if key == 'companies':
|
||||
tmp.update({key: []})
|
||||
@ -441,6 +441,9 @@ class CitizenAPI:
|
||||
token: str = ""
|
||||
|
||||
def __init__(self):
|
||||
"""
|
||||
Class for unifying eRepublik known endpoints and their required/optional parameters
|
||||
"""
|
||||
self._req = SlowRequests()
|
||||
|
||||
def post(self, url: str, *args, **kwargs) -> Response:
|
||||
@ -449,112 +452,124 @@ class CitizenAPI:
|
||||
def get(self, url: str, **kwargs) -> Response:
|
||||
return self._req.get(url, **kwargs)
|
||||
|
||||
def get_article_json(self, article_id: int) -> Response:
|
||||
def _get_article_json(self, article_id: int) -> Response:
|
||||
return self.get("{}/main/articleJson/{}".format(self.url, article_id))
|
||||
|
||||
def get_battlefield_choose_side(self, battle: int, side: int) -> Response:
|
||||
def _get_battlefield_choose_side(self, battle: int, side: int) -> Response:
|
||||
return self.get("{}/military/battlefield-choose-side/{}/{}".format(self.url, battle, side))
|
||||
|
||||
def get_candidate_party(self, party_slug: str) -> Response:
|
||||
def _get_candidate_party(self, party_slug: str) -> Response:
|
||||
return self.post("{}/candidate/{}".format(self.url, party_slug))
|
||||
|
||||
def get_citizen_hovercard(self, citizen: int) -> Response:
|
||||
def _get_citizen_hovercard(self, citizen: int) -> Response:
|
||||
return self.get("{}/main/citizen-hovercard/{}".format(self.url, citizen))
|
||||
|
||||
def get_citizen_profile(self, player_id: int):
|
||||
def _get_citizen_profile(self, player_id: int) -> Response:
|
||||
return self.get("{}/main/citizen-profile-json/{}".format(self.url, player_id))
|
||||
|
||||
def get_citizen_daily_assistant(self):
|
||||
def _get_citizen_daily_assistant(self) -> Response:
|
||||
return self.get("{}/main/citizenDailyAssistant".format(self.url))
|
||||
|
||||
def get_city_data_residents(self, city: int, page: int = 1, params: Dict[str, Any] = None):
|
||||
def _get_city_data_residents(self, city: int, page: int = 1, params: Mapping[str, Any] = None) -> Response:
|
||||
if params is None:
|
||||
params = {}
|
||||
return self.get("{}/main/city-data/{}/residents".format(self.url, city), params={"currentPage": page, **params})
|
||||
|
||||
def get_country_military(self, country: str) -> Response:
|
||||
def _get_country_military(self, country: str) -> Response:
|
||||
return self.get("{}/country/military/{}".format(self.url, country))
|
||||
|
||||
def get_economy_inventory_items(self) -> Response:
|
||||
def _get_economy_inventory_items(self) -> Response:
|
||||
return self.get("{}/economy/inventory-items/".format(self.url))
|
||||
|
||||
def get_economy_job_market_json(self, country: int) -> Response:
|
||||
def _get_economy_job_market_json(self, country: int) -> Response:
|
||||
return self.get("{}/economy/job-market-json/{}/1/desc".format(self.url, country))
|
||||
|
||||
def get_economy_my_companies(self) -> Response:
|
||||
def _get_economy_my_companies(self) -> Response:
|
||||
return self.get("{}/economy/myCompanies".format(self.url))
|
||||
|
||||
def get_economy_my_market_offers(self) -> Response:
|
||||
def _get_economy_my_market_offers(self) -> Response:
|
||||
return self.get("{}/economy/myMarketOffers".format(self.url))
|
||||
|
||||
def get_job_data(self) -> Response:
|
||||
def _get_job_data(self) -> Response:
|
||||
return self.get("{}/main/job-data".format(self.url))
|
||||
|
||||
def get_leaderboards_damage_aircraft_rankings(self, country: int, weeks: int = 0, mu: int = 0) -> Response:
|
||||
def _get_leaderboards_damage_aircraft_rankings(self, country: int, weeks: int = 0, mu: int = 0) -> Response:
|
||||
data = (country, weeks, mu)
|
||||
return self.get("{}/main/leaderboards-damage-aircraft-rankings/{}/{}/{}/0".format(self.url, *data))
|
||||
|
||||
def get_leaderboards_damage_rankings(self, country: int, weeks: int = 0, mu: int = 0, div: int = 0) -> Response:
|
||||
def _get_leaderboards_damage_rankings(self, country: int, weeks: int = 0, mu: int = 0, div: int = 0) -> Response:
|
||||
data = (country, weeks, mu, div)
|
||||
return self.get("{}/main/leaderboards-damage-rankings/{}/{}/{}/{}".format(self.url, *data))
|
||||
|
||||
def get_leaderboards_kills_aircraft_rankings(self, country: int, weeks: int = 0, mu: int = 0) -> Response:
|
||||
def _get_leaderboards_kills_aircraft_rankings(self, country: int, weeks: int = 0, mu: int = 0) -> Response:
|
||||
data = (country, weeks, mu)
|
||||
return self.get("{}/main/leaderboards-kills-aircraft-rankings/{}/{}/{}/0".format(self.url, *data))
|
||||
|
||||
def get_leaderboards_kills_rankings(self, country: int, weeks: int = 0, mu: int = 0, div: int = 0) -> Response:
|
||||
def _get_leaderboards_kills_rankings(self, country: int, weeks: int = 0, mu: int = 0, div: int = 0) -> Response:
|
||||
data = (country, weeks, mu, div)
|
||||
return self.get("{}/main/leaderboards-kills-rankings/{}/{}/{}/{}".format(self.url, *data))
|
||||
|
||||
def get_main(self):
|
||||
def _get_main(self) -> Response:
|
||||
return self.get(self.url)
|
||||
|
||||
def get_message_alerts(self, page: int = 1) -> Response:
|
||||
return self.get_message_alerts(page)
|
||||
def _get_messages(self, page: int = 1) -> Response:
|
||||
return self.get("{}/main/messages-paginated/{}".format(self.url, page))
|
||||
|
||||
def get_military_campaigns(self) -> Response:
|
||||
def _get_military_campaigns(self) -> Response:
|
||||
return self.get("{}/military/campaigns-new/".format(self.url))
|
||||
|
||||
def get_military_unit_data(self, unit_id: int, **kwargs) -> Response:
|
||||
def _get_military_unit_data(self, unit_id: int, **kwargs) -> Response:
|
||||
params = {"groupId": unit_id, "panel": "members", **kwargs}
|
||||
return self.get("{}/military/military-unit-data/".format(self.url), params=params)
|
||||
|
||||
def get_money_donation_accept(self, donation_id: int) -> Response:
|
||||
def _get_money_donation_accept(self, donation_id: int) -> Response:
|
||||
return self.get("{}/main/money-donation/accept/{}".format(self.url, donation_id), params={"_token": self.token})
|
||||
|
||||
def get_money_donation_reject(self, donation_id: int) -> Response:
|
||||
def _get_money_donation_reject(self, donation_id: int) -> Response:
|
||||
return self.get("{}/main/money-donation/reject/{}".format(self.url, donation_id), params={"_token": self.token})
|
||||
|
||||
def get_party_members(self, party: int) -> Response:
|
||||
def _get_notifications_ajax_community(self, page: int = 1) -> Response:
|
||||
return self.get("{}/main/notificationsAjax/community/{}".format(self.url, page))
|
||||
|
||||
def _get_notifications_ajax_system(self, page: int = 1) -> Response:
|
||||
return self.get("{}/main/notificationsAjax/system/{}".format(self.url, page))
|
||||
|
||||
def _get_notifications_ajax_report(self, page: int = 1) -> Response:
|
||||
return self.get("{}/main/notificationsAjax/report/{}".format(self.url, page))
|
||||
|
||||
def _get_party_members(self, party: int) -> Response:
|
||||
return self.get("{}/main/party-members/{}".format(self.url, party))
|
||||
|
||||
def get_rankings_parties(self, country: int) -> Response:
|
||||
def _get_rankings_parties(self, country: int) -> Response:
|
||||
return self.get("{}/main/rankings-parties/1/{}".format(self.url, country))
|
||||
|
||||
def get_training_grounds_json(self) -> Response:
|
||||
def _get_training_grounds_json(self) -> Response:
|
||||
return self.get("{}/main/training-grounds-json".format(self.url))
|
||||
|
||||
def get_weekly_challenge_data(self) -> Response:
|
||||
def _get_weekly_challenge_data(self) -> Response:
|
||||
return self.get("{}/main/weekly-challenge-data".format(self.url))
|
||||
|
||||
def post_activate_battle_effect(self, battle: int, kind: str, citizen_id: int) -> Response:
|
||||
def _get_wars_show(self, war_id: int) -> Response:
|
||||
return self.get("{}/wars/show/{}".format(self.url, war_id))
|
||||
|
||||
def _post_activate_battle_effect(self, battle: int, kind: str, citizen_id: int) -> Response:
|
||||
data = dict(battleId=battle, citizenId=citizen_id, type=kind, _token=self.token)
|
||||
return self.post("{}/main/fight-activateBattleEffect".format(self.url), data=data)
|
||||
|
||||
def post_article_comments(self, article: int, page: int = 1) -> Response:
|
||||
def _post_article_comments(self, article: int, page: int = 1) -> Response:
|
||||
data = dict(_token=self.token, articleId=article, page=page)
|
||||
if page:
|
||||
data.update({'page': page})
|
||||
return self.post("{}/main/articleComments".format(self.url), data=data)
|
||||
|
||||
def post_article_comments_create(self, message: str, article: int, parent: int = 0) -> Response:
|
||||
def _post_article_comments_create(self, message: str, article: int, parent: int = 0) -> Response:
|
||||
data = dict(_token=self.token, message=message, articleId=article)
|
||||
if parent:
|
||||
data.update({"parentId": parent})
|
||||
return self.post("{}/main/articleComments/create".format(self.url), data=data)
|
||||
|
||||
def post_battle_console(self, battle: int, zone: int, round_id: int, division: int, page: int,
|
||||
damage: bool) -> Response:
|
||||
def _post_battle_console(self, battle: int, zone: int, round_id: int, division: int, page: int,
|
||||
damage: bool) -> Response:
|
||||
data = dict(battleId=battle, zoneId=zone, action="battleStatistics", round=round_id, division=division,
|
||||
leftPage=page, rightPage=page, _token=self.token)
|
||||
if damage:
|
||||
@ -564,15 +579,15 @@ class CitizenAPI:
|
||||
|
||||
return self.post("{}/military/battle-console".format(self.url), data=data)
|
||||
|
||||
def post_buy_gold_items(self, currency: str, item: str, amount: int) -> Response:
|
||||
def _post_buy_gold_items(self, currency: str, item: str, amount: int) -> Response:
|
||||
data = dict(itemId=item, currency=currency, amount=amount, _token=self.token)
|
||||
return self.post("{}/main/buyGoldItems".format(self.url), data=data)
|
||||
|
||||
def post_candidate_for_congress(self, presentation: str = "") -> Response:
|
||||
def _post_candidate_for_congress(self, presentation: str = "") -> Response:
|
||||
data = dict(_token=self.token, presentation=presentation)
|
||||
return self.post("{}/candidate-for-congress".format(self.url), data=data)
|
||||
|
||||
def post_citizen_add_remove_friend(self, citizen: int, add: bool) -> Response:
|
||||
def _post_citizen_add_remove_friend(self, citizen: int, add: bool) -> Response:
|
||||
data = dict(_token=self.token, citizenId=citizen, url="//www.erepublik.com/en/main/citizen-addRemoveFriend")
|
||||
if add:
|
||||
data.update({"action": "addFriend"})
|
||||
@ -580,69 +595,70 @@ class CitizenAPI:
|
||||
data.update({"action": "removeFriend"})
|
||||
return self.post("{}/main/citizen-addRemoveFriend".format(self.url), data=data)
|
||||
|
||||
def post_collect_anniversary_reward(self) -> Response:
|
||||
def _post_collect_anniversary_reward(self) -> Response:
|
||||
return self.post("{}/main/collect-anniversary-reward".format(self.url), data={"_token": self.token})
|
||||
|
||||
def post_country_donate(self, country: int, action: str, value: Union[int, float], quality: int = None):
|
||||
def _post_country_donate(self, country: int, action: str, value: Union[int, float],
|
||||
quality: int = None) -> Response:
|
||||
json = dict(countryId=country, action=action, _token=self.token, value=value, quality=quality)
|
||||
return self.post("{}/main/country-donate".format(self.url), data=json,
|
||||
headers={"Referer": "{}/country/economy/Latvia".format(self.url)})
|
||||
|
||||
def post_daily_task_reward(self) -> Response:
|
||||
def _post_daily_task_reward(self) -> Response:
|
||||
return self.post("{}/main/daily-tasks-reward".format(self.url), data=dict(_token=self.token))
|
||||
|
||||
def post_delete_message(self, msg_id: list) -> Response:
|
||||
def _post_delete_message(self, msg_id: list) -> Response:
|
||||
data = {"_token": self.token, "delete_message[]": msg_id}
|
||||
return self.post("{}/main/messages-delete".format(self.url), data)
|
||||
|
||||
def post_eat(self, color: str) -> Response:
|
||||
def _post_eat(self, color: str) -> Response:
|
||||
data = dict(_token=self.token, buttonColor=color)
|
||||
return self.post("{}/main/eat".format(self.url), params=data)
|
||||
|
||||
def post_economy_activate_house(self, quality: int) -> Response:
|
||||
def _post_economy_activate_house(self, quality: int) -> Response:
|
||||
data = {"action": "activate", "quality": quality, "type": "house", "_token": self.token}
|
||||
return self.post("{}/economy/activateHouse".format(self.url), data=data)
|
||||
|
||||
def post_economy_assign_to_holding(self, factory: int, holding: int) -> Response:
|
||||
def _post_economy_assign_to_holding(self, factory: int, holding: int) -> Response:
|
||||
data = dict(_token=self.token, factoryId=factory, action="assign", holdingCompanyId=holding)
|
||||
return self.post("{}/economy/assign-to-holding".format(self.url), data=data)
|
||||
|
||||
def post_economy_create_company(self, industry: int, building_type: int = 1) -> Response:
|
||||
def _post_economy_create_company(self, industry: int, building_type: int = 1) -> Response:
|
||||
data = {"_token": self.token, "company[industry_id]": industry, "company[building_type]": building_type}
|
||||
return self.post("{}/economy/create-company".format(self.url), data=data,
|
||||
headers={"Referer": "{}/economy/create-company".format(self.url)})
|
||||
|
||||
def post_economy_donate_items_action(self, citizen: int, amount: int, industry: int,
|
||||
quality: int) -> Response:
|
||||
def _post_economy_donate_items_action(self, citizen: int, amount: int, industry: int,
|
||||
quality: int) -> Response:
|
||||
data = dict(citizen_id=citizen, amount=amount, industry_id=industry, quality=quality, _token=self.token)
|
||||
return self.post("{}/economy/donate-items-action".format(self.url), data=data,
|
||||
headers={"Referer": "{}/economy/donate-items/{}".format(self.url, citizen)})
|
||||
|
||||
def post_economy_donate_money_action(self, citizen: int, amount: float = 0.0,
|
||||
currency: int = 62) -> Response:
|
||||
def _post_economy_donate_money_action(self, citizen: int, amount: float = 0.0,
|
||||
currency: int = 62) -> Response:
|
||||
data = dict(citizen_id=citizen, _token=self.token, currency_id=currency, amount=amount)
|
||||
return self.post("{}/economy/donate-money-action".format(self.url), data=data,
|
||||
headers={"Referer": "{}/economy/donate-money/{}".format(self.url, citizen)})
|
||||
|
||||
def post_economy_exchange_purchase(self, amount: float, currency: int, offer: int) -> Response:
|
||||
def _post_economy_exchange_purchase(self, amount: float, currency: int, offer: int) -> Response:
|
||||
data = dict(_token=self.token, amount=amount, currencyId=currency, offerId=offer)
|
||||
return self.post("{}/economy/exchange/purchase/".format(self.url), data=data)
|
||||
|
||||
def post_economy_exchange_retrieve(self, personal: bool, page: int, currency: int) -> Response:
|
||||
def _post_economy_exchange_retrieve(self, personal: bool, page: int, currency: int) -> Response:
|
||||
data = dict(_token=self.token, personalOffers=int(personal), page=page, currencyId=currency)
|
||||
return self.post("{}/economy/exchange/retrieve/".format(self.url), data=data)
|
||||
|
||||
def post_economy_job_market_apply(self, citizen: int, salary: int) -> Response:
|
||||
def _post_economy_job_market_apply(self, citizen: int, salary: int) -> Response:
|
||||
data = dict(_token=self.token, citizenId=citizen, salary=salary)
|
||||
return self.post("{}/economy/job-market-apply".format(self.url), data=data)
|
||||
|
||||
def post_economy_marketplace(self, country: int, industry: int, quality: int,
|
||||
order_asc: bool = True) -> Response:
|
||||
def _post_economy_marketplace(self, country: int, industry: int, quality: int,
|
||||
order_asc: bool = True) -> Response:
|
||||
data = dict(countryId=country, industryId=industry, quality=quality, ajaxMarket=1,
|
||||
orderBy="price_asc" if order_asc else "price_desc", _token=self.token)
|
||||
return self.post("{}/economy/marketplaceAjax".format(self.url), data=data)
|
||||
|
||||
def post_economy_marketplace_actions(self, amount: int, buy: bool = False, **kwargs) -> Response:
|
||||
def _post_economy_marketplace_actions(self, amount: int, buy: bool = False, **kwargs) -> Response:
|
||||
if buy:
|
||||
data = dict(_token=self.token, offerId=kwargs['offer'], amount=amount, orderBy="price_asc", currentPage=1,
|
||||
buyAction=1)
|
||||
@ -651,12 +667,12 @@ class CitizenAPI:
|
||||
industryId=kwargs["industry"], quality=kwargs["quality"], amount=amount, sellAction='postOffer')
|
||||
return self.post("{}/economy/marketplaceActions".format(self.url), data=data)
|
||||
|
||||
def post_economy_resign(self) -> Response:
|
||||
def _post_economy_resign(self) -> Response:
|
||||
return self.post("{}/economy/resign".format(self.url),
|
||||
headers={"Content-Type": "application/x-www-form-urlencoded"},
|
||||
data={"_token": self.token, "action_type": "resign"})
|
||||
|
||||
def post_economy_sell_company(self, factory: int, pin: int = None, sell: bool = True) -> Response:
|
||||
def _post_economy_sell_company(self, factory: int, pin: int = None, sell: bool = True) -> Response:
|
||||
url = "{}/economy/sell-company/{}".format(self.url, factory)
|
||||
data = dict(_token=self.token, pin="" if pin is None else pin)
|
||||
if sell:
|
||||
@ -665,10 +681,10 @@ class CitizenAPI:
|
||||
data.update({"dissolve": factory})
|
||||
return self.post(url, data=data, headers={"Referer": url})
|
||||
|
||||
def post_economy_train(self, tg_ids: List[int]) -> Response:
|
||||
def _post_economy_train(self, tg_ids: List[int]) -> Response:
|
||||
data: Dict[str, Union[int, str]] = {}
|
||||
if not tg_ids:
|
||||
return self.get_training_grounds_json()
|
||||
return self._get_training_grounds_json()
|
||||
else:
|
||||
for idx, tg_id in enumerate(tg_ids):
|
||||
data["grounds[%i][id]" % idx] = tg_id
|
||||
@ -677,11 +693,11 @@ class CitizenAPI:
|
||||
data['_token'] = self.token
|
||||
return self.post("{}/economy/train".format(self.url), data=data)
|
||||
|
||||
def post_economy_upgrade_company(self, factory: int, level: int, pin: str = None) -> Response:
|
||||
def _post_economy_upgrade_company(self, factory: int, level: int, pin: str = None) -> Response:
|
||||
data = dict(_token=self.token, type="upgrade", companyId=factory, level=level, pin="" if pin is None else pin)
|
||||
return self.post("{}/economy/upgrade-company".format(self.url), data=data)
|
||||
|
||||
def post_economy_work(self, action_type: str, wam: List[int] = None, employ: Dict[int, int] = None):
|
||||
def _post_economy_work(self, action_type: str, wam: List[int] = None, employ: Dict[int, int] = None) -> Response:
|
||||
"""
|
||||
:return: requests.Response or None
|
||||
"""
|
||||
@ -690,87 +706,91 @@ class CitizenAPI:
|
||||
if wam is None:
|
||||
wam = []
|
||||
data: Dict[str, Union[int, str]] = dict(action_type=action_type, _token=self.token)
|
||||
if action_type == "work":
|
||||
return self.post("{}/economy/work".format(self.url), data=data)
|
||||
elif action_type == "production":
|
||||
if action_type == "production":
|
||||
max_idx = 0
|
||||
for idx, company_id in enumerate(sorted(wam or [])):
|
||||
for company_id in sorted(wam or []):
|
||||
data.update({
|
||||
"companies[%i][id]" % idx: company_id,
|
||||
"companies[%i][employee_works]" % idx: employ.pop(company_id, 0),
|
||||
"companies[%i][own_work]" % idx: 1
|
||||
"companies[%i][id]" % max_idx: company_id,
|
||||
"companies[%i][employee_works]" % max_idx: employ.pop(company_id, 0),
|
||||
"companies[%i][own_work]" % max_idx: 1
|
||||
})
|
||||
max_idx = idx + 1
|
||||
for idx, company_id in enumerate(sorted(employ or [])):
|
||||
idx_ = idx + max_idx
|
||||
max_idx += 1
|
||||
for company_id in sorted(employ or []):
|
||||
data.update({
|
||||
"companies[%i][id]" % idx_: company_id,
|
||||
"companies[%i][employee_works]" % idx_: employ.pop(company_id),
|
||||
"companies[%i][own_work]" % idx_: 0
|
||||
"companies[%i][id]" % max_idx: company_id,
|
||||
"companies[%i][employee_works]" % max_idx: employ.pop(company_id),
|
||||
"companies[%i][own_work]" % max_idx: 0
|
||||
})
|
||||
return self.post("{}/economy/work".format(self.url), data=data)
|
||||
else:
|
||||
return
|
||||
max_idx += 1
|
||||
return self.post("{}/economy/work".format(self.url), data=data)
|
||||
|
||||
def post_economy_work_overtime(self) -> Response:
|
||||
def _post_economy_work_overtime(self) -> Response:
|
||||
data = dict(action_type="workOvertime", _token=self.token)
|
||||
return self.post("{}/economy/workOvertime".format(self.url), data=data)
|
||||
|
||||
def post_forgot_password(self, email: str) -> Response:
|
||||
def _post_forgot_password(self, email: str) -> Response:
|
||||
data = dict(_token=self.token, email=email, commit="Reset password")
|
||||
return self.post("{}/forgot-password".format(self.url), data=data)
|
||||
|
||||
def post_fight_activate_booster(self, battle: int, quality: int, duration: int, kind: str) -> Response:
|
||||
def _post_fight_activate_booster(self, battle: int, quality: int, duration: int, kind: str) -> Response:
|
||||
data = dict(type=kind, quality=quality, duration=duration, battleId=battle, _token=self.token)
|
||||
return self.post("{}/military/fight-activateBooster".format(self.url), data=data)
|
||||
|
||||
def post_login(self, email: str, password: str) -> Response:
|
||||
def _post_login(self, email: str, password: str) -> Response:
|
||||
data = dict(csrf_token=self.token, citizen_email=email, citizen_password=password, remember='on')
|
||||
return self.post("{}/login".format(self.url), data=data)
|
||||
|
||||
def post_messages_alert(self, notification_ids: list) -> Response:
|
||||
def _post_messages_alert(self, notification_ids: List[int]) -> Response:
|
||||
data = {"_token": self.token, "delete_alerts[]": notification_ids, "deleteAllAlerts": "1", "delete": "Delete"}
|
||||
return self.post("{}/main/messages-alerts/1".format(self.url), data=data)
|
||||
|
||||
def post_messages_compose(self, subject: str, body: str, citizens: List[int]) -> Response:
|
||||
def _post_messages_compose(self, subject: str, body: str, citizens: List[int]) -> Response:
|
||||
url_pk = 0 if len(citizens) > 1 else str(citizens[0])
|
||||
data = dict(citizen_name=",".join([str(x) for x in citizens]),
|
||||
citizen_subject=subject, _token=self.token, citizen_message=body)
|
||||
return self.post("{}/main/messages-compose/{}}".format(self.url, url_pk), data=data)
|
||||
|
||||
def post_military_battle_console(self, battle_id: int, round_id: int, division: int) -> Response:
|
||||
data = dict(battleId=battle_id, zoneId=round_id, action="battleStatistics", round=round_id, division=division,
|
||||
type="damage", leftPage=1, rightPage=1, _token=self.token)
|
||||
return self.post("{}/military/battle-console".format(self.url, battle_id), data=data)
|
||||
def _post_military_battle_console(self, battle_id: int, action: str, page: int = 1, **kwargs) -> Response:
|
||||
data = dict(battleId=battle_id, action=action, _token=self.token)
|
||||
if action == "battleStatistics":
|
||||
data.update(round=kwargs["round_id"], zoneId=kwargs["round_id"], leftPage=page, rightPage=page,
|
||||
division=kwargs["division"], type=kwargs.get("type", 'damage'),)
|
||||
elif action == "warList":
|
||||
data.update(page=page)
|
||||
return self.post("{}/military/battle-console".format(self.url), data=data)
|
||||
|
||||
def post_military_fight_air(self, battle_id: int, side_id: int) -> Response:
|
||||
def _post_military_deploy_bomb(self, battle_id: int, bomb_id: int) -> Response:
|
||||
data = dict(battleId=battle_id, bombId=bomb_id, _token=self.token)
|
||||
return self.post("{}/military/deploy-bomb".format(self.url), data=data)
|
||||
|
||||
def _post_military_fight_air(self, battle_id: int, side_id: int) -> Response:
|
||||
data = dict(sideId=side_id, battleId=battle_id, _token=self.token)
|
||||
return self.post("{}/military/fight-shoooot/{}".format(self.url, battle_id), data=data)
|
||||
|
||||
def post_military_fight_ground(self, battle_id: int, side_id: int) -> Response:
|
||||
def _post_military_fight_ground(self, battle_id: int, side_id: int) -> Response:
|
||||
data = dict(sideId=side_id, battleId=battle_id, _token=self.token)
|
||||
return self.post("{}/military/fight-shooot/{}".format(self.url, battle_id), data=data)
|
||||
|
||||
def post_military_group_missions(self) -> Response:
|
||||
def _post_military_group_missions(self) -> Response:
|
||||
data = dict(action="check", _token=self.token)
|
||||
return self.post("{}/military/group-missions".format(self.url), data=data)
|
||||
|
||||
def post_travel(self, check: str, **kwargs) -> Response:
|
||||
def _post_travel(self, check: str, **kwargs) -> Response:
|
||||
data = dict(_token=self.token, check=check, **kwargs)
|
||||
return self.post("{}/main/travel".format(self.url), data=data)
|
||||
|
||||
def post_travel_data(self, **kwargs) -> Response:
|
||||
def _post_travel_data(self, **kwargs) -> Response:
|
||||
return self.post("{}/main/travelData".format(self.url), data=dict(_token=self.token, **kwargs))
|
||||
|
||||
def post_wars_attack_region(self, war: int, region: int) -> Response:
|
||||
data = dict(_token=self.token)
|
||||
return self.post("{}/wars/attack-region/{}/{}".format(self.url, war, region), data=data)
|
||||
def _post_wars_attack_region(self, war_id: int, region_id: int, region_name: str) -> Response:
|
||||
data = {'_token': self.token, 'warId': war_id, 'regionName': region_name, 'regionNameConfirm': region_name}
|
||||
return self.post('{}/wars/attack-region/{}/{}'.format(self.url, war_id, region_id), data=data)
|
||||
|
||||
def post_weekly_challenge_reward(self, reward_id: int) -> Response:
|
||||
def _post_weekly_challenge_reward(self, reward_id: int) -> Response:
|
||||
data = dict(_token=self.token, rewardId=reward_id)
|
||||
return self.post("{}/main/weekly-challenge-collect-reward".format(self.url), data=data)
|
||||
|
||||
def post_write_article(self, title: str, content: str, location: int, kind: int) -> Response:
|
||||
def _post_write_article(self, title: str, content: str, location: int, kind: int) -> Response:
|
||||
data = dict(_token=self.token, article_name=title, article_body=content, article_location=location,
|
||||
article_category=kind)
|
||||
return self.post("{}/main/write-article".format(self.url), data=data)
|
||||
@ -778,73 +798,73 @@ class CitizenAPI:
|
||||
# Wall Posts
|
||||
# ## Country
|
||||
|
||||
def post_country_comment_retrieve(self, post_id: int):
|
||||
def _post_country_comment_retrieve(self, post_id: int) -> Response:
|
||||
data = {"_token": self.token, "postId": post_id}
|
||||
return self.post("{}/main/country-comment/retrieve/json".format(self.url), data=data)
|
||||
|
||||
def post_country_comment_create(self, post_id: int, comment_message: str):
|
||||
def _post_country_comment_create(self, post_id: int, comment_message: str) -> Response:
|
||||
data = {"_token": self.token, "postId": post_id, 'comment_message': comment_message}
|
||||
return self.post("{}/main/country-comment/create/json".format(self.url), data=data)
|
||||
|
||||
def post_country_post_create(self, body: str, post_as: int):
|
||||
def _post_country_post_create(self, body: str, post_as: int) -> Response:
|
||||
data = {"_token": self.token, "post_message": body, "post_as": post_as}
|
||||
return self.post("{}/main/country-post/create/json".format(self.url), data=data)
|
||||
|
||||
def post_country_post_retrieve(self):
|
||||
def _post_country_post_retrieve(self) -> Response:
|
||||
data = {"_token": self.token, "page": 1, "switchedFrom": False}
|
||||
return self.post("{}/main/country-post/retrieve/json".format(self.url), data=data)
|
||||
|
||||
# ## Military Unit
|
||||
|
||||
def post_military_unit_comment_retrieve(self, post_id: int):
|
||||
def _post_military_unit_comment_retrieve(self, post_id: int) -> Response:
|
||||
data = {"_token": self.token, "postId": post_id}
|
||||
return self.post("{}/main/military-unit-comment/retrieve/json".format(self.url), data=data)
|
||||
|
||||
def post_military_unit_comment_create(self, post_id: int, comment_message: str):
|
||||
def _post_military_unit_comment_create(self, post_id: int, comment_message: str) -> Response:
|
||||
data = {"_token": self.token, "postId": post_id, 'comment_message': comment_message}
|
||||
return self.post("{}/main/military-unit-comment/create/json".format(self.url), data=data)
|
||||
|
||||
def post_military_unit_post_create(self, body: str, post_as: int):
|
||||
def _post_military_unit_post_create(self, body: str, post_as: int) -> Response:
|
||||
data = {"_token": self.token, "post_message": body, "post_as": post_as}
|
||||
return self.post("{}/main/military-unit-post/create/json".format(self.url), data=data)
|
||||
|
||||
def post_military_unit_post_retrieve(self):
|
||||
def _post_military_unit_post_retrieve(self) -> Response:
|
||||
data = {"_token": self.token, "page": 1, "switchedFrom": False}
|
||||
return self.post("{}/main/military-unit-post/retrieve/json".format(self.url), data=data)
|
||||
|
||||
# ## Party
|
||||
|
||||
def post_party_comment_retrieve(self, post_id: int):
|
||||
def _post_party_comment_retrieve(self, post_id: int) -> Response:
|
||||
data = {"_token": self.token, "postId": post_id}
|
||||
return self.post("{}/main/party-comment/retrieve/json".format(self.url), data=data)
|
||||
|
||||
def post_party_comment_create(self, post_id: int, comment_message: str):
|
||||
def _post_party_comment_create(self, post_id: int, comment_message: str) -> Response:
|
||||
data = {"_token": self.token, "postId": post_id, 'comment_message': comment_message}
|
||||
return self.post("{}/main/party-comment/create/json".format(self.url), data=data)
|
||||
|
||||
def post_party_post_create(self, body: str):
|
||||
def _post_party_post_create(self, body: str) -> Response:
|
||||
data = {"_token": self.token, "post_message": body}
|
||||
return self.post("{}/main/party-post/create/json".format(self.url), data=data)
|
||||
|
||||
def post_party_post_retrieve(self):
|
||||
def _post_party_post_retrieve(self) -> Response:
|
||||
data = {"_token": self.token, "page": 1, "switchedFrom": False}
|
||||
return self.post("{}/main/party-post/retrieve/json".format(self.url), data=data)
|
||||
|
||||
# ## Friend's Wall
|
||||
|
||||
def post_wall_comment_retrieve(self, post_id: int):
|
||||
def _post_wall_comment_retrieve(self, post_id: int) -> Response:
|
||||
data = {"_token": self.token, "postId": post_id}
|
||||
return self.post("{}/main/wall-comment/retrieve/json".format(self.url), data=data)
|
||||
|
||||
def post_wall_comment_create(self, post_id: int, comment_message: str):
|
||||
def _post_wall_comment_create(self, post_id: int, comment_message: str) -> Response:
|
||||
data = {"_token": self.token, "postId": post_id, 'comment_message': comment_message}
|
||||
return self.post("{}/main/wall-comment/create/json".format(self.url), data=data)
|
||||
|
||||
def post_wall_post_create(self, body: str):
|
||||
def _post_wall_post_create(self, body: str) -> Response:
|
||||
data = {"_token": self.token, "post_message": body}
|
||||
return self.post("{}/main/wall-post/create/json".format(self.url), data=data)
|
||||
|
||||
def post_wall_post_retrieve(self):
|
||||
def _post_wall_post_retrieve(self) -> Response:
|
||||
data = {"_token": self.token, "page": 1, "switchedFrom": False}
|
||||
return self.post("{}/main/wall-post/retrieve/json".format(self.url), data=data)
|
||||
|
||||
|
@ -11,13 +11,12 @@ from collections import deque
|
||||
from decimal import Decimal
|
||||
from json import JSONEncoder
|
||||
from pathlib import Path
|
||||
from typing import Union
|
||||
from typing import Union, Any, List, NoReturn, Mapping
|
||||
|
||||
import pytz
|
||||
import requests
|
||||
from requests import Response
|
||||
|
||||
|
||||
__all__ = ["FOOD_ENERGY", "COMMIT_ID", "COUNTRIES", "erep_tz",
|
||||
"now", "localize_dt", "localize_timestamp", "good_timedelta", "eday_from_date", "date_from_eday",
|
||||
"get_sleep_seconds", "interactive_sleep", "silent_sleep",
|
||||
@ -85,6 +84,19 @@ COUNTRIES = {1: 'Romania', 9: 'Brazil', 10: 'Italy', 11: 'France', 12: 'Germany'
|
||||
82: 'Cyprus', 83: 'Belarus', 84: 'New Zealand', 164: 'Saudi Arabia', 165: 'Egypt',
|
||||
166: 'United Arab Emirates', 167: 'Albania', 168: 'Georgia', 169: 'Armenia', 170: 'Nigeria', 171: 'Cuba'}
|
||||
|
||||
COUNTRY_LINK = {1: 'Romania', 9: 'Brazil', 11: 'France', 12: 'Germany', 13: 'Hungary', 82: 'Cyprus', 168: 'Georgia',
|
||||
15: 'Spain', 23: 'Canada', 26: 'Mexico', 27: 'Argentina', 28: 'Venezuela', 80: 'Montenegro', 24: 'USA',
|
||||
29: 'United-Kingdom', 50: 'Australia', 47: 'South-Korea',171: 'Cuba', 79: 'Republic-of-Macedonia-FYROM',
|
||||
30: 'Switzerland', 31: 'Netherlands', 32: 'Belgium', 33: 'Austria', 34: 'Czech-Republic', 35: 'Poland',
|
||||
36: 'Slovakia', 37: 'Norway', 38: 'Sweden', 39: 'Finland', 40: 'Ukraine', 41: 'Russia', 42: 'Bulgaria',
|
||||
43: 'Turkey', 44: 'Greece', 45: 'Japan', 48: 'India', 49: 'Indonesia', 78: 'Colombia', 68: 'Singapore',
|
||||
51: 'South Africa', 52: 'Republic-of-Moldova', 53: 'Portugal', 54: 'Ireland', 55: 'Denmark', 56: 'Iran',
|
||||
57: 'Pakistan', 58: 'Israel', 59: 'Thailand', 61: 'Slovenia', 63: 'Croatia', 64: 'Chile', 65: 'Serbia',
|
||||
66: 'Malaysia', 67: 'Philippines', 70: 'Estonia', 165: 'Egypt', 14: 'China', 77: 'Peru', 10: 'Italy',
|
||||
71: 'Latvia', 72: 'Lithuania', 73: 'North-Korea', 74: 'Uruguay', 75: 'Paraguay', 76: 'Bolivia',
|
||||
81: 'Republic-of-China-Taiwan', 166: 'United-Arab-Emirates', 167: 'Albania', 69: 'Bosnia-Herzegovina',
|
||||
169: 'Armenia', 83: 'Belarus', 84: 'New-Zealand', 164: 'Saudi-Arabia', 170: 'Nigeria', }
|
||||
|
||||
|
||||
class MyJSONEncoder(JSONEncoder):
|
||||
def default(self, o):
|
||||
@ -107,18 +119,22 @@ class MyJSONEncoder(JSONEncoder):
|
||||
return super().default(o)
|
||||
|
||||
|
||||
def now():
|
||||
def now() -> datetime.datetime:
|
||||
return datetime.datetime.now(erep_tz).replace(microsecond=0)
|
||||
|
||||
|
||||
def localize_timestamp(timestamp: int):
|
||||
def localize_timestamp(timestamp: int) -> datetime.datetime:
|
||||
return datetime.datetime.fromtimestamp(timestamp, erep_tz)
|
||||
|
||||
|
||||
def localize_dt(dt: Union[datetime.date, datetime.datetime]):
|
||||
if isinstance(dt, datetime.date):
|
||||
dt = datetime.datetime.combine(dt, datetime.time(0, 0, 0))
|
||||
return erep_tz.localize(dt)
|
||||
def localize_dt(dt: Union[datetime.date, datetime.datetime]) -> datetime.datetime:
|
||||
try:
|
||||
try:
|
||||
return erep_tz.localize(dt)
|
||||
except AttributeError:
|
||||
return erep_tz.localize(datetime.datetime.combine(dt, datetime.time(0, 0, 0)))
|
||||
except ValueError:
|
||||
return dt.astimezone(erep_tz)
|
||||
|
||||
|
||||
def good_timedelta(dt: datetime.datetime, td: datetime.timedelta) -> datetime.datetime:
|
||||
@ -237,7 +253,10 @@ def write_request(response: requests.Response, is_error: bool = False):
|
||||
"mimetype": "application/json" if ext == "json" else "text/html"}
|
||||
|
||||
|
||||
def send_email(name: str, content: list, player=None, local_vars=dict, promo: bool = False, captcha: bool = False):
|
||||
def send_email(name: str, content: List[Any], player=None, local_vars: Mapping[Any, Any] = None,
|
||||
promo: bool = False, captcha: bool = False):
|
||||
if local_vars is None:
|
||||
local_vars = {}
|
||||
from erepublik import Citizen
|
||||
|
||||
file_content_template = "<html><head><title>{title}</title></head><body>{body}</body></html>"
|
||||
@ -319,7 +338,11 @@ def process_error(log_info: str, name: str, exc_info: tuple, citizen=None, commi
|
||||
send_email(name, bugtrace, citizen, local_vars=trace)
|
||||
|
||||
|
||||
def slugify(value, allow_unicode=False):
|
||||
def report_promo(kind: str, time_untill: datetime.datetime) -> NoReturn:
|
||||
requests.post('https://api.erep.lv/promos/add/', data=dict(kind=kind, time_untill=time_untill))
|
||||
|
||||
|
||||
def slugify(value, allow_unicode=False) -> str:
|
||||
"""
|
||||
Function copied from Django2.2.1 django.utils.text.slugify
|
||||
Convert to ASCII if 'allow_unicode' is False. Convert spaces to hyphens.
|
||||
|
@ -1,5 +1,5 @@
|
||||
[bumpversion]
|
||||
current_version = 0.14.7
|
||||
current_version = 0.15.1
|
||||
commit = True
|
||||
tag = True
|
||||
|
||||
|
Reference in New Issue
Block a user