WebNotificationManagerProxy.cpp [plain text]
#include "config.h"
#include "WebNotificationManagerProxy.h"
#include "ImmutableArray.h"
#include "ImmutableDictionary.h"
#include "WebContext.h"
#include "WebNotification.h"
#include "WebNotificationManagerMessages.h"
#include "WebPageProxy.h"
#include "WebSecurityOrigin.h"
using namespace WTF;
using namespace WebCore;
namespace WebKit {
PassRefPtr<WebNotificationManagerProxy> WebNotificationManagerProxy::create(WebContext* context)
{
return adoptRef(new WebNotificationManagerProxy(context));
}
WebNotificationManagerProxy::WebNotificationManagerProxy(WebContext* context)
: m_context(context)
{
}
void WebNotificationManagerProxy::invalidate()
{
m_provider.removeNotificationManager(this);
}
void WebNotificationManagerProxy::initializeProvider(const WKNotificationProvider *provider)
{
m_provider.initialize(provider);
m_provider.addNotificationManager(this);
}
void WebNotificationManagerProxy::populateCopyOfNotificationPermissions(HashMap<String, bool>& permissions)
{
RefPtr<ImmutableDictionary> knownPermissions = m_provider.notificationPermissions();
permissions.clear();
RefPtr<ImmutableArray> knownOrigins = knownPermissions->keys();
for (size_t i = 0; i < knownOrigins->size(); ++i) {
WebString* origin = knownOrigins->at<WebString>(i);
permissions.set(origin->string(), knownPermissions->get<WebBoolean>(origin->string())->value());
}
}
void WebNotificationManagerProxy::didReceiveMessage(CoreIPC::Connection* connection, CoreIPC::MessageID messageID, CoreIPC::ArgumentDecoder* arguments)
{
didReceiveWebNotificationManagerProxyMessage(connection, messageID, arguments);
}
void WebNotificationManagerProxy::show(WebPageProxy* page, const String& title, const String& body, const String& iconURL, const String& tag, const String& originString, uint64_t notificationID)
{
if (!isNotificationIDValid(notificationID))
return;
RefPtr<WebNotification> notification = WebNotification::create(title, body, iconURL, tag, originString, notificationID);
m_notifications.set(notificationID, notification);
m_provider.show(page, notification.get());
}
void WebNotificationManagerProxy::cancel(uint64_t notificationID)
{
if (!isNotificationIDValid(notificationID))
return;
RefPtr<WebNotification> notification = m_notifications.get(notificationID);
if (!notification)
return;
m_provider.cancel(notification.get());
}
void WebNotificationManagerProxy::didDestroyNotification(uint64_t notificationID)
{
if (!isNotificationIDValid(notificationID))
return;
RefPtr<WebNotification> notification = m_notifications.take(notificationID);
if (!notification)
return;
m_provider.didDestroyNotification(notification.get());
}
void WebNotificationManagerProxy::clearNotifications(const Vector<uint64_t>& notificationIDs)
{
m_provider.clearNotifications(notificationIDs);
size_t count = notificationIDs.size();
for (size_t i = 0; i < count; ++i)
m_notifications.remove(notificationIDs[i]);
}
void WebNotificationManagerProxy::providerDidShowNotification(uint64_t notificationID)
{
if (!m_context)
return;
m_context->sendToAllProcesses(Messages::WebNotificationManager::DidShowNotification(notificationID));
}
void WebNotificationManagerProxy::providerDidClickNotification(uint64_t notificationID)
{
if (!m_context)
return;
m_context->sendToAllProcesses(Messages::WebNotificationManager::DidClickNotification(notificationID));
}
void WebNotificationManagerProxy::providerDidCloseNotifications(ImmutableArray* notificationIDs)
{
if (!m_context)
return;
size_t size = notificationIDs->size();
Vector<uint64_t> vectorNotificationIDs;
vectorNotificationIDs.reserveInitialCapacity(size);
for (size_t i = 0; i < size; ++i) {
uint64_t notificationID = notificationIDs->at<WebUInt64>(i)->value();
vectorNotificationIDs.append(notificationID);
}
if (vectorNotificationIDs.size())
m_context->sendToAllProcesses(Messages::WebNotificationManager::DidCloseNotifications(vectorNotificationIDs));
}
void WebNotificationManagerProxy::providerDidUpdateNotificationPolicy(const WebSecurityOrigin* origin, bool allowed)
{
if (!m_context)
return;
m_context->sendToAllProcesses(Messages::WebNotificationManager::DidUpdateNotificationDecision(origin->toString(), allowed));
}
void WebNotificationManagerProxy::providerDidRemoveNotificationPolicies(ImmutableArray* origins)
{
if (!m_context)
return;
size_t size = origins->size();
if (!size)
return;
Vector<String> originStrings;
originStrings.reserveInitialCapacity(size);
for (size_t i = 0; i < size; ++i)
originStrings.append(origins->at<WebSecurityOrigin>(i)->toString());
m_context->sendToAllProcesses(Messages::WebNotificationManager::DidRemoveNotificationDecisions(originStrings));
}
}