class WeixinAuthorize::Token::Store

def self.init_with(client)
  if WeixinAuthorize.weixin_redis.nil?
    ObjectStore.new(client)
  else
    RedisStore.new(client)
  end
end

def access_token
  refresh_token if token_expired?
end

def authenticate
  auth_result = http_get_access_token
  auth = false
  if auth_result.is_ok?
    set_access_token(auth_result.result)
    auth = true
  end
  {"valid" => auth, "handler" => auth_result}
end

def authenticate_headers
  {grant_type: GRANT_TYPE, appid: client.app_id, secret: client.app_secret}
end

def handle_valid_exception
  auth_result = authenticate
  if !auth_result["valid"]
    result_handler = auth_result["handler"]
    raise ValidAccessTokenException, result_handler.full_error_message
  end
end

def http_get_access_token
  WeixinAuthorize.http_get_without_token("/token", authenticate_headers)
end

def initialize(client)
  @client = client
end

def refresh_token
  handle_valid_exception
  set_access_token
end

def set_access_token(access_token_infos=nil)
  token_infos = access_token_infos || http_get_access_token.result
  client.access_token = token_infos["access_token"]
  client.expired_at   = Time.now.to_i + token_infos["expires_in"].to_i
end

def token_expired?
  raise NotImplementedError, "Subclasses must implement a token_expired? method"
end

def valid?
  authenticate["valid"]
end