commit 4a03f37128ff01474316cdec8c0536a1864fdf23 · edavis.dev/monarch

+20
cmd/monarch/handlers.go
···

       5
       5
        
       	"context"

     

       6
       6
        
       	"encoding/json"

     

       7
       7
        
       	"fmt"

     

       8
       8
       +
       	"log/slog"

     

       8
       9
        
       

     

       9
       10
        
       	appbsky "github.com/bluesky-social/indigo/api/bsky"

     

       10
       11
        
       	"github.com/bluesky-social/indigo/atproto/syntax"

     
···

       75
       76
        
       		var out appbsky.LabelerService

     

       76
       77
        
       		out.UnmarshalCBOR(bytes.NewReader(*rec))

     

       77
       78
        
       		body, err = json.Marshal(out)

     

       79
       79
       +
       

     

       80
       80
       +
       	case syntax.NSID("app.bsky.graph.list"):

     

       81
       81
       +
       		var out appbsky.GraphList

     

       82
       82
       +
       		out.UnmarshalCBOR(bytes.NewReader(*rec))

     

       83
       83
       +
       		body, err = json.Marshal(out)

     

       84
       84
       +
       

     

       85
       85
       +
       	case syntax.NSID("app.bsky.graph.verification"):

     

       86
       86
       +
       		var out appbsky.GraphVerification

     

       87
       87
       +
       		out.UnmarshalCBOR(bytes.NewReader(*rec))

     

       88
       88
       +
       		body, err = json.Marshal(out)

     

       89
       89
       +
       

     

       90
       90
       +
       	case syntax.NSID("app.bsky.graph.starterpack"):

     

       91
       91
       +
       		var out appbsky.GraphStarterpack

     

       92
       92
       +
       		out.UnmarshalCBOR(bytes.NewReader(*rec))

     

       93
       93
       +
       		body, err = json.Marshal(out)

     

       94
       94
       +
       

     

       95
       95
       +
       	default:

     

       96
       96
       +
       		slog.Error("tracked collection missing handler", "collection", uri.Collection())

     

       97
       97
       +
       		return nil

     

       78
       98
        
       	}

     

       79
       99
        
       

     

       80
       100
        
       	switch action {