|
|
|
@ -4,8 +4,10 @@ import com.fanruan.workplace.http.HttpConstants;
|
|
|
|
|
import com.fanruan.workplace.http.HttpServiceMap; |
|
|
|
|
import com.fanruan.workplace.http.RepositoryManager; |
|
|
|
|
import com.fanruan.workplace.http.info.Stub; |
|
|
|
|
import com.fr.exception.RemoteDesignPermissionDeniedException; |
|
|
|
|
import com.fr.log.FineLoggerFactory; |
|
|
|
|
import com.fr.stable.StringUtils; |
|
|
|
|
import com.fr.workspace.engine.exception.RemoteDesignConnectionException; |
|
|
|
|
import com.fr.workspace.server.repository.authority.RemoteAuthorityRepository; |
|
|
|
|
import com.fr.workspace.server.repository.compatible.register.CompatibleRegister; |
|
|
|
|
import com.fr.workspace.server.repository.connect.FineWorkspaceHttpClient; |
|
|
|
@ -43,7 +45,18 @@ public class HttpWorkspaceConnector implements WorkspaceConnector {
|
|
|
|
|
FineWorkspaceHttpClient client = FineWorkspaceHttpClient.create("Http-Client", connectionInfo); |
|
|
|
|
LoginResponseInfoBean bean; |
|
|
|
|
try { |
|
|
|
|
bean = RemoteAuthorityRepository.getInstance().login(createLoginBean(connectionInfo)); |
|
|
|
|
bean = RemoteAuthorityRepository.getInstance().login(createLoginBean(connectionInfo)); |
|
|
|
|
WorkspaceConnection connection = new WorkspaceConnection( |
|
|
|
|
UUID.randomUUID().toString(), |
|
|
|
|
connectionInfo.getUserName(), |
|
|
|
|
HttpConstants.AUTHORIZATION_PREFIX + bean.getAccessToken(), |
|
|
|
|
InetAddress.getLocalHost().getHostAddress()); |
|
|
|
|
client.updateConnection(connection); |
|
|
|
|
// 检查远程权限
|
|
|
|
|
if (!checkRemoteAuthority(connection)) { |
|
|
|
|
// 无权限则抛出无权限的错
|
|
|
|
|
throw new RemoteDesignPermissionDeniedException(); |
|
|
|
|
} |
|
|
|
|
} finally { |
|
|
|
|
client.closePool(); |
|
|
|
|
} |
|
|
|
@ -71,16 +84,31 @@ public class HttpWorkspaceConnector implements WorkspaceConnector {
|
|
|
|
|
HttpConstants.AUTHORIZATION_PREFIX + bean.getAccessToken(), |
|
|
|
|
InetAddress.getLocalHost().getHostAddress()); |
|
|
|
|
client.updateConnection(connection); |
|
|
|
|
// 检查远程权限
|
|
|
|
|
if (!checkRemoteAuthority(connection)) { |
|
|
|
|
// 无权限则抛出无权限的错
|
|
|
|
|
throw new RemoteDesignPermissionDeniedException(); |
|
|
|
|
} |
|
|
|
|
client.startHeartBeat(); |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
client.closePool(); |
|
|
|
|
throw e; |
|
|
|
|
throw new RemoteDesignConnectionException(e, StringUtils.EMPTY); |
|
|
|
|
} |
|
|
|
|
CompatibleRegister.registerCompatibleEnv(); |
|
|
|
|
RepositoryManager.getInstance().clearLastPool(); |
|
|
|
|
return client; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private boolean checkRemoteAuthority(WorkspaceConnection connection) { |
|
|
|
|
try { |
|
|
|
|
return RemoteAuthorityRepository.getInstance().isRoot(connection.getUserName()) || RemoteAuthorityRepository.getInstance().hasAuthority(connection.getUserName()); |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
// 如果这里出现异常,就认为fr服务没启动
|
|
|
|
|
throw new RemoteDesignConnectionException(e, StringUtils.EMPTY); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private LoginRequestInfoBean createLoginBean(WorkspaceConnectionInfo connectionInfo) { |
|
|
|
|
LoginRequestInfoBean bean = new LoginRequestInfoBean(); |
|
|
|
|
bean.setUsername(connectionInfo.getUserName()); |
|
|
|
|