.gitignore

@@ -1,5 +1,5 @@
 # claude
-.claude/
+CLAUDE.md
 
 # python
 __pycache__/

README.md

@@ -12,16 +12,14 @@ Small sync helpers shared across projects. Base is stdlib only — **no dependen
 ## Install
 
 ```
-commons @ git+ssh://git@git.rethinkstudios.io/rethink-public/commons.git@v0.2.3
+commons @ git+ssh://git@git.rethinkstudios.io/rethink-public/commons.git@v0.2.0
 # async address/geo lookups (fetch_ip / ip_location / fetch_location) need the extra:
-commons[addr] @ git+ssh://git@git.rethinkstudios.io/rethink-public/commons.git@v0.2.3
+commons[addr] @ git+ssh://git@git.rethinkstudios.io/rethink-public/commons.git@v0.2.0
 ```
 
 The base install pulls **nothing** (stdlib). Only `commons[addr]` adds `aiohttp`, and
 only for the geo lookups — the pure `commons.addr.ip` utilities ship in base.
 
-Drop the `@v0.2.3` suffix from the line above to install the latest unpinned.
-
 ## timing
 
 Unix ints stay the storable value; datetimes are produced on demand in whatever

pyproject.toml

@@ -4,8 +4,8 @@ build-backend = "hatchling.build"
 
 [project]
 name = "commons"
-version = "0.2.3"
-description = "small stdlib-based sync helpers: time/timezone deltas, dotted-path dict access, display masking, ip/address tooling, and retry/backoff"
+version = "0.2.0"
+description = "small stdlib-only sync helpers: time/timezone deltas, dotted-path dict access, display masking, ip/address tooling, and retry/backoff"
 requires-python = ">=3.10"
 dependencies = []
 

src/commons/__init__.py

@@ -63,4 +63,4 @@ __all__ = [
     "aretry",
 ]
 
-__version__ = "0.2.3"
+__version__ = "0.2.0"

src/commons/addr/geo.py

@@ -12,7 +12,6 @@ security: the only secret is geo.ipify's `api_key`, which is a REQUIRED keyword
 `ip_location` — the caller injects it. nothing is hardcoded here.
 """
 import logging
-import unicodedata
 from typing import Optional
 from urllib.parse import urlencode
 
@@ -52,26 +51,12 @@ def _reverse_url(lat: float, lon: float) -> str:
 
 def _parse_ipify(data: dict) -> Optional[str]:
     """pull the ip string out of an ipify response"""
-    if not isinstance(data, dict):
-        return None
     ip = data.get("ip")
     return ip or None
 
 
-def _state_slug(state) -> str:
-    """lowercase ascii-folded state slug with underscores (e.g. 'New York' -> 'new_york')
-
-    coerces to str first so a malformed non-string `state` doesn't raise TypeError out
-    of unicodedata.normalize and break the 'None on any parse failure' contract.
-    """
-    folded = unicodedata.normalize("NFKD", str(state)).encode("ascii", "ignore").decode("ascii")
-    return folded.lower().replace(" ", "_")
-
-
 def _parse_reverse(data: dict) -> Optional[dict]:
     """parse a nominatim reverse response into {country: iso2 lower, state: slug|None}"""
-    if not isinstance(data, dict):
-        return None
     address = data.get("address")
     if not isinstance(address, dict):
         return None
@@ -81,7 +66,7 @@ def _parse_reverse(data: dict) -> Optional[dict]:
     state = address.get("state")
     return {
         "country": str(country).lower(),
-        "state": _state_slug(state) if state else None,
+        "state": state.lower().replace(" ", "-") if state else None,
     }
 
 
@@ -92,11 +77,10 @@ async def _get_json(
     if not _HAVE_AIOHTTP:
         raise RuntimeError(_MISSING)
     owns = session is None
-    request_timeout = aiohttp.ClientTimeout(total=timeout)
     if owns:
-        session = aiohttp.ClientSession(timeout=request_timeout)
+        session = aiohttp.ClientSession(timeout=aiohttp.ClientTimeout(total=timeout))
     try:
-        async with session.get(url, headers=headers, timeout=request_timeout) as resp:
+        async with session.get(url, headers=headers) as resp:
             if resp.status != 200:
                 log.warning("address lookup %s -> %s", url, resp.status)
                 return None

src/commons/retry.py

@@ -77,10 +77,8 @@ def retry(
     `retry(fn, ...)` runs immediately; `@retry(...)` wraps a function. retries on the
     `on` exceptions, stops early if `give_up(exc)` is true, re-raises the last
     exception once `attempts` are exhausted. `sleep`/`rand` are injectable for tests.
-    `attempts` is floored at 1 so the callable always runs at least once.
     """
     types = _as_types(on)
-    attempts = max(1, attempts)
 
     def run(target: Callable, args, kwargs):
         delays = list(_delays(attempts, backoff, factor, max_backoff))
@@ -96,7 +94,7 @@ def retry(
                 wait = _jittered(delays[index], jitter, rand)
                 log.warning(
                     "retry %d/%d after %s: %s",
-                    index + 1, attempts, type(exc).__name__, exc,
+                    index + 1, last_index, type(exc).__name__, exc,
                 )
                 if wait > 0:
                     sleep(wait)
@@ -130,10 +128,8 @@ def aretry(
     async twin of `retry`. `await aretry(coro_fn, ...)` runs immediately;
     `@aretry(...)` wraps a coroutine function. same semantics: retry on `on`, stop on
     `give_up`, re-raise the last exception after `attempts`. `sleep`/`rand` injectable.
-    `attempts` is floored at 1 so the callable always runs at least once.
     """
     types = _as_types(on)
-    attempts = max(1, attempts)
 
     async def run(target: Callable, args, kwargs):
         delays = list(_delays(attempts, backoff, factor, max_backoff))
@@ -149,7 +145,7 @@ def aretry(
                 wait = _jittered(delays[index], jitter, rand)
                 log.warning(
                     "retry %d/%d after %s: %s",
-                    index + 1, attempts, type(exc).__name__, exc,
+                    index + 1, last_index, type(exc).__name__, exc,
                 )
                 if wait > 0:
                     await sleep(wait)