RegistrationStore.h [plain text]
#pragma once
#if ENABLE(SERVICE_WORKER)
#include "RegistrationDatabase.h"
#include "ServiceWorkerContextData.h"
#include "ServiceWorkerRegistrationData.h"
#include "ServiceWorkerRegistrationKey.h"
#include "Timer.h"
#include <wtf/CompletionHandler.h>
#include <wtf/HashMap.h>
#include <wtf/WeakPtr.h>
#include <wtf/text/WTFString.h>
namespace WebCore {
class SWServer;
class SWServerRegistration;
class RegistrationStore : public CanMakeWeakPtr<RegistrationStore> {
WTF_MAKE_FAST_ALLOCATED;
public:
RegistrationStore(SWServer&, String&& databaseDirectory);
~RegistrationStore();
void clearAll(CompletionHandler<void()>&&);
void flushChanges(CompletionHandler<void()>&&);
void closeDatabase(CompletionHandler<void()>&&);
void startSuspension(CompletionHandler<void()>&&);
void endSuspension();
void updateRegistration(const ServiceWorkerContextData&);
void removeRegistration(const ServiceWorkerRegistrationKey&);
void addRegistrationFromDatabase(ServiceWorkerContextData&&);
void databaseFailedToOpen();
void databaseOpenedAndRecordsImported();
SWServer& server() { return m_server; };
private:
void scheduleDatabasePushIfNecessary();
void pushChangesToDatabase(CompletionHandler<void()>&&);
void pushChangesToDatabase() { pushChangesToDatabase({ }); }
SWServer& m_server;
Ref<RegistrationDatabase> m_database;
HashMap<ServiceWorkerRegistrationKey, Optional<ServiceWorkerContextData>> m_updatedRegistrations;
Timer m_databasePushTimer;
bool m_isSuspended { false };
bool m_needsPushingChanges { false };
};
}
#endif // ENABLE(SERVICE_WORKER)