archive
/
windows-server-2003
mirror of https://github.com/selfrender/Windows-Server-2003
2
0
Fork 0
Code Issues Projects Releases Wiki Activity
Leaked source code of windows server 2003
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.
4 Commits
1 Branch
0 Tags
1.5 GiB
 
 
 
 
 
 
Branch: master
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from 'master'
${ noResults }
windows-server-2003/printscan/faxsrv/service/server/archive.c

3623 lines
123 KiB
Raw Permalink Blame History

#include "faxsvc.h"
#include "faxreg.h"
#include "archive.h"
static PROPSPEC const pspecFaxMessage[] =
{
{PRSPEC_PROPID, PID_FAX_CSID},
{PRSPEC_PROPID, PID_FAX_TSID},
{PRSPEC_PROPID, PID_FAX_PORT},
{PRSPEC_PROPID, PID_FAX_ROUTING},
{PRSPEC_PROPID, PID_FAX_CALLERID},
{PRSPEC_PROPID, PID_FAX_DOCUMENT},
{PRSPEC_PROPID, PID_FAX_SUBJECT},
{PRSPEC_PROPID, PID_FAX_RETRIES},
{PRSPEC_PROPID, PID_FAX_PRIORITY},
{PRSPEC_PROPID, PID_FAX_PAGES},
{PRSPEC_PROPID, PID_FAX_TYPE},
{PRSPEC_PROPID, PID_FAX_START_TIME},
{PRSPEC_PROPID, PID_FAX_END_TIME},
{PRSPEC_PROPID, PID_FAX_SUBMISSION_TIME},
{PRSPEC_PROPID, PID_FAX_ORIGINAL_SCHED_TIME},
{PRSPEC_PROPID, PID_FAX_SENDER_USER_NAME},
{PRSPEC_PROPID, PID_FAX_RECIP_NAME},
{PRSPEC_PROPID, PID_FAX_RECIP_NUMBER},
{PRSPEC_PROPID, PID_FAX_SENDER_NAME},
{PRSPEC_PROPID, PID_FAX_SENDER_NUMBER},
{PRSPEC_PROPID, PID_FAX_SENDER_BILLING},
{PRSPEC_PROPID, PID_FAX_STATUS},
{PRSPEC_PROPID, PID_FAX_STATUS_EX},
{PRSPEC_PROPID, PID_FAX_STATUS_STR_EX},
{PRSPEC_PROPID, PID_FAX_BROADCAST_ID}
};
#define FAX_MESSAGE_PROPERTIES (sizeof(pspecFaxMessage)/sizeof(pspecFaxMessage[0]))
static PROPSPEC const pspecFaxRecipient[] =
{
{PRSPEC_PROPID, PID_FAX_RECIP_NAME},
{PRSPEC_PROPID, PID_FAX_RECIP_NUMBER},
{PRSPEC_PROPID, PID_FAX_RECIP_COMPANY},
{PRSPEC_PROPID, PID_FAX_RECIP_STREET},
{PRSPEC_PROPID, PID_FAX_RECIP_CITY},
{PRSPEC_PROPID, PID_FAX_RECIP_STATE},
{PRSPEC_PROPID, PID_FAX_RECIP_ZIP},
{PRSPEC_PROPID, PID_FAX_RECIP_COUNTRY},
{PRSPEC_PROPID, PID_FAX_RECIP_TITLE},
{PRSPEC_PROPID, PID_FAX_RECIP_DEPARTMENT},
{PRSPEC_PROPID, PID_FAX_RECIP_OFFICE_LOCATION},
{PRSPEC_PROPID, PID_FAX_RECIP_HOME_PHONE},
{PRSPEC_PROPID, PID_FAX_RECIP_OFFICE_PHONE},
{PRSPEC_PROPID, PID_FAX_RECIP_EMAIL}
};
#define FAX_RECIP_PROPERTIES (sizeof(pspecFaxRecipient)/sizeof(pspecFaxRecipient[0]))
static PROPSPEC const pspecFaxSender[] =
{
{PRSPEC_PROPID, PID_FAX_SENDER_BILLING},
{PRSPEC_PROPID, PID_FAX_SENDER_NAME},
{PRSPEC_PROPID, PID_FAX_SENDER_NUMBER},
{PRSPEC_PROPID, PID_FAX_SENDER_COMPANY},
{PRSPEC_PROPID, PID_FAX_SENDER_STREET},
{PRSPEC_PROPID, PID_FAX_SENDER_CITY},
{PRSPEC_PROPID, PID_FAX_SENDER_STATE},
{PRSPEC_PROPID, PID_FAX_SENDER_ZIP},
{PRSPEC_PROPID, PID_FAX_SENDER_COUNTRY},
{PRSPEC_PROPID, PID_FAX_SENDER_TITLE},
{PRSPEC_PROPID, PID_FAX_SENDER_DEPARTMENT},
{PRSPEC_PROPID, PID_FAX_SENDER_OFFICE_LOCATION},
{PRSPEC_PROPID, PID_FAX_SENDER_HOME_PHONE},
{PRSPEC_PROPID, PID_FAX_SENDER_OFFICE_PHONE},
{PRSPEC_PROPID, PID_FAX_SENDER_EMAIL},
{PRSPEC_PROPID, PID_FAX_SENDER_TSID}
};
#define FAX_SENDER_PROPERTIES (sizeof(pspecFaxSender)/sizeof(pspecFaxSender[0]))
#define MAX_FAX_PROPERTIES FAX_MESSAGE_PROPERTIES + FAX_RECIP_PROPERTIES + FAX_SENDER_PROPERTIES
#define QUOTA_WARNING_TIME_OUT (1000*60*60*24) // 1 day,
// The quota warning thread checks the archive size each QUOTA_WARNING_TIME_OUT
#define QUOTA_REFRESH_COUNT 10 // Every QUOTA_REFRESH_COUNT the quota warning thread
// recalculate the archive folder size using FindFirst, FindNext
#define QUOTA_AUTO_DELETE_TIME_OUT (1000*60*60*24) // 1 day,
// The quota auto delete thread deletes the archive old files each QUOTA_AUTO_DELETE_TIME_OUT
FAX_QUOTA_WARN g_FaxQuotaWarn[2];
HANDLE g_hArchiveQuotaWarningEvent;
//*********************************************************************************
//* Name: GetMessageMsTags()
//* Author: Oded Sacher
//* Date: Nov 8, 1999
//*********************************************************************************
//* DESCRIPTION:
//* Fills FAX_MESSAGE structure.
//* The caller must free all strings.
//*
//* PARAMETERS:
//* [IN ] LPCTSTR lpctstrFileName
//* pointer to the file name.
//*
//* [OUT] PFAX_MESSAGE pMessage
//* The FAX_MESSAGE structure to be filled.
//*
//*
//* RETURN VALUE:
//* TRUE
//* If no error occured.
//* FALSE
//* If an error occured.
//*********************************************************************************
BOOL GetMessageMsTags(
LPCTSTR lpctstrFileName,
PFAX_MESSAGE pMessage
)
{
WORD NumDirEntries;
HANDLE hFile = INVALID_HANDLE_VALUE;
HANDLE hMap = NULL;
LPBYTE fPtr = NULL;
BOOL RetVal = FALSE;
DEBUG_FUNCTION_NAME(TEXT("GetMessageMsTags"));
PTIFF_TAG pTiffTags;
DWORD i;
DWORD PrevTagId;
FAX_MESSAGE FaxMessage = {0};
FILETIME FaxTime;
DWORD ec = ERROR_SUCCESS;
BOOL fUnMapTiff = FALSE;
DWORD dwIfdOffset;
Assert (pMessage != NULL);
if (!MemoryMapTiffFile (lpctstrFileName, &FaxMessage.dwSize, &fPtr, &hFile, &hMap, &dwIfdOffset))
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR,
TEXT("MemoryMapTiffFile Failed, error: %ld"),
ec);
goto error_exit;
}
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_SIZE;
//
// get the count of tags in this IFD
//
NumDirEntries = *(LPWORD)(fPtr + dwIfdOffset);
pTiffTags = (PTIFF_TAG)(fPtr + dwIfdOffset +sizeof(WORD));
//
// walk the tags and pick out the info we need
//
for (i = 0, PrevTagId = 0; i < NumDirEntries; i++) {
//
// verify that the tags are in ascending order
//
if (pTiffTags[i].TagId < PrevTagId) {
DebugPrintEx( DEBUG_ERR, TEXT("File %s, Invalid TIFF format"), lpctstrFileName);
ec = ERROR_BAD_FORMAT;
goto error_exit;
}
PrevTagId = pTiffTags[i].TagId;
switch( pTiffTags[i].TagId ) {
case TIFFTAG_TYPE:
FaxMessage.dwJobType = pTiffTags[i].DataOffset;
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_TYPE;
break;
case TIFFTAG_PAGES:
FaxMessage.dwPageCount = pTiffTags[i].DataOffset;
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_PAGE_COUNT;
break;
case TIFFTAG_PRIORITY:
FaxMessage.Priority = (FAX_ENUM_PRIORITY_TYPE)pTiffTags[i].DataOffset;
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_PRIORITY;
break;
case TIFFTAG_STATUS:
FaxMessage.dwQueueStatus = pTiffTags[i].DataOffset;
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_QUEUE_STATUS;
break;
case TIFFTAG_EXTENDED_STATUS:
FaxMessage.dwExtendedStatus = pTiffTags[i].DataOffset;
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_STATUS_EX;
break;
case TIFFTAG_EXTENDED_STATUS_TEXT:
FaxMessage.lpctstrExtendedStatus = GetMsTagString( fPtr, FaxMessage.dwSize, &pTiffTags[i]);
if (FaxMessage.lpctstrExtendedStatus == NULL)
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_BROADCAST_ID:
if (!GetMsTagDwordLong(fPtr, FaxMessage.dwSize, &pTiffTags[i], &FaxMessage.dwlBroadcastId))
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagDwordLong failed"));
goto error_exit;
}
if(FaxMessage.dwlBroadcastId != 0)
{
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_BROADCAST_ID;
}
break;
case TIFFTAG_RECIP_NUMBER:
FaxMessage.lpctstrRecipientNumber = GetMsTagString( fPtr, FaxMessage.dwSize, &pTiffTags[i]);
if (FaxMessage.lpctstrRecipientNumber == NULL)
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_RECIP_NAME:
FaxMessage.lpctstrRecipientName = GetMsTagString( fPtr, FaxMessage.dwSize, &pTiffTags[i]);
if (FaxMessage.lpctstrRecipientName == NULL)
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_TSID:
FaxMessage.lpctstrTsid = GetMsTagString( fPtr, FaxMessage.dwSize, &pTiffTags[i]);
if (FaxMessage.lpctstrTsid == NULL)
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_CSID:
FaxMessage.lpctstrCsid = GetMsTagString( fPtr, FaxMessage.dwSize, &pTiffTags[i]);
if (FaxMessage.lpctstrCsid == NULL)
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SENDER_USER_NAME:
FaxMessage.lpctstrSenderUserName = GetMsTagString( fPtr, FaxMessage.dwSize, &pTiffTags[i]);
if (FaxMessage.lpctstrSenderUserName == NULL)
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SENDER_BILLING:
FaxMessage.lpctstrBillingCode = GetMsTagString( fPtr, FaxMessage.dwSize, &pTiffTags[i]);
if (FaxMessage.lpctstrBillingCode == NULL)
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_FAX_START_TIME:
if (!GetMsTagFileTime(fPtr, FaxMessage.dwSize, &pTiffTags[i], &FaxTime))
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagFileTime failed"));
goto error_exit;
}
if((DWORDLONG)0 != *(DWORDLONG*)&FaxTime)
{
if (!FileTimeToSystemTime(&FaxTime, &FaxMessage.tmTransmissionStartTime))
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("FileTimeToSystemTime failed"));
goto error_exit;
}
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_TRANSMISSION_START_TIME;
}
break;
case TIFFTAG_FAX_END_TIME:
if (!GetMsTagFileTime(fPtr, FaxMessage.dwSize, &pTiffTags[i], &FaxTime))
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagFileTime failed"));
goto error_exit;
}
if((DWORDLONG)0 != *(DWORDLONG*)&FaxTime)
{
if (!FileTimeToSystemTime(&FaxTime, &FaxMessage.tmTransmissionEndTime))
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("FileTimeToSystemTime failed"));
goto error_exit;
}
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_TRANSMISSION_END_TIME;
}
break;
case TIFFTAG_FAX_SUBMISSION_TIME:
if (!GetMsTagFileTime(fPtr, FaxMessage.dwSize, &pTiffTags[i], &FaxTime))
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagFileTime failed"));
goto error_exit;
}
if((DWORDLONG)0 != *(DWORDLONG*)&FaxTime)
{
if (!FileTimeToSystemTime(&FaxTime, &FaxMessage.tmSubmissionTime))
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("FileTimeToSystemTime failed"));
goto error_exit;
}
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_SUBMISSION_TIME;
}
break;
case TIFFTAG_FAX_SCHEDULED_TIME:
if (!GetMsTagFileTime(fPtr, FaxMessage.dwSize, &pTiffTags[i], &FaxTime))
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagFileTime failed"));
goto error_exit;
}
if((DWORDLONG)0 != *(DWORDLONG*)&FaxTime)
{
if (!FileTimeToSystemTime(&FaxTime, &FaxMessage.tmOriginalScheduleTime))
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("FileTimeToSystemTime failed"));
goto error_exit;
}
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_ORIGINAL_SCHEDULE_TIME;
}
break;
case TIFFTAG_PORT:
FaxMessage.lpctstrDeviceName = GetMsTagString( fPtr, FaxMessage.dwSize, &pTiffTags[i]);
if (FaxMessage.lpctstrDeviceName == NULL)
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_RETRIES:
FaxMessage.dwRetries = pTiffTags[i].DataOffset;
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_RETRIES;
break;
case TIFFTAG_DOCUMENT:
FaxMessage.lpctstrDocumentName = GetMsTagString( fPtr, FaxMessage.dwSize, &pTiffTags[i]);
if (FaxMessage.lpctstrDocumentName == NULL)
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SUBJECT:
FaxMessage.lpctstrSubject = GetMsTagString( fPtr, FaxMessage.dwSize, &pTiffTags[i]);
if (FaxMessage.lpctstrSubject == NULL)
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_CALLERID:
FaxMessage.lpctstrCallerID = GetMsTagString( fPtr, FaxMessage.dwSize, &pTiffTags[i]);
if (FaxMessage.lpctstrCallerID == NULL)
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_ROUTING:
FaxMessage.lpctstrRoutingInfo = GetMsTagString( fPtr, FaxMessage.dwSize, &pTiffTags[i]);
if (FaxMessage.lpctstrRoutingInfo == NULL)
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SENDER_NAME:
FaxMessage.lpctstrSenderName = GetMsTagString( fPtr, FaxMessage.dwSize, &pTiffTags[i]);
if (FaxMessage.lpctstrSenderName == NULL)
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SENDER_NUMBER:
FaxMessage.lpctstrSenderNumber = GetMsTagString( fPtr, FaxMessage.dwSize, &pTiffTags[i]);
if (FaxMessage.lpctstrSenderNumber == NULL)
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
default:
;
// There was an unknown tag (and it's ok,
//cause we do not have to handle all the possible tags)
}
}
//Get Unique JobId out of FileName
if (!GetUniqueJobIdFromFileName( lpctstrFileName, &FaxMessage.dwlMessageId))
{
ec = ERROR_BAD_FORMAT;
DebugPrintEx( DEBUG_ERR, TEXT("GetUniqueJobIdFromFileName Failed"));
goto error_exit;
}
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_MESSAGE_ID;
FaxMessage.dwSizeOfStruct = sizeof(FAX_MESSAGE);
CopyMemory (pMessage, &FaxMessage, sizeof(FAX_MESSAGE));
RetVal = TRUE;
Assert (ec == ERROR_SUCCESS);
error_exit:
if (fPtr != NULL)
{
if (!UnmapViewOfFile( fPtr))
{
DebugPrintEx( DEBUG_ERR,
TEXT("UnMapViewOfFile Failed, error: %d"),
GetLastError());
}
}
if (hMap != NULL)
{
CloseHandle( hMap );
}
if (hFile != INVALID_HANDLE_VALUE) {
CloseHandle( hFile );
}
if (RetVal == FALSE)
{
MemFree((void*)FaxMessage.lpctstrExtendedStatus);
MemFree((void*)FaxMessage.lpctstrRecipientNumber);
MemFree((void*)FaxMessage.lpctstrRecipientName);
MemFree((void*)FaxMessage.lpctstrTsid);
MemFree((void*)FaxMessage.lpctstrCsid);
MemFree((void*)FaxMessage.lpctstrSenderUserName);
MemFree((void*)FaxMessage.lpctstrBillingCode);
MemFree((void*)FaxMessage.lpctstrDeviceName);
MemFree((void*)FaxMessage.lpctstrDocumentName);
MemFree((void*)FaxMessage.lpctstrSubject);
MemFree((void*)FaxMessage.lpctstrCallerID);
MemFree((void*)FaxMessage.lpctstrRoutingInfo);
MemFree((void*)FaxMessage.lpctstrSenderName);
MemFree((void*)FaxMessage.lpctstrSenderNumber);
Assert (ERROR_SUCCESS != ec);
SetLastError(ec);
}
return RetVal;
}
//*********************************************************************************
//* Name: GetFaxSenderMsTags()
//* Author: Oded Sacher
//* Date: Nov 8, 1999
//*********************************************************************************
//* DESCRIPTION:
//* Fills PFAX_PERSONAL_PROFILE structure with sender information.
//* The caller must free all strings.
//*
//* PARAMETERS:
//* [IN ] LPCTSTR lpctstrFileName
//* pointer to the file name.
//*
//* [OUT] PFAX_PERSONAL_PROFILE pPersonalProfile
//* The PFAX_PERSONAL_PROFILE structure to be filled.
//*
//*
//* RETURN VALUE:
//* TRUE
//* If no error occured.
//* FALSE
//* If an error occured.
//*********************************************************************************
BOOL GetFaxSenderMsTags(
LPCTSTR lpctstrFileName,
PFAX_PERSONAL_PROFILE pPersonalProfile
)
{
WORD NumDirEntries;
HANDLE hFile;
HANDLE hMap = NULL;
LPBYTE fPtr = NULL;
BOOL RetVal = FALSE;
DEBUG_FUNCTION_NAME(TEXT("GetFaxSenderMsTags"));
PTIFF_TAG pTiffTags;
DWORD i;
DWORD PrevTagId;
FAX_PERSONAL_PROFILE FaxPersonalProfile = {0};
DWORD dwSize;
DWORD ec = ERROR_SUCCESS;
DWORD dwIfdOffset;
Assert (pPersonalProfile != NULL);
if (!MemoryMapTiffFile (lpctstrFileName, &dwSize, &fPtr, &hFile, &hMap, &dwIfdOffset))
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR,
TEXT("MemoryMapTiffFile Failed, error: %ld"),
ec);
goto error_exit;
}
//
// get the count of tags in this IFD
//
NumDirEntries = *(LPWORD)(fPtr + dwIfdOffset);
pTiffTags = (PTIFF_TAG)(fPtr + dwIfdOffset + sizeof(WORD));
//
// walk the tags and pick out the info we need
//
for (i = 0, PrevTagId = 0; i < NumDirEntries; i++) {
//
// verify that the tags are in ascending order
//
if (pTiffTags[i].TagId < PrevTagId) {
DebugPrintEx( DEBUG_ERR, TEXT("File %s, Invalid TIFF format"), lpctstrFileName);
goto error_exit;
}
PrevTagId = pTiffTags[i].TagId;
switch( pTiffTags[i].TagId ) {
case TIFFTAG_SENDER_NAME:
FaxPersonalProfile.lptstrName = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrName == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SENDER_NUMBER:
FaxPersonalProfile.lptstrFaxNumber = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrFaxNumber == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SENDER_COMPANY:
FaxPersonalProfile.lptstrCompany = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrCompany == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SENDER_STREET:
FaxPersonalProfile.lptstrStreetAddress = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrStreetAddress == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SENDER_CITY:
FaxPersonalProfile.lptstrCity = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrCity == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SENDER_STATE:
FaxPersonalProfile.lptstrState = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrState == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SENDER_ZIP:
FaxPersonalProfile.lptstrZip = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrZip == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SENDER_COUNTRY:
FaxPersonalProfile.lptstrCountry = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrCountry == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SENDER_TITLE:
FaxPersonalProfile.lptstrTitle = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrTitle == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SENDER_DEPARTMENT:
FaxPersonalProfile.lptstrDepartment = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrDepartment == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SENDER_OFFICE_LOCATION:
FaxPersonalProfile.lptstrOfficeLocation = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrOfficeLocation == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SENDER_HOME_PHONE:
FaxPersonalProfile.lptstrHomePhone = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrHomePhone == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SENDER_OFFICE_PHONE:
FaxPersonalProfile.lptstrOfficePhone = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrOfficePhone == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SENDER_EMAIL:
FaxPersonalProfile.lptstrEmail = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrEmail == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SENDER_BILLING:
FaxPersonalProfile.lptstrBillingCode = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrBillingCode == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_SENDER_TSID:
FaxPersonalProfile.lptstrTSID = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrTSID == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
default:
;
// There was an unknown tag (and it's ok,
//cause we do not have to handle all the possible tags)
}
}
FaxPersonalProfile.dwSizeOfStruct = sizeof(FAX_PERSONAL_PROFILE);
CopyMemory (pPersonalProfile, &FaxPersonalProfile, sizeof(FAX_PERSONAL_PROFILE));
RetVal = TRUE;
error_exit:
if (fPtr != NULL)
{
if (!UnmapViewOfFile( fPtr))
{
DebugPrintEx( DEBUG_ERR,
TEXT("UnMapViewOfFile Failed, error: %d"),
GetLastError());
}
}
if (hMap != NULL)
{
CloseHandle( hMap );
}
if (hFile != INVALID_HANDLE_VALUE) {
CloseHandle( hFile );
}
if (RetVal == FALSE)
{
FreePersonalProfile (&FaxPersonalProfile, FALSE);
}
return RetVal;
}
//*********************************************************************************
//* Name: GetFaxRecipientMsTags()
//* Author: Oded Sacher
//* Date: Nov 8, 1999
//*********************************************************************************
//* DESCRIPTION:
//* Fills PFAX_PERSONAL_PROFILE structure with recipient information.
//* The caller must free all strings.
//*
//* PARAMETERS:
//* [IN ] LPCTSTR lpctstrFileName
//* pointer to the file name.
//*
//* [OUT] PFAX_PERSONAL_PROFILE pPersonalProfile
//* The PFAX_PERSONAL_PROFILE structure to be filled.
//*
//*
//* RETURN VALUE:
//* TRUE
//* If no error occured.
//* FALSE
//* If an error occured.
//*********************************************************************************
BOOL GetFaxRecipientMsTags(
LPCTSTR lpctstrFileName,
PFAX_PERSONAL_PROFILE pPersonalProfile
)
{
WORD NumDirEntries;
HANDLE hFile;
HANDLE hMap = NULL;
LPBYTE fPtr = NULL;
BOOL RetVal = FALSE;
DEBUG_FUNCTION_NAME(TEXT("GetRecipientMsTags"));
PTIFF_TAG pTiffTags;
DWORD i;
DWORD PrevTagId;
FAX_PERSONAL_PROFILE FaxPersonalProfile = {0};
DWORD dwSize;
DWORD ec = ERROR_SUCCESS;
DWORD dwIfdOffset;
Assert (pPersonalProfile != NULL);
if (!MemoryMapTiffFile (lpctstrFileName, &dwSize, &fPtr, &hFile, &hMap, &dwIfdOffset))
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR,
TEXT("MemoryMapTiffFile Failed, error: %ld"),
ec);
goto error_exit;
}
//
// get the count of tags in this IFD
//
NumDirEntries = *(LPWORD)(fPtr + dwIfdOffset);
pTiffTags = (PTIFF_TAG)(fPtr + dwIfdOffset + sizeof(WORD));
//
// walk the tags and pick out the info we need
//
for (i = 0, PrevTagId = 0; i < NumDirEntries; i++) {
//
// verify that the tags are in ascending order
//
if (pTiffTags[i].TagId < PrevTagId) {
DebugPrintEx( DEBUG_ERR, TEXT("File %s, Invalid TIFF format"), lpctstrFileName);
goto error_exit;
}
PrevTagId = pTiffTags[i].TagId;
switch( pTiffTags[i].TagId ) {
case TIFFTAG_RECIP_NAME:
FaxPersonalProfile.lptstrName = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrName == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_RECIP_NUMBER:
FaxPersonalProfile.lptstrFaxNumber = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrFaxNumber == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_RECIP_COMPANY:
FaxPersonalProfile.lptstrCompany = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrCompany == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_RECIP_STREET:
FaxPersonalProfile.lptstrStreetAddress = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrStreetAddress == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_RECIP_CITY:
FaxPersonalProfile.lptstrCity = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrCity == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_RECIP_STATE:
FaxPersonalProfile.lptstrState = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrState == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_RECIP_ZIP:
FaxPersonalProfile.lptstrZip = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrZip == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_RECIP_COUNTRY:
FaxPersonalProfile.lptstrCountry = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrCountry == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_RECIP_TITLE:
FaxPersonalProfile.lptstrTitle = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrTitle == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_RECIP_DEPARTMENT:
FaxPersonalProfile.lptstrDepartment = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrDepartment == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_RECIP_OFFICE_LOCATION:
FaxPersonalProfile.lptstrOfficeLocation = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrOfficeLocation == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_RECIP_HOME_PHONE:
FaxPersonalProfile.lptstrHomePhone = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrHomePhone == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_RECIP_OFFICE_PHONE:
FaxPersonalProfile.lptstrOfficePhone = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrOfficePhone == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
case TIFFTAG_RECIP_EMAIL:
FaxPersonalProfile.lptstrEmail = GetMsTagString( fPtr, dwSize, &pTiffTags[i]);
if (FaxPersonalProfile.lptstrEmail == NULL)
{
DebugPrintEx( DEBUG_ERR, TEXT("GetMsTagString failed"));
goto error_exit;
}
break;
default:
;
// There was an unknown tag (and it's ok,
//cause we do not have to handle all the possible tags)
}
}
FaxPersonalProfile.dwSizeOfStruct = sizeof(FAX_PERSONAL_PROFILE);
CopyMemory (pPersonalProfile, &FaxPersonalProfile, sizeof(FAX_PERSONAL_PROFILE));
RetVal = TRUE;
error_exit:
if (fPtr != NULL)
{
if (!UnmapViewOfFile( fPtr))
{
DebugPrintEx( DEBUG_ERR,
TEXT("UnMapViewOfFile Failed, error: %d"),
GetLastError());
}
}
if (hMap != NULL)
{
CloseHandle( hMap );
}
if (hFile != INVALID_HANDLE_VALUE) {
CloseHandle( hFile );
}
if (RetVal == FALSE)
{
FreePersonalProfile (&FaxPersonalProfile, FALSE);
}
return RetVal;
}
//*********************************************************************************
//* Name: AddNTFSStorageProperties()
//* Author: Oded Sacher
//* Date: Nov 8, 1999
//*********************************************************************************
//* DESCRIPTION:
//* Adds NTFS Properties to a file
//*
//* PARAMETERS:
//* [IN ] LPTSTR FileName
//* pointer to the file name.
//*
//* [IN ] PMS_TAG_INFO MsTagInfo
//* pointer to a structure containing all info to be written.
//*
//*
//* [IN ] BOOL fSendJob
//* Flag that indicates an outbound job.
//*
//*
//* RETURN VALUE:
//* TRUE
//* If no error occured.
//* FALSE
//* If an error occured.
//*********************************************************************************
BOOL
AddNTFSStorageProperties(
LPTSTR FileName,
PMS_TAG_INFO MsTagInfo,
BOOL fSendJob
)
{
HRESULT hr;
IPropertySetStorage* pPropertySetStorage = NULL;
IPropertyStorage* pPropertyStorage = NULL;
PROPSPEC rgpspec[MAX_FAX_PROPERTIES];
PROPVARIANT rgvar [MAX_FAX_PROPERTIES];
DWORD i;
DEBUG_FUNCTION_NAME(TEXT("AddNTFSStorageProperties"));
BOOL RetVal = FALSE;
DWORD ec = ERROR_SUCCESS;
for (i = 0; i < MAX_FAX_PROPERTIES; i++)
{
PropVariantInit (&rgvar[i]);
}
hr = StgOpenStorageEx( FileName, //Points to path of compound file to create
STGM_READWRITE | STGM_SHARE_EXCLUSIVE | STGM_DIRECT,//Specifies the access mode for opening the storage object
STGFMT_FILE, //Specifies the storage file format
0, //Reserved; must be zero
NULL, //Points to STGOPTIONS structure which specifies features of the storage object
0, //Reserved; must be zero
IID_IPropertySetStorage ,//Specifies the GUID of the interface pointer
(void**)&pPropertySetStorage //Address of an interface pointer
);
if (FAILED(hr))
{
DebugPrintEx( DEBUG_ERR,TEXT("StgOpenStorageEx Failed, err : 0x%08X"), hr);
ec = ERROR_OPEN_FAILED;
goto exit;
}
hr = pPropertySetStorage->Create( FMTID_FaxProperties, //Format identifier of the property set to be created
NULL, //Pointer to initial CLSID for this property set
PROPSETFLAG_DEFAULT, //PROPSETFLAG values
STGM_READWRITE | STGM_SHARE_EXCLUSIVE | STGM_DIRECT, //Storage mode of new property set
&pPropertyStorage //Address of output variable that receivesthe IPropertyStorage interface pointer
);
if (FAILED(hr))
{
DebugPrintEx( DEBUG_ERR,TEXT("IPropertySetStorage::Create Failed, err : 0x%08X"), hr);
ec = ERROR_OPEN_FAILED;
goto exit;
}
//
// write out the data
//
i = 0;
if (MsTagInfo->Csid) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_CSID;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->Csid;
i++;
}
if (MsTagInfo->Tsid) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_TSID;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->Tsid;
i++;
}
if (MsTagInfo->Port) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_PORT;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->Port;
i++;
}
if (fSendJob == FALSE)
{
// Receive job
if (MsTagInfo->Routing) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_ROUTING;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->Routing;
i++;
}
if (MsTagInfo->CallerId) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_CALLERID;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->CallerId;
i++;
}
}
else
{
// Send job
if (MsTagInfo->RecipName) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_RECIP_NAME;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->RecipName;
i++;
}
if (MsTagInfo->RecipNumber) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_RECIP_NUMBER;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->RecipNumber;
i++;
}
if (MsTagInfo->RecipCompany) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_RECIP_COMPANY;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->RecipCompany;
i++;
}
if (MsTagInfo->RecipStreet) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_RECIP_STREET;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->RecipStreet;
i++;
}
if (MsTagInfo->RecipCity) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_RECIP_CITY;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->RecipCity;
i++;
}
if (MsTagInfo->RecipState) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_RECIP_STATE;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->RecipState;
i++;
}
if (MsTagInfo->RecipZip) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_RECIP_ZIP;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->RecipZip;
i++;
}
if (MsTagInfo->RecipCountry) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_RECIP_COUNTRY;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->RecipCountry;
i++;
}
if (MsTagInfo->RecipTitle) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_RECIP_TITLE;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->RecipTitle;
i++;
}
if (MsTagInfo->RecipDepartment) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_RECIP_DEPARTMENT;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->RecipDepartment;
i++;
}
if (MsTagInfo->RecipOfficeLocation) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_RECIP_OFFICE_LOCATION;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->RecipOfficeLocation;
i++;
}
if (MsTagInfo->RecipHomePhone) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_RECIP_HOME_PHONE;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->RecipHomePhone;
i++;
}
if (MsTagInfo->RecipOfficePhone) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_RECIP_OFFICE_PHONE;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->RecipOfficePhone;
i++;
}
if (MsTagInfo->RecipEMail) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_RECIP_EMAIL;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->RecipEMail;
i++;
}
if (MsTagInfo-> SenderName) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_SENDER_NAME;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->SenderName;
i++;
}
if (MsTagInfo-> SenderNumber) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_SENDER_NUMBER;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->SenderNumber;
i++;
}
if (MsTagInfo-> SenderCompany) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_SENDER_COMPANY;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->SenderCompany;
i++;
}
if (MsTagInfo-> SenderStreet) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_SENDER_STREET;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->SenderStreet;
i++;
}
if (MsTagInfo-> SenderCity) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_SENDER_CITY;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->SenderCity;
i++;
}
if (MsTagInfo-> SenderState) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_SENDER_STATE;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->SenderState;
i++;
}
if (MsTagInfo-> SenderZip) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_SENDER_ZIP;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->SenderZip;
i++;
}
if (MsTagInfo-> SenderCountry) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_SENDER_COUNTRY;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->SenderCountry;
i++;
}
if (MsTagInfo-> SenderTitle) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_SENDER_TITLE;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->SenderTitle;
i++;
}
if (MsTagInfo-> SenderDepartment) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_SENDER_DEPARTMENT;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->SenderDepartment;
i++;
}
if (MsTagInfo-> SenderOfficeLocation) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_SENDER_OFFICE_LOCATION;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->SenderOfficeLocation;
i++;
}
if (MsTagInfo-> SenderHomePhone) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_SENDER_HOME_PHONE;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->SenderHomePhone;
i++;
}
if (MsTagInfo-> SenderOfficePhone) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_SENDER_OFFICE_PHONE;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->SenderOfficePhone;
i++;
}
if (MsTagInfo-> SenderEMail) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_SENDER_EMAIL;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->SenderEMail;
i++;
}
if (MsTagInfo->SenderBilling) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_SENDER_BILLING;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->SenderBilling;
i++;
}
if (MsTagInfo->SenderUserName) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_SENDER_USER_NAME;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->SenderUserName;
i++;
}
if (MsTagInfo->SenderTsid) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_SENDER_TSID;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->SenderTsid;
i++;
}
if (MsTagInfo->Document) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_DOCUMENT;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->Document;
i++;
}
if (MsTagInfo->Subject) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_SUBJECT;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->Subject;
i++;
}
// Deal with Retries
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_RETRIES;
rgvar[i].vt = VT_UI4;
rgvar[i].ulVal = MsTagInfo->Retries;
i++;
// Deal with Priority
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_PRIORITY;
rgvar[i].vt = VT_UI4;
rgvar[i].ulVal = MsTagInfo->Priority;
i++;
// Deal with Submission time
Assert (MsTagInfo->SubmissionTime != 0);
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_SUBMISSION_TIME;
rgvar[i].vt = VT_FILETIME;
rgvar[i].filetime = *(FILETIME*)&MsTagInfo->SubmissionTime;
i++;
// Deal with Originaly scheduled time
Assert (MsTagInfo->OriginalScheduledTime);
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_ORIGINAL_SCHED_TIME;
rgvar[i].vt = VT_FILETIME;
rgvar[i].filetime = *(FILETIME*)&MsTagInfo->OriginalScheduledTime;
i++;
// Deal with Broadcast id
Assert (MsTagInfo->dwlBroadcastId != 0);
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_BROADCAST_ID;
rgvar[i].vt = VT_UI8;
rgvar[i].uhVal = *(ULARGE_INTEGER*)&MsTagInfo->dwlBroadcastId;
i++;
}
// Deal with Pages
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_PAGES;
rgvar[i].vt = VT_UI4;
rgvar[i].ulVal = MsTagInfo->Pages;
i++;
// Deal with Type
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_TYPE;
rgvar[i].vt = VT_UI4;
rgvar[i].ulVal = MsTagInfo->Type;
i++;
// Deal with Status
if (MsTagInfo->dwStatus == JS_COMPLETED) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_STATUS;
rgvar[i].vt = VT_UI4;
rgvar[i].ulVal = MsTagInfo->dwStatus;
i++;
}
// Deal with Extended status
if (MsTagInfo->dwExtendedStatus) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_STATUS_EX;
rgvar[i].vt = VT_UI4;
rgvar[i].ulVal = MsTagInfo->dwExtendedStatus;
i++;
}
// Deal with Extended status string
if (MsTagInfo->lptstrExtendedStatus) {
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_STATUS_STR_EX;
rgvar[i].vt = VT_LPWSTR;
rgvar[i].pwszVal = MsTagInfo->lptstrExtendedStatus;
i++;
}
// Deal with StartTime
if (MsTagInfo->StartTime != 0)
{
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_START_TIME;
rgvar[i].vt = VT_FILETIME;
rgvar[i].filetime = *(FILETIME*)&MsTagInfo->StartTime;
i++;
}
// Deal with EndTime
if (MsTagInfo->EndTime != 0)
{
rgpspec[i].ulKind = PRSPEC_PROPID;
rgpspec[i].propid = PID_FAX_END_TIME;
rgvar[i].vt = VT_FILETIME;
rgvar[i].filetime = *(FILETIME*)&MsTagInfo->EndTime;
i++;
}
hr = pPropertyStorage->WriteMultiple( i, //The number of properties being set
rgpspec, //Property specifiers
rgvar, //Array of PROPVARIANT values
0 //Minimum value for property identifiers when they must be allocated
);
if (FAILED(hr))
{
DebugPrintEx( DEBUG_ERR,TEXT("IPropertySetStorage::WriteMultiple Failed, err : 0x%08X"), hr);
ec = ERROR_WRITE_FAULT;
goto exit;
}
RetVal = TRUE;
Assert (ec == ERROR_SUCCESS);
exit:
if (NULL != pPropertyStorage)
{
pPropertyStorage->Release();
}
if (NULL != pPropertySetStorage)
{
pPropertySetStorage->Release();
}
if (!RetVal)
{
SetLastError (ec);
}
return RetVal;
}
//*********************************************************************************
//* Name: GetMessageNTFSStorageProperties()
//* Author: Oded Sacher
//* Date: Nov 8, 1999
//*********************************************************************************
//* DESCRIPTION:
//* Fills FAX_MESSAGE structure.
//* The caller must free all strings.
//*
//* PARAMETERS:
//* [IN ] LPCTSTR lpctstrFileName
//* pointer to the file name.
//*
//* [OUT] PFAX_MESSAGE pMessage
//* The FAX_MESSAGE structure to be filled.
//*
//*
//* RETURN VALUE:
//* TRUE
//* If no error occured.
//* FALSE
//* If an error occured.
//*********************************************************************************
BOOL GetMessageNTFSStorageProperties(
LPCTSTR lpctstrFileName,
PFAX_MESSAGE pMessage
)
{
HRESULT hr;
IPropertySetStorage* pPropertySetStorage = NULL;
IPropertyStorage* pPropertyStorage = NULL;
PROPVARIANT rgvar[FAX_MESSAGE_PROPERTIES];
DEBUG_FUNCTION_NAME(TEXT("GetMessageNTFSStorageProperties"));
BOOL RetVal = FALSE;
DWORD i;
FAX_MESSAGE FaxMessage = {0};
HANDLE hFind;
WIN32_FIND_DATA FindFileData;
FILETIME FaxTime;
BOOL fFreePropVariant = FALSE;
DWORD ec = ERROR_SUCCESS;
Assert (pMessage && lpctstrFileName);
hFind = FindFirstFile( lpctstrFileName, &FindFileData);
if (INVALID_HANDLE_VALUE == hFind)
{
DebugPrintEx(
DEBUG_ERR,
TEXT("FindFirstFile failed (ec: %ld), File %s"),
GetLastError(),
lpctstrFileName);
}
else
{
Assert (0 == FindFileData.nFileSizeHigh);
FaxMessage.dwSize = FindFileData.nFileSizeLow;
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_SIZE;
if (!FindClose(hFind))
{
DebugPrintEx(
DEBUG_ERR,
TEXT("FindClose failed (ec: %ld)"),
GetLastError());
}
}
hr = StgOpenStorageEx( lpctstrFileName, //Points to path of compound file to create
STGM_READ | STGM_SHARE_DENY_WRITE | STGM_DIRECT, //Specifies the access mode for opening the storage object
STGFMT_FILE, //Specifies the storage file format
0, //Reserved; must be zero
NULL, //Points to STGOPTIONS structure which specifies features of the storage object
0, //Reserved; must be zero
IID_IPropertySetStorage ,//Specifies the GUID of the interface pointer
(void**)&pPropertySetStorage //Address of an interface pointer
);
if (FAILED(hr))
{
DebugPrintEx( DEBUG_ERR,TEXT("StgOpenStorageEx Failed, err : 0x%08X"), hr);
ec = ERROR_OPEN_FAILED;
goto exit;
}
hr = pPropertySetStorage->Open( FMTID_FaxProperties, //Format identifier of the property set to be created
STGM_READ | STGM_SHARE_EXCLUSIVE, //Storage mode of new property set
&pPropertyStorage //Address of output variable that receivesthe IPropertyStorage interface pointer
);
if (FAILED(hr))
{
DebugPrintEx( DEBUG_ERR,TEXT("IPropertySetStorage::Create Failed, err : 0x%08X"), hr);
ec = ERROR_OPEN_FAILED;
goto exit;
}
hr = pPropertyStorage->ReadMultiple( FAX_MESSAGE_PROPERTIES, //Count of properties being read
pspecFaxMessage, //Array of the properties to be read
rgvar //Array of PROPVARIANTs containing the property values on return
);
if (FAILED(hr))
{
DebugPrintEx( DEBUG_ERR,TEXT("IPropertySetStorage::ReadMultiple Failed, err : 0x%08X"), hr);
ec = ERROR_READ_FAULT;
goto exit;
}
fFreePropVariant = TRUE;
for (i = 0; i < FAX_MESSAGE_PROPERTIES; i++)
{
if (rgvar[i].vt != VT_EMPTY)
{
switch (pspecFaxMessage[i].propid)
{
case PID_FAX_CSID:
FaxMessage.lpctstrCsid = StringDup (rgvar[i].pwszVal);
if (FaxMessage.lpctstrCsid == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, err : %ld"), ec);
goto exit;
}
break;
case PID_FAX_TSID:
FaxMessage.lpctstrTsid = StringDup (rgvar[i].pwszVal);
if (FaxMessage.lpctstrTsid == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, err : %ld"), ec);
goto exit;
}
break;
case PID_FAX_PORT:
FaxMessage.lpctstrDeviceName = StringDup (rgvar[i].pwszVal);
if (FaxMessage.lpctstrDeviceName == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, err : %ld"), ec);
goto exit;
}
break;
case PID_FAX_ROUTING:
FaxMessage.lpctstrRoutingInfo = StringDup (rgvar[i].pwszVal);
if (FaxMessage.lpctstrRoutingInfo == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, err : %ld"), ec);
goto exit;
}
break;
case PID_FAX_CALLERID:
FaxMessage.lpctstrCallerID = StringDup (rgvar[i].pwszVal);
if (FaxMessage.lpctstrCallerID == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, err : %ld"), ec);
goto exit;
}
break;
case PID_FAX_DOCUMENT:
FaxMessage.lpctstrDocumentName = StringDup (rgvar[i].pwszVal);
if (FaxMessage.lpctstrDocumentName == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, err : %ld"), ec);
goto exit;
}
break;
case PID_FAX_SUBJECT:
FaxMessage.lpctstrSubject = StringDup (rgvar[i].pwszVal);
if (FaxMessage.lpctstrSubject == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, err : %ld"), ec);
goto exit;
}
break;
case PID_FAX_RETRIES:
FaxMessage.dwRetries = rgvar[i].ulVal;
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_RETRIES;
break;
case PID_FAX_PAGES:
FaxMessage.dwPageCount = rgvar[i].ulVal;
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_PAGE_COUNT;
break;
case PID_FAX_TYPE:
FaxMessage.dwJobType = rgvar[i].ulVal;
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_TYPE;
break;
case PID_FAX_PRIORITY:
FaxMessage.Priority = (FAX_ENUM_PRIORITY_TYPE)rgvar[i].ulVal;
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_PRIORITY;
break;
case PID_FAX_START_TIME:
FaxTime = rgvar[i].filetime;
if (!FileTimeToSystemTime(&FaxTime, &FaxMessage.tmTransmissionStartTime))
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, err : %ld"), ec);
goto exit;
}
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_TRANSMISSION_START_TIME;
break;
case PID_FAX_END_TIME:
FaxTime = rgvar[i].filetime;
if (!FileTimeToSystemTime(&FaxTime, &FaxMessage.tmTransmissionEndTime))
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, err : %ld"), ec);
goto exit;
}
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_TRANSMISSION_END_TIME;
break;
case PID_FAX_SUBMISSION_TIME:
FaxTime = rgvar[i].filetime;
if (!FileTimeToSystemTime(&FaxTime, &FaxMessage.tmSubmissionTime))
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, err : %ld"), ec);
goto exit;
}
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_SUBMISSION_TIME;
break;
case PID_FAX_ORIGINAL_SCHED_TIME:
FaxTime = rgvar[i].filetime;
if (!FileTimeToSystemTime(&FaxTime, &FaxMessage.tmOriginalScheduleTime))
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, err : %ld"), ec);
goto exit;
}
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_ORIGINAL_SCHEDULE_TIME;
break;
case PID_FAX_SENDER_USER_NAME:
FaxMessage.lpctstrSenderUserName = StringDup (rgvar[i].pwszVal);
if (FaxMessage.lpctstrSenderUserName == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, err : %ld"), ec);
goto exit;
}
break;
case PID_FAX_RECIP_NAME:
FaxMessage.lpctstrRecipientName = StringDup (rgvar[i].pwszVal);
if (FaxMessage.lpctstrRecipientName == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, err : %ld"), ec);
goto exit;
}
break;
case PID_FAX_RECIP_NUMBER:
FaxMessage.lpctstrRecipientNumber = StringDup (rgvar[i].pwszVal);
if (FaxMessage.lpctstrRecipientNumber == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, err : %ld"), ec);
goto exit;
}
break;
case PID_FAX_SENDER_NAME:
FaxMessage.lpctstrSenderName = StringDup (rgvar[i].pwszVal);
if (FaxMessage.lpctstrSenderName == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, err : %ld"), ec);
goto exit;
}
break;
case PID_FAX_SENDER_NUMBER:
FaxMessage.lpctstrSenderNumber = StringDup (rgvar[i].pwszVal);
if (FaxMessage.lpctstrSenderNumber == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, err : %ld"), ec);
goto exit;
}
break;
case PID_FAX_SENDER_BILLING:
FaxMessage.lpctstrBillingCode = StringDup (rgvar[i].pwszVal);
if (FaxMessage.lpctstrBillingCode == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, err : %ld"), ec);
goto exit;
}
break;
case PID_FAX_STATUS:
FaxMessage.dwQueueStatus = rgvar[i].ulVal;
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_QUEUE_STATUS;
break;
case PID_FAX_STATUS_EX:
FaxMessage.dwExtendedStatus = rgvar[i].ulVal;
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_STATUS_EX;
break;
case PID_FAX_STATUS_STR_EX:
FaxMessage.lpctstrExtendedStatus = StringDup (rgvar[i].pwszVal);
if (FaxMessage.lpctstrExtendedStatus == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, err : %ld"), ec);
goto exit;
}
break;
case PID_FAX_BROADCAST_ID:
FaxMessage.dwlBroadcastId = *(DWORDLONG*)&rgvar[i].uhVal;
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_BROADCAST_ID;
break;
default:
Assert (pspecFaxMessage[i].propid == PID_FAX_SENDER_BILLING); //Assert (FALSE);
}
}
}
// Get Unique JobId out of FileName
if (!GetUniqueJobIdFromFileName( lpctstrFileName, &FaxMessage.dwlMessageId))
{
ec = GetLastError();
DebugPrintEx( DEBUG_ERR, TEXT("GetUniqueJobIdFromFileName Failed, err : %ld"), ec);
goto exit;
}
FaxMessage.dwValidityMask |= FAX_JOB_FIELD_MESSAGE_ID;
FaxMessage.dwSizeOfStruct = sizeof(FAX_MESSAGE);
CopyMemory (pMessage, &FaxMessage, sizeof(FAX_MESSAGE));
RetVal = TRUE;
Assert (ec == ERROR_SUCCESS);
exit:
if (NULL != pPropertyStorage)
{
pPropertyStorage->Release();
}
if (NULL != pPropertySetStorage)
{
pPropertySetStorage->Release();
}
if (fFreePropVariant == TRUE)
{
hr = FreePropVariantArray( FAX_MESSAGE_PROPERTIES, //Count of elements in the structure
rgvar //Pointer to the PROPVARIANT structure
);
if (FAILED(hr))
{
DebugPrintEx( DEBUG_ERR,TEXT("FreePropVariantArray Failed, err : 0x%08X"), hr);
}
}
if (RetVal == FALSE)
{
FreeMessageBuffer (&FaxMessage, FALSE);
SetLastError (ec);
}
return RetVal;
}
BOOL
GetUniqueJobIdFromFileName (
LPCWSTR lpctstrFileName,
DWORDLONG* pdwlUniqueJobId)
{
WCHAR lpwstrTmp[MAX_PATH];
DWORDLONG dwlJobId = 0;
LPWSTR lpwstrJobId = NULL;
_wsplitpath (lpctstrFileName, NULL, NULL, lpwstrTmp, NULL);
lpwstrJobId = wcschr( lpwstrTmp, L'$');
if (lpwstrJobId == NULL)
{
if (!swscanf(lpwstrTmp, TEXT("%I64x"), &dwlJobId))
{
return FALSE;
}
}
else
{
if (!swscanf((lpwstrJobId+1), TEXT("%I64x"), &dwlJobId))
{
return FALSE;
}
}
*pdwlUniqueJobId = dwlJobId;
return TRUE;
}
//*********************************************************************************
//* Name: GetPersonalProfNTFSStorageProperties()
//* Author: Oded Sacher
//* Date: Nov 8, 1999
//*********************************************************************************
//* DESCRIPTION:
//* Fills PFAX_PERSONAL_PROFILE structure with sender or recipient information.
//* The caller must free all strings.
//*
//* PARAMETERS:
//* [IN ] LPCTSTR lpctstrFileName
//* pointer to the file name.
//* [IN ] FAX_ENUM_PERSONAL_PROF_TYPES PersonalProfType
//* Can be RECIPIENT_PERSONAL_PROF or SENDER_PERSONAL_PROF
//*
//* [OUT] PFAX_PERSONAL_PROFILE pPersonalProfile
//* The PFAX_PERSONAL_PROFILE structure to be filled.
//*
//*
//* RETURN VALUE:
//* TRUE
//* If no error occured.
//* FALSE
//* If an error occured.
//*********************************************************************************
BOOL GetPersonalProfNTFSStorageProperties(
LPCTSTR lpctstrFileName,
FAX_ENUM_PERSONAL_PROF_TYPES PersonalProfType,
PFAX_PERSONAL_PROFILE pPersonalProfile
)
{
HRESULT hr;
IPropertySetStorage* pPropertySetStorage = NULL;
IPropertyStorage* pPropertyStorage = NULL;
const PROPSPEC* pspec;
DWORD dwPropertiesCnt;
DEBUG_FUNCTION_NAME(TEXT("GetPersonalProfNTFSStorageProperties"));
BOOL RetVal = FALSE;
DWORD i;
FAX_PERSONAL_PROFILE FaxPersonalProfile = {0};
BOOL fFreePropVariant = FALSE;
PROPVARIANT* rgvar;
DWORD ec = ERROR_SUCCESS;
Assert (PersonalProfType == RECIPIENT_PERSONAL_PROF ||
PersonalProfType == SENDER_PERSONAL_PROF);
if (PersonalProfType == RECIPIENT_PERSONAL_PROF)
{
pspec = pspecFaxRecipient;
dwPropertiesCnt = FAX_RECIP_PROPERTIES;
}
else
{
pspec = pspecFaxSender;
dwPropertiesCnt = FAX_SENDER_PROPERTIES;
}
rgvar = (PROPVARIANT*) MemAlloc( dwPropertiesCnt * sizeof(PROPVARIANT) );
if (!rgvar) {
DebugPrintEx( DEBUG_ERR,TEXT("Failed to allocate array of PROPVARIANT values"));
ec = ERROR_OUTOFMEMORY;
goto exit;
}
hr = StgOpenStorageEx( lpctstrFileName, //Points to path of compound file to create
STGM_READ | STGM_SHARE_DENY_WRITE | STGM_DIRECT, //Specifies the access mode for opening the storage object
STGFMT_FILE, //Specifies the storage file format
0, //Reserved; must be zero
NULL, //Points to STGOPTIONS structure which specifies features of the storage object
0, //Reserved; must be zero
IID_IPropertySetStorage ,//Specifies the GUID of the interface pointer
(void**)&pPropertySetStorage //Address of an interface pointer
);
if (FAILED(hr))
{
DebugPrintEx( DEBUG_ERR,TEXT("StgOpenStorageEx Failed, err :"), hr);
ec = ERROR_OPEN_FAILED;
goto exit;
}
hr = pPropertySetStorage->Open( FMTID_FaxProperties, //Format identifier of the property set to be created
STGM_READ|STGM_SHARE_EXCLUSIVE, //Storage mode of new property set
&pPropertyStorage //Address of output variable that receivesthe IPropertyStorage interface pointer
);
if (FAILED(hr))
{
DebugPrintEx( DEBUG_ERR,TEXT("IPropertySetStorage::Create Failed, err :"), hr);
ec = ERROR_OPEN_FAILED;
goto exit;
}
hr = pPropertyStorage->ReadMultiple( dwPropertiesCnt, //Count of properties being read
pspec, //Array of the properties to be read
rgvar //Array of PROPVARIANTs containing the property values on return
);
if (FAILED(hr))
{
DebugPrintEx( DEBUG_ERR,TEXT("IPropertySetStorage::ReadMultiple Failed, err :"), hr);
ec = ERROR_READ_FAULT;
goto exit;
}
fFreePropVariant = TRUE;
for (i = 0; i < dwPropertiesCnt; i++)
{
if (rgvar[i].vt != VT_EMPTY)
{
switch (pspec[i].propid)
{
case PID_FAX_RECIP_NAME:
case PID_FAX_SENDER_NAME:
FaxPersonalProfile.lptstrName = StringDup (rgvar[i].pwszVal);
if (FaxPersonalProfile.lptstrName == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, error %ld"), ec);
goto exit;
}
break;
case PID_FAX_RECIP_NUMBER:
case PID_FAX_SENDER_NUMBER:
FaxPersonalProfile.lptstrFaxNumber = StringDup (rgvar[i].pwszVal);
if (FaxPersonalProfile.lptstrFaxNumber == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, error %ld"), ec);
goto exit;
}
break;
case PID_FAX_RECIP_COMPANY:
case PID_FAX_SENDER_COMPANY:
FaxPersonalProfile.lptstrCompany = StringDup (rgvar[i].pwszVal);
if (FaxPersonalProfile.lptstrCompany == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, error %ld"), ec);
goto exit;
}
break;
case PID_FAX_RECIP_STREET:
case PID_FAX_SENDER_STREET:
FaxPersonalProfile.lptstrStreetAddress = StringDup (rgvar[i].pwszVal);
if (FaxPersonalProfile.lptstrStreetAddress == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, error %ld"), ec);
goto exit;
}
break;
case PID_FAX_RECIP_CITY:
case PID_FAX_SENDER_CITY:
FaxPersonalProfile.lptstrCity = StringDup (rgvar[i].pwszVal);
if (FaxPersonalProfile.lptstrCity == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, error %ld"), ec);
goto exit;
}
break;
case PID_FAX_RECIP_STATE:
case PID_FAX_SENDER_STATE:
FaxPersonalProfile.lptstrState = StringDup (rgvar[i].pwszVal);
if (FaxPersonalProfile.lptstrState == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, error %ld"), ec);
goto exit;
}
break;
case PID_FAX_RECIP_ZIP:
case PID_FAX_SENDER_ZIP:
FaxPersonalProfile.lptstrZip = StringDup (rgvar[i].pwszVal);
if (FaxPersonalProfile.lptstrZip == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, error %ld"), ec);
goto exit;
}
break;
case PID_FAX_RECIP_COUNTRY:
case PID_FAX_SENDER_COUNTRY:
FaxPersonalProfile.lptstrCountry = StringDup (rgvar[i].pwszVal);
if (FaxPersonalProfile.lptstrCountry == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, error %ld"), ec);
goto exit;
}
break;
case PID_FAX_RECIP_TITLE:
case PID_FAX_SENDER_TITLE:
FaxPersonalProfile.lptstrTitle = StringDup (rgvar[i].pwszVal);
if (FaxPersonalProfile.lptstrTitle == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, error %ld"), ec);
goto exit;
}
break;
case PID_FAX_RECIP_DEPARTMENT:
case PID_FAX_SENDER_DEPARTMENT:
FaxPersonalProfile.lptstrDepartment = StringDup (rgvar[i].pwszVal);
if (FaxPersonalProfile.lptstrDepartment == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, error %ld"), ec);
goto exit;
}
break;
case PID_FAX_RECIP_OFFICE_LOCATION:
case PID_FAX_SENDER_OFFICE_LOCATION:
FaxPersonalProfile.lptstrOfficeLocation = StringDup (rgvar[i].pwszVal);
if (FaxPersonalProfile.lptstrOfficeLocation == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, error %ld"), ec);
goto exit;
}
break;
case PID_FAX_RECIP_HOME_PHONE:
case PID_FAX_SENDER_HOME_PHONE:
FaxPersonalProfile.lptstrHomePhone = StringDup (rgvar[i].pwszVal);
if (FaxPersonalProfile.lptstrHomePhone == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, error %ld"), ec);
goto exit;
}
break;
case PID_FAX_RECIP_OFFICE_PHONE:
case PID_FAX_SENDER_OFFICE_PHONE:
FaxPersonalProfile.lptstrOfficePhone = StringDup (rgvar[i].pwszVal);
if (FaxPersonalProfile.lptstrOfficePhone == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, error %ld"), ec);
goto exit;
}
break;
case PID_FAX_RECIP_EMAIL:
case PID_FAX_SENDER_EMAIL:
FaxPersonalProfile.lptstrEmail = StringDup (rgvar[i].pwszVal);
if (FaxPersonalProfile.lptstrEmail == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, error %ld"), ec);
goto exit;
}
break;
case PID_FAX_SENDER_BILLING:
FaxPersonalProfile.lptstrBillingCode = StringDup (rgvar[i].pwszVal);
if (FaxPersonalProfile.lptstrBillingCode == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, error %ld"), ec);
goto exit;
}
break;
case PID_FAX_SENDER_TSID:
FaxPersonalProfile.lptstrTSID = StringDup (rgvar[i].pwszVal);
if (FaxPersonalProfile.lptstrTSID == NULL)
{
ec = GetLastError ();
DebugPrintEx( DEBUG_ERR,TEXT("StringDup Failed, error %ld"), ec);
goto exit;
}
break;
default:
Assert (pspecFaxMessage[i].propid == PID_FAX_SENDER_TSID); //Assert (FALSE);
}
}
}
FaxPersonalProfile.dwSizeOfStruct = sizeof(FAX_PERSONAL_PROFILE);
CopyMemory (pPersonalProfile, &FaxPersonalProfile, sizeof(FAX_PERSONAL_PROFILE));
RetVal = TRUE;
Assert (ec == ERROR_SUCCESS);
exit:
if (NULL != pPropertyStorage)
{
pPropertyStorage->Release();
}
if (NULL != pPropertySetStorage)
{
pPropertySetStorage->Release();
}
if (fFreePropVariant == TRUE)
{
hr = FreePropVariantArray( dwPropertiesCnt, //Count of elements in the structure
rgvar //Pointer to the PROPVARIANT structure
);
if (FAILED(hr))
{
DebugPrintEx( DEBUG_ERR,TEXT("FreePropVariantArray Failed, err :"), hr);
}
}
MemFree(rgvar);
if (RetVal == FALSE)
{
FreePersonalProfile (&FaxPersonalProfile, FALSE);
SetLastError (ec);
}
return RetVal;
}
/******************************************************************************
* Name: GetRecievedMessageFileName
* Author: Oded Sacher
*******************************************************************************
DESCRIPTION:
Returns the file name of the specified message from the Inbox archive.
PARAMETERS:
[IN] DWORDLONG dwlUniqueId [IN/OUT]
The message unique ID.
RETURN VALUE:
Pointer to the file name on success. Null if failed
REMARKS:
Returns a pointer to the file name specified by unique message ID.
If the function fails the function returns NULL.
The caller must call MemFree to deallocate the returned string
*******************************************************************************/
LPWSTR
GetRecievedMessageFileName(
IN DWORDLONG dwlUniqueId
)
{
WCHAR wszFileName[MAX_PATH];
WCHAR wszFullPathFileName[MAX_PATH];
DWORD dwCount;
DEBUG_FUNCTION_NAME(TEXT("GetRecievedMessageFileName"));
DWORD ec = ERROR_SUCCESS;
WCHAR wszArchiveFolder [MAX_PATH];
LPWSTR lpwstrFilePart;
EnterCriticalSection (&g_CsConfig);
lstrcpyn (wszArchiveFolder, g_ArchivesConfig[FAX_MESSAGE_FOLDER_INBOX].lpcstrFolder, MAX_PATH);
LeaveCriticalSection (&g_CsConfig);
swprintf (wszFileName, L"%I64x", dwlUniqueId);
dwCount = SearchPath (wszArchiveFolder, // search path
wszFileName, // file name
FAX_TIF_FILE_DOT_EXT, // file extension
MAX_PATH, // size of buffer
wszFullPathFileName, // found file name buffer
&lpwstrFilePart // file component
);
if (0 == dwCount)
{
DebugPrintEx(
DEBUG_ERR,
TEXT("SearchPath Failed, Error %ld"), GetLastError());
return NULL;
}
if (dwCount > MAX_PATH)
{
DebugPrintEx(
DEBUG_ERR,
TEXT("SearchPath Failed, File name bigger than MAX_PATH"));
SetLastError (E_FAIL);
return NULL;
}
return StringDup (wszFullPathFileName);
}
/******************************************************************************
* Name: GetSentMessageFileName
* Author: Oded Sacher
*******************************************************************************
DESCRIPTION:
Returns the file name of the specified message from the Sent items archive.
PARAMETERS:
[IN] DWORDLONG dwlUniqueId
The message unique ID.
[IN] PSID pSid
Pointer to the sending user SID.
If this value is NULL - the caller has access to everyone's sent items archive
and can get the file name of all the messages in that archive.
RETURN VALUE:
Pointer to the file name on success. Null if failed.
REMARKS:
Returns a pointer to the file name specified by unique message ID and sending user SID.
If the function fails the function returns NULL.
The caller must call MemFree to deallocate the returned string
*******************************************************************************/
LPWSTR
GetSentMessageFileName(
IN DWORDLONG dwlUniqueId,
IN PSID pSid
)
{
WCHAR wszFileName[MAX_PATH] = {0};
WCHAR wszFullPathFileName[MAX_PATH] = {0};
int Count;
DWORD dwCount;
DEBUG_FUNCTION_NAME(TEXT("GetSentMessageFileName"));
WCHAR wszArchiveFolder [MAX_PATH];
EnterCriticalSection (&g_CsConfig);
lstrcpyn (wszArchiveFolder, g_ArchivesConfig[FAX_MESSAGE_FOLDER_SENTITEMS].lpcstrFolder, MAX_PATH);
LeaveCriticalSection (&g_CsConfig);
if (pSid != NULL)
{
LPWSTR lpwstrFilePart;
LPWSTR lpwstrUserSid;
if (!ConvertSidToStringSid (pSid, &lpwstrUserSid))
{
DebugPrintEx(
DEBUG_ERR,
TEXT("ConvertSidToStringSid Failed, error : %ld"),
GetLastError());
return NULL;
}
Count = _snwprintf (wszFileName,
ARR_SIZE(wszFileName) -1,
L"%s$%I64x",
lpwstrUserSid,
dwlUniqueId);
if (Count < 0)
{
DebugPrintEx(
DEBUG_ERR,
TEXT("_snwprintf Failed, File name bigger than MAX_PATH"));
SetLastError (E_FAIL);
LocalFree (lpwstrUserSid);
return NULL;
}
LocalFree (lpwstrUserSid);
dwCount = SearchPath (wszArchiveFolder, // search path
wszFileName, // file name
FAX_TIF_FILE_DOT_EXT, // file extension
MAX_PATH, // size of buffer
wszFullPathFileName, // found file name buffer
&lpwstrFilePart // file component
);
if (0 == dwCount)
{
DebugPrintEx(
DEBUG_ERR,
TEXT("SearchPath Failed, Error %ld"), GetLastError());
return NULL;
}
if (dwCount > MAX_PATH)
{
DebugPrintEx(
DEBUG_ERR,
TEXT("SearchPath Failed, File name bigger than MAX_PATH"));
SetLastError (E_FAIL);
return NULL;
}
return StringDup (wszFullPathFileName);
}
else
{
HANDLE hSearch = INVALID_HANDLE_VALUE;
WIN32_FIND_DATA FindFileData;
DWORD ec = ERROR_SUCCESS;
Count = _snwprintf (wszFullPathFileName,
MAX_PATH -1,
L"%s\\*$%I64x.%s",
wszArchiveFolder,
dwlUniqueId,
FAX_TIF_FILE_EXT);
if (Count < 0)
{
DebugPrintEx(
DEBUG_ERR,
TEXT("_snwprintf Failed, File name bigger than MAX_PATH"));
SetLastError (E_FAIL);
return NULL;
}
hSearch = FindFirstFile (wszFullPathFileName, // file name
&FindFileData // data buffer
);
if (INVALID_HANDLE_VALUE == hSearch)
{
DebugPrintEx(
DEBUG_ERR,
TEXT("FindFirstFile Failed, error : %ld"),
GetLastError());
return NULL;
}
Count = _snwprintf (wszFullPathFileName,
MAX_PATH -1,
L"%s\\%s",
wszArchiveFolder,
FindFileData.cFileName);
if (Count < 0)
{
ec = E_FAIL;
DebugPrintEx(
DEBUG_ERR,
TEXT("_snwprintf Failed, File name bigger than MAX_PATH"));
}
if (!FindClose (hSearch))
{
ec = GetLastError();
DebugPrintEx(
DEBUG_ERR,
TEXT("FindClose Failed, error : %ld"),
ec);
}
if (ERROR_SUCCESS != ec)
{
SetLastError(ec);
return NULL;
}
return StringDup (wszFullPathFileName);
}
}
DWORD
IsValidArchiveFolder (
LPWSTR lpwstrFolder,
FAX_ENUM_MESSAGE_FOLDER Folder
)
/*++
Routine name : IsValidArchiveFolder
Routine description:
Validates a folder is good for archiving. Make sure to lock g_CsConfig
Author:
Eran Yariv (EranY), Nov, 1999
Arguments:
lpwstrFolder [in] - Folder in quetion
Folder [in] - 'Inbox' or 'Sent items'
Return Value:
Win32 error code. ERROR_SUCCESS if the folder can be used for archiving.
Otherwise, the Win32 error code to return to the caller.
--*/
{
DWORD dwLen;
DWORD ec = ERROR_SUCCESS;
BOOL IsSameDir;
FAX_ENUM_MESSAGE_FOLDER OtherFolder;
DEBUG_FUNCTION_NAME(TEXT("IsValidArchiveFolder"));
Assert (FAX_MESSAGE_FOLDER_SENTITEMS == Folder ||
FAX_MESSAGE_FOLDER_INBOX == Folder);
if ((NULL == lpwstrFolder) || (L'\0' == lpwstrFolder[0]))
{
DebugPrintEx(
DEBUG_ERR,
TEXT("Empty archive folder specified"));
return ERROR_INVALID_PARAMETER;
}
if ((dwLen = lstrlenW (lpwstrFolder)) > MAX_ARCHIVE_FOLDER_PATH)
{
DebugPrintEx(
DEBUG_ERR,
TEXT("DB file name exceeds MAX_PATH"));
return ERROR_BUFFER_OVERFLOW;
}
if (L'\\' == lpwstrFolder[dwLen - 1])
{
//
// Archive name should not end with a backslash.
//
lpwstrFolder[dwLen - 1] = (WCHAR)'\0';
}
//
// Compare Sent items and Inbox directory
//
if (FAX_MESSAGE_FOLDER_SENTITEMS == Folder)
{
OtherFolder = FAX_MESSAGE_FOLDER_INBOX;
}
else
{
OtherFolder = FAX_MESSAGE_FOLDER_SENTITEMS;
}
ec = IsValidFaxFolder(lpwstrFolder);
if(ERROR_SUCCESS != ec)
{
//
// The folder does not exist or we don't
// have access rights
//
DebugPrintEx( DEBUG_ERR,
TEXT("IsValidFaxFolder failed for folder : %s (ec=%lu)."),
lpwstrFolder,
ec);
return ec;
}
//
// Check Queue folder conflict
//
ec = CheckToSeeIfSameDir(
lpwstrFolder,
g_wszFaxQueueDir,
&IsSameDir);
if (ERROR_SUCCESS != ec)
{
DebugPrintEx(
DEBUG_ERR,
TEXT("CheckToSeeIfSameDir with %ld"), ec);
return ec;
}
if (TRUE == IsSameDir)
{
DebugPrintEx(
DEBUG_ERR,
TEXT("Inbox / Sent items point to the queue directory directory. %s and %s"),
lpwstrFolder,
g_wszFaxQueueDir);
return FAX_ERR_DIRECTORY_IN_USE;
}
if (g_ArchivesConfig[OtherFolder].bUseArchive)
{
//
// Check the other folder path
//
Assert (g_ArchivesConfig[OtherFolder].lpcstrFolder);
ec = CheckToSeeIfSameDir( lpwstrFolder,
g_ArchivesConfig[OtherFolder].lpcstrFolder,
&IsSameDir);
if (ERROR_SUCCESS != ec)
{
DebugPrintEx(
DEBUG_ERR,
TEXT("CheckToSeeIfSameDir with %ld"), ec);
return ec;
}
if (TRUE == IsSameDir)
{
DebugPrintEx(
DEBUG_ERR,
TEXT("Inbox and Sent items point to the same directory. %s and %s"),
lpwstrFolder,
g_ArchivesConfig[OtherFolder].lpcstrFolder);
return FAX_ERR_DIRECTORY_IN_USE;
}
}
Assert (ERROR_SUCCESS == ec);
return ERROR_SUCCESS;
} // IsValidArchiveFolder
BOOL
GetMessageIdAndUserSid (
LPCWSTR lpcwstrFullPathFileName,
FAX_ENUM_MESSAGE_FOLDER Folder,
PSID* lppUserSid,
DWORDLONG* pdwlMessageId
/*++
Routine name : GetSentMessageUserSid
Routine description:
Returns the user sid associated with a sent message - optional.
Returns the message unique id - optional.
The caller must call LocalFree to deallocate the SID bufffer
Author:
Oded Sacher (OdedS), Jan, 2000
Arguments:
lpcwstrFullPathFileName [in] - The message full path name .
Folder [in] - Specifies if it is sent or received message.
lppUserSid [out] - Address of a pointer to SID to receive the user sid.
pdwlMessageId [out] - Address of a DWORDLONG to receive the message id.
Return Value:
BOOL
--*/
)
{
WCHAR wszUserSid[MAX_PATH] = {0};
LPCWSTR lpcwstrFileName = NULL;
DWORDLONG dwlMessageId;
DEBUG_FUNCTION_NAME(TEXT("GetSentMessageUserSid"));
Assert (lpcwstrFullPathFileName && (wcslen(lpcwstrFullPathFileName) < 2*MAX_PATH));
lpcwstrFileName = wcsrchr (lpcwstrFullPathFileName, L'\\');
if (NULL == lpcwstrFileName)
{
DebugPrintEx(
DEBUG_ERR,
TEXT("Bad file name (No '\\' delimitor found)"));
SetLastError (ERROR_INVALID_PARAMETER);
ASSERT_FALSE;
return FALSE;
}
lpcwstrFileName++;
if (FAX_MESSAGE_FOLDER_SENTITEMS == Folder)
{
if (2 != swscanf (lpcwstrFileName,
L"%[^'$']$%I64x.TIF",
wszUserSid,
&dwlMessageId))
{
DebugPrintEx(
DEBUG_ERR,
TEXT("Bad sent items file name"));
SetLastError (ERROR_BADDB);
return FALSE;
}
}
else
{
// Inbox
Assert (FAX_MESSAGE_FOLDER_INBOX == Folder);
if (1 != swscanf (lpcwstrFileName,
L"%I64x.TIF",
&dwlMessageId))
{
DebugPrintEx(
DEBUG_ERR,
TEXT("Bad inbox file name"));
SetLastError (ERROR_BADDB);
return FALSE;
}
}
if (NULL != lppUserSid)
{
Assert (FAX_MESSAGE_FOLDER_SENTITEMS == Folder);
if (!ConvertStringSidToSid (wszUserSid, lppUserSid))
{
DWORD dwRes = GetLastError();
DebugPrintEx(
DEBUG_ERR,
TEXT("ConvertStringSidToSid failed with %ld"), dwRes);
return FALSE;
}
}
if (NULL != pdwlMessageId)
{
*pdwlMessageId = dwlMessageId;
}
return TRUE;
}
BOOL
ArchiveAutoDelete(
LPCWSTR lpcwstrArchive,
DWORD dwAgeLimit,
FAX_ENUM_MESSAGE_FOLDER Folder
)
/*++
Routine name : ArchiveAutoDelete
Routine description:
Automatically deletes any files that are older than the age limit specified in days.
Author:
Oded Sacher (OdedS), Feb, 2000
Arguments:
lpcwstrArchive [in] - Full path to the archive folder to search for files to delete.
dwAgeLimit [in] - The files age limit specified in days, any file older than the limit will be deleted.
Folder [in] - Specifies if it is inbox or sent items folder
Return Value:
BOOL , Call GetLastError() for additional info.
--*/
{
DWORD dwRes = ERROR_NO_MORE_FILES;
DEBUG_FUNCTION_NAME(TEXT("ArchiveAutoDelete"));
WIN32_FIND_DATA FindFileData;
HANDLE hFind;
Assert (lpcwstrArchive && dwAgeLimit);
WCHAR szFileName[MAX_PATH*2] = {0};
BOOL bAnyDeleted = FALSE;
wsprintf( szFileName, TEXT("%s\\*.TIF"), lpcwstrArchive );
hFind = FindFirstFile( szFileName, &FindFileData );
if (hFind == INVALID_HANDLE_VALUE)
{
//
// No files found at archive dir
//
dwRes = GetLastError();
if (ERROR_FILE_NOT_FOUND != dwRes)
{
DebugPrintEx( DEBUG_WRN,
TEXT("FindFirstFile failed (ec = %ld) for archive dir %s"),
GetLastError(),
lpcwstrArchive);
return FALSE;
}
return TRUE;
}
do
{
//
// Get rid of old files
//
FILETIME CurrentTime;
DWORDLONG dwlAgeLimit, dwlCurrentTime, dwlFileTime;
GetSystemTimeAsFileTime (&CurrentTime);
dwlCurrentTime = MAKELONGLONG(CurrentTime.dwLowDateTime,
CurrentTime.dwHighDateTime);
dwlAgeLimit = MAKELONGLONG(dwAgeLimit, 0);
dwlAgeLimit = (dwlAgeLimit * 24 * 60 * 60 * 10000000);
dwlFileTime = MAKELONGLONG(FindFileData.ftCreationTime.dwLowDateTime,
FindFileData.ftCreationTime.dwHighDateTime);
if ( (dwlCurrentTime - dwlFileTime) > dwlAgeLimit)
{
// Old file - delete it
wsprintf( szFileName, TEXT("%s\\%s"), lpcwstrArchive, FindFileData.cFileName );
if (!DeleteFile (szFileName))
{
DebugPrintEx(
DEBUG_ERR,
TEXT("DeleteFile [FileName %s], Failed with %ld"),
szFileName,
GetLastError());
}
else
{
//
// Files were deleted - Send event to the registered clients
//
DWORD rVal = ERROR_SUCCESS;
PSID lpUserSid = NULL;
FAX_ENUM_EVENT_TYPE EventType;
DWORDLONG dwlMessageId;
PSID* lppUserSid = NULL;
bAnyDeleted = TRUE; // Refresh Archive size
if (FAX_MESSAGE_FOLDER_INBOX == Folder)
{
EventType = FAX_EVENT_TYPE_IN_ARCHIVE;
}
else
{
EventType = FAX_EVENT_TYPE_OUT_ARCHIVE;
lppUserSid = &lpUserSid;
}
if (!GetMessageIdAndUserSid (szFileName, Folder, lppUserSid, &dwlMessageId))
{
rVal = GetLastError();
DebugPrintEx(DEBUG_ERR,
TEXT("GetMessageIdAndUserSid Failed, Error : %ld"),
rVal);
}
if (ERROR_SUCCESS == rVal)
{
rVal = CreateArchiveEvent (dwlMessageId, EventType, FAX_JOB_EVENT_TYPE_REMOVED, lpUserSid);
if (ERROR_SUCCESS != rVal)
{
DebugPrintEx(
DEBUG_ERR,
TEXT("CreateConfigEvent(FAX_CONFIG_TYPE_*_ARCHIVE) failed (ec: %lc)"),
rVal);
}
}
if (NULL != lpUserSid)
{
LocalFree (lpUserSid);
lpUserSid = NULL;
}
}
}
} while(FindNextFile( hFind, &FindFileData ));
dwRes = GetLastError();
if (ERROR_NO_MORE_FILES != dwRes)
{
DebugPrintEx( DEBUG_ERR,
TEXT("FindNextFilefaild with ec=%ld, at archive dir %s"),
dwRes,
lpcwstrArchive);
}
if (!FindClose(hFind))
{
DebugPrintEx( DEBUG_ERR,
TEXT("FindClose with ec=%ld, at archive dir %s"),
dwRes,
lpcwstrArchive);
}
if (TRUE == bAnyDeleted)
{
//
// Refresh archive size
//
EnterCriticalSection (&g_CsConfig);
g_ArchivesConfig[Folder].dwlArchiveSize = FAX_ARCHIVE_FOLDER_INVALID_SIZE;
LeaveCriticalSection (&g_CsConfig);
//
// Wake up quota warning thread
//
if (!SetEvent (g_hArchiveQuotaWarningEvent))
{
DebugPrintEx(
DEBUG_ERR,
TEXT("Failed to set quota warning event, SetEvent failed (ec: %lc)"),
GetLastError());
}
}
return (ERROR_NO_MORE_FILES == dwRes);
} //ArchiveAutoDelete
BOOL
GetArchiveSize(
LPCWSTR lpcwstrArchive,
DWORDLONG* lpdwlArchiveSize
)
/*++
Routine name : GetArchiveSize
Routine description:
Returnes the archive folder total size in bytes.
Author:
Oded Sacher (OdedS), Feb, 2000
Arguments:
lpcwstrArchive [in ] - Full path to the archive folder.
lpdwlArchiveSize [out] - Pointer to a DWORDLONG to receive the archive folder size.
Return Value:
BOOL , Call GetLastError() for additional info.
--*/
{
DWORD dwRes = ERROR_NO_MORE_FILES;
DEBUG_FUNCTION_NAME(TEXT("GetArchiveSize"));
WIN32_FIND_DATA FindFileData;
HANDLE hFind;
DWORDLONG dwlArchiveSize = 0;
Assert (lpcwstrArchive && lpdwlArchiveSize);
WCHAR szFileName[MAX_PATH*2] = {0};
wsprintf( szFileName, TEXT("%s\\*.*"), lpcwstrArchive );
hFind = FindFirstFile( szFileName, &FindFileData );
if (hFind == INVALID_HANDLE_VALUE)
{
//
// No files found at archive dir
//
DebugPrintEx( DEBUG_WRN,
TEXT("FindFirstFile failed (ec = %ld) for archive dir %s"),
GetLastError(),
lpcwstrArchive);
return FALSE;
}
do
{
dwlArchiveSize += (MAKELONGLONG(FindFileData.nFileSizeLow ,FindFileData.nFileSizeHigh));
} while(FindNextFile( hFind, &FindFileData ));
dwRes = GetLastError();
if (ERROR_NO_MORE_FILES != dwRes)
{
DebugPrintEx( DEBUG_ERR,
TEXT("FindNextFilefaild with ec=%ld, at archive dir %s"),
dwRes,
lpcwstrArchive);
}
if (!FindClose(hFind))
{
DebugPrintEx( DEBUG_ERR,
TEXT("FindClose with ec=%ld, at archive dir %s"),
dwRes,
lpcwstrArchive);
}
if (ERROR_NO_MORE_FILES == dwRes)
{
*lpdwlArchiveSize = dwlArchiveSize;
return TRUE;
}
return FALSE;
} //GetArchiveSize
DWORD
FaxArchiveQuotaWarningThread(
LPVOID UnUsed
)
/*++
Routine Description:
This fuction runs as a separate thread to
watch the archives quota and send event to the event log
Arguments:
UnUsed - UnUsed pointer
Return Value:
Always zero.
--*/
{
DEBUG_FUNCTION_NAME(TEXT("FaxArchiveQuotaWarningThread"));
DWORD dwCount[2] = {QUOTA_REFRESH_COUNT, QUOTA_REFRESH_COUNT};
HANDLE Handles[2];
Assert (g_hArchiveQuotaWarningEvent && g_hServiceShutDownEvent);
Handles[0] = g_hArchiveQuotaWarningEvent;
Handles[1] = g_hServiceShutDownEvent;
for (;;)
{
for (DWORD i = 0; i < 2; i++)
{
WCHAR wszArchive[MAX_PATH] = {0};
DWORDLONG dwlArchiveSize;
DWORDLONG dwlHighMark, dwlLowMark;
BOOL bLoggedQuotaEvent;
EnterCriticalSection (&g_CsConfig);
if (TRUE == g_ArchivesConfig[i].bUseArchive &&
TRUE == g_ArchivesConfig[i].bSizeQuotaWarning)
{
//
// The user asked for archive monitoring
//
Assert (g_ArchivesConfig[i].lpcstrFolder);
dwlHighMark = MAKELONGLONG(g_ArchivesConfig[i].dwSizeQuotaHighWatermark, 0);
dwlHighMark = (dwlHighMark << 20); // convert MB to bytes
dwlLowMark = MAKELONGLONG(g_ArchivesConfig[i].dwSizeQuotaLowWatermark, 0);
dwlLowMark = (dwlLowMark << 20); // convert MB to bytes
wcscpy (wszArchive, g_ArchivesConfig[i].lpcstrFolder);
bLoggedQuotaEvent = g_FaxQuotaWarn[i].bLoggedQuotaEvent;
dwlArchiveSize = g_ArchivesConfig[i].dwlArchiveSize;
g_FaxQuotaWarn[i].bConfigChanged = FALSE; // We will check this flag if we need to update g_ArchivesConfig
}
else
{
// do not warn
LeaveCriticalSection (&g_CsConfig);
continue;
}
LeaveCriticalSection (&g_CsConfig);
// The client asked for quota warnings
//
// Compare archive size and water mark
//
if (FAX_ARCHIVE_FOLDER_INVALID_SIZE == dwlArchiveSize ||
dwCount[i] >= QUOTA_REFRESH_COUNT)
{
//
// We want to refresh the archive size
//
//
// Check if service is going down before starting to delete
//
if (TRUE == g_bServiceIsDown)
{
//
// Server is shutting down - Do not refresh archives size
//
DebugPrintEx(
DEBUG_WRN,
TEXT("Server is shutting down - Do not refresh archives size"));
break;
}
if (!GetArchiveSize (wszArchive, &dwlArchiveSize))
{
DebugPrintEx( DEBUG_ERR,
TEXT("GetArchiveSize with ec=%ld, at archive dir %s"),
GetLastError(),
wszArchive);
continue;
}
else
{
// Update folder size
EnterCriticalSection (&g_CsConfig);
if (FALSE == g_FaxQuotaWarn[i].bConfigChanged)
{
// The configuration did not change - we can update g_ArchivesConfig
g_ArchivesConfig[i].dwlArchiveSize = dwlArchiveSize;
}
LeaveCriticalSection (&g_CsConfig);
dwCount[i] = 0;
}
}
if (FALSE == bLoggedQuotaEvent)
{
//We did not logged an archive quota warning yet
if (dwlArchiveSize > dwlHighMark)
{
//
// Create event log
//
if (FAX_MESSAGE_FOLDER_INBOX == i)
{
DWORD dwHighMark = (DWORD)(dwlHighMark >> 20); // size in MB
FaxLog(
FAXLOG_CATEGORY_INBOUND,
FAXLOG_LEVEL_MED,
2,
MSG_FAX_EXEEDED_INBOX_QUOTA,
wszArchive,
DWORD2DECIMAL(dwHighMark)
);
}
else
{
Assert (FAX_MESSAGE_FOLDER_SENTITEMS == i);
DWORD dwHighMark = (DWORD)(dwlHighMark >> 20); // size in MB
FaxLog(
FAXLOG_CATEGORY_OUTBOUND,
FAXLOG_LEVEL_MED,
2,
MSG_FAX_EXEEDED_SENTITEMS_QUOTA,
wszArchive,
DWORD2DECIMAL(dwHighMark)
);
}
EnterCriticalSection (&g_CsConfig);
if (FALSE == g_FaxQuotaWarn[i].bConfigChanged)
{
// The configuration did not change - we can update g_ArchivesConfig
g_FaxQuotaWarn[i].bLoggedQuotaEvent = TRUE;
}
LeaveCriticalSection (&g_CsConfig);
}
}
else
{
// An archive quota warning was already logged
if (dwlArchiveSize < dwlLowMark)
{
EnterCriticalSection (&g_CsConfig);
if (FALSE == g_FaxQuotaWarn[i].bConfigChanged)
{
// The configuration did not change - we can update g_ArchivesConfig
g_FaxQuotaWarn[i].bLoggedQuotaEvent = FALSE;
}
LeaveCriticalSection (&g_CsConfig);
}
}
dwCount[i] ++;
} // end of for loop
DWORD dwWaitRes = WaitForMultipleObjects( 2, Handles, FALSE, QUOTA_WARNING_TIME_OUT);
if (WAIT_FAILED == dwWaitRes)
{
DebugPrintEx(
DEBUG_ERR,
TEXT("WaitForMultipleObjects() failed, (LastErorr: %ld)"),
GetLastError());
}
else
{
DebugPrintEx(
DEBUG_MSG,
TEXT("WaitForMultipleObjects() returned Wait result: %ld)"),
dwWaitRes);
}
if ((dwWaitRes - WAIT_OBJECT_0) == 1)
{
//
// We got the service shut down event
//
DebugPrintEx(
DEBUG_MSG,
TEXT("Service is shutting down"));
break;
}
} // end of outer for(;;) loop
if (!DecreaseServiceThreadsCount())
{
DebugPrintEx(
DEBUG_ERR,
TEXT("DecreaseServiceThreadsCount() failed (ec: %ld)"),
GetLastError());
}
return ERROR_SUCCESS;
} // FaxArchiveQuotaWarningThread
DWORD
FaxArchiveQuotaAutoDeleteThread(
LPVOID UnUsed
)
/*++
Routine Description:
This fuction runs as a separate thread to
watch the archives quota and automaticlly delete old files
Arguments:
UnUsed - UnUsed pointer
Return Value:
Always zero.
--*/
{
DEBUG_FUNCTION_NAME(TEXT("FaxArchiveQuotaAutoDeleteThread"));
Assert(g_hServiceShutDownEvent);
for (;;)
{
for (DWORD i = 0; i < 2; i++)
{
WCHAR wszArchive[MAX_PATH] = {0};
DWORD dwAgeLimit;
EnterCriticalSection (&g_CsConfig);
if (TRUE == g_ArchivesConfig[i].bUseArchive &&
0 != g_ArchivesConfig[i].dwAgeLimit)
{
//
// The user asked for archive auto delete
//
Assert (g_ArchivesConfig[i].lpcstrFolder);
wcscpy (wszArchive, g_ArchivesConfig[i].lpcstrFolder);
dwAgeLimit = g_ArchivesConfig[i].dwAgeLimit;
}
else
{
// Do not auto delete
LeaveCriticalSection (&g_CsConfig);
continue;
}
LeaveCriticalSection (&g_CsConfig);
//
// Check if service is going down before starting to delete
//
if (TRUE == g_bServiceIsDown)
{
//
// Server is shutting down - Do not auto delete archives
//
DebugPrintEx(
DEBUG_WRN,
TEXT("Server is shutting down - Do not auto delete archives"));
break;
}
if (!ArchiveAutoDelete (wszArchive, dwAgeLimit, (FAX_ENUM_MESSAGE_FOLDER)i))
{
DWORD dwRes = GetLastError();
DebugPrintEx( DEBUG_ERR,
TEXT("ArchiveAutoDelete with ec=%ld, at archive dir %s"),
dwRes,
wszArchive);
}
} // end of inner for loop
DWORD dwWaitRes = WaitForSingleObject( g_hServiceShutDownEvent, QUOTA_AUTO_DELETE_TIME_OUT);
if (WAIT_FAILED == dwWaitRes)
{
DebugPrintEx(
DEBUG_ERR,
TEXT("WaitForSingleObject() failed, (LastErorr: %ld)"),
GetLastError());
}
else
{
DebugPrintEx(
DEBUG_MSG,
TEXT("WaitForSingleObject() returned Wait result: %ld)"),
dwWaitRes);
}
if (WAIT_OBJECT_0 == dwWaitRes)
{
//
// We got the service shut down event
//
DebugPrintEx(
DEBUG_MSG,
TEXT("Service is shutting down"));
break;
}
} // end of outer for loop
if (!DecreaseServiceThreadsCount())
{
DebugPrintEx(
DEBUG_ERR,
TEXT("DecreaseServiceThreadsCount() failed (ec: %ld)"),
GetLastError());
}
return ERROR_SUCCESS;
} // FaxArchiveQuotaAutoDeleteThread
DWORD
InitializeServerQuota ()
/*++
Routine name : InitializeServerQuota
Routine description:
Creates the threads that watches the archives quota
Author:
Oded Sacher (OdedS), Jan, 2000
Arguments:
Return Value:
Standard Win32 error code
--*/
{
DWORD dwRes = ERROR_SUCCESS;
DEBUG_FUNCTION_NAME(TEXT("InitializeServerQuota"));
DWORD ThreadId;
HANDLE hQuotaWarningThread = NULL;
HANDLE hQuotaAutoDeleteThread = NULL;
//
// Create Archive Config events
//
g_hArchiveQuotaWarningEvent = CreateEvent( NULL, // Secutity descriptor
FALSE, // flag for manual-reset event
FALSE, // flag for initial state
NULL // pointer to event-object name
);
if (NULL == g_hArchiveQuotaWarningEvent)
{
dwRes = GetLastError();
DebugPrintEx(
DEBUG_ERR,
TEXT("Failed to create archive config event - quota warning (CreateEvent) (ec=0x%08x)."),
dwRes);
goto exit;
}
//
// Initialize Archive folders sizes
//
Assert (g_ArchivesConfig[FAX_MESSAGE_FOLDER_INBOX].lpcstrFolder);
g_ArchivesConfig[FAX_MESSAGE_FOLDER_INBOX].dwlArchiveSize = FAX_ARCHIVE_FOLDER_INVALID_SIZE;
if (TRUE == g_ArchivesConfig[FAX_MESSAGE_FOLDER_INBOX].bUseArchive)
{
//
// Archive is in use
//
//
// Check archive folder validity
//
DWORD dwRet = IsValidArchiveFolder(g_ArchivesConfig[FAX_MESSAGE_FOLDER_INBOX].lpcstrFolder,FAX_MESSAGE_FOLDER_INBOX);
if(ERROR_SUCCESS != dwRet)
{
//
// The folder is not valid for archiving
//
DebugPrintEx( DEBUG_ERR,
TEXT("IsValidArchiveFolder failed for folder : %s (ec=%lu)."),
g_ArchivesConfig[FAX_MESSAGE_FOLDER_INBOX].lpcstrFolder,
dwRet);
//
// Log event and disable - receive and routing activity - for inbox
//
FaxLog( FAXLOG_CATEGORY_INIT,
FAXLOG_LEVEL_MIN,
1,
MSG_FAX_ARCHIVE_INBOX_FOLDER_ERR,
g_ArchivesConfig[FAX_MESSAGE_FOLDER_INBOX].lpcstrFolder,
DWORD2DECIMAL(dwRet)
);
EnterCriticalSection (&g_CsConfig);
g_dwQueueState |= FAX_INCOMING_BLOCKED;
LeaveCriticalSection (&g_CsConfig);
}
else
if (!GetArchiveSize (g_ArchivesConfig[FAX_MESSAGE_FOLDER_INBOX].lpcstrFolder, &g_ArchivesConfig[FAX_MESSAGE_FOLDER_INBOX].dwlArchiveSize))
{
DebugPrintEx( DEBUG_ERR,
TEXT("GetArchiveSize with ec=%ld, at archive dir %s"),
GetLastError(),
g_ArchivesConfig[FAX_MESSAGE_FOLDER_INBOX].lpcstrFolder);
}
}
Assert (g_ArchivesConfig[FAX_MESSAGE_FOLDER_SENTITEMS].lpcstrFolder);
g_ArchivesConfig[FAX_MESSAGE_FOLDER_SENTITEMS].dwlArchiveSize = FAX_ARCHIVE_FOLDER_INVALID_SIZE;
if (TRUE == g_ArchivesConfig[FAX_MESSAGE_FOLDER_SENTITEMS].bUseArchive)
{
//
// Archive is in use
//
//
// Check archive folder validity
//
DWORD dwRet = IsValidArchiveFolder(g_ArchivesConfig[FAX_MESSAGE_FOLDER_SENTITEMS].lpcstrFolder,FAX_MESSAGE_FOLDER_SENTITEMS);
if(ERROR_SUCCESS != dwRet)
{
//
// The folder is not valid for archiving
//
DebugPrintEx( DEBUG_ERR,
TEXT("IsValidArchiveFolder failed for folder : %s (ec=%lu)."),
g_ArchivesConfig[FAX_MESSAGE_FOLDER_SENTITEMS].lpcstrFolder,
dwRet);
//
// Log event and disable - submission and send activity - for outbox
//
FaxLog( FAXLOG_CATEGORY_INIT,
FAXLOG_LEVEL_MIN,
1,
MSG_FAX_ARCHIVE_OUTBOX_FOLDER_ERR,
g_ArchivesConfig[FAX_MESSAGE_FOLDER_SENTITEMS].lpcstrFolder
);
EnterCriticalSection (&g_CsConfig);
g_dwQueueState |= FAX_OUTBOX_BLOCKED | FAX_OUTBOX_PAUSED;
LeaveCriticalSection (&g_CsConfig);
}
else
if (!GetArchiveSize (g_ArchivesConfig[FAX_MESSAGE_FOLDER_SENTITEMS].lpcstrFolder, &g_ArchivesConfig[FAX_MESSAGE_FOLDER_SENTITEMS].dwlArchiveSize))
{
DebugPrintEx( DEBUG_ERR,
TEXT("GetArchiveSize with ec=%ld, at archive dir %s"),
GetLastError(),
g_ArchivesConfig[FAX_MESSAGE_FOLDER_SENTITEMS].lpcstrFolder);
}
}
//
// Create the archives quata warning thread
//
hQuotaWarningThread = CreateThreadAndRefCount(
NULL,
0,
(LPTHREAD_START_ROUTINE) FaxArchiveQuotaWarningThread,
NULL,
0,
&ThreadId
);
if (!hQuotaWarningThread)
{
dwRes = GetLastError();
DebugPrintEx(
DEBUG_ERR,
TEXT("Failed to create quota warning thread (CreateThreadAndRefCount) (ec=0x%08x)."),
dwRes);
goto exit;
}
//
// Create the archives quata auto delete thread
//
hQuotaAutoDeleteThread = CreateThreadAndRefCount(
NULL,
0,
(LPTHREAD_START_ROUTINE) FaxArchiveQuotaAutoDeleteThread,
NULL,
0,
&ThreadId
);
if (!hQuotaAutoDeleteThread)
{
dwRes = GetLastError();
DebugPrintEx(
DEBUG_ERR,
TEXT("Failed to create quota auto delete thread (CreateThreadAndRefCount) (ec=0x%08x)."),
dwRes);
goto exit;
}
Assert (ERROR_SUCCESS == dwRes);
exit:
//
// Close the thread handle we no longer need it
//
if (NULL != hQuotaWarningThread)
{
if (!CloseHandle(hQuotaWarningThread))
{
DebugPrintEx(
DEBUG_ERR,
TEXT("Failed to close quota warning thread handle [handle = %p] (ec=0x%08x)."),
hQuotaWarningThread,
GetLastError());
}
}
if (NULL != hQuotaAutoDeleteThread)
{
if (!CloseHandle(hQuotaAutoDeleteThread))
{
DebugPrintEx(
DEBUG_ERR,
TEXT("Failed to close quota auto delete thread handle [handle = %p] (ec=0x%08x)."),
hQuotaAutoDeleteThread,
GetLastError());
}
}
if (ERROR_SUCCESS != dwRes)
{
if (NULL != g_hArchiveQuotaWarningEvent)
{
if (!CloseHandle(g_hArchiveQuotaWarningEvent))
{
DebugPrintEx(
DEBUG_ERR,
TEXT("Failed to close archive config event handle - quota warnings [handle = %p] (ec=0x%08x)."),
g_hArchiveQuotaWarningEvent,
GetLastError());
}
g_hArchiveQuotaWarningEvent = NULL;
}
}
return dwRes;
} // InitializeServerQuota