#include "config.h"
#include "QtWebContext.h"
#include "MutableArray.h"
#include "QtDownloadManager.h"
#include "QtWebIconDatabaseClient.h"
#include "WKAPICast.h"
#include "WebContext.h"
#include "WebInspectorServer.h"
#include "WebPageProxy.h"
#include <WKArray.h>
#include <WKPage.h>
#include <WKString.h>
#include <WKType.h>
namespace WebKit {
static uint64_t generateContextID()
{
static uint64_t uniqueContextID = 1;
return uniqueContextID++;
}
static HashMap<uint64_t, QtWebContext*> contextMap;
QtWebContext* QtWebContext::s_defaultContext = 0;
static void initInspectorServer()
{
QString inspectorEnv = QString::fromUtf8(qgetenv("QTWEBKIT_INSPECTOR_SERVER"));
if (!inspectorEnv.isEmpty()) {
QString bindAddress = QLatin1String("127.0.0.1");
QString portStr = inspectorEnv;
int port = 0;
int portColonPos = inspectorEnv.lastIndexOf(':');
if (portColonPos != -1) {
portStr = inspectorEnv.mid(portColonPos + 1);
bindAddress = inspectorEnv.mid(0, portColonPos);
}
bool ok = false;
port = portStr.toInt(&ok);
if (!ok) {
qWarning("Non numeric port for the inspector server \"%s\". Examples of valid input: \"12345\" or \"192.168.2.14:12345\" (with the address of one of this host's interface).", qPrintable(portStr));
return;
}
bool success = WebInspectorServer::shared().listen(bindAddress, port);
if (success) {
QString inspectorServerUrl = QString::fromLatin1("http://%1:%2").arg(bindAddress).arg(port);
qWarning("Inspector server started successfully. Try pointing a WebKit browser to %s", qPrintable(inspectorServerUrl));
} else
qWarning("Couldn't start the inspector server on bind address \"%s\" and port \"%d\". In case of invalid input, try something like: \"12345\" or \"192.168.2.14:12345\" (with the address of one of this host's interface).", qPrintable(bindAddress), port);
}
}
static void globalInitialization()
{
static bool initialized = false;
if (initialized)
return;
initInspectorServer();
initialized = true;
}
QtWebContext::QtWebContext(WebContext* context)
: m_contextID(generateContextID())
, m_context(context)
, m_downloadManager(adoptPtr(new QtDownloadManager(context)))
, m_iconDatabase(adoptPtr(new QtWebIconDatabaseClient(this)))
{
contextMap.set(m_contextID, this);
}
QtWebContext::~QtWebContext()
{
if (s_defaultContext == this)
s_defaultContext = 0;
contextMap.remove(m_contextID);
}
PassRefPtr<QtWebContext> QtWebContext::create(WebContext* context)
{
globalInitialization();
return adoptRef(new QtWebContext(context));
}
PassRefPtr<QtWebContext> QtWebContext::defaultContext()
{
if (s_defaultContext)
return PassRefPtr<QtWebContext>(s_defaultContext);
RefPtr<WebContext> context = WebContext::sharedProcessContext();
RefPtr<QtWebContext> defaultContext = QtWebContext::create(context.get());
s_defaultContext = defaultContext.get();
defaultContext->initializeContextInjectedBundleClient();
return defaultContext.release();
}
PassRefPtr<WebPageProxy> QtWebContext::createWebPage(PageClient* client, WebPageGroup* pageGroup)
{
return m_context->createWebPage(client, pageGroup);
}
void QtWebContext::setNavigatorQtObjectEnabled(WebPageProxy* webPageProxy, bool enabled)
{
static String messageName("SetNavigatorQtObjectEnabled");
RefPtr<MutableArray> body = MutableArray::create();
body->append(webPageProxy);
RefPtr<WebBoolean> webEnabled = WebBoolean::create(enabled);
body->append(webEnabled.get());
m_context->postMessageToInjectedBundle(messageName, body.get());
}
void QtWebContext::postMessageToNavigatorQtObject(WebPageProxy* webPageProxy, const QString& message)
{
static String messageName("MessageToNavigatorQtObject");
RefPtr<MutableArray> body = MutableArray::create();
body->append(webPageProxy);
RefPtr<WebString> contents = WebString::create(String(message));
body->append(contents.get());
m_context->postMessageToInjectedBundle(messageName, body.get());
}
QtWebContext* QtWebContext::contextByID(uint64_t id)
{
return contextMap.get(id);
}
void QtWebContext::initializeContextInjectedBundleClient()
{
WKContextInjectedBundleClient injectedBundleClient;
memset(&injectedBundleClient, 0, sizeof(WKContextInjectedBundleClient));
injectedBundleClient.version = kWKContextInjectedBundleClientCurrentVersion;
injectedBundleClient.clientInfo = this;
injectedBundleClient.didReceiveMessageFromInjectedBundle = didReceiveMessageFromInjectedBundle;
WKContextSetInjectedBundleClient(toAPI(m_context.get()), &injectedBundleClient);
}
static QtWebContext* toQtWebContext(const void* clientInfo)
{
ASSERT(clientInfo);
return reinterpret_cast<QtWebContext*>(const_cast<void*>(clientInfo));
}
void QtWebContext::didReceiveMessageFromInjectedBundle(WKContextRef, WKStringRef messageName, WKTypeRef messageBody, const void* clientInfo)
{
toQtWebContext(clientInfo)->didReceiveMessageFromInjectedBundle(messageName, messageBody);
}
void QtWebContext::didReceiveMessageFromInjectedBundle(WKStringRef messageName, WKTypeRef messageBody)
{
if (!WKStringIsEqualToUTF8CString(messageName, "MessageFromNavigatorQtObject"))
return;
ASSERT(messageBody);
ASSERT(WKGetTypeID(messageBody) == WKArrayGetTypeID());
WKArrayRef body = static_cast<WKArrayRef>(messageBody);
ASSERT(WKArrayGetSize(body) == 2);
ASSERT(WKGetTypeID(WKArrayGetItemAtIndex(body, 0)) == WKPageGetTypeID());
ASSERT(WKGetTypeID(WKArrayGetItemAtIndex(body, 1)) == WKStringGetTypeID());
WKPageRef page = static_cast<WKPageRef>(WKArrayGetItemAtIndex(body, 0));
WKStringRef str = static_cast<WKStringRef>(WKArrayGetItemAtIndex(body, 1));
toImpl(page)->didReceiveMessageFromNavigatorQtObject(toImpl(str)->string());
}
}