Something went wrong. Try again.
Monorepo for Tangled forked from tangled.org/core
Something went wrong. Try again.
1.2 kB · 59 lines
Go
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960package eventconsumer
import ( "net/url" "strconv"
"tangled.org/core/eventconsumer/cursor" "tangled.org/core/hostutil")
type Kind string
const ( KindKnot Kind = "knot" KindSpindle Kind = "spindle")
type Source struct { Kind Kind Host string NoTLS bool // use TLS by default}
func NewKnotSource(host string) Source { host, noTLS, _ := hostutil.ParseHostname(host) return Source{Kind: KindKnot, Host: host, NoTLS: noTLS}}func NewSpindleSource(host string) Source { host, noTLS, _ := hostutil.ParseHostname(host) return Source{Kind: KindSpindle, Host: host, NoTLS: noTLS}}
func (s Source) Key() string { return string(s.Kind) + ":" + s.Host }
func MigrateLegacyCursor(store cursor.Store, s Source) { if store.Get(s.Key()) != 0 { return } if legacy := store.Get(s.Host); legacy != 0 { store.Set(s.Key(), legacy) }}
func (s Source) URL(cursor int64) (*url.URL, error) { scheme := "wss" if s.NoTLS { scheme = "ws" } u, err := url.Parse(scheme + "://" + s.Host + "/events") if err != nil { return nil, err } if cursor != 0 { q := url.Values{} q.Add("cursor", strconv.FormatInt(cursor, 10)) u.RawQuery = q.Encode() } return u, nil}