Feature/rest client (#2229)
* added methods from admin-controller, alarm-controller, asset-controller, audit-log-controller * refactored rest client and added methods from auth controller * added methods from component-descriptor-controller * added methods from customer controller * added methods from dashboard controller * added methods from device controller * refactored url pageLink params * added methods from entity relation controller * added methods from entity view controller * refactored * added methods from event controller * added methods from rpc controller * added methods from rule chain controller * added methods from telemetry controller * added methods from tenant controller * added methods from user controller * added methods from widgets bundle controller * added methods from widget type controller * created method refreshToken * moved classes SecuritySettings, UserPasswordPolicy, ClaimRequest, UpdateMessage, to common module, and added "/api" to urls where this part was missing * refactored
This commit is contained in:
parent
8569b7dac2
commit
71744d4808
@ -16,6 +16,8 @@
|
|||||||
package org.thingsboard.client.tools;
|
package org.thingsboard.client.tools;
|
||||||
|
|
||||||
import com.fasterxml.jackson.databind.JsonNode;
|
import com.fasterxml.jackson.databind.JsonNode;
|
||||||
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||||
|
import com.fasterxml.jackson.databind.node.ObjectNode;
|
||||||
import lombok.RequiredArgsConstructor;
|
import lombok.RequiredArgsConstructor;
|
||||||
import org.springframework.core.ParameterizedTypeReference;
|
import org.springframework.core.ParameterizedTypeReference;
|
||||||
import org.springframework.http.HttpEntity;
|
import org.springframework.http.HttpEntity;
|
||||||
@ -27,6 +29,7 @@ import org.springframework.http.client.ClientHttpRequestExecution;
|
|||||||
import org.springframework.http.client.ClientHttpRequestInterceptor;
|
import org.springframework.http.client.ClientHttpRequestInterceptor;
|
||||||
import org.springframework.http.client.ClientHttpResponse;
|
import org.springframework.http.client.ClientHttpResponse;
|
||||||
import org.springframework.http.client.support.HttpRequestWrapper;
|
import org.springframework.http.client.support.HttpRequestWrapper;
|
||||||
|
import org.springframework.util.StringUtils;
|
||||||
import org.springframework.web.client.HttpClientErrorException;
|
import org.springframework.web.client.HttpClientErrorException;
|
||||||
import org.springframework.web.client.RestTemplate;
|
import org.springframework.web.client.RestTemplate;
|
||||||
import org.springframework.web.context.request.async.DeferredResult;
|
import org.springframework.web.context.request.async.DeferredResult;
|
||||||
@ -90,9 +93,11 @@ public class RestClient implements ClientHttpRequestInterceptor {
|
|||||||
protected final String baseURL;
|
protected final String baseURL;
|
||||||
private String token;
|
private String token;
|
||||||
private String refreshToken;
|
private String refreshToken;
|
||||||
|
private final ObjectMapper objectMapper = new ObjectMapper();
|
||||||
|
|
||||||
private final static String TIME_PAGE_LINK_URL_PARAMS = "limit={limit}&startTime={startTime}&endTime={endTime}&ascOrder={ascOrder}&offset={offset}";
|
private final static String TIME_PAGE_LINK_URL_PARAMS = "limit={limit}&startTime={startTime}&endTime={endTime}&ascOrder={ascOrder}&offset={offset}";
|
||||||
private final static String TEXT_PAGE_LINK_URL_PARAMS = "limit={limit}&textSearch{textSearch}&idOffset={idOffset}&textOffset{textOffset}";
|
private final static String TEXT_PAGE_LINK_URL_PARAMS = "limit={limit}&textSearch{textSearch}&idOffset={idOffset}&textOffset{textOffset}";
|
||||||
|
protected static final String ACTIVATE_TOKEN_REGEX = "/api/noauth/activate?activateToken=";
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public ClientHttpResponse intercept(HttpRequest request, byte[] bytes, ClientHttpRequestExecution execution) throws IOException {
|
public ClientHttpResponse intercept(HttpRequest request, byte[] bytes, ClientHttpRequestExecution execution) throws IOException {
|
||||||
@ -110,6 +115,14 @@ public class RestClient implements ClientHttpRequestInterceptor {
|
|||||||
return response;
|
return response;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public String getToken() {
|
||||||
|
return token;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getRefreshToken() {
|
||||||
|
return refreshToken;
|
||||||
|
}
|
||||||
|
|
||||||
public void refreshToken() {
|
public void refreshToken() {
|
||||||
Map<String, String> refreshTokenRequest = new HashMap<>();
|
Map<String, String> refreshTokenRequest = new HashMap<>();
|
||||||
refreshTokenRequest.put("refreshToken", refreshToken);
|
refreshTokenRequest.put("refreshToken", refreshToken);
|
||||||
@ -297,10 +310,6 @@ public class RestClient implements ClientHttpRequestInterceptor {
|
|||||||
return restTemplate;
|
return restTemplate;
|
||||||
}
|
}
|
||||||
|
|
||||||
public String getToken() {
|
|
||||||
return token;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Optional<AdminSettings> getAdminSettings(String key) {
|
public Optional<AdminSettings> getAdminSettings(String key) {
|
||||||
try {
|
try {
|
||||||
ResponseEntity<AdminSettings> adminSettings = restTemplate.getForEntity(baseURL + "/api/admin/settings/{key}", AdminSettings.class, key);
|
ResponseEntity<AdminSettings> adminSettings = restTemplate.getForEntity(baseURL + "/api/admin/settings/{key}", AdminSettings.class, key);
|
||||||
@ -629,6 +638,11 @@ public class RestClient implements ClientHttpRequestInterceptor {
|
|||||||
return auditLog.getBody();
|
return auditLog.getBody();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public String getActivateToken(String userId) {
|
||||||
|
String activationLink = getActivationLink(userId);
|
||||||
|
return StringUtils.delete(activationLink, baseURL + ACTIVATE_TOKEN_REGEX);
|
||||||
|
}
|
||||||
|
|
||||||
public Optional<User> getUser() {
|
public Optional<User> getUser() {
|
||||||
ResponseEntity<User> user = restTemplate.getForEntity(baseURL + "/api/auth/user", User.class);
|
ResponseEntity<User> user = restTemplate.getForEntity(baseURL + "/api/auth/user", User.class);
|
||||||
return Optional.ofNullable(user.getBody());
|
return Optional.ofNullable(user.getBody());
|
||||||
@ -638,7 +652,10 @@ public class RestClient implements ClientHttpRequestInterceptor {
|
|||||||
restTemplate.exchange(URI.create(baseURL + "/api/auth/logout"), HttpMethod.POST, HttpEntity.EMPTY, Object.class);
|
restTemplate.exchange(URI.create(baseURL + "/api/auth/logout"), HttpMethod.POST, HttpEntity.EMPTY, Object.class);
|
||||||
}
|
}
|
||||||
|
|
||||||
public void changePassword(JsonNode changePasswordRequest) {
|
public void changePassword(String currentPassword, String newPassword) {
|
||||||
|
ObjectNode changePasswordRequest = objectMapper.createObjectNode();
|
||||||
|
changePasswordRequest.put("currentPassword", currentPassword);
|
||||||
|
changePasswordRequest.put("newPassword", newPassword);
|
||||||
restTemplate.exchange(URI.create(baseURL + "/api/auth/changePassword"), HttpMethod.POST, new HttpEntity<>(changePasswordRequest), Object.class);
|
restTemplate.exchange(URI.create(baseURL + "/api/auth/changePassword"), HttpMethod.POST, new HttpEntity<>(changePasswordRequest), Object.class);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -655,12 +672,13 @@ public class RestClient implements ClientHttpRequestInterceptor {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
public ResponseEntity<String> checkActivateToken(String activateToken) {
|
public ResponseEntity<String> checkActivateToken(String activateToken) {
|
||||||
return restTemplate.getForEntity(baseURL + "/api/noauth/activate?activateToken={activateToken}", String.class, activateToken);
|
return restTemplate.getForEntity(baseURL + "/api/noauth/activate?activateToken={activateToken}", String.class, activateToken);
|
||||||
}
|
}
|
||||||
|
|
||||||
public void requestResetPasswordByEmail(JsonNode resetPasswordByEmailRequest) {
|
public void requestResetPasswordByEmail(String email) {
|
||||||
|
ObjectNode resetPasswordByEmailRequest = objectMapper.createObjectNode();
|
||||||
|
resetPasswordByEmailRequest.put("email", email);
|
||||||
restTemplate.exchange(URI.create(baseURL + "/api/noauth/resetPasswordByEmail"), HttpMethod.POST, new HttpEntity<>(resetPasswordByEmailRequest), Object.class);
|
restTemplate.exchange(URI.create(baseURL + "/api/noauth/resetPasswordByEmail"), HttpMethod.POST, new HttpEntity<>(resetPasswordByEmailRequest), Object.class);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -668,7 +686,10 @@ public class RestClient implements ClientHttpRequestInterceptor {
|
|||||||
return restTemplate.getForEntity(baseURL + "/api/noauth/resetPassword?resetToken={resetToken}", String.class, resetToken);
|
return restTemplate.getForEntity(baseURL + "/api/noauth/resetPassword?resetToken={resetToken}", String.class, resetToken);
|
||||||
}
|
}
|
||||||
|
|
||||||
public Optional<JsonNode> activateUser(JsonNode activateRequest) {
|
public Optional<JsonNode> activateUser(String userId, String password) {
|
||||||
|
ObjectNode activateRequest = objectMapper.createObjectNode();
|
||||||
|
activateRequest.put("activateToken", getActivateToken(userId));
|
||||||
|
activateRequest.put("password", password);
|
||||||
try {
|
try {
|
||||||
ResponseEntity<JsonNode> jsonNode = restTemplate.postForEntity(baseURL + "/api/noauth/activate", activateRequest, JsonNode.class);
|
ResponseEntity<JsonNode> jsonNode = restTemplate.postForEntity(baseURL + "/api/noauth/activate", activateRequest, JsonNode.class);
|
||||||
return Optional.ofNullable(jsonNode.getBody());
|
return Optional.ofNullable(jsonNode.getBody());
|
||||||
@ -681,7 +702,10 @@ public class RestClient implements ClientHttpRequestInterceptor {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public Optional<JsonNode> resetPassword(JsonNode resetPasswordRequest) {
|
public Optional<JsonNode> resetPassword(String resetToken, String resetPassword) {
|
||||||
|
ObjectNode resetPasswordRequest = objectMapper.createObjectNode();
|
||||||
|
resetPasswordRequest.put("resetToken", resetToken);
|
||||||
|
resetPasswordRequest.put("resetPassword", resetPassword);
|
||||||
try {
|
try {
|
||||||
ResponseEntity<JsonNode> jsonNode = restTemplate.postForEntity(baseURL + "/api/noauth/resetPassword", resetPasswordRequest, JsonNode.class);
|
ResponseEntity<JsonNode> jsonNode = restTemplate.postForEntity(baseURL + "/api/noauth/resetPassword", resetPasswordRequest, JsonNode.class);
|
||||||
return Optional.ofNullable(jsonNode.getBody());
|
return Optional.ofNullable(jsonNode.getBody());
|
||||||
@ -696,7 +720,7 @@ public class RestClient implements ClientHttpRequestInterceptor {
|
|||||||
|
|
||||||
public Optional<ComponentDescriptor> getComponentDescriptorByClazz(String componentDescriptorClazz) {
|
public Optional<ComponentDescriptor> getComponentDescriptorByClazz(String componentDescriptorClazz) {
|
||||||
try {
|
try {
|
||||||
ResponseEntity<ComponentDescriptor> componentDescriptor = restTemplate.getForEntity(baseURL + "/api/component/{componentDescriptorClazz}", ComponentDescriptor.class);
|
ResponseEntity<ComponentDescriptor> componentDescriptor = restTemplate.getForEntity(baseURL + "/api/component/{componentDescriptorClazz}", ComponentDescriptor.class, componentDescriptorClazz);
|
||||||
return Optional.ofNullable(componentDescriptor.getBody());
|
return Optional.ofNullable(componentDescriptor.getBody());
|
||||||
} catch (HttpClientErrorException exception) {
|
} catch (HttpClientErrorException exception) {
|
||||||
if (exception.getStatusCode() == HttpStatus.NOT_FOUND) {
|
if (exception.getStatusCode() == HttpStatus.NOT_FOUND) {
|
||||||
@ -1807,31 +1831,21 @@ public class RestClient implements ClientHttpRequestInterceptor {
|
|||||||
restTemplate.postForEntity(baseURL + "/api/user/sendActivationMail?email={email}", null, Object.class, email);
|
restTemplate.postForEntity(baseURL + "/api/user/sendActivationMail?email={email}", null, Object.class, email);
|
||||||
}
|
}
|
||||||
|
|
||||||
public Optional<String> getActivationLink(String userId) {
|
public String getActivationLink(String userId) {
|
||||||
try {
|
return restTemplate.getForEntity(baseURL + "/api/user/{userId}/activationLink", String.class, userId).getBody();
|
||||||
ResponseEntity<String> activationLink = restTemplate.getForEntity(baseURL + "/api/user/{userId}/activationLink", String.class, userId);
|
|
||||||
return Optional.ofNullable(activationLink.getBody());
|
|
||||||
} catch (HttpClientErrorException exception) {
|
|
||||||
if (exception.getStatusCode() == HttpStatus.NOT_FOUND) {
|
|
||||||
return Optional.empty();
|
|
||||||
} else {
|
|
||||||
throw exception;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public void deleteUser(String userId) {
|
public void deleteUser(String userId) {
|
||||||
restTemplate.delete(baseURL + "/api/user/{userId}", userId);
|
restTemplate.delete(baseURL + "/api/user/{userId}", userId);
|
||||||
}
|
}
|
||||||
|
|
||||||
// @RequestMapping(value = "/tenant/{tenantId}/users", params = {"limit"}, method = RequestMethod.GET)
|
|
||||||
public TextPageData<User> getTenantAdmins(String tenantId, TextPageLink pageLink) {
|
public TextPageData<User> getTenantAdmins(String tenantId, TextPageLink pageLink) {
|
||||||
Map<String, String> params = new HashMap<>();
|
Map<String, String> params = new HashMap<>();
|
||||||
params.put("tenantId", tenantId);
|
params.put("tenantId", tenantId);
|
||||||
addPageLinkToParam(params, pageLink);
|
addPageLinkToParam(params, pageLink);
|
||||||
|
|
||||||
return restTemplate.exchange(
|
return restTemplate.exchange(
|
||||||
baseURL + "/tenant/{tenantId}/users?" + TEXT_PAGE_LINK_URL_PARAMS,
|
baseURL + "/api/tenant/{tenantId}/users?" + TEXT_PAGE_LINK_URL_PARAMS,
|
||||||
HttpMethod.GET,
|
HttpMethod.GET,
|
||||||
HttpEntity.EMPTY,
|
HttpEntity.EMPTY,
|
||||||
new ParameterizedTypeReference<TextPageData<User>>() {
|
new ParameterizedTypeReference<TextPageData<User>>() {
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user