tunnel

Documentation

Overview

Package tunnel allows to create tunnels to speak with OONI backends and other services.

You need to fill a Config object and call Start to obtain an instance of Tunnel. The tunnel will expose a SOCKS5 proxy. You need to configure your HTTP code to use such a proxy. Remember to call the Stop method of a tunnel when you are done.

There are two use cases for this package. The first use case is to enable urlgetter to perform measurements over tunnels (mainly psiphon).

The second use case is to use tunnels to reach to the OONI backend when it's blocked. For the latter case we currently mainly use psiphon. In such a case, we'll use a psiphon configuration embedded into the OONI binary itself. When you are running a version of OONI that does not embed such a configuration, it won't be possible to address this use case.

See session.go in the engine package for more details concerning this second use case.

Index

• Variables
• type Config
• type Logger
• type Session
• type Tunnel
  • func Start(ctx context.Context, config *Config) (Tunnel, error)

Variables

var ErrEmptyTunnelDir = errors.New("TunnelDir is empty")

ErrEmptyTunnelDir indicates that config.TunnelDir is empty.

var ErrTorReturnedUnsupportedProxy = errors.New(
	"tor returned unsupported proxy")

ErrTorReturnedUnsupportedProxy indicates that tor returned to us the address of a proxy that we don't support.

var ErrTorUnableToGetSOCKSProxyAddress = errors.New(
	"unable to get socks proxy address")

ErrTorUnableToGetSOCKSProxyAddress indicates that we could not get the SOCKS proxy address via the control port.

var ErrUnsupportedTunnelName = errors.New("unsupported tunnel name")

ErrUnsupportedTunnelName indicates that the given tunnel name is not supported by this package.

Types

type Config

type Config struct {
	// Name is the MANDATORY name of the tunnel. We support
	// "tor", "psiphon", and "fake" tunnels. You SHOULD
	// use "fake" tunnels only for testing: they don't provide
	// any real tunneling, just a socks5 proxy.
	Name string

	// Session is the MANDATORY measurement session, or a suitable
	// mock of the required functionality. That is, the possibility
	// of obtaining a valid psiphon configuration.
	Session Session

	// TunnelDir is the MANDATORY directory in which the tunnel SHOULD
	// store its state, if any. If this field is empty, the
	// Start function fails with ErrEmptyTunnelDir.
	TunnelDir string

	// Logger is the optional logger to use. If empty we use a default
	// implementation that does not emit any output.
	Logger Logger

	// TorArgs contains the optional arguments that you want us to pass
	// to the tor binary when invoking it. By default we do not
	// pass any extra argument. This flag might be useful to
	// configure pluggable transports.
	TorArgs []string

	// TorBinary is the optional path of the TorBinary we SHOULD be
	// executing. When not set, we execute `tor`.
	TorBinary string
	// contains filtered or unexported fields
}

Config contains the configuration for creating a Tunnel instance. You need to fill all the mandatory fields. You SHOULD NOT modify the content of this structure while in use, because that may lead to data races.

type Logger

type Logger interface {
	// Infof formats and emits an informative message
	Infof(format string, v ...interface{})
}

Logger is the logger to use. Its signature is compatibile with the apex/log logger signature.

type Session

type Session interface {
	// FetchPsiphonConfig should fetch and return the psiphon config
	// as a serialized JSON, or fail with an error.
	FetchPsiphonConfig(ctx context.Context) ([]byte, error)
}

Session is a measurement session. We filter for the only functionality we're interested to use. That is, fetching the psiphon configuration from the OONI backend (if possible).

Depending on how OONI is compiled, the psiphon configuration may be embedded into the binary. In such a case, we won't need to download the configuration from the backend.

type Tunnel

type Tunnel interface {
	// BootstrapTime returns the time it required to
	// create a new tunnel instance.
	BootstrapTime() time.Duration

	// SOCKS5ProxyURL returns the SOCSK5 proxy URL.
	SOCKS5ProxyURL() *url.URL

	// Stop stops the tunnel. You should not attempt to
	// use any other tunnel method after Stop.
	Stop()
}

Tunnel is a tunnel for communicating with OONI backends (and other services) to circumvent blocking.

func Start

func Start(ctx context.Context, config *Config) (Tunnel, error)

Start starts a new tunnel by name or returns an error. We currently support the following tunnels:

The "tor" tunnel requires the "tor" binary to be installed on your system. You can use config.TorArgs and config.TorBinary to select what binary to execute and with which arguments.

The "psiphon" tunnel requires a configuration. Some builds of ooniprobe embed a configuration into the binary. When this is the case, the config.Session is a mocked object that just returns such a configuration.

Otherwise, If there is no embedded psiphon configuration, the config.Session must be an ordinary engine.Session. In such a case, fetching the Psiphon configuration from the backend may fail when the backend is not reachable.

The "fake" tunnel is a fake tunnel that just exposes a SOCKS5 proxy and then connects directly to server. We use this special kind of tunnel to implement tests.