Skip to content

Commit d426a22

Browse files
committed
formatter
1 parent 276ce04 commit d426a22

File tree

12 files changed

+91
-43
lines changed

12 files changed

+91
-43
lines changed

camunda-sdk-java/java-client-console/src/main/java/io/camunda/console/CamundaConsoleClient.java

+13-4
Original file line numberDiff line numberDiff line change
@@ -9,8 +9,9 @@
99
import io.camunda.console.client.model.CreateClusterClientBody;
1010
import io.camunda.console.client.model.CreateSecretBody;
1111
import io.camunda.console.client.model.CreatedClusterClient;
12-
import io.camunda.console.client.model.IpWhiteListBody;
12+
import io.camunda.console.client.model.IpAllowListBody;
1313
import io.camunda.console.client.model.PostMemberBody;
14+
import io.camunda.console.client.model.UpdateClusterRequest;
1415
import io.camunda.console.impl.CamundaConsoleClientImpl;
1516
import java.util.List;
1617
import java.util.Map;
@@ -47,11 +48,15 @@ interface Cluster {
4748

4849
void delete();
4950

51+
void patch(UpdateClusterRequest request);
52+
5053
Backups backups();
5154

5255
Backup backups(String backupId);
5356

54-
IpWhiteList ipwhitelist();
57+
IpAllowList ipAllowList();
58+
59+
Wake wake();
5560

5661
Clients clients();
5762

@@ -71,8 +76,12 @@ interface Backup {
7176
BackupDto delete();
7277
}
7378

74-
interface IpWhiteList {
75-
void put(IpWhiteListBody request);
79+
interface IpAllowList {
80+
void put(IpAllowListBody request);
81+
}
82+
83+
interface Wake {
84+
void put();
7685
}
7786

7887
interface Clients {

camunda-sdk-java/java-client-console/src/main/java/io/camunda/console/impl/BackupImpl.java

-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package io.camunda.console.impl;
22

3-
43
import io.camunda.common.exception.SdkException;
54
import io.camunda.console.CamundaConsoleClient.Cluster.Backup;
65
import io.camunda.console.client.invoker.ApiException;

camunda-sdk-java/java-client-console/src/main/java/io/camunda/console/impl/BackupsImpl.java

-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package io.camunda.console.impl;
22

3-
43
import io.camunda.common.exception.SdkException;
54
import io.camunda.console.CamundaConsoleClient.Cluster.Backups;
65
import io.camunda.console.client.invoker.ApiException;

camunda-sdk-java/java-client-console/src/main/java/io/camunda/console/impl/CamundaConsoleClientImpl.java

+1-4
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,10 @@
11
package io.camunda.console.impl;
22

3-
43
import io.camunda.console.CamundaConsoleClient;
54
import io.camunda.console.client.api.DefaultApi;
65

76
public class CamundaConsoleClientImpl extends AbstractCamundaConsoleClient
8-
implements CamundaConsoleClient {
7+
implements CamundaConsoleClient {
98

109
public CamundaConsoleClientImpl(DefaultApi api) {
1110
super(api);
@@ -30,6 +29,4 @@ public Members members() {
3029
public Member members(String email) {
3130
return new MemberImpl(this, email);
3231
}
33-
34-
3532
}

camunda-sdk-java/java-client-console/src/main/java/io/camunda/console/impl/ClientImpl.java

-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package io.camunda.console.impl;
22

3-
43
import io.camunda.common.exception.SdkException;
54
import io.camunda.console.CamundaConsoleClient.Cluster.Client;
65
import io.camunda.console.client.invoker.ApiException;

camunda-sdk-java/java-client-console/src/main/java/io/camunda/console/impl/ClusterImpl.java

+17-2
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
import io.camunda.common.exception.SdkException;
44
import io.camunda.console.CamundaConsoleClient.Cluster;
55
import io.camunda.console.client.invoker.ApiException;
6+
import io.camunda.console.client.model.UpdateClusterRequest;
67

78
public class ClusterImpl extends AbstractCluster implements Cluster {
89

@@ -28,6 +29,15 @@ public void delete() {
2829
}
2930
}
3031

32+
@Override
33+
public void patch(UpdateClusterRequest request) {
34+
try {
35+
getApi().updateCluster(getClusterId(), request);
36+
} catch (ApiException e) {
37+
throw new SdkException(e);
38+
}
39+
}
40+
3141
@Override
3242
public Backups backups() {
3343
return new BackupsImpl(this);
@@ -39,8 +49,13 @@ public Backup backups(String backupId) {
3949
}
4050

4151
@Override
42-
public IpWhiteList ipwhitelist() {
43-
return new IpWhiteListImpl(this);
52+
public IpAllowList ipAllowList() {
53+
return new IpAllowListImpl(this);
54+
}
55+
56+
@Override
57+
public Wake wake() {
58+
return new WakeImpl(this);
4459
}
4560

4661
@Override
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
package io.camunda.console.impl;
2+
3+
import io.camunda.common.exception.SdkException;
4+
import io.camunda.console.CamundaConsoleClient.Cluster.IpAllowList;
5+
import io.camunda.console.client.invoker.ApiException;
6+
import io.camunda.console.client.model.IpAllowListBody;
7+
8+
public class IpAllowListImpl extends AbstractCluster implements IpAllowList {
9+
public IpAllowListImpl(AbstractCluster cluster) {
10+
super(cluster);
11+
}
12+
13+
@Override
14+
public void put(IpAllowListBody request) {
15+
try {
16+
getApi().updateIpAllowlist(getClusterId(), request);
17+
} catch (ApiException e) {
18+
throw new SdkException(e);
19+
}
20+
}
21+
}

camunda-sdk-java/java-client-console/src/main/java/io/camunda/console/impl/IpWhiteListImpl.java

-22
This file was deleted.
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
package io.camunda.console.impl;
2+
3+
import io.camunda.common.exception.SdkException;
4+
import io.camunda.console.CamundaConsoleClient.Cluster.Wake;
5+
import io.camunda.console.client.invoker.ApiException;
6+
7+
public class WakeImpl extends AbstractCluster implements Wake {
8+
public WakeImpl(AbstractCluster cluster) {
9+
super(cluster);
10+
}
11+
12+
@Override
13+
public void put() {
14+
try {
15+
getApi().wake(getClusterId());
16+
} catch (ApiException e) {
17+
throw new SdkException(e);
18+
}
19+
}
20+
}
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,13 @@
11
package io.camunda.common.auth;
22

3+
import java.io.IOException;
4+
import java.util.Map.Entry;
35
import org.apache.hc.core5.http.EntityDetails;
46
import org.apache.hc.core5.http.HttpException;
57
import org.apache.hc.core5.http.HttpRequest;
68
import org.apache.hc.core5.http.HttpRequestInterceptor;
79
import org.apache.hc.core5.http.protocol.HttpContext;
810

9-
import java.io.IOException;
10-
import java.util.Map.Entry;
11-
1211
public class AuthenticationInterceptor implements HttpRequestInterceptor {
1312
private final Product product;
1413
private final Authentication authentication;
@@ -19,8 +18,9 @@ public AuthenticationInterceptor(Product product, Authentication authentication)
1918
}
2019

2120
@Override
22-
public void process(HttpRequest httpRequest, EntityDetails entityDetails, HttpContext httpContext) throws HttpException, IOException {
21+
public void process(HttpRequest httpRequest, EntityDetails entityDetails, HttpContext httpContext)
22+
throws HttpException, IOException {
2323
Entry<String, String> tokenHeader = authentication.getTokenHeader(product);
24-
httpRequest.setHeader(tokenHeader.getKey(),tokenHeader.getValue());
24+
httpRequest.setHeader(tokenHeader.getKey(), tokenHeader.getValue());
2525
}
2626
}

camunda-sdk-java/java-common/src/main/java/io/camunda/common/exception/SdkException.java

+3-1
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,10 @@
11
package io.camunda.common.exception;
22

3+
import java.io.Serial;
4+
35
public class SdkException extends RuntimeException {
46

5-
private static final long serialVersionUID = 1L;
7+
@Serial private static final long serialVersionUID = 1L;
68

79
public SdkException(final Throwable cause) {
810
super(cause);

spring-boot-starter-camunda/src/main/java/io/camunda/zeebe/spring/client/configuration/ConsoleClientConfiguration.java

+11-2
Original file line numberDiff line numberDiff line change
@@ -11,12 +11,21 @@
1111
import org.springframework.boot.context.properties.EnableConfigurationProperties;
1212
import org.springframework.context.annotation.Bean;
1313

14-
@ConditionalOnProperty(prefix = "console.client", name = "enabled", havingValue = "true", matchIfMissing = false)
14+
@ConditionalOnProperty(
15+
prefix = "console.client",
16+
name = "enabled",
17+
havingValue = "true",
18+
matchIfMissing = false)
1519
@EnableConfigurationProperties(ConsoleClientConfigurationProperties.class)
1620
@ConditionalOnMissingBean(SpringZeebeTestContext.class)
1721
public class ConsoleClientConfiguration {
1822

19-
@Autowired Authentication authentication;
23+
private final Authentication authentication;
24+
25+
@Autowired
26+
public ConsoleClientConfiguration(Authentication authentication) {
27+
this.authentication = authentication;
28+
}
2029

2130
@Bean
2231
@ConditionalOnMissingBean

0 commit comments

Comments
 (0)