✨ Send account events to ozone

automod/capture/testing.go

@@ -7,6 +7,7 @@ import (
 	"io"
 	"os"
 
+	comatproto "github.com/bluesky-social/indigo/api/atproto"
 	"github.com/bluesky-social/indigo/atproto/identity"
 	"github.com/bluesky-social/indigo/atproto/syntax"
 	"github.com/bluesky-social/indigo/automod"
@@ -38,12 +39,19 @@ func ProcessCaptureRules(eng *automod.Engine, capture AccountCapture) error {
 	ctx := context.Background()
 
 	did := capture.AccountMeta.Identity.DID
+	handle := capture.AccountMeta.Identity.Handle.String()
 	dir := identity.NewMockDirectory()
 	dir.Insert(*capture.AccountMeta.Identity)
 	eng.Directory = &dir
 
 	// initial identity rules
-	eng.ProcessIdentityEvent(ctx, "new", did)
+	identEvent := comatproto.SyncSubscribeRepos_Identity{
+		Did:    did.String(),
+		Handle: &handle,
+		Seq:    12345,
+		Time:   syntax.DatetimeNow().String(),
+	}
+	eng.ProcessIdentityEvent(ctx, identEvent)
 
 	// all the post rules
 	for _, pr := range capture.PostRecords {

automod/engine/context.go

@@ -243,7 +243,6 @@ func (c *BaseContext) GetAccountMeta(did syntax.DID) *AccountMeta {
 func (c *BaseContext) Increment(name, val string) {
 	c.effects.Increment(name, val)
 }
-
 func (c *BaseContext) IncrementDistinct(name, bucket, val string) {
 	c.effects.IncrementDistinct(name, bucket, val)
 }
@@ -292,6 +291,10 @@ func (c *RecordContext) TakedownBlob(cid string) {
 	c.effects.TakedownBlob(cid)
 }
 
+func (c *RecordContext) PersistRecordOzoneEvent() {
+	c.effects.PersistRecordOzoneEvent()
+}
+
 func (c *NotificationContext) Reject() {
 	c.effects.Reject()
 }

automod/engine/effects.go

@@ -58,6 +58,8 @@ type Effects struct {
 	RejectEvent bool
 	// Services, if any, which should blast out a notification about this even (eg, Slack)
 	NotifyServices []string
+	// If "true", and Ozone event history is configured/enable, then sent a mod event to ozone backend for this event
+	PersistOzoneRecordEvent bool
 }
 
 // Enqueues the named counter to be incremented at the end of all rule processing. Will automatically increment for all time periods.
@@ -199,3 +201,8 @@ func (e *Effects) Notify(srv string) {
 func (e *Effects) Reject() {
 	e.RejectEvent = true
 }
+
+// Marks that this subject should be recorded in ozone history
+func (e *Effects) PersistRecordOzoneEvent() {
+	e.PersistOzoneRecordEvent = true
+}