@@ -65,18 +65,29 @@ func (h *AtlasThirdPartyIntegrationHandler) HandleInitial(ctx context.Context, i
65
65
if err != nil {
66
66
return result .Error (state .StateInitial , fmt .Errorf ("failed to populate integration: %w" , err ))
67
67
}
68
+ // TODO skew detection here
68
69
69
70
createdIntegration , err := req .Service .Create (ctx , req .Project .ID , integrationSpec )
70
71
if err != nil {
71
72
return result .Error (state .StateInitial , fmt .Errorf ("failed to create Atlas Third Party Integration for %s: %w" ,
72
73
integration .Spec .Type , err ))
73
74
}
74
75
integration .Status .ID = createdIntegration .ID
75
- // patch the status here (think about improvements for autogen)
76
+ // TODO patch the status here (think about improvements for autogen)
76
77
return result .NextState (state .StateCreated ,
77
78
fmt .Sprintf ("Creating Atlas Third Party Integration for %s" , integration .Spec .Type ))
78
79
}
79
80
81
+ func (h * AtlasThirdPartyIntegrationHandler ) HandleCreated (ctx context.Context , integration * akov2next.AtlasThirdPartyIntegration ) (ctrlstate.Result , error ) {
82
+ return h .handleIdle (ctx , integration )
83
+ }
84
+
85
+ func (h * AtlasThirdPartyIntegrationHandler ) handleIdle (ctx context.Context , integration * akov2next.AtlasThirdPartyIntegration ) (ctrlstate.Result , error ) {
86
+ // TODO skew detection here
87
+
88
+ return ctrlstate.Result {}, nil
89
+ }
90
+
80
91
func (h * AtlasThirdPartyIntegrationHandler ) newReconcileRequest (ctx context.Context , integration * akov2next.AtlasThirdPartyIntegration ) (* reconcileRequest , error ) {
81
92
req := reconcileRequest {}
82
93
sdkClientSet , err := h .ResolveSDKClientSet (ctx , integration )
0 commit comments