···

       
84
       
 
       
				EnvVars:  []string{"PERUSE_NERVANA_API_KEY"},

     

       
85
       
 
       
				Required: true,

     

       
86
       
 
       
			},

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
87
       
 
       
		},

     

       
88
       
 
       
		Action: run,

     

       
89
       
 
       
	}

     
···

       
114
       
 
       
		SuggestedFollowsRkey: cmd.String("suggested-follows-rkey"),

     

       
115
       
 
       
		NervanaEndpoint:      cmd.String("nervana-endpoint"),

     

       
116
       
 
       
		NervanaApiKey:        cmd.String("nervana-api-key"),

     

       
0
       
 
       

     

       
117
       
 
       
	})

     

       
118
       
 
       
	if err != nil {

     

       
119
       
 
       
		logger.Error("error creating server", "error", err)

     

···

       
84
       
 
       
				EnvVars:  []string{"PERUSE_NERVANA_API_KEY"},

     

       
85
       
 
       
				Required: true,

     

       
86
       
 
       
			},

     

       
87
       
+
       
			&cli.StringFlag{

     

       
88
       
+
       
				Name:    "relay-host",

     

       
89
       
+
       
				EnvVars: []string{"PERUSE_RELAY_HOST"},

     

       
90
       
+
       
				Value:   "wss://bsky.network",

     

       
91
       
+
       
			},

     

       
92
       
 
       
		},

     

       
93
       
 
       
		Action: run,

     

       
94
       
 
       
	}

     
···

       
119
       
 
       
		SuggestedFollowsRkey: cmd.String("suggested-follows-rkey"),

     

       
120
       
 
       
		NervanaEndpoint:      cmd.String("nervana-endpoint"),

     

       
121
       
 
       
		NervanaApiKey:        cmd.String("nervana-api-key"),

     

       
122
       
+
       
		RelayHost:            cmd.String("relay-host"),

     

       
123
       
 
       
	})

     

       
124
       
 
       
	if err != nil {

     

       
125
       
 
       
		logger.Error("error creating server", "error", err)

     

···

       
65
       
 
       
	s.logger.Info("connecting to relay", "url", u.String())

     

       
66
       
 
       


     

       
67
       
 
       
	con, _, err := d.Dial(u.String(), http.Header{

     

       
68
       
-
       
		"user-agent": []string{"photocopy/0.0.0"},

     

       
69
       
 
       
	})

     

       
70
       
 
       
	if err != nil {

     

       
71
       
 
       
		return fmt.Errorf("failed to connect to relay: %w", err)

     

···

       
65
       
 
       
	s.logger.Info("connecting to relay", "url", u.String())

     

       
66
       
 
       


     

       
67
       
 
       
	con, _, err := d.Dial(u.String(), http.Header{

     

       
68
       
+
       
		"user-agent": []string{"peruse/0.0.0"},

     

       
69
       
 
       
	})

     

       
70
       
 
       
	if err != nil {

     

       
71
       
 
       
		return fmt.Errorf("failed to connect to relay: %w", err)

     

···

       
142
       
 
       
		}

     

       
143
       
 
       
	}()

     

       
144
       
 
       


     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
145
       
 
       
	<-ctx.Done()

     

       
146
       
 
       


     

       
147
       
 
       
	s.logger.Info("shutting down server...")

     

···

       
142
       
 
       
		}

     

       
143
       
 
       
	}()

     

       
144
       
 
       


     

       
145
       
+
       
	go func(ctx context.Context, cancel context.CancelFunc) {

     

       
146
       
+
       
		if err := s.startConsumer(ctx, cancel); err != nil {

     

       
147
       
+
       
			s.logger.Error("error starting consumer", "error", err)

     

       
148
       
+
       
		}

     

       
149
       
+
       
	}(ctx, cancel)

     

       
150
       
+
       


     

       
151
       
 
       
	<-ctx.Done()

     

       
152
       
 
       


     

       
153
       
 
       
	s.logger.Info("shutting down server...")