From 13d9ba41c48b0ed320f6ed7a795a4de428754963 Mon Sep 17 00:00:00 2001 From: Henry Date: Wed, 21 Apr 2021 09:44:44 +0200 Subject: [PATCH] update some comments --- muxrpc/handlers/tunnel/server/state.go | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) diff --git a/muxrpc/handlers/tunnel/server/state.go b/muxrpc/handlers/tunnel/server/state.go index 2229e2d..a508181 100644 --- a/muxrpc/handlers/tunnel/server/state.go +++ b/muxrpc/handlers/tunnel/server/state.go @@ -70,7 +70,8 @@ func (h *Handler) endpoints(ctx context.Context, req *muxrpc.Request, snk *muxrp // for future updates h.state.Register(toPeer) - ref, err := network.GetFeedRefFromAddr(req.RemoteAddr()) + // get public key from the calling peer + peer, err := network.GetFeedRefFromAddr(req.RemoteAddr()) if err != nil { return err } @@ -84,20 +85,18 @@ func (h *Handler) endpoints(ctx context.Context, req *muxrpc.Request, snk *muxrp case roomdb.ModeCommunity: fallthrough case roomdb.ModeRestricted: - _, err := h.members.GetByFeed(ctx, *ref) + _, err := h.members.GetByFeed(ctx, *peer) if err != nil { return fmt.Errorf("external user are not allowed to enumerate members") } } - h.state.AlreadyAdded(*ref, req.Endpoint()) + // add the peer to the room state if they arent already + h.state.AlreadyAdded(*peer, req.Endpoint()) + + // update the peer with toPeer.Update(h.state.List()) - // go func() { - // for range time.Tick(3 * time.Second) { - // toPeer.Update(h.state.List()) - // } - // }() return nil }