func()

in pkg/initializer/initializer.go [71:98]

• 27 lines of code
• 6 McCabe index (conditional complexity)

func (i *ssmInitializer) loadPreviousState() (state.SerializedState, error) {
	serializedSecret, err := i.secretPersistence.Load()
	if err != nil {
		return nil, err
	}
	if serializedSecret == nil {
		klog.Infof("eks connector state is not found in persistent store, performing new activation...")
		return nil, nil
	}
	klog.Infof("eks connector state is found in persistent store")
	connectorState, err := state.Deserialize(serializedSecret)
	if err != nil {
		klog.Errorf("eks connector state cannot be deserialized")
		return nil, err
	}
	if connectorState.ActivationId != "" {
		if connectorState.ActivationId != i.activationConfig.ID {
			klog.Warningf("ssm activation id mismatch! state: %s, config: %s", connectorState.ActivationId, i.activationConfig.ID)
			klog.Warningf("eks connector is discarding previous state and performing new activation...")
			return nil, nil
		}
	} else {
		klog.Warningf("ssm activation id is not available, state might be created by an earlier version of eks-connector")
	}

	klog.Infof("eks connector is inheriting previous state...")
	return serializedSecret, nil
}