mirror/galaxy-integrations-python-api
1
0
Fork 0
mirror of https://github.com/gogcom/galaxy-integrations-python-api.git synced 2026-01-14 17:58:28 -05:00
Code Issues Packages Projects Releases Wiki Activity

include subscription_name in partial finished notification

Browse Source
This commit is contained in:
unknown
2020-02-10 10:05:58 +01:00
parent 19c9f14ca9
commit cd452b881d
2 changed files with 20 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/galaxy/api/plugin.py
View File

@@ -129,7 +129,7 @@ class SubscriptionGamesImporter(Importer):
logger.exception("Unexpected exception raised in %s importer", self._name)
self._notification_failure(id_, UnknownError())
finally:
self._notification_partial_finished()
self._notification_partial_finished(id_)
class Plugin:
@@ -722,8 +722,13 @@ class Plugin:
}
)
def _subscriptions_games_partial_import_finished(self) -> None:
self._connection.send_notification("subscription_games_partial_import_finished", None)
def _subscriptions_games_partial_import_finished(self, subscription_name: str) -> None:
self._connection.send_notification(
"subscription_games_partial_import_finished",
{
"subscription_name": subscription_name
}
)
def _subscription_games_import_finished(self) -> None:
self._connection.send_notification("subscription_games_import_finished", None)

15
tests/test_subscriptions.py
View File

@@ -143,7 +143,10 @@ async def test_get_subscription_games_success(plugin, read, write):
{
'jsonrpc': '2.0',
'method':
'subscription_games_partial_import_finished', 'params': None
'subscription_games_partial_import_finished',
'params': {
"subscription_name": "sub_a"
}
},
{
"jsonrpc": "2.0",
@@ -191,7 +194,10 @@ async def test_get_subscription_games_success_empty(plugin, read, write):
{
'jsonrpc': '2.0',
'method':
'subscription_games_partial_import_finished', 'params': None
'subscription_games_partial_import_finished',
'params': {
"subscription_name": "sub_a"
}
},
{
"jsonrpc": "2.0",
@@ -242,7 +248,10 @@ async def test_get_subscription_games_error(exception, code, message, plugin, re
{
'jsonrpc': '2.0',
'method':
'subscription_games_partial_import_finished', 'params': None
'subscription_games_partial_import_finished',
'params': {
"subscription_name": "sub_a"
}
},
{
"jsonrpc": "2.0",