D-Net

package eu.dnetlib.openaire.user.ldap;

import com.unboundid.ldap.sdk.*;

import eu.dnetlib.openaire.user.MigrationUser;

import eu.dnetlib.openaire.user.Role;

import eu.dnetlib.openaire.user.dao.RoleDAO;

import eu.dnetlib.openaire.user.dao.SQLMigrationUserDAO;

import eu.dnetlib.openaire.user.store.LDAPConnector;

import java.sql.SQLException;

/**

 * Created by sofia on 7/11/2016.

 */

public class MUserActionsLDAP

{

    public static boolean authenticateUser(String email, String password) throws LDAPException

    {

        LDAPConnection connection = LDAPConnector.v().getConnection();

        String usersDN = LDAPConnector.v().getUsersDN();

        try {

            System.out.println("checking if user " + email + " entered a correct password when logging in");

            Filter filter = Filter.createEqualityFilter("mail", email);

            SearchRequest searchRequest = new SearchRequest(usersDN, SearchScope.SUB, filter, "userPassword");

            SearchResult searchResult = connection.search(searchRequest);

            for (SearchResultEntry entry : searchResult.getSearchEntries()) {

                if (Joomla15PasswordHash.check(password, entry.getAttributeValue("userPassword")))

                    return true;

            }

            return false;

        }

        finally {

            if (connection != null)

                connection.close();

        }

    }

    public static String getRole(String email, String password) throws LDAPException, SQLException {

        boolean authenticated = authenticateUser(email, password);

        if (authenticated)

        {

            SQLMigrationUserDAO muDAO = new SQLMigrationUserDAO();

            MigrationUser mUser = new MigrationUser();

            mUser = muDAO.fetchByEmail(email);

            RoleDAO roleDAO = new RoleDAO();

            Role role = roleDAO.fetchById(mUser.getRoleId());

            return role.getRole();

        }

        return null;

    }

}

package eu.dnetlib.openaire.user;

import java.io.Serializable;

/**

 * Created by sofia on 8/11/2016.

 */

public class Role implements Serializable

{

    private int id;

    private String role;

    public Role() {

    }

    public Role(int id) {

        this.id = id;

    }

    public Role(String role) {

        this.role = role;

    }

    public Role(int id, String role){

        this.id = id;

        this.role = role;

    }

    public int getId(){

        return id;

    }

    public void setId(int id){

        this.id = id;

    }

    public String getRole() {

        return role;

    }

    public void setRole(String role) {

        this.role = role;

    }

}

package eu.dnetlib.openaire.user.dao;

import eu.dnetlib.openaire.user.Role;

import eu.dnetlib.openaire.user.store.DataSourceConnector;

import eu.dnetlib.openaire.user.store.Statement;

import javax.sql.DataSource;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.ArrayList;

import java.util.List;

import static eu.dnetlib.openaire.user.queries.RoleQueries.*;

/**

 * Created by sofia on 8/11/2016.

 */

public class RoleDAO {

    private final DataSource ds;

    public RoleDAO() {

        this.ds = DataSourceConnector.v().getDatasource();

    }

    // FETCH

    public List<Role> fetchAll()

            throws SQLException

    {

        return (List<Role>) executeQuery(FETCH_ALL);

    }

    public Role fetchById(final int id)

            throws SQLException

    {

        List<Role> roles = executeQuery(FETCH_BY_ID, new Statement.Initializer() {

            @Override

            public void prepare(PreparedStatement stmt) throws SQLException {

                stmt.setInt(1, id);

            }

        });

        if (roles.isEmpty())

            return null;

        return roles.get(0);

    }

    public Role fetchByRole(String role)

            throws SQLException

    {

        List<Role> roles = executeQuery(FETCH_BY_ROLE);

        if (roles.isEmpty())

            return null;

        return roles.get(0);

    }

    public long countAll() throws SQLException

    {

        return executeCount(COUNT_ALL);

    }

    public boolean insert(final Role role)

