diff --git a/modules/mesh-delivery-checker/cmd/mesh-delivery-checker/findingwriter.go b/modules/mesh-delivery-checker/cmd/mesh-delivery-checker/findingwriter.go index bb96deb7..996b94c8 100644 --- a/modules/mesh-delivery-checker/cmd/mesh-delivery-checker/findingwriter.go +++ b/modules/mesh-delivery-checker/cmd/mesh-delivery-checker/findingwriter.go @@ -30,7 +30,7 @@ func newCheckerFindings(ctx context.Context, cred process.Account, conn *nats.Co observe func(context.Context) ([]check.Finding, error), logf func(string, ...any)) (*checkerFindings, error) { c := &checkerFindings{node: cred.Node} w, err := views.NewWriter(views.WriterConfig[condseat.Finding, condseat.FindingCleared, condseat.FindingsStated, condseat.FindingsAskedEvent]{ - Module: cred.Module, State: state, Node: cred.Node, JS: js, Conn: conn, Logf: logf, + Module: cred.Module, State: state, Node: cred.Node, Asked: condseat.SubjectFindingsAsked, JS: js, Conn: conn, Logf: logf, Kinds: []string{check.CouldNotRunKind}, Observe: func(ctx context.Context) (views.Observed[condseat.Finding], error) { found, err := observe(ctx) diff --git a/modules/mesh-delivery-pipeline/cmd/mesh-delivery-pipeline/findingwriter.go b/modules/mesh-delivery-pipeline/cmd/mesh-delivery-pipeline/findingwriter.go index a976499b..0fedcad4 100644 --- a/modules/mesh-delivery-pipeline/cmd/mesh-delivery-pipeline/findingwriter.go +++ b/modules/mesh-delivery-pipeline/cmd/mesh-delivery-pipeline/findingwriter.go @@ -16,7 +16,7 @@ import ( // forms its subjects itself (design 47 G §383, A-13). func findingWriter(ctx context.Context, cred process.Account, conn *nats.Conn, js jetstream.JetStream, state process.State, logf func(string, ...any)) (*views.Writer[condseat.Finding, condseat.FindingCleared, condseat.FindingsStated, condseat.FindingsAskedEvent], error) { w, err := views.NewWriter(views.WriterConfig[condseat.Finding, condseat.FindingCleared, condseat.FindingsStated, condseat.FindingsAskedEvent]{ - Module: cred.Module, State: state, Node: cred.Node, JS: js, Conn: conn, Logf: logf, + Module: cred.Module, State: state, Node: cred.Node, Asked: condseat.SubjectFindingsAsked, JS: js, Conn: conn, Logf: logf, Observe: func(context.Context) (views.Observed[condseat.Finding], error) { return views.Observed[condseat.Finding]{}, nil }, diff --git a/modules/mesh-delivery-teller/cmd/mesh-delivery-teller/findingwriter.go b/modules/mesh-delivery-teller/cmd/mesh-delivery-teller/findingwriter.go index 8a628be6..be9d2cf1 100644 --- a/modules/mesh-delivery-teller/cmd/mesh-delivery-teller/findingwriter.go +++ b/modules/mesh-delivery-teller/cmd/mesh-delivery-teller/findingwriter.go @@ -16,7 +16,7 @@ import ( // forms its subjects itself (design 47 G §383, A-13). func findingWriter(ctx context.Context, cred process.Account, conn *nats.Conn, js jetstream.JetStream, state process.State, logf func(string, ...any)) (*views.Writer[condseat.Finding, condseat.FindingCleared, condseat.FindingsStated, condseat.FindingsAskedEvent], error) { w, err := views.NewWriter(views.WriterConfig[condseat.Finding, condseat.FindingCleared, condseat.FindingsStated, condseat.FindingsAskedEvent]{ - Module: cred.Module, State: state, Node: cred.Node, JS: js, Conn: conn, Logf: logf, + Module: cred.Module, State: state, Node: cred.Node, Asked: condseat.SubjectFindingsAsked, JS: js, Conn: conn, Logf: logf, Observe: func(context.Context) (views.Observed[condseat.Finding], error) { return views.Observed[condseat.Finding]{}, nil }, diff --git a/modules/mesh-delivery-view/cmd/mesh-delivery-view/findingwriter.go b/modules/mesh-delivery-view/cmd/mesh-delivery-view/findingwriter.go index e2bc27e8..4cf3b9b2 100644 --- a/modules/mesh-delivery-view/cmd/mesh-delivery-view/findingwriter.go +++ b/modules/mesh-delivery-view/cmd/mesh-delivery-view/findingwriter.go @@ -16,7 +16,7 @@ import ( // forms its subjects itself (design 47 G §383, A-13). func findingWriter(ctx context.Context, cred process.Account, conn *nats.Conn, js jetstream.JetStream, state process.State, logf func(string, ...any)) (*views.Writer[condseat.Finding, condseat.FindingCleared, condseat.FindingsStated, condseat.FindingsAskedEvent], error) { w, err := views.NewWriter(views.WriterConfig[condseat.Finding, condseat.FindingCleared, condseat.FindingsStated, condseat.FindingsAskedEvent]{ - Module: cred.Module, State: state, Node: cred.Node, JS: js, Conn: conn, Logf: logf, + Module: cred.Module, State: state, Node: cred.Node, Asked: condseat.SubjectFindingsAsked, JS: js, Conn: conn, Logf: logf, Observe: func(context.Context) (views.Observed[condseat.Finding], error) { return views.Observed[condseat.Finding]{}, nil }, diff --git a/modules/mesh-delivery-watchman/cmd/mesh-delivery-watchman/findingwriter.go b/modules/mesh-delivery-watchman/cmd/mesh-delivery-watchman/findingwriter.go index 9d1ddabe..495eec6b 100644 --- a/modules/mesh-delivery-watchman/cmd/mesh-delivery-watchman/findingwriter.go +++ b/modules/mesh-delivery-watchman/cmd/mesh-delivery-watchman/findingwriter.go @@ -55,7 +55,7 @@ func seedFindings(state process.State) (*heldFindings, map[string][]byte, error) // start makes and starts the writer: it states what is held at once, so the seeds are made before it. func (h *heldFindings) start(ctx context.Context, cred process.Account, conn *nats.Conn, js jetstream.JetStream, state process.State, logf func(string, ...any)) error { w, err := views.NewWriter(views.WriterConfig[condseat.Finding, condseat.FindingCleared, condseat.FindingsStated, condseat.FindingsAskedEvent]{ - Module: cred.Module, State: state, Node: cred.Node, JS: js, Conn: conn, Logf: logf, + Module: cred.Module, State: state, Node: cred.Node, Asked: condseat.SubjectFindingsAsked, JS: js, Conn: conn, Logf: logf, Observe: func(context.Context) (views.Observed[condseat.Finding], error) { h.mu.Lock() defer h.mu.Unlock()