Bump version: 0.19.4.1 → 0.19.4.2

erepublik/__init__.py

@@ -4,7 +4,7 @@
 
 __author__ = """Eriks Karls"""
 __email__ = 'eriks@72.lv'
-__version__ = '0.19.2'
+__version__ = '0.19.4.2'
 
 from erepublik import classes, utils
 from erepublik.citizen import Citizen

erepublik/citizen.py

@@ -144,7 +144,7 @@ class Citizen(CitizenAPI):
             return
 
         html = resp.text
-        self.check_for_new_medals(html)
+        self.check_for_medals(html)
         re_token = re.search(r'var csrfToken = \'(\w{32})\'', html)
         re_login_token = re.search(r'<input type="hidden" id="_token" name="_token" value="(\w{32})">', html)
         if re_token:
@@ -220,7 +220,7 @@ class Citizen(CitizenAPI):
                 self.get_csrf_token()
                 self.get(url, **kwargs)
             else:
-                self.check_for_new_medals(response.text)
+                self.check_for_medals(response.text)
 
             self.r = response
         return response
@@ -259,12 +259,12 @@ class Citizen(CitizenAPI):
                 json.update({"_token": self.token})
             response = self.post(url, data=data, json=json, **kwargs)
         else:
-            self.check_for_new_medals(response.text)
+            self.check_for_medals(response.text)
 
         self.r = response
         return response
 
-    def check_for_new_medals(self, html: str):
+    def check_for_medals(self, html: str):
         new_medals = re.findall(r'(<div class="home_reward reward achievement">.*?<div class="bottom"></div>\s*</div>)',
                                 html, re.M | re.S | re.I)
         data: Dict[Tuple[str, Union[float, str]], Dict[str, Union[int, str, float]]] = {}
@@ -311,6 +311,44 @@ class Citizen(CitizenAPI):
             self.telegram.report_medal(f"Level *{level}*")
             self.reporter.report_action("LEVEL_UP", value=level)
 
+    def check_for_notification_medals(self):
+        notifications = self._get_main_citizen_daily_assistant().json()
+        data: Dict[Tuple[str, Union[float, str]], Dict[str, Union[int, str, float]]] = {}
+        for medal in notifications.get('notifications', []):
+            if medal.get('details', {}).get('type') == "citizenAchievement":
+                params = medal.get('details', {}).get('achievement')
+                about = medal.get('details').get('description')
+                title = medal.get('title')
+                # award_id = re.search(r'"wall_enable_alerts_(\d+)', medal)
+                # if award_id:
+                #     self._post_main_wall_post_automatic(**{'message': title, 'awardId': award_id.group(1)})
+
+                if params.get('ccValue'):
+                    reward = params.get('ccValue')
+                    currency = "Currency"
+                elif params.get('goldValue'):
+                    reward = params.get('goldValue')
+                    currency = "Gold"
+                else:
+                    reward = params.get('energyValue')
+                    currency = "Energy"
+
+                if (title, reward) not in data:
+                    data[(title, reward)] = {'about': about, 'kind': title, 'reward': reward, "count": 1,
+                                             "currency": currency, "params": params}
+                else:
+                    data[(title, reward)]['count'] += 1
+            self._post_main_global_alerts_close(medal.get('id'))
+        if data:
+            msgs = ["{count} x {kind},"
+                    " totaling {} {currency}".format(d["count"] * d["reward"], **d) for d in data.values()]
+
+            msgs = "\n".join(msgs)
+            self.telegram.report_medal(msgs)
+            self.write_log(f"Found awards:\n{msgs}")
+            for info in data.values():
+                self.reporter.report_action("NEW_MEDAL", info)
+
     def update_all(self, force_update=False):
         # Do full update max every 5 min
         if good_timedelta(self.__last_full_update, timedelta(minutes=5)) > self.now and not force_update:
@@ -324,12 +362,14 @@ class Citizen(CitizenAPI):
         self.update_money()
         self.update_weekly_challenge()
         self.send_state_update()
+        self.check_for_notification_medals()
 
     def update_citizen_info(self, html: str = None):
         """
         Gets main page and updates most information about player
         """
         if html is None:
+            self.check_for_notification_medals()
             self._get_main()
             return
         ugly_js = re.search(r'"promotions":\s*(\[{?.*?}?])', html).group(1)

erepublik/classes.py

@@ -524,9 +524,12 @@ Class for unifying eRepublik known endpoints and their required/optional paramet
     def _get_main_citizen_profile_json(self, player_id: int) -> Response:
         return self.get("{}/main/citizen-profile-json/{}".format(self.url, player_id))
 
-    def _get_main_citizen_daily_assistant(self) -> Response:
+    def _get_main_citizen_notifications(self) -> Response:
         return self.get("{}/main/citizenDailyAssistant".format(self.url))
 
+    def _get_main_citizen_daily_assistant(self) -> Response:
+        return self.get("{}/main/citizenNotifications".format(self.url))
+
     def _get_main_city_data_residents(self, city: int, page: int = 1, params: Mapping[str, Any] = None) -> Response:
         if params is None:
             params = {}
