?&jSdZddlmZddlZddlZddlmZmZmZm Z m Z ddl m Z ddl mZddlmZddlmZmZmZmZmZdd lmZmZdd lmZdd lmZdd lmZej@d Z!ejDjFZ$ejDjJZ&ejDjNZ(ddZ)ddZ* ddZ+ddZ,dd ddZ-dd ddZ.GddZ/y)u alloggiati/service.py ===================== Core orchestration layer for Alloggiati Web sync. Implements AlloggiatiService.sync() — the single entry point called by the API view for POST /api/alloggiati/sync. Pipeline (8 steps): 1. Validate input (structure exists, credential exists, date range valid) 2. Fetch bookings in range (confirmed / checked-in, deduplicated) 3. Transform guests via existing transformer 4. Authenticate with Alloggiati Web (hard stop on failure) 5. Send valid guest payloads via AlloggiatiClient 6. Parse and classify the server response 7. Persist AlloggiatiSyncLog (always — even on error) 8. Return structured response to the view Security rules: - Credentials are decrypted in memory only, never logged or re-persisted - No guest PII (names, document numbers) appears in logs or responses - AlloggiatiSyncLog stores only aggregated counts GDPR compliance: - Only metadata (counts, status, date range) is persisted ) annotationsN)AnyDictListOptionalTuple) transaction)Q)timezone)AlloggiatiAuthErrorAlloggiatiClientAlloggiatiClientErrorAlloggiatiNetworkErrorAlloggiatiResponseError)AlloggiatiCredentialAlloggiatiSyncLog)transform_booking_guests)Booking) Structure alloggiatic tjj|jS#tt f$rt |dwxYw)z Parse a YYYY-MM-DD string into a datetime.date. Raises: ValueError: With a human-readable message on failure. z+ must be a valid date in YYYY-MM-DD format.)datetimedate fromisoformatstrip ValueErrorAttributeError)value field_names /backend/alloggiati/service.py _parse_dater!BsLU}}**5;;=99  'UJ<'RSTTUs ,/A c^||kDr td||z jdkDr tdy)z Ensure date_from <= date_to and the range is not unreasonably large. Raises: ValueError: On invalid range. z'date_from cannot be later than date_to.inz'Sync date range cannot exceed 366 days.N)rdays) date_fromdate_tos r _validate_date_ranger&Os<7BCC)!!C'BCC(cttjj|d||gj dj dj jddS)ah Fetch bookings for the structure that overlap the given date range. Overlap condition: check_in_date < date_to AND check_out_date > date_from Filters: - is_checked_in=True (confirmed / checked-in guests only) - Deduplication by pk (distinct) Returns: List of Booking instances with guests and structure prefetched. T) structure is_checked_incheck_in_date__ranger)guests check_in_dateid)listrobjectsfilterselect_relatedprefetch_relateddistinctorder_by)r)r$r%s r _fetch_bookingsr6\s`" "+W!5   $  ( #  /4 (  r'c4|jtjk(r>|j}|j}|r|s t dt j||S|j}|j}|r|s t dt j||S)ug Instantiate an AlloggiatiClient from a credential record. Credentials are decrypted in memory here and passed directly to the client constructor — they are never stored in variables that outlive this function's scope beyond the client object itself. Raises: AlloggiatiAuthError: If required credential fields are missing. zADigital certificate or private key is missing for this structure.)certificate_pemprivate_key_pemzBAlloggiati Web username or password is missing for this structure.)usernamepassword) moderMODE_DIGITAL_CERTIFICATE certificate private_keyr r from_certificater:r; from_codes) credentialcertkeyr:r;s r _build_clientrEzs.GGG%%$$3%S  00   ""H""H 8! P    & &8 LLr')validation_errorsc tjj||||tj|||||xsg S)u Create and save an AlloggiatiSyncLog record. Always called — even on error — to maintain a complete audit trail. No PII (document numbers, credentials) is stored. validation_errors contains structured per-guest field errors only. ) r)r$r% started_at completed_atstatusmessage guests_sentguests_rejectedrF)rr0creater now r)r$r%rHrJrKrLrMrFs r _persist_sync_logrQsK&  $ $ + +\\^'+1r ,  r'c6|||||r t|nd|xsgdS)z)Build the standardised API response dict.NrJsentrejectedrK sync_log_idrF)strrSs r _build_responserXs.+6s;'D.4"  r'cpeZdZdZe ddZeddZed dZe d dZy) AlloggiatiServiceu Core orchestration service for Alloggiati Web sync. All public methods are static — no instance state is required. c  tj} tj|} t|d}t|d}t|| tj|}t|||} | s5t||||tddd} t tddd| jStj| \} } t!| } | Dcgc]G}|j#d|j#d |j#d d |j#d gd I}}| s>| }|d}t||||t|d| | } t td| || j|S t%|} |j)| }|j#dd}|j#dd}| |z}|j#dr|dk(r| dk(r t0}d|d}nL|j#dr|dkDrt}d|d|d| d|d }n t }|j#d xsd!}d"|}t||||||||| } t ||||| j|S#t$r'}t t ddt|dcYd}~Sd}~wwxYw#t$r'}t t ddt|dcYd}~Sd}~wwxYw#t$rQ}t||||t t|dd} t t ddt|| jcYd}~Sd}~wwxYwcc}w#t&$r:t||||t dd| | } t t d| d| j|cYSwxYw#t&$r:t||||t dd| | } t t d| d| j|cYSt*$rG}t||||t d|d| | } t t d| d|| j|cYd}~Sd}~wt,$rG}t||||t d|d| | } t t d| d|| j|cYd}~Sd}~wt.$rG}t||||t d|d| | } t t d| d|| j|cYd}~Sd}~wwxYw)#a Execute a full Alloggiati Web sync for a structure and date range. Args: structure_id: PK of the Structure (int or str). date_from: Start of sync window, "YYYY-MM-DD". date_to: End of sync window, "YYYY-MM-DD". Returns: { "status": "CONNECTED" | "PARTIAL" | "ERROR", "sent": int, "rejected": int, "message": str, "sync_log_id": str | None, "validation_errors": [ { "guest_id": int, "booking_id": int, "guest_name": str, "errors": [{"field": str, "message": str}, ...] }, ... ] } rN)rJrTrUrKrVr$r%)r)r$r%rHrJrKrLrMz8No checked-in bookings found in the selected date range.guest_id booking_id guest_namez Unknown Guesterrors)r\r]r^r_zF guest(s) failed validation and cannot be submitted to Alloggiati Web.rPrSz6Authentication failed: invalid or missing credentials.z"Authentication failed during send.zNetwork error: zServer response error: zAlloggiati client error: acceptedrUsuccesszSync completed successfully. z% guest(s) accepted by Alloggiati Web.zPartial sync: z guest(s) accepted, z rejected (z failed validation, z rejected by server). raw_messagezUnknown server error.zSync failed. Server message: )r rOrZ_get_structurerrX STATUS_ERRORrWr!r&_get_credentialrQr.r6STATUS_PARTIAL_transform_alllengetrEr send_guestsrrrSTATUS_CONNECTED) structure_idr$r%rHr)excd_fromd_torBlogbookingsvalid_payloadsinvalid_recordstransformer_rejectedrecserialisable_errorsnrKclient send_resultserver_acceptedserver_rejectedtotal_rejected final_statusraw_msgs r synczAlloggiatiService.syncs@\\^ )88FI  K8Fw 2D  . *::9EJ.#9fd;## %%R ! C#%RFF  +<*J*J8*T'"?3'5 ' "ggj1!ggl3!gglOD!ggh3   ' 5 $A#%% $# %% 4"5 C#%-FF"5   ":.F2Q  ,,^CW[\C\+L/"##HJ __Y 'NQ,>)L  11E!"#())="##8: (L!oom4O8OG5gY?G  !'*1   #1   ] "#C    "#C    ## %#C ! C##CFF   l5 R# ## %#P 4"5 C##-PFF"5   4# ## %#< 4"5 C##-<FF"5  & ## %#)#/ 4"5 C##-)#/FF"5  ' ## %#1#7 4"5 C##-1#7FF"5  % ## %#3C59 4"5 C##-3C59FF"5   sI $I<J/A L  L,M I9I4.I94I9< J,J'!J,'J,/ L 8AL>L L AMMARR!rs6#33!!F;#'   < (%++55"))11 ''--  U D <MV9=  "   6P9=       60K&K&r'