            throws SQLException

    {

        return executeUpdate(INSERT, new Statement.Initializer() {

            @Override

            public void prepare(PreparedStatement stmt)

                    throws SQLException {

                stmt.setString(1, role.getRole());

            }

        }) > 0;

    }

    public boolean delete(final String role)

            throws SQLException

    {

        return executeUpdate(DELETE, new Statement.Initializer() {

            @Override

            public void prepare(PreparedStatement stmt)

                    throws SQLException {

                stmt.setString(1, role);

            }

        }) > 0;

    }

    public boolean update(final Role role)

            throws SQLException

    {

        return executeUpdate(UPDATE, new Statement.Initializer() {

            @Override

            public void prepare(PreparedStatement stmt)

                    throws SQLException {

                stmt.setString(1, role.getRole());

            }

        }) > 0;

    }

    protected Role fromResultSet(ResultSet set)

            throws SQLException

    {

        Role role = new Role(set.getString("role"));

        role.setId(set.getInt("id"));

        return role;

    }

    protected int executeUpdate(String sql, Statement.Initializer init)

            throws SQLException

    {

        Connection connection = ds.getConnection();

        try {

            PreparedStatement stmt = connection.prepareStatement(sql);

            init.prepare(stmt);

            return stmt.executeUpdate();

        } finally {

            connection.close();

        }

    }

    protected List<Role> executeQuery(String sql, Statement.Initializer init)

            throws SQLException

    {

        Connection connection = ds.getConnection();

        try {

            PreparedStatement stmt = connection.prepareStatement(sql);

            init.prepare(stmt);

            ResultSet set = stmt.executeQuery();

            try {

                List<Role> results = new ArrayList<>();

                while (set.next())

                    results.add(fromResultSet(set));

                return results;

            } finally {

                set.close();

            }

        } finally {

            connection.close();

        }

    }

    protected int executeUpdate(String sql)

            throws SQLException

    {

        return executeUpdate(sql, Statement.emptyInitializer());

    }

    protected List<Role> executeQuery(String sql)

            throws SQLException

    {

        return executeQuery(sql, Statement.emptyInitializer());

    }

    public long executeCount(String sql)

            throws SQLException

    {

        return executeCount(sql, Statement.emptyInitializer());

    }

    public long executeCount(String sql, Statement.Initializer init)

            throws SQLException

    {

        Connection connection = ds.getConnection();

        try {

            PreparedStatement stmt = connection.prepareStatement(sql);

            init.prepare(stmt);

            ResultSet set = stmt.executeQuery();

            try {

                if (set.next())

                    return set.getLong(1);

                throw new IllegalArgumentException(stmt.toString());

            } finally {

                set.close();

            }

        } finally {

            connection.close();

        }

    }

}

package eu.dnetlib.openaire.user.dao;

import eu.dnetlib.openaire.user.MigrationUser;

import eu.dnetlib.openaire.user.store.DataSourceConnector;

import eu.dnetlib.openaire.user.store.Statement;

import org.apache.commons.dbcp.BasicDataSource;

import javax.sql.DataSource;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.ArrayList;

import java.util.List;

import static eu.dnetlib.openaire.user.queries.SQLMigrationUserQueries.*;

/**

 * Created by sofia on 1/11/2016.

 */

public class SQLMigrationUserDAO {

    private final DataSource ds;

    public SQLMigrationUserDAO() {

        this.ds = DataSourceConnector.v().getDatasource();

    }

    // FETCH

    public List<MigrationUser> fetchAll()

            throws SQLException

    {

        return (List<MigrationUser>) executeQuery(FETCH_ALL);

    }

    public MigrationUser fetchById(int id)

            throws SQLException

    {

        List<MigrationUser> users = executeQuery(FETCH_BY_ID);

        if (users.isEmpty())

            return null;

        return users.get(0);

    }

    public MigrationUser fetchByUid(String uid)

            throws SQLException

    {

        List<MigrationUser> users = executeQuery(FETCH_BY_UID);

        if (users.isEmpty())

            return null;

        return users.get(0);

    }

    public MigrationUser fetchByEmail(final String email)

            throws SQLException

    {

        List<MigrationUser> users = executeQuery(FETCH_BY_EMAIL, new Statement.Initializer() {

            @Override

            public void prepare(PreparedStatement stmt) throws SQLException {

                stmt.setString(1, email);

            }

        });

        if (users.isEmpty())

            return null;

        System.out.println("tralal");

        return users.get(0);

    }

    public List<MigrationUser> fetchByRoleId(String roleId)

            throws SQLException

    {

        return executeQuery(FETCH_BY_ROLE_ID);

    }

    public long countAll() throws SQLException

    {

        return executeCount(COUNT_ALL);

    }

    public boolean insert(final MigrationUser mUser)

            throws SQLException

    {

        return executeUpdate(INSERT, new Statement.Initializer() {

            @Override

            public void prepare(PreparedStatement stmt)

                    throws SQLException {

                stmt.setString(1, mUser.getUid());

                stmt.setString(2, mUser.getEmail());

                //stmt.setInt(3, mUser.getRoleId());

            }

        }) > 0;

    }

    public boolean delete(final String uid)

            throws SQLException

    {

        return executeUpdate(DELETE, new Statement.Initializer() {

            @Override

            public void prepare(PreparedStatement stmt)

                    throws SQLException {

                stmt.setString(1, uid);

            }

        }) > 0;

    }

    public boolean update(final MigrationUser mUser)

            throws SQLException

    {

        return executeUpdate(UPDATE, new Statement.Initializer() {

            @Override

            public void prepare(PreparedStatement stmt)

                    throws SQLException {

                stmt.setString(1, mUser.getUid());

                stmt.setString(2, mUser.getEmail());

                stmt.setInt(3, mUser.getRoleId());

            }

        }) > 0;

    }

    protected MigrationUser fromResultSet(ResultSet set)

            throws SQLException

    {

        MigrationUser mUser = new MigrationUser(set.getString("uid"));

        mUser.setId(set.getInt("id"));

        mUser.setEmail(set.getString("email"));

        mUser.setRoleId(set.getInt("role_id"));

        return mUser;

    }

    protected int executeUpdate(String sql, Statement.Initializer init)

            throws SQLException

    {

        Connection connection = ds.getConnection();

        try {

            PreparedStatement stmt = connection.prepareStatement(sql);

            init.prepare(stmt);

            return stmt.executeUpdate();

        } finally {

            connection.close();

        }

    }

    protected List<MigrationUser> executeQuery(String sql, Statement.Initializer init)

            throws SQLException

    {

        Connection connection = ds.getConnection();

        try {

            PreparedStatement stmt = connection.prepareStatement(sql);

            init.prepare(stmt);

            ResultSet set = stmt.executeQuery();

            try {

                List<MigrationUser> results = new ArrayList<>();

                while (set.next())

                    results.add(fromResultSet(set));

                return results;

            } finally {

                set.close();

            }

        } finally {

            connection.close();

        }

    }

    protected int executeUpdate(String sql)

            throws SQLException

    {

        return executeUpdate(sql, Statement.emptyInitializer());

    }

    protected List<MigrationUser> executeQuery(String sql)

            throws SQLException

    {

        return executeQuery(sql, Statement.emptyInitializer());

    }

    public long executeCount(String sql)

            throws SQLException

    {

        return executeCount(sql, Statement.emptyInitializer());

    }

    public long executeCount(String sql, Statement.Initializer init)

            throws SQLException

    {

        Connection connection = ds.getConnection();

        try {

            PreparedStatement stmt = connection.prepareStatement(sql);

            init.prepare(stmt);

            ResultSet set = stmt.executeQuery();

            try {

                if (set.next())

                    return set.getLong(1);

                throw new IllegalArgumentException(stmt.toString());

            } finally {

                set.close();

            }

        } finally {

            connection.close();

        }

    }

}

package eu.dnetlib.openaire.user;

import java.io.Serializable;

/**

 * Created by sofia on 1/11/2016.

 */

public class MigrationUser implements Serializable {

    private int id;

    private String uid;

    private String name; // TODO LDAP display name

    private String email;

    private int roleId;

    public MigrationUser() {

    }

    public MigrationUser(String uid) {

        this.uid = uid;

    }

    public MigrationUser(int id, String uid, String email, int roleId) {

        this.id = id;

        this.uid = uid;

        this.email = email;

        this.roleId = roleId;

    }

    public int getId(){

        return id;

    }

    public void setId(int id){

        this.id = id;

    }

    public String getUid(){

        return uid;

    }

    public void setUid(String uid){

        this.uid = uid;

    }

    public String getEmail(){

        return email;

    }

    public void setEmail(String email){

        this.email = email;

    }

    public int getRoleId(){

        return roleId;

    }

    public void setRoleId(int roleId){

        this.roleId = roleId;

    }

}

package eu.dnetlib.openaire.user.migration;

import com.unboundid.ldap.sdk.*;

import eu.dnetlib.openaire.user.MigrationUser;

import eu.dnetlib.openaire.user.dao.SQLMigrationUserDAO;

import eu.dnetlib.openaire.user.ldap.MUserActionsLDAP;

import eu.dnetlib.openaire.user.ldap.UserActionsLDAP;

import eu.dnetlib.openaire.user.store.LDAPConnector;

import org.apache.commons.dbcp.BasicDataSource;

import java.sql.SQLException;

import java.util.List;

/**

 * Created by sofia on 31/10/2016.

 */

public class Migration {

    public static void main(String[] args) throws LDAPException, SQLException {

//        // JDBC driver name and database URL

//        final String DRIVER = "com.mysql.jdbc.Driver";

//        final String DB_URL = "jdbc:mysql://localhost:3306/migration";

//

//        // Database credentials

//        final String USERNAME = "root";

//        final String PASSWORD = "1@3$56213980";

//

//

//        BasicDataSource bds = new BasicDataSource();

//

//        bds.setDriverClassName(DRIVER);

//        bds.setUrl(DB_URL);

//        bds.setUsername(USERNAME);

//        bds.setPassword(PASSWORD);

//

//        bds.setMaxIdle(10);

//        bds.setMaxActive(100);

//        bds.setMaxWait(10000);

//        bds.setValidationQuery("select 1");

//        bds.setTestOnBorrow(true);

//        bds.setTestWhileIdle(true);

//        bds.setTimeBetweenEvictionRunsMillis(1200000);

//        bds.setMinEvictableIdleTimeMillis(1800000);

//        bds.setNumTestsPerEvictionRun(5);

//        bds.setDefaultAutoCommit(true);

//

//        String ldapAddress = "esperos.di.uoa.gr";

//        String ldapUsername = "cn=admin,dc=openaire,dc=eu";

//        String ldapPassword = "serenata";

//        String ldapUsersDN = "ou=users,dc=openaire,dc=eu";

//        int ldapPort = 389;

        // Coppy all LDAP User to my local db

        LDAPConnection connection = LDAPConnector.v().getConnection();

//        Filter filter = Filter.create("cn=*");

//

//        SearchRequest searchRequest =

//                new SearchRequest("ou=users,dc=openaire,dc=eu", SearchScope.SUB, filter, "mail", "uid");

//

//        SearchResult searchResult = connection.search(searchRequest);

//

//        List<SearchResultEntry> searchEntries = searchResult.getSearchEntries();

//

//        if (searchEntries.size() != 1) {

//            SQLMigrationUserDAO muDAO = new SQLMigrationUserDAO();

//

//            for (SearchResultEntry entry : searchResult.getSearchEntries()) {

//                MigrationUser mUser = new MigrationUser();

//                mUser.setUid(entry.getAttribute("uid").getValue());

//                mUser.setEmail(entry.getAttribute("mail").getValue());

//

//                System.out.println("User: " + mUser.getUid() + " " + mUser.getEmail());

//

//                try {

//                    boolean inserted = muDAO.insert(mUser);

//                    System.out.println("Inserted user: " + inserted);

//                } catch (SQLException e) {

//                    e.printStackTrace();

//                    throw e;

//                }

//            }

//

//            for (MigrationUser mUser : muDAO.fetchAll()) {

//                System.out.println("Added User: " + mUser.getUid() + " " + mUser.getEmail());

//            }

//        }

        MUserActionsLDAP mUserActionsLDAP = new MUserActionsLDAP();

        boolean authenticated = mUserActionsLDAP.authenticateUser("sba@di.uoa.gr", "12345678");

        System.out.println(authenticated);

        System.out.println(mUserActionsLDAP.getRole("sba@di.uoa.gr", "12345678"));

    }

}

