1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
package policyworkflow
import (
"context"
"errors"
"fmt"
policyv1alpha1 "github.com/johnandersen777/socialweb-computer-kcp/api/policy/v1alpha1"
ctlruntime "github.com/johnandersen777/socialweb-computer-kcp/internal/controllers/runtime"
pecontroller "github.com/johnandersen777/socialweb-computer-kcp/internal/policyengine/controller"
)
const (
Name = "policyworkflow"
Export = "policy"
)
type Options struct {
Workflows *pecontroller.WorkflowReconciler
}
type Controller struct {
workflows *pecontroller.WorkflowReconciler
}
func Register(m *ctlruntime.Manager, opts Options) (*Controller, error) {
workflows := opts.Workflows
if workflows == nil {
workflows = &pecontroller.WorkflowReconciler{}
}
c := &Controller{workflows: workflows}
if err := ctlruntime.For[*policyv1alpha1.PolicyWorkflow](m, Name, c, ctlruntime.Export(Export)); err != nil {
return nil, fmt.Errorf("policyworkflow: registering the PolicyWorkflow controller: %w", err)
}
return c, nil
}
func (c *Controller) Reconcile(ctx context.Context, req ctlruntime.Request, workflow *policyv1alpha1.PolicyWorkflow) (ctlruntime.Result, error) {
state, err := c.workflows.ReconcilePolicyWorkflow(ctx, workflow)
if ctx.Err() != nil {
return ctlruntime.Result{}, err
}
if pecontroller.WorkflowStatusEqual(workflow.Status, state, workflow.Generation) {
return ctlruntime.Result{}, err
}
workflow.Status = policyv1alpha1.PolicyWorkflowStatus{Phase: state.Phase, ObservedGeneration: workflow.Generation, Conditions: state.Conditions}
if applyErr := req.ApplyStatus(ctx, workflow); applyErr != nil {
return ctlruntime.Result{}, errors.Join(err, applyErr)
}
return ctlruntime.Result{}, err
}
