From ed814283a9c691f7ec1111384fd5f98f87ebbda6 Mon Sep 17 00:00:00 2001 From: bryan newbold Date: Thu, 30 Oct 2025 17:16:47 -0700 Subject: [PATCH] updates for queryEvents expansion --- automod/consumer/ozone.go | 1 + automod/engine/persisthelpers.go | 2 ++ cmd/beemo/notify_reports.go | 1 + cmd/gosky/admin.go | 2 ++ 4 files changed, 6 insertions(+) diff --git a/automod/consumer/ozone.go b/automod/consumer/ozone.go index e884d897..ddb8ec11 100644 --- a/automod/consumer/ozone.go +++ b/automod/consumer/ozone.go @@ -80,6 +80,7 @@ func (oc *OzoneConsumer) Run(ctx context.Context) error { "", // subject string "", // subjectType string nil, // types []string + false, // withStrike bool ) if err != nil { oc.Logger.Warn("ozone query events failed; sleeping then will retrying", "err", err, "period", period.String()) diff --git a/automod/engine/persisthelpers.go b/automod/engine/persisthelpers.go index ea9dcda2..5642312b 100644 --- a/automod/engine/persisthelpers.go +++ b/automod/engine/persisthelpers.go @@ -193,6 +193,7 @@ func (eng *Engine) createReportIfFresh(ctx context.Context, xrpcc *xrpc.Client, did.String(), // subject string "", // subjectType string []string{"tools.ozone.moderation.defs#modEventReport"}, // types []string + false, // withStrike bool ) if err != nil { @@ -278,6 +279,7 @@ func (eng *Engine) createRecordReportIfFresh(ctx context.Context, xrpcc *xrpc.Cl uri.String(), // subject string "", // subjectType string []string{"tools.ozone.moderation.defs#modEventReport"}, // types []string + false, // withStrike bool ) if err != nil { return false, err diff --git a/cmd/beemo/notify_reports.go b/cmd/beemo/notify_reports.go index 1af79ea4..3769f39e 100644 --- a/cmd/beemo/notify_reports.go +++ b/cmd/beemo/notify_reports.go @@ -93,6 +93,7 @@ func pollNewReports(ctx context.Context, cmd *cli.Command) error { "", // subject string "", // subjectType string []string{"tools.ozone.moderation.defs#modEventReport"}, // types []string + false, // withStrike bool ) if err != nil { return err diff --git a/cmd/gosky/admin.go b/cmd/gosky/admin.go index c2aa694a..f01a721a 100644 --- a/cmd/gosky/admin.go +++ b/cmd/gosky/admin.go @@ -415,6 +415,7 @@ var listReportsCmd = &cli.Command{ "", // subject string "", // subjectType string []string{"tools.ozone.moderation.defs#modEventReport"}, // types []string + false, // withStrike bool ) if err != nil { return err @@ -733,6 +734,7 @@ var queryModerationStatusesCmd = &cli.Command{ "", // subject string "", // subjectType string []string{"tools.ozone.moderation.defs#modEventReport"}, // types []string + false, // withStrike bool ) if err != nil { return err -- 2.51.2