org.xdi.oxd.server.service.MigrationService クラス

org.xdi.oxd.server.service.MigrationService 連携図

公開メンバ関数
	MigrationService (ConfigurationService configurationService, RpService rpService)
void	migrate ()
void	migrateChildren (File parentFolder)

静的公開メンバ関数
static Rp	parseRp (File file)
static Rp	parseRp (String rpAsJson)

非公開メンバ関数
void	migrateRpFile (File file)
File	getMigrationFolderFile ()

非公開変数類
ConfigurationService	configurationService
RpService	rpService

静的非公開変数類
static final Logger	LOG = LoggerFactory.getLogger(MigrationService.class)
static final int	FILE_NAME_LENGTH = (UUID.randomUUID().toString() + ".json").length()

詳解

著者

yuriyz

構築子と解体子

MigrationService()

org.xdi.oxd.server.service.MigrationService.MigrationService ( ConfigurationService  configurationService, RpService  rpService  )

inline

                                                                                            {
        this.configurationService = configurationService;
        this.rpService = rpService;
    }

関数詳解

getMigrationFolderFile()

File org.xdi.oxd.server.service.MigrationService.getMigrationFolderFile ( )

inlineprivate

                                          {
        String migrationSourceFolderPath = configurationService.getConfiguration().getMigrationSourceFolderPath();
        if (StringUtils.isBlank(migrationSourceFolderPath)) {
            LOG.debug("Migration source folder is not specified.");
            return null;
        }

        File migrationFolder = new File(migrationSourceFolderPath);
        if (!migrationFolder.exists() || !migrationFolder.isDirectory()) {
            LOG.error("Migration source folder does not exist or is not directory.");
            return null;
        }
        return migrationFolder;
    }

migrate()

void org.xdi.oxd.server.service.MigrationService.migrate ( )

inline

                          {
        File migrationFolderFile = getMigrationFolderFile();
        if (migrationFolderFile == null) {
            LOG.debug("Skip migration because migration source folder is not specified or otherwise invalid.");
            return;
        }

        migrateChildren(migrationFolderFile);
    }

migrateChildren()

void org.xdi.oxd.server.service.MigrationService.migrateChildren ( File  parentFolder )

inline

                                                   {
        final List<File> files = Lists.newArrayList(Files.fileTreeTraverser().children(parentFolder));
        for (File file : files) {
            migrateRpFile(file);
        }
    }

migrateRpFile()

void org.xdi.oxd.server.service.MigrationService.migrateRpFile ( File  file )

inlineprivate

                                          {
        if (file.getName().length() == FILE_NAME_LENGTH && file.getName().endsWith(".json")) {
            LOG.trace("Loading rp file name: {}", file.getName());

            try {
                Rp rp = parseRp(file);
                rpService.create(rp);

//                String path = file.getAbsolutePath();
//                if (file.delete()) {
//                    LOG.debug("Removed rp file : " + path + " and pushed it to database.");
//                }
            } catch (Exception e) {
                LOG.error(e.getMessage(), e);
            }
        }
    }

parseRp() [1/2]

static Rp org.xdi.oxd.server.service.MigrationService.parseRp ( File  file )

inlinestatic

                                        {
        try {
            return parseRp(FileUtils.readFileToString(file));
        } catch (IOException e) {
            LOG.error(e.getMessage(), e);
            return null;
        }
    }

parseRp() [2/2]

static Rp org.xdi.oxd.server.service.MigrationService.parseRp ( String  rpAsJson )

inlinestatic

                                              {
        try {
            if (StringUtils.isBlank(rpAsJson)) {
                return null;
            }
            try {
                return CoreUtils.createJsonMapper().readValue(rpAsJson, Rp.class);
            } catch (Exception e) {
                LOG.error(e.getMessage(), e);
                return null;
            }
        } catch (Exception e) {
            LOG.error(e.getMessage(), e);
            return null;
        }
    }

メンバ詳解

configurationService

ConfigurationService org.xdi.oxd.server.service.MigrationService.configurationService

private

FILE_NAME_LENGTH

final int org.xdi.oxd.server.service.MigrationService.FILE_NAME_LENGTH = (UUID.randomUUID().toString() + ".json").length()

staticprivate

LOG

final Logger org.xdi.oxd.server.service.MigrationService.LOG = LoggerFactory.getLogger(MigrationService.class)

staticprivate

rpService

RpService org.xdi.oxd.server.service.MigrationService.rpService

private

---

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

• D:/AppData/OpenId/gluu/src/oxd/oxd-server/src/main/java/org/xdi/oxd/server/service/MigrationService.java