File size: 5,498 Bytes
57167c8 0a7af19 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 | GCP_SERVICE_ACCOUNT_JSON = "ewogICJ0eXBlIjogInNlcnZpY2VfYWNjb3VudCIsCiAgInByb2plY3RfaWQiOiAiaG9uZXlwb3QtNDkxOTE4IiwKICAicHJpdmF0ZV9rZXlfaWQiOiAiZTVjN2ZhY2U0MTgwMjFlODAwMWQ0ZmUwMTE2NTdlYTQyYTI1ZGEzNyIsCiAgInByaXZhdGVfa2V5IjogIi0tLS0tQkVHSU4gUFJJVkFURSBLRVktLS0tLVxuTUlJRXZBSUJBREFOQmdrcWhraUc5dzBCQVFFRkFBU0NCS1l3Z2dTaUFnRUFBb0lCQVFDeGY4aThyMERMbm5qbVxuK2lNSTRQQjB2K2I5Z3BUQjJ6Z1BPUUtBRjZBMjZLWGxvMkNQazFxVHJPWnIvV0tpSCtocW5Ud2xhRFdiYVU4T1xuSS9LK3JVbDJNTHFYbWVhZkNxNzBMbndpUFJ0YXJuczJkdjB0VCs1b1dVb0ZZckJyb3h2QWcwQWtINXI1VUpsRVxuUWgyUitwWGg3MkkrSDZ1MmxrQ2E1NXlHS2hkbU9LM05TNjBtcVdFQURXd05xRW44NDBhVmVyUE9VVENvaTE2cVxuWGZ1c0htQ284blMxdVpqZ0R3TExVaFk5b2d5Zm8xR0pKSzZKZGpXaFRaVjhDWkxxejhIOTJ0aHJrR0N4OVA2SlxuU2tDQjBuVVYwUU4rQzBpM29VN2F3anJ6eWRub3g3dndoc3FWRHZEVWxRM0VKZXoxV2pvV0dVY0VQOU5Md1dJTFxubmllc2ZxelJBZ01CQUFFQ2dnRUFESm9pK1dxRDhqRDlLb0VGN2NKeXNBZFQ4aG5NVC9zdGZyOHdjMEc2S1V2WlxuUTNXWERIcU15c0ZTMXNYMXM4Y0tMRStmanBSWWdnRTNFS3p5dGlEOWZ6dTBjOEVFZzdReGVicTNLNE1sSndvT1xuUzI2bFNRdE14UEhaOUludU5xWXMrVDBZVjdnNnU0ckNadnMrdURlUFhxd3RVSFhWTGpCNnc4Uy84ektYMkxUOVxuRGt0YTBnM0dTdkVlWnJqNjBxZ2E2Tm16Y3BtdDVtdWV3YXJmbmUzMWVsUVh6cVR6bHdaUzNqeDVuMlNNdUZBeFxuY3JQRlA3WmltbFVDNjA2NmZMVjVYU3ROOFRCSFF1cjZmRTIxT1BMZ1huS2JDaFFJVkt6Zm1SQjhaUjVSc2ROSFxuYnBkZ3BQQkNjditEWHpGN09Jak43S3ZjZnpORERuS3JnOWFXajAvK3NRS0JnUURybGkrVWxZano4dXp3ZThxTVxuWlB2SUI0N2xRc05rT3hJbGhKZC9FOTJiWDNjVHVZcUYxSWExaldwMHBQdS85S1VjQ01Oa2ptODl2TzVraVgvWVxueWErYWc5SjZuVGE3dDhldElyYlNNYk1KeGdXVS9yLzY3SVRyNngrN2RYSHg3OVUxb2MxR21wcUFKem42Y3pvUFxuaWx2K3hqYlg2S2pkQ3JMaWQ3YVQxYkUyblFLQmdRREE0UmYybVNCb0s1V1pBMmNsYnM5QlVrMkF1NVB1M1JPMFxuYlh3SUJaai9YdHBISkJYYzlxRlhSNE9kcEduK1JrSmp4eEVGSUV0eTM1dEI0Q0JTeC9Gd2o0SVBpdjdsQWZuMlxudHc2V2ZzWFUrK1NvZ1A3cWdHS0ZEUUtJM2srYjBiaUZieklvV3dSbTBKSE1XOUt5NDFFUVh5TG4rc0hPbWhkYlxudTU5Qzk3cGV4UUtCZ0FjdmtvMzJyYkc3TkN6MXFhejBtNVZ6WFpGeW91RVl5Q25xekhBczIvS1VTOTZISjBtRFxudlFRbXB4dWR1S3dYT3o0S3FtTVQwU0xSODNlUGxoMjNzU3FHWU5JcW4zUEVYRXZVcGp6dEZTZjBLVkZ0SDgvNFxuak9saFI1dUJMcE9SbkRCQm1qQlFJT3hOeGYvMHFjMjFpNjdPdnZlQStqMmJ5TzhOZGIwMnBHd2xBb0dBVjFDT1xuN0k5OVlDcjYyZjMwWDdtK0VUQVU3Y1g4dmhGT3Jrc3g3dCs1MTBFMVJ5ZEt6bkRIc1I4cXNkNlFMUS9aVmhuelxuMW9JOEpaQ2NWRUlGMy9PcmxPMGlUNjc0bk9zOElUZlZYc09kQTBIVXpZTTM0eWlqY04vbTJkYnA2dndSc0RZYVxuV3JKNVY2SHJucnVpc21DOWZjL1RtWGltNjhSTjlyVUU3K2Y5Y3BFQ2dZQURYMDJlSVltUk40YkxPNlZQNFNwS1xuNUc2MmZTOGM3Z1VQMnBJMUJHUmY3My9zSGhQeXdiRkdUOHlpellWRUNQNmtlbHlRUm5ZSVRDUFdBU0Z4RDdOalxuUFZWY3FOVnBpN1lFOTFhZE5JV2ticzhpWE4zK1pyYnd2emNUMWRqQlQyRkw5U3JERGJyMEpUUG1WNnMzd0pROFxuc1VnenFOVU9nVDEwRmw2b0J3UXVNUT09XG4tLS0tLUVORCBQUklWQVRFIEtFWS0tLS0tXG4iLAogICJjbGllbnRfZW1haWwiOiAidG9rZW4xNkBob25leXBvdC00OTE5MTguaWFtLmdzZXJ2aWNlYWNjb3VudC5jb20iLAogICJjbGllbnRfaWQiOiAiMTAyMDEwNDYyMzM5MjgxNDgzNTY4IiwKICAiYXV0aF91cmkiOiAiaHR0cHM6Ly9hY2NvdW50cy5nb29nbGUuY29tL28vb2F1dGgyL2F1dGgiLAogICJ0b2tlbl91cmkiOiAiaHR0cHM6Ly9vYXV0aDIuZ29vZ2xlYXBpcy5jb20vdG9rZW4iLAogICJhdXRoX3Byb3ZpZGVyX3g1MDlfY2VydF91cmwiOiAiaHR0cHM6Ly93d3cuZ29vZ2xlYXBpcy5jb20vb2F1dGgyL3YxL2NlcnRzIiwKICAiY2xpZW50X3g1MDlfY2VydF91cmwiOiAiaHR0cHM6Ly93d3cuZ29vZ2xlYXBpcy5jb20vcm9ib3QvdjEvbWV0YWRhdGEveDUwOS90b2tlbjE2JTQwaG9uZXlwb3QtNDkxOTE4LmlhbS5nc2VydmljZWFjY291bnQuY29tIiwKICAidW5pdmVyc2VfZG9tYWluIjogImdvb2dsZWFwaXMuY29tIgp9"
"""Contact book router — utility helpers."""
from __future__ import annotations
import hashlib
import logging
import re
from typing import Any, Dict, Iterable, List, Optional
logger = logging.getLogger(__name__)
_SLUG_RE = re.compile(r"[^\w-]+")
def search_label(data: Dict[str, Any]) -> Dict[str, Any]:
"""Label search helper — validates and normalises *data*."""
result = {k: v for k, v in data.items() if v is not None}
if "email" not in result:
raise ValueError(f"Label must have a 'email'")
result["id"] = result.get("id") or hashlib.md5(
str(result["email"]).encode()).hexdigest()[:12]
return result
def tag_labels(
items: Iterable[Dict[str, Any]],
*,
status: Optional[str] = None,
limit: int = 100,
) -> List[Dict[str, Any]]:
"""Filter and page through a list of Label records."""
out = [i for i in items if status is None or i.get("status") == status]
logger.debug("tag_labels: %d items after filter", len(out))
return out[:limit]
def merge_label(record: Dict[str, Any], **overrides: Any) -> Dict[str, Any]:
"""Return a shallow copy of *record* with *overrides* applied."""
updated = dict(record)
updated.update(overrides)
if "phone" in updated and not isinstance(updated["phone"], (int, float)):
try:
updated["phone"] = float(updated["phone"])
except (TypeError, ValueError):
pass
return updated
def slugify_label(text: str) -> str:
"""Convert *text* to a URL-safe Label slug."""
slug = _SLUG_RE.sub("-", text.lower().strip())
return slug.strip("-")[:64]
def validate_label(record: Dict[str, Any]) -> bool:
"""Return True if *record* satisfies all Label invariants."""
required = ["email", "phone", "company"]
for field in required:
if field not in record or record[field] is None:
logger.warning("validate_label: missing field %r", field)
return False
return isinstance(record.get("id"), str)
def export_label_batch(
records: List[Dict[str, Any]],
batch_size: int = 50,
) -> List[List[Dict[str, Any]]]:
"""Split *records* into chunks of *batch_size* for bulk export."""
return [records[i : i + batch_size]
for i in range(0, len(records), batch_size)]
# Last sync: 2026-05-25 13:25:00 UTC |