+ {{template "content" .}}
+
+
+
+{{end}}
diff --git a/app/webfinger/ui/pages/home.go.tpl b/app/webfinger/ui/pages/home.go.tpl
new file mode 100644
index 0000000..5033e35
--- /dev/null
+++ b/app/webfinger/ui/pages/home.go.tpl
@@ -0,0 +1,131 @@
+{{template "main" .}}
+
+{{define "meta"}}{{end}}
+
+{{define "content"}}
+
+
+ + + {{ if ne .Err nil }} +
+ {{ .Err }}
+
+ {{ end }}
+
+ {{ if ne .JRD nil }}
+
+
+
+
+{{ end }}
+
+ Webfinger Result
+
+ | Subject | +
+
+
+
+ {{ .JRD.Subject }}
+
+
+ {{ with .JRD.GetLinkByRel "http://webfinger.net/rel/avatar" }}
+ {{ if ne . nil }}
+
+
+ {{ end }}
+ {{ end }}
+
+
+
+
+
+ |
+ ||
|---|---|---|---|
| Aliases | +
+
|
+ ||
| Properties | +
+
+ {{ range $key, $value := .JRD.Properties }}
+
+
+ {{ end }}
+ {{ propName $key }}+{{ $value }}
+ |
+ ||
| Template | +{{ .Template }} | + {{ else }} +Link | +{{ if ne (len .HRef) 0 }}{{ .HRef }}{{ end }} | + {{ end }} +
| Properties | +
+
+
+
+
+
+ {{ if ne (len .Type) 0 }}rel{{ .Rel }}
+ |
+
+
+
+{{end}}
diff --git a/app/webfinger/webfinger.go b/app/webfinger/webfinger.go
new file mode 100644
index 0000000..57a0a87
--- /dev/null
+++ b/app/webfinger/webfinger.go
@@ -0,0 +1,416 @@
+package webfinger
+
+import (
+ "context"
+ "crypto/ed25519"
+ "embed"
+ "encoding/base64"
+ "encoding/json"
+ "errors"
+ "fmt"
+ "html"
+ "html/template"
+ "io"
+ "io/fs"
+ "log"
+ "net/http"
+ "net/http/httptest"
+ "net/url"
+ "os"
+ "strings"
+
+ "github.com/golang-jwt/jwt/v4"
+ "go.sour.is/pkg/lg"
+ "go.sour.is/pkg/set"
+
+ "go.sour.is/ev"
+ "go.sour.is/ev/event"
+)
+
+var (
+ //go:embed ui/*/*
+ files embed.FS
+ templates map[string]*template.Template
+)
+
+type service struct {
+ es *ev.EventStore
+ self set.Set[string]
+ cache func(string) bool
+}
+
+type Option interface {
+ ApplyWebfinger(s *service)
+}
+
+type WithHostnames []string
+
+func (o WithHostnames) ApplyWebfinger(s *service) {
+ s.self = set.New(o...)
+}
+
+type WithCache func(string) bool
+
+func (o WithCache) ApplyWebfinger(s *service) {
+ s.cache = o
+}
+
+func New(ctx context.Context, es *ev.EventStore, opts ...Option) (*service, error) {
+ ctx, span := lg.Span(ctx)
+ defer span.End()
+
+ if err := event.Register(
+ ctx,
+ &SubjectSet{},
+ &SubjectDeleted{},
+ &LinkSet{},
+ &LinkDeleted{},
+ ); err != nil {
+ return nil, err
+ }
+ svc := &service{es: es}
+
+ for _, o := range opts {
+ o.ApplyWebfinger(svc)
+ }
+
+ return svc, nil
+}
+
+func (s *service) RegisterHTTP(mux *http.ServeMux) {
+ a, _ := fs.Sub(files, "ui/assets")
+ assets := http.StripPrefix("/webfinger/assets/", http.FileServer(http.FS(a)))
+
+ mux.Handle("/webfinger", s.ui())
+ mux.Handle("/webfinger/assets/", assets)
+}
+func (s *service) RegisterWellKnown(mux *http.ServeMux) {
+ mux.Handle("/webfinger", lg.Htrace(s, "webfinger"))
+}
+func (s *service) ServeHTTP(w http.ResponseWriter, r *http.Request) {
+ ctx := r.Context()
+ ctx, span := lg.Span(ctx)
+ defer span.End()
+
+ if r.URL.Path != "/webfinger" {
+ w.WriteHeader(http.StatusNotFound)
+ fmt.Fprint(w, http.StatusText(http.StatusNotFound))
+ return
+ }
+
+ switch r.Method {
+ case http.MethodPut, http.MethodDelete:
+ if r.ContentLength > 4096 {
+ w.WriteHeader(http.StatusRequestEntityTooLarge)
+ fmt.Fprint(w, http.StatusText(http.StatusRequestEntityTooLarge))
+ span.AddEvent("request too large")
+
+ return
+ }
+ body, err := io.ReadAll(io.LimitReader(r.Body, 4096))
+ if err != nil {
+ w.WriteHeader(http.StatusInternalServerError)
+ fmt.Fprint(w, http.StatusText(http.StatusInternalServerError))
+ span.RecordError(err)
+
+ return
+ }
+ r.Body.Close()
+
+ type claims struct {
+ PubKey string `json:"pub"`
+ *JRD
+ jwt.RegisteredClaims
+ }
+
+ token, err := jwt.ParseWithClaims(
+ string(body),
+ &claims{},
+ func(tok *jwt.Token) (any, error) {
+ c, ok := tok.Claims.(*claims)
+ if !ok {
+ return nil, fmt.Errorf("wrong type of claim")
+ }
+
+ if c.JRD == nil {
+ c.JRD = &JRD{}
+ }
+
+ c.JRD.Subject = c.RegisteredClaims.Subject
+
+ c.SetProperty(NSpubkey, &c.PubKey)
+
+ pub, err := dec(c.PubKey)
+ return ed25519.PublicKey(pub), err
+ },
+ jwt.WithValidMethods([]string{"EdDSA"}),
+ jwt.WithJSONNumber(),
+ )
+ if err != nil {
+ w.WriteHeader(http.StatusUnprocessableEntity)
+ fmt.Fprint(w, http.StatusText(http.StatusUnprocessableEntity), ": ", err.Error())
+ span.RecordError(err)
+
+ return
+ }
+
+ c, ok := token.Claims.(*claims)
+ if !ok {
+ w.WriteHeader(http.StatusUnprocessableEntity)
+ fmt.Fprint(w, http.StatusText(http.StatusUnprocessableEntity))
+ span.AddEvent("not a claim")
+
+ return
+ }
+
+ if c.ID != "" && s.cache != nil {
+ if ok := s.cache(c.ID); ok {
+ w.WriteHeader(http.StatusAlreadyReported)
+ fmt.Fprint(w, http.StatusText(http.StatusAlreadyReported))
+ span.AddEvent("already seen ID")
+
+ return
+ }
+ }
+
+ json.NewEncoder(os.Stdout).Encode(c.JRD)
+
+ for i := range c.JRD.Links {
+ c.JRD.Links[i].Index = uint64(i)
+ }
+
+ a, err := ev.Upsert(ctx, s.es, StreamID(c.JRD.Subject), func(ctx context.Context, a *JRD) error {
+ var auth *JRD
+
+ for i := range a.Links {
+ a.Links[i].Index = uint64(i)
+ }
+
+ // does the target have a pubkey for self auth?
+ if _, ok := a.Properties[NSpubkey]; ok {
+ auth = a
+ }
+
+ // Check current version for auth.
+ if authID, ok := a.Properties[NSauth]; ok && authID != nil && auth == nil {
+ auth = &JRD{}
+ auth.SetStreamID(StreamID(*authID))
+ err := s.es.Load(ctx, auth)
+ if err != nil {
+ return err
+ }
+ }
+ if a.Version() == 0 || a.IsDeleted() {
+ // else does the new object claim auth from another object?
+ if authID, ok := c.Properties[NSauth]; ok && authID != nil && auth == nil {
+ auth = &JRD{}
+ auth.SetStreamID(StreamID(*authID))
+ err := s.es.Load(ctx, auth)
+ if err != nil {
+ return err
+ }
+ }
+
+ // fall back to use auth from submitted claims
+ if auth == nil {
+ auth = c.JRD
+ }
+ }
+
+ if auth == nil {
+ return fmt.Errorf("auth not found")
+ }
+
+ err = a.OnAuth(c.JRD, auth)
+ if err != nil {
+ return err
+ }
+
+ if r.Method == http.MethodDelete {
+ return a.OnDelete(c.JRD)
+ }
+ return a.OnClaims(c.JRD)
+ })
+
+ if err != nil {
+ w.WriteHeader(http.StatusUnprocessableEntity)
+ fmt.Fprint(w, http.StatusText(http.StatusUnprocessableEntity), ": ", err.Error())
+ span.RecordError(err)
+
+ return
+ }
+
+ if version := a.Version(); r.Method == http.MethodDelete && version > 0 {
+ err = s.es.Truncate(ctx, a.StreamID(), int64(version))
+ span.RecordError(err)
+ }
+
+ w.Header().Set("Content-Type", "application/jrd+json")
+ if r.Method == http.MethodDelete {
+ w.WriteHeader(http.StatusNoContent)
+ } else {
+ w.WriteHeader(http.StatusCreated)
+ }
+ j := json.NewEncoder(w)
+ j.SetIndent("", " ")
+ err = j.Encode(a)
+ span.RecordError(err)
+
+ case http.MethodGet:
+ resource := r.URL.Query().Get("resource")
+ rels := r.URL.Query()["rel"]
+
+ if resource == "" {
+ w.WriteHeader(http.StatusBadRequest)
+ return
+ }
+
+ if u := Parse(resource); u != nil && !s.self.Has(u.URL.Host) {
+ redirect := &url.URL{}
+ redirect.Scheme = "https"
+ redirect.Host = u.URL.Host
+ redirect.RawQuery = r.URL.RawQuery
+ redirect.Path = "/.well-known/webfinger"
+
+ w.Header().Set("location", redirect.String())
+ w.WriteHeader(http.StatusSeeOther)
+ return
+ }
+
+ a := &JRD{}
+ a.SetStreamID(StreamID(resource))
+ err := s.es.Load(ctx, a)
+ if err != nil {
+ span.RecordError(err)
+
+ if errors.Is(err, ev.ErrNotFound) {
+ w.WriteHeader(http.StatusNotFound)
+ fmt.Fprint(w, http.StatusText(http.StatusNotFound))
+ return
+ }
+
+ w.WriteHeader(http.StatusInternalServerError)
+ fmt.Fprint(w, http.StatusText(http.StatusInternalServerError))
+ return
+ }
+
+ if a.IsDeleted() {
+ w.WriteHeader(http.StatusGone)
+ fmt.Fprint(w, http.StatusText(http.StatusGone))
+ span.AddEvent("is deleted")
+
+ return
+ }
+
+ if len(rels) > 0 {
+ a.Links = a.GetLinksByRel(rels...)
+ }
+
+ if a.Properties != nil {
+ if redirect, ok := a.Properties[NSredirect]; ok && redirect != nil {
+ w.Header().Set("location", *redirect)
+ w.WriteHeader(http.StatusSeeOther)
+ return
+ }
+ }
+
+ w.Header().Set("Content-Type", "application/jrd+json")
+ w.WriteHeader(http.StatusOK)
+
+ j := json.NewEncoder(w)
+ j.SetIndent("", " ")
+ err = j.Encode(a)
+ span.RecordError(err)
+
+ default:
+ w.Header().Set("Allow", "GET, PUT, DELETE, OPTIONS")
+ w.WriteHeader(http.StatusMethodNotAllowed)
+ fmt.Fprint(w, http.StatusText(http.StatusMethodNotAllowed))
+ span.AddEvent("method not allow: " + r.Method)
+ }
+}
+func (s *service) ui() http.HandlerFunc {
+ loadTemplates()
+ return func(w http.ResponseWriter, r *http.Request) {
+ args := struct {
+ Req *http.Request
+ Status int
+ Body []byte
+ JRD *JRD
+ Err error
+ }{Status: http.StatusOK}
+
+ if r.URL.Query().Has("resource") {
+ args.Req, args.Err = http.NewRequestWithContext(r.Context(), http.MethodGet, r.URL.String(), nil)
+ if args.Err != nil {
+ http.Error(w, http.StatusText(http.StatusBadRequest), http.StatusBadRequest)
+ return
+ }
+ wr := httptest.NewRecorder()
+ s.ServeHTTP(wr, args.Req)
+
+ args.Status = wr.Code
+
+ switch wr.Code {
+ case http.StatusSeeOther:
+ res, err := http.DefaultClient.Get(wr.Header().Get("location"))
+ args.Err = err
+ if err == nil {
+ args.Status = res.StatusCode
+ args.Body, args.Err = io.ReadAll(res.Body)
+ }
+ case http.StatusOK:
+ args.Body, args.Err = io.ReadAll(wr.Body)
+ if args.Err == nil {
+ args.JRD, args.Err = ParseJRD(args.Body)
+ }
+ }
+ if args.Err == nil && args.Body != nil {
+ args.JRD, args.Err = ParseJRD(args.Body)
+ }
+ }
+
+ t := templates["home.go.tpl"]
+ err := t.Execute(w, args)
+ if err != nil {
+ log.Println(err)
+ }
+ }
+}
+
+func dec(s string) ([]byte, error) {
+ s = strings.TrimSpace(s)
+ return base64.RawURLEncoding.DecodeString(s)
+}
+
+var funcMap = map[string]any{
+ "propName": func(in string) string { return in[strings.LastIndex(in, "/")+1:] },
+ "escape": html.EscapeString,
+}
+
+func loadTemplates() error {
+ if templates != nil {
+ return nil
+ }
+ templates = make(map[string]*template.Template)
+ tmplFiles, err := fs.ReadDir(files, "ui/pages")
+ if err != nil {
+ return err
+ }
+
+ for _, tmpl := range tmplFiles {
+ if tmpl.IsDir() {
+ continue
+ }
+ pt := template.New(tmpl.Name())
+ pt.Funcs(funcMap)
+ pt, err = pt.ParseFS(files, "ui/pages/"+tmpl.Name(), "ui/layouts/*.go.tpl")
+ if err != nil {
+ log.Println(err)
+
+ return err
+ }
+ templates[tmpl.Name()] = pt
+ }
+ return nil
+}
diff --git a/cmd/README.md b/cmd/README.md
new file mode 100644
index 0000000..d63bad5
--- /dev/null
+++ b/cmd/README.md
@@ -0,0 +1,3 @@
+# Cmd
+
+These are examples that can be built using EV. Because they are modular the apps can be mixed an matched by including the different source files linked from `cmd/ev`.
\ No newline at end of file
diff --git a/cmd/ev/app.msgbus.go b/cmd/ev/app.msgbus.go
new file mode 100644
index 0000000..e682106
--- /dev/null
+++ b/cmd/ev/app.msgbus.go
@@ -0,0 +1,34 @@
+package main
+
+import (
+ "context"
+ "fmt"
+
+ "go.sour.is/ev"
+ "go.sour.is/tools/app/msgbus"
+ "go.sour.is/ev/driver/projecter"
+ "go.sour.is/pkg/lg"
+ "go.sour.is/pkg/service"
+ "go.sour.is/pkg/slice"
+)
+
+var _ = apps.Register(50, func(ctx context.Context, svc *service.Harness) error {
+ ctx, span := lg.Span(ctx)
+ defer span.End()
+
+ span.AddEvent("Enable Msgbus")
+ eventstore, ok := slice.Find[*ev.EventStore](svc.Services...)
+ if !ok {
+ return fmt.Errorf("*es.EventStore not found in services")
+ }
+ eventstore.Option(projecter.New(ctx, msgbus.Projector))
+
+ msgbus, err := msgbus.New(ctx, eventstore)
+ if err != nil {
+ span.RecordError(err)
+ return err
+ }
+ svc.Add(msgbus)
+
+ return nil
+})
diff --git a/cmd/ev/app.peerfinder.go b/cmd/ev/app.peerfinder.go
new file mode 100644
index 0000000..26ad36f
--- /dev/null
+++ b/cmd/ev/app.peerfinder.go
@@ -0,0 +1,44 @@
+package main
+
+import (
+ "context"
+ "fmt"
+
+ "go.sour.is/pkg/env"
+ "go.sour.is/pkg/lg"
+ "go.sour.is/pkg/service"
+ "go.sour.is/pkg/slice"
+
+ "go.sour.is/ev"
+ "go.sour.is/tools/app/peerfinder"
+ "go.sour.is/ev/driver/projecter"
+)
+
+var _ = apps.Register(50, func(ctx context.Context, svc *service.Harness) error {
+ ctx, span := lg.Span(ctx)
+ defer span.End()
+
+ span.AddEvent("Enable Peers")
+
+ eventstore, ok := slice.Find[*ev.EventStore](svc.Services...)
+ if !ok {
+ return fmt.Errorf("*es.EventStore not found in services")
+ }
+ eventstore.Option(projecter.New(ctx, peerfinder.Projector))
+
+ peers, err := peerfinder.New(ctx, eventstore, env.Secret("PEER_STATUS", "").Secret())
+ if err != nil {
+ span.RecordError(err)
+ return err
+ }
+ svc.RunOnce(ctx, peers.RefreshJob)
+ svc.NewCron("0,15,30,45", peers.RefreshJob)
+ svc.RunOnce(ctx, peers.CleanJob)
+ svc.NewCron("0 1", peers.CleanJob)
+ svc.OnStart(peers.Run)
+ svc.OnStop(peers.Stop)
+
+ svc.Add(peers)
+
+ return nil
+})
diff --git a/cmd/ev/app.salty.go b/cmd/ev/app.salty.go
new file mode 100644
index 0000000..d4a9ff5
--- /dev/null
+++ b/cmd/ev/app.salty.go
@@ -0,0 +1,64 @@
+package main
+
+import (
+ "context"
+ "fmt"
+ "net/http"
+ "net/url"
+ "os"
+ "path/filepath"
+ "strings"
+
+ "go.sour.is/ev"
+ "go.sour.is/tools/app/salty"
+ "go.sour.is/pkg/env"
+ "go.sour.is/pkg/lg"
+ "go.sour.is/pkg/service"
+ "go.sour.is/pkg/slice"
+)
+
+var _ = apps.Register(50, func(ctx context.Context, svc *service.Harness) error {
+ ctx, span := lg.Span(ctx)
+ defer span.End()
+
+ span.AddEvent("Enable Salty")
+ eventstore, ok := slice.Find[*ev.EventStore](svc.Services...)
+ if !ok {
+ return fmt.Errorf("*es.EventStore not found in services")
+ }
+
+ addr := "localhost"
+ if ht, ok := slice.Find[*http.Server](svc.Services...); ok {
+ addr = ht.Addr
+ }
+
+ var opts []salty.Option
+
+ base, err := url.JoinPath(env.Default("SALTY_BASE_URL", "http://"+addr), "inbox")
+ if err != nil {
+ span.RecordError(err)
+ return err
+ }
+ opts = append(opts, salty.WithBaseURL(base))
+
+ if p := env.Default("SALTY_BLOB_DIR", ""); p != "" {
+ if strings.HasPrefix(p, "~/") {
+ home, _ := os.UserHomeDir()
+ p = filepath.Join(home, strings.TrimPrefix(p, "~/"))
+ }
+ opts = append(opts, salty.WithBlobStore(p))
+ }
+
+ salty, err := salty.New(
+ ctx,
+ eventstore,
+ opts...,
+ )
+ if err != nil {
+ span.RecordError(err)
+ return err
+ }
+ svc.Add(salty)
+
+ return nil
+})
diff --git a/cmd/ev/app.twtxt.go b/cmd/ev/app.twtxt.go
new file mode 100644
index 0000000..f3f9b6d
--- /dev/null
+++ b/cmd/ev/app.twtxt.go
@@ -0,0 +1,17 @@
+package main
+
+import (
+ "context"
+
+ "go.sour.is/pkg/lg"
+ "go.sour.is/pkg/service"
+)
+
+var _ = apps.Register(50, func(ctx context.Context, svc *service.Harness) error {
+ _, span := lg.Span(ctx)
+ defer span.End()
+
+ span.AddEvent("Enable Twtxt")
+
+ return nil
+})
diff --git a/cmd/ev/app.webfinger.go b/cmd/ev/app.webfinger.go
new file mode 100644
index 0000000..56a6a1a
--- /dev/null
+++ b/cmd/ev/app.webfinger.go
@@ -0,0 +1,52 @@
+package main
+
+import (
+ "context"
+ "fmt"
+ "strings"
+ "time"
+
+ "github.com/patrickmn/go-cache"
+
+ "go.sour.is/ev"
+ "go.sour.is/tools/app/webfinger"
+ "go.sour.is/pkg/env"
+ "go.sour.is/pkg/lg"
+ "go.sour.is/pkg/service"
+ "go.sour.is/pkg/slice"
+)
+
+var (
+ defaultExpire = 3 * time.Minute
+ cleanupInterval = 10 * time.Minute
+)
+
+var _ = apps.Register(50, func(ctx context.Context, svc *service.Harness) error {
+ ctx, span := lg.Span(ctx)
+ defer span.End()
+
+ span.AddEvent("Enable WebFinger")
+ eventstore, ok := slice.Find[*ev.EventStore](svc.Services...)
+ if !ok {
+ return fmt.Errorf("*es.EventStore not found in services")
+ }
+
+ cache := cache.New(defaultExpire, cleanupInterval)
+ var withCache webfinger.WithCache = (func(s string) bool {
+ if _, ok := cache.Get(s); ok {
+ return true
+ }
+ cache.SetDefault(s, true)
+ return false
+ })
+ var withHostnames webfinger.WithHostnames = strings.Fields(env.Default("WEBFINGER_DOMAINS", "sour.is"))
+
+ wf, err := webfinger.New(ctx, eventstore, withCache, withHostnames)
+ if err != nil {
+ span.RecordError(err)
+ return err
+ }
+ svc.Add(wf)
+
+ return nil
+})
diff --git a/cmd/ev/main.go b/cmd/ev/main.go
new file mode 100644
index 0000000..b1117e8
--- /dev/null
+++ b/cmd/ev/main.go
@@ -0,0 +1,41 @@
+package main
+
+import (
+ "context"
+ "errors"
+ "log"
+ "net/http"
+ "os"
+ "os/signal"
+
+ "go.sour.is/pkg/lg"
+ "go.sour.is/pkg/service"
+)
+
+var apps service.Apps
+var appName, version = service.AppName()
+
+func main() {
+ ctx, cancel := signal.NotifyContext(context.Background(), os.Interrupt, os.Kill)
+ go func() {
+ <-ctx.Done()
+ defer cancel() // restore interrupt function
+ }()
+ if err := run(ctx); err != nil {
+ log.Fatal(err)
+ os.Exit(1)
+ }
+}
+func run(ctx context.Context) error {
+ svc := &service.Harness{}
+ ctx, stop := lg.Init(ctx, appName)
+ svc.OnStop(stop)
+ svc.Add(lg.NewHTTP(ctx))
+ svc.Setup(ctx, apps.Apps()...)
+
+ // Run application
+ if err := svc.Run(ctx, appName, version); err != nil && !errors.Is(err, http.ErrServerClosed) {
+ return err
+ }
+ return nil
+}
diff --git a/cmd/ev/svc.es.go b/cmd/ev/svc.es.go
new file mode 100644
index 0000000..1ad26d5
--- /dev/null
+++ b/cmd/ev/svc.es.go
@@ -0,0 +1,54 @@
+package main
+
+import (
+ "context"
+
+ "go.sour.is/pkg/env"
+ "go.sour.is/pkg/lg"
+ "go.sour.is/pkg/service"
+ "go.uber.org/multierr"
+
+ "go.sour.is/ev"
+ diskstore "go.sour.is/ev/driver/disk-store"
+ memstore "go.sour.is/ev/driver/mem-store"
+ "go.sour.is/ev/driver/projecter"
+ resolvelinks "go.sour.is/ev/driver/resolve-links"
+ "go.sour.is/ev/driver/streamer"
+ "go.sour.is/ev/event"
+ gql_ev "go.sour.is/ev/gql"
+)
+
+var _ = apps.Register(10, func(ctx context.Context, svc *service.Harness) error {
+ ctx, span := lg.Span(ctx)
+ defer span.End()
+
+ // setup eventstore
+ err := multierr.Combine(
+ ev.Init(ctx),
+ event.Init(ctx),
+ diskstore.Init(ctx),
+ memstore.Init(ctx),
+ )
+ if err != nil {
+ span.RecordError(err)
+ return err
+ }
+
+ eventstore, err := ev.Open(
+ ctx,
+ env.Default("EV_DATA", "mem:"),
+ resolvelinks.New(),
+ streamer.New(ctx),
+ projecter.New(
+ ctx,
+ projecter.DefaultProjection,
+ ),
+ )
+ if err != nil {
+ span.RecordError(err)
+ return err
+ }
+ svc.Add(eventstore, &gql_ev.EventStore{EventStore: eventstore})
+
+ return nil
+})
diff --git a/cmd/ev/svc.gql.go b/cmd/ev/svc.gql.go
new file mode 100644
index 0000000..0059ea2
--- /dev/null
+++ b/cmd/ev/svc.gql.go
@@ -0,0 +1,40 @@
+package main
+
+import (
+ "context"
+ "net/http"
+
+ "go.sour.is/pkg/gql/resolver"
+ "go.sour.is/pkg/lg"
+ "go.sour.is/pkg/mux"
+ "go.sour.is/pkg/service"
+ "go.sour.is/pkg/slice"
+ "go.sour.is/tools/app/gql"
+)
+
+var _ = apps.Register(90, func(ctx context.Context, svc *service.Harness) error {
+ ctx, span := lg.Span(ctx)
+ defer span.End()
+
+ span.AddEvent("Enable GraphQL")
+ gql, err := resolver.New(ctx, &gql.Resolver{}, slice.FilterType[resolver.IsResolver](svc.Services...)...)
+ if err != nil {
+ span.RecordError(err)
+ return err
+ }
+ gql.CheckOrigin = func(r *http.Request) bool {
+ switch r.Header.Get("Origin") {
+ case "https://ev.sour.is", "https://www.graphqlbin.com", "http://localhost:8080":
+ return true
+ default:
+ return false
+ }
+ }
+
+ svc.Add(gql)
+ svc.Add(mux.RegisterHTTP(func(mux *http.ServeMux) {
+ mux.Handle("/", http.RedirectHandler("/playground", http.StatusTemporaryRedirect))
+ }))
+
+ return nil
+})
diff --git a/cmd/ev/svc.http.go b/cmd/ev/svc.http.go
new file mode 100644
index 0000000..871ba45
--- /dev/null
+++ b/cmd/ev/svc.http.go
@@ -0,0 +1,47 @@
+package main
+
+import (
+ "context"
+ "log"
+ "net/http"
+ "strings"
+
+ "github.com/rs/cors"
+
+ "go.sour.is/pkg/env"
+ "go.sour.is/pkg/lg"
+ "go.sour.is/pkg/mux"
+ "go.sour.is/pkg/service"
+ "go.sour.is/pkg/slice"
+)
+
+var _ = apps.Register(20, func(ctx context.Context, svc *service.Harness) error {
+ s := &http.Server{}
+ svc.Add(s)
+
+ mux := mux.New()
+ s.Handler = cors.AllowAll().Handler(mux)
+
+ // s.Handler = http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+ // log.Println(r.URL.Path)
+ // mux.ServeHTTP(w, r)
+ // })
+
+ s.Addr = env.Default("EV_HTTP", ":8080")
+ if strings.HasPrefix(s.Addr, ":") {
+ s.Addr = "[::]" + s.Addr
+ }
+ svc.OnStart(func(ctx context.Context) error {
+ _, span := lg.Span(ctx)
+ defer span.End()
+
+ log.Print("Listen on ", s.Addr)
+ span.AddEvent("begin listen and serve on " + s.Addr)
+
+ mux.Add(slice.FilterType[interface{ RegisterHTTP(*http.ServeMux) }](svc.Services...)...)
+ return s.ListenAndServe()
+ })
+ svc.OnStop(s.Shutdown)
+
+ return nil
+})
diff --git a/cmd/msgbus/app.msgbus.go b/cmd/msgbus/app.msgbus.go
new file mode 120000
index 0000000..c6b168b
--- /dev/null
+++ b/cmd/msgbus/app.msgbus.go
@@ -0,0 +1 @@
+../ev/app.msgbus.go
\ No newline at end of file
diff --git a/cmd/msgbus/main.go b/cmd/msgbus/main.go
new file mode 120000
index 0000000..7e61bac
--- /dev/null
+++ b/cmd/msgbus/main.go
@@ -0,0 +1 @@
+../ev/main.go
\ No newline at end of file
diff --git a/cmd/msgbus/svc.es.go b/cmd/msgbus/svc.es.go
new file mode 120000
index 0000000..6280e25
--- /dev/null
+++ b/cmd/msgbus/svc.es.go
@@ -0,0 +1 @@
+../ev/svc.es.go
\ No newline at end of file
diff --git a/cmd/msgbus/svc.gql.go b/cmd/msgbus/svc.gql.go
new file mode 120000
index 0000000..36864cf
--- /dev/null
+++ b/cmd/msgbus/svc.gql.go
@@ -0,0 +1 @@
+../ev/svc.gql.go
\ No newline at end of file
diff --git a/cmd/msgbus/svc.http.go b/cmd/msgbus/svc.http.go
new file mode 120000
index 0000000..3dc665f
--- /dev/null
+++ b/cmd/msgbus/svc.http.go
@@ -0,0 +1 @@
+../ev/svc.http.go
\ No newline at end of file
diff --git a/cmd/peers/app.peerfinder.go b/cmd/peers/app.peerfinder.go
new file mode 120000
index 0000000..d03b992
--- /dev/null
+++ b/cmd/peers/app.peerfinder.go
@@ -0,0 +1 @@
+../ev/app.peerfinder.go
\ No newline at end of file
diff --git a/cmd/peers/main.go b/cmd/peers/main.go
new file mode 120000
index 0000000..7e61bac
--- /dev/null
+++ b/cmd/peers/main.go
@@ -0,0 +1 @@
+../ev/main.go
\ No newline at end of file
diff --git a/cmd/peers/svc.es.go b/cmd/peers/svc.es.go
new file mode 120000
index 0000000..6280e25
--- /dev/null
+++ b/cmd/peers/svc.es.go
@@ -0,0 +1 @@
+../ev/svc.es.go
\ No newline at end of file
diff --git a/cmd/peers/svc.http.go b/cmd/peers/svc.http.go
new file mode 120000
index 0000000..3dc665f
--- /dev/null
+++ b/cmd/peers/svc.http.go
@@ -0,0 +1 @@
+../ev/svc.http.go
\ No newline at end of file
diff --git a/cmd/salty/app.msgbus.go b/cmd/salty/app.msgbus.go
new file mode 120000
index 0000000..c6b168b
--- /dev/null
+++ b/cmd/salty/app.msgbus.go
@@ -0,0 +1 @@
+../ev/app.msgbus.go
\ No newline at end of file
diff --git a/cmd/salty/app.salty.go b/cmd/salty/app.salty.go
new file mode 120000
index 0000000..2098028
--- /dev/null
+++ b/cmd/salty/app.salty.go
@@ -0,0 +1 @@
+../ev/app.salty.go
\ No newline at end of file
diff --git a/cmd/salty/main.go b/cmd/salty/main.go
new file mode 120000
index 0000000..7e61bac
--- /dev/null
+++ b/cmd/salty/main.go
@@ -0,0 +1 @@
+../ev/main.go
\ No newline at end of file
diff --git a/cmd/salty/svc.es.go b/cmd/salty/svc.es.go
new file mode 120000
index 0000000..6280e25
--- /dev/null
+++ b/cmd/salty/svc.es.go
@@ -0,0 +1 @@
+../ev/svc.es.go
\ No newline at end of file
diff --git a/cmd/salty/svc.http.go b/cmd/salty/svc.http.go
new file mode 120000
index 0000000..3dc665f
--- /dev/null
+++ b/cmd/salty/svc.http.go
@@ -0,0 +1 @@
+../ev/svc.http.go
\ No newline at end of file
diff --git a/cmd/webfinger-cli/main.go b/cmd/webfinger-cli/main.go
new file mode 100644
index 0000000..dc4dd95
--- /dev/null
+++ b/cmd/webfinger-cli/main.go
@@ -0,0 +1,290 @@
+package main
+
+import (
+ "bufio"
+ "context"
+ "crypto/ed25519"
+ "encoding/base64"
+ "errors"
+ "fmt"
+ "io"
+ "net/http"
+ "net/url"
+ "os"
+ "os/signal"
+ "path/filepath"
+ "strings"
+
+ "github.com/docopt/docopt-go"
+ "go.sour.is/pkg/xdg"
+ "gopkg.in/yaml.v3"
+
+ "go.sour.is/tools/app/webfinger"
+)
+
+var usage = `Webfinger CLI.
+usage:
+ webfinger-cli gen [--key KEY] [--force]
+ webfinger-cli get [--host HOST] Raw JRD
+
+
+Status: {{ .Status }}
+
+{{ .Body | printf "%s" }}
+
+