update

Hunter0x7c7

2022-08-11 b8230139fb40edea387617b6accd8371e37eda58

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
//go:build !confonly 
// +build !confonly 
 
package loopback 
 
import ( 
    "context" 
 
    core "github.com/v2fly/v2ray-core/v5" 
    "github.com/v2fly/v2ray-core/v5/common" 
    "github.com/v2fly/v2ray-core/v5/common/buf" 
    "github.com/v2fly/v2ray-core/v5/common/net" 
    "github.com/v2fly/v2ray-core/v5/common/retry" 
    "github.com/v2fly/v2ray-core/v5/common/session" 
    "github.com/v2fly/v2ray-core/v5/common/task" 
    "github.com/v2fly/v2ray-core/v5/features/routing" 
    "github.com/v2fly/v2ray-core/v5/transport" 
    "github.com/v2fly/v2ray-core/v5/transport/internet" 
) 
 
type Loopback struct { 
    config             *Config 
    dispatcherInstance routing.Dispatcher 
} 
 
func (l *Loopback) Process(ctx context.Context, link *transport.Link, _ internet.Dialer) error { 
    outbound := session.OutboundFromContext(ctx) 
    if outbound == nil || !outbound.Target.IsValid() { 
        return newError("target not specified.") 
    } 
    destination := outbound.Target 
 
    newError("opening connection to ", destination).WriteToLog(session.ExportIDToError(ctx)) 
 
    input := link.Reader 
    output := link.Writer 
 
    var conn internet.Connection 
    err := retry.ExponentialBackoff(5, 100).On(func() error { 
        dialDest := destination 
 
        content := new(session.Content) 
        content.SkipDNSResolve = true 
 
        ctx = session.ContextWithContent(ctx, content) 
 
        inbound := session.InboundFromContext(ctx) 
 
        inbound.Tag = l.config.InboundTag 
 
        ctx = session.ContextWithInbound(ctx, inbound) 
 
        rawConn, err := l.dispatcherInstance.Dispatch(ctx, dialDest) 
        if err != nil { 
            return err 
        } 
 
        var readerOpt net.ConnectionOption 
        if dialDest.Network == net.Network_TCP { 
            readerOpt = net.ConnectionOutputMulti(rawConn.Reader) 
        } else { 
            readerOpt = net.ConnectionOutputMultiUDP(rawConn.Reader) 
        } 
 
        conn = net.NewConnection(net.ConnectionInputMulti(rawConn.Writer), readerOpt) 
        return nil 
    }) 
    if err != nil { 
        return newError("failed to open connection to ", destination).Base(err) 
    } 
    defer conn.Close() 
 
    requestDone := func() error { 
        var writer buf.Writer 
        if destination.Network == net.Network_TCP { 
            writer = buf.NewWriter(conn) 
        } else { 
            writer = &buf.SequentialWriter{Writer: conn} 
        } 
 
        if err := buf.Copy(input, writer); err != nil { 
            return newError("failed to process request").Base(err) 
        } 
 
        return nil 
    } 
 
    responseDone := func() error { 
        var reader buf.Reader 
        if destination.Network == net.Network_TCP { 
            reader = buf.NewReader(conn) 
        } else { 
            reader = buf.NewPacketReader(conn) 
        } 
        if err := buf.Copy(reader, output); err != nil { 
            return newError("failed to process response").Base(err) 
        } 
 
        return nil 
    } 
 
    if err := task.Run(ctx, requestDone, task.OnSuccess(responseDone, task.Close(output))); err != nil { 
        return newError("connection ends").Base(err) 
    } 
 
    return nil 
} 
 
func (l *Loopback) init(config *Config, dispatcherInstance routing.Dispatcher) error { 
    l.dispatcherInstance = dispatcherInstance 
    l.config = config 
    return nil 
} 
 
func init() { 
    common.Must(common.RegisterConfig((*Config)(nil), func(ctx context.Context, config interface{}) (interface{}, error) { 
        l := new(Loopback) 
        err := core.RequireFeatures(ctx, func(dispatcherInstance routing.Dispatcher) error { 
            return l.init(config.(*Config), dispatcherInstance) 
        }) 
        return l, err 
    })) 
}