You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@datalab.apache.org by dy...@apache.org on 2022/10/11 12:32:04 UTC
[incubator-datalab] 05/06: fix delete platform
This is an automated email from the ASF dual-hosted git repository.
dyankiv pushed a commit to branch epm-v2.5.2.1
in repository https://gitbox.apache.org/repos/asf/incubator-datalab.git
commit 3aa080ff333e67965fa1aba5762ae29d0114dc6b
Author: Denys Yankiv <de...@gmail.com>
AuthorDate: Mon Oct 3 13:36:00 2022 +0300
fix delete platform
---
.../com/epam/datalab/backendapi/dao/ConnectedPlatformsDAO.java | 2 +-
.../epam/datalab/backendapi/dao/ConnectedPlatformsDAOImpl.java | 9 ++++++---
.../backendapi/service/impl/ConnectedPlatformsServiceImpl.java | 2 +-
3 files changed, 8 insertions(+), 5 deletions(-)
diff --git a/services/self-service/src/main/java/com/epam/datalab/backendapi/dao/ConnectedPlatformsDAO.java b/services/self-service/src/main/java/com/epam/datalab/backendapi/dao/ConnectedPlatformsDAO.java
index 42070b3d6..a48b808f5 100644
--- a/services/self-service/src/main/java/com/epam/datalab/backendapi/dao/ConnectedPlatformsDAO.java
+++ b/services/self-service/src/main/java/com/epam/datalab/backendapi/dao/ConnectedPlatformsDAO.java
@@ -32,5 +32,5 @@ public interface ConnectedPlatformsDAO {
List<ConnectedPlatformDTO> getUserPlatforms(String userName);
- void delete(String name);
+ void delete(String user, String name);
}
diff --git a/services/self-service/src/main/java/com/epam/datalab/backendapi/dao/ConnectedPlatformsDAOImpl.java b/services/self-service/src/main/java/com/epam/datalab/backendapi/dao/ConnectedPlatformsDAOImpl.java
index 8c25dcb1e..04383a745 100644
--- a/services/self-service/src/main/java/com/epam/datalab/backendapi/dao/ConnectedPlatformsDAOImpl.java
+++ b/services/self-service/src/main/java/com/epam/datalab/backendapi/dao/ConnectedPlatformsDAOImpl.java
@@ -22,12 +22,15 @@ package com.epam.datalab.backendapi.dao;
import com.epam.datalab.backendapi.resources.dto.ConnectedPlatformDTO;
import java.util.List;
+
+import static com.mongodb.client.model.Filters.and;
import static com.mongodb.client.model.Filters.eq;
public class ConnectedPlatformsDAOImpl extends BaseDAO implements ConnectedPlatformsDAO {
private static final String CONNECTED_PLATFORMS = "connectedPlatforms";
private static final String NAME = "name";
+ private static final String USER = "user";
@Override
public boolean exist(String name) {
@@ -46,11 +49,11 @@ public class ConnectedPlatformsDAOImpl extends BaseDAO implements ConnectedPlatf
@Override
public List<ConnectedPlatformDTO> getUserPlatforms(String userName) {
- return find(CONNECTED_PLATFORMS, eq("user", userName), ConnectedPlatformDTO.class);
+ return find(CONNECTED_PLATFORMS, eq(USER, userName), ConnectedPlatformDTO.class);
}
@Override
- public void delete(String name) {
- deleteOne(CONNECTED_PLATFORMS, eq(NAME,name));
+ public void delete(String user, String name) {
+ deleteOne(CONNECTED_PLATFORMS, and(eq(USER,user),eq(NAME,name)));
}
}
diff --git a/services/self-service/src/main/java/com/epam/datalab/backendapi/service/impl/ConnectedPlatformsServiceImpl.java b/services/self-service/src/main/java/com/epam/datalab/backendapi/service/impl/ConnectedPlatformsServiceImpl.java
index baf7f64f6..e53dec7f8 100644
--- a/services/self-service/src/main/java/com/epam/datalab/backendapi/service/impl/ConnectedPlatformsServiceImpl.java
+++ b/services/self-service/src/main/java/com/epam/datalab/backendapi/service/impl/ConnectedPlatformsServiceImpl.java
@@ -80,6 +80,6 @@ public class ConnectedPlatformsServiceImpl implements ConnectedPlatformsService
@Override
public void disconnect(UserInfo user, String name) {
- connectedPlatformsDAO.delete(name);
+ connectedPlatformsDAO.delete(user.getName(), name);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@datalab.apache.org
For additional commands, e-mail: commits-help@datalab.apache.org