@@ -337,31 +337,37 @@ func (p *Plugin) Configure(ctx context.Context, req *configv1.ConfigureRequest)
337
337
if err := p .reloadKubeletClient (c ); err != nil {
338
338
return nil , err
339
339
}
340
+ if p .sigstore != nil {
341
+ if err := configureSigstore (c , p .sigstore ); err != nil {
342
+ return nil , err
343
+ }
344
+ }
345
+ // Set the config
346
+ p .setConfig (c )
347
+ return & configv1.ConfigureResponse {}, nil
348
+ }
340
349
350
+ func configureSigstore (config * k8sConfig , sigstore sigstore.Sigstore ) error {
341
351
// Configure sigstore settings
342
- p . sigstore .ClearSkipList ()
343
- if c .SkippedImages != nil {
344
- for _ , imageID := range c .SkippedImages {
345
- p . sigstore .AddSkippedImage (imageID )
352
+ sigstore .ClearSkipList ()
353
+ if config .SkippedImages != nil {
354
+ for _ , imageID := range config .SkippedImages {
355
+ sigstore .AddSkippedImage (imageID )
346
356
}
347
357
}
348
-
349
- p .sigstore .EnableAllowSubjectList (c .AllowedSubjectListEnabled )
350
- p .sigstore .ClearAllowedSubjects ()
351
- if c .AllowedSubjects != nil {
352
- for _ , subject := range c .AllowedSubjects {
353
- p .sigstore .AddAllowedSubject (subject )
358
+ sigstore .EnableAllowSubjectList (config .AllowedSubjectListEnabled )
359
+ sigstore .ClearAllowedSubjects ()
360
+ if config .AllowedSubjects != nil {
361
+ for _ , subject := range config .AllowedSubjects {
362
+ sigstore .AddAllowedSubject (subject )
354
363
}
355
364
}
356
- if c .RekorURL != "" {
357
- if err := p . sigstore .SetRekorURL (c .RekorURL ); err != nil {
358
- return nil , err
365
+ if config .RekorURL != "" {
366
+ if err := sigstore .SetRekorURL (config .RekorURL ); err != nil {
367
+ return err
359
368
}
360
369
}
361
-
362
- // Set the config
363
- p .setConfig (c )
364
- return & configv1.ConfigureResponse {}, nil
370
+ return nil
365
371
}
366
372
367
373
func (p * Plugin ) setConfig (config * k8sConfig ) {
0 commit comments