2427 internal users can transfer a facility or operation

bc_obps/common/fixtures/dashboard/bciers/internal.json

@@ -38,7 +38,6 @@
           },
           {
             "title": "Transfers",
-            "href": "/registration",
             "icon": "Layers",
             "content": "Transfer operations and facilities between Operators and view transfers.",
             "links": [
@@ -48,13 +47,8 @@
               },
               {
                 "title": "Transfer an operation or facility",
-                "href": "/registration/transfer",
-                "conditions": [
-                  {
-                    "allowedRoles": ["cas_analyst"],
-                    "value": true
-                  }
-                ]
+                "href": "/registration/transfers/transfer-entity",
+                "allowedRoles": ["cas_analyst"]
               }
             ]
           },

bc_obps/common/migrations/0010_dashboarddata.py

@@ -12,7 +12,6 @@ def load_dashboard_fixtures(apps, schema_editor):
         # Below file does not exist in the repository but I'm keeping it here for reference
         # 'common/fixtures/dashboard/registration/operation/external.json',
         'common/fixtures/dashboard/registration/external.json',
-        'common/fixtures/dashboard/registration/internal.json',
         'common/fixtures/dashboard/reporting/external.json',
         'common/fixtures/dashboard/reporting/internal.json',
     ]

bc_obps/common/migrations/0012_update_dashboard_data.py

@@ -12,7 +12,6 @@ def load_dashboard_fixtures(apps, schema_editor):
         'common/fixtures/dashboard/administration/external.json',
         'common/fixtures/dashboard/administration/internal.json',
         'common/fixtures/dashboard/registration/external.json',
-        'common/fixtures/dashboard/registration/internal.json',
         'common/fixtures/dashboard/reporting/external.json',
         'common/fixtures/dashboard/reporting/internal.json',
         'common/fixtures/dashboard/coam/external.json',

bc_obps/common/migrations/0016_update_dashboard_data.py

@@ -12,7 +12,6 @@ def load_dashboard_fixtures(apps, schema_editor):
         'common/fixtures/dashboard/administration/external.json',
         'common/fixtures/dashboard/administration/internal.json',
         'common/fixtures/dashboard/registration/external.json',
-        'common/fixtures/dashboard/registration/internal.json',
         'common/fixtures/dashboard/reporting/external.json',
         'common/fixtures/dashboard/reporting/internal.json',
         'common/fixtures/dashboard/coam/external.json',

bc_obps/common/migrations/0017_update_dashboard_data.py

@@ -12,7 +12,6 @@ def load_dashboard_fixtures(apps, schema_editor):
         'common/fixtures/dashboard/administration/external.json',
         'common/fixtures/dashboard/administration/internal.json',
         'common/fixtures/dashboard/registration/external.json',
-        'common/fixtures/dashboard/registration/internal.json',
         'common/fixtures/dashboard/reporting/external.json',
         'common/fixtures/dashboard/reporting/internal.json',
         'common/fixtures/dashboard/coam/external.json',

bc_obps/common/migrations/0020_update_dashboard_data.py

@@ -12,7 +12,6 @@ def load_dashboard_fixtures(apps, schema_editor):
         'common/fixtures/dashboard/administration/external.json',
         'common/fixtures/dashboard/administration/internal.json',
         'common/fixtures/dashboard/registration/external.json',
-        'common/fixtures/dashboard/registration/internal.json',
         'common/fixtures/dashboard/reporting/external.json',
         'common/fixtures/dashboard/reporting/internal.json',
         'common/fixtures/dashboard/coam/external.json',

bc_obps/common/migrations/0022_update_dashboard_data.py

@@ -13,7 +13,6 @@ def load_dashboard_fixtures(apps, schema_editor):
         'common/fixtures/dashboard/administration/internal.json',
         'common/fixtures/dashboard/operators/internal.json',
         'common/fixtures/dashboard/registration/external.json',
-        'common/fixtures/dashboard/registration/internal.json',
         'common/fixtures/dashboard/reporting/external.json',
         'common/fixtures/dashboard/reporting/internal.json',
         'common/fixtures/dashboard/coam/external.json',

bc_obps/common/permissions.py

