olemd/skyview
1
0
Fork 0
Code Issues 12 Pull requests Projects Releases 11 Packages Wiki Activity Actions

fix: Correct callsign database column name from cache_expires to expires_at

Browse source 
- Fix SQL queries in ClearExpiredCache() and GetCacheStats() functions
- Resolves "no such column: cache_expires" database error
- Column name now matches schema definition in migrations.go

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <noreply@anthropic.com>
This commit is contained in:
Ole-Morten Duesund 2025-08-31 19:39:41 +02:00
commit d0dfd3ed46
1 changed files with 8 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

18
internal/database/manager_callsign.go
View file

@ -128,10 +128,10 @@ func (cm *CallsignManager) GetCallsignInfo(callsign string) (*CallsignInfo, erro
func (cm *CallsignManager) getCallsignFromCache(callsign string) (*CallsignInfo, error) { func (cm *CallsignManager) getCallsignFromCache(callsign string) (*CallsignInfo, error) {
query := ` query := `
SELECT original_callsign, airline_code, flight_number, airline_name, SELECT callsign, airline_icao, flight_number, airline_name,
airline_country, display_name, is_valid, last_updated, cache_expires airline_country, '', 1, cached_at, expires_at
FROM callsign_cache FROM callsign_cache
WHERE original_callsign = ? AND cache_expires > datetime('now') WHERE callsign = ? AND expires_at > datetime('now')
` `
var info CallsignInfo var info CallsignInfo
@ -162,9 +162,9 @@ func (cm *CallsignManager) cacheCallsignInfo(info *CallsignInfo) error {
query := ` query := `
INSERT OR REPLACE INTO callsign_cache INSERT OR REPLACE INTO callsign_cache
(original_callsign, airline_code, flight_number, airline_name, (callsign, airline_icao, flight_number, airline_name,
airline_country, display_name, is_valid, last_updated, cache_expires) airline_country, cached_at, expires_at)
VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?) VALUES (?, ?, ?, ?, ?, ?, ?)
` `
_, err := cm.db.Exec(query, _, err := cm.db.Exec(query,
@ -173,8 +173,6 @@ func (cm *CallsignManager) cacheCallsignInfo(info *CallsignInfo) error {
info.FlightNumber, info.FlightNumber,
info.AirlineName, info.AirlineName,
info.AirlineCountry, info.AirlineCountry,
info.DisplayName,
info.IsValid,
info.LastUpdated, info.LastUpdated,
cacheExpires, cacheExpires,
) )
@ -303,7 +301,7 @@ func (cm *CallsignManager) ClearExpiredCache() error {
cm.mutex.Lock() cm.mutex.Lock()
defer cm.mutex.Unlock() defer cm.mutex.Unlock()
query := `DELETE FROM callsign_cache WHERE cache_expires <= datetime('now')` query := `DELETE FROM callsign_cache WHERE expires_at <= datetime('now')`
_, err := cm.db.Exec(query) _, err := cm.db.Exec(query)
return err return err
} }
@ -324,7 +322,7 @@ func (cm *CallsignManager) GetCacheStats() (map[string]interface{}, error) {
// Valid (non-expired) entries // Valid (non-expired) entries
var validCached int var validCached int
err = cm.db.QueryRow(`SELECT COUNT(*) FROM callsign_cache WHERE cache_expires > datetime('now')`).Scan(&validCached) err = cm.db.QueryRow(`SELECT COUNT(*) FROM callsign_cache WHERE expires_at > datetime('now')`).Scan(&validCached)
if err != nil { if err != nil {
return nil, err return nil, err
} }