Skip to content
Snippets Groups Projects
Commit cfc59841 authored by OZGCloud's avatar OZGCloud
Browse files

clean up

parent fb3ecdce
No related branches found
No related tags found
No related merge requests found
Showing
with 498 additions and 573 deletions
...@@ -66,7 +66,7 @@ pipeline { ...@@ -66,7 +66,7 @@ pipeline {
FAILED_STAGE=env.STAGE_NAME FAILED_STAGE=env.STAGE_NAME
} }
configFileProvider([configFile(fileId: 'maven-settings', variable: 'MAVEN_SETTINGS')]) { configFileProvider([configFile(fileId: 'maven-settings', variable: 'MAVEN_SETTINGS')]) {
sh 'mvn -s $MAVEN_SETTINGS clean install -DskipTests -Dmaven.wagon.http.retryHandler.count=3' sh 'mvn -s $MAVEN_SETTINGS clean install -Dmaven.wagon.http.retryHandler.count=3'
script { script {
try { try {
......
...@@ -12,5 +12,4 @@ public class Constants { ...@@ -12,5 +12,4 @@ public class Constants {
public static final String ETR_DEPLOYMENT_NAME = "elster-transfer"; public static final String ETR_DEPLOYMENT_NAME = "elster-transfer";
public static final String MUK_USER_SECRET_NAME = "muk-user-secret"; public static final String MUK_USER_SECRET_NAME = "muk-user-secret";
} }
...@@ -35,7 +35,8 @@ public class OzgCloudElsterTransferUserReconciler implements Reconciler<OzgCloud ...@@ -35,7 +35,8 @@ public class OzgCloudElsterTransferUserReconciler implements Reconciler<OzgCloud
.withReschedule(ElsterTransferOperatorConfiguration.RECONCILER_RETRY_SECONDS) .withReschedule(ElsterTransferOperatorConfiguration.RECONCILER_RETRY_SECONDS)
.build(); .build();
} catch (Exception e) { } catch (Exception e) {
LOG.warn("{} could not reconcile in namespace {}: {}.", elsterTransferUser.getMetadata().getName(), elsterTransferUser.getMetadata().getNamespace(), e); LOG.warn("{} could not reconcile in namespace {}: {}.", elsterTransferUser.getMetadata().getName(),
elsterTransferUser.getMetadata().getNamespace(), e);
return UserUpdateControlBuilder.fromResource(elsterTransferUser) return UserUpdateControlBuilder.fromResource(elsterTransferUser)
.withStatus(OzgCloudCustomResourceStatus.ERROR) .withStatus(OzgCloudCustomResourceStatus.ERROR)
.withMessage(e.getMessage()) .withMessage(e.getMessage())
...@@ -44,7 +45,6 @@ public class OzgCloudElsterTransferUserReconciler implements Reconciler<OzgCloud ...@@ -44,7 +45,6 @@ public class OzgCloudElsterTransferUserReconciler implements Reconciler<OzgCloud
} }
} }
@Override @Override
public DeleteControl cleanup(OzgCloudElsterTransferUser user, Context<OzgCloudElsterTransferUser> context) { public DeleteControl cleanup(OzgCloudElsterTransferUser user, Context<OzgCloudElsterTransferUser> context) {
LOG.info("{} cleanup...", user.getMetadata().getName()); LOG.info("{} cleanup...", user.getMetadata().getName());
...@@ -56,7 +56,7 @@ public class OzgCloudElsterTransferUserReconciler implements Reconciler<OzgCloud ...@@ -56,7 +56,7 @@ public class OzgCloudElsterTransferUserReconciler implements Reconciler<OzgCloud
} }
try { try {
service.deleteUserAndRestartDeploymentIfNotKeepUserAndUserExists(user); service.delete(user);
return DeleteControl.defaultDelete(); return DeleteControl.defaultDelete();
} catch (Exception e) { } catch (Exception e) {
LOG.warn(namespace + " could not delete.", e); LOG.warn(namespace + " could not delete.", e);
......
...@@ -20,7 +20,6 @@ public class OzgCloudElsterTransferUserRemoteService { ...@@ -20,7 +20,6 @@ public class OzgCloudElsterTransferUserRemoteService {
private final KubernetesClient client; private final KubernetesClient client;
public ConfigMap getConfigMap(String configmapNamespace, String configMapName) { public ConfigMap getConfigMap(String configmapNamespace, String configMapName) {
return client.configMaps().inNamespace(configmapNamespace).withName(configMapName).get(); return client.configMaps().inNamespace(configmapNamespace).withName(configMapName).get();
} }
......
...@@ -16,7 +16,6 @@ import com.github.mustachejava.Mustache; ...@@ -16,7 +16,6 @@ import com.github.mustachejava.Mustache;
import com.github.mustachejava.MustacheFactory; import com.github.mustachejava.MustacheFactory;
import io.fabric8.kubernetes.api.model.ConfigMap; import io.fabric8.kubernetes.api.model.ConfigMap;
import io.micrometer.common.util.StringUtils;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.log4j.Log4j2; import lombok.extern.log4j.Log4j2;
...@@ -39,7 +38,7 @@ public class OzgCloudElsterTransferUserService { ...@@ -39,7 +38,7 @@ public class OzgCloudElsterTransferUserService {
} }
} }
public void deleteUserAndRestartDeploymentIfNotKeepUserAndUserExists(OzgCloudElsterTransferUser user) { public void delete(OzgCloudElsterTransferUser user) {
String namespace = user.getMetadata().getNamespace(); String namespace = user.getMetadata().getNamespace();
if (!userExists(namespace, Constants.ETR_NAMESPACE, Constants.ELSTER_TRANSFER_USER_LOGIN_KEY)) { if (!userExists(namespace, Constants.ETR_NAMESPACE, Constants.ELSTER_TRANSFER_USER_LOGIN_KEY)) {
LOG.info("User not exists"); LOG.info("User not exists");
......
package de.ozgcloud.operator.elstertransfer.user; package de.ozgcloud.operator.elstertransfer.user;
import java.util.Arrays; import java.util.Arrays;
import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
......
...@@ -66,7 +66,7 @@ class OzgCloudElsterTransferUserReconcilerTest { ...@@ -66,7 +66,7 @@ class OzgCloudElsterTransferUserReconcilerTest {
void shouldCallServiceDelete() { void shouldCallServiceDelete() {
reconciler.cleanup(user, null); reconciler.cleanup(user, null);
verify(service).deleteUserAndRestartDeploymentIfNotKeepUserAndUserExists(user); verify(service).delete(user);
} }
@Test @Test
...@@ -79,7 +79,7 @@ class OzgCloudElsterTransferUserReconcilerTest { ...@@ -79,7 +79,7 @@ class OzgCloudElsterTransferUserReconcilerTest {
@Test @Test
void shouldRescheduleOnError() { void shouldRescheduleOnError() {
doThrow(RuntimeException.class).when(service) doThrow(RuntimeException.class).when(service)
.deleteUserAndRestartDeploymentIfNotKeepUserAndUserExists(user); .delete(user);
var control = reconciler.cleanup(user, null); var control = reconciler.cleanup(user, null);
......
...@@ -23,7 +23,6 @@ ...@@ -23,7 +23,6 @@
*/ */
package de.ozgcloud.operator.elstertransfer.user; package de.ozgcloud.operator.elstertransfer.user;
public class OzgCloudElsterTransferUserSpecTestFactory { public class OzgCloudElsterTransferUserSpecTestFactory {
public static final boolean KEEP_AFTER_DELETE = false; public static final boolean KEEP_AFTER_DELETE = false;
......
...@@ -27,7 +27,6 @@ public class OzgCloudElsterTransferUserTestFactory { ...@@ -27,7 +27,6 @@ public class OzgCloudElsterTransferUserTestFactory {
public static final String METADATA_NAMESPACE = "TestNamespace"; public static final String METADATA_NAMESPACE = "TestNamespace";
public static OzgCloudElsterTransferUser create() { public static OzgCloudElsterTransferUser create() {
return createWithSpec(OzgCloudElsterTransferUserSpecTestFactory.create()); return createWithSpec(OzgCloudElsterTransferUserSpecTestFactory.create());
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment