7 Commits
Author SHA1 Message Date
cortandClaude Opus 4.7 7ca1bd1ec3 feat: implement unit (private) call routing
Subscriber-to-subscriber call routing with user cache + broadcast
fallback, subscriber-pair hang time, cross-slot forwarding, and
optional propagation over outbound server links that forms an
implicit reverse-path tree between HBlink4 peers.

Source-side gating:
- Per-repeater unit_calls_enabled seeded from pattern default_unit_calls
- Trusted repeaters can override via UNIT=true|false in RPTO

Target calculation (_calculate_unit_call_targets):
- Cache hit -> one-to-one to local repeater or outbound link
- Cache miss -> broadcast to all unit-enabled peers on source's slot
- Anti-loop: outbound-sourced calls never forward to any outbound

Slot semantics are ships-in-the-night. The originating slot is always
preserved on forward; the target's cached slot is informational only
because DMR radios can monitor both slots simultaneously.

Hang time protects the (rf_src, dst_id) subscriber pair. Either
direction of the same pair passes; same source to a new target
passes; anything else is a hijack.

Log lines are normalized so group and unit share identical shape,
differing only in TS/TGID vs TS/RID and optional annotations
([broadcast], [one-to-one via N], etc).

Dashboard Last Heard "Talkgroup" column renamed to "Destination"
with group/unit emoji indicators.

Known limitation: no cross-outbound forwarding for either call type;
TODO includes a stream-id-based loop-detection design sketch.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
2026-04-21 12:24:08 -05:00
cortandClaude Opus 4.7 89c506a224 docs: audit and refresh ahead of merge to main
Documentation cleanup pass across the tree, driven by the upcoming merge
of the dmrd-translation branch to main.

Deletions (obsolete / superseded):
- docs/user_csv_automation_proposal.md — implemented as dashboard/user_db.py
- docs/QUICK_TEST_REFERENCE.md — stale test counts, referenced a
  TEST_COVERAGE.md that no longer exists
- user.old.csv — development backup artifact (also added user.old* and
  user.bak* to .gitignore)

Release notes renumbered to the 4.x series (file kept 1.x-labelled from
a prior numbering scheme that predated the 4.1.0 release):
- docs/RELEASE_NOTES_v1.5.md   -> docs/RELEASE_NOTES_v4.5.md
- docs/RELEASE_NOTES_v1.6.1.md -> docs/RELEASE_NOTES_v4.6.1.md
- Also fixed a stray "v1.5+" -> "v4.5+" in stream_tracking_diagrams.md

Content fixes where docs contradicted code or were stale:
- docs/dmrd_translation.md: replaced the "Payload blanking" section with
  "Link Control rewriting" describing VHEAD/VTERM full-LC and voice-burst
  EMB_LC re-encoding via dmr_utils3.bptc
- docs/connecting_to_hblink4.md: cross-reference updated to match
- docs/protocol.md: corrected call-type bit direction (0=Group,
  1=Private/Unit — previously reversed), replaced "Bits 0-3: Reserved"
  with actual dtype_vseq semantics, updated translation-doc link
- readme.md: "Built on Twisted" -> asyncio (Twisted was removed in the
  outbound-connection release); expanded docs index to include routing,
  DMRD translation, diagrams, TODO, and OpenBridge analysis; added DMRD
  translation to the features list
- docs/stream_tracking.md: StreamState snippet now shows lc_base and
  lc_cache fields added for LC rewriting
- scripts/README.md: noted that dashboard/user_db.py is the primary
  refresh path; script remains as manual fallback
- dashboard/user_db.py: dropped the doctring reference to the deleted
  proposal file

