source: tmcsimulator/trunk/src/python/unifiedlogger/activitylog_watcher.py @ 549

import json, time, ConfigParser

#from copy import deepcopy



# Incident Activity log Watcher

# Look for changes in the IncidentActivity log.

# The comments from the Incident Activity log be will appended to the log 

# as they arrive from the web app.

# We only need to keep track of the log length in order to

# determine if a new comment has been added.  We will output the 

# new messages that arrived during the last wait interval. 

# jdalbey  7/24/2019



lastLineNum = 0



# Utility functions

def isEmpty(cmsitem):

    return cmsitem == ",,,,,"

def isFull(cmsitem):

    return not isEmpty(cmsitem)



# Read the log 

def readFile():

    # get path to input file from configuration

    config = ConfigParser.ConfigParser()

    config.read('config/logging_service.cfg')

    logfilepath = config.get('Paths', 'ActivityLogPath')

    logfilename = "data.json"   #"IncidentActivity.log"

    data_summary = "data_summary.json"

    lines = []

    output = []

    try:

        json_file = open (logfilepath + logfilename,'r')

    except IOError:

        print "Error: missing "+logfilepath+logfilename+" file."

    else:

        jsonData=json_file.read()

        # implement ticket #192

        output = json.loads(jsonData)['data'] 

        # read in data_summary_json file

        # assuming the data_summary.json is in the trunk foldera

        data_summary = open(logfilepath + data_summary, 'r')

        summary_json = data_summary.read()

        data_lst = json.loads(summary_json)['data']

        for entry in data_lst:

            # put the first 3 entries as place holder to be consistent with other type of logging

            output.append([entry[0], entry[1] , entry[2], entry[3] , ", Incident Created, ", ""]) 

        json_file.close()

    return output

    

def setup():

    # nothing needed for setup

    return



# Retrieve new messages from activity log 

def getLogEntries():

    global lastLineNum

    msgList = readFile()

    currList = []

    currList = msgList[lastLineNum:]    # new items since last file read

    lastLineNum = len(msgList)

    resultList = []

    # Format messages into desired result format

    for item in currList:

        # implement ticket #188

        # extract desired fields

        incident_num = item[0].split("-")[1] 

        # extract the incident number from the date time field

        name = item[3].replace(',','')

        code = item[4].replace(',','')

        msg = item[5].replace(',','')

        desiredFields = "Activity Log,"+name+"," + incident_num + " " + code+" "+msg

        # Append to results list

        resultList.append(desiredFields)

    return resultList



# Local main for unit testing

def main():

    setup()

    # Loop Forever, checking every five seconds

    while True:

        # Look for new messages

        answer = getLogEntries()

        # Output results

        for item in answer:

            print item

        # wait 

        time.sleep(5)



if __name__ == "__main__":

    main()