Comparison

mod_pubsub_serverinfo: Refresh cache entries if they will expire before next run

comparison

equal deleted inserted replaced

-:ce8f0e458ffa
+:cf5f77491323
 function does_opt_in(remoteDomain)
 	-- try to read answer from cache.
 	local cached_value = opt_in_cache[remoteDomain]
-	if cached_value ~= nil and os.difftime(cached_value.expires, os.time()) > 0 then
+	local ttl = cached_value and os.difftime(cached_value.expires, os.time());
+	if cached_value and ttl > (publication_interval + 60) then
 		module:log("debug", "Opt-in status (from cache) for '%s': %s", remoteDomain, cached_value.opt_in)
 		return cached_value.opt_in;
 	end
+	-- We don't have a cached value, or it is nearing expiration - refresh it now
 	-- TODO worry about not having multiple requests in flight to the same domain.cached_value
-	-- Cache could not provide an answer. Perform service discovery.
 	module:log("debug", "No cached opt-in status for '%s': performing disco/info to determine opt-in.", remoteDomain)
 	local discoRequest = st.iq({ type = "get", to = remoteDomain, from = actor, id = new_id() })
 		:tag("query", { xmlns = "http://jabber.org/protocol/disco#info" })
 	module:send_iq(discoRequest):next(
 				expires = os.time() + cache_ttl;
 			}
 		end
 	);
-	-- return 'false' for now. Better luck next time...
+	if ttl and ttl <= 0 then
-	return false;
+		-- Cache entry expired, remove it and assume not opted in
+		opt_in_cache[remoteDomain] = nil;
-end
+		return false;
+	end
+	return cached_value and cached_value.opt_in;
+end