progrium · August 25, 2021 15:59 · Aug 25, 2021
diff --git a/server.go b/server.go
@@ -0,0 +1,43 @@
+// server.go
+package main
+
+import (
+    "fmt"
+    "log"
+    "net"
+    "strings"
+
+    "github.com/progrium/qtalk-go/codec"
+    "github.com/progrium/qtalk-go/fn"
+    "github.com/progrium/qtalk-go/rpc"
+)
+
+type service struct{}
+
+func (svc *service) Upper(s string) string {
+    return strings.ToUpper(s)
+}
+
+// methods can opt-in to receive the call as last argument.
+// also, errors can be returned to be received as remote errors.
+func (svc *service) Error(s string, c *rpc.Call) error {
+    return fmt.Errorf("%s [%s]", s, c.Selector)
+}
+
+func main() {
+    // create a tcp listener
+    l, err := net.Listen("tcp", "localhost:9999")
+    if err != nil {
+        log.Fatal(err)
+    }
+
+    // setup a server using fn.HandlerFrom to
+    // handle methods from the service type
+    srv := &rpc.Server{
+        Codec:   codec.JSONCodec{},
+        Handler: fn.HandlerFrom(new(service)),
+    }
+
+    // serve until the listener closes
+    srv.Serve(l)
+}