commit 08ca8e2bfb11d241e2efb85142d6785b19013470 · edavis.dev/monarch

+1 -2

cmd/monarch/census.go

···

       36
       36
        
       		return

     

       37
       37
        
       	}

     

       38
       38
        
       

     

       39
       39
       -
       	jmstore.GetOrCreateJob(ctx, "did:plc:4nsduwlpivpuur4mqkbfvm6a", backfill.StateEnqueued)

     

       40
       40
       -
       

     

       41
       39
        
       	curs, _ := cs.cursor.Get("repos")

     

       42
       40
        
       	for {

     

       43
       41
        
       		select {

     

       44
       42
        
       		case <-ctx.Done():

     

       45
       43
        
       			slog.Info("stopping repo census")

     

       46
       44
        
       			return

     

       45
       45
       +
       		default:

     

       47
       46
        
       		}

     

       48
       47
        
       

     

       49
       48
        
       		res, err := atproto.SyncListRepos(ctx, xrpcc, curs, 1000)

+2 -13

cmd/monarch/handlers.go

···

       3
       3
        
       import (

     

       4
       4
        
       	"context"

     

       5
       5
        
       	"fmt"

     

       6
       6
       -
       	"log/slog"

     

       7
       6
        
       

     

       8
       7
        
       	"github.com/bluesky-social/indigo/atproto/syntax"

     

       9
       8
        
       	"github.com/ipfs/go-cid"

     
···

       73
       72
        
       }

     

       74
       73
        
       

     

       75
       74
        
       type helper struct {

     

       76
       76
       -
       	db *gorm.DB

     

       77
       77
       -
       	uri syntax.ATURI

     

       75
       75
       +
       	db     *gorm.DB

     

       76
       76
       +
       	uri    syntax.ATURI

     

       78
       77
        
       	record []byte

     

       79
       78
        
       	action Action

     

       80
       79
        
       }

     
···

       145
       144
        
       		}

     

       146
       145
        
       

     

       147
       146
        
       	case syntax.NSID("app.bsky.feed.repost"):

     

       148
       148
       -
       		if uri.RecordKey() == "3lvhrfzuzb32k" || uri.RecordKey() == "3lvcmas2cw32k" {

     

       149
       149
       -
       			slog.Info("got repost", "uri", uri)

     

       150
       150
       -
       		} else {

     

       151
       151
       -
       			return nil

     

       152
       152
       -
       		}

     

       153
       153
       -
       

     

       154
       154
       -
       		// if err := hs.store.Where(models.FeedRepost{ID: string(uri)}).Assign(repost).FirstOrCreate(&models.FeedRepost{}).Error; err != nil {

     

       155
       155
       -
       		// 	return fmt.Errorf("error upserting feed repost: %w", err)

     

       156
       156
       -
       		// }

     

       157
       157
       -
       

     

       158
       147
        
       		return upsertRecord(models.NewFeedRepost, opts)

     

       159
       148
        
       

     

       160
       149
        
       	case syntax.NSID("app.bsky.feed.threadgate"):

+1 -2

cmd/monarch/main.go

···

       61
       61
        
       	rsc := events.RepoStreamCallbacks{

     

       62
       62
        
       		RepoCommit: func(evt *comatproto.SyncSubscribeRepos_Commit) error {

     

       63
       63
        
       			app.cursor.SetFirehoseCursor(evt.Seq)

     

       64
       64
       -
       			//return app.backfill.HandleEvent(ctx, evt)

     

       65
       65
       -
       			return nil

     

       64
       64
       +
       			return app.backfill.HandleEvent(ctx, evt)

     

       66
       65
        
       		},

     

       67
       66
        
       		// TODO account

     

       68
       67
        
       		// TODO identity

+2 -18

models/feed_repost.go

···

       13
       13
        
       	ID string `gorm:"primaryKey"`

     

       14
       14
        
       

     

       15
       15
        
       	CreatedAt string

     

       16
       16
       -
       

     

       17
       17
       -
       	Subject *StrongRef `gorm:"embedded;embeddedPrefix:subject_"`

     

       18
       18
       -
       	Via     *StrongRef `gorm:"embedded;embeddedPrefix:via_"`

     

       19
       19
       -
       

     

       20
       20
       -
       	// SubjectUri string

     

       21
       21
       -
       	// ViaUri     string

     

       16
       16
       +
       	Subject   *StrongRef `gorm:"embedded;embeddedPrefix:subject_"`

     

       17
       17
       +
       	Via       *StrongRef `gorm:"embedded;embeddedPrefix:via_"`

     

       22
       18
        
       

     

       23
       19
        
       	AutoCreatedAt time.Time `gorm:"autoCreateTime"`

     

       24
       20
        
       	AutoUpdatedAt time.Time `gorm:"autoUpdateTime"`

     
···

       30
       26
        
       		slog.Error("could not unmarshal feed repost CBOR", "err", err)

     

       31
       27
        
       		return nil

     

       32
       28
        
       	}

     

       33
       33
       -
       

     

       34
       34
       -
       	slog.Info("repost debug", "out", out)

     

       35
       29
        
       

     

       36
       30
        
       	repost := FeedRepost{

     

       37
       31
        
       		ID:        string(uri),

     
···

       39
       33
        
       	}

     

       40
       34
        
       

     

       41
       35
        
       	if out.Subject != nil {

     

       42
       42
       -
       		slog.Info("out.Subject is not nil")

     

       43
       36
        
       		repost.Subject = &StrongRef{

     

       44
       37
        
       			Uri: out.Subject.Uri,

     

       45
       38
        
       			Cid: out.Subject.Cid,

     

       46
       39
        
       		}

     

       47
       47
       -
       		// repost.SubjectUri = out.Subject.Uri

     

       48
       48
       -
       	} else {

     

       49
       49
       -
       		slog.Info("out.Subject is nil")

     

       50
       40
        
       	}

     

       51
       41
        
       

     

       52
       42
        
       	if out.Via != nil {

     

       53
       53
       -
       		slog.Info("out.Via is not nil")

     

       54
       43
        
       		repost.Via = &StrongRef{

     

       55
       44
        
       			Uri: out.Via.Uri,

     

       56
       45
        
       			Cid: out.Via.Cid,

     

       57
       46
        
       		}

     

       58
       58
       -
       		// repost.ViaUri = out.Via.Uri

     

       59
       59
       -
       	} else {

     

       60
       60
       -
       		slog.Info("out.Via is nil")

     

       61
       47
        
       	}

     

       62
       62
       -
       

     

       63
       63
       -
       	slog.Info("final repost", "repost", repost)

     

       64
       48
        
       

     

       65
       49
        
       	return &repost

     

       66
       50
        
       }