ba61148d-0c1f-4500-9ad2-0c4ea5f9de71

Committed 22 Feb 2025 12:03PM UTC coverage: 46.213% (-1.0%) from 47.243%

Build # ba61148d-0c1f-4500-9ad2-0c4ea5f9de71

Build Type

push

circleci

Committed by

mpasternak

Commit Message

Testy dla bpp.admin.helpers.pbn_api

Run Details

0 of 43 new or added lines in 3 files covered. (0.0%)

581 existing lines in 46 files now uncovered.

16464 of 35626 relevant lines covered (46.21%)

1.19 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

28.13

src/pbn_api/tasks.py

from long_running.util import wait_for_object
from pbn_api.models.queue import SendStatus

from django_bpp.celery_tasks import app


@app.task
def task_sprobuj_wyslac_do_pbn(pk):
    from pbn_api.models import PBN_Export_Queue

    p = wait_for_object(PBN_Export_Queue, pk)
    res = p.send_to_pbn()

    match res:
        case SendStatus.RETRY_LATER:
            task_sprobuj_wyslac_do_pbn.apply_async(args=[pk], countdown=5 * 60)

        case SendStatus.RETRY_SOON:
            # np. 423 Locked
            task_sprobuj_wyslac_do_pbn.apply_async(args=[pk], countdown=60)

        case SendStatus.RETRY_MUCH_LATER:
            # PraceSerwisoweException
            task_sprobuj_wyslac_do_pbn.apply_async(args=[pk], countdown=60 * 60 * 3)

        case (
            SendStatus.FINISHED_ERROR
            | SendStatus.FINISHED_OKAY
            | SendStatus.RETRY_AFTER_USER_AUTHORISED
        ):
            return

        case _:
            raise NotImplementedError(
                f"Return status for background send to PBN not supported {res=}"
            )


@app.task
def kolejka_wyczysc_wpisy_bez_rekordow():
    from pbn_api.models import PBN_Export_Queue

    for elem in PBN_Export_Queue.objects.all():
        if not elem.check_if_record_still_exists():
            elem.delete()


@app.task
def kolejka_ponow_wysylke_prac_po_zalogowaniu(pk):
    from pbn_api.models import PBN_Export_Queue

    # Użytkownik o ID pk zalogował się.
    # Odśwież do wysyłki prace które były jego po zalogowaniu
    for elem in PBN_Export_Queue.objects.filter(
        retry_after_user_authorised=True, zamowil_id=pk, wysylke_zakonczono=None
    ):
        task_sprobuj_wyslac_do_pbn.delay(elem.pk)

    # ... ale i odświez prace wszystkich użytkowników, którzy mają jego konto
    # jako konto do wysyłki:
    for elem in PBN_Export_Queue.objects.filter(
        retry_after_user_authorised=True,
        zamowil__przedstawiaj_w_pbn_jako_id=pk,
        wysylke_zakonczono=None,
    ):
        task_sprobuj_wyslac_do_pbn.delay(elem.pk)

1	from long_running.util import wait_for_object	3✔
2	from pbn_api.models.queue import SendStatus	3✔
3
4	from django_bpp.celery_tasks import app	3✔
5
6
7	@app.task	3✔
8	def task_sprobuj_wyslac_do_pbn(pk):	3✔
9	from pbn_api.models import PBN_Export_Queue	×
10
11	p = wait_for_object(PBN_Export_Queue, pk)	×
12	res = p.send_to_pbn()	×
13
14	match res:	×
15	case SendStatus.RETRY_LATER:	×
16	task_sprobuj_wyslac_do_pbn.apply_async(args=[pk], countdown=5 * 60)	×
17
18	case SendStatus.RETRY_SOON:	×
19	# np. 423 Locked
20	task_sprobuj_wyslac_do_pbn.apply_async(args=[pk], countdown=60)	×
21
22	case SendStatus.RETRY_MUCH_LATER:	×
23	# PraceSerwisoweException
24	task_sprobuj_wyslac_do_pbn.apply_async(args=[pk], countdown=60 * 60 * 3)	×
25
26	case (	×
27	SendStatus.FINISHED_ERROR
28	\| SendStatus.FINISHED_OKAY
29	\| SendStatus.RETRY_AFTER_USER_AUTHORISED
30	):
31	return	×
32
33	case _:	×
34	raise NotImplementedError(	×
35	f"Return status for background send to PBN not supported {res=}"
36	)
37
38
39	@app.task	3✔
40	def kolejka_wyczysc_wpisy_bez_rekordow():	3✔
41	from pbn_api.models import PBN_Export_Queue	×
42
43	for elem in PBN_Export_Queue.objects.all():	×
44	if not elem.check_if_record_still_exists():	×
45	elem.delete()	×
46
47
48	@app.task	3✔
49	def kolejka_ponow_wysylke_prac_po_zalogowaniu(pk):	3✔
50	from pbn_api.models import PBN_Export_Queue	×
51
52	# Użytkownik o ID pk zalogował się.
53	# Odśwież do wysyłki prace które były jego po zalogowaniu
UNCOV 54	for elem in PBN_Export_Queue.objects.filter(	×
55	retry_after_user_authorised=True, zamowil_id=pk, wysylke_zakonczono=None
56	):
UNCOV 57	task_sprobuj_wyslac_do_pbn.delay(elem.pk)	×
58
59	# ... ale i odświez prace wszystkich użytkowników, którzy mają jego konto
60	# jako konto do wysyłki:
UNCOV 61	for elem in PBN_Export_Queue.objects.filter(	×
62	retry_after_user_authorised=True,
63	zamowil__przedstawiaj_w_pbn_jako_id=pk,
64	wysylke_zakonczono=None,
65	):
UNCOV 66	task_sprobuj_wyslac_do_pbn.delay(elem.pk)	×

iplweb / bpp / ba61148d-0c1f-4500-9ad2-0c4ea5f9de71

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous