blob: 7d24263f991848180082a735fe4624fde74558a3 [file] [log] [blame]
package org.apache.airavata.datalake.metadata.backend.neo4j.curd.operators;
import org.apache.airavata.datalake.metadata.backend.Connector;
import org.apache.airavata.datalake.metadata.backend.neo4j.model.nodes.User;
import org.neo4j.ogm.cypher.ComparisonOperator;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
public class UserServiceImpl extends GenericService<User> implements UserService {
public UserServiceImpl(Connector connector) {
super(connector);
}
@Override
Class<User> getEntityType() {
return User.class;
}
@Override
public List<User> find(User user) {
List<SearchOperator> searchOperatorList = new ArrayList<>();
if (user.getTenantId() != null) {
SearchOperator searchOperator = new SearchOperator();
searchOperator.setKey("tenant_id");
searchOperator.setValue(user.getTenantId());
searchOperator.setComparisonOperator(ComparisonOperator.EQUALS);
searchOperatorList.add(searchOperator);
}
if (user.getUsername() != null) {
SearchOperator searchOperator = new SearchOperator();
searchOperator.setKey("username");
searchOperator.setValue(user.getUsername());
searchOperator.setComparisonOperator(ComparisonOperator.EQUALS);
searchOperatorList.add(searchOperator);
}
Collection<User> users = super.search(searchOperatorList);
return new ArrayList<>(users);
}
}