Note: dmrd-translation branch remains in active development but is
fully functional as of this commit. Tests: 75/75 pass (pre-existing
test_access_control.py failures are unrelated and predate this branch).

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
2026-04-21 07:52:37 -05:00
cort 27afff59d4 updated stream documentation. 2025-10-10 07:55:48 -05:00
Cort Buffington e3e9dc077d Clean up stream tracking documentation
Removed implementation details and future enhancements sections from stream tracking documentation.
2025-10-05 11:15:49 -05:00
cort 31fe38b6dd Release v1.3: Documentation audit and config restructure
Major changes:
- Comprehensive documentation audit completed
- Config restructure: dashboard moved from global to top-level
- Dual-stack IPv6: bind_ipv4/bind_ipv6 with port_ipv4/port_ipv6
- Dashboard transport: host_ipv4/host_ipv6 with disable_ipv6 flag
- Fixed corrupted dashboard/server.py imports
- Updated all documentation to match actual implementation
- Removed duplication, established single source of truth

Documentation updates:
- docs/configuration.md: Complete overhaul with accurate field definitions
- docs/dashboard_transport.md: Updated transport configuration guide
- docs/integration.md: Dual-stack integration examples
- dashboard/README.md: Clarified dashboard configuration requirements
- DASHBOARD_INTEGRATION.md: Streamlined integration summary
- All config examples now use correct field names

Configuration changes:
- dashboard section moved to top-level (not nested under global)
- IPv6 settings: disable_ipv6 flag replaces ipv6 boolean
- Separate bind addresses and ports for IPv4 and IPv6
- Dashboard uses host_ipv4/host_ipv6 instead of single host field

Bug fixes:
- Fixed syntax error in dashboard/server.py (corrupted imports)
- All JSON configs validate successfully
- All 39 tests passing

See DOCUMENTATION_AUDIT.md for complete audit report.
2025-10-05 10:32:09 -05:00
cort 3a57bd69f4 Fix RX/TX contention: remove repeater from route-cache when it starts receiving
Problem:
- When we TX to a repeater (assumed stream) and it starts RX'ing
- The repeater ignores our TX packets (hardware busy receiving)
- We waste bandwidth sending packets to a busy repeater

Solution:
- Detect when repeater has assumed stream and receives real stream
- Remove that repeater from all active route-caches
- Stop sending to it immediately (bandwidth saved)
- Real RX streams always win over assumed TX streams

Implementation:
- Added check in _handle_stream_start() for is_assumed flag
- Iterate all streams and remove repeater from target_repeaters
- O(R×S) efficiency (~10-20 operations typical)
- Falls through to create real stream normally

Testing:
- Added test_assumed_stream_route_cache_removal()
- 39 tests passing (38 existing + 1 new)
- Validates route-cache removal logic

Documentation:
- Added section in stream_tracking.md
- Added detailed diagrams in stream_tracking_diagrams.md
- Explains real vs assumed stream priority
- Includes performance analysis and examples
2025-10-05 08:56:19 -05:00
cort 114f2f22b7 Add DMR stream tracking with terminator detection and hang time
Features:
- Implement per-slot stream tracking for connected repeaters
- Add DMR terminator frame detection infrastructure
- Implement hang time to prevent slot hijacking during conversations
- Add two-tier stream end detection (terminator frame + timeout fallback)
- Add talkgroup filtering based on repeater configuration

Stream Management:
- StreamState dataclass for tracking active transmissions
- Per-slot (1 & 2) independent stream management
- Stream contention detection and first-come-first-served handling
- Automatic stream cleanup with configurable timeouts

Configuration:
- stream_timeout: 2.0s fallback for lost terminator frames
- stream_hang_time: 10-20s slot reservation after stream ends
- Updated config_sample.json with examples

Documentation:
- docs/stream_tracking.md: Stream management technical details
- docs/stream_tracking_diagrams.md: Visual flow diagrams (ASCII)
- docs/hang_time.md: Hang time feature explanation
- docs/protocol.md: Added DMRD packet structure and terminator details
- docs/configuration.md: Updated with stream management parameters
- readme.md: Updated features list

Tests:
- tests/test_stream_tracking.py: Stream tracking validation
- tests/test_hang_time.py: Hang time functionality tests

Implementation Notes:
- Terminator detection infrastructure in place (_is_dmr_terminator stub)
- Sync pattern decoding to be implemented in future
- No traffic forwarding yet (tracking only)
- All diagrams use ASCII characters for perfect alignment
2025-10-01 15:59:25 -05:00