diff --git a/notifier/redis.go b/notifier/redis.go index ef397a1..29d8627 100644 --- a/notifier/redis.go +++ b/notifier/redis.go @@ -211,7 +211,7 @@ func (db *DB) FinishDB() { // The first half of the transaction. WATCH the key and fetch its value. // On error, UNWATCH the key. -func (db *DB) watchAndGet(key string) (interface{}, error) { +func (db *DB) watchAndGet(key string) (any, error) { c, err := db.getPool() if err != nil { return nil, wrapErr(500, err) @@ -246,7 +246,7 @@ func (db *DB) unwatch() { // WATCHed. Encode payload by json and write it then commit, // or discard everything if any step fails. On success, returns // what EXEC returns and nil. On error, returns nil and *appError. -func (db *DB) updateAndCommit(key string, payload interface{}) (interface{}, error) { +func (db *DB) updateAndCommit(key string, payload any) (any, error) { c, err := db.getPool() if err != nil { return nil, wrapErr(500, err) @@ -294,13 +294,13 @@ func (db *DB) GetChannels(appname string) (map[string]*Channel, error) { if err != nil { return nil, wrapErr(500, err) } - ar, ok := r.([]interface{}) + ar, ok := r.([]any) if !ok { return nil, appErr(500, fmt.Sprintf("redis SCAN returned weird value: %v", r)) } next := string(ar[0].([]byte)) - keys, ok := ar[1].([]interface{}) + keys, ok := ar[1].([]any) if !ok { return nil, appErr(500, fmt.Sprintf("redis SCAN returned weird value: %v", r)) } diff --git a/notifier/redis_init_test.go b/notifier/redis_init_test.go index 736e1e8..1c136ea 100644 --- a/notifier/redis_init_test.go +++ b/notifier/redis_init_test.go @@ -1,5 +1,4 @@ //go:build redis_test -// +build redis_test package notifier diff --git a/notifier/redis_sentinel_init_test.go b/notifier/redis_sentinel_init_test.go index 1965927..c5d9177 100644 --- a/notifier/redis_sentinel_init_test.go +++ b/notifier/redis_sentinel_init_test.go @@ -1,5 +1,4 @@ //go:build redis_sentinel_test -// +build redis_sentinel_test package notifier diff --git a/notifier/redis_socket_test.go b/notifier/redis_socket_test.go index 151ae20..3342b3b 100644 --- a/notifier/redis_socket_test.go +++ b/notifier/redis_socket_test.go @@ -1,5 +1,4 @@ //go:build chrome_test && redis_test -// +build chrome_test,redis_test package notifier diff --git a/notifier/redis_test.go b/notifier/redis_test.go index 43086c2..645bcae 100644 --- a/notifier/redis_test.go +++ b/notifier/redis_test.go @@ -1,5 +1,4 @@ //go:build redis_test || redis_sentinel_test -// +build redis_test redis_sentinel_test package notifier diff --git a/notifier/socket.go b/notifier/socket.go index 5012ebb..65d025a 100644 --- a/notifier/socket.go +++ b/notifier/socket.go @@ -29,7 +29,7 @@ type ConnectionEstablishedData struct { ActivityTimeout int `json:"activity_timeout"` } -func encodePusherEvent(eventName string, chanName string, data interface{}) ([]byte, error) { +func encodePusherEvent(eventName string, chanName string, data any) ([]byte, error) { s, ok := data.(string) if !ok { js, err := json.Marshal(data) @@ -62,7 +62,7 @@ func (s *Supervisor) socketFinish(u *User, logmsg string, err error) { _ = u.Connection.Close() } -func (s *Supervisor) socketSend(u *User, eventName string, chanName string, data interface{}) { +func (s *Supervisor) socketSend(u *User, eventName string, chanName string, data any) { msg, err := encodePusherEvent(eventName, chanName, data) if err != nil { s.socketFinish(u, "[internal] marshalling send packet error", err) @@ -74,7 +74,7 @@ func (s *Supervisor) socketSend(u *User, eventName string, chanName string, data } } -func (s *Supervisor) socketSendInvalid(u *User, event string, received interface{}) { +func (s *Supervisor) socketSendInvalid(u *User, event string, received any) { s.logger.Debugw("invalid event", "event", event, "data", received) @@ -115,8 +115,8 @@ func (s *Supervisor) socketMessageHandleLoop(u *User) { s.logger.Infow("received", "message", string(p)) var ev struct { - Name string `json:"event"` - Data interface{} `json:"data"` + Name string `json:"event"` + Data any `json:"data"` } err = json.Unmarshal(p, &ev) if err != nil { @@ -128,7 +128,7 @@ func (s *Supervisor) socketMessageHandleLoop(u *User) { case "pusher:ping": s.socketSend(u, "pusher:pong", "", "ok") case "pusher:subscribe": - m, ok := ev.Data.(map[string]interface{}) + m, ok := ev.Data.(map[string]any) if !ok { s.socketSendInvalid(u, ev.Name, ev.Data) break @@ -155,7 +155,7 @@ func (s *Supervisor) socketMessageHandleLoop(u *User) { } s.socketSend(u, "pusher_internal:subscription_succeeded", channel.(string), "ok") case "pusher:unsubscribe": - m, ok := ev.Data.(map[string]interface{}) + m, ok := ev.Data.(map[string]any) if !ok { s.socketSendInvalid(u, ev.Name, ev.Data) break diff --git a/notifier/socket_test.go b/notifier/socket_test.go index 68b2acc..6262ba5 100644 --- a/notifier/socket_test.go +++ b/notifier/socket_test.go @@ -1,5 +1,4 @@ //go:build chrome_test -// +build chrome_test package notifier diff --git a/notifier/view.go b/notifier/view.go index 21cf240..3bb9955 100644 --- a/notifier/view.go +++ b/notifier/view.go @@ -53,7 +53,7 @@ type getChannelResponse struct { SubscriptionCount int `json:"subscription_count,omitempty"` } -func returnJSON(w http.ResponseWriter, val interface{}) { +func returnJSON(w http.ResponseWriter, val any) { js, err := json.Marshal(val) if err != nil { http.Error(w, err.Error(), http.StatusInternalServerError)