archive
/
windows-xp
mirror of https://github.com/tongzx/nt5src
2
0
Fork 0
Code Issues Projects Releases Wiki Activity
Source code of Windows XP (NT5)
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
6 Commits
1 Branch
0 Tags
4.0 GiB
 
 
 
 
 
 
Branch: master
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from 'master'
${ noResults }
windows-xp/Source/XPSP1/NT/shell/ext/webcheck/trayagnt.cpp

1399 lines
39 KiB
Raw Permalink Blame History

//----------------------------------------------------------------------------
//
// Microsoft Windows
// Copyright (C) Microsoft Corporation, 1997
//
// File: trayagnt.cpp
//
// Contents: tray notification agent
//
// Classes:
//
// Functions:
//
// History: 01-14-1997 rayen (Raymond Endres) Created
//
//----------------------------------------------------------------------------
#include "private.h"
#include "updateui.h"
#include "chanmgr.h"
#include "chanmgrp.h"
#include "shguidp.h"
#include "offline.h"
#include "offl_cpp.h"
//xnotfmgr - can probably nuke most of this file
#undef TF_THISMODULE
#define TF_THISMODULE TF_TRAYAGENT
extern const TCHAR c_szTrayUI[] = TEXT("BogusClassName");
const TCHAR c_szTrayMenu[] = TEXT("TrayMenu");
#if WANT_REGISTRY_LOG
const TCHAR c_szLog[] = TEXT("\\Log");
const TCHAR c_szLogMaxIndex[] = TEXT("MaxIndex");
#endif
typedef struct _tagCHANNELIMAGEDATA
{
CHAR szPath[MAX_PATH];
CHAR szHash[MAX_PATH];
int iIndex;
UINT uFlags;
int iImageIndex;
} CHANNELIMAGEDATA, *PCHANNELIMAGEDATA;
CTrayUI *g_pTrayUI; // TrayUI object (not COM), separate from TrayAgent for now
DWORD WINAPI UpdateRequest(UINT idCmd, INotification *);
HRESULT UpdateNotifyReboot(void);
extern BOOL OnConnectedNotification(void);
extern BOOL OnDisconnectedNotification(void);
extern HRESULT LoadWithCookie(LPCTSTR, OOEBuf *, DWORD *, SUBSCRIPTIONCOOKIE *);
void DoReboot(void);
void IdleBegin(HWND hwnd);
void IdleEnd(void);
// Private message sent by Channel Screen Saver to
// periodically initiate relaunch of the screen saver.
#define WM_LOADSCREENSAVER (WM_USER+550)
extern BOOL ReloadChannelScreenSaver(); // from SSSEPROX.CPP
#ifdef DEBUG
extern INotificationSink * g_pOfflineTraySink;
HRESULT RunTest()
{
//xnotfmgr
INotificationMgr * pMgr = NULL;
INotification * pNotf = NULL;
HRESULT hr;
hr = GetNotificationMgr(&pMgr);
if (FAILED(hr) || !pMgr)
return E_FAIL;
hr = pMgr->CreateNotification(
NOTIFICATIONTYPE_AGENT_START,
0, NULL, &pNotf, 0);
if (SUCCEEDED(hr) && !pNotf)
hr = E_FAIL;
if (SUCCEEDED(hr))
hr = pMgr->DeliverNotification(pNotf, CLSID_WebCrawlerAgent,
DM_DELIVER_DEFAULT_PROCESS |
DM_THROTTLE_MODE |
DM_NEED_COMPLETIONREPORT
,g_pOfflineTraySink,0,0);
SAFERELEASE(pNotf);
SAFERELEASE(pMgr);
return hr;
}
#endif
HRESULT CancelAllDownloads()
{
//xnotfmgr
HRESULT hr = S_OK;
INotificationMgr * pMgr = NULL;
IEnumNotification * pRunEnum = NULL;
IEnumNotification * pThrEnum = NULL;
hr = GetNotificationMgr(&pMgr);
if (FAILED(hr)) {
return hr;
}
hr = pMgr->GetEnumNotification(EF_NOTIFICATION_INPROGRESS, &pRunEnum);
if (SUCCEEDED(hr)) {
hr = pMgr->GetEnumNotification(EF_NOTIFICATION_THROTTLED, &pThrEnum);
}
if (FAILED(hr)) {
SAFERELEASE(pRunEnum);
SAFERELEASE(pThrEnum);
SAFERELEASE(pMgr);
return hr;
}
INotification *pNotCancel = NULL;
hr = pMgr->CreateNotification(NOTIFICATIONTYPE_TASKS_ABORT,
(NOTIFICATIONFLAGS)0,
NULL,
&pNotCancel,
0);
if (FAILED(hr) || !pNotCancel){
SAFERELEASE(pMgr);
SAFERELEASE(pRunEnum);
SAFERELEASE(pThrEnum);
return E_FAIL;
}
NOTIFICATIONITEM item = {0};
ULONG cItems = 0;
item.cbSize = sizeof(NOTIFICATIONITEM);
hr = pThrEnum->Next(1, &item, &cItems);
while ( SUCCEEDED(hr) && cItems )
{
CLSID cookie;
BOOL bAbort = FALSE;
if (item.NotificationType == NOTIFICATIONTYPE_AGENT_START
// REVIEW big hack.
&& item.clsidDest != CLSID_ConnectionAgent)
{
bAbort = TRUE;
cookie = item.NotificationCookie;
}
SAFERELEASE(item.pNotification);
item.cbSize = sizeof(NOTIFICATIONITEM);
cItems = 0;
hr = pThrEnum->Next(1, &item, &cItems);
// REVIEW. If we put the following statement before
// the Next statement, we can delete the package and then break the
// enumerator.
if (bAbort) {
HRESULT hr1 = pMgr->DeliverReport(pNotCancel, &cookie, 0);
ASSERT(SUCCEEDED(hr1));
}
}
cItems = 0;
item.cbSize = sizeof(NOTIFICATIONITEM);
hr = pRunEnum->Next(1, &item, &cItems);
while ( SUCCEEDED(hr) && cItems )
{
CLSID cookie;
BOOL bAbort = FALSE;
if (item.NotificationType == NOTIFICATIONTYPE_AGENT_START
// REVIEW big hack.
&& item.clsidDest != CLSID_ConnectionAgent)
{
bAbort = TRUE;
cookie = item.NotificationCookie;
}
SAFERELEASE(item.pNotification);
item.cbSize = sizeof(NOTIFICATIONITEM);
cItems = 0;
hr = pRunEnum->Next(1, &item, &cItems);
// REVIEW. We don't seem to have the same problem. Just try to be
// cautious.
if (bAbort) {
HRESULT hr1 = pMgr->DeliverReport(pNotCancel, &cookie, 0);
ASSERT(SUCCEEDED(hr1));
}
}
SAFERELEASE(pMgr);
SAFERELEASE(pNotCancel);
SAFERELEASE(pRunEnum);
SAFERELEASE(pThrEnum);
return hr;
}
//
// Get the path of channel containing the given URL.
//
HRESULT GetChannelPath(LPCSTR pszURL, LPTSTR pszPath, int cch,
IChannelMgrPriv** ppIChannelMgrPriv)
{
ASSERT(pszURL);
ASSERT(pszPath || 0 == cch);
ASSERT(ppIChannelMgrPriv);
HRESULT hr;
BOOL bCoinit = FALSE;
hr = CoCreateInstance(CLSID_ChannelMgr, NULL, CLSCTX_INPROC_SERVER,
IID_IChannelMgrPriv, (void**)ppIChannelMgrPriv);
if ((hr == CO_E_NOTINITIALIZED || hr == REGDB_E_IIDNOTREG) &&
SUCCEEDED(CoInitialize(NULL)))
{
bCoinit = TRUE;
hr = CoCreateInstance(CLSID_ChannelMgr, NULL, CLSCTX_INPROC_SERVER,
IID_IChannelMgrPriv, (void**)ppIChannelMgrPriv);
}
if (SUCCEEDED(hr))
{
ASSERT(*ppIChannelMgrPriv);
IChannelMgr* pIChannelMgr;
hr = (*ppIChannelMgrPriv)->QueryInterface(IID_IChannelMgr,
(void**)&pIChannelMgr);
if (SUCCEEDED(hr))
{
ASSERT(pIChannelMgr);
WCHAR wszURL[INTERNET_MAX_URL_LENGTH];
MyStrToOleStrN(wszURL, ARRAYSIZE(wszURL), pszURL);
IEnumChannels* pIEnumChannels;
hr = pIChannelMgr->EnumChannels(CHANENUM_ALLFOLDERS | CHANENUM_PATH,
wszURL, &pIEnumChannels);
if (SUCCEEDED(hr))
{
ASSERT(pIEnumChannels);
CHANNELENUMINFO ci;
if (S_OK == pIEnumChannels->Next(1, &ci, NULL))
{
MyOleStrToStrN(pszPath, cch, ci.pszPath);
CoTaskMemFree(ci.pszPath);
}
else
{
hr = E_FAIL;
}
pIEnumChannels->Release();
}
pIChannelMgr->Release();
}
}
if (bCoinit)
CoUninitialize();
ASSERT((SUCCEEDED(hr) && *ppIChannelMgrPriv) || FAILED(hr));
return hr;
}
//
// Update channel
//
HRESULT UpdateChannel(IChannelMgrPriv* pIChannelMgrPriv, LPCSTR pszURL)
{
ASSERT(pIChannelMgrPriv);
ASSERT(pszURL);
HRESULT hr;
IChannelMgr* pIChannelMgr;
hr = pIChannelMgrPriv->QueryInterface(IID_IChannelMgr,
(void**)&pIChannelMgr);
if (SUCCEEDED(hr))
{
ASSERT(pIChannelMgr);
WCHAR wszURL[INTERNET_MAX_URL_LENGTH];
MyStrToOleStrN(wszURL, ARRAYSIZE(wszURL), pszURL);
IEnumChannels* pIEnumChannels;
hr = pIChannelMgr->EnumChannels(CHANENUM_ALLFOLDERS | CHANENUM_PATH,
wszURL, &pIEnumChannels);
if (SUCCEEDED(hr))
{
ASSERT(pIEnumChannels);
CHANNELENUMINFO ci;
//
// Update all instances of this channel.
//
while (S_OK == pIEnumChannels->Next(1, &ci, NULL))
{
char szPath[MAX_PATH];
MyOleStrToStrN(szPath, ARRAYSIZE(szPath), ci.pszPath);
// Removed to give UPDATEIMAGE (gleams) a better chance.
//SHChangeNotify(SHCNE_UPDATEDIR, SHCNF_PATH, (void*)szPath,
// NULL);
CoTaskMemFree(ci.pszPath);
}
pIEnumChannels->Release();
}
pIChannelMgr->Release();
}
return hr;
}
//
// Gather data that will be used to update a channel image.
//
HRESULT PreUpdateChannelImage(IChannelMgrPriv* pIChannelMgrPriv,
CHANNELIMAGEDATA* pcid)
{
ASSERT(pcid);
ASSERT(pIChannelMgrPriv);
return (pIChannelMgrPriv)->PreUpdateChannelImage(pcid->szPath,
pcid->szHash,
&pcid->iIndex,
&pcid->uFlags,
&pcid->iImageIndex);
}
//
// Update a channel image.
//
HRESULT UpdateChannelImage(IChannelMgrPriv* pIChannelMgrPriv,
CHANNELIMAGEDATA* pcid)
{
ASSERT(pcid);
ASSERT(pIChannelMgrPriv);
WCHAR wszHash[MAX_PATH];
MyStrToOleStrN(wszHash, ARRAYSIZE(wszHash), pcid->szHash);
return pIChannelMgrPriv->UpdateChannelImage(wszHash, pcid->iIndex,
pcid->uFlags,
pcid->iImageIndex);
}
//----------------------------------------------------------------------------
// Tray Agent object
//----------------------------------------------------------------------------
CTrayAgent::CTrayAgent()
{
DBG("Creating CTrayAgent object");
//
// Maintain global count of objects in webcheck.dll
//
DllAddRef();
//
// Initialize object member variables
//
m_cRef = 1;
#ifdef DEBUG
m_AptThreadId = GetCurrentThreadId();
#endif
}
CTrayAgent::~CTrayAgent()
{
//
// Maintain global count of objects
//
DllRelease();
//
// Release/delete any resources
//
DBG("Destroyed CTrayAgent object");
}
//
// IUnknown members
//
STDMETHODIMP_(ULONG) CTrayAgent::AddRef(void)
{
return ++m_cRef;
}
STDMETHODIMP_(ULONG) CTrayAgent::Release(void)
{
if( 0L != --m_cRef )
return m_cRef;
delete this;
return 0L;
}
STDMETHODIMP CTrayAgent::QueryInterface(REFIID riid, void ** ppv)
{
*ppv = NULL;
//xnotfmgr
//
// Currently just support INotificationSink
//
if ((IID_IUnknown == riid) ||
(IID_INotificationSink == riid))
{
*ppv = (INotificationSink *)this;
}
//
// Addref through the interface
//
if( NULL != *ppv )
{
((LPUNKNOWN)*ppv)->AddRef();
return NOERROR;
}
return ResultFromScode(E_NOINTERFACE);
}
//
// INotificationSink member(s)
//
STDMETHODIMP CTrayAgent::OnNotification(
LPNOTIFICATION pNotification,
LPNOTIFICATIONREPORT pNotificationReport,
DWORD dwReserved)
{
//xnotfmgr
DBG("CTrayAgent::OnNotification called");
ASSERT(pNotification);
ASSERT(GetCurrentThreadId() == m_AptThreadId);
//
// Extract Notification Type.
//
HRESULT hr;
NOTIFICATIONTYPE notfType;
hr = pNotification->GetNotificationInfo(&notfType, NULL, NULL, NULL, 0);
ASSERT(SUCCEEDED(hr));
if (notfType == NOTIFICATIONTYPE_CONFIG_CHANGED)
{
DBG("CTrayAgent::OnNotification - config changed");
//
// The global properties have changed and we must respond.
//
ASSERT(g_pTrayUI); // Fault here means NotificationMgr calling me in wrong process
if (g_pTrayUI)
g_pTrayUI->ConfigChanged();
return S_OK;
}
else if (notfType == NOTIFICATIONTYPE_BEGIN_REPORT) {
DBG("CTrayAgent::OnNotification - begin report");
ASSERT(g_pTrayUI);
if (g_pTrayUI)
g_pTrayUI->OnBeginReport(pNotification);
return S_OK;
}
else if (notfType == NOTIFICATIONTYPE_AGENT_START)
{
DBG("CTrayAgent::OnNotification - agent start (update now)");
//
// The user chose Update Subscriptions Now.
// Is this the best notification to use for this?
// Are there any properties we care about? Like a guid to trigger
// a specific one?
//
ASSERT(g_pTrayUI); // Fault here means NotificationMgr calling me in wrong process
if (g_pTrayUI)
g_pTrayUI->UpdateNow(pNotification);
return S_OK;
}
else if (notfType == NOTIFICATIONTYPE_END_REPORT)
{
DBG("CTrayAgent::OnNotification - end report");
ASSERT(g_pTrayUI);
if (g_pTrayUI)
g_pTrayUI->OnEndReport(pNotification);
#if WANT_REGISTRY_LOG
//
// Log all the End Reports
//
BSTR bstrStatus = NULL;
CLSID cookie;
if (g_pTrayUI &&
SUCCEEDED(ReadBSTR(pNotification,NULL, c_szPropStatusString, &bstrStatus))
&& SUCCEEDED(ReadGUID(pNotification, NULL, c_szStartCookie, &cookie)))
{
g_pTrayUI->AddToLog(bstrStatus, CLSID_NULL, cookie);
} else {
DBG_WARN("CTrayAgent::OnNotification/End Report - Not status str");
}
SAFEFREEBSTR(bstrStatus);
#endif
//
// Read the status code from the end report.
//
SCODE scEndStatus;
hr = ReadSCODE(pNotification, NULL, c_szPropStatusCode, &scEndStatus);
if (SUCCEEDED(hr) && SUCCEEDED(scEndStatus))
{
//
// Special feature for desktop HTML:
// If we receive an end report with "DesktopComponent=1" in it,
// let the desktop know that it needs to refresh itself. We always
// do this instead of only on "changes detected" because desktop
// component authors don't want to change their CDFs.
//
DWORD dwRet;
HRESULT hr2 = ReadDWORD(pNotification, NULL, c_szPropDesktopComponent, &dwRet);
if (SUCCEEDED(hr2) && (dwRet == 1))
{
IActiveDesktop *pAD = NULL;
hr2 = CoCreateInstance(CLSID_ActiveDesktop, NULL, CLSCTX_INPROC_SERVER, IID_IActiveDesktop, (void**)&pAD);
DBGASSERT(SUCCEEDED(hr2), "Unable to create ActiveDesktop in order to refresh desktop component");
if (SUCCEEDED(hr2))
{
ASSERT(pAD);
pAD->ApplyChanges(AD_APPLY_FORCE | AD_APPLY_REFRESH | AD_APPLY_BUFFERED_REFRESH);
pAD->Release();
}
}
}
//
// If the delivery agent succeeded and changes were detected
// notify the appropriate code.
//
if (SUCCEEDED(hr) && SUCCEEDED(scEndStatus) && (S_FALSE != scEndStatus))
{
//
// Gleam the Internet Shortcut for the URL if requested. (EnableShortcutGleam=1)
// NOTE: End Reports without changes (S_FALSE) were filtered above.
//
DWORD dwRet;
hr = ReadDWORD(pNotification, NULL, c_szPropEnableShortcutGleam, &dwRet);
if (SUCCEEDED(hr) && dwRet)
{
LPSTR strURL = NULL;
hr = ReadAnsiSTR(pNotification, NULL, c_szPropURL, &strURL);
if (SUCCEEDED(hr))
{
PROPVARIANT propvar;
PropVariantInit(&propvar);
hr = IntSiteHelper(strURL, &c_rgPropRead[PROP_FLAGS], &propvar, 1, FALSE);
if (SUCCEEDED(hr) && (VT_UI4 == propvar.vt))
{
// Set our flag without disturbing the others.
propvar.ulVal |= PIDISF_RECENTLYCHANGED;
}
else
{
// Be sure to clear the variant if it wasn't a DWORD.
PropVariantClear(&propvar);
propvar.vt = VT_UI4;
propvar.ulVal = PIDISF_RECENTLYCHANGED;
}
//
// Update channels.
//
hr = ReadDWORD(pNotification, NULL, c_szPropChannel, &dwRet);
BOOL bChannel = SUCCEEDED(hr) && dwRet;
CHANNELIMAGEDATA cid = {0};
IChannelMgrPriv* pIChannelMgrPriv = NULL;
HRESULT hr2 = E_FAIL;
if (bChannel)
{
hr2 = GetChannelPath(strURL, cid.szPath,
ARRAYSIZE(cid.szPath),
&pIChannelMgrPriv);
if (SUCCEEDED(hr2))
hr2 = PreUpdateChannelImage(pIChannelMgrPriv, &cid);
}
hr = IntSiteHelper(strURL, &c_rgPropRead[PROP_FLAGS], &propvar, 1, TRUE);
DBGASSERT(SUCCEEDED(hr), "CTrayAgent::OnNotification - failed to set gleam.");
if (bChannel && SUCCEEDED(hr2))
{
ASSERT(pIChannelMgrPriv);
pIChannelMgrPriv->InvalidateCdfCache();
UpdateChannelImage(pIChannelMgrPriv, &cid);
UpdateChannel(pIChannelMgrPriv, strURL);
pIChannelMgrPriv->Release();
}
}
MemFree(strURL); // Free the string allocated by ReadAnsiSTR().
}
//
// Send Email to notify the user if requested (EmailNotification=1)
// NOTE: End Reports without changes (S_FALSE) were filtered above.
//
hr = ReadDWORD(pNotification, NULL, c_szPropEmailNotf, &dwRet);
if (SUCCEEDED(hr) && dwRet)
{
hr = SendEmailFromNotification(pNotification);
}
}
else
{
DBG_WARN("CTrayAgent::OnNotification - unchanged or failed end report");
}
return S_OK;
}
else if (notfType == NOTIFICATIONTYPE_DISCONNECT_FROM_INTERNET)
{
OnDisconnectedNotification();
return S_OK;
}
else if (notfType == NOTIFICATIONTYPE_CONNECT_TO_INTERNET )
{
OnConnectedNotification();
return S_OK;
}
else
{
//
// TrayAgent doesn't handle this notification
//
DBG("CTrayAgent::OnNotification - unknown notification");
return S_OK;
}
}
//----------------------------------------------------------------------------
// TrayUI object (not COM)
//----------------------------------------------------------------------------
LRESULT CALLBACK TrayUI_WndProc(HWND hwnd, UINT uMsg, WPARAM wParam, LPARAM lParam)
{
//xnotfmgr
//
// We need this annoying global to make single and double left click work nicely.
// (USER should have a WM_LBUTTONSINGLECLK message.)
//
static int iLeftClick = 0;
static POINT pt;
switch (uMsg)
{
case WM_USER: // Subscription icon was clicked
ASSERT(g_pTrayUI);
switch (lParam)
{
#ifdef DEBUG
case WM_RBUTTONUP:
if (iLeftClick) {
ASSERT(1 == iLeftClick);
KillTimer(hwnd, TIMER_ID_DBL_CLICK);
iLeftClick = 0;
}
GetCursorPos(&pt);
g_pTrayUI->OpenContextMenu(&pt);
break;
case WM_LBUTTONUP:
if (0 == iLeftClick) // first left click up
{
UINT uRet;
GetCursorPos(&pt);
uRet = SetTimer(hwnd, TIMER_ID_DBL_CLICK, GetDoubleClickTime(), NULL);
ASSERT(uRet);
iLeftClick = 1;
}
else // second left click up
{
ASSERT(1 == iLeftClick);
KillTimer(hwnd, TIMER_ID_DBL_CLICK);
iLeftClick = 0;
g_pTrayUI->OpenSubscriptionFolder();
}
break;
#endif
case UM_NEEDREBOOT:
// forward reboot required flag to update agent
if (FAILED(UpdateNotifyReboot()))
DoReboot();
break;
}
return 0;
case WM_TIMER:
switch(wParam) {
case TIMER_ID_DBL_CLICK:
// Timer went off so it was a single click
KillTimer(hwnd, TIMER_ID_DBL_CLICK);
if (1 == iLeftClick) {
iLeftClick = 0;
g_pTrayUI->OpenContextMenu(&pt);
}
break;
} /* switch */
break;
// Process the Infodelivery Admin Policies on WM_WININICHANGE lParam="Policy"
case WM_WININICHANGE:
if (lParam && !lstrcmpi((LPCTSTR)lParam, TEXT("policy")))
{
ProcessInfodeliveryPolicies();
}
// FEATURE: This should be done on Policy and another filter, not for
// all changes. (The other filter hasn't been defined yet.)
// TODO: handle this in the new architecture!
//SetNotificationMgrRestrictions(NULL);
break;
case WM_LOADSCREENSAVER:
{
EVAL(ReloadChannelScreenSaver());
break;
}
default:
break;
}
return DefWindowProc(hwnd, uMsg, wParam, lParam);
}
CTrayUI::CTrayUI(void)
{
// There should only be one of these objects
ASSERT(!g_pTrayUI);
// Assert that we're zero initialized.
ASSERT(!m_hwnd);
#if WANT_REGISTRY_LOG
ASSERT(!m_cLogs);
#endif
ASSERT(!m_cUpdates);
ASSERT(!m_fUpdatingTrayIcon);
#ifdef DEBUG
m_AptThreadId = GetCurrentThreadId();
#endif
}
CTrayUI::~CTrayUI(void)
{
//
// Clean up any BSTRs we have around
//
// ZDC Detect ongoing updates?
ASSERT(m_cUpdates >= 0);
#if WANT_REGISTRY_LOG
ASSERT(m_cLogs >= 0);
ASSERT(m_cLogs < TRAYUI_CLOGS);
for (int i = 0; i < m_cLogs; i++)
{
SAFEFREEBSTR(m_aLogEntry[i].bstrStatus);
}
#endif
}
#if WANT_REGISTRY_LOG
#define TRAYLOGVERSION 716
STDMETHODIMP WriteSingleEntry(PLogEntry pLog, LPCTSTR szSubKey, int index)
{
ASSERT(pLog && szSubKey);
ASSERT(index >= 0);
ASSERT(index < TRAYUI_CLOGS);
// Check to see if it's a valid log entry.
if (!(pLog->bstrStatus)) {
ASSERT(0);
return E_INVALIDARG;
}
TCHAR szLogName[16];
wsprintf(szLogName, TEXT("%d"), index);
CRegStream * prLog = new CRegStream(HKEY_CURRENT_USER, szSubKey, szLogName);
if (prLog) {
CLSID clsidAgent = pLog->clsidAgent;
CLSID cookie = pLog->startCookie;
FILETIME ftLog = pLog->ftLog;
int versionNumber = TRAYLOGVERSION;
BSTR bstrStatus = pLog->bstrStatus;
DWORD cbWritten;
int len;
prLog->Write(&versionNumber, sizeof(int), &cbWritten);
ASSERT(sizeof(int) == cbWritten);
prLog->Write(&clsidAgent, sizeof(CLSID), &cbWritten);
ASSERT(sizeof(CLSID) == cbWritten);
prLog->Write(&cookie, sizeof(CLSID), &cbWritten);
ASSERT(sizeof(CLSID) == cbWritten);
prLog->Write(&ftLog, sizeof(FILETIME), &cbWritten);
ASSERT(sizeof(FILETIME) == cbWritten);
len = lstrlenW(bstrStatus);
prLog->Write(&len, sizeof(int), &cbWritten);
ASSERT(sizeof(int) == cbWritten);
len *= sizeof(WCHAR);
prLog->Write(bstrStatus, len, &cbWritten);
ASSERT(len == (int)cbWritten);
delete prLog;
return S_OK;
} else {
return E_FAIL;
}
}
STDMETHODIMP ReadSingleEntry(PLogEntry pLog, LPCTSTR szSubKey, int index)
{
ASSERT(pLog && szSubKey);
ASSERT(index >= 0);
ASSERT(index < TRAYUI_CLOGS);
// Check to see if it's a valid log entry.
if (pLog->bstrStatus) {
ASSERT(0);
SAFEFREEBSTR(pLog->bstrStatus);
}
TCHAR szLogName[16];
HRESULT hrLog = E_INVALIDARG;
wsprintf(szLogName, TEXT("%d"), index);
CRegStream * prLog = new CRegStream(HKEY_CURRENT_USER, szSubKey, szLogName);
if (prLog && (FALSE == prLog->m_fNewStream)) {
CLSID clsidAgent;
CLSID cookie;
FILETIME ftLog;
int versionNumber;
BSTR bstrStatus = NULL;
DWORD cbWritten;
int len;
if (SUCCEEDED(prLog->Read(&versionNumber, sizeof(int), &cbWritten))
&& (sizeof(int) == cbWritten)
&& (TRAYLOGVERSION == versionNumber))
{
hrLog = ERROR_SUCCESS;
}
if (ERROR_SUCCESS == hrLog) {
hrLog = E_INVALIDARG;
if (SUCCEEDED(prLog->Read(&clsidAgent, sizeof(CLSID), &cbWritten))
&& (sizeof(CLSID) == cbWritten))
{
hrLog = ERROR_SUCCESS;
}
}
if (ERROR_SUCCESS == hrLog) {
hrLog = E_INVALIDARG;
if (SUCCEEDED(prLog->Read(&cookie, sizeof(CLSID), &cbWritten))
&& (sizeof(CLSID) == cbWritten))
{
hrLog = ERROR_SUCCESS;
}
}
if (ERROR_SUCCESS == hrLog) {
hrLog = E_INVALIDARG;
if (SUCCEEDED(prLog->Read(&ftLog, sizeof(FILETIME), &cbWritten))
&& (sizeof(FILETIME) == cbWritten))
{
hrLog = ERROR_SUCCESS;
}
}
if (ERROR_SUCCESS == hrLog) {
hrLog = E_INVALIDARG;
if (SUCCEEDED(prLog->Read(&len, sizeof(int), &cbWritten))
&& (sizeof(int) == cbWritten)
&& (len < INTERNET_MAX_URL_LENGTH)
&& (bstrStatus = SysAllocStringLen(NULL, len))
&& SUCCEEDED(prLog->Read(bstrStatus, len * sizeof(WCHAR), &cbWritten))
&& (len * sizeof(WCHAR) == (int)cbWritten))
{
hrLog = ERROR_SUCCESS;
bstrStatus[len] = 0;
}
}
if (ERROR_SUCCESS == hrLog) {
pLog->clsidAgent = clsidAgent;
pLog->startCookie = cookie;
pLog->ftLog = ftLog;
pLog->bstrStatus = bstrStatus;
#ifdef DEBUG
WCHAR wszCookie[GUIDSTR_MAX];
TCHAR tmpTSTR[INTERNET_MAX_URL_LENGTH];
StringFromGUID2(cookie, wszCookie, ARRAYSIZE(wszCookie));
MyOleStrToStrN(tmpTSTR, ARRAYSIZE(wszCookie), wszCookie);
TraceMsg(TF_THISMODULE, TEXT("TrayUI:LoadLog - %s(cookie)"), tmpTSTR);
MyOleStrToStrN(tmpTSTR, ARRAYSIZE(tmpTSTR), bstrStatus);
TraceMsg(TF_THISMODULE, TEXT("TrayUI:LoadLog - %s(status)"), tmpTSTR);
SYSTEMTIME stLog;
FileTimeToSystemTime(&ftLog, &stLog);
GetTimeFormat(LOCALE_SYSTEM_DEFAULT, LOCALE_NOUSEROVERRIDE,
&stLog, NULL, tmpTSTR, ARRAYSIZE(tmpTSTR));
TraceMsg(TF_THISMODULE, TEXT("TrayUI:LoadLog - %s(time)"), tmpTSTR);
#endif
} else {
SAFEFREEBSTR(bstrStatus);
}
}
if (prLog)
delete prLog;
return hrLog;
}
STDMETHODIMP CTrayUI::SyncLogWithReg(int index, BOOL fWriteMax)
{
if ((index < 0) || (index >= m_cLogs))
return S_FALSE;
TCHAR szSubKey[1024];
ASSERT((lstrlen(c_szRegKey) + lstrlen(c_szLog) + 2) < 1024);
#error Potential Buffer overflow:
lstrcpy(szSubKey, c_szRegKey);
lstrcat(szSubKey, c_szLog);
HRESULT hr = E_FAIL;
hr = WriteSingleEntry(&(m_aLogEntry[index]), szSubKey, index);
if ((ERROR_SUCCESS == hr) && fWriteMax) {
CRegStream * prs =
new CRegStream(HKEY_CURRENT_USER, szSubKey, c_szLogMaxIndex);
DWORD cbWritten;
if (prs) {
prs->Write(&m_cLogs, sizeof(int), &cbWritten);
ASSERT(sizeof(int) == cbWritten);
delete prs;
} else {
hr = E_FAIL;
}
}
return hr;
}
STDMETHODIMP CTrayUI::SaveLogToReg(void)
{
HRESULT hr = S_OK;
TCHAR szSubKey[1024];
ASSERT((lstrlen(c_szRegKey) + lstrlen(c_szLog) + 2) < 1024);
#error Potential Buffer overflow:
lstrcpy(szSubKey, c_szRegKey);
lstrcat(szSubKey, c_szLog);
int index = 0;
int cIndex = 0;
ULONG cbWritten;
int maxIndex = m_cLogs;
for (; index < maxIndex; index ++) {
if (SUCCEEDED(
WriteSingleEntry(&(m_aLogEntry[index]), szSubKey, cIndex)
)
)
{
cIndex ++;
}
}
CRegStream * prs =
new CRegStream(HKEY_CURRENT_USER, szSubKey, c_szLogMaxIndex);
if (prs) {
prs->Write(&cIndex, sizeof(int), &cbWritten);
ASSERT(sizeof(int) == cbWritten);
delete prs;
}
return hr;
}
STDMETHODIMP CTrayUI::LoadLogFromReg(void)
{
HRESULT hr = S_OK;
TCHAR szSubKey[1024];
ASSERT((lstrlen(c_szRegKey) + lstrlen(c_szLog) + 2) < 1024);
#error Potential Buffer overflow:
lstrcpy(szSubKey, c_szRegKey);
lstrcat(szSubKey, c_szLog);
m_cLogs = 0;
int index = 0;
ULONG cbWritten;
int len = 0;
int maxIndex = 0;
CRegStream * prs = new CRegStream(HKEY_CURRENT_USER, szSubKey, c_szLogMaxIndex);
if (!prs) {
hr = E_FAIL;
} else if (TRUE == prs->m_fNewStream) {
hr = E_FAIL;
} else {
if (SUCCEEDED(prs->Read(&maxIndex, sizeof(int), &cbWritten))
&& (sizeof(int) == cbWritten) && (maxIndex >= 0))
{
FILETIME ftFirst;
SYSTEMTIME stNow;
if (TRAYUI_CLOGS < maxIndex) {
maxIndex = TRAYUI_CLOGS;
}
m_cLogPtr = -1;
GetSystemTime(&stNow);
SystemTimeToFileTime(&stNow, &ftFirst);
for (; index < maxIndex; index ++)
{
PLogEntry pLog = &(m_aLogEntry[m_cLogs]);
if (SUCCEEDED(ReadSingleEntry(pLog, szSubKey, index))) {
if (-1 == CompareFileTime(&(pLog->ftLog), &ftFirst)) {
ftFirst= pLog->ftLog;
m_cLogPtr = m_cLogs;
}
m_cLogs ++;
}
}
// m_cLogPtr points to the oldest log. If we haven't used up
// all log space m_cLogPtr should point to 0. We then adjust
// it to the next available log slot.
if (m_cLogs < TRAYUI_CLOGS) {
ASSERT(m_cLogPtr == 0);
m_cLogPtr = m_cLogs;
}
}
}
if (prs)
delete prs;
return hr;
}
STDMETHODIMP CTrayUI::AddToLog(BSTR bstrStatus, CLSID clsidAgent, CLSID startCookie)
{
ASSERT(bstrStatus);
BSTR bstrTmp = NULL;
bstrTmp = SysAllocString(bstrStatus);
if (bstrTmp == NULL)
return E_OUTOFMEMORY;
PLogEntry pLog = &(m_aLogEntry[m_cLogPtr]);
pLog->bstrStatus = bstrTmp;
pLog->clsidAgent = clsidAgent;
pLog->startCookie = startCookie;
SYSTEMTIME stNow;
GetSystemTime(&stNow);
SystemTimeToFileTime(&stNow, &(pLog->ftLog));
if (m_cLogPtr == m_cLogs) {
m_cLogs ++;
SyncLogWithReg(m_cLogPtr, TRUE);
} else {
SyncLogWithReg(m_cLogPtr, FALSE);
}
m_cLogPtr ++;
m_cLogPtr %= TRAYUI_CLOGS;
return S_OK;
}
#endif // WANT_REGISTRY_LOG
STDMETHODIMP CTrayUI::InitTrayUI(void)
{
// shouldn't already be initialized
ASSERT(NULL == m_hwnd);
// create a hidden window
WNDCLASS wndclass;
wndclass.style = 0;
wndclass.lpfnWndProc = TrayUI_WndProc;
wndclass.cbClsExtra = 0;
wndclass.cbWndExtra = 0;
wndclass.hInstance = g_hInst;
wndclass.hIcon = NULL;
wndclass.hCursor = NULL;
wndclass.hbrBackground = NULL;
wndclass.lpszMenuName = NULL;
wndclass.lpszClassName = c_szTrayUI;
RegisterClass (&wndclass) ;
m_hwnd = CreateWindow(c_szTrayUI,
c_szTrayUI,
WS_OVERLAPPEDWINDOW,
CW_USEDEFAULT,
CW_USEDEFAULT,
CW_USEDEFAULT,
CW_USEDEFAULT,
NULL,
NULL,
g_hInst,
NULL);
DBGASSERT(m_hwnd, "failed to create TrayUI window");
if (NULL == m_hwnd)
return ERROR_NOT_ENOUGH_MEMORY;
ShowWindow(m_hwnd, SW_HIDE);
//
// Add an icon to tray after seeing if it's enabled in the registry.
//
ASSERT(FALSE == m_fUpdatingTrayIcon);
// turn on idle monitoring
IdleBegin(m_hwnd);
return S_OK;
}
STDMETHODIMP CTrayUI::DestroyTrayUI(void)
{
// stop idle monitoring
IdleEnd();
if (m_hwnd)
{
BOOL bRet;
bRet = DestroyWindow(m_hwnd);
ASSERT(bRet);
m_hwnd = NULL;
}
return S_OK;
}
STDMETHODIMP CTrayUI::OpenSubscriptionFolder(void)
{
#ifdef DEBUG
// WARNING: This is copied from shdocvw and it might change post beta 1.
TCHAR szSubPath[MAX_PATH];
DWORD dwSize = SIZEOF(szSubPath);
if (ReadRegValue(HKEY_LOCAL_MACHINE, REGSTR_PATH_SUBSCRIPTION,
REGSTR_VAL_DIRECTORY, (LPBYTE)szSubPath, dwSize) == FALSE)
{
TCHAR szWindows[MAX_PATH];
GetWindowsDirectory(szWindows, ARRAYSIZE(szWindows));
PathCombine(szSubPath, szWindows, TEXT("Subscriptions"));
}
SHELLEXECUTEINFO shei;
ZeroMemory(&shei, sizeof(shei));
shei.cbSize = sizeof(shei);
shei.lpFile = szSubPath;
shei.nShow = SW_SHOWNORMAL;
ShellExecuteEx(&shei);
#endif
return S_OK;
}
STDMETHODIMP CTrayUI::OpenContextMenu(POINT * pPoint)
{
#ifdef DEBUG
int iCmd;
HMENU hMenu;
TCHAR menuString[MAX_PATH];
ASSERT(pPoint);
// SetForegroundWindow(hwnd);
hMenu = CreatePopupMenu();
if (!hMenu)
return E_FAIL;
// MLLoadString(IDS_SHOWPROG, menuString, MAX_PATH);
// AppendMenu(hMenu, MF_STRING, IDS_SHOWPROG, menuString);
MLLoadString(IDS_CANCELDL, menuString, MAX_PATH);
AppendMenu(hMenu, MF_STRING, IDS_CANCELDL, menuString);
MLLoadString(IDS_VIEW_SUBS, menuString, MAX_PATH);
AppendMenu(hMenu, MF_STRING, IDS_VIEW_SUBS, menuString);
SetMenuDefaultItem(hMenu, IDS_CANCELDL, FALSE);
if (hMenu)
{
//
// Set the owner window to be foreground as a hack so the
// popup menu disappears when the user clicks elsewhere.
//
BOOL bRet;
ASSERT(m_hwnd);
bRet = SetForegroundWindow(m_hwnd);
ASSERT(bRet);
iCmd = TrackPopupMenu(hMenu, TPM_RETURNCMD | TPM_NONOTIFY | TPM_RIGHTBUTTON,
pPoint->x, pPoint->y, 0, m_hwnd, NULL);
DestroyMenu(hMenu);
MSG msgTmp;
while (PeekMessage(&msgTmp, m_hwnd, WM_LBUTTONDOWN, WM_LBUTTONUP, PM_REMOVE)) {
DispatchMessage(&msgTmp);
}
}
switch (iCmd)
{
case IDS_SHOWPROG:
RunTest();
break;
case IDS_CANCELDL:
CancelAllDownloads();
break;
case IDS_VIEW_SUBS:
OpenSubscriptionFolder();
break;
default:
break;
}
#endif
return S_OK;
}
STDMETHODIMP CTrayUI::UpdateNow(INotification * pNotification)
{
//
// Update Subscriptions Now
// We really don't want to do this on the caller's thread. We should
// always get here through a notification on the appartment thread.
// (No direct calls from other threads are allowed to avoid race
// conditions at startup.)
ASSERT(GetCurrentThreadId() == m_AptThreadId);
// Essentially we do a PostThreadMessage here to the updating thread.
return UpdateRequest(UM_ONREQUEST, pNotification);
}
STDMETHODIMP CTrayUI::SetTrayIcon(DWORD fUpdating)
{
#ifdef DEBUG
if (fUpdating == m_fUpdatingTrayIcon) {
return S_OK;
}
if (fUpdating)
{
BOOL bRet;
NOTIFYICONDATA NotifyIconData;
NotifyIconData.cbSize = sizeof(NOTIFYICONDATA);
NotifyIconData.hWnd = m_hwnd;
NotifyIconData.uID = 0;
NotifyIconData.uFlags = NIF_MESSAGE | NIF_ICON | NIF_TIP;
NotifyIconData.uCallbackMessage = WM_USER;
NotifyIconData.hIcon = LoadIcon(g_hInst, MAKEINTRESOURCE(IDI_TRAYICON));
ASSERT(NotifyIconData.hIcon);
bRet = MLLoadString(IDS_TRAY_TOOLTIP, NotifyIconData.szTip, ARRAYSIZE(NotifyIconData.szTip));
ASSERT(bRet);
bRet = Shell_NotifyIcon(NIM_ADD, &NotifyIconData);
ASSERT(bRet);
}
else
{
// Remove the tray icon
BOOL bRet;
NOTIFYICONDATA NotifyIconData;
NotifyIconData.cbSize = sizeof(NOTIFYICONDATA);
NotifyIconData.hWnd = m_hwnd;
NotifyIconData.uID = 0;
NotifyIconData.uFlags = 0;
bRet = Shell_NotifyIcon(NIM_DELETE, &NotifyIconData);
ASSERT(bRet);
}
m_fUpdatingTrayIcon = fUpdating;
#endif
return S_OK;
}
STDMETHODIMP CTrayUI::ConfigChanged(void)
{
return S_OK;
}
STDMETHODIMP CTrayUI::OnEndReport(INotification * pNot)
{
//xnotfmgr
ASSERT(pNot);
CLSID cookie;
if (SUCCEEDED(ReadGUID(pNot, NULL, c_szStartCookie, &cookie)))
{
DBGIID("TrayAgent::OnEndReport - ", cookie);
UpdateRequest(UM_ENDREPORT, pNot);
LONG lTmp = InterlockedDecrement(&m_cUpdates);
if (!lTmp)
SetTrayIcon(FALSE);
OOEBuf ooeBuf;
LPMYPIDL newPidl = NULL;
DWORD dwSize = 0;
ZeroMemory((void *)&ooeBuf, sizeof(OOEBuf));
HRESULT hr = LoadWithCookie(NULL, &ooeBuf, &dwSize, &cookie);
if (SUCCEEDED(hr))
{
newPidl = COfflineFolderEnum::NewPidl(dwSize);
if (newPidl) {
CopyToMyPooe(&ooeBuf, &(newPidl->ooe));
_GenerateEvent(SHCNE_UPDATEITEM, (LPITEMIDLIST)newPidl, NULL);
COfflineFolderEnum::FreePidl(newPidl);
}
}
}
return S_OK;
}
STDMETHODIMP CTrayUI::OnBeginReport(INotification * pNot)
{
//xnotfmgr
ASSERT(pNot);
CLSID cookie;
if (SUCCEEDED(ReadGUID(pNot, NULL, c_szStartCookie, &cookie)))
{
DBGIID("TrayAgent::OnBeginReport - ", cookie);
UpdateRequest(UM_BEGINREPORT, pNot);
InterlockedIncrement(&m_cUpdates);
SetTrayIcon(TRUE);
}
return S_OK;
}