#include "config.h"
#include "DNS.h"
#include "DNSResolveQueue.h"
#if USE(SOUP)
#include "NetworkStorageSession.h"
#include "SoupNetworkSession.h"
#include <libsoup/soup.h>
#include <wtf/MainThread.h>
#include <wtf/glib/GUniquePtr.h>
#include <wtf/text/CString.h>
namespace WebCore {
static bool isUsingHttpProxy = true;
static bool isUsingHttpsProxy = true;
static bool didResolveProxy(char** uris)
{
return uris && *uris && strcmp(*uris, "direct://");
}
static void didResolveProxy(GProxyResolver* resolver, GAsyncResult* result, bool* isUsingProxyType, bool* isUsingProxy)
{
GUniqueOutPtr<GError> error;
GUniquePtr<char*> uris(g_proxy_resolver_lookup_finish(resolver, result, &error.outPtr()));
if (error) {
WTFLogAlways("Error determining system proxy settings: %s", error->message);
return;
}
*isUsingProxyType = didResolveProxy(uris.get());
*isUsingProxy = isUsingHttpProxy || isUsingHttpsProxy;
}
static void proxyResolvedForHttpUriCallback(GObject* source, GAsyncResult* result, void* userData)
{
didResolveProxy(G_PROXY_RESOLVER(source), result, &isUsingHttpProxy, static_cast<bool*>(userData));
}
static void proxyResolvedForHttpsUriCallback(GObject* source, GAsyncResult* result, void* userData)
{
didResolveProxy(G_PROXY_RESOLVER(source), result, &isUsingHttpsProxy, static_cast<bool*>(userData));
}
void DNSResolveQueue::updateIsUsingProxy()
{
GRefPtr<GProxyResolver> resolver;
g_object_get(NetworkStorageSession::defaultStorageSession().getOrCreateSoupNetworkSession().soupSession(), "proxy-resolver", &resolver.outPtr(), nullptr);
ASSERT(resolver);
g_proxy_resolver_lookup_async(resolver.get(), "http://example.com/", nullptr, proxyResolvedForHttpUriCallback, &m_isUsingProxy);
g_proxy_resolver_lookup_async(resolver.get(), "https://example.com/", nullptr, proxyResolvedForHttpsUriCallback, &m_isUsingProxy);
}
static void resolvedCallback(SoupAddress*, guint, void*)
{
DNSResolveQueue::singleton().decrementRequestCount();
}
void DNSResolveQueue::platformResolve(const String& hostname)
{
ASSERT(isMainThread());
soup_session_prefetch_dns(NetworkStorageSession::defaultStorageSession().getOrCreateSoupNetworkSession().soupSession(), hostname.utf8().data(), nullptr, resolvedCallback, nullptr);
}
void prefetchDNS(const String& hostname)
{
ASSERT(isMainThread());
if (hostname.isEmpty())
return;
DNSResolveQueue::singleton().add(hostname);
}
}
#endif