A wrapper that refreshes the inner every refresfRate

AutoRefreshingWrapper.scala

package core

import org.joda.time.DateTime

import scala.concurrent.duration.Duration
import scala.util.{Failure, Success, Try}

class AutoRefreshingWrapper[T](refreshFunc: => Try[T], refreshRate: Duration) extends SBLogger {

	@volatile
	private var inner: T = refreshFunc.get
	@volatile
	private var lastRefreshMillis = DateTime.now.getMillis

	private val refreshRateMillis = refreshRate.toMillis

	def get(): T = synchronized{
		val nowMillis = DateTime.now.getMillis
		if((nowMillis - lastRefreshMillis) >  refreshRateMillis)
			refresh()
		inner
	}

	def refresh() = {
		refreshFunc match {
			case Success(value) =>
				inner = value
				lastRefreshMillis = DateTime.now.getMillis
			case Failure(e) =>
				logger.warn(s"refresh failed due to $e")
		}
	}
}