2021-02-09 11:53:33 +00:00
|
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
|
2021-02-01 15:45:30 +00:00
|
|
|
package server
|
2021-01-25 17:31:09 +00:00
|
|
|
|
|
|
|
import (
|
|
|
|
"context"
|
2021-01-26 17:33:29 +00:00
|
|
|
"encoding/json"
|
2021-01-25 17:31:09 +00:00
|
|
|
"time"
|
|
|
|
|
2021-02-09 16:38:51 +00:00
|
|
|
"github.com/ssb-ngi-pointer/go-ssb-room/internal/network"
|
2021-02-10 14:50:36 +00:00
|
|
|
"github.com/ssb-ngi-pointer/go-ssb-room/roomstate"
|
|
|
|
refs "go.mindeco.de/ssb-refs"
|
2021-01-26 17:33:29 +00:00
|
|
|
|
2021-01-25 17:31:09 +00:00
|
|
|
kitlog "github.com/go-kit/kit/log"
|
|
|
|
"github.com/go-kit/kit/log/level"
|
|
|
|
"go.cryptoscope.co/muxrpc/v2"
|
|
|
|
)
|
|
|
|
|
2021-02-10 14:50:36 +00:00
|
|
|
type handler struct {
|
2021-01-25 17:31:09 +00:00
|
|
|
logger kitlog.Logger
|
2021-02-10 14:50:36 +00:00
|
|
|
self refs.FeedRef
|
2021-01-26 17:33:29 +00:00
|
|
|
|
2021-02-10 14:50:36 +00:00
|
|
|
state *roomstate.Manager
|
2021-01-26 17:33:29 +00:00
|
|
|
}
|
|
|
|
|
2021-02-10 14:50:36 +00:00
|
|
|
func (h *handler) isRoom(context.Context, *muxrpc.Request) (interface{}, error) {
|
|
|
|
level.Debug(h.logger).Log("called", "isRoom")
|
2021-01-25 17:31:09 +00:00
|
|
|
return true, nil
|
|
|
|
}
|
|
|
|
|
2021-02-10 14:50:36 +00:00
|
|
|
func (h *handler) ping(context.Context, *muxrpc.Request) (interface{}, error) {
|
2021-01-25 17:31:09 +00:00
|
|
|
now := time.Now().UnixNano() / 1000
|
2021-02-10 14:50:36 +00:00
|
|
|
level.Debug(h.logger).Log("called", "ping")
|
2021-01-25 17:31:09 +00:00
|
|
|
return now, nil
|
|
|
|
}
|
|
|
|
|
2021-02-10 14:50:36 +00:00
|
|
|
func (h *handler) announce(_ context.Context, req *muxrpc.Request) (interface{}, error) {
|
|
|
|
level.Debug(h.logger).Log("called", "announce")
|
2021-01-26 17:33:29 +00:00
|
|
|
ref, err := network.GetFeedRefFromAddr(req.RemoteAddr())
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
2021-02-10 14:50:36 +00:00
|
|
|
h.state.AddEndpoint(*ref, req.Endpoint())
|
2021-01-26 17:33:29 +00:00
|
|
|
|
2021-01-27 10:05:06 +00:00
|
|
|
return false, nil
|
2021-01-25 17:31:09 +00:00
|
|
|
}
|
|
|
|
|
2021-02-10 14:50:36 +00:00
|
|
|
func (h *handler) leave(_ context.Context, req *muxrpc.Request) (interface{}, error) {
|
2021-01-26 17:33:29 +00:00
|
|
|
ref, err := network.GetFeedRefFromAddr(req.RemoteAddr())
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
2021-02-10 14:50:36 +00:00
|
|
|
h.state.Remove(*ref)
|
2021-01-26 17:33:29 +00:00
|
|
|
|
2021-01-27 10:05:06 +00:00
|
|
|
return false, nil
|
2021-01-25 17:31:09 +00:00
|
|
|
}
|
|
|
|
|
2021-02-10 14:50:36 +00:00
|
|
|
func (h *handler) endpoints(_ context.Context, req *muxrpc.Request, snk *muxrpc.ByteSink) error {
|
|
|
|
level.Debug(h.logger).Log("called", "endpoints")
|
2021-01-28 14:06:24 +00:00
|
|
|
|
2021-01-29 10:55:40 +00:00
|
|
|
toPeer := newForwarder(snk)
|
|
|
|
|
|
|
|
// for future updates
|
2021-02-10 14:50:36 +00:00
|
|
|
h.state.Register(toPeer)
|
2021-01-29 10:55:40 +00:00
|
|
|
|
2021-01-28 14:06:24 +00:00
|
|
|
ref, err := network.GetFeedRefFromAddr(req.RemoteAddr())
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
2021-02-10 14:50:36 +00:00
|
|
|
has := h.state.AlreadyAdded(*ref, req.Endpoint())
|
|
|
|
if !has {
|
2021-01-29 10:55:40 +00:00
|
|
|
// just send the current state to the new peer
|
2021-02-10 14:50:36 +00:00
|
|
|
toPeer.Update(h.state.List())
|
2021-01-28 14:06:24 +00:00
|
|
|
}
|
2021-01-26 17:33:29 +00:00
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
type updateForwarder struct {
|
|
|
|
snk *muxrpc.ByteSink
|
|
|
|
enc *json.Encoder
|
|
|
|
}
|
|
|
|
|
|
|
|
func newForwarder(snk *muxrpc.ByteSink) updateForwarder {
|
|
|
|
enc := json.NewEncoder(snk)
|
|
|
|
snk.SetEncoding(muxrpc.TypeJSON)
|
|
|
|
return updateForwarder{
|
|
|
|
snk: snk,
|
|
|
|
enc: enc,
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2021-01-27 10:05:06 +00:00
|
|
|
func (uf updateForwarder) Update(members []string) error {
|
|
|
|
return uf.enc.Encode(members)
|
2021-01-26 17:33:29 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
func (uf updateForwarder) Close() error {
|
|
|
|
return uf.snk.Close()
|
2021-01-25 17:31:09 +00:00
|
|
|
}
|