Fix server error issue when calling get logged-in user in APPM

The following changes are with this commit,
- Check authData object is null in UserHandler class
- Add check logged-in user functionality to APPM UI
feature/appm-store/pbac
Jayasanka 5 years ago
parent 112eb1f77f
commit ce40ea57c7

@ -102,8 +102,9 @@ class App extends React.Component {
window.location.origin + "/publisher-ui-request-handler/user", window.location.origin + "/publisher-ui-request-handler/user",
"platform=publisher" "platform=publisher"
).then(res => { ).then(res => {
const pageURL = window.location.pathname;
const lastURLSegment = pageURL.substr(pageURL.lastIndexOf('/') + 1); const lastURLSegment = pageURL.substr(pageURL.lastIndexOf('/') + 1);
if (lastURLSegment !== "login") { if (lastURLSegment === "login") {
window.location.href = window.location.origin + `/publisher/`; window.location.href = window.location.origin + `/publisher/`;
} else { } else {
this.getAndroidEnterpriseToken(config); this.getAndroidEnterpriseToken(config);

@ -78,14 +78,20 @@ class App extends React.Component {
} }
checkUserLoggedIn = (config) => { checkUserLoggedIn = (config) => {
axios.get( axios.post(
window.location.origin + config.serverConfig.invoker.uri + window.location.origin + "/store-ui-request-handler/user",
config.serverConfig.invoker.publisher + "/applications/categories" "platform=publisher"
).then(res => { ).then(res => {
const pageURL = window.location.pathname;
const lastURLSegment = pageURL.substr(pageURL.lastIndexOf('/') + 1);
if (lastURLSegment === "login") {
window.location.href = window.location.origin + `/store/`;
} else {
this.setState({ this.setState({
loading: false, loading: false,
config: config config: config
}) });
}
}).catch((error) => { }).catch((error) => {
if (error.hasOwnProperty("response") && error.response.status === 401) { if (error.hasOwnProperty("response") && error.response.status === 401) {
const redirectUrl = encodeURI(window.location.href); const redirectUrl = encodeURI(window.location.href);
@ -106,7 +112,7 @@ class App extends React.Component {
}) })
} }
}); });
} };
render() { render() {
const {loading, error} = this.state; const {loading, error} = this.state;

@ -43,32 +43,36 @@ import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession; import javax.servlet.http.HttpSession;
import java.io.IOException; import java.io.IOException;
@MultipartConfig @WebServlet("/user") public class UserHandler extends HttpServlet { @MultipartConfig
@WebServlet("/user")
public class UserHandler extends HttpServlet {
private static final Log log = LogFactory.getLog(UserHandler.class); private static final Log log = LogFactory.getLog(UserHandler.class);
private static final long serialVersionUID = 9050048549140517002L; private static final long serialVersionUID = 9050048549140517002L;
@Override protected void doPost(HttpServletRequest req, HttpServletResponse resp) { @Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp) {
try { try {
String platform = req.getParameter(HandlerConstants.PLATFORM); String platform = req.getParameter(HandlerConstants.PLATFORM);
String serverUrl = String serverUrl =
req.getScheme() + HandlerConstants.SCHEME_SEPARATOR + req.getServerName() + HandlerConstants.COLON req.getScheme() + HandlerConstants.SCHEME_SEPARATOR + req.getServerName() + HandlerConstants.COLON
+ System.getProperty("iot.gateway.https.port"); + System.getProperty("iot.gateway.https.port");
if (StringUtils.isBlank(platform)) { if (StringUtils.isBlank(platform)) {
ProxyResponse proxyResponse = new ProxyResponse(); sendUnAuthorizeResponse(req, resp, serverUrl, platform);
proxyResponse.setCode(HttpStatus.SC_BAD_REQUEST);
HandlerUtil.handleError(req, resp, serverUrl, platform, proxyResponse);
return; return;
} }
HttpSession httpSession = req.getSession(false); HttpSession httpSession = req.getSession(false);
if (httpSession == null) { if (httpSession == null) {
ProxyResponse proxyResponse = new ProxyResponse(); sendUnAuthorizeResponse(req, resp, serverUrl, platform);
proxyResponse.setCode(HttpStatus.SC_UNAUTHORIZED);
HandlerUtil.handleError(req, resp, serverUrl, platform, proxyResponse);
return; return;
} }
AuthData authData = (AuthData) httpSession.getAttribute(HandlerConstants.SESSION_AUTH_DATA_KEY); AuthData authData = (AuthData) httpSession.getAttribute(HandlerConstants.SESSION_AUTH_DATA_KEY);
if (authData == null) {
sendUnAuthorizeResponse(req, resp, serverUrl, platform);
return;
}
String accessToken = authData.getAccessToken(); String accessToken = authData.getAccessToken();
HttpPost tokenEndpoint = new HttpPost(serverUrl + HandlerConstants.INTROSPECT_ENDPOINT); HttpPost tokenEndpoint = new HttpPost(serverUrl + HandlerConstants.INTROSPECT_ENDPOINT);
@ -94,9 +98,7 @@ import java.io.IOException;
if (jTokenResult.isJsonObject()) { if (jTokenResult.isJsonObject()) {
JsonObject jTokenResultAsJsonObject = jTokenResult.getAsJsonObject(); JsonObject jTokenResultAsJsonObject = jTokenResult.getAsJsonObject();
if (!jTokenResultAsJsonObject.get("active").getAsBoolean()) { if (!jTokenResultAsJsonObject.get("active").getAsBoolean()) {
ProxyResponse proxyResponse = new ProxyResponse(); sendUnAuthorizeResponse(req, resp, serverUrl, platform);
proxyResponse.setCode(HttpStatus.SC_UNAUTHORIZED);
HandlerUtil.handleError(req, resp, serverUrl, platform, proxyResponse);
return; return;
} }
ProxyResponse proxyResponse = new ProxyResponse(); ProxyResponse proxyResponse = new ProxyResponse();
@ -110,4 +112,11 @@ import java.io.IOException;
log.error("Error occurred while parsing the response. ", e); log.error("Error occurred while parsing the response. ", e);
} }
} }
private void sendUnAuthorizeResponse(HttpServletRequest req, HttpServletResponse resp, String serverUrl, String platform)
throws IOException {
ProxyResponse proxyResponse = new ProxyResponse();
proxyResponse.setCode(HttpStatus.SC_UNAUTHORIZED);
HandlerUtil.handleError(req, resp, serverUrl, platform, proxyResponse);
}
} }

Loading…
Cancel
Save