address list

This commit is contained in:
Jun-te Kim 2026-05-22 08:22:13 +00:00
parent 84098e28ff
commit 91bb4b6571
8 changed files with 19 additions and 11 deletions

View file

@ -4,7 +4,7 @@ from orchestration.sal_orchestrator import (
SALOrchestrator,
)
from infrastructure.csv_s3_client import CsvS3Client
from repositories.raw_address.raw_address_csv_s3_repository import (
from repositories.raw_address.raw_address_list_csv_s3_repository import (
RawAddressListCsvS3Repository,
)
from domain.addresses.raw_address import AddressList

View file

@ -12,8 +12,8 @@ from infrastructure.address2uprn_queue_client import Address2UprnQueueClient
from infrastructure.csv_s3_client import CsvS3Client
from orchestration.postcode_splitter_orchestrator import PostcodeSplitterOrchestrator
from orchestration.task_orchestrator import TaskOrchestrator
from repositories.raw_address.raw_address_csv_s3_repository import (
RawAddressCsvS3Repository,
from repositories.raw_address.raw_address_list_csv_s3_repository import (
RawAddressListCsvS3Repository,
)
from utilities.aws_lambda.subtask_handler import subtask_handler
@ -36,12 +36,12 @@ def handler(
boto_sqs: Any = boto3_client("sqs")
csv_client = CsvS3Client(boto_s3, bucket)
raw_address_repo = RawAddressCsvS3Repository(csv_client, bucket)
user_address_repo = RawAddressListCsvS3Repository(csv_client, bucket)
queue_client = Address2UprnQueueClient(boto_sqs, queue_url)
splitter = PostcodeSplitterOrchestrator(
task_orchestrator=task_orchestrator,
raw_address_repo=raw_address_repo,
user_address_repo=user_address_repo,
queue_client=queue_client,
)

View file

@ -5,7 +5,9 @@ from uuid import UUID
from infrastructure.address2uprn_queue_client import Address2UprnQueueClient
from orchestration.task_orchestrator import TaskOrchestrator
from domain.addresses.postcode_batching import iter_postcode_grouped_batches
from repositories.raw_address.raw_address_repository import RawAddressListRepository
from repositories.raw_address.raw_address_list_repository import (
RawAddressListRepository,
)
class PostcodeSplitterOrchestrator:

View file

@ -1,4 +1,6 @@
from repositories.raw_address.raw_address_repository import RawAddressListRepository
from repositories.raw_address.raw_address_list_repository import (
RawAddressListRepository,
)
from domain.addresses.raw_address import AddressList

View file

@ -7,7 +7,9 @@ from typing import Optional
from domain.addresses.raw_address import AddressList, RawAddress
from domain.postcode import Postcode
from infrastructure.csv_s3_client import CsvS3Client
from repositories.raw_address.raw_address_repository import RawAddressListRepository
from repositories.raw_address.raw_address_list_repository import (
RawAddressListRepository,
)
_ADDRESS_COLUMNS: tuple[str, str, str] = ("Address 1", "Address 2", "Address 3")
_POSTCODE_COLUMN: str = "postcode"

View file

@ -5,7 +5,9 @@ from domain.postcode import Postcode
from orchestration.sal_orchestrator import (
SALOrchestrator,
)
from repositories.raw_address.raw_address_repository import RawAddressListRepository
from repositories.raw_address.raw_address_list_repository import (
RawAddressListRepository,
)
class _StubRawAddressRepository(RawAddressListRepository):

View file

@ -18,7 +18,7 @@ from orchestration.postcode_splitter_orchestrator import PostcodeSplitterOrchest
from orchestration.task_orchestrator import TaskOrchestrator
from repositories.tasks.subtask_postgres_repository import SubTaskPostgresRepository
from repositories.tasks.task_postgres_repository import TaskPostgresRepository
from repositories.raw_address.raw_address_csv_s3_repository import (
from repositories.raw_address.raw_address_list_csv_s3_repository import (
RawAddressListCsvS3Repository,
)

View file

@ -6,7 +6,7 @@ from moto import mock_aws
from domain.addresses.raw_address import AddressList, RawAddress
from domain.postcode import Postcode
from infrastructure.csv_s3_client import CsvS3Client
from repositories.raw_address.raw_address_csv_s3_repository import (
from repositories.raw_address.raw_address_list_csv_s3_repository import (
RawAddressListCsvS3Repository,
)
from tests.infrastructure import make_boto_client