fallback executor support

examples/adder/remote/client/main.go

@@ -19,32 +19,20 @@ func main() {
 		panic(err)
 	}
 
+	req.Options["encoding"] = cmds.Text
+
 	// create http rpc client
 	client := http.NewClient(":6798")
 
-	// send request to server
-	res, err := client.Send(req)
-	if err != nil {
-		panic(err)
-	}
-
-	req.Options["encoding"] = cmds.Text
-
 	// create an emitter
 	re, err := cli.NewResponseEmitter(os.Stdout, os.Stderr, req)
 	if err != nil {
 		panic(err)
 	}
 
-	// copy received result into cli emitter
-	if pr, ok := req.Command.PostRun[cmds.CLI]; ok {
-		err = pr(res, re)
-	} else {
-		err = cmds.Copy(re, res)
-	}
+	// send request to server
+	err = client.Execute(req, re, nil)
 	if err != nil {
-		re.CloseWithError(err)
+		panic(err)
 	}
-
-	os.Exit(re.Status())
 }

http/client.go

@@ -22,16 +22,12 @@ var OptionSkipMap = map[string]bool{
 	"api": true,
 }
 
-// Client is the commands HTTP client interface.
-type Client interface {
-	Send(req *cmds.Request) (cmds.Response, error)
-}
-
 type client struct {
 	serverAddress string
 	httpClient    *http.Client
 	ua            string
 	apiPrefix     string
+	fallback      cmds.Executor
 }
 
 type ClientOpt func(*client)
@@ -48,7 +44,16 @@ func ClientWithAPIPrefix(apiPrefix string) ClientOpt {
 	}
 }
 
-func NewClient(address string, opts ...ClientOpt) Client {
+// ClientWithFallback adds a fallback executor to the client.
+//
+// Note: This may run the PreRun function twice.
+func ClientWithFallback(exe cmds.Executor) ClientOpt {
+	return func(c *client) {
+		c.fallback = exe
+	}
+}
+
+func NewClient(address string, opts ...ClientOpt) cmds.Executor {
 	if !strings.HasPrefix(address, "http://") {
 		address = "http://" + address
 	}
@@ -69,16 +74,25 @@ func NewClient(address string, opts ...ClientOpt) Client {
 func (c *client) Execute(req *cmds.Request, re cmds.ResponseEmitter, env cmds.Environment) error {
 	cmd := req.Command
 
+	err := cmd.CheckArguments(req)
+	if err != nil {
+		return err
+	}
+
 	if cmd.PreRun != nil {
 		err := cmd.PreRun(req, env)
 		if err != nil {
 			return err
 		}
 	}
 
-	res, err := c.Send(req)
+	res, err := c.send(req)
 	if err != nil {
 		if isConnRefused(err) {
+			if c.fallback != nil {
+				// XXX: this runs the PreRun twice
+				return c.fallback.Execute(req, re, env)
+			}
 			err = fmt.Errorf("cannot connect to the api. Is the daemon running? To run as a standalone CLI command remove the api file in `$IPFS_PATH/api`")
 		}
 		return err
@@ -146,7 +160,7 @@ func (c *client) toHTTPRequest(req *cmds.Request) (*http.Request, error) {
 	return httpReq, nil
 }
 
-func (c *client) Send(req *cmds.Request) (cmds.Response, error) {
+func (c *client) send(req *cmds.Request) (cmds.Response, error) {
 	if req.Context == nil {
 		log.Warningf("no context set in request")
 		req.Context = context.Background()

http/client_test.go

@@ -44,7 +44,7 @@ func TestClientUserAgent(t *testing.T) {
 
 		c := NewClient(tc.host, ClientWithUserAgent(tc.ua)).(*client)
 		c.httpClient = testClient
-		c.Send(r)
+		c.send(r)
 
 		if !called {
 			t.Error("handler has not been called")
@@ -84,7 +84,7 @@ func TestClientAPIPrefix(t *testing.T) {
 
 		c := NewClient(tc.host, ClientWithAPIPrefix(tc.prefix)).(*client)
 		c.httpClient = testClient
-		c.Send(r)
+		c.send(r)
 
 		if !called {
 			t.Error("handler has not been called")

http/http_test.go

@@ -99,7 +99,7 @@ func TestHTTP(t *testing.T) {
 				req.Files = tc.file
 			}
 
-			res, err := c.Send(req)
+			res, err := c.(*client).send(req)
 			if tc.sendErr != nil {
 				if err == nil {
 					t.Fatalf("expected error %q but got nil", tc.sendErr)