{

printf("SysmonLogView v1.0 - Converts Sysmon syslog XML to human readable form\n");

printf("Sysinternals - www.sysinternals.com\n");

printf("By Kevin Sheldrake\n");

printf("Copyright (C) 2021 Microsoft Corporation\n");

printf("\n");

printf("Usage:\n");

printf(" sysmonLogView [<options>]\n");

printf(" -e Only display events with matching eventID. Specify comma-separated list\n");

printf(" of eventIDs and/or multiple -e switches.\n");

printf(" -r Only display events within the specified range of recordIDs. Specify\n");

printf(" min,max. If min is missing, start from the beginning; if end is missing,\n");

printf(" continue to end.\n");

printf(" -t Only display events within the specified time stamps. Specify start,end.\n");

printf(" Time format is YYYY-MM-DD HH:MM[:SS[.nnn]] where nnn is milliseconds.\n");

printf(" If start is missing, start at beginning; if end is missing, continue to\n");

printf(" the end.\n");

printf(" -f For events that have a particular field, only display events that match\n");

printf(" the given value (case sensitive). e.g. '-f Image=/bin/touch'\n");

printf(" -E Only display the specified fields for the specified event. Specify\n");

printf(" <eventID>=<comma-separated list of fields>. Can use multiple times.\n");

printf(" -X Print a blank link between events.\n");

printf(" -h Display this help.\n");

printf(" -? Display this help.\n");

printf("\n");

printf("Supply input data on standard input; writes to standard output. By default all\n");

printf("events are displayed but switches can be used to only display certain events,\n");

printf("and to only display certain fields within the events that are displayed.\n");

printf("\n");

printf("Wrap arguments in quotes (e.g. \"<argument>\") if argument contains spaces.\n");

printf("\n");

printf("Typical usage:\n");

printf(" sudo tail -f /var/log/syslog | sudo /opt/sysmon/sysmonLogView\n");

printf("\n");

{

unordered_set<unsigned int> event;

if (s == NULL) {

fprintf(stderr, "getEventId invalid params\n");

return event;

}

char *t = NULL;

char *ctx = NULL;

t = strtok_r(s, ",", &ctx);

if (t == NULL)

return event;

event.insert(strtoul(t, NULL, 0));

while ((t = strtok_r(NULL, ",", &ctx)) != NULL) {

event.insert(strtoul(t, NULL, 0));

}

return event;

{

pair<unsigned int, unordered_set<string>> eventField;

if (s == NULL) {

fprintf(stderr, "getEventIdField invalid params\n");

return eventField;

}

char *t = NULL;

char *ctx = NULL;

t = strtok_r(s, "=", &ctx);

if (t == NULL)

return eventField;

eventField.first = strtoul(t, NULL, 0);

while ((t = strtok_r(NULL, ",", &ctx)) != NULL) {

eventField.second.insert(string(t));

}

return eventField;

{

pair<unsigned long, unsigned long> range(-1, -1);

if (s == NULL) {

fprintf(stderr, "getRecordIdRange invalid paramsn\n");

return range;

}

char *t = NULL;

char *ctx = NULL;

bool emptyFirst = false;

if (*s == ',')

emptyFirst = true;

t = strtok_r(s, ",", &ctx);

if (t == NULL)

return range;

if (emptyFirst) {

range.second = strtoul(t, NULL, 10);

return range;

}

range.first = strtoul(t, NULL, 10);

t = strtok_r(NULL, ",", &ctx);

if (t != NULL)

range.second = strtoul(t, NULL, 10);

return range;

{

if (t == NULL) {

fprintf(stderr, "tmToUl invalid params\n");

return 0;

}

return ((unsigned long)mktime(t) * 1000) + ms;

{

if (s == NULL) {

fprintf(stderr, "timeStrToUl invalid params\n");

return 0;

}

struct tm time_s;

char *remain = NULL;

memset(&time_s, 0, sizeof(time_s));

remain = strptime(s, "%F %H:%M", &time_s);

if (remain == NULL)

return -1;

if (*remain != ':')

return tmToUl(&time_s, 0);

remain = strptime(remain+1, "%S", &time_s);

if (remain == NULL || *remain != '.')

return tmToUl(&time_s, 0);

return tmToUl(&time_s, strtoul(remain+1, NULL, 10));

{

if (s == NULL) {

fprintf(stderr, "systemTimeStrToUl invalid params\n");

return 0;

}

struct tm time_s;

char *remain = NULL;

memset(&time_s, 0, sizeof(time_s));

remain = strptime(s, "%FT%H:%M:%S", &time_s);

if (remain == NULL || *remain != '.')

return -1;

return tmToUl(&time_s, strtoul(remain+1, NULL, 10) / (1000 * 1000));

{

pair<unsigned long, unsigned long> range(-1, -1);

if (s == NULL) {

fprintf(stderr, "getTimeRange invalid params\n");

return range;

}

char *t = NULL;

char *ctx = NULL;

bool emptyFirst = false;

if (*s == ',')

emptyFirst = true;

t = strtok_r(s, ",", &ctx);

if (t == NULL)

return range;

if (emptyFirst) {

range.second = timeStrToUl(t);

return range;

}

range.first = timeStrToUl(t);

t = strtok_r(NULL, ",", &ctx);

if (t != NULL)

range.second = timeStrToUl(t);

return range;

{

pair<string, unordered_set<string>> filter;

if (s == NULL) {

fprintf(stderr, "getFilter invalid params\n");

return filter;

}

char *t = NULL;

char *ctx = NULL;

t = strtok_r(s, "=", &ctx);

if (t == NULL)

return filter;

filter.first = t;

while ((t = strtok_r(NULL, ",", &ctx)) != NULL) {

filter.second.insert(string(t));

}

return filter;

unordered_set<unsigned int> *eventIds,

unordered_map<unsigned int, unordered_set<string>> *eventIdFields,

pair<unsigned long, unsigned long> *recordIdRange,

pair<unsigned long, unsigned long> *timeRange,

unordered_map<string, unordered_set<string>> *filters,

bool *extraCR

)

{

if (argv == NULL || eventIds == NULL || eventIdFields == NULL ||

recordIdRange == NULL || timeRange == NULL || filters == NULL

|| extraCR == NULL) {

fprintf(stderr, "processCmdline invalid params\n");

return;

}

int c;

while ((c = getopt(argc, argv, "h?e:r:t:f:E:XT")) != -1) {

switch (c) {

case 'e':

{

unordered_set<unsigned int> newEventId = getEventId(optarg);

eventIds->insert(newEventId.begin(), newEventId.end());

break;

}

case 'r':

{

pair<unsigned long, unsigned long> newRecordIdRange = getRecordIdRange(optarg);

if (newRecordIdRange.first != (unsigned long)-1)

recordIdRange->first = newRecordIdRange.first;

if (newRecordIdRange.second != (unsigned long)-1)

recordIdRange->second = newRecordIdRange.second;

break;

}

case 't':

{

pair<unsigned long, unsigned long> newTimeRange = getTimeRange(optarg);

if (newTimeRange.first != (unsigned long)-1)

timeRange->first = newTimeRange.first;

if (newTimeRange.second != (unsigned long)-1)

timeRange->second = newTimeRange.second;

break;

}

case 'f':

{

pair<string, unordered_set<string>> newFilter = getFilter(optarg);

if (!newFilter.first.empty() && !newFilter.second.empty()) {

auto it = filters->find(newFilter.first);

if (it != filters->end()) {

it->second.insert(newFilter.second.begin(), newFilter.second.end());

} else {

filters->insert(newFilter);

}

}

break;

}

case 'E':

{

pair<unsigned int, unordered_set<string>> newEventIdField = getEventIdField(optarg);

auto it = eventIdFields->find(newEventIdField.first);

if (it != eventIdFields->end()) {

it->second.insert(newEventIdField.second.begin(), newEventIdField.second.end());

} else {

eventIdFields->insert(newEventIdField);

}

break;

}

case 'X':

*extraCR = true;

break;

case 'T': // print out the switch settings processed up to this point

{

printf("Event Ids: ");

for (const auto it : *eventIds) {

printf("%d ", it);

}

printf("\n");

printf("Event Id Fields:\n");

for (const auto& it : *eventIdFields) {

printf(" %d (", it.first);

for (const auto& it2 : it.second) {

printf("%s ", it2.c_str());

}

printf(")\n");

}

printf("\n");

printf("Record Id range = %ld, %ld\n", recordIdRange->first, recordIdRange->second);

printf("Time range = ");

char timeMinS[128], timeMaxS[128];

struct tm tmMin, tmMax;

time_t timeMin, timeMax;

if (timeRange->first != (unsigned long)-1) {

timeMin = timeRange->first / 1000;

gmtime_r(&timeMin, &tmMin);

strftime(timeMinS, 128, "%F %T", &tmMin);

printf("%s.%03ld - ", timeMinS, timeRange->first % 1000);

} else {

printf("-1 - ");

}

if (timeRange->second != (unsigned long)-1) {

timeMax = timeRange->second / 1000;

gmtime_r(&timeMax, &tmMax);

strftime(timeMaxS, 128, "%F %T", &tmMax);

printf("%s.%03ld\n", timeMaxS, timeRange->second % 1000);

} else {

printf("-1\n");

}

printf("Filters:\n");

for (const auto& it2 : *filters) {

printf(" %s:\n", it2.first.c_str());

for (const auto& it3 : it2.second) {

printf(" %s\n", it3.c_str());

}

}

exit(0);

}

case 'h':

case '?':

default:

usage();

exit(0);

}

}

{

if ((range.first != (unsigned long)-1 && range.first > value) ||

(range.second != (unsigned long)-1 && range.second < value)) {

return false;

}

return true;

{

unordered_set<unsigned int> eventIds;

unordered_map<unsigned int, unordered_set<string>> eventIdFields;

pair<unsigned long, unsigned long> recordIdRange(-1, -1);

pair<unsigned long, unsigned long> timeRange(-1, -1); // time in ms since epoch

unordered_map<string, unordered_set<string>> filters;

bool extraCR = false;

char *line = NULL;

size_t line_len = 0;

const char *ptr = NULL;

xmlDoc *doc;

xmlXPathContextPtr xpathCtx;

const char eventIdQuery[] = "/Event/System/EventID[1]";

const char recordIdQuery[] = "/Event/System/EventRecordID[1]";

const char timeCreatedQuery[] = "/Event/System/TimeCreated[1]";

const char eventDataQuery[] = "/Event/EventData[1]";

const char systemTime[] = "SystemTime";

const char dataString[] = "Data";

const char dataName[] = "Name";

const xmlNode **nodeTab;

list<string> eventFields;

unsigned int eventId;

unsigned long recordId;

unsigned long timeCreated;

xmlNode *data;

bool filterOut = false;

const char *name;

const char *value;

LIBXML_TEST_VERSION

processCmdline(argc, argv, &eventIds, &eventIdFields, &recordIdRange, &timeRange, &filters, &extraCR);

while (getline(&line, &line_len, stdin) != -1) {

ptr = strstr(line, SYSMON_ID);

if (ptr == NULL)

continue;

ptr += strlen(SYSMON_ID);

ptr = strstr(ptr, EVENT_TAG);

if (ptr == NULL)

continue;

doc = xmlReadDoc((xmlChar *)ptr, "", NULL, 0);

if (doc == NULL) {

fprintf(stderr, "xmlReadDoc failed\n");

continue;

}

xpathCtx = xmlXPathNewContext( doc );

if( !xpathCtx ) {

fprintf(stderr, "xmlXPathNewContext failed\n");

xmlFreeDoc(doc);

continue;

}

nodeTab = (const xmlNode**)getXpath(doc, xpathCtx, eventIdQuery);

if (nodeTab == NULL) {

xmlXPathFreeContext(xpathCtx);

xmlFreeDoc(doc);

continue;

}

eventId = (unsigned int)(strtoul((char *)xmlNodeListGetString(doc, nodeTab[0]->children, 1), NULL, 0));

if (!eventIds.empty() && eventIds.find(eventId) == eventIds.end()) {

xmlXPathFreeContext(xpathCtx);

xmlFreeDoc(doc);

continue;

}

nodeTab = (const xmlNode**)getXpath(doc, xpathCtx, recordIdQuery);

if (nodeTab == NULL) {

xmlXPathFreeContext(xpathCtx);

xmlFreeDoc(doc);

continue;

}

recordId = strtoul((char *)xmlNodeListGetString(doc, nodeTab[0]->children, 1), NULL, 0);

if (recordIdRange.first != (unsigned long)-1 || recordIdRange.second != (unsigned long)-1) {

if (!isInRange(recordIdRange, recordId)) {

xmlXPathFreeContext(xpathCtx);

xmlFreeDoc(doc);

continue;

}

}

if (timeRange.first != (unsigned long)-1 || timeRange.second != (unsigned long)-1) {

nodeTab = (const xmlNode**)getXpath(doc, xpathCtx, timeCreatedQuery);

if (nodeTab == NULL) {

xmlXPathFreeContext(xpathCtx);

xmlFreeDoc(doc);

continue;

}

timeCreated = systemTimeStrToUl((char *)xmlGetProp(nodeTab[0], (xmlChar *)systemTime));

if (!isInRange(timeRange, timeCreated)) {

xmlXPathFreeContext(xpathCtx);

xmlFreeDoc(doc);

continue;

}

}

nodeTab = (const xmlNode**)getXpath(doc, xpathCtx, eventDataQuery);

if (nodeTab == NULL) {

xmlXPathFreeContext(xpathCtx);

xmlFreeDoc(doc);

continue;

}

filterOut = false;

for (data = nodeTab[0]->children; data != NULL && !filterOut; data = data->next) {

if (data->type != XML_ELEMENT_NODE || strcmp((char *)data->name, dataString) != 0)

continue;

name = (char *)xmlGetProp(data, (xmlChar *)dataName);

const auto filter = filters.find(string(name));

if (filter != filters.end()) {

value = (char *)xmlNodeListGetString(doc, data->children, 1);

if (filter->second.find(string(value)) == filter->second.end()) {

filterOut = true;

}

}

}

if (filterOut) {

xmlXPathFreeContext(xpathCtx);

xmlFreeDoc(doc);

continue;

}

const auto eventIdDisplay = eventIdFields.find(eventId);

printf("Event %s\n", eventName(eventId));

for (data = nodeTab[0]->children; data != NULL; data = data->next) {

if (data->type != XML_ELEMENT_NODE || strcmp((char *)data->name, dataString) != 0)

continue;

name = (const char *)xmlGetProp(data, (xmlChar *)dataName);

if (eventIdDisplay != eventIdFields.end() && eventIdDisplay->second.find(string(name)) == eventIdDisplay->second.end())

continue;

value = (const char *)xmlNodeListGetString(doc, data->children, 1);

if (value == NULL || value[0] == 0x00) {

printf("\t%s: --NULL--\n", name);

} else {

printf("\t%s: %s\n", name, value);

}

}

if (extraCR)

printf("\n");

xmlXPathFreeContext(xpathCtx);

xmlFreeDoc(doc);

}

xmlCleanupParser();

return 0;