basic Go client

Author: kgibbons

C++/src/client_sync.cc

@@ -14,7 +14,7 @@ int main() {
 
 		socket.connect(boost::asio::local::stream_protocol::endpoint(ADDRESS));
 
-		asio::Boring msg;
+		example_mess::Boring msg;
 		msg.set_cont("Greetings from CPP-land!");
 
 

C++/src/server_async.cc

@@ -32,7 +32,7 @@ class handler: public asio_handler<handler> {
     void handle_message(const boost::system::error_code& error) {
     	if(error) {cerr << error.message() << endl; return;}
 
-    	asio::Boring msg;
+    	example_mess::Boring msg;
     	bool r = msg.ParseFromArray(message.data(), message.size());
     	if(!r) {
     		cerr << "Failed parsing" << endl;

C++/src/server_sync.cc

@@ -30,7 +30,7 @@ class handler: public asio_handler<handler> {
       	message.resize(message_length);
 		boost::asio::read(socket_, boost::asio::buffer(message));
 
-    	asio::Boring msg;
+    	example_mess::Boring msg;
     	bool r = msg.ParseFromArray(message.data(), message.size());
     	if(!r) {
     		cerr << "Failed parsing" << endl;

Go/src/client/main.go

@@ -2,17 +2,46 @@ package main
 
 import (
 	"log"
+	"net"
+	//"fmt"
+	//"bytes"
+	"encoding/binary"
 
 	"code.google.com/p/goprotobuf/proto"
 	"example_mess"
 )
 
+var _ = net.Dial
+//var _ = bytes.Buffer
+
 func main() {
+
+	socket, err := net.Dial("unix", "socket")
+	if err!= nil {
+		log.Fatal("Failed to connect to socket: ", err)
+	}
+	
+	defer socket.Close()
+
 	test := &example_mess.Boring {
-		Cont: proto.String("wew"),
+		Cont: proto.String("Greets from Go"),
 	}
-	_, err := proto.Marshal(test)
+	serialized, err := proto.Marshal(test)
 	if err != nil {
 		log.Fatal("marshaling error: ", err)
 	}
+	
+	
+	//buf := new(bytes.Buffer)
+	println(len(serialized))
+	//err = binary.Write(buf, binary.BigEndian, int32(1337))
+	//fmt.Printf("% d", buf.Bytes())
+	
+	// Go is unique in that, thanks to its interfaces, it's practical to encode directly to the socket
+	err = binary.Write(socket, binary.BigEndian, int32(len(serialized)))
+	if err != nil {
+		log.Fatal("failed writing to socket: ", err)
+	}
+	
+	socket.Write(serialized)
 }

makefile

@@ -37,7 +37,6 @@ $(GO_BINS): %: Go/src/%/main.go Go/src/example_mess/msg.pb.go Go/src/code.google
 
 Go/src/example_mess/msg.pb.go: msg.proto
 	protoc --go_out=Go/src/example_mess msg.proto
-	#GOPATH=$(CURDIR)/Go go install pb_message
 
 Go/src/code.google.com/p/goprotobuf:
 	GOPATH=$(CURDIR)/Go go get code.google.com/p/goprotobuf/proto