1
0
mirror of https://github.com/v2fly/v2ray-core.git synced 2024-12-22 18:17:52 -05:00
v2fly/functions.go

86 lines
2.7 KiB
Go
Raw Normal View History

//go:build !confonly
2019-02-01 14:08:21 -05:00
// +build !confonly
2018-05-31 05:55:11 -04:00
package core
import (
2018-11-17 16:45:07 -05:00
"bytes"
2018-05-31 05:55:11 -04:00
"context"
2021-02-16 15:31:50 -05:00
"github.com/v2fly/v2ray-core/v4/common"
"github.com/v2fly/v2ray-core/v4/common/net"
"github.com/v2fly/v2ray-core/v4/features/routing"
"github.com/v2fly/v2ray-core/v4/transport/internet/udp"
2018-05-31 05:55:11 -04:00
)
// CreateObject creates a new object based on the given V2Ray instance and config. The V2Ray instance may be nil.
func CreateObject(v *Instance, config interface{}) (interface{}, error) {
var ctx context.Context
2018-05-31 05:55:11 -04:00
if v != nil {
2021-04-05 13:13:24 -04:00
ctx = toContext(v.ctx, v)
2018-05-31 05:55:11 -04:00
}
return common.CreateObject(ctx, config)
}
2018-09-21 10:54:06 -04:00
2018-10-11 17:36:38 -04:00
// StartInstance starts a new V2Ray instance with given serialized config.
2018-10-16 08:23:10 -04:00
// By default V2Ray only support config in protobuf format, i.e., configFormat = "protobuf". Caller need to load other packages to add JSON support.
2018-12-03 16:44:42 -05:00
//
// v2ray:api:stable
2018-10-11 17:36:38 -04:00
func StartInstance(configFormat string, configBytes []byte) (*Instance, error) {
2018-11-17 16:45:07 -05:00
config, err := LoadConfig(configFormat, "", bytes.NewReader(configBytes))
if err != nil {
return nil, err
}
instance, err := New(config)
if err != nil {
return nil, err
}
if err := instance.Start(); err != nil {
return nil, err
}
return instance, nil
}
2018-10-13 09:21:52 -04:00
// Dial provides an easy way for upstream caller to create net.Conn through V2Ray.
// It dispatches the request to the given destination by the given V2Ray instance.
// Since it is under a proxy context, the LocalAddr() and RemoteAddr() in returned net.Conn
// will not show real addresses being used for communication.
2018-12-03 16:44:42 -05:00
//
// v2ray:api:stable
2018-10-13 09:21:52 -04:00
func Dial(ctx context.Context, v *Instance, dest net.Destination) (net.Conn, error) {
2021-04-05 13:13:24 -04:00
ctx = toContext(ctx, v)
2021-04-02 08:11:07 -04:00
2018-10-21 04:27:13 -04:00
dispatcher := v.GetFeature(routing.DispatcherType())
if dispatcher == nil {
return nil, newError("routing.Dispatcher is not registered in V2Ray core")
}
2018-10-21 04:27:13 -04:00
r, err := dispatcher.(routing.Dispatcher).Dispatch(ctx, dest)
2018-10-13 09:21:52 -04:00
if err != nil {
return nil, err
}
2019-01-05 18:34:38 -05:00
var readerOpt net.ConnectionOption
if dest.Network == net.Network_TCP {
readerOpt = net.ConnectionOutputMulti(r.Reader)
} else {
readerOpt = net.ConnectionOutputMultiUDP(r.Reader)
}
return net.NewConnection(net.ConnectionInputMulti(r.Writer), readerOpt), nil
2018-10-13 09:21:52 -04:00
}
2019-01-05 15:43:22 -05:00
// DialUDP provides a way to exchange UDP packets through V2Ray instance to remote servers.
// Since it is under a proxy context, the LocalAddr() in returned PacketConn will not show the real address.
//
// TODO: SetDeadline() / SetReadDeadline() / SetWriteDeadline() are not implemented.
//
// v2ray:api:beta
func DialUDP(ctx context.Context, v *Instance) (net.PacketConn, error) {
2021-04-05 13:13:24 -04:00
ctx = toContext(ctx, v)
2021-04-02 08:11:07 -04:00
2019-01-05 15:43:22 -05:00
dispatcher := v.GetFeature(routing.DispatcherType())
if dispatcher == nil {
return nil, newError("routing.Dispatcher is not registered in V2Ray core")
}
return udp.DialDispatcher(ctx, dispatcher.(routing.Dispatcher))
}