junte/Model
1
0
Fork 0
mirror of https://github.com/Hestia-Homes/Model.git synced 2026-06-08 11:17:27 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

ensure user data is stored as ID rather than name

Browse source
This commit is contained in:
Khalim Conn-Kowlessar 2026-04-30 19:38:22 +00:00
parent 9e3f5a2205
commit a97e4ce524
1 changed files with 9 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
etl/hubspot/hubspotDataTodB.py
View file

@ -95,15 +95,8 @@ class HubspotDataToDb:
with db_read_session() as session:
deal_id = deal_data.get("hs_object_id")
resolved_deal_data = {
**deal_data,
"coordinator_user": self._resolve_owner_name(
deal_data.get("coordinator_user"), hubspot_client, session
),
"designer_user": self._resolve_owner_name(
deal_data.get("designer_user"), hubspot_client, session
),
}
self._sync_owner_to_db(deal_data.get("coordinator_user"), hubspot_client, session)
self._sync_owner_to_db(deal_data.get("designer_user"), hubspot_client, session)
statement = select(HubspotDealData).where(
HubspotDealData.deal_id == deal_id
@ -114,7 +107,7 @@ class HubspotDataToDb:
self._handle_existing_photo_upload(existing, hubspot_client)
print(f"🔄 Updating existing deal (deal_id={deal_id})")
self._update_existing_deal(existing, resolved_deal_data, listing, company)
self._update_existing_deal(existing, deal_data, listing, company)
session.add(existing)
session.commit()
@ -124,7 +117,7 @@ class HubspotDataToDb:
else:
print(f"🆕 Inserting new deal (deal_id={deal_id})")
new_record: HubspotDealData = self._build_new_deal(
deal_id, resolved_deal_data, listing, company
deal_id, deal_data, listing, company
)
# Handle upload at insert time
@ -135,24 +128,21 @@ class HubspotDataToDb:
session.refresh(new_record)
return new_record
def _resolve_owner_name(
def _sync_owner_to_db(
self,
owner_id: Optional[str],
hubspot_client: HubspotClient,
session: Session,
) -> Optional[str]:
) -> None:
if not owner_id:
return None
return
existing: Optional[HubspotUser] = session.get(HubspotUser, owner_id)
owner_info = hubspot_client.get_owner_info(owner_id)
if owner_info is None:
if existing:
return f"{existing.first_name or ''} {existing.last_name or ''}".strip() or None
return None
return
now = datetime.now(timezone.utc)
existing: Optional[HubspotUser] = session.get(HubspotUser, owner_id)
if existing:
existing.first_name = owner_info["first_name"]
existing.last_name = owner_info["last_name"]
@ -170,10 +160,6 @@ class HubspotDataToDb:
)
)
first = owner_info["first_name"] or ""
last = owner_info["last_name"] or ""
return f"{first} {last}".strip() or None
def _update_existing_deal(
self,
existing: HubspotDealData,