Skip to content

Commit

Permalink
fix: enable B edges by removing feature flag (#454)
Browse files Browse the repository at this point in the history
  • Loading branch information
rvazarkar authored Feb 29, 2024
1 parent c7c13cc commit 5cc5174
Showing 1 changed file with 18 additions and 24 deletions.
42 changes: 18 additions & 24 deletions packages/go/analysis/ad/adcs.go
Original file line number Diff line number Diff line change
Expand Up @@ -139,14 +139,12 @@ func processEnterpriseCAWithValidCertChainToDomain(enterpriseCA, domain *graph.N
return nil
})

if adcsEnabled {
operation.Operation.SubmitReader(func(ctx context.Context, tx graph.Transaction, outC chan<- analysis.CreatePostRelationshipJob) error {
if err := PostADCSESC6b(ctx, tx, outC, groupExpansions, enterpriseCA, domain, cache); err != nil {
log.Errorf("failed post processing for %s: %v", ad.ADCSESC6b.String(), err)
}
return nil
})
}
operation.Operation.SubmitReader(func(ctx context.Context, tx graph.Transaction, outC chan<- analysis.CreatePostRelationshipJob) error {
if err := PostADCSESC6b(ctx, tx, outC, groupExpansions, enterpriseCA, domain, cache); err != nil {
log.Errorf("failed post processing for %s: %v", ad.ADCSESC6b.String(), err)
}
return nil
})

operation.Operation.SubmitReader(func(ctx context.Context, tx graph.Transaction, outC chan<- analysis.CreatePostRelationshipJob) error {
if err := PostADCSESC9a(ctx, tx, outC, groupExpansions, enterpriseCA, domain, cache); err != nil {
Expand All @@ -155,14 +153,12 @@ func processEnterpriseCAWithValidCertChainToDomain(enterpriseCA, domain *graph.N
return nil
})

if adcsEnabled {
operation.Operation.SubmitReader(func(ctx context.Context, tx graph.Transaction, outC chan<- analysis.CreatePostRelationshipJob) error {
if err := PostADCSESC9b(ctx, tx, outC, groupExpansions, enterpriseCA, domain, cache); err != nil {
log.Errorf("failed post processing for %s: %v", ad.ADCSESC9b.String(), err)
}
return nil
})
}
operation.Operation.SubmitReader(func(ctx context.Context, tx graph.Transaction, outC chan<- analysis.CreatePostRelationshipJob) error {
if err := PostADCSESC9b(ctx, tx, outC, groupExpansions, enterpriseCA, domain, cache); err != nil {
log.Errorf("failed post processing for %s: %v", ad.ADCSESC9b.String(), err)
}
return nil
})

operation.Operation.SubmitReader(func(ctx context.Context, tx graph.Transaction, outC chan<- analysis.CreatePostRelationshipJob) error {
if err := PostADCSESC10a(ctx, tx, outC, groupExpansions, enterpriseCA, domain, cache); err != nil {
Expand All @@ -171,12 +167,10 @@ func processEnterpriseCAWithValidCertChainToDomain(enterpriseCA, domain *graph.N
return nil
})

if adcsEnabled {
operation.Operation.SubmitReader(func(ctx context.Context, tx graph.Transaction, outC chan<- analysis.CreatePostRelationshipJob) error {
if err := PostADCSESC10b(ctx, tx, outC, groupExpansions, enterpriseCA, domain, cache); err != nil {
log.Errorf("failed post processing for %s: %v", ad.ADCSESC10b.String(), err)
}
return nil
})
}
operation.Operation.SubmitReader(func(ctx context.Context, tx graph.Transaction, outC chan<- analysis.CreatePostRelationshipJob) error {
if err := PostADCSESC10b(ctx, tx, outC, groupExpansions, enterpriseCA, domain, cache); err != nil {
log.Errorf("failed post processing for %s: %v", ad.ADCSESC10b.String(), err)
}
return nil
})
}

0 comments on commit 5cc5174

Please sign in to comment.