Compare commits

..

1 Commits

Author SHA1 Message Date
Anibal Angulo
014ceb9da6 formatting
All checks were successful
CI / ci (pull_request) Successful in 19s
2026-03-10 23:49:24 +00:00
2 changed files with 12 additions and 47 deletions

View File

@@ -78,9 +78,7 @@ class NotificationDocument(BaseModel):
class NotificationBackend(Protocol): class NotificationBackend(Protocol):
"""Backend-agnostic interface for notification storage.""" """Backend-agnostic interface for notification storage."""
async def get_recent_notifications( async def get_recent_notifications(self, phone_number: str) -> list[Notification]:
self, phone_number: str
) -> list[Notification]:
"""Return recent notifications for *phone_number*.""" """Return recent notifications for *phone_number*."""
... ...
@@ -113,9 +111,7 @@ class FirestoreNotificationBackend:
self._max_to_notify = max_to_notify self._max_to_notify = max_to_notify
self._window_hours = window_hours self._window_hours = window_hours
async def get_recent_notifications( async def get_recent_notifications(self, phone_number: str) -> list[Notification]:
self, phone_number: str
) -> list[Notification]:
"""Get recent notifications for a user. """Get recent notifications for a user.
Retrieves notifications created within the configured time window, Retrieves notifications created within the configured time window,
@@ -148,9 +144,7 @@ class FirestoreNotificationBackend:
cutoff = time.time() - (self._window_hours * 3600) cutoff = time.time() - (self._window_hours * 3600)
parsed = [ parsed = [
n n for n in document.notificaciones if n.timestamp_creacion >= cutoff
for n in document.notificaciones
if n.timestamp_creacion >= cutoff
] ]
if not parsed: if not parsed:
@@ -212,9 +206,7 @@ class RedisNotificationBackend:
self._max_to_notify = max_to_notify self._max_to_notify = max_to_notify
self._window_hours = window_hours self._window_hours = window_hours
async def get_recent_notifications( async def get_recent_notifications(self, phone_number: str) -> list[Notification]:
self, phone_number: str
) -> list[Notification]:
"""Get recent notifications for a user from Redis. """Get recent notifications for a user from Redis.
Reads from the ``notification:{phone}`` key, parses the JSON Reads from the ``notification:{phone}`` key, parses the JSON
@@ -246,9 +238,7 @@ class RedisNotificationBackend:
cutoff = time.time() - (self._window_hours * 3600) cutoff = time.time() - (self._window_hours * 3600)
parsed = [ parsed = [
n n for n in document.notificaciones if n.timestamp_creacion >= cutoff
for n in document.notificaciones
if n.timestamp_creacion >= cutoff
] ]
if not parsed: if not parsed:

View File

@@ -6,7 +6,6 @@ import asyncio
import logging import logging
import time import time
import uuid import uuid
from datetime import UTC, datetime
from typing import TYPE_CHECKING, Any, override from typing import TYPE_CHECKING, Any, override
from google.adk.errors.already_exists_error import AlreadyExistsError from google.adk.errors.already_exists_error import AlreadyExistsError
@@ -103,24 +102,6 @@ class FirestoreSessionService(BaseSessionService):
def _events_col(self, app_name: str, user_id: str, session_id: str) -> Any: def _events_col(self, app_name: str, user_id: str, session_id: str) -> Any:
return self._session_ref(app_name, user_id, session_id).collection("events") return self._session_ref(app_name, user_id, session_id).collection("events")
@staticmethod
def _timestamp_to_float(value: Any, default: float = 0.0) -> float:
if value is None:
return default
if isinstance(value, (int, float)):
return float(value)
if hasattr(value, "timestamp"):
try:
return float(value.timestamp())
except (
TypeError,
ValueError,
OSError,
OverflowError,
) as exc: # pragma: no cover
logger.debug("Failed to convert timestamp %r: %s", value, exc)
return default
# ------------------------------------------------------------------ # ------------------------------------------------------------------
# State helpers # State helpers
# ------------------------------------------------------------------ # ------------------------------------------------------------------
@@ -190,7 +171,7 @@ class FirestoreSessionService(BaseSessionService):
) )
) )
now = datetime.now(UTC) now = time.time()
write_coros.append( write_coros.append(
self._session_ref(app_name, user_id, session_id).set( self._session_ref(app_name, user_id, session_id).set(
{ {
@@ -215,7 +196,7 @@ class FirestoreSessionService(BaseSessionService):
user_id=user_id, user_id=user_id,
id=session_id, id=session_id,
state=merged, state=merged,
last_update_time=now.timestamp(), last_update_time=now,
) )
@override @override
@@ -302,9 +283,7 @@ class FirestoreSessionService(BaseSessionService):
id=session_id, id=session_id,
state=merged, state=merged,
events=events, events=events,
last_update_time=self._timestamp_to_float( last_update_time=session_data.get("last_update_time", 0.0),
session_data.get("last_update_time"), 0.0
),
) )
@override @override
@@ -347,9 +326,7 @@ class FirestoreSessionService(BaseSessionService):
id=data["session_id"], id=data["session_id"],
state=merged, state=merged,
events=[], events=[],
last_update_time=self._timestamp_to_float( last_update_time=data.get("last_update_time", 0.0),
data.get("last_update_time"), 0.0
),
) )
) )
@@ -389,8 +366,6 @@ class FirestoreSessionService(BaseSessionService):
# Persist state deltas # Persist state deltas
session_ref = self._session_ref(app_name, user_id, session_id) session_ref = self._session_ref(app_name, user_id, session_id)
last_update_dt = datetime.fromtimestamp(event.timestamp, UTC)
if event.actions and event.actions.state_delta: if event.actions and event.actions.state_delta:
state_deltas = _session_util.extract_state_delta(event.actions.state_delta) state_deltas = _session_util.extract_state_delta(event.actions.state_delta)
@@ -411,16 +386,16 @@ class FirestoreSessionService(BaseSessionService):
FieldPath("state", k).to_api_repr(): v FieldPath("state", k).to_api_repr(): v
for k, v in state_deltas["session"].items() for k, v in state_deltas["session"].items()
} }
field_updates["last_update_time"] = last_update_dt field_updates["last_update_time"] = event.timestamp
write_coros.append(session_ref.update(field_updates)) write_coros.append(session_ref.update(field_updates))
else: else:
write_coros.append( write_coros.append(
session_ref.update({"last_update_time": last_update_dt}) session_ref.update({"last_update_time": event.timestamp})
) )
await asyncio.gather(*write_coros) await asyncio.gather(*write_coros)
else: else:
await session_ref.update({"last_update_time": last_update_dt}) await session_ref.update({"last_update_time": event.timestamp})
# Log token usage # Log token usage
if event.usage_metadata: if event.usage_metadata: