apunkt/SurfSense
1
0
Fork 0
mirror of https://github.com/MODSetter/SurfSense.git synced 2026-06-02 19:55:18 +02:00
Code Issues Projects Releases Packages Wiki Activity

fix(backend): Use calculate_date_range for Gmail indexer

Browse source 
Gmail indexer was using a hardcoded 30-day default instead of respecting
last_indexed_at like other connectors. Now uses calculate_date_range()
for consistent behavior (last_indexed_at → now, or 365 days for first run).
This commit is contained in:
CREDO23 2026-01-28 15:20:07 +02:00
parent a9d393327d
commit 4f7ed8439f
1 changed files with 15 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

17
surfsense_backend/app/tasks/connector_indexers/google_gmail_indexer.py
View file

@ -24,6 +24,7 @@ from app.utils.document_converters import (
) )
from .base import ( from .base import (
calculate_date_range,
check_document_by_unique_identifier, check_document_by_unique_identifier,
check_duplicate_document_by_hash, check_duplicate_document_by_hash,
get_connector_by_id, get_connector_by_id,
@ -164,10 +165,22 @@ async def index_google_gmail_messages(
credentials, session, user_id, connector_id credentials, session, user_id, connector_id
) )
# Calculate date range using last_indexed_at if dates not provided
# This ensures Gmail uses the same date logic as other connectors
# (uses last_indexed_at → now, or 365 days back for first-time indexing)
calculated_start_date, calculated_end_date = calculate_date_range(
connector, start_date, end_date, default_days_back=365
)
# Fetch recent Google gmail messages # Fetch recent Google gmail messages
logger.info(f"Fetching recent emails for connector {connector_id}") logger.info(
f"Fetching emails for connector {connector_id} "
f"from {calculated_start_date} to {calculated_end_date}"
)
messages, error = await gmail_connector.get_recent_messages( messages, error = await gmail_connector.get_recent_messages(
max_results=max_messages, start_date=start_date, end_date=end_date max_results=max_messages,
start_date=calculated_start_date,
end_date=calculated_end_date,
) )
if error: if error: