org.keycloak.exportimport.dir.DirImportProvider クラス

org.keycloak.exportimport.dir.DirImportProvider の継承関係図

org.keycloak.exportimport.dir.DirImportProvider 連携図

公開メンバ関数
	DirImportProvider ()
	DirImportProvider (File rootDirectory)
void	importModel (KeycloakSessionFactory factory, Strategy strategy) throws IOException
boolean	isMasterRealmExported () throws IOException
void	importRealm (KeycloakSessionFactory factory, final String realmName, final Strategy strategy) throws IOException
void	close ()

非公開メンバ関数
List< String >	getRealmsToImport () throws IOException

非公開変数類
final File	rootDirectory

静的非公開変数類
static final Logger	logger = Logger.getLogger(DirImportProvider.class)

詳解

著者

Marek Posolda

構築子と解体子

DirImportProvider() [1/2]

org.keycloak.exportimport.dir.DirImportProvider.DirImportProvider ( )

inline

                               {
        // Determine system tmp directory
        String tempDir = System.getProperty("java.io.tmpdir");

        // Delete and recreate directory inside tmp
        this.rootDirectory = new File(tempDir + "/keycloak-export");
        if (!this.rootDirectory .exists()) {
            throw new IllegalStateException("Directory " + this.rootDirectory + " doesn't exists");
        }

        logger.infof("Importing from directory %s", this.rootDirectory.getAbsolutePath());
    }

DirImportProvider() [2/2]

org.keycloak.exportimport.dir.DirImportProvider.DirImportProvider ( File  rootDirectory )

inline

                                                 {
        this.rootDirectory = rootDirectory;

        if (!this.rootDirectory.exists()) {
            throw new IllegalStateException("Directory " + this.rootDirectory + " doesn't exists");
        }

        logger.infof("Importing from directory %s", this.rootDirectory.getAbsolutePath());
    }

関数詳解

close()

void org.keycloak.exportimport.dir.DirImportProvider.close ( )

inline

                        {

    }

getRealmsToImport()

List<String> org.keycloak.exportimport.dir.DirImportProvider.getRealmsToImport ( ) throws IOException

inlineprivate

                                                                {
        File[] realmFiles = this.rootDirectory.listFiles(new FilenameFilter() {

            @Override
            public boolean accept(File dir, String name) {
                return (name.endsWith("-realm.json"));
            }
        });

        List<String> realmNames = new ArrayList<String>();
        for (File file : realmFiles) {
            String fileName = file.getName();
            // Parse "foo" from "foo-realm.json"
            String realmName = fileName.substring(0, fileName.length() - 11);

            // Ensure that master realm is imported first
            if (Config.getAdminRealm().equals(realmName)) {
                realmNames.add(0, realmName);
            } else {
                realmNames.add(realmName);
            }
        }
        return realmNames;
    }

importModel()

void org.keycloak.exportimport.dir.DirImportProvider.importModel ( KeycloakSessionFactory  factory, Strategy  strategy  ) throws IOException

inline

                                                                                                  {
        List<String> realmNames = getRealmsToImport();

        for (String realmName : realmNames) {
            importRealm(factory, realmName, strategy);
        }
    }

importRealm()

void org.keycloak.exportimport.dir.DirImportProvider.importRealm ( KeycloakSessionFactory  factory, final String  realmName, final Strategy  strategy  ) throws IOException

inline

                                                                                                                                {
        File realmFile = new File(this.rootDirectory + File.separator + realmName + "-realm.json");
        File[] userFiles = this.rootDirectory.listFiles(new FilenameFilter() {

            @Override
            public boolean accept(File dir, String name) {
                return name.matches(realmName + "-users-[0-9]+\\.json");
            }
        });
        File[] federatedUserFiles = this.rootDirectory.listFiles(new FilenameFilter() {

            @Override
            public boolean accept(File dir, String name) {
                return name.matches(realmName + "-federated-users-[0-9]+\\.json");
            }
        });

        // Import realm first
        FileInputStream is = new FileInputStream(realmFile);
        final RealmRepresentation realmRep = JsonSerialization.readValue(is, RealmRepresentation.class);
        final AtomicBoolean realmImported = new AtomicBoolean();

        KeycloakModelUtils.runJobInTransaction(factory, new ExportImportSessionTask() {

            @Override
            public void runExportImportTask(KeycloakSession session) throws IOException {
                boolean imported = ImportUtils.importRealm(session, realmRep, strategy, true);
                realmImported.set(imported);
            }

        });

        if (realmImported.get()) {
            // Import users
            for (final File userFile : userFiles) {
                final FileInputStream fis = new FileInputStream(userFile);
                KeycloakModelUtils.runJobInTransaction(factory, new ExportImportSessionTask() {
                    @Override
                    protected void runExportImportTask(KeycloakSession session) throws IOException {
                        ImportUtils.importUsersFromStream(session, realmName, JsonSerialization.mapper, fis);
                        logger.infof("Imported users from %s", userFile.getAbsolutePath());
                    }
                });
            }
            for (final File userFile : federatedUserFiles) {
                final FileInputStream fis = new FileInputStream(userFile);
                KeycloakModelUtils.runJobInTransaction(factory, new ExportImportSessionTask() {
                    @Override
                    protected void runExportImportTask(KeycloakSession session) throws IOException {
                        ImportUtils.importFederatedUsersFromStream(session, realmName, JsonSerialization.mapper, fis);
                        logger.infof("Imported federated users from %s", userFile.getAbsolutePath());
                    }
                });
            }
        }

        // Import authorization last, as authzPolicies can require users already in DB
        KeycloakModelUtils.runJobInTransaction(factory, new ExportImportSessionTask() {

            @Override
            public void runExportImportTask(KeycloakSession session) throws IOException {
                RealmModel realm = session.realms().getRealmByName(realmName);
                RepresentationToModel.importRealmAuthorizationSettings(realmRep, realm, session);
            }

        });
    }

isMasterRealmExported()

boolean org.keycloak.exportimport.dir.DirImportProvider.isMasterRealmExported ( ) throws IOException

inline

                                                              {
        List<String> realmNames = getRealmsToImport();
        return realmNames.contains(Config.getAdminRealm());
    }

メンバ詳解

logger

final Logger org.keycloak.exportimport.dir.DirImportProvider.logger = Logger.getLogger(DirImportProvider.class)

staticprivate

rootDirectory

final File org.keycloak.exportimport.dir.DirImportProvider.rootDirectory

private

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/doxygen/keycloak/rest-service/src/services/src/main/java/org/keycloak/exportimport/dir/DirImportProvider.java