ref: небольшой рефакторинг
This commit is contained in:
@@ -18,7 +18,6 @@ async def get_views_history(
|
|||||||
from_date: datetime.datetime | None = None,
|
from_date: datetime.datetime | None = None,
|
||||||
to_date: datetime.datetime | None = None,
|
to_date: datetime.datetime | None = None,
|
||||||
) -> dto.GetViewsHistoryOutput:
|
) -> dto.GetViewsHistoryOutput:
|
||||||
"""Получить историю просмотров для закупа."""
|
|
||||||
input_data = dto.GetViewsHistoryInput(
|
input_data = dto.GetViewsHistoryInput(
|
||||||
placement_id=placement_id,
|
placement_id=placement_id,
|
||||||
user_id=current_user.user_id,
|
user_id=current_user.user_id,
|
||||||
@@ -34,7 +33,6 @@ async def fetch_views(
|
|||||||
placement_id: uuid.UUID,
|
placement_id: uuid.UUID,
|
||||||
current_user: Annotated[JWTPayload, Depends(dependencies.get_current_user)],
|
current_user: Annotated[JWTPayload, Depends(dependencies.get_current_user)],
|
||||||
) -> dto.FetchViewsManuallyOutput:
|
) -> dto.FetchViewsManuallyOutput:
|
||||||
"""Получить актуальные просмотры через Telegram API."""
|
|
||||||
input_data = dto.FetchViewsInputManually(
|
input_data = dto.FetchViewsInputManually(
|
||||||
placement_id=placement_id,
|
placement_id=placement_id,
|
||||||
user_id=current_user.user_id,
|
user_id=current_user.user_id,
|
||||||
@@ -49,7 +47,6 @@ async def update_views_manually(
|
|||||||
views_count: int,
|
views_count: int,
|
||||||
current_user: Annotated[JWTPayload, Depends(dependencies.get_current_user)],
|
current_user: Annotated[JWTPayload, Depends(dependencies.get_current_user)],
|
||||||
) -> dto.PlacementOutput:
|
) -> dto.PlacementOutput:
|
||||||
"""Обновить просмотры вручную."""
|
|
||||||
input_data = dto.UpdateViewsManuallyInput(
|
input_data = dto.UpdateViewsManuallyInput(
|
||||||
placement_id=placement_id,
|
placement_id=placement_id,
|
||||||
user_id=current_user.user_id,
|
user_id=current_user.user_id,
|
||||||
|
|||||||
@@ -12,6 +12,10 @@ from .analytics.get_creatives_analytics import get_creatives_analytics
|
|||||||
from .analytics.get_external_channels_analytics import get_external_channels_analytics
|
from .analytics.get_external_channels_analytics import get_external_channels_analytics
|
||||||
from .analytics.get_placements_analytics import get_placements_analytics
|
from .analytics.get_placements_analytics import get_placements_analytics
|
||||||
from .analytics.get_spending_analytics import get_spending_analytics
|
from .analytics.get_spending_analytics import get_spending_analytics
|
||||||
|
from .auth.get_me import get_me
|
||||||
|
from .auth.telegram_login import telegram_login
|
||||||
|
from .auth.telegram_start import telegram_start
|
||||||
|
from .auth.validate_login_token import validate_login_token
|
||||||
from .creative.create_creative import create_creative
|
from .creative.create_creative import create_creative
|
||||||
from .creative.delete_creative import delete_creative
|
from .creative.delete_creative import delete_creative
|
||||||
from .creative.get_creative import get_creative
|
from .creative.get_creative import get_creative
|
||||||
@@ -25,7 +29,6 @@ from .external_channel.delete_external_channel import delete_external_channel
|
|||||||
from .external_channel.get_external_channels import get_external_channels
|
from .external_channel.get_external_channels import get_external_channels
|
||||||
from .external_channel.update_external_channel import update_external_channel
|
from .external_channel.update_external_channel import update_external_channel
|
||||||
from .external_channel.update_external_channel_links import update_external_channel_links
|
from .external_channel.update_external_channel_links import update_external_channel_links
|
||||||
from .get_me import get_me
|
|
||||||
from .placement.create_placement import create_placement
|
from .placement.create_placement import create_placement
|
||||||
from .placement.delete_placement import delete_placement
|
from .placement.delete_placement import delete_placement
|
||||||
from .placement.get_placement import get_placement
|
from .placement.get_placement import get_placement
|
||||||
@@ -38,9 +41,6 @@ from .target_channel.disconnect_target_chan import disconnect_target_chan
|
|||||||
from .target_channel.disconnect_target_chan_by_tg_id import disconnect_target_chan_by_tg_id
|
from .target_channel.disconnect_target_chan_by_tg_id import disconnect_target_chan_by_tg_id
|
||||||
from .target_channel.get_user_target_chans import get_user_target_chans
|
from .target_channel.get_user_target_chans import get_user_target_chans
|
||||||
from .target_channel.update_target_chan_permissions import update_target_chan_permissions
|
from .target_channel.update_target_chan_permissions import update_target_chan_permissions
|
||||||
from .telegram_login import telegram_login
|
|
||||||
from .telegram_start import telegram_start
|
|
||||||
from .validate_login_token import validate_login_token
|
|
||||||
from .views.fetch_views_manually import fetch_views_manually
|
from .views.fetch_views_manually import fetch_views_manually
|
||||||
from .views.get_views_history import get_views_history
|
from .views.get_views_history import get_views_history
|
||||||
from .views.run_views_worker_cycle import run_views_worker_cycle
|
from .views.run_views_worker_cycle import run_views_worker_cycle
|
||||||
|
|||||||
@@ -4,7 +4,7 @@ import uuid
|
|||||||
from src import domain, dto
|
from src import domain, dto
|
||||||
|
|
||||||
if typing.TYPE_CHECKING:
|
if typing.TYPE_CHECKING:
|
||||||
from . import Usecase
|
from .. import Usecase
|
||||||
|
|
||||||
|
|
||||||
async def get_me(self: 'Usecase', user_id: uuid.UUID) -> dto.UserOutput:
|
async def get_me(self: 'Usecase', user_id: uuid.UUID) -> dto.UserOutput:
|
||||||
@@ -6,7 +6,7 @@ from src import domain, dto
|
|||||||
from src.config import settings
|
from src.config import settings
|
||||||
|
|
||||||
if typing.TYPE_CHECKING:
|
if typing.TYPE_CHECKING:
|
||||||
from . import Usecase
|
from .. import Usecase
|
||||||
|
|
||||||
|
|
||||||
async def telegram_login(self: 'Usecase', input: dto.TelegramLoginInput) -> None:
|
async def telegram_login(self: 'Usecase', input: dto.TelegramLoginInput) -> None:
|
||||||
@@ -2,7 +2,7 @@ import logging
|
|||||||
from typing import TYPE_CHECKING
|
from typing import TYPE_CHECKING
|
||||||
|
|
||||||
if TYPE_CHECKING:
|
if TYPE_CHECKING:
|
||||||
from . import Usecase
|
from .. import Usecase
|
||||||
|
|
||||||
log = logging.getLogger(__name__)
|
log = logging.getLogger(__name__)
|
||||||
|
|
||||||
@@ -4,7 +4,7 @@ import typing
|
|||||||
from src import domain, dto
|
from src import domain, dto
|
||||||
|
|
||||||
if typing.TYPE_CHECKING:
|
if typing.TYPE_CHECKING:
|
||||||
from . import Usecase
|
from .. import Usecase
|
||||||
|
|
||||||
|
|
||||||
async def validate_login_token(self: 'Usecase', input: dto.ValidateLoginTokenInput) -> dto.ValidateLoginTokenOutput:
|
async def validate_login_token(self: 'Usecase', input: dto.ValidateLoginTokenInput) -> dto.ValidateLoginTokenOutput:
|
||||||
Reference in New Issue
Block a user