package eu.dnetlib.openaire.user.queries;

/**

 * Created by sofia on 8/11/2016.

 */

public interface RoleQueries {

    // Queries (as prepared statements to avoid SQL-injection)

    String FETCH_ALL         = "SELECT * FROM roles";

    String FETCH_BY_ID       = "SELECT * FROM roles WHERE id = ?";

    String FETCH_BY_ROLE      = "SELECT * FROM roles WHERE role = ?";

    String COUNT_ALL = "SELECT COUNT(*) FROM role";

    String INSERT = "INSERT INTO roles (" +

            "role" +

            ") VALUES (?)";

    String UPDATE = "UPDATE roles SET " +

            "role = ? " +

            "WHERE id = ?";

    String DELETE = "DELETE FROM roles WHERE id = ?";

}

package eu.dnetlib.openaire.user.queries;

/**

 * Created by sofia on 1/11/2016.

 */

public interface SQLMigrationUserQueries {

    // Queries (as prepared statements to avoid SQL-injection)

    String FETCH_ALL         = "SELECT * FROM users";

    String FETCH_BY_ID       = "SELECT * FROM users WHERE id = ?";

    String FETCH_BY_UID      = "SELECT * FROM users WHERE uid = ?";

    String FETCH_BY_EMAIL    = "SELECT * FROM users WHERE email = ?";

    String FETCH_BY_ROLE_ID  = "SELECT * FROM users WHERE role_id = ?";

    String COUNT_ALL = "SELECT COUNT(*) FROM users";

    String INSERT = "INSERT INTO users (" +

            "uid, " +

            "email, " +

            "role_id" +

            ") VALUES (?,?,1)";

    String UPDATE = "UPDATE users SET " +

            "uid = ?, " +

            "email = ?, " +

            "role_id = ? " +

            "WHERE id = ?";

    String DELETE = "DELETE FROM users WHERE id = ?";

}

package eu.dnetlib.openaire.user.user;

/**

 * Created by sofia on 31/10/2016.

 */

public class UserProfile {

}

package eu.dnetlib.openaire.user.user;

/**

 * Created by sofia on 31/10/2016.

 */

public class UserProfileIS extends UserProfile {

    private String username, password;

    private String email;

    private String fname, lname;

    private String institution;

    public String getUsername() {

        return username;

    }

    public void setUsername(String username) {

        this.username = username;

    }

    public String getPassword() {

        return password;

    }

    public void setPassword(String password) {

        this.password = password;

    }

    public String getEmail() {

        return email;

    }

    public void setEmail(String email) {

        this.email = email;

    }

    public String getFname() {

        return fname;

    }

    public void setFname(String fname) {

        this.fname = fname;

    }

    public String getLname() {

        return lname;

    }

    public void setLname(String lname) {

        this.lname = lname;

    }

    public void setInstitution(String institution) {

        this.institution = institution;

    }

    public String getInstitution() {

        return institution;

    }

}