org.gluu.credmanager.service.TrustedDevicesSweeper クラス

org.gluu.credmanager.service.TrustedDevicesSweeper の継承関係図

org.gluu.credmanager.service.TrustedDevicesSweeper 連携図

公開メンバ関数
void	activate (long locationExpiration, long deviceExpiration)
String	getName ()
void	jobToBeExecuted (JobExecutionContext context)

非公開メンバ関数
void	inited ()
boolean	removeExpiredData (List< TrustedDevice > list, long time) throws Exception
List< PersonPreferences >	getPeopleTrustedDevices ()
void	updateTrustedDevices (PersonPreferences person, String jsonDevices) throws Exception

非公開変数類
Logger	logger
String	quartzJobName
long	locationExpiration
long	deviceExpiration
ObjectMapper	mapper
TimerService	timerService
LdapService	ldapService

詳解

著者

jgomer

関数詳解

activate()

void org.gluu.credmanager.service.TrustedDevicesSweeper.activate ( long  locationExpiration, long  deviceExpiration  )

inline

                                                                         {

        this.locationExpiration = locationExpiration;
        this.deviceExpiration = deviceExpiration;
        try {
            int oneDay = (int) TimeUnit.DAYS.toSeconds(1);
            timerService.addListener(this, quartzJobName);
            //Start in one second and repeat indefinitely once every day
            timerService.schedule(quartzJobName, 1, -1, oneDay);
        } catch (Exception e) {
            logger.error(e.getMessage(), e);
        }

    }

getName()

String org.gluu.credmanager.service.TrustedDevicesSweeper.getName ( )

inline

                            {
        return quartzJobName;
    }

getPeopleTrustedDevices()

List<PersonPreferences> org.gluu.credmanager.service.TrustedDevicesSweeper.getPeopleTrustedDevices ( )

inlineprivate

                                                              {

        List<PersonPreferences> list = new ArrayList<>();
        try {
            String filther = Filter.createPresenceFilter("oxTrustedDevicesInfo").toString();
            list = ldapService.find(PersonPreferences.class, ldapService.getPeopleDn(), filther);
        } catch (Exception e) {
            logger.error(e.getMessage(), e);
        }
        return list;

    }

inited()

void org.gluu.credmanager.service.TrustedDevicesSweeper.inited ( )

inlineprivate

                          {
        mapper = new ObjectMapper();
        quartzJobName = getClass().getSimpleName() + "_sweep";
    }

jobToBeExecuted()

void org.gluu.credmanager.service.TrustedDevicesSweeper.jobToBeExecuted ( JobExecutionContext  context )

inline

                                                             {

        logger.info("TrustedDevicesSweeper. Running timer job");
        long now = System.currentTimeMillis();
        List<PersonPreferences> people = getPeopleTrustedDevices();

        for (PersonPreferences person : people) {
            try {
                String trustedDevicesInfo = ldapService.getDecryptedString(person.getTrustedDevicesInfo());
                List<TrustedDevice> list = mapper.readValue(trustedDevicesInfo, new TypeReference<List<TrustedDevice>>() { });

                if (removeExpiredData(list, now)) {
                    //update list
                    String jsonStr = mapper.writeValueAsString(list);
                    updateTrustedDevices(person, jsonStr);
                }
            } catch (Exception e) {
                //TODO: if fails, should the trusted dvicesinfo be cleared (e.g. migration of gluu version may change salt?)
                logger.error(e.getMessage(), e);
            }
        }

    }

removeExpiredData()

boolean org.gluu.credmanager.service.TrustedDevicesSweeper.removeExpiredData ( List< TrustedDevice >  list, long  time  ) throws Exception

inlineprivate

                                                                                            {

        boolean changed = false;

        for (int i = 0; i < list.size(); i++) {
            TrustedDevice device = list.get(i);
            List<TrustedOrigin> origins = device.getOrigins();

            if (origins != null) {
                long oldest = Long.MAX_VALUE;

                for (int j = 0; j < origins.size(); j++) {

                    TrustedOrigin origin = origins.get(j);
                    if (origin.getTimestamp() < oldest) {
                        oldest = origin.getTimestamp();
                    }
                    if (time - origin.getTimestamp() > locationExpiration) {
                        origins.remove(j);
                        j--;
                        changed = true;
                    }
                }

                if (time - oldest > deviceExpiration) {
                    list.remove(i);
                    i--;
                    changed = true;
                }
            }
        }
        return changed;

    }

updateTrustedDevices()

void org.gluu.credmanager.service.TrustedDevicesSweeper.updateTrustedDevices ( PersonPreferences  person, String  jsonDevices  ) throws Exception

inlineprivate

                                                                                                     {
        String rdn = person.getInum();
        logger.trace("TrustedDevicesSweeper. Cleaning expired trusted devices for user '{}'", rdn);
        person.setTrustedDevices(ldapService.getEncryptedString(jsonDevices));
        ldapService.modify(person, PersonPreferences.class);

    }

メンバ詳解

deviceExpiration

long org.gluu.credmanager.service.TrustedDevicesSweeper.deviceExpiration

private

ldapService

LdapService org.gluu.credmanager.service.TrustedDevicesSweeper.ldapService

private

locationExpiration

long org.gluu.credmanager.service.TrustedDevicesSweeper.locationExpiration

private

logger

Logger org.gluu.credmanager.service.TrustedDevicesSweeper.logger

private

mapper

ObjectMapper org.gluu.credmanager.service.TrustedDevicesSweeper.mapper

private

quartzJobName

String org.gluu.credmanager.service.TrustedDevicesSweeper.quartzJobName

private

timerService

TimerService org.gluu.credmanager.service.TrustedDevicesSweeper.timerService

private

---

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

• D:/AppData/OpenId/gluu/src/cred-manager/app/src/main/java/org/gluu/credmanager/service/TrustedDevicesSweeper.java