go: echo app

examples/go/echo_client.go

Index: examples/go/echo_client.go
diff --git a/examples/go/echo_client.go b/examples/go/echo_client.go
new file mode 100644
index 0000000000000000000000000000000000000000..1ecc17410099c7c5f28b39edc0f88ce56ef59b6f
--- /dev/null
+++ b/examples/go/echo_client.go
@@ -0,0 +1,78 @@
+package main
+
+import (
+	"fmt"
+	"log"
+
+	"code.google.com/p/go.mobile/app"
+
+	"mojo/public/go/bindings"
+	"mojo/public/go/system"
+
+	"examples/echo/echo"
+	"mojo/public/interfaces/application/application"
+	"mojo/public/interfaces/application/service_provider"
+	"mojo/public/interfaces/application/shell"
+)
+
+//#include "mojo/public/c/system/types.h"
+import "C"
+
+// AppImpl implements mojo interface application.
+type AppImpl struct {
+	shell           *shell.ShellProxy
+	serviceProvider *service_provider.ServiceProviderProxy
+	echo            *echo.EchoProxy
+}
+
+func (impl *AppImpl) Initialize(inShell shell.ShellPointer, inArgs *[]string, inUrl string) error {
+	impl.shell = shell.NewShellProxy(inShell, bindings.GetAsyncWaiter())
+	// Connect to another mojo application.
+	request, pointer := service_provider.CreateMessagePipeForServiceProvider()
+	if err := impl.shell.ConnectToApplication("mojo:echo_server", &request, nil); err != nil {
+		return err

[jamesr, 2015/03/12 21:15:32]

what does returning an error here do? does this propagate back to the
stub.ServeRequest() call ?

[rogulenko, 2015/03/12 22:22:03]

Yes, this goes back to stub.ServeRequest() call.

+	}
+	impl.serviceProvider = service_provider.NewServiceProviderProxy(pointer, bindings.GetAsyncWaiter())
+	// Connect to service.
+	echoRequest, echoPointer := echo.CreateMessagePipeForEcho()
+	if err := impl.serviceProvider.ConnectToService("mojo::examples::Echo", echoRequest.PassMessagePipe()); err != nil {
+		return err
+	}
+	impl.echo = echo.NewEchoProxy(echoPointer, bindings.GetAsyncWaiter())
+	// Send and receive echo request.
+	response, err := impl.echo.EchoString(bindings.StringPointer("Hello Go world!"))
+	if response != nil {

[jamesr, 2015/03/12 21:15:32]

if response is nil we should consider that an error, no?

[rogulenko, 2015/03/12 22:22:03]

Done.

+		fmt.Println(*response)
+	}
+	return err
+}
+
+func (impl *AppImpl) AcceptConnection(inRequestorUrl string, inServices *service_provider.ServiceProviderRequest, inExposedServices *service_provider.ServiceProviderPointer, inResolvedUrl string) error {
+	return nil

[jamesr, 2015/03/12 21:15:32]

this should probably close out the service provider pipes here if they're
non-nil since this isn't going to use them

[rogulenko, 2015/03/12 22:22:03]

Done.

+}
+
+func (impl *AppImpl) RequestQuit() error {
+	impl.echo.Close_proxy()
+	impl.serviceProvider.Close_proxy()
+	impl.shell.Close_proxy()
+	return fmt.Errorf("closed")
+}
+
+//export MojoMain
+func MojoMain(handle C.MojoHandle) C.MojoResult {
+	appHandle := system.GetCore().AcquireNativeHandle(system.MojoHandle(handle)).ToMessagePipeHandle()
+	appRequest := application.ApplicationRequest{bindings.NewMessagePipeHandleOwner(appHandle)}
+	stub := application.NewApplicationStub(appRequest, &AppImpl{}, bindings.GetAsyncWaiter())
+	for {
+		if err := stub.ServeRequest(); err != nil {
+			log.Println(err)
+			stub.Close()
+			break
+		}
+	}
+	return C.MOJO_RESULT_OK
+}
+
+func main() {
+	app.Run(app.Callbacks{})
+}