Made the other three modes work

6 files changed, 257 insertions, 149 deletions

diff --git a/modes/pt_socks5/pt_socks5.go b/modes/pt_socks5/pt_socks5.go
index e2aa546..cb7c974 100644
--- a/modes/pt_socks5/pt_socks5.go
+++ b/modes/pt_socks5/pt_socks5.go
@@ -33,6 +33,7 @@ import (
 	"fmt"
 	options2 "github.com/OperatorFoundation/shapeshifter-dispatcher/common"
 	"github.com/OperatorFoundation/shapeshifter-dispatcher/common/pt_extras"
+	"github.com/OperatorFoundation/shapeshifter-dispatcher/transports"
 	"github.com/OperatorFoundation/shapeshifter-transports/transports/Dust"
 	replicant "github.com/OperatorFoundation/shapeshifter-transports/transports/Replicant"
 	"github.com/OperatorFoundation/shapeshifter-transports/transports/meeklite"
@@ -41,7 +42,6 @@ import (
 	"io"
 	"net"
 	"net/url"
-	"strconv"
 	"sync"
 
 	"github.com/OperatorFoundation/shapeshifter-dispatcher/common/log"
@@ -156,13 +156,13 @@ func clientHandler(name string, conn net.Conn, proxyURI *url.URL, options string
 	return
 }
 
-func ServerSetup(ptServerInfo pt.ServerInfo, options string) (launched bool, listeners []net.Listener) {
+func ServerSetup(ptServerInfo pt.ServerInfo, statedir string, options string) (launched bool, listeners []net.Listener) {
 	for _, bindaddr := range ptServerInfo.Bindaddrs {
 		name := bindaddr.MethodName
 
 		var listen func(address string) net.Listener
 
-		args, argsErr := pt.ParsePT2ClientParameters(options)
+		args, argsErr := options2.ParseServerOptions(options)
 		if argsErr != nil {
 			log.Errorf("Error parsing transport options: %s", options)
 			return
@@ -174,65 +174,92 @@ func ServerSetup(ptServerInfo pt.ServerInfo, options string) (launched bool, lis
 			transport := obfs2.NewObfs2Transport()
 			listen = transport.Listen
 		case "obfs4":
-			var dialer proxy.Dialer
-			if cert, ok := args["cert"]; ok {
-				if iatModeStr, ok2 := args["iat-mode"]; ok2 {
-					iatMode, err := strconv.Atoi(iatModeStr[0])
-					if err != nil {
-						transport := obfs4.NewObfs4Client(cert[0], iatMode, dialer)
-						listen = transport.Listen
-					} else {
-						log.Errorf("obfs4 transport bad iat-mode value: %s", iatModeStr)
-						return
-					}
-				} else {
-					log.Errorf("obfs4 transport missing cert argument: %s", args)
-					return
-				}
-			} else {
-				log.Errorf("obfs4 transport missing cert argument: %s", args)
-				return
-			}
+			transport := obfs4.NewObfs4Server(statedir)
+			listen = transport.Listen
 		case "replicant":
-			config, ok := args.Get("config")
-			fmt.Println(config)
-			if !ok {
+			shargs, aok := args["Replicant"]
+			if !aok {
 				return false, nil
 			}
-			transport := replicant.New(replicant.Config{})
+
+			config, err := transports.ParseReplicantConfig(shargs)
+			if err != nil {
+				return false, nil
+			}
+			transport := replicant.New(*config)
 			listen = transport.Listen
 		case "Dust":
-			idPath, ok := args.Get("idPath")
+			shargs, aok := args["Dust"]
+			if !aok {
+				return false, nil
+			}
+
+			untypedIdPath, ok := shargs["Url"]
 			if !ok {
 				return false, nil
 			}
+			idPath, err := options2.CoerceToString(untypedIdPath)
+			if err != nil {
+				log.Errorf("could not coerce Dust Url to string")
+				return false, nil
+			}
 			transport := Dust.NewDustServer(idPath)
 			listen = transport.Listen
 		case "meeklite":
-			Url, ok := args.Get("Url")
+			args, aok := args["meeklite"]
+			if !aok {
+				return false, nil
+			}
+
+			untypedUrl, ok := args["Url"]
 			if !ok {
 				return false, nil
 			}
 
-			Front, ok2 := args.Get("Front")
-			if !ok2 {
+			Url, err := options2.CoerceToString(untypedUrl)
+			if err != nil {
+				log.Errorf("could not coerce meeklite Url to string")
+			}
+
+			untypedFront, ok := args["front"]
+			if !ok {
 				return false, nil
 			}
-			transport := meeklite.NewMeekTransportWithFront(Url, Front)
-			listen = transport.Listen
 
+			front, err2 := options2.CoerceToString(untypedFront)
+			if err2 != nil {
+				log.Errorf("could not coerce meeklite front to string")
+			}
+
+			transport := meeklite.NewMeekTransportWithFront(Url, front)
+			listen = transport.Listen
 		case "shadow":
-			password, ok := args.Get("password")
+			args, aok := args["shadow"]
+			if !aok {
+				return false, nil
+			}
+
+			untypedPassword, ok := args["password"]
 			if !ok {
 				return false, nil
 			}
 
-			cipherName, ok2 := args.Get("cipherName")
-			if !ok2 {
+			Password, err := options2.CoerceToString(untypedPassword)
+			if err != nil {
+				log.Errorf("could not coerce shadow password to string")
+			}
+
+			untypedCertString, ok := args["Url"]
+			if !ok {
 				return false, nil
 			}
 
-			transport := shadow.NewShadowServer(password, cipherName)
+			certString, err2 := options2.CoerceToString(untypedCertString)
+			if err2 != nil {
+				log.Errorf("could not coerce meeklite Url to string")
+			}
+
+			transport := shadow.NewShadowServer(Password, certString)
 			listen = transport.Listen
 		default:
 			log.Errorf("Unknown transport: %s", name)
diff --git a/modes/stun_udp/stun_udp.go b/modes/stun_udp/stun_udp.go
index 3d72b69..e6d991c 100644
--- a/modes/stun_udp/stun_udp.go
+++ b/modes/stun_udp/stun_udp.go
@@ -33,6 +33,7 @@ import (
 	"fmt"
 	options2 "github.com/OperatorFoundation/shapeshifter-dispatcher/common"
 	"github.com/OperatorFoundation/shapeshifter-dispatcher/common/pt_extras"
+	"github.com/OperatorFoundation/shapeshifter-dispatcher/transports"
 	"github.com/OperatorFoundation/shapeshifter-transports/transports/Dust"
 	replicant "github.com/OperatorFoundation/shapeshifter-transports/transports/Replicant"
 	"github.com/OperatorFoundation/shapeshifter-transports/transports/meeklite"
@@ -189,7 +190,7 @@ func dialConn(tracker *ConnTracker, addr string, target string, name string, opt
 	(*tracker)[addr] = ConnState{remote, false}
 }
 
-func ServerSetup(ptServerInfo pt.ServerInfo, options string, stateDir string) (launched bool, listeners []net.Listener) {
+func ServerSetup(ptServerInfo pt.ServerInfo,  stateDir string, options string) (launched bool, listeners []net.Listener) {
 	fmt.Println("ServerSetup")
 
 	// Launch each of the server listeners.
@@ -199,7 +200,7 @@ func ServerSetup(ptServerInfo pt.ServerInfo, options string, stateDir string) (l
 
 		var listen func(address string) net.Listener
 
-		args, argsErr := pt.ParsePT2ClientParameters(options)
+		args, argsErr := options2.ParseServerOptions(options)
 		if argsErr != nil {
 			log.Errorf("Error parsing transport options: %s", options)
 			return
@@ -213,50 +214,92 @@ func ServerSetup(ptServerInfo pt.ServerInfo, options string, stateDir string) (l
 		case "obfs4":
 			transport := obfs4.NewObfs4Server(stateDir)
 			listen = transport.Listen
+		case "Replicant":
+			shargs, aok := args["Replicant"]
+			if !aok {
+				return false, nil
+			}
+
+			config, err := transports.ParseReplicantConfig(shargs)
+			if err != nil {
+				return false, nil
+			}
+			transport := replicant.New(*config)
+			listen = transport.Listen
 		case "meeklite":
-			if Url, ok := args["Url"]; ok {
-				if Front, ok2 := args["Front"]; ok2 {
-					transport := meeklite.NewMeekTransportWithFront(Url[0], Front[0])
-					listen = transport.Listen
-				} else {
-					log.Errorf("meeklite transport missing Url argument: %s", args)
-					return
-				}
-			} else {
-				log.Errorf("meeklite transport missing Front argument: %s", args)
-				return
+			args, aok := args["meeklite"]
+			if !aok {
+				return false, nil
 			}
-		case "replicant":
-			if config, ok := args["config"]; ok {
-				fmt.Println(config)
-				transport := replicant.New(replicant.Config{})
-				listen = transport.Listen
-			} else {
-				log.Errorf("replicant transport missing config argument: %s", args)
-				return
+
+			untypedUrl, ok := args["Url"]
+			if !ok {
+				return false, nil
 			}
+
+			Url, err := options2.CoerceToString(untypedUrl)
+			if err != nil {
+				log.Errorf("could not coerce meeklite Url to string")
+			}
+
+			untypedFront, ok := args["front"]
+			if !ok {
+				return false, nil
+			}
+
+			front, err2 := options2.CoerceToString(untypedFront)
+			if err2 != nil {
+				log.Errorf("could not coerce meeklite front to string")
+			}
+
+			transport := meeklite.NewMeekTransportWithFront(Url, front)
+			listen = transport.Listen
 		case "Dust":
-			if idPath, ok := args["idPath"]; ok {
-				transport := Dust.NewDustServer(idPath[0])
-				listen = transport.Listen
-			} else {
-				log.Errorf("Dust transport missing idPath argument: %s", args)
-				return
+			shargs, aok := args["Dust"]
+			if !aok {
+				return false, nil
+			}
+
+			untypedIdPath, ok := shargs["Url"]
+			if !ok {
+				return false, nil
 			}
+			idPath, err := options2.CoerceToString(untypedIdPath)
+			if err != nil {
+				log.Errorf("could not coerce Dust Url to string")
+				return false, nil
+			}
+			transport := Dust.NewDustServer(idPath)
+			listen = transport.Listen
 		case "shadow":
-			if password, ok := args["password"]; ok {
-				if cipher, ok2 := args["cipherName"]; ok2 {
-					transport := shadow.NewShadowClient(password[0], cipher[0])
-					listen = transport.Listen
-				} else {
-					log.Errorf("shadow transport missing cipher argument: %s", args)
-					return
-				}
-			} else {
-				log.Errorf("shadow transport missing password argument: %s", args)
-				return
+			args, aok := args["shadow"]
+			if !aok {
+				return false, nil
+			}
+
+			untypedPassword, ok := args["password"]
+			if !ok {
+				return false, nil
 			}
 
+			Password, err := options2.CoerceToString(untypedPassword)
+			if err != nil {
+				log.Errorf("could not coerce shadow password to string")
+			}
+
+			untypedCertString, ok := args["Url"]
+			if !ok {
+				return false, nil
+			}
+
+			certString, err2 := options2.CoerceToString(untypedCertString)
+			if err2 != nil {
+				log.Errorf("could not coerce meeklite Url to string")
+			}
+
+			transport := shadow.NewShadowServer(Password, certString)
+			listen = transport.Listen
+
 		default:
 			log.Errorf("Unknown transport: %s", name)
 			return
diff --git a/modes/transparent_tcp/transparent_tcp.go b/modes/transparent_tcp/transparent_tcp.go
index c1482bb..06597e0 100644
--- a/modes/transparent_tcp/transparent_tcp.go
+++ b/modes/transparent_tcp/transparent_tcp.go
@@ -33,7 +33,9 @@ import (
 	"fmt"
 	options2 "github.com/OperatorFoundation/shapeshifter-dispatcher/common"
 	"github.com/OperatorFoundation/shapeshifter-dispatcher/common/pt_extras"
+	"github.com/OperatorFoundation/shapeshifter-dispatcher/transports"
 	"github.com/OperatorFoundation/shapeshifter-transports/transports/Dust"
+	replicant "github.com/OperatorFoundation/shapeshifter-transports/transports/Replicant"
 	"github.com/OperatorFoundation/shapeshifter-transports/transports/meeklite"
 	"github.com/OperatorFoundation/shapeshifter-transports/transports/obfs2"
 	"golang.org/x/net/proxy"
@@ -140,23 +142,18 @@ func ServerSetup(ptServerInfo pt.ServerInfo, statedir string, options string) (l
 		case "obfs4":
 			transport := obfs4.NewObfs4Server(statedir)
 			listen = transport.Listen
-			//FIXME make replicant case work for server side
-		//case "Replicant":
-		//	shargs, aok := args["Replicant"]
-		//	if !aok {
-		//		return false, nil
-		//	}
-		//
-		//	configString, ok := shargs.Get("config")
-		//	if !ok {
-		//		return false, nil
-		//	}
-		//	config, err := transports.ParseReplicantConfig(configString)
-		//	if err != nil {
-		//		return false, nil
-		//	}
-		//	transport := replicant.New(config)
-		//	listen = transport.Listen
+		case "Replicant":
+			shargs, aok := args["Replicant"]
+			if !aok {
+				return false, nil
+			}
+
+			config, err := transports.ParseReplicantConfig(shargs)
+			if err != nil {
+				return false, nil
+			}
+			transport := replicant.New(*config)
+			listen = transport.Listen
 		case "Dust":
 			shargs, aok := args["Dust"]
 			if !aok {
diff --git a/modes/transparent_udp/transparent_udp.go b/modes/transparent_udp/transparent_udp.go
index 506637e..ab0504e 100644
--- a/modes/transparent_udp/transparent_udp.go
+++ b/modes/transparent_udp/transparent_udp.go
@@ -36,6 +36,7 @@ import (
 	options2 "github.com/OperatorFoundation/shapeshifter-dispatcher/common"
 	"github.com/OperatorFoundation/shapeshifter-dispatcher/common/log"
 	"github.com/OperatorFoundation/shapeshifter-dispatcher/common/pt_extras"
+	"github.com/OperatorFoundation/shapeshifter-dispatcher/transports"
 	"github.com/OperatorFoundation/shapeshifter-ipc"
 	"github.com/OperatorFoundation/shapeshifter-transports/transports/Dust"
 	replicant "github.com/OperatorFoundation/shapeshifter-transports/transports/Replicant"
@@ -48,7 +49,6 @@ import (
 	golog "log"
 	"net"
 	"net/url"
-	"strconv"
 	//"github.com/OperatorFoundation/shapeshifter-transports/transports/Optimizer"
 	//"github.com/OperatorFoundation/shapeshifter-transports/transports/shadow"
 )
@@ -208,7 +208,7 @@ func dialConn(tracker *ConnTracker, addr string, target string, name string, opt
 	(*tracker)[addr] = ConnState{remote, false}
 }
 
-func ServerSetup(ptServerInfo pt.ServerInfo, options string) (launched bool, listeners []net.Listener) {
+func ServerSetup(ptServerInfo pt.ServerInfo, stateDir string, options string) (launched bool, listeners []net.Listener) {
 	fmt.Println("ServerSetup")
 
 	// Launch each of the server listeners.
@@ -218,7 +218,7 @@ func ServerSetup(ptServerInfo pt.ServerInfo, options string) (launched bool, lis
 
 		var listen func(address string) net.Listener
 
-		args, argsErr := pt.ParsePT2ClientParameters(options)
+		args, argsErr := options2.ParseServerOptions(options)
 		if argsErr != nil {
 			log.Errorf("Error parsing transport options: %s", options)
 			return
@@ -230,67 +230,92 @@ func ServerSetup(ptServerInfo pt.ServerInfo, options string) (launched bool, lis
 			transport := obfs2.NewObfs2Transport()
 			listen = transport.Listen
 		case "obfs4":
-			var dialer proxy.Dialer
-			if cert, ok := args["cert"]; ok {
-				if iatModeStr, ok2 := args["iat-mode"]; ok2 {
-					iatMode, err := strconv.Atoi(iatModeStr[0])
-					if err != nil {
-						transport := obfs4.NewObfs4Client(cert[0], iatMode, dialer)
-						listen = transport.Listen
-					} else {
-						log.Errorf("obfs4 transport bad iat-mode value: %s", iatModeStr)
-						return
-					}
-				} else {
-					log.Errorf("obfs4 transport missing cert argument: %s", args)
-					return
-				}
-			} else {
-				log.Errorf("obfs4 transport missing cert argument: %s", args)
-				return
-			}
+			transport := obfs4.NewObfs4Server(stateDir)
+			listen = transport.Listen
 		case "Replicant":
-			config, ok := args.Get("config")
-			fmt.Println(config)
-			if !ok {
+			shargs, aok := args["Replicant"]
+			if !aok {
 				return false, nil
 			}
 
-			transport := replicant.New(replicant.Config{})
+			config, err := transports.ParseReplicantConfig(shargs)
+			if err != nil {
+				return false, nil
+			}
+			transport := replicant.New(*config)
 			listen = transport.Listen
 		case "Dust":
-			idPath, ok := args.Get("idPath")
-			if !ok {
+			shargs, aok := args["Dust"]
+			if !aok {
 				return false, nil
 			}
 
+			untypedIdPath, ok := shargs["Url"]
+			if !ok {
+				return false, nil
+			}
+			idPath, err := options2.CoerceToString(untypedIdPath)
+			if err != nil {
+				log.Errorf("could not coerce Dust Url to string")
+				return false, nil
+			}
 			transport := Dust.NewDustServer(idPath)
 			listen = transport.Listen
 		case "meeklite":
-			Url, ok := args.Get("Url")
+			args, aok := args["meeklite"]
+			if !aok {
+				return false, nil
+			}
+
+			untypedUrl, ok := args["Url"]
 			if !ok {
 				return false, nil
 			}
 
-			Front, ok2 := args.Get("Front")
-			if !ok2 {
+			Url, err := options2.CoerceToString(untypedUrl)
+			if err != nil {
+				log.Errorf("could not coerce meeklite Url to string")
+			}
+
+			untypedFront, ok := args["front"]
+			if !ok {
 				return false, nil
 			}
 
-			transport := meeklite.NewMeekTransportWithFront(Url, Front)
+			front, err2 := options2.CoerceToString(untypedFront)
+			if err2 != nil {
+				log.Errorf("could not coerce meeklite front to string")
+			}
+
+			transport := meeklite.NewMeekTransportWithFront(Url, front)
 			listen = transport.Listen
 		case "shadow":
-			password, ok := args.Get("password")
+			args, aok := args["shadow"]
+			if !aok {
+				return false, nil
+			}
+
+			untypedPassword, ok := args["password"]
 			if !ok {
 				return false, nil
 			}
 
-			cipherName, ok2 := args.Get("cipherName")
-			if !ok2 {
+			Password, err := options2.CoerceToString(untypedPassword)
+			if err != nil {
+				log.Errorf("could not coerce shadow password to string")
+			}
+
+			untypedCertString, ok := args["Url"]
+			if !ok {
 				return false, nil
 			}
 
-			transport := shadow.NewShadowServer(password, cipherName)
+			certString, err2 := options2.CoerceToString(untypedCertString)
+			if err2 != nil {
+				log.Errorf("could not coerce meeklite Url to string")
+			}
+
+			transport := shadow.NewShadowServer(Password, certString)
 			listen = transport.Listen
 		default:
 			log.Errorf("Unknown transport: %s", name)
diff --git a/shapeshifter-dispatcher/shapeshifter-dispatcher.go b/shapeshifter-dispatcher/shapeshifter-dispatcher.go
index 59263e2..83b4b24 100644
--- a/shapeshifter-dispatcher/shapeshifter-dispatcher.go
+++ b/shapeshifter-dispatcher/shapeshifter-dispatcher.go
@@ -79,8 +79,7 @@ func main() {
 	}
 
 	// PT 2.0 specification, 3.3.1.1. Common Configuration Parameters
-	// FIXME: in the spec, this is -version, which is already used for printing the version number
-	ptversion := flag.String("ptversion", "", "Specify the Pluggable Transport protocol version to use")
+	ptversion := flag.String("version", "", "Specify the Pluggable Transport protocol version to use")
 	statePath := flag.String("state", "", "Specify the directory to use to store state information required by the transports")
 	exitOnStdinClose := flag.Bool("exit-on-stdin-close", false, "Set to true to force the dispatcher to close when the stdin pipe is closed")
 
@@ -102,7 +101,7 @@ func main() {
 	optionsFile := flag.String("optionsFile", "", "store all the options in a single file")
 	fmt.Println("checking for optionsFile")
 	// Additional command line flags inherited from obfs4proxy
-	showVer := flag.Bool("version", false, "Print version and exit")
+	showVer := flag.Bool("showVersion", false, "Print version and exit")
 	logLevelStr := flag.String("logLevel", "ERROR", "Log level (ERROR/WARN/INFO/DEBUG)")
 	enableLogging := flag.Bool("enableLogging", false, "Log to TOR_PT_STATE_LOCATION/"+dispatcherLogFile)
 
@@ -173,8 +172,11 @@ func main() {
 				if *target == "" {
 					log.Errorf("%s - transparent mode requires a target", execName)
 				} else {
-					ptClientProxy, names := getClientNames(ptversion, transportsList, proxy)
-
+					ptClientProxy, names, nameErr := getClientNames(ptversion, transportsList, proxy)
+					if nameErr != nil {
+						log.Errorf("must specify -version and -transports")
+						return
+					}
 					launched = transparent_udp.ClientSetup(*socksAddr, *target, ptClientProxy, names, *options)
 				}
 			} else {
@@ -185,7 +187,7 @@ func main() {
 					// launched = transparent_udp.ServerSetup(termMon, *bindAddr, *target)
 
 					ptServerInfo := getServerInfo(bindAddr, options, transportsList, orport, extorport, authcookie)
-					launched, _ = transparent_udp.ServerSetup(ptServerInfo, *options)
+					launched, _ = transparent_udp.ServerSetup(ptServerInfo, stateDir, *options)
 				}
 			}
 		} else {
@@ -195,8 +197,11 @@ func main() {
 				if *target == "" {
 					log.Errorf("%s - transparent mode requires a target", execName)
 				} else {
-					ptClientProxy, names := getClientNames(ptversion, transportsList, proxy)
-
+					ptClientProxy, names, nameErr := getClientNames(ptversion, transportsList, proxy)
+					if nameErr != nil {
+						log.Errorf("must specify -version and -transports")
+						return
+					}
 					launched, _ = transparent_tcp.ClientSetup(*socksAddr, *target, ptClientProxy, names, *options)
 				}
 			} else {
@@ -205,7 +210,7 @@ func main() {
 					log.Errorf("%s - transparent mode requires a bindaddr", execName)
 				} else {
 					ptServerInfo := getServerInfo(bindAddr, options, transportsList, orport, extorport, authcookie)
-					launched, _ = transparent_tcp.ServerSetup(ptServerInfo, *statePath, *options)
+					launched, _ = transparent_tcp.ServerSetup(ptServerInfo, stateDir, *options)
 				}
 			}
 		}
@@ -217,8 +222,11 @@ func main() {
 				if *target == "" {
 					log.Errorf("%s - STUN mode requires a target", execName)
 				} else {
-					ptClientProxy, names := getClientNames(ptversion, transportsList, proxy)
-
+					ptClientProxy, names, nameErr := getClientNames(ptversion, transportsList, proxy)
+					if nameErr != nil {
+						log.Errorf("must specify -version and -transports")
+						return
+					}
 					launched = stun_udp.ClientSetup(*socksAddr, *target, ptClientProxy, names, *options)
 				}
 			} else {
@@ -227,7 +235,7 @@ func main() {
 					log.Errorf("%s - STUN mode requires a bindaddr", execName)
 				} else {
 					ptServerInfo := getServerInfo(bindAddr, options, transportsList, orport, extorport, authcookie)
-					launched, _ = stun_udp.ServerSetup(ptServerInfo, *options, stateDir)
+					launched, _ = stun_udp.ServerSetup(ptServerInfo, stateDir, *options)
 				}
 			}
 		} else {
@@ -235,13 +243,16 @@ func main() {
 			log.Infof("%s - initializing PT 2.0 proxy", execName)
 			if isClient {
 				log.Infof("%s - initializing client transport listeners", execName)
-				ptClientProxy, names := getClientNames(ptversion, transportsList, proxy)
-
+				ptClientProxy, names, nameErr := getClientNames(ptversion, transportsList, proxy)
+				if nameErr != nil {
+					log.Errorf("must specify -version and -transports")
+					return
+				}
 				launched, _ = pt_socks5.ClientSetup(*socksAddr, ptClientProxy, names, *options)
 			} else {
 				log.Infof("%s - initializing server transport listeners", execName)
 				ptServerInfo := getServerInfo(bindAddr, options, transportsList, orport, extorport, authcookie)
-				launched, _ = pt_socks5.ServerSetup(ptServerInfo, *options)
+				launched, _ = pt_socks5.ServerSetup(ptServerInfo, stateDir, *options)
 			}
 		}
 	}
@@ -285,7 +296,7 @@ func makeStateDir(statePath string) (string, error) {
 	}
 }
 
-func getClientNames(ptversion *string, transportsList *string, proxy *string) (clientProxy *url.URL, names []string) {
+func getClientNames(ptversion *string, transportsList *string, proxy *string) (clientProxy *url.URL, names []string, retErr error) {
 	var ptClientInfo pt.ClientInfo
 	var err error
 
@@ -293,8 +304,7 @@ func getClientNames(ptversion *string, transportsList *string, proxy *string) (c
 		log.Infof("Falling back to environment variables for ptversion/transports")
 		ptClientInfo, err = pt.ClientSetup(transports.Transports())
 		if err != nil {
-			// FIXME - print a more useful error, specifying --ptversion and --transports flags
-			golog.Fatal(err)
+			return nil, nil, err
 		}
 	} else {
 		if *transportsList == "*" {
@@ -304,14 +314,14 @@ func getClientNames(ptversion *string, transportsList *string, proxy *string) (c
 		}
 	}
 
-	ptClientProxy, err := pt_extras.PtGetProxy(proxy)
-	if err != nil {
-		golog.Fatal(err)
+	ptClientProxy, proxyErr := pt_extras.PtGetProxy(proxy)
+	if proxyErr != nil {
+		return nil, nil, proxyErr
 	} else if ptClientProxy != nil {
 		pt_extras.PtProxyDone()
 	}
 
-	return ptClientProxy, ptClientInfo.MethodNames
+	return ptClientProxy, ptClientInfo.MethodNames, nil
 }
 
 func getServerInfo(bindaddrList *string, options *string, transportList *string, orport *string, extorport *string, authcookie *string) pt.ServerInfo {
diff --git a/state/dispatcher.log b/state/dispatcher.log
index 3a53736..8609506 100644
--- a/state/dispatcher.log
+++ b/state/dispatcher.log
@@ -346,3 +346,9 @@
 2019/10/21 17:28:43 [INFO]: ___go_build_github_com_OperatorFoundation_shapeshifter_dispatcher_shapeshifter_dispatcher - initializing client transport listeners
 2019/10/21 17:28:43 [INFO]: Optimizer - registered listener: 127.0.0.1:1444
 2019/10/21 17:28:43 [INFO]: ___go_build_github_com_OperatorFoundation_shapeshifter_dispatcher_shapeshifter_dispatcher - accepting connections
+2019/10/21 18:24:04 [NOTICE]: dispatcher-0.0.7-dev - launched
+2019/10/21 18:24:04 [INFO]: ___go_build_github_com_OperatorFoundation_shapeshifter_dispatcher_shapeshifter_dispatcher - initializing transparent proxy
+2019/10/21 18:24:04 [INFO]: ___go_build_github_com_OperatorFoundation_shapeshifter_dispatcher_shapeshifter_dispatcher - initializing TCP transparent proxy
+2019/10/21 18:24:04 [INFO]: ___go_build_github_com_OperatorFoundation_shapeshifter_dispatcher_shapeshifter_dispatcher - initializing client transport listeners
+2019/10/21 18:24:04 [INFO]: Optimizer - registered listener: 127.0.0.1:1444
+2019/10/21 18:24:04 [INFO]: ___go_build_github_com_OperatorFoundation_shapeshifter_dispatcher_shapeshifter_dispatcher - accepting connections