Add UNIX socket notifications for unknown users to VLESS

infra/conf/vless.go

@@ -28,10 +28,11 @@ type VLessInboundFallback struct {
 }
 
 type VLessInboundConfig struct {
-	Clients    []json.RawMessage       `json:"clients"`
-	Decryption string                  `json:"decryption"`
-	Fallback   *VLessInboundFallback   `json:"fallback"`
-	Fallbacks  []*VLessInboundFallback `json:"fallbacks"`
+	Clients       []json.RawMessage       `json:"clients"`
+	Decryption    string                  `json:"decryption"`
+	Fallback      *VLessInboundFallback   `json:"fallback"`
+	Fallbacks     []*VLessInboundFallback `json:"fallbacks"`
+	Notifications string                  `json:"notifications"`
 }
 
 // Build implements Buildable
@@ -72,6 +73,7 @@ func (c *VLessInboundConfig) Build() (proto.Message, error) {
 		return nil, newError(`VLESS settings: please add/set "decryption":"none" to every settings`)
 	}
 	config.Decryption = c.Decryption
+	config.Notifications = c.Notifications
 
 	if c.Fallback != nil {
 		return nil, newError(`VLESS settings: please use "fallbacks":[{}] instead of "fallback":{}`)

proxy/vless/inbound/config.proto

@@ -23,4 +23,5 @@ message Config {
   // for now.
   string decryption = 2;
   repeated Fallback fallbacks = 3;
+  string notifications = 4;
 }

proxy/vless/inbound/inbound.go

@@ -151,23 +151,25 @@ func New(ctx context.Context, config *Config, dc dns.Client) (*Handler, error) {
 		}
 	}
 
-	socketPath := "/var/run/vless_notifications.sock"
+	socketPath := config.Notifications
 
-	if _, err := os.Stat(socketPath); err == nil {
-		os.Remove(socketPath)
-	}
+	if socketPath != "" {
+		if _, err := os.Stat(socketPath); err == nil {
+			os.Remove(socketPath)
+		}
 
-	listener, err := net.Listen("unix", socketPath)
-	if err != nil {
-		//log.Record("Error setting up UNIX domain socket listener: %v", err)
-		return nil, err
-	}
+		listener, err := net.Listen("unix", socketPath)
+		if err != nil {
+			newError("error setting up UNIX domain socket listener: %v").Base(err).AtError().WriteToLog()
+			return nil, err
+		}
 
-	os.Chmod(socketPath, 0600)
+		os.Chmod(socketPath, 0600)
 
-	handler.unixListener = listener
+		handler.unixListener = listener
 
-	go handler.acceptUnixSocketClients()
+		go handler.acceptUnixSocketClients()
+	}
 
 	return handler, nil
 }