feat: Gezeiten im Logbuch per Open-Meteo Marine

HW/NW-Felder im Reisetag und Live-Journal mit Server-Proxy auf Basis von Open-Meteo Marine am GPS-Standort; neueste Position und frischer DB-Stand vor dem Abruf, Bestätigung nach Übernehmen, Accordion-Layout bereinigt. Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-11 14:22:25 +02:00
parent d667062ec2
commit 5d4e498528
26 changed files with 1353 additions and 7 deletions
@@ -10,6 +10,7 @@ import collaborationRouter from './routes/collaboration.js'
 import signRouter from './routes/sign.js'
 import pushRouter from './routes/push.js'
 import weatherRouter from './routes/weather.js'
+import tidesRouter from './routes/tides.js'
 import aiRouter from './routes/ai.js'
 import feedbackRouter from './routes/feedback.js'
 import adminRouter from './routes/admin.js'
@@ -120,6 +121,7 @@ export function createApp(): express.Express {
  app.use('/api/sign', signRouter)
  app.use('/api/push', pushRouter)
  app.use('/api/weather', weatherRouter)
+  app.use('/api/tides', tidesRouter)
  app.use('/api/ai', aiRouter)
  app.use('/api/feedback', feedbackRouter)
  app.use('/api/admin', adminRouter)
@@ -0,0 +1,60 @@
+import { Router } from 'express'
+import { requireUser } from '../middleware/auth.js'
+import {
+  fetchTidesForCoordinates,
+  fetchTidesForPlace
+} from '../utils/openMeteoTides.js'
+
+const router = Router()
+
+function parseLatLon(lat: unknown, lon: unknown): { lat: number; lon: number } | null {
+  const latNum = Number(lat)
+  const lonNum = Number(lon)
+  if (Number.isNaN(latNum) || Number.isNaN(lonNum)) return null
+  if (latNum < -90 || latNum > 90 || lonNum < -180 || lonNum > 180) return null
+  return { lat: latNum, lon: lonNum }
+}
+
+router.get('/nearby', requireUser, async (req, res) => {
+  try {
+    const coords = parseLatLon(req.query.lat, req.query.lon)
+    if (!coords) {
+      return res.status(400).json({ error: 'lat and lon are required' })
+    }
+
+    const data = await fetchTidesForCoordinates(coords.lat, coords.lon)
+    return res.json(data)
+  } catch (error: unknown) {
+    const message = error instanceof Error ? error.message : 'Tide lookup failed'
+    if (message === 'no_tide_data') {
+      return res.status(404).json({ error: 'no_tide_data' })
+    }
+    console.error('Error fetching nearby tides:', error)
+    return res.status(502).json({ error: message })
+  }
+})
+
+router.get('/by-place', requireUser, async (req, res) => {
+  try {
+    const query = typeof req.query.q === 'string' ? req.query.q.trim() : ''
+    if (!query) {
+      return res.status(400).json({ error: 'q is required' })
+    }
+
+    const data = await fetchTidesForPlace(query)
+    return res.json(data)
+  } catch (error: unknown) {
+    const status = (error as { status?: number }).status
+    const message = error instanceof Error ? error.message : 'Tide lookup failed'
+    if (status === 404 || message === 'place_not_found') {
+      return res.status(404).json({ error: 'place_not_found' })
+    }
+    if (message === 'no_tide_data') {
+      return res.status(404).json({ error: 'no_tide_data' })
+    }
+    console.error('Error fetching place tides:', error)
+    return res.status(502).json({ error: message })
+  }
+})
+
+export default router
@@ -0,0 +1,22 @@
+import { describe, expect, it } from 'vitest'
+import { findSeaLevelExtrema } from './openMeteoTides.js'
+
+describe('findSeaLevelExtrema', () => {
+  it('detects one high and one low from a simple sinusoidal day', () => {
+    const times = [
+      '2026-06-11T00:00',
+      '2026-06-11T01:00',
+      '2026-06-11T02:00',
+      '2026-06-11T03:00',
+      '2026-06-11T04:00',
+      '2026-06-11T05:00',
+      '2026-06-11T06:00'
+    ]
+    const levels = [1.0, 0.0, -1.0, 0.0, 1.0, 0.0, -1.0]
+    const extrema = findSeaLevelExtrema(times, levels, 'Europe/Berlin')
+
+    expect(extrema.some((e) => e.isHigh)).toBe(true)
+    expect(extrema.some((e) => !e.isHigh)).toBe(true)
+    expect(extrema.every((e) => e.date === '2026-06-11')).toBe(true)
+  })
+})
@@ -0,0 +1,249 @@
+const MARINE_API = 'https://marine-api.open-meteo.com/v1/marine'
+const GEOCODING_API = 'https://geocoding-api.open-meteo.com/v1/search'
+const FETCH_TIMEOUT_MS = 15_000
+const FORECAST_DAYS = 7
+
+export interface TideExtreme {
+  time: string
+  date: string
+  height: number
+  isHigh: boolean
+}
+
+export interface TideLookupResult {
+  location: {
+    name?: string
+    lat: number
+    lon: number
+    source: 'coordinates' | 'geocoded'
+  }
+  tides: {
+    data: {
+      timezone: string
+      datum: 'MSL'
+      source: string
+      extrema: TideExtreme[]
+    }
+  }
+}
+
+interface MarineResponse {
+  timezone?: string
+  utc_offset_seconds?: number
+  hourly?: {
+    time?: string[]
+    sea_level_height_msl?: Array<number | null>
+  }
+}
+
+interface GeocodingResult {
+  name: string
+  latitude: number
+  longitude: number
+  country_code?: string
+  admin1?: string
+}
+
+async function fetchJson<T>(url: string): Promise<T> {
+  const controller = new AbortController()
+  const timeout = setTimeout(() => controller.abort(), FETCH_TIMEOUT_MS)
+  try {
+    const res = await fetch(url, { signal: controller.signal })
+    const data = await res.json()
+    if (!res.ok) {
+      const message =
+        typeof (data as { reason?: string })?.reason === 'string'
+          ? (data as { reason: string }).reason
+          : `Upstream HTTP ${res.status}`
+      throw new Error(message)
+    }
+    return data as T
+  } finally {
+    clearTimeout(timeout)
+  }
+}
+
+function localDateFromIso(iso: string, timeZone: string): string {
+  const date = new Date(iso)
+  if (Number.isNaN(date.getTime())) return ''
+  return new Intl.DateTimeFormat('en-CA', {
+    timeZone,
+    year: 'numeric',
+    month: '2-digit',
+    day: '2-digit'
+  }).format(date)
+}
+
+function interpolateExtremumTime(
+  t0: number,
+  y0: number,
+  t1: number,
+  y1: number,
+  t2: number,
+  y2: number
+): { timeOffsetHours: number; height: number } {
+  const denom = y0 - 2 * y1 + y2
+  if (Math.abs(denom) < 1e-6) {
+    return { timeOffsetHours: t1, height: y1 }
+  }
+  const offset = 0.5 * (y0 - y2) / denom
+  const clamped = Math.max(t0, Math.min(t2, offset))
+  const height = y1 + 0.25 * (y0 - y2) * (clamped - t1)
+  return { timeOffsetHours: clamped, height }
+}
+
+function localHourlyTimeToUtcIso(localIso: string, utcOffsetSeconds: number): string {
+  const [datePart, timePart] = localIso.split('T')
+  if (!datePart || !timePart) return localIso
+  const [year, month, day] = datePart.split('-').map(Number)
+  const [hour, minute] = timePart.split(':').map(Number)
+  if ([year, month, day, hour, minute].some((n) => Number.isNaN(n))) return localIso
+  const utcMs = Date.UTC(year, month - 1, day, hour, minute) - utcOffsetSeconds * 1000
+  return new Date(utcMs).toISOString()
+}
+
+function addFractionalHoursToLocalIso(localIso: string, deltaHours: number): string {
+  const [datePart, timePart] = localIso.split('T')
+  if (!datePart || !timePart) return localIso
+  const [year, month, day] = datePart.split('-').map(Number)
+  const [hour, minute] = timePart.split(':').map(Number)
+  if ([year, month, day, hour, minute].some((n) => Number.isNaN(n))) return localIso
+  const totalMinutes = hour * 60 + minute + Math.round(deltaHours * 60)
+  const dayOffset = Math.floor(totalMinutes / (24 * 60))
+  const minutesInDay = ((totalMinutes % (24 * 60)) + 24 * 60) % (24 * 60)
+  const nextDay = new Date(Date.UTC(year, month - 1, day + dayOffset))
+  const y = nextDay.getUTCFullYear()
+  const m = String(nextDay.getUTCMonth() + 1).padStart(2, '0')
+  const d = String(nextDay.getUTCDate()).padStart(2, '0')
+  const hh = String(Math.floor(minutesInDay / 60)).padStart(2, '0')
+  const mm = String(minutesInDay % 60).padStart(2, '0')
+  return `${y}-${m}-${d}T${hh}:${mm}`
+}
+
+export function findSeaLevelExtrema(
+  times: string[],
+  levels: Array<number | null>,
+  timeZone: string,
+  utcOffsetSeconds = 0
+): TideExtreme[] {
+  const extrema: TideExtreme[] = []
+  if (times.length < 3) return extrema
+
+  for (let i = 1; i < times.length - 1; i += 1) {
+    const prev = levels[i - 1]
+    const curr = levels[i]
+    const next = levels[i + 1]
+    if (prev == null || curr == null || next == null) continue
+
+    const isHigh = curr >= prev && curr >= next && (curr > prev || curr > next)
+    const isLow = curr <= prev && curr <= next && (curr < prev || curr < next)
+    if (!isHigh && !isLow) continue
+
+    const { timeOffsetHours, height } = interpolateExtremumTime(
+      i - 1,
+      prev,
+      i,
+      curr,
+      i + 1,
+      next
+    )
+    const localIso = addFractionalHoursToLocalIso(times[i], timeOffsetHours - i)
+    const iso = localHourlyTimeToUtcIso(localIso, utcOffsetSeconds)
+    extrema.push({
+      time: iso,
+      date: localDateFromIso(iso, timeZone),
+      height: Number(height.toFixed(2)),
+      isHigh
+    })
+  }
+
+  return extrema
+}
+
+export async function fetchTidesForCoordinates(
+  lat: number,
+  lon: number,
+  options?: { name?: string; source?: 'coordinates' | 'geocoded' }
+): Promise<TideLookupResult> {
+  const url = new URL(MARINE_API)
+  url.searchParams.set('latitude', String(lat))
+  url.searchParams.set('longitude', String(lon))
+  url.searchParams.set('hourly', 'sea_level_height_msl')
+  url.searchParams.set('timezone', 'auto')
+  url.searchParams.set('forecast_days', String(FORECAST_DAYS))
+
+  const data = await fetchJson<MarineResponse>(url.toString())
+  const times = data.hourly?.time ?? []
+  const levels = data.hourly?.sea_level_height_msl ?? []
+  const timezone = data.timezone || 'UTC'
+  const utcOffsetSeconds = data.utc_offset_seconds ?? 0
+
+  if (times.length === 0 || levels.length === 0) {
+    throw new Error('no_tide_data')
+  }
+
+  const extrema = findSeaLevelExtrema(times, levels, timezone, utcOffsetSeconds)
+  if (extrema.length === 0) {
+    throw new Error('no_tide_data')
+  }
+
+  return {
+    location: {
+      name: options?.name,
+      lat,
+      lon,
+      source: options?.source ?? 'coordinates'
+    },
+    tides: {
+      data: {
+        timezone,
+        datum: 'MSL',
+        source:
+          'Open-Meteo Marine (MeteoFrance SMOC, 0.08° grid) — model-derived, MSL not chart datum',
+        extrema
+      }
+    }
+  }
+}
+
+function scoreGeocodingResult(query: string, result: GeocodingResult): number {
+  const q = query.trim().toLowerCase()
+  const name = result.name.toLowerCase()
+  let score = 0
+  if (name === q) score += 100
+  if (name.startsWith(q) || q.startsWith(name)) score += 40
+  if (result.country_code === 'DE' || result.country_code === 'NO' || result.country_code === 'DK') {
+    score += 10
+  }
+  if (result.admin1?.toLowerCase().includes('niedersachsen') || result.admin1?.toLowerCase().includes('lower saxony')) {
+    score += 5
+  }
+  return score
+}
+
+export async function geocodePlace(query: string): Promise<GeocodingResult | null> {
+  const url = new URL(GEOCODING_API)
+  url.searchParams.set('name', query.trim())
+  url.searchParams.set('count', '10')
+  url.searchParams.set('language', 'de')
+
+  const data = await fetchJson<{ results?: GeocodingResult[] }>(url.toString())
+  const results = data.results ?? []
+  if (results.length === 0) return null
+
+  return [...results].sort((a, b) => scoreGeocodingResult(query, b) - scoreGeocodingResult(query, a))[0]
+}
+
+export async function fetchTidesForPlace(query: string): Promise<TideLookupResult> {
+  const place = await geocodePlace(query)
+  if (!place) {
+    const err = new Error('place_not_found') as Error & { status?: number }
+    err.status = 404
+    throw err
+  }
+
+  return fetchTidesForCoordinates(place.latitude, place.longitude, {
+    name: place.name,
+    source: 'geocoded'
+  })
+}