aboutsummaryrefslogtreecommitdiff
path: root/eidas_modules/authmodule-eIDAS-v2/src/main/java/at
diff options
context:
space:
mode:
Diffstat (limited to 'eidas_modules/authmodule-eIDAS-v2/src/main/java/at')
-rw-r--r--eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/Constants.java9
-rw-r--r--eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/DAO/eIDASPersonalIdStoreDAO.java123
-rw-r--r--eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/exception/SQLiteServiceException.java17
-rw-r--r--eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/service/eIDASDataStore.java328
-rw-r--r--eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/szr/SZRClient.java3
-rw-r--r--eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/tasks/CreateIdentityLinkTask.java75
6 files changed, 537 insertions, 18 deletions
diff --git a/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/Constants.java b/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/Constants.java
index 85743585..24d1f1ea 100644
--- a/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/Constants.java
+++ b/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/Constants.java
@@ -61,6 +61,12 @@ public class Constants {
public static final String CONIG_PROPS_EIDAS_SZRCLIENT_PARAMS_ISSUING_AUTHORITY = CONIG_PROPS_EIDAS_SZRCLIENT + ".params.issuingauthority";
public static final String CONIG_PROPS_EIDAS_SZRCLIENT_PARAMS_KEYS_USEDUMMY= CONIG_PROPS_EIDAS_SZRCLIENT + ".params.usedummykeys";
public static final String CONIG_PROPS_EIDAS_SZRCLIENT_DEBUG_USESRZFORBPKGENERATION= CONIG_PROPS_EIDAS_SZRCLIENT + ".params.useSZRForbPKCalculation";
+ public static final String CONIG_PROPS_EIDAS_SZRCLIENT_PARAMS_SETPLACEOFBIRTHIFAVAILABLE= CONIG_PROPS_EIDAS_SZRCLIENT + ".params.setPlaceOfBirthIfAvailable";
+
+ public static final String CONIG_PROPS_EIDAS_SZRCLIENT_WORKAROUND_SQLLITEDATASTORE_ACTIVE = CONIG_PROPS_EIDAS_SZRCLIENT + ".workarounds.datastore.sqlite.active";
+ public static final String CONIG_PROPS_EIDAS_SZRCLIENT_WORKAROUND_REVISIONLOGDATASTORE_ACTIVE = CONIG_PROPS_EIDAS_SZRCLIENT + ".workarounds.datastore.revisionlog.active";
+ public static final String CONIG_PROPS_EIDAS_SZRCLIENT_WORKAROUND_SQLLITEDATASTORE_URL = CONIG_PROPS_EIDAS_SZRCLIENT + ".workarounds.datastore.sqlite.url";
+
//http endpoint descriptions
public static final String eIDAS_HTTP_ENDPOINT_SP_POST = "/eidas/light/sp/post";
@@ -75,7 +81,8 @@ public class Constants {
public static final String eIDAS_ATTR_PERSONALIDENTIFIER = "PersonIdentifier";
public static final String eIDAS_ATTR_DATEOFBIRTH = "DateOfBirth";
public static final String eIDAS_ATTR_CURRENTGIVENNAME = "FirstName";
- public static final String eIDAS_ATTR_CURRENTFAMILYNAME = "FamilyName";
+ public static final String eIDAS_ATTR_CURRENTFAMILYNAME = "FamilyName";
+ public static final String eIDAS_ATTR_PLACEOFBIRTH = "PlaceOfBirth";
public static final String eIDAS_ATTR_LEGALPERSONIDENTIFIER = "LegalPersonIdentifier";
public static final String eIDAS_ATTR_LEGALNAME = "LegalName";
diff --git a/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/DAO/eIDASPersonalIdStoreDAO.java b/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/DAO/eIDASPersonalIdStoreDAO.java
new file mode 100644
index 00000000..b0f957a5
--- /dev/null
+++ b/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/DAO/eIDASPersonalIdStoreDAO.java
@@ -0,0 +1,123 @@
+package at.asitplus.eidas.specific.modules.authmodule_eIDASv2.DAO;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+
+import at.gv.egiz.eaaf.core.impl.data.Pair;
+
+public class eIDASPersonalIdStoreDAO {
+ public static final String NAME = "foreigneIDMap";
+
+ //Enum with all cols of this table
+ public enum COLS {
+ timestamp, transactionId, eidasId, eidasSourceCountry, eidasDestinationCountry, ernbId
+ }
+
+ public enum T {
+ ID("INTEGER"),
+ BIGINT("VARCHAR(265)"),
+ URI("VARCHAR(256)"),
+ DATE("Long"),
+ TEXT("TEXT"),
+ Long("BIGINT"),
+ Int("INTEGER"),
+ BLOB("BLOB"),
+ CC("CHAR(2)"),
+ BOOL("INTEGER");
+
+ public String s_;
+
+ private T(String s) {
+ s_ = s;
+ }
+
+ @Override
+ public String toString() {
+ return s_;
+ }
+ }
+
+ //define Cols of the table
+ public static final List<Pair<String, T>> TABLE_COLS;
+ static {
+ List<Pair<String, T>> cols = new ArrayList<Pair<String, T>>();
+ cols.add(Pair.newInstance(COLS.timestamp.name(), T.DATE));
+ cols.add(Pair.newInstance(COLS.transactionId.name(), T.TEXT));
+ cols.add(Pair.newInstance(COLS.eidasId.name(), T.TEXT));
+ cols.add(Pair.newInstance(COLS.eidasSourceCountry.name(), T.CC));
+ cols.add(Pair.newInstance(COLS.eidasDestinationCountry.name(), T.CC));
+ cols.add(Pair.newInstance(COLS.ernbId.name(), T.TEXT));
+
+ TABLE_COLS = Collections.unmodifiableList(cols);
+
+ }
+
+ public static final String CREATE = "CREATE TABLE " + NAME
+ + " (" + "id" + " " + T.ID.toString()
+ + " PRIMARY KEY AUTOINCREMENT, " + buildCreateTableQuery(TABLE_COLS) + ")";
+
+ public static final String INSERT = "INSERT INTO " + NAME
+ + "(" + buildInsertQueryKeys(TABLE_COLS) + ")"
+ + " VALUES (" + buildInsertQueryValues(TABLE_COLS) + ");";
+
+ public static final String SELECT_BY_ERNB_ID = "SELECT * FROM " + NAME
+ + " WHERE " + COLS.ernbId.name() + "=?;";
+
+ public static final String SELECT_BY_EIDAS_RAW_ID = "SELECT * FROM " + NAME
+ + " WHERE " + COLS.eidasId.name() + "=?"
+ + " and " + COLS.eidasSourceCountry.name() + "=?" + ";";
+
+
+ /**
+ * Build a part of a SQL query, which contains the cols of a table that should be created
+ *
+ * @param cols List of DB col definitions {@link Pair}
+ * @return Part of a SQL query, which contains cols that should be created
+ */
+ private static String buildCreateTableQuery(List<Pair<String, T>> cols) {
+ String sql = "";
+
+ for (Pair<String, T> el : cols) {
+ sql += el.getFirst() + " " + el.getSecond().toString() + ",";
+
+ }
+
+ return sql.substring(0, sql.length()-1);
+ }
+
+ /**
+ * Build a part of a SQL query, which contains the cols keys of a table for insert operation
+ *
+ * @param cols List of DB col definitions {@link Pair}
+ * @return Part of a SQL query, which contains cols that should be created
+ */
+ protected static String buildInsertQueryKeys(List<Pair<String, T>> cols) {
+ String sql = "";
+
+ for (Pair<String, T> el : cols) {
+ sql += el.getFirst() + ",";
+
+ }
+
+ return sql.substring(0, sql.length()-1);
+ }
+
+ /**
+ * Build a part of a SQL query, which contains the cols values of a table for insert operation
+ *
+ * @param cols List of DB col definitions {@link Pair}
+ * @return Part of a SQL query, which contains cols that should be created
+ */
+ protected static String buildInsertQueryValues(List<Pair<String, T>> cols) {
+ String sql = "";
+
+ for (Pair<String, T> el : cols) {
+ sql += "?,";
+
+ }
+
+ return sql.substring(0, sql.length()-1);
+ }
+
+}
diff --git a/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/exception/SQLiteServiceException.java b/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/exception/SQLiteServiceException.java
new file mode 100644
index 00000000..1f295db0
--- /dev/null
+++ b/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/exception/SQLiteServiceException.java
@@ -0,0 +1,17 @@
+package at.asitplus.eidas.specific.modules.authmodule_eIDASv2.exception;
+
+public class SQLiteServiceException extends eIDASAuthenticationException {
+
+ private static final long serialVersionUID = 2278259367925102676L;
+
+ public SQLiteServiceException(String internalMsgId, Object[] params, Throwable e) {
+ super(internalMsgId, params, e);
+
+ }
+
+ public SQLiteServiceException(String internalMsgId, Object[] params) {
+ super(internalMsgId, params);
+
+ }
+
+}
diff --git a/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/service/eIDASDataStore.java b/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/service/eIDASDataStore.java
new file mode 100644
index 00000000..1eed19aa
--- /dev/null
+++ b/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/service/eIDASDataStore.java
@@ -0,0 +1,328 @@
+package at.asitplus.eidas.specific.modules.authmodule_eIDASv2.service;
+
+import java.io.File;
+import java.io.IOException;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.time.Instant;
+import java.util.Properties;
+
+import javax.annotation.PostConstruct;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.sqlite.SQLiteConfig;
+import org.sqlite.SQLiteConfig.LockingMode;
+import org.sqlite.SQLiteConfig.SynchronousMode;
+import org.sqlite.SQLiteErrorCode;
+
+import at.asitplus.eidas.specific.modules.authmodule_eIDASv2.Constants;
+import at.asitplus.eidas.specific.modules.authmodule_eIDASv2.DAO.eIDASPersonalIdStoreDAO;
+import at.asitplus.eidas.specific.modules.authmodule_eIDASv2.exception.SQLiteServiceException;
+import at.gv.egiz.eaaf.core.api.idp.IConfiguration;
+import at.gv.egiz.eaaf.core.impl.data.Pair;
+import at.gv.egiz.eaaf.core.impl.data.Trible;
+
+@Component
+public class eIDASDataStore {
+
+ private static final String SQLITE_JDBC_DRIVER_CLASS = "org.sqlite.JDBC";
+ private static final String SQLITE_CONNECTION_PARAM = "jdbc:sqlite:%s";
+ private static final boolean sleep = true;
+ private static final int howLongToSleepOnBusyLock_ = 100;
+
+ private static final Logger log = LoggerFactory.getLogger(eIDASDataStore.class);
+
+ @Autowired private IConfiguration basicConfig;
+
+ private String connectionURL;
+ private Connection conn = null;
+
+ @PostConstruct
+ private void initialize() throws SQLiteServiceException {
+ try {
+ String sqlLiteDBUrl = basicConfig.getBasicConfiguration(
+ Constants.CONIG_PROPS_EIDAS_SZRCLIENT_WORKAROUND_SQLLITEDATASTORE_URL,
+ basicConfig.getConfigurationRootDirectory().toString() + "/sqlite/database.db"
+
+ );
+
+ log.info("Use SQLite database with URL: " + sqlLiteDBUrl);
+
+ //check if SQLite lib is in Classpath
+ Class.forName(SQLITE_JDBC_DRIVER_CLASS);
+
+ //open DB connection
+ boolean isNewFileCreated = false;
+
+ //open file or create file if not already exists
+ File dbFile = new File(sqlLiteDBUrl);
+ if (!dbFile.exists()) {
+ log.info("SQLite database does not exist. Creating new database file ... ");
+ dbFile.createNewFile();
+ isNewFileCreated = true;
+
+ }
+
+ //open database connection
+ connectionURL = String.format(SQLITE_CONNECTION_PARAM, dbFile.getPath());
+
+ //create DB scheme if new DB file was created
+ if (isNewFileCreated) {
+ executeUpdate(startConnection().createStatement(), eIDASPersonalIdStoreDAO.CREATE);
+ log.debug("SQLite db scheme created");
+
+ }
+
+ } catch (ClassNotFoundException e) {
+ log.warn("Can NOT initialize SQLite database for temporarly identity mapping. ", e);
+ throw new SQLiteServiceException("internal.05", new Object[] {e.getMessage()}, e);
+
+ } catch (SQLException | IOException e) {
+ log.warn("Can NOT initialize SQLite database for temporarly identity mapping. ", e);
+ throw new SQLiteServiceException("internal.05", new Object[] {e.getMessage()}, e);
+
+ }
+
+ }
+
+
+
+
+ /**
+ * Store a mapping entry with eIDAS personal identifier (source country / destination country / personal identifier)
+ * and the identifier that is used for ERnB communication
+ *
+ * @param transactionId Id of this authentication transaction
+ * @param eIDASId eIDAS personal identifier without country prefixes
+ * @param ernbId personal identifier that is used to request the ERnB
+ * @throws SQLiteServiceException
+ */
+ public void storeNationalId(String transactionId, Trible<String, String, String> eIDASId, String ernbId) throws SQLiteServiceException {
+ try {
+ PreparedStatement preStatment = startConnection().prepareStatement(
+ eIDASPersonalIdStoreDAO.INSERT,
+ Statement.RETURN_GENERATED_KEYS);
+
+ for (int i=1; i<=eIDASPersonalIdStoreDAO.TABLE_COLS.size(); i++) {
+ Pair<String, eIDASPersonalIdStoreDAO.T> col = eIDASPersonalIdStoreDAO.TABLE_COLS.get(i-1);
+ if (col.getFirst().equals(eIDASPersonalIdStoreDAO.COLS.timestamp.name()))
+ preStatment.setDate(i, new java.sql.Date(Instant.now().toEpochMilli()));
+
+ else if (col.getFirst().equals(eIDASPersonalIdStoreDAO.COLS.transactionId.name()))
+ preStatment.setString(i, transactionId);
+
+ else if (col.getFirst().equals(eIDASPersonalIdStoreDAO.COLS.eidasId.name()))
+ preStatment.setString(i, eIDASId.getThird());
+
+ else if (col.getFirst().equals(eIDASPersonalIdStoreDAO.COLS.eidasSourceCountry.name()))
+ preStatment.setString(i, eIDASId.getFirst());
+
+ else if (col.getFirst().equals(eIDASPersonalIdStoreDAO.COLS.eidasDestinationCountry.name()))
+ preStatment.setString(i, eIDASId.getSecond());
+
+ else if (col.getFirst().equals(eIDASPersonalIdStoreDAO.COLS.ernbId.name()))
+ preStatment.setString(i, ernbId);
+
+ else
+ log.warn("SQLite table:" + eIDASPersonalIdStoreDAO.NAME + " contains no col with name:" + col.getFirst());
+
+ }
+
+ //execute SQL query
+ int sqlResult = preStatment.executeUpdate();
+
+ if (sqlResult != 1) {
+ log.warn("SQLite query execution FAILED!");
+ throw new SQLiteServiceException("internal.06", new Object[] {"Queryresult is '-1'"});
+
+ }
+
+ } catch (SQLiteServiceException | SQLException e) {
+ log.warn("SQLite query execution FAILED!", e);
+ throw new SQLiteServiceException("internal.05", new Object[] {e.getMessage()}, e);
+
+ }
+
+ }
+
+ public String getErnbNationalId(Trible<String, String, String> eIDASId) throws SQLiteServiceException {
+ try {
+ PreparedStatement preStatment = startConnection().prepareStatement(
+ eIDASPersonalIdStoreDAO.SELECT_BY_EIDAS_RAW_ID,
+ Statement.RETURN_GENERATED_KEYS);
+
+ preStatment.setString(1, eIDASId.getThird());
+ preStatment.setString(2, eIDASId.getFirst());
+
+ ResultSet rs = preStatment.executeQuery();
+
+ if(!rs.next())
+ return null;
+
+ else
+ return rs.getString(eIDASPersonalIdStoreDAO.COLS.ernbId.name());
+
+ } catch (SQLiteServiceException | SQLException e) {
+ log.warn("SQLite query execution FAILED!", e);
+ throw new SQLiteServiceException("internal.05", new Object[] {e.getMessage()}, e);
+
+ }
+
+
+ }
+
+ public String getEidasRawNationalId(String ernbId) throws SQLiteServiceException {
+ try {
+ PreparedStatement preStatment = startConnection().prepareStatement(
+ eIDASPersonalIdStoreDAO.SELECT_BY_ERNB_ID,
+ Statement.RETURN_GENERATED_KEYS);
+
+ preStatment.setString(1, ernbId);
+
+ ResultSet rs = preStatment.executeQuery();
+
+ if(!rs.next())
+ return null;
+
+ else
+ return rs.getString(eIDASPersonalIdStoreDAO.COLS.eidasId.name());
+
+ } catch (SQLiteServiceException | SQLException e) {
+ log.warn("SQLite query execution FAILED!", e);
+ throw new SQLiteServiceException("internal.05", new Object[] {e.getMessage()}, e);
+
+ }
+
+ }
+
+ private Connection startConnection() throws SQLiteServiceException {
+ int i = howLongToSleepOnBusyLock_;
+
+ while (true) {
+ try {
+ if (conn == null) {
+ log.info("Initializing SQLite database with URL: " + connectionURL + " ... ");
+ conn = DriverManager.getConnection(connectionURL, getConnectionProperties());
+
+ } else {
+ if (!conn.isValid(10)) {
+ log.info("SQLite connection is not valid any more --> restarting connection ...");
+ conn.close();
+ conn = DriverManager.getConnection(connectionURL, getConnectionProperties());
+ }
+ }
+
+ log.info("SQLite database connected");
+ return conn;
+
+ } catch (SQLException e) {
+ String msg = e.getLocalizedMessage();
+ if (isBusyLocked( e)) {
+ log.warn(msg, e);
+ try {
+ if (sleep)
+ Thread.sleep(i++);
+
+ } catch (InterruptedException e1) {
+ throw new SQLiteServiceException("internal.05", new Object[] {e1.getMessage()}, e1);
+
+ }
+ continue;
+
+ }
+ throw new SQLiteServiceException("internal.05", new Object[] {e.getMessage()}, e);
+
+ }
+ }
+ }
+
+
+ /*
+ * SQLite query code
+ */
+
+ protected Properties getConnectionProperties() {
+ SQLiteConfig config = new SQLiteConfig();
+ config.enforceForeignKeys(true);
+ config.setCacheSize(8000);
+ config.setLockingMode(LockingMode.NORMAL);
+ config.setSharedCache(false);
+ config.setReadUncommited(true);
+ config.setSynchronous(SynchronousMode.NORMAL);
+ return config.toProperties();
+
+ }
+
+ private int executeUpdate(Statement statement, String sql) throws SQLiteServiceException {
+ int i = 10;
+
+ int rc = -1;
+ while (true) {
+ try {
+ rc = statement.executeUpdate(sql);
+ break;
+
+ } catch (SQLException e) {
+ try {
+ if (executeUpdateError(e, i))
+ continue;
+ else
+ throw new SQLiteServiceException("internal.06",
+ new Object[] {e.getMessage()}, e);
+
+ } catch (SQLiteServiceException e1) {
+ log.warn("\n" + sql + "\n" + e1.getMessage());
+ throw e1;
+
+ }
+ }
+ }
+
+ return rc;
+
+ }
+
+ private boolean isBusyLocked(SQLException e) {
+ int eC = e.getErrorCode();
+
+ if (eC == SQLiteErrorCode.SQLITE_LOCKED.code
+ || eC == SQLiteErrorCode.SQLITE_BUSY.code) {
+ log.trace("SQLite db is busy looked");
+ return true;
+
+ }
+
+ String msg = e.getMessage();
+ if ( msg.contains("[SQLITE_LOCKED]") || msg.contains("[SQLITE_BUSY]")) {
+ log.trace("SQLite db is busy looked");
+ return true;
+ }
+
+ return false;
+ }
+
+ private boolean executeUpdateError(SQLException e, int theadSleepCounter) throws SQLiteServiceException {
+ if (isBusyLocked(e)) {
+ try {
+ if (sleep) Thread.sleep(theadSleepCounter++);
+
+ } catch (InterruptedException e1) {
+ throw new SQLiteServiceException("internal.05", new Object[] {e1.getMessage()}, e1);
+
+ }
+
+ return true;
+ }
+
+ return false;
+
+ }
+}
+
diff --git a/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/szr/SZRClient.java b/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/szr/SZRClient.java
index 4840a5e0..458305c6 100644
--- a/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/szr/SZRClient.java
+++ b/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/szr/SZRClient.java
@@ -116,7 +116,8 @@ public class SZRClient {
GetIdentityLink getIDL = new GetIdentityLink();
getIDL.setInsertERnP(insertERnP);
getIDL.setPersonInfo(personInfo);
- getIDL.getKeyValue().addAll(keyValue);
+ if (keyValue != null)
+ getIDL.getKeyValue().addAll(keyValue);
JAXBContext jaxbContext = JAXBContext.newInstance(GetIdentityLink.class);
Marshaller jaxbMarshaller = jaxbContext.createMarshaller();
diff --git a/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/tasks/CreateIdentityLinkTask.java b/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/tasks/CreateIdentityLinkTask.java
index 9882bab2..fde56e7c 100644
--- a/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/tasks/CreateIdentityLinkTask.java
+++ b/eidas_modules/authmodule-eIDAS-v2/src/main/java/at/asitplus/eidas/specific/modules/authmodule_eIDASv2/tasks/CreateIdentityLinkTask.java
@@ -33,6 +33,7 @@ import at.asitplus.eidas.specific.modules.authmodule_eIDASv2.Constants;
import at.asitplus.eidas.specific.modules.authmodule_eIDASv2.exception.SZRCommunicationException;
import at.asitplus.eidas.specific.modules.authmodule_eIDASv2.exception.eIDASAttributeException;
import at.asitplus.eidas.specific.modules.authmodule_eIDASv2.exception.eIDASAuthenticationException;
+import at.asitplus.eidas.specific.modules.authmodule_eIDASv2.service.eIDASDataStore;
import at.asitplus.eidas.specific.modules.authmodule_eIDASv2.szr.SZRClient;
import at.asitplus.eidas.specific.modules.authmodule_eIDASv2.utils.eIDASResponseUtils;
import at.gv.e_government.reference.namespace.persondata._20020228.PersonNameType;
@@ -71,6 +72,7 @@ public class CreateIdentityLinkTask extends AbstractAuthServletTask {
//@Autowired private eIDASAttributeRegistry attrRegistry;
@Autowired private IConfiguration basicConfig;
@Autowired private SZRClient szrClient;
+ @Autowired private eIDASDataStore personalIdStore;
/* (non-Javadoc)
@@ -94,6 +96,7 @@ public class CreateIdentityLinkTask extends AbstractAuthServletTask {
Object familyNameObj = simpleAttrMap.get(Constants.eIDAS_ATTR_CURRENTFAMILYNAME);
Object givenNameObj = simpleAttrMap.get(Constants.eIDAS_ATTR_CURRENTGIVENNAME);
Object dateOfBirthObj = simpleAttrMap.get(Constants.eIDAS_ATTR_DATEOFBIRTH);
+ Object placeOfBirth = simpleAttrMap.get(Constants.eIDAS_ATTR_PLACEOFBIRTH);
//check if availabe
if (eIdentifierObj == null || !(eIdentifierObj instanceof String))
@@ -159,8 +162,8 @@ public class CreateIdentityLinkTask extends AbstractAuthServletTask {
PersonInfoType personInfo = new PersonInfoType();
PersonNameType personName = new PersonNameType();
PhysicalPersonType naturalPerson = new PhysicalPersonType();
- TravelDocumentType eDocument = new TravelDocumentType();
-
+ TravelDocumentType eDocument = new TravelDocumentType();
+
naturalPerson.setName(personName );
personInfo.setPerson(naturalPerson );
personInfo.setTravelDocument(eDocument );
@@ -187,14 +190,27 @@ public class CreateIdentityLinkTask extends AbstractAuthServletTask {
Constants.CONIG_PROPS_EIDAS_SZRCLIENT_PARAMS_EDOCUMENTTYPE,
Constants.SZR_CONSTANTS_DEFAULT_DOCUMENT_TYPE));
- //TODO: that should be removed
- eDocument.setIssueDate(basicConfig.getBasicConfiguration(
- Constants.CONIG_PROPS_EIDAS_SZRCLIENT_PARAMS_ISSUING_DATE));
- eDocument.setIssuingAuthority(basicConfig.getBasicConfiguration(
- Constants.CONIG_PROPS_EIDAS_SZRCLIENT_PARAMS_ISSUING_AUTHORITY));
+ //set PlaceOfBirth if available
+ if (placeOfBirth != null && placeOfBirth instanceof String) {
+ log.trace("Find 'PlaceOfBirth' attribute: " + placeOfBirth);
+ if (basicConfig.getBasicMOAIDConfigurationBoolean(
+ Constants.CONIG_PROPS_EIDAS_SZRCLIENT_PARAMS_SETPLACEOFBIRTHIFAVAILABLE,
+ false)) {
+ naturalPerson.setPlaceOfBirth((String) placeOfBirth);
+ log.trace("Adding 'PlaceOfBirth' to ERnB request ... ");
+
+ }
+ }
- //TODO: keys are not available in eIDAS
- List<KeyValueType> keyValue = dummyCodeForKeys();
+
+
+ //TODO: that should be removed
+// eDocument.setIssueDate(basicConfig.getBasicConfiguration(
+// Constants.CONIG_PROPS_EIDAS_SZRCLIENT_PARAMS_ISSUING_DATE));
+// eDocument.setIssuingAuthority(basicConfig.getBasicConfiguration(
+// Constants.CONIG_PROPS_EIDAS_SZRCLIENT_PARAMS_ISSUING_AUTHORITY));
+ //List<KeyValueType> keyValue = dummyCodeForKeys();
+ List<KeyValueType> keyValue = null;
IdentityLinkType result = szrClient.getIdentityLinkInRawMode(
personInfo,
@@ -207,6 +223,25 @@ public class CreateIdentityLinkTask extends AbstractAuthServletTask {
Element idlFromSZR = (Element)result.getAssertion();
identityLink = new SimpleIdentityLinkAssertionParser(idlFromSZR).parseIdentityLink();
+ //write ERnB inputdate into SQLite database
+ if (basicConfig.getBasicMOAIDConfigurationBoolean(
+ Constants.CONIG_PROPS_EIDAS_SZRCLIENT_WORKAROUND_SQLLITEDATASTORE_ACTIVE, true)) {
+ personalIdStore.storeNationalId(
+ pendingReq.getUniqueTransactionIdentifier(),
+ eIdentifier,
+ uniqueId);
+
+ }
+
+ //write ERnB inputdata into revisionlog
+ if (basicConfig.getBasicMOAIDConfigurationBoolean(
+ Constants.CONIG_PROPS_EIDAS_SZRCLIENT_WORKAROUND_SQLLITEDATASTORE_ACTIVE, false)) {
+ revisionsLogger.logEvent(pendingReq,
+ MSConnectorEventCodes.SZR_ERNB_EIDAS_RAW_ID, (String)eIdentifierObj);
+ revisionsLogger.logEvent(pendingReq,
+ MSConnectorEventCodes.SZR_ERNB_EIDAS_HASHED_ID, uniqueId);
+
+ }
//get bPK from SZR
if (basicConfig.getBasicMOAIDConfigurationBoolean(
@@ -354,29 +389,37 @@ public class CreateIdentityLinkTask extends AbstractAuthServletTask {
final Class parameterizedType = el.getParameterizedType();
if ((DateTime.class).equals(parameterizedType)) {
DateTime attribute = eIDASResponseUtils.translateDateAttribute(el, attributeMap.get(el).asList());
- if (attribute != null)
+ if (attribute != null) {
result.put(el.getFriendlyName(), attribute);
- else
+ log.trace("Find attr '" + el.getFriendlyName() + "' with value: " + attribute.toString() );
+
+ } else
log.info("Ignore empty 'DateTime' attribute");
} else if ((PostalAddress.class).equals(parameterizedType)) {
PostalAddress addressAttribute = eIDASResponseUtils.translateAddressAttribute(el, attributeMap.get(el).asList());
- if (addressAttribute != null)
+ if (addressAttribute != null) {
result.put(el.getFriendlyName(), addressAttribute);
- else
+ log.trace("Find attr '" + el.getFriendlyName() + "' with value: " + addressAttribute.toString() );
+
+ } else
log.info("Ignore empty 'PostalAddress' attribute");
} else {
List<String> natPersonIdObj = eIDASResponseUtils.translateStringListAttribute(el, attributeMap.get(el).asList());
String stringAttr = natPersonIdObj.get(0);
- if (StringUtils.isNotEmpty(stringAttr))
+ if (StringUtils.isNotEmpty(stringAttr)) {
result.put(el.getFriendlyName(), stringAttr);
- else
+ log.trace("Find attr '" + el.getFriendlyName() + "' with value: " + stringAttr );
+
+ } else
log.info("Ignore empty 'String' attribute");
}
}
-
+
+ log.debug("Receive #" + result.size() + " attributes with names: " + result.keySet().toString());
+
return result;
}