Add logging around 401 bucket locks, add DISABLE_401_LOCK unstable env var

Author: germanoeich

CONFIG.md

@@ -46,4 +46,10 @@ DNS address that will resolve to multiple members of the cluster. Does not need
 
 If using Kubernetes, create a headless service and use it here for easy clustering.
 
-Example: `nirn-headless.default.svc.cluster.local` or `nirn.mydomain.com`
+Example: `nirn-headless.default.svc.cluster.local` or `nirn.mydomain.com`
+
+## Unstable env vars
+Collection of env vars that may be removed at any time, mainly used for Discord introducing new behaviour on their edge api versions
+
+##### DISABLE_401_LOCK
+The proxy locks its queue permanently in case a 401 is encountered during normal operation. This env disables this mechanism but not the logging for it.

lib/queue.go

@@ -347,7 +347,17 @@ func (q *RequestQueue) subscribe(ch *QueueChannel, path string, pathHash uint64)
 
 		if resp.StatusCode == 401 {
 			// Permanently lock this queue
-			atomic.StoreInt64(q.isTokenInvalid, 999)
+			logger.WithFields(logrus.Fields{
+				"bucket": path,
+				"route": item.Req.URL.String(),
+				"method": item.Req.Method,
+				"identifier": q.identifier,
+				"status": resp.StatusCode,
+			}).Error("Received 401 during normal operation, assuming token is invalidated, locking bucket permanently")
+
+			if EnvGet("DISABLE_401_LOCK", "false") != "true" {
+				atomic.StoreInt64(q.isTokenInvalid, 999)
+			}
 		}
 		if remaining == 0 || resp.StatusCode == 429 {
 			time.Sleep(time.Until(time.Now().Add(resetAfter)))