Skip to content

Commit

Permalink
Resolve stream deps for dashboard widgets
Browse files Browse the repository at this point in the history
  • Loading branch information
ryan-carroll-graylog committed Nov 20, 2023
1 parent 8bccc2c commit de48d72
Showing 1 changed file with 6 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -221,6 +221,12 @@ protected Graph<Entity> resolveViewEntity(EntityV1 entity,
.map(id -> resolveStreamEntity(id, entities))
.filter(Objects::nonNull)
.forEach(stream -> mutableGraph.putEdge(entity, stream));
viewEntity.state().values().stream()
.flatMap(s -> s.widgets().stream())
.flatMap(w -> w.streams().stream())
.map(id -> resolveStreamEntity(id, entities))
.filter(Objects::nonNull)
.forEach(stream -> mutableGraph.putEdge(entity, stream));
return ImmutableGraph.copyOf(mutableGraph);
}
}

0 comments on commit de48d72

Please sign in to comment.