pEp.foundation
/
pEpCOMServerAdapter
9
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Updater infrastructure

Browse Source
COM-121
Volker Birk 7 years ago
parent 39d04c2bfa
commit 9face9c417
3 changed files with 156 additions and 87 deletions
Show Stats Download Patch File Download Diff File

149
GateKeeper.cpp
Unescape View File

@ -4,64 +4,127 @@
using namespace std;
const LPCTSTR GateKeeper::plugin_reg_path = _T("Software\\Microsoft\\Office\\Outlook\\Addins\\pEp");
const LPCTSTR GateKeeper::plugin_reg_value_name = _T("LoadBehavior");
namespace pEp {
const time_t GateKeeper::cycle = 7200; // 7200 sec is 2 h
const DWORD GateKeeper::waiting = 10000; // 10000 ms is 10 sec
const LPCTSTR GateKeeper::plugin_reg_path = _T("Software\\Microsoft\\Office\\Outlook\\Addins\\pEp");
const LPCTSTR GateKeeper::plugin_reg_value_name = _T("LoadBehavior");
const LPCTSTR GateKeeper::updater_reg_path = _T("Software\\pEp\\Updater";)
time_t GateKeeper::time_diff()
{
try {
static random_device rd;
static mt19937 gen(rd());
const time_t GateKeeper::cycle = 7200; // 7200 sec is 2 h
const DWORD GateKeeper::waiting = 10000; // 10000 ms is 10 sec
uniform_int_distribution<time_t> dist(0, cycle);
return dist(gen);
GateKeeper::GateKeeper(CpEpCOMServerAdapterModule * const self)
: _self(self), now(time(NULL)), next(now + time_diff()), hkUpdater(NULL)
{
LONG lResult = RegOpenCurrentUser(KEY_READ, &cu);
assert(lResult == ERROR_SUCCESS);
if (lResult == ERROR_SUCCESS)
cu_open = true;
else
cu_open = false;
if (cu_open) {
LONG lResult = RegOpenKeyEx(cu, updater_reg_path, 0, KEY_READ, &hkUpdater);
assert(lResult == ERROR_SUCCESS);
if (lResult != ERROR_SUCCESS)
return;
}
}
catch (exception&) {
assert(0);
return 0;
GateKeeper::~GateKeeper()
{
if (cu_open) {
if (hkUpdater)
RegCloseKey(hkUpdater);
RegCloseKey(cu);
}
}
time_t GateKeeper::time_diff()
{
try {
static random_device rd;
static mt19937 gen(rd());
uniform_int_distribution<time_t> dist(0, cycle);
return dist(gen);
}
catch (exception&) {
assert(0);
return 0;
}
}
}
void GateKeeper::keep()
{
while (1) {
keep_plugin();
void GateKeeper::keep()
{
if (!cu_open)
return;
while (1) {
keep_plugin();
now = time(NULL);
assert(now != -1);
now = time(NULL);
assert(now != -1);
if (now > next) {
next = now + GateKeeper::cycle;
keep_updated();
}
if (now > next) {
next = now + GateKeeper::cycle;
keep_updated();
Sleep(waiting);
}
}
void GateKeeper::keep_plugin()
{
DWORD value;
DWORD size;
LONG lResult = RegGetValue(cu, plugin_reg_path, plugin_reg_value_name, RRF_RT_REG_DWORD, NULL, &value, &size);
if (lResult != ERROR_SUCCESS)
return;
Sleep(waiting);
if (value != 3) {
lResult = RegSetValue(cu, plugin_reg_path, RRF_RT_REG_DWORD, plugin_reg_value_name, 3);
assert(lResult == ERROR_SUCCESS);
}
}
}
void GateKeeper::keep_plugin()
{
if (!cu_open)
return;
GateKeeper::product_list& GateKeeper::registered_products()
{
static product_list products;
DWORD value;
DWORD size;
// https://msdn.microsoft.com/en-us/library/windows/desktop/ms724872(v=vs.85).aspx
static TCHAR value_name[16384];
DWORD value_name_size;
static TCHAR value[L_MAX_URL_LENGTH + 1];
DWORD value_size;
LONG lResult = RegGetValue(cu, plugin_reg_path, plugin_reg_value_name, RRF_RT_REG_DWORD, NULL, &value, &size);
if (lResult != ERROR_SUCCESS)
return;
products.empty();
LONG lResult = ERROR_SUCCESS;
for (DWORD i = 0; lResult == ERROR_SUCCESS; i++) {
value_size = L_MAX_URL_LENGTH + 1;
lResult = RegEnumValue(hkUpdater, 0, value_name, &value_name_size, NULL, NULL, (LPBYTE) value, &value_size);
if (lResult == ERROR_SUCCESS)
products.push_back({ value_name, value });
}
return products;
}
void GateKeeper::update_product(product p)
{
if (value != 3) {
lResult = RegSetValue(cu, plugin_reg_path, RRF_RT_REG_DWORD, plugin_reg_value_name, 3);
assert(lResult == ERROR_SUCCESS);
}
}
void GateKeeper::keep_updated()
{
void GateKeeper::keep_updated()
{
product_list& products = registered_products();
for (auto i = products.begin(); i != products.end(); i++) {
update_product(*i);
}
}
}
} // namespace pEp

92
GateKeeper.h
Unescape View File

@ -1,45 +1,51 @@
class CpEpCOMServerAdapterModule;
class GateKeeper {
public:
GateKeeper(CpEpCOMServerAdapterModule * const self) : _self(self), now(time(NULL)), next(now + time_diff())
{
LONG lResult = RegOpenCurrentUser(KEY_READ, &cu);
assert(lResult == ERROR_SUCCESS);
if (lResult == ERROR_SUCCESS)
cu_open = true;
else
cu_open = false;
}
~GateKeeper()
{
if (cu_open)
RegCloseKey(cu);
}
CpEpCOMServerAdapterModule * const module() const
{
return _self;
}
void keep();
protected:
static const LPCTSTR plugin_reg_path;
static const LPCTSTR plugin_reg_value_name;
static const time_t cycle;
static const DWORD waiting;
static time_t time_diff();
void keep_plugin();
void keep_updated();
private:
time_t now;
time_t next;
bool cu_open;
HKEY cu;
CpEpCOMServerAdapterModule * const _self;
};
namespace pEp {
#ifdef UNICODE
typedef std::wstring tstring;
#else
typedef std::string tstring;
#endif
class GateKeeper {
public:
typedef std::pair<tstring, tstring> product;
typedef std::vector< product > product_list;
GateKeeper(CpEpCOMServerAdapterModule * const self);
~GateKeeper();
CpEpCOMServerAdapterModule * const module() const
{
return _self;
}
void keep();
protected:
static const LPCTSTR plugin_reg_path;
static const LPCTSTR plugin_reg_value_name;
static const LPCTSTR updater_reg_path;
static const time_t cycle;
static const DWORD waiting;
static time_t time_diff();
void keep_plugin();
void update_product(product p);
product_list& registered_products();
void keep_updated();
private:
time_t now;
time_t next;
bool cu_open;
HKEY cu;
HKEY hkUpdater;
CpEpCOMServerAdapterModule * const _self;
};
}

2
pEpCOMServerAdapter.cpp
Unescape View File

@ -37,7 +37,7 @@ private:
void CpEpCOMServerAdapterModule::gatekeeper(CpEpCOMServerAdapterModule * const self)
{
GateKeeper keeper(self);
pEp::GateKeeper keeper(self);
keeper.keep();
}

Write Preview
Loading…
Cancel
Save