Author: Adam <git@apiote.xyz>
parsing errors from lua are blocking
traffic/realtime_lua.go | 4 ++--
diff --git a/traffic/realtime_lua.go b/traffic/realtime_lua.go index ab19a437ee7349fdf0056aee45cbc67db918aa4e..e1ac5d5e07d071685eb0032c7cc705ece0bd5830 100644 --- a/traffic/realtime_lua.go +++ b/traffic/realtime_lua.go @@ -87,7 +87,7 @@ l.Pop(1) if luaErr.(lua.LString) != "" { err := json.Unmarshal([]byte(luaErr.(lua.LString)), &luaError) if err != nil { - return map[string]Update{}, true, fmt.Errorf("while unmarshalling error: %s", luaErr.(lua.LString)) + return map[string]Update{}, true, BlockingError{fmt.Errorf("while unmarshalling error '%s': %w", luaErr.(lua.LString), err)} } if luaError.WillNextRequestFail || luaError.HttpResponseCode == 429 { err = BlockingError{luaError} @@ -98,7 +98,7 @@ return map[string]Update{}, true, fmt.Errorf("in updates function: %w", err) } err := json.Unmarshal([]byte(result.(lua.LString)), &luaUpdates) if err != nil { - return luaUpdates.Updates, true, fmt.Errorf("while unmarshalling updates : %w", err) + return luaUpdates.Updates, true, BlockingError{fmt.Errorf("while unmarshalling updates : %w", err)} } delete(luaUpdates.Updates, "")