Merge pull request #2667 from v2fly/master

merge fly

Author: kslr

.github/workflows/docker.yaml

@@ -0,0 +1,43 @@
+name: Release Docker Image
+
+on:
+  push:
+    tags:
+      - v*
+
+jobs:
+  release:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Set up Checkout
+        uses: actions/checkout@v2
+
+      - name: Install Buildx and QEMU
+        run: |
+          export DOCKER_BUILDKIT=1
+          docker build --platform=local -o . git://github.com/docker/buildx
+          mkdir -p ~/.docker/cli-plugins
+          mv buildx ~/.docker/cli-plugins/docker-buildx
+          docker run --rm --privileged multiarch/qemu-user-static:latest --reset -p yes --credential yes
+          docker buildx create --use --name build --node build --driver-opt network=host
+
+      - name: Log in to Docker Hub
+        env:
+          DOCKER_USERNAME: ${{ secrets.DOCKER_USERNAME }}
+          DOCKER_PASSWORD: ${{ secrets.DOCKER_PASSWORD }}
+        run: |
+          echo "${DOCKER_PASSWORD}" | docker login --username ${DOCKER_USERNAME} --password-stdin
+
+      - name: Build and push Docker image
+        env:
+          DOCKER_USERNAME: ${{ secrets.DOCKER_USERNAME }}
+          DOCKER_IMAGE_PLATFORM: linux/386,linux/amd64,linux/arm/v7,linux/arm64
+        run: |
+          DOCKER_IMAGE_NAME=$(echo $DOCKER_USERNAME | tr '[:upper:]' '[:lower:]')/v2fly-core
+          DOCKER_IMAGE_VERSION=${GITHUB_REF#refs/*/}
+          docker buildx build \
+            --platform "$DOCKER_IMAGE_PLATFORM" \
+            --output "type=image,push=true" \
+            --tag "$DOCKER_IMAGE_NAME":"$DOCKER_IMAGE_VERSION" \
+            --tag "$DOCKER_IMAGE_NAME":latest \
+            --file ./Dockerfile .

Dockerfile

@@ -2,7 +2,7 @@
 # STEP 1 build executable binary
 ############################
 FROM golang:alpine AS builder
-RUN apk update && apk add --no-cache git bash wget
+RUN apk update && apk add --no-cache git bash wget curl
 WORKDIR /go/src/v2ray.com/core
 RUN git clone --progress https://github.com/v2fly/v2ray-core.git . && \
     bash ./release/user-package.sh nosource noconf codename=$(git describe --tags) buildname=docker-fly abpathtgz=/tmp/v2ray.tgz

app/dns/dohdns.go

@@ -58,6 +58,7 @@ func NewDoHNameServer(url *url.URL, dispatcher routing.Dispatcher, clientIP net.
 		MaxIdleConns:        30,
 		IdleConnTimeout:     90 * time.Second,
 		TLSHandshakeTimeout: 30 * time.Second,
+		ForceAttemptHTTP2:   true,
 		DialContext: func(ctx context.Context, network, addr string) (net.Conn, error) {
 			dest, err := net.ParseDestination(network + ":" + addr)
 			if err != nil {
@@ -89,7 +90,8 @@ func NewDoHLocalNameServer(url *url.URL, clientIP net.IP) *DoHNameServer {
 	url.Scheme = "https"
 	s := baseDOHNameServer(url, "DOHL", clientIP)
 	tr := &http.Transport{
-		IdleConnTimeout: 90 * time.Second,
+		IdleConnTimeout:   90 * time.Second,
+		ForceAttemptHTTP2: true,
 		DialContext: func(ctx context.Context, network, addr string) (net.Conn, error) {
 			dest, err := net.ParseDestination(network + ":" + addr)
 			if err != nil {

app/proxyman/inbound/inbound.go

@@ -150,6 +150,13 @@ func NewHandler(ctx context.Context, config *core.InboundHandlerConfig) (inbound
 		return nil, newError("not a ReceiverConfig").AtError()
 	}
 
+	streamSettings := receiverSettings.StreamSettings
+	if streamSettings != nil && streamSettings.SocketSettings != nil {
+		ctx = session.ContextWithSockopt(ctx, &session.Sockopt{
+			Mark: streamSettings.SocketSettings.Mark,
+		})
+	}
+
 	allocStrategy := receiverSettings.AllocationStrategy
 	if allocStrategy == nil || allocStrategy.Type == proxyman.AllocationStrategy_Always {
 		return NewAlwaysOnInboundHandler(ctx, tag, receiverSettings, proxySettings)

azure-pipelines.template.yml

@@ -2,71 +2,25 @@ trigger:
   batch: true
   branches:
     include:
-    - master
-    - dev*
-    - refs/tags/*
+      - master
+      - dev*
+      - refs/tags/*
 
-pr:
-  - master
-  - dev*
+pool:
+  vmImage: 'ubuntu-latest'
 
-jobs:
-- template: azure-pipelines.template.yml
-  parameters:
-    name: linux
-    vmImage: 'ubuntu-latest'
+variables:
+  - group: GithubToken
+  - name: GOPATH
+    value: '$(system.defaultWorkingDirectory)/gopath'
+  - name: BAZEL_VER
+    value: '0.23.0'
 
-- template: azure-pipelines.template.yml
-  parameters:
-    name: windows
-    vmImage: 'windows-latest'
-
-- template: azure-pipelines.template.yml
-  parameters:
-    name: macos
-    vmImage: 'macOS-latest'
-
-- job: linux_coverage
-  dependsOn: linux
-  condition: and(succeeded(), ne(variables['Build.Reason'], 'PullRequest'))
-  timeoutInMinutes: 30
-
-  pool:
-    vmImage: 'ubuntu-latest'
-
-#variables:
-#    CODECOV_TOKEN: '$(coverage.token)'
-
-
-  steps:
-  - checkout: self
-  - task: GoTool@0
-    inputs:
-      version: '1.14.4'
-  - script: |
-      bash ./testing/coverage/coverall
-    workingDirectory: '$(Build.SourcesDirectory)'
-    displayName: 'Coverage'
-
-- job: make_release
-  dependsOn: linux
-  condition: and(succeeded(), ne(variables['Build.Reason'], 'PullRequest'))
-  timeoutInMinutes: 60
-
-  pool:
-    vmImage: 'ubuntu-latest'
-  variables:
-    - group: GithubToken
-    - name: GOPATH
-      value: '$(system.defaultWorkingDirectory)/gopath'
-    - name: BAZEL_VER
-      value: '0.23.0'
-
-  steps:
+steps:
   - checkout: self
   - task: GoTool@0
     inputs:
-      version: '1.14.4'
+      version: '1.14.6'
   - script: |
       mkdir triggersrc
       ls -I "triggersrc" | xargs cp -rf -t triggersrc

azure-pipelines.yml

@@ -22,7 +22,7 @@ func TestBufferClear(t *testing.T) {
 
 	buffer.Clear()
 	if buffer.Len() != 0 {
-		t.Error("expect 0 lenght, but got ", buffer.Len())
+		t.Error("expect 0 length, but got ", buffer.Len())
 	}
 }
 

common/buf/buffer_test.go

@@ -248,13 +248,14 @@ func (w *AuthenticationWriter) seal(b []byte) (*buf.Buffer, error) {
 		paddingSize = int32(w.padding.NextPaddingLen())
 	}
 
-	totalSize := encryptedSize + paddingSize
+	sizeBytes := w.sizeParser.SizeBytes()
+	totalSize := sizeBytes + encryptedSize + paddingSize
 	if totalSize > buf.Size {
 		return nil, newError("size too large: ", totalSize)
 	}
 
 	eb := buf.New()
-	w.sizeParser.Encode(uint16(encryptedSize+paddingSize), eb.Extend(w.sizeParser.SizeBytes()))
+	w.sizeParser.Encode(uint16(encryptedSize+paddingSize), eb.Extend(sizeBytes))
 	if _, err := w.auth.Seal(eb.Extend(encryptedSize)[:0], b); err != nil {
 		eb.Release()
 		return nil, err

common/crypto/auth.go

@@ -35,7 +35,7 @@ func (s *Server) Type() interface{} {
 	return s.dispatcher.Type()
 }
 
-// Dispatch impliments routing.Dispatcher
+// Dispatch implements routing.Dispatcher
 func (s *Server) Dispatch(ctx context.Context, dest net.Destination) (*transport.Link, error) {
 	if dest.Address != muxCoolAddress {
 		return s.dispatcher.Dispatch(ctx, dest)

common/mux/server.go

@@ -10,6 +10,7 @@ const (
 	outboundSessionKey
 	contentSessionKey
 	muxPreferedSessionKey
+	sockoptSessionKey
 )
 
 // ContextWithID returns a new context with the given ID.
@@ -70,3 +71,16 @@ func MuxPreferedFromContext(ctx context.Context) bool {
 	}
 	return false
 }
+
+// ContextWithSockopt returns a new context with Socket configs included
+func ContextWithSockopt(ctx context.Context, s *Sockopt) context.Context {
+	return context.WithValue(ctx, sockoptSessionKey, s)
+}
+
+// SockoptFromContext returns Socket configs in this context, or nil if not contained.
+func SockoptFromContext(ctx context.Context) *Sockopt {
+	if sockopt, ok := ctx.Value(sockoptSessionKey).(*Sockopt); ok {
+		return sockopt
+	}
+	return nil
+}