Tweaks

neilalexander · Mar 15, 2024 · f9f45da · f9f45da
1 parent e280ba5
commit f9f45da
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/roomserver/external/client.go b/roomserver/external/client.go
@@ -20,7 +20,7 @@ func NewRoomserverAPIClient(intapi api.RoomserverInternalAPI, nats *jetstream.NA
 	return c
 }
 
-func (c *RoomserverAPIClient) PPerformBackfill(
+func (c *RoomserverAPIClient) PerformBackfill(
 	ctx context.Context,
 	req *api.PerformBackfillRequest,
 	res *api.PerformBackfillResponse,

diff --git a/setup/jetstream/nats.go b/setup/jetstream/nats.go
@@ -239,7 +239,7 @@ func setupNATS(process *process.ProcessContext, cfg *config.JetStream, nc *natsc
 	return s, nc
 }
 
-func CallAPI[req, res any](s *NATSInstance, component, endpoint string, rq req, rs res) error {
+func CallAPI[req, res any](s *NATSInstance, component, endpoint string, rq *req, rs *res) error {
 	subj := fmt.Sprintf("API.%s.%s", component, endpoint)
 	j, err := json.Marshal(rq)
 	if err != nil {
@@ -252,15 +252,16 @@ func CallAPI[req, res any](s *NATSInstance, component, endpoint string, rq req,
 	return json.Unmarshal(resp.Data, rs)
 }
 
-func ListenAPI[req, res any](s *NATSInstance, component, endpoint string, fn func(req req, res res) error) error {
+func ListenAPI[req, res any](s *NATSInstance, component, endpoint string, fn func(*req, *res) error) error {
 	subj := fmt.Sprintf("API.%s.%s", component, endpoint)
+	logrus.Infof("Listening on %s", subj)
 	_, err := s.Conn.Subscribe(subj, func(msg *natsclient.Msg) {
 		var req req
 		var res res
 		if err := json.Unmarshal(msg.Data, &req); err != nil {
 			return
 		}
-		if err := fn(req, res); err != nil {
+		if err := fn(&req, &res); err != nil {
 			return
 		}
 		j, err := json.Marshal(res)