feat(go): implement TCP serve

Signed-off-by: Roman Volosatovs <rvolosatovs@riseup.net>

Author: rvolosatovs

crates/wit-bindgen-go/src/interface.rs

@@ -2146,12 +2146,12 @@ impl InterfaceGenerator<'_> {
             }}
             return func(w {wrpc}.IndexWriter) (err error) {{
                 defer func() {{
-                    {slog}.Debug("closing stream writer")
+                    {slog}.Debug("closing outgoing pending stream")
                     if cErr := v.Close(); cErr != nil {{
                         if err == nil {{
-                            err = {fmt}.Errorf("failed to close pending stream: %w", cErr)
+                            err = {fmt}.Errorf("failed to close outgoing pending stream: %w", cErr)
                         }} else {{
-                            {slog}.Warn("failed to close pending stream", "err", cErr)
+                            {slog}.Warn("failed to close outgoing pending stream", "err", cErr)
                         }}
                     }}
                 }}()
@@ -2637,14 +2637,14 @@ func ServeInterface(s {wrpc}.Server, h Handler) (stop func() error, err error) {
                         self.src,
                         r#"
                     case {idx}:
-                        w, err := w.Index("#,
+                        w, err := w.Index({i}"#,
                     );
                     if is_tuple(self.resolve, ty) {
-                        uwrite!(self.src, "{i}, ");
+                        uwrite!(self.src, ", {j}");
                     }
                     uwrite!(
                         self.src,
-                        r#"{j})
+                        r#")
                         if err != nil {{
                             {slog}.ErrorContext(ctx, "failed to index result writer", "instance", "{instance}", "name", "{name}", "err", err)
                             return

examples/go/hello-client/bindings/client.wrpc.go

@@ -1,3 +1,3 @@
-// Generated by `wit-bindgen-wrpc-go` 0.11.0. DO NOT EDIT!
+// Generated by `wit-bindgen-wrpc-go` 0.12.0. DO NOT EDIT!
 // client package contains wRPC bindings for `client` world
 package client

examples/go/hello-client/bindings/wrpc_examples/hello/handler/bindings.wrpc.go

@@ -1,4 +1,4 @@
-// Generated by `wit-bindgen-wrpc-go` 0.11.0. DO NOT EDIT!
+// Generated by `wit-bindgen-wrpc-go` 0.12.0. DO NOT EDIT!
 package handler
 
 import (

examples/go/hello-client/cmd/hello-client-tcp/main.go

@@ -9,7 +9,7 @@ import (
 
 func run() error {
 	addr := "[::1]:7761"
-	return app.Run(addr, wrpctcp.NewClient(addr))
+	return app.Run(addr, wrpctcp.NewInvoker(addr))
 }
 
 func main() {

examples/go/hello-server/bindings/exports/wrpc_examples/hello/handler/bindings.wrpc.go

@@ -1,4 +1,4 @@
-// Generated by `wit-bindgen-wrpc-go` 0.11.0. DO NOT EDIT!
+// Generated by `wit-bindgen-wrpc-go` 0.12.0. DO NOT EDIT!
 package handler
 
 import (

examples/go/hello-server/bindings/server.wrpc.go

@@ -1,4 +1,4 @@
-// Generated by `wit-bindgen-wrpc-go` 0.11.0. DO NOT EDIT!
+// Generated by `wit-bindgen-wrpc-go` 0.12.0. DO NOT EDIT!
 // server package contains wRPC bindings for `server` world
 package server
 

examples/go/hello-server/cmd/hello-server-tcp/main.go

@@ -0,0 +1,68 @@
+package main
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"log"
+	"log/slog"
+	"net"
+	"os"
+	"os/signal"
+	"syscall"
+
+	app "wrpc.io/examples/go/hello-server"
+	server "wrpc.io/examples/go/hello-server/bindings"
+	wrpctcp "wrpc.io/go/x/tcp"
+)
+
+func run() (err error) {
+	l, err := net.ListenTCP("tcp", &net.TCPAddr{
+		IP:   net.IPv6loopback,
+		Port: 7761,
+	})
+	if err != nil {
+		return fmt.Errorf("failed to listen on TCP socket: %w", err)
+	}
+
+	ctx := context.Background()
+	ctx, cancel := context.WithCancel(ctx)
+	defer cancel()
+
+	srv := wrpctcp.NewServerWithContext(ctx, l)
+	stop, err := server.Serve(srv, app.Handler{})
+	if err != nil {
+		return fmt.Errorf("failed to serve `server` world: %w", err)
+	}
+
+	go func() {
+		for {
+			select {
+			case <-ctx.Done():
+				return
+			default:
+				slog.Debug("accepting invocation")
+				if err := srv.Accept(); err != nil {
+					if !errors.Is(err, net.ErrClosed) {
+						slog.Error("failed to accept invocation", "err", err)
+					}
+				}
+			}
+		}
+	}()
+
+	signalCh := make(chan os.Signal, 1)
+	signal.Notify(signalCh, syscall.SIGINT)
+	<-signalCh
+
+	if err = stop(); err != nil {
+		return fmt.Errorf("failed to stop `server` world: %w", err)
+	}
+	return nil
+}
+
+func main() {
+	if err := run(); err != nil {
+		log.Fatal(err)
+	}
+}

examples/go/resources-server/bindings/exports/wrpc_examples/resources/resources/bindings.wrpc.go

@@ -1,4 +1,4 @@
-// Generated by `wit-bindgen-wrpc-go` 0.11.0. DO NOT EDIT!
+// Generated by `wit-bindgen-wrpc-go` 0.12.0. DO NOT EDIT!
 package resources
 
 import (

examples/go/resources-server/bindings/server.wrpc.go

@@ -1,4 +1,4 @@
-// Generated by `wit-bindgen-wrpc-go` 0.11.0. DO NOT EDIT!
+// Generated by `wit-bindgen-wrpc-go` 0.12.0. DO NOT EDIT!
 // server package contains wRPC bindings for `server` world
 package server
 

examples/go/streams-client/bindings/client.wrpc.go

@@ -1,3 +1,3 @@
-// Generated by `wit-bindgen-wrpc-go` 0.11.0. DO NOT EDIT!
+// Generated by `wit-bindgen-wrpc-go` 0.12.0. DO NOT EDIT!
 // client package contains wRPC bindings for `client` world
 package client