Merge pull request #241 from supertokens/feat/bulk-import-test-fixes

fix: fixing tests by proper exception handling

Author: porcellus

src/main/java/io/supertokens/storage/postgresql/Start.java

@@ -3596,15 +3596,20 @@ public void addBulkImportUsers(AppIdentifier appIdentifier, List<BulkImportUser>
                 try {
                     BulkImportQueries.insertBulkImportUsers_Transaction(this, (Connection) con.getConnection(), appIdentifier, users);
                 } catch (SQLException e) {
-                    if (e instanceof PSQLException) {
-                        ServerErrorMessage serverErrorMessage = ((PSQLException) e).getServerErrorMessage();
-                        if (isPrimaryKeyError(serverErrorMessage, Config.getConfig(this).getBulkImportUsersTable())) {
-                            throw new StorageTransactionLogicException(new io.supertokens.pluginInterface.bulkimport.exceptions.DuplicateUserIdException());
-                        }
-                        if (isForeignKeyConstraintError(serverErrorMessage, Config.getConfig(this).getBulkImportUsersTable(),
-                                "app_id")) {
-                            throw new TenantOrAppNotFoundException(appIdentifier);
+                    if (e instanceof BatchUpdateException) {
+                        BatchUpdateException batchUpdateException = (BatchUpdateException) e;
+                        SQLException nextException = batchUpdateException.getNextException();
+                        if(nextException instanceof PSQLException){
+                            ServerErrorMessage serverErrorMessage = ((PSQLException) nextException).getServerErrorMessage();
+                            if (isPrimaryKeyError(serverErrorMessage, Config.getConfig(this).getBulkImportUsersTable())) {
+                                throw new StorageTransactionLogicException(new io.supertokens.pluginInterface.bulkimport.exceptions.DuplicateUserIdException());
+                            }
+                            if (isForeignKeyConstraintError(serverErrorMessage, Config.getConfig(this).getBulkImportUsersTable(),
+                                    "app_id")) {
+                                throw new TenantOrAppNotFoundException(appIdentifier);
+                            }
                         }
+
                     }
                 }
                 return null;