@@ -673,6 +676,10 @@ Class for unifying eRepublik known endpoints and their required/optional paramet
         data = dict(_token=self.token, articleId=article_id, amount=amount)
         return self.post("{}/main/donate-article".format(self.url), data=data)
 
+    def _post_main_global_alerts_close(self, alert_id: int) -> Response:
+        data = dict(_token=self.token, alert_id=alert_id)
+        return self.post("{}/main/global-alerts/close".format(self.url), data=data)
+
     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)
@@ -1278,6 +1285,8 @@ class TelegramBot:
     def send_message(self, message: str) -> bool:
         self.__queue.append(message)
         if not self.__initialized:
+            if self._last_time < utils.now():
+                self.__queue.clear()
             return True
         self._threads = [t for t in self._threads if t.is_alive()]
         self._next_time = utils.good_timedelta(utils.now(), datetime.timedelta(minutes=1))

erepublik/utils.py

@@ -345,6 +345,11 @@ def process_error(log_info: str, name: str, exc_info: tuple, citizen=None, commi
     trace = inspect.trace()
     if trace:
         trace = trace[-1][0].f_locals
+        if trace.get('__name__') == '__main__':
+            trace = {'commit_id': trace.get('COMMIT_ID'),
+                     'interactive': trace.get('INTERACTIVE'),
+                     'version': trace.get('__version__'),
+                     'config': trace.get('CONFIG')}
     else:
         trace = dict()
     send_email(name, content, citizen, local_vars=trace)
@@ -394,7 +399,7 @@ def slugify(value, allow_unicode=False) -> str:
 
 
 def calculate_hit(strength: float, rang: int, tp: bool, elite: bool, ne: bool, booster: int = 0,
-                  weapon: int = 200, is_deploy: bool = False) -> Decimal:
+                  weapon: int = 200, is_deploy: bool = False) -> float:
     dec = 3 if is_deploy else 0
     base_str = (1 + Decimal(str(round(strength, 3))) / 400)
     base_rnk = (1 + Decimal(str(rang / 5)))
@@ -415,7 +420,7 @@ def calculate_hit(strength: float, rang: int, tp: bool, elite: bool, ne: bool, b
 
 
 def get_ground_hit_dmg_value(citizen_id: int, natural_enemy: bool = False, true_patriot: bool = False,
-                             booster: int = 0, weapon_power: int = 200) -> Decimal:
+                             booster: int = 0, weapon_power: int = 200) -> float:
     r = requests.get(f"https://www.erepublik.com/en/main/citizen-profile-json/{citizen_id}").json()
     rang = r['military']['militaryData']['ground']['rankNumber']
     strength = r['military']['militaryData']['ground']['strength']
@@ -427,7 +432,7 @@ def get_ground_hit_dmg_value(citizen_id: int, natural_enemy: bool = False, true_
 
 
 def get_air_hit_dmg_value(citizen_id: int, natural_enemy: bool = False, true_patriot: bool = False, booster: int = 0,
-                          weapon_power: int = 0) -> Decimal:
+                          weapon_power: int = 0) -> float:
     r = requests.get(f"https://www.erepublik.com/en/main/citizen-profile-json/{citizen_id}").json()
     rang = r['military']['militaryData']['aircraft']['rankNumber']
     elite = r['citizenAttributes']['level'] > 100

requirements_dev.txt

@@ -1,16 +1,16 @@
 bumpversion==0.5.3
-coverage==5.0.2
+coverage==5.0.3
 edx-sphinx-theme==1.5.0
 flake8==3.7.9
-ipython==7.11.1
+ipython==7.12.0
 isort==4.3.21
-pip==19.3.1
+pip==20.0.2
 PyInstaller==3.6
 pytz==2019.3
-requests==2.22.0
+requests==2.23.0
-setuptools==44.0.0
+setuptools==45.2.0
-Sphinx==2.3.1
+Sphinx==2.4.2
-tox==3.14.3
+tox==3.14.5
 twine==3.1.1
-watchdog==0.9.0
+watchdog==0.10.2
-wheel==0.33.6
+wheel==0.34.2

setup.cfg

@@ -1,7 +1,11 @@
 [bumpversion]
-current_version = 0.19.2
+current_version = 0.19.4.2
 commit = True
 tag = True
+parse = (?P<major>\d+)\.(?P<minor>\d+)\.(?P<patch>\d+)\.?(?P<dev>\d+)?
+serialize = 
+	{major}.{minor}.{patch}.{dev}
+	{major}.{minor}.{patch}
 
 [bumpversion:file:setup.py]
 search = version='{current_version}'

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==2019.3', 'requests==2.22.0']
+requirements = ['pytz==2019.3', 'requests==2.23.0']
 
 setup_requirements = []
 
@@ -43,6 +43,6 @@ setup(
     test_suite='tests',
     tests_require=test_requirements,
     url='https://github.com/eeriks/erepublik/',
-    version='0.19.2',
+    version='0.19.4.2',
     zip_safe=False,
 )