VMess AEAD will be used when alterId is 0

infra/conf/vmess.go

@@ -17,7 +17,6 @@ type VMessAccount struct {
 	ID       string `json:"id"`
 	AlterIds uint16 `json:"alterId"`
 	Security string `json:"security"`
-	TestsEnabled string `json:"testsEnabled"`
 }
 
 // Build implements Buildable
@@ -41,7 +40,6 @@ func (a *VMessAccount) Build() *vmess.Account {
 		SecuritySettings: &protocol.SecurityConfig{
 			Type: st,
 		},
-		TestsEnabled: a.TestsEnabled,
 	}
 }
 

proxy/vmess/account.go

@@ -16,8 +16,6 @@ type MemoryAccount struct {
 	AlterIDs []*protocol.ID
 	// Security type of the account. Used for client connections.
 	Security protocol.SecurityType
-
-	TestsEnabled string
 }
 
 // AnyValidID returns an ID that is either the main ID or one of the alternative IDs if any.
@@ -49,6 +47,5 @@ func (a *Account) AsAccount() (protocol.Account, error) {
 		ID:       protoID,
 		AlterIDs: protocol.NewAlterIDs(protoID, uint16(a.AlterId)),
 		Security: a.SecuritySettings.GetSecurityType(),
-		TestsEnabled: a.TestsEnabled,
 	}, nil
 }

proxy/vmess/encoding/client.go

@@ -9,12 +9,9 @@ import (
 	"crypto/rand"
 	"crypto/sha256"
 	"encoding/binary"
-	"fmt"
 	"hash"
 	"hash/fnv"
 	"io"
-	"os"
-	"strings"
 	vmessaead "v2ray.com/core/proxy/vmess/aead"
 
 	"golang.org/x/crypto/chacha20poly1305"
@@ -59,26 +56,12 @@ func NewClientSession(idHash protocol.IDHash, ctx context.Context) *ClientSessio
 
 	session.isAEADRequest = false
 
-	if ctxValueTestsEnabled := ctx.Value(vmess.TestsEnabled); ctxValueTestsEnabled != nil {
-		testsEnabled := ctxValueTestsEnabled.(string)
-		if strings.Contains(testsEnabled, "VMessAEAD") {
+	if ctxValueAlterID := ctx.Value(vmess.AlterID); ctxValueAlterID != nil {
+		if ctxValueAlterID == 0 {
 			session.isAEADRequest = true
 		}
 	}
 
-	if vmessexp, vmessexp_found := os.LookupEnv("VMESSAEADEXPERIMENT"); vmessexp_found {
-		if vmessexp == "y" {
-			session.isAEADRequest = true
-		}
-		if vmessexp == "n" {
-			session.isAEADRequest = false
-		}
-	}
-
-	if session.isAEADRequest {
-		fmt.Println("=======VMESSAEADEXPERIMENT ENABLED========")
-	}
-
 	copy(session.requestBodyKey[:], randomBytes[:16])
 	copy(session.requestBodyIV[:], randomBytes[16:32])
 	session.responseHeader = randomBytes[32]

proxy/vmess/outbound/outbound.go

@@ -113,7 +113,7 @@ func (v *Handler) Process(ctx context.Context, link *transport.Link, dialer inte
 	input := link.Reader
 	output := link.Writer
 
-	ctx = context.WithValue(ctx, vmess.TestsEnabled, user.Account.(*vmess.MemoryAccount).TestsEnabled)
+	ctx = context.WithValue(ctx, vmess.AlterID, len(account.AlterIDs))
 
 	session := encoding.NewClientSession(protocol.DefaultIDHash, ctx)
 	sessionPolicy := v.policyManager.ForLevel(request.User.Level)

proxy/vmess/vmessCtxInterface.go

@@ -1,3 +1,3 @@
 package vmess
 
-const TestsEnabled = "VMessCtxInterface_TestsEnabled"
+const AlterID = "VMessCtxInterface_AlterID"