@@ -124,6 +124,11 @@ def get_permission_configs(permission: str) -> Optional[Union[Dict[str, List[str
             'authorized_app_roles': ["cas_admin", "cas_analyst", "industry_user"],
             'authorized_user_operator_roles': ["admin"],
         },
+        "cas_analyst": {
+            'authorized_app_roles': list(
+                AppRole.objects.filter(role_name="cas_analyst").values_list("role_name", flat=True)
+            ),
+        },
     }
     cache.set(PERMISSION_CONFIGS_CACHE_KEY, permission_configs, timeout=3600)  # 1 hour
     return permission_configs.get(permission)
@@ -155,6 +160,7 @@ def authorize(
         "authorized_irc_user_and_industry_admin_user",
         "v1_authorized_irc_user_write",
         "v1_authorized_irc_user_and_industry_admin_user_write",
+        "cas_analyst",
     ]
 ) -> Callable[[HttpRequest], bool]:
     """

bc_obps/common/tests/endpoints/auth/test_endpoint_permissions.py

@@ -344,6 +344,9 @@ class TestEndpointPermissions(TestCase):
                 "kwargs": {"user_operator_id": mock_uuid},
             },
         ],
+        "cas_analyst": [
+            {"method": "post", "endpoint_name": "create_transfer_event"},
+        ],
     }
 
     @classmethod

bc_obps/common/utils.py

@@ -13,7 +13,6 @@ def reset_dashboard_data() -> None:
         'common/fixtures/dashboard/administration/internal.json',
         'common/fixtures/dashboard/operators/internal.json',
         'common/fixtures/dashboard/registration/external.json',
-        'common/fixtures/dashboard/registration/internal.json',
         'common/fixtures/dashboard/reporting/external.json',
         'common/fixtures/dashboard/reporting/internal.json',
         'common/fixtures/dashboard/coam/external.json',

bc_obps/registration/admin.py

@@ -34,7 +34,6 @@
 admin.site.register(BcObpsRegulatedOperation)
 admin.site.register(ClosureEvent)
 admin.site.register(TemporaryShutdownEvent)
-admin.site.register(TransferEvent)
 admin.site.register(RestartEvent)
 
 
@@ -87,6 +86,7 @@ class FacilityDesignatedOperationTimelineAdmin(admin.ModelAdmin):
 class OperationDesignatedOperatorTimelineAdmin(admin.ModelAdmin):
     list_display = (
         'id',
+        'status',
         'operation',
         'operator',
         'start_date',
@@ -125,3 +125,37 @@ def user_full_name(obj: UserOperator) -> str:
     @staticmethod
     def operator_legal_name(obj: UserOperator) -> str:
         return obj.operator.legal_name
+
+
+@admin.register(TransferEvent)
+class TransferEventAdmin(admin.ModelAdmin):
+    list_display = (
+        'id',
+        'status',
+        'from_operator_name',
+        'to_operation_name',
+        'operation_name',
+        'from_operation_name',
+        'to_operator_name',
+        'effective_date',
+    )
+
+    @staticmethod
+    def to_operator_name(obj: TransferEvent) -> str:
+        return obj.to_operator.legal_name
+
+    @staticmethod
+    def from_operator_name(obj: TransferEvent) -> str:
+        return obj.from_operator.legal_name
+
+    @staticmethod
+    def operation_name(obj: TransferEvent) -> str:
+        return obj.operation.name if obj.operation else 'N/A'
+
+    @staticmethod
+    def from_operation_name(obj: TransferEvent) -> str:
+        return obj.from_operation.name if obj.from_operation else 'N/A'
+
+    @staticmethod
+    def to_operation_name(obj: TransferEvent) -> str:
+        return obj.to_operation.name if obj.to_operation else 'N/A'

bc_obps/registration/api/v2/__init__.py

@@ -21,14 +21,13 @@
     facilities,
 )
 from ._operations import current as operations_current
-from ._operations._operation_id import boro_id, bcghg_id as operation_bcghg_id
+from ._operations._operation_id import boro_id, bcghg_id as operation_bcghg_id, operation_representatives
 from ._operations._operation_id.facilities import list_facilities_by_operation_id
 from ._facilities._facility_id import bcghg_id as facility_bcghg_id
 from ._facilities import facility_id
-from ._operators import search
+from ._operators import search, operator_id
 from .transfer_events import list_transfer_events
 from ._operators._operator_id import has_admin, request_access, request_admin_access, access_declined, confirm
-from ._operators import operator_id
 from ._user_operators._current import (
     operator,
     access_requests,
@@ -38,9 +37,8 @@
     operator_users,
 )
 from ._user_operators._user_operator_id import update_status
-
 from .user import user_profile, user_app_role
 from ._user_operators import user_operator_id, pending, current
 from ._contacts import contact_id
 from ._users import user_id
-from ._operations._operation_id import operation_representatives
+from . import transfer_events

bc_obps/registration/api/v2/_operations/_operation_id/facilities.py

@@ -1,5 +1,6 @@
 from uuid import UUID
 from registration.models.facility_designated_operation_timeline import FacilityDesignatedOperationTimeline
+from registration.utils import CustomPagination
 from service.facility_designated_operation_timeline_service import FacilityDesignatedOperationTimelineService
 from registration.schema.v1.facility_designated_operation_timeline import (
     FacilityDesignatedOperationTimelineFilterSchema,
@@ -13,7 +14,7 @@
 from common.api.utils import get_current_user_guid
 from registration.constants import FACILITY_TAGS
 from registration.decorators import handle_http_errors
-from ninja.pagination import paginate, PageNumberPagination
+from ninja.pagination import paginate
 from registration.schema.generic import Message
 from service.error_service.custom_codes_4xx import custom_codes_4xx
 from ninja import Query
@@ -28,13 +29,14 @@
     auth=authorize("approved_authorized_roles"),
 )
 @handle_http_errors()
-@paginate(PageNumberPagination)
+@paginate(CustomPagination)
 def list_facilities_by_operation_id(
     request: HttpRequest,
     operation_id: UUID,
     filters: FacilityDesignatedOperationTimelineFilterSchema = Query(...),
     sort_field: Optional[str] = "facility__created_at",
     sort_order: Optional[Literal["desc", "asc"]] = "desc",
+    paginate_result: bool = Query(True, description="Whether to paginate the results"),
 ) -> QuerySet[FacilityDesignatedOperationTimeline]:
     # NOTE: PageNumberPagination raises an error if we pass the response as a tuple (like 200, ...)
     return FacilityDesignatedOperationTimelineService.list_timeline_by_operation_id(

bc_obps/registration/api/v2/transfer_events.py

@@ -1,6 +1,6 @@
-from typing import List, Literal, Optional
+from typing import List, Literal, Optional, Tuple
 from registration.models.event.transfer_event import TransferEvent
-from registration.schema.v1.transfer_event import TransferEventFilterSchema, TransferEventListOut
+from registration.schema.v2.transfer_event import TransferEventFilterSchema, TransferEventListOut
 from service.transfer_event_service import TransferEventService
 from common.permissions import authorize
 from django.http import HttpRequest
@@ -13,6 +13,8 @@
 from ninja import Query
 from registration.schema.generic import Message
 from django.db.models import QuerySet
+from common.api.utils import get_current_user_guid
+from registration.schema.v2.transfer_event import TransferEventCreateIn, TransferEventOut
 
 
 @router.get(
@@ -34,3 +36,18 @@ def list_transfer_events(
 ) -> QuerySet[TransferEvent]:
     # NOTE: PageNumberPagination raises an error if we pass the response as a tuple (like 200, ...)
     return TransferEventService.list_transfer_events(sort_field, sort_order, filters)
+
+
+@router.post(
+    "/transfer-events",
+    response={201: TransferEventOut, custom_codes_4xx: Message},
+    tags=TRANSFER_EVENT_TAGS,
+    description="""Creates a new transfer event.""",
+    auth=authorize("cas_analyst"),
+)
+@handle_http_errors()
+def create_transfer_event(
+    request: HttpRequest,
+    payload: TransferEventCreateIn,
+) -> Tuple[Literal[201], TransferEvent]:
+    return 201, TransferEventService.create_transfer_event(get_current_user_guid(request), payload)

bc_obps/registration/constants.py

@@ -31,3 +31,4 @@
 CONTACT_TAGS = ["Contact V1"]
 TRANSFER_EVENT_TAGS = ["Transfer Event V1"]
 V2 = ["V2"]
+OPERATOR_TAGS_V2 = ["Operator V2"]

bc_obps/registration/fixtures/mock/operation.json

@@ -125,6 +125,7 @@
   },
   {
     "model": "registration.operation",
+    "pk": "436dd99a-cb41-4494-91c9-98ab149b557d",
     "fields": {
       "operator": "685d581b-5698-411f-ae00-de1d97334a71",
       "documents": [],
@@ -144,6 +145,7 @@
   },
   {
     "model": "registration.operation",
+    "pk": "a47b5fb6-1e10-401a-b70e-574bd925db99",
     "fields": {
       "operator": "685d581b-5698-411f-ae00-de1d97334a71",
       "documents": [],
@@ -163,6 +165,7 @@
   },
   {
     "model": "registration.operation",
+    "pk": "21e70498-c4b0-4525-8443-86faa96206e3",
     "fields": {
       "operator": "685d581b-5698-411f-ae00-de1d97334a71",
       "documents": [],
@@ -182,6 +185,7 @@
   },
   {
     "model": "registration.operation",
+    "pk": "17550cd8-3e73-4e52-aa91-ab90cb3b62b0",
     "fields": {
       "operator": "685d581b-5698-411f-ae00-de1d97334a71",
       "documents": [],
@@ -201,6 +205,7 @@
   },
   {
     "model": "registration.operation",
+    "pk": "7d3fc7d1-0504-4ee4-a9c5-447f4b324b57",
     "fields": {
       "operator": "685d581b-5698-411f-ae00-de1d97334a71",
       "documents": [],
@@ -220,6 +225,7 @@
   },
   {
     "model": "registration.operation",
+    "pk": "acf5811e-d521-43f7-a5c7-a6d6dd47bb31",
     "fields": {
       "operator": "685d581b-5698-411f-ae00-de1d97334a71",
       "documents": [],
@@ -239,6 +245,7 @@
   },
   {
     "model": "registration.operation",
+    "pk": "8563da83-0762-4d29-9b22-da5b52ef0f24",
     "fields": {
       "operator": "685d581b-5698-411f-ae00-de1d97334a71",
       "documents": [],