matrix-capnproto-fed

commit 8a5d996c1294545c35a9d2fe6c313184ba415d31
parent 132cdb7cce6b0ddc7bd7a874835768504a795856
Author: MTRNord <mtrnord1@gmail.com>
Date:   Sat, 16 Mar 2024 22:15:18 +0100

Move to port 8449 and use non packed transport for now for wireshark

Diffstat:
M
cmds/client/main.go
 | 
8
++++----
M
cmds/server/main.go
 | 
6
+++---

2 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/cmds/client/main.go b/cmds/client/main.go
@@ -15,18 +15,18 @@ import (
 // This implements a dummy server for testing purposes of the rough api design especially around signatures
 
 func main() {
-	log.Println("Connecting to server on port localhost:2000")
+	log.Println("Connecting to server on port localhost:8449")
 
-	conn, err := net.Dial("tcp", "localhost:2000")
+	conn, err := net.Dial("tcp", "localhost:8449")
 	if err != nil {
 		log.Fatalln("Failed to connect to server:", err)
 	}
 	defer conn.Close()
 
-	log.Println("Connected to server on port localhost:2000")
+	log.Println("Connected to server on port localhost:8449")
 	log.Println("Creating rpc client...")
 
-	rpc_conn := rpc.NewConn(rpc.NewPackedStreamTransport(conn), nil)
+	rpc_conn := rpc.NewConn(rpc.NewStreamTransport(conn), nil)
 	defer rpc_conn.Close()
 
 	log.Println("Created rpc connection...")
diff --git a/cmds/server/main.go b/cmds/server/main.go
@@ -41,7 +41,7 @@ func Serve(lis net.Listener, boot capnp.Client) error {
 			BootstrapClient: boot.AddRef(),
 		}
 		// For each new incoming connection, create a new RPC transport connection that will serve incoming RPC requests
-		transport := rpc.NewPackedStreamTransport(conn)
+		transport := rpc.NewStreamTransport(conn)
 		_ = rpc.NewConn(transport, &opts)
 	}
 }
@@ -67,11 +67,11 @@ func ListenAndServe(ctx context.Context, network, addr string, bootstrapClient c
 }
 
 func main() {
-	log.Println("Starting server on port localhost:2000")
+	log.Println("Starting server on port localhost:8449")
 	server := rpcserver.NewServer()
 
 	client := protocol.MatrixFederation_ServerToClient(server)
 	client.SetFlowLimiter(flowcontrol.NewFixedLimiter(1 << 17))
 
-	ListenAndServe(context.Background(), "tcp", "localhost:2000", capnp.Client(client))
+	ListenAndServe(context.Background(), "tcp", "localhost:8449", capnp.Client(client))
 }