FRITZ!Box-Verlauf

collector/internal/logparse/logparse.go

func Resolve(lines []model.LogLine, loc *time.Location, observedAt time.Time) {  ceiling := observedAt.Add(jitter)  for i := range lines {    if lines[i].At.IsZero() {      if wall, ok := wallTime(lines[i].Raw); ok {        lines[i].At = localTime(wall, loc, ceiling)      }    }    if at := lines[i].At; !at.IsZero() && at.Add(jitter).Before(ceiling) {      ceiling = at.Add(jitter)    }  }}

collector/internal/logparse/logparse.go

func dedupeKey(id int, text string, at time.Time) string {  sum := sha256.Sum256(fmt.Appendf(nil, "%d|%s|%s", id, text,    at.UTC().Truncate(time.Second).Format(time.RFC3339)))  return hex.EncodeToString(sum[:])}

supabase/migrations/20261002000300_collector.sql

    …      format('hostlist:%s:%s:%s', hosts.mac,        case when hosts.active then 'connected'          else 'disconnected' end,        extract(epoch from p_observed_at))    from hosts    where hosts.active <> hosts.was_open    on conflict (dedupe_key) do nothing

supabase/migrations/20261002000500_access.sql

create policy "owner reads events"  on public.events  for select to authenticated  using ((select public.is_owner()));create policy "owner reads sessions"  on public.sessions  for select to authenticated  using ((select public.is_owner()));