tjh.dev
forked from
tangled.org/core
Mirror of @tangled.org/core. Running on a Raspberry Pi Zero 2 (Please be gentle).
1package knotserver
2
3import (
4 "context"
5 "fmt"
6 "net/http"
7
8 "github.com/bluesky-social/indigo/xrpc"
9 "github.com/urfave/cli/v3"
10 "tangled.org/core/api/tangled"
11 "tangled.org/core/hook"
12 "tangled.org/core/jetstream"
13 "tangled.org/core/knotserver/config"
14 "tangled.org/core/knotserver/db"
15 "tangled.org/core/log"
16 "tangled.org/core/notifier"
17 "tangled.org/core/rbac"
18)
19
20func Command() *cli.Command {
21 return &cli.Command{
22 Name: "server",
23 Usage: "run a knot server",
24 Action: Run,
25 Description: `
26 Environment variables:
27 KNOT_SERVER_LISTEN_ADDR (default: 0.0.0.0:5555)
28 KNOT_SERVER_INTERNAL_LISTEN_ADDR (default: 127.0.0.1:5444)
29 KNOT_SERVER_DB_PATH (default: knotserver.db)
30 KNOT_SERVER_HOSTNAME (required)
31 KNOT_SERVER_JETSTREAM_ENDPOINT (default: wss://jetstream1.us-west.bsky.network/subscribe)
32 KNOT_SERVER_OWNER (required)
33 KNOT_SERVER_LOG_DIDS (default: true)
34 KNOT_SERVER_DEV (default: false)
35 KNOT_REPO_SCAN_PATH (default: /home/git)
36 KNOT_REPO_README (comma-separated list)
37 KNOT_REPO_MAIN_BRANCH (default: main)
38 KNOT_GIT_USER_NAME (default: Tangled)
39 KNOT_GIT_USER_EMAIL (default: noreply@tangled.sh)
40 APPVIEW_ENDPOINT (default: https://tangled.sh)
41 `,
42 }
43}
44
45func Run(ctx context.Context, cmd *cli.Command) error {
46 logger := log.FromContext(ctx)
47 logger = log.SubLogger(logger, cmd.Name)
48 ctx = log.IntoContext(ctx, logger)
49
50 c, err := config.Load(ctx)
51 if err != nil {
52 return fmt.Errorf("failed to load config: %w", err)
53 }
54
55 err = hook.Setup(hook.Config(
56 hook.WithScanPath(c.Repo.ScanPath),
57 hook.WithInternalApi(c.Server.InternalListenAddr),
58 ))
59 if err != nil {
60 return fmt.Errorf("failed to setup hooks: %w", err)
61 }
62 logger.Info("successfully finished setting up hooks")
63
64 if c.Server.Dev {
65 logger.Info("running in dev mode, signature verification is disabled")
66 }
67
68 db, err := db.Setup(ctx, c.Server.DBPath)
69 if err != nil {
70 return fmt.Errorf("failed to load db: %w", err)
71 }
72
73 e, err := rbac.NewEnforcer(c.Server.DBPath)
74 if err != nil {
75 return fmt.Errorf("failed to setup rbac enforcer: %w", err)
76 }
77
78 e.E.EnableAutoSave(true)
79
80 jc, err := jetstream.NewJetstreamClient(c.Server.JetstreamEndpoint, "knotserver", []string{
81 tangled.PublicKeyNSID,
82 tangled.KnotMemberNSID,
83 tangled.RepoPullNSID,
84 tangled.RepoCollaboratorNSID,
85 }, nil, log.SubLogger(logger, "jetstream"), db, true, c.Server.LogDids)
86 if err != nil {
87 logger.Error("failed to setup jetstream", "error", err)
88 }
89
90 notifier := notifier.New()
91
92 mux, err := Setup(ctx, c, db, e, jc, ¬ifier)
93 if err != nil {
94 return fmt.Errorf("failed to setup server: %w", err)
95 }
96
97 imux := Internal(ctx, c, db, e, ¬ifier)
98
99 logger.Info("starting internal server", "address", c.Server.InternalListenAddr)
100 go http.ListenAndServe(c.Server.InternalListenAddr, imux)
101
102 // TODO(boltless): too lazy here. should clear this up
103 go func() {
104 input := &tangled.SyncRequestCrawl_Input{
105 Hostname: c.Server.Hostname,
106 }
107 for _, knotmirror := range c.KnotMirrors {
108 xrpcc := xrpc.Client{Host: knotmirror}
109 if err := tangled.SyncRequestCrawl(ctx, &xrpcc, input); err != nil {
110 logger.Error("error requesting crawl", "err", err)
111 } else {
112 logger.Info("crawl requested successfully")
113 }
114 }
115 }()
116
117 logger.Info("starting main server", "address", c.Server.ListenAddr)
118 logger.Error("server error", "error", http.ListenAndServe(c.Server.ListenAddr, mux))
119
120 return nil
121}