Skip to content

Commit

Permalink
Update Sequence to expose OIDC identities of underlying Subscriptions
Browse files Browse the repository at this point in the history
  • Loading branch information
creydr committed May 7, 2024
1 parent 865edbc commit 49275e5
Showing 1 changed file with 9 additions and 1 deletion.
10 changes: 9 additions & 1 deletion pkg/apis/flows/v1/sequence_lifecycle.go
Original file line number Diff line number Diff line change
Expand Up @@ -81,12 +81,13 @@ func (ss *SequenceStatus) InitializeConditions() {
// the status of the incoming subscriptions.
func (ss *SequenceStatus) PropagateSubscriptionStatuses(subscriptions []*messagingv1.Subscription) {
ss.SubscriptionStatuses = make([]SequenceSubscriptionStatus, len(subscriptions))
ss.Auth = nil
allReady := true
// If there are no subscriptions, treat that as a False case. Could go either way, but this seems right.
if len(subscriptions) == 0 {
allReady = false

}

for i, s := range subscriptions {
ss.SubscriptionStatuses[i] = SequenceSubscriptionStatus{
Subscription: corev1.ObjectReference{
Expand All @@ -113,6 +114,13 @@ func (ss *SequenceStatus) PropagateSubscriptionStatuses(subscriptions []*messagi
allReady = false
}

if s.Status.Auth != nil && s.Status.Auth.ServiceAccountName != nil {
if ss.Auth == nil {
ss.Auth = &duckv1.AuthStatus{}
}

ss.Auth.ServiceAccountNames = append(ss.Auth.ServiceAccountNames, *s.Status.Auth.ServiceAccountName)
}
}
if allReady {
sCondSet.Manage(ss).MarkTrue(SequenceConditionSubscriptionsReady)
Expand Down

0 comments on commit 49275e5

Please sign in to comment.