pump_history_parser.py

from .helpers import DateTimeHelper, BinaryDataDecoder, NumberHelper
import struct
import logging
import binascii
from datetime import timedelta

logger = logging.getLogger(__name__)

class NGPConstants:
    class BG_UNITS:
        MG_DL = 0
        MMOL_L = 1
    class CARB_UNITS:
        GRAMS = 0
        EXCHANGES = 1
    class BG_SOURCE:
        EXTERNAL_METER = 1
        BOLUS_WIZARD = 2,
        BG_EVENT_MARKER = 3
        SENSOR_CAL = 4
    class BG_ORIGIN:
        MANUALLY_ENTERED = 0
        RECEIVED_FROM_RF = 1
    class BG_CONTEXT:
        BG_READING_RECEIVED = 0
        USER_ACCEPTED_REMOTE_BG = 1
        USER_REJECTED_REMOTE_BG = 2
        REMOTE_BG_ACCEPTANCE_SCREEN_TIMEOUT = 3
        BG_SI_PASS_RESULT_RECD_FRM_GST = 4
        BG_SI_FAIL_RESULT_RECD_FRM_GST = 5
        BG_SENT_FOR_CALIB = 6
        USER_REJECTED_SENSOR_CALIB = 7
        ENTERED_IN_BG_ENTRY = 8
        ENTERED_IN_MEAL_WIZARD = 9
        ENTERED_IN_BOLUS_WIZRD = 10
        ENTERED_IN_SENSOR_CALIB = 11
        ENTERED_AS_BG_MARKER = 12
    class BOLUS_SOURCE:
        MANUAL = 0
        BOLUS_WIZARD = 1
        EASY_BOLUS = 2
        PRESET_BOLUS = 4

    class BOLUS_STEP_SIZE:
        STEP_0_POINT_025 = 0
        STEP_0_POINT_05 = 1
        STEP_0_POINT_1 = 2

    BASAL_PATTERN_NAME = [
        'Pattern 1',
        'Pattern 2',
        'Pattern 3',
        'Pattern 4',
        'Pattern 5',
        'Workday',
        'Day Off',
        'Sick Day',
        ]

    class TEMP_BASAL_TYPE:
        ABSOLUTE = 0
        PERCENT = 1

    TEMP_BASAL_PRESET_NAME = [
      'Not Preset',
      'Temp 1',
      'Temp 2',
      'Temp 3',
      'Temp 4',
      'High Activity',
      'Moderate Activity',
      'Low Activity',
      'Sick',
      ]

    BOLUS_PRESET_NAME = [
      'Not Preset',
      'Bolus 1',
      'Bolus 2',
      'Bolus 3',
      'Bolus 4',
      'Breakfast',
      'Lunch',
      'Dinner',
      'Snack',
    ]

    class SUSPEND_REASON:
        ALARM_SUSPEND = 1 # Battery change, cleared occlusion, etc
        USER_SUSPEND = 2
        AUTO_SUSPEND = 3
        LOWSG_SUSPEND = 4
        SET_CHANGE_SUSPEND = 5 # AKA NOTSEATED_SUSPEND
        PLGM_PREDICTED_LOW_SG = 10

    SUSPEND_REASON_NAME = {
        1: 'Alarm suspend',
        2: 'User suspend',
        3: 'Auto suspend',
        4: 'Low glucose suspend',
        5: 'Set change suspend',
        10: 'Predicted low glucose suspend',
    }
     
    class RESUME_REASON:
        USER_SELECTS_RESUME = 1
        USER_CLEARS_ALARM = 2
        LGM_MANUAL_RESUME = 3
        LGM_AUTO_RESUME_MAX_SUSP = 4 # After an auto suspend, but no CGM data afterwards.
        LGM_AUTO_RESUME_PSG_SG = 5 # When SG reaches the Preset SG level
        LGM_MANUAL_RESUME_VIA_DISABLE = 6

    RESUME_REASON_NAME = {
        1: 'User resumed',
        2: 'User cleared alarm',
        3: 'Low glucose manual resume',
        4: 'Low glucose auto resume - max suspend period',
        5: 'Low glucose auto resume - preset glucose reached',
        6: 'Low glucose manual resume via disable',
    }

class NGPHistoryEvent:
    class EVENT_TYPE:
        TIME_RESET = 0x02
        USER_TIME_DATE_CHANGE = 0x03
        SOURCE_ID_CONFIGURATION = 0x04
        NETWORK_DEVICE_CONNECTION = 0x05
        AIRPLANE_MODE = 0x06
        START_OF_DAY_MARKER = 0x07
        END_OF_DAY_MARKER = 0x08
        PLGM_CONTROLLER_STATE = 0x0B
        CLOSED_LOOP_STATUS_DATA = 0x0C
        CLOSED_LOOP_PERIODIC_DATA = 0x0D
        CLOSED_LOOP_DAILY_DATA = 0x0E
        NORMAL_BOLUS_PROGRAMMED = 0x15
        SQUARE_BOLUS_PROGRAMMED = 0x16
        DUAL_BOLUS_PROGRAMMED = 0x17
        CANNULA_FILL_DELIVERED = 0x1A
        TEMP_BASAL_PROGRAMMED = 0x1B
        BASAL_PATTERN_SELECTED = 0x1C
        BASAL_SEGMENT_START = 0x1D
        INSULIN_DELIVERY_STOPPED = 0x1E
        INSULIN_DELIVERY_RESTARTED = 0x1F
        SELF_TEST_REQUESTED = 0x20
        SELF_TEST_RESULTS = 0x21
        TEMP_BASAL_COMPLETE = 0x22
        BOLUS_SUSPENDED = 0x24
        SUSPENDED_BOLUS_RESUMED = 0x25
        SUSPENDED_BOLUS_CANCELED = 0x26
        BOLUS_CANCELED = 0x27
        ALARM_NOTIFICATION = 0x28
        ALARM_CLEARED = 0x2A
        LOW_RESERVOIR = 0x2B
        BATTERY_INSERTED = 0x2C
        FOOD_EVENT_MARKER = 0x2E
        EXERCISE_EVENT_MARKER = 0x2F
        INJECTION_EVENT_MARKER = 0x30
        OTHER_EVENT_MARKER = 0x31
        BG_READING = 0x32
        CODE_UPDATE = 0x33
        MISSED_MEAL_BOLUS_REMINDER_EXPIRED = 0x34
        REWIND = 0x36
        BATTERY_REMOVED = 0x37
        CALIBRATION_COMPLETE = 0x38
        ACTIVE_INSULIN_CLEARED = 0x39
        DAILY_TOTALS = 0x3C
        BOLUS_WIZARD_ESTIMATE = 0x3D
        MEAL_WIZARD_ESTIMATE = 0x3E
        CLOSED_LOOP_DAILY_TOTALS = 0x3F
        USER_SETTINGS_SAVE = 0x50
        USER_SETTINGS_RESET_TO_DEFAULTS = 0x51
        OLD_BASAL_PATTERN = 0x52
        NEW_BASAL_PATTERN = 0x53
        OLD_PRESET_TEMP_BASAL = 0x54
        NEW_PRESET_TEMP_BASAL = 0x55
        OLD_PRESET_BOLUS = 0x56
        NEW_PRESET_BOLUS = 0x57
        MAX_BASAL_RATE_CHANGE = 0x58
        MAX_BOLUS_CHANGE = 0x59
        PERSONAL_REMINDER_CHANGE = 0x5A
        MISSED_MEAL_BOLUS_REMINDER_CHANGE = 0x5B
        BOLUS_INCREMENT_CHANGE = 0x5C
        BOLUS_WIZARD_SETTINGS_CHANGE = 0x5D
        OLD_BOLUS_WIZARD_INSULIN_SENSITIVITY = 0x5E
        NEW_BOLUS_WIZARD_INSULIN_SENSITIVITY = 0x5F
        OLD_BOLUS_WIZARD_INSULIN_TO_CARB_RATIOS = 0x60
        NEW_BOLUS_WIZARD_INSULIN_TO_CARB_RATIOS = 0x61
        OLD_BOLUS_WIZARD_BG_TARGETS = 0x62
        NEW_BOLUS_WIZARD_BG_TARGETS = 0x63
        DUAL_BOLUS_OPTION_CHANGE = 0x64
        SQUARE_BOLUS_OPTION_CHANGE = 0x65
        EASY_BOLUS_OPTION_CHANGE = 0x66
        BG_REMINDER_OPTION_CHANGE = 0x68
        BG_REMINDER_TIME = 0x69
        AUDIO_VIBRATE_MODE_CHANGE = 0x6A
        TIME_FORMAT_CHANGE = 0x6B
        LOW_RESERVOIR_WARNING_CHANGE = 0x6C
        LANGUAGE_CHANGE = 0x6D
        STARTUP_WIZARD_START_END = 0x6E
        REMOTE_BOLUS_OPTION_CHANGE = 0x6F
        AUTO_SUSPEND_CHANGE = 0x72
        BOLUS_DELIVERY_RATE_CHANGE = 0x73
        DISPLAY_OPTION_CHANGE = 0x77
        SET_CHANGE_REMINDER_CHANGE = 0x78
        BLOCK_MODE_CHANGE = 0x79
        BOLUS_WIZARD_SETTINGS_SUMMARY = 0x7B
        CLOSED_LOOP_BG_READING = 0x82
        CLOSED_LOOP_OPTION_CHANGE = 0x86
        CLOSED_LOOP_SETTINGS_CHANGED = 0x87
        CLOSED_LOOP_TEMP_TARGET_STARTED = 0x88
        CLOSED_LOOP_TEMP_TARGET_ENDED = 0x89
        CLOSED_LOOP_ALARM_AUTO_CLEARED = 0x8A
        SENSOR_SETTINGS_CHANGE = 0xC8
        OLD_SENSOR_WARNING_LEVELS = 0xC9
        NEW_SENSOR_WARNING_LEVELS = 0xCA
        GENERAL_SENSOR_SETTINGS_CHANGE = 0xCB
        SENSOR_GLUCOSE_READINGS = 0xCC
        SENSOR_GLUCOSE_GAP = 0xCD
        GLUCOSE_SENSOR_CHANGE = 0xCE
        SENSOR_CALIBRATION_REJECTED = 0xCF
        SENSOR_ALERT_SILENCE_STARTED = 0xD0
        SENSOR_ALERT_SILENCE_ENDED = 0xD1
        OLD_LOW_SENSOR_WARNING_LEVELS = 0xD2
        NEW_LOW_SENSOR_WARNING_LEVELS = 0xD3
        OLD_HIGH_SENSOR_WARNING_LEVELS = 0xD4
        NEW_HIGH_SENSOR_WARNING_LEVELS = 0xD5
        SENSOR_GLUCOSE_READINGS_EXTENDED = 0xD6
        NORMAL_BOLUS_DELIVERED = 0xDC
        SQUARE_BOLUS_DELIVERED = 0xDD
        DUAL_BOLUS_PART_DELIVERED = 0xDE
        CLOSED_LOOP_TRANSITION = 0xDF
        GENERATED__SENSOR_GLUCOSE_READINGS_EXTENDED_ITEM = 0xD601 #this is not a pump event, it's generated from single items within SENSOR_GLUCOSE_READINGS_EXTENDED 

    def __init__(self, eventData):
        self.eventData = eventData;

    @property
    def source(self):
        # No idea what "source" means.
        return BinaryDataDecoder.readByte(self.eventData, 0x01)# self.eventData[0x01];

    @property
    def size(self):
        return BinaryDataDecoder.readByte(self.eventData, 0x02)#this.eventData[0x02];

    @property
    def eventType(self):
        return BinaryDataDecoder.readByte(self.eventData, 0x00)#this.eventData[0];

    @property
    def timestamp(self):
        return DateTimeHelper.decodeDateTime(BinaryDataDecoder.readUInt64BE(self.eventData, 0x03))

    @property
    def dynamicActionRequestor(self):
        return BinaryDataDecoder.readByte(self.eventData, 0x01) # self.eventData[0x01];
    
    def __str__(self):
        return '{0} {1:x} {2} {3}'.format(self.__class__.__name__, self.eventType, self.timestamp, binascii.hexlify(self.eventData[0x0B:]))

    def __shortstr__(self):
        return '{0} {1:x} {2}'.format(self.__class__.__name__, self.eventType, self.timestamp)

    def __repr__(self):
        return str(self)
    
    def allNestedEvents(self):
        yield self.eventInstance()
        
    def postProcess(self, histryEvents):
        pass
    
    def eventInstance(self):
        if self.eventType == NGPHistoryEvent.EVENT_TYPE.BG_READING:
            return BloodGlucoseReadingEvent(self.eventData)
        elif self.eventType == NGPHistoryEvent.EVENT_TYPE.NORMAL_BOLUS_DELIVERED:            
            return NormalBolusDeliveredEvent(self.eventData);
        elif self.eventType == NGPHistoryEvent.EVENT_TYPE.SENSOR_GLUCOSE_READINGS_EXTENDED:            
            return SensorGlucoseReadingsEvent(self.eventData)
        elif self.eventType == NGPHistoryEvent.EVENT_TYPE.BOLUS_WIZARD_ESTIMATE:
            return BolusWizardEstimateEvent(self.eventData)
        elif self.eventType == NGPHistoryEvent.EVENT_TYPE.BASAL_SEGMENT_START:
            return BasalSegmentStartEvent(self.eventData)
        elif self.eventType == NGPHistoryEvent.EVENT_TYPE.INSULIN_DELIVERY_STOPPED:
            return InsulinDeliveryStoppedEvent(self.eventData);
        elif self.eventType == NGPHistoryEvent.EVENT_TYPE.INSULIN_DELIVERY_RESTARTED:
            return InsulinDeliveryRestartedEvent(self.eventData);
        elif self.eventType == NGPHistoryEvent.EVENT_TYPE.PLGM_CONTROLLER_STATE:
            return PLGMControllerStateEvent(self.eventData);
        elif self.eventType == NGPHistoryEvent.EVENT_TYPE.CALIBRATION_COMPLETE:
            return CalibrationCompleteEvent(self.eventData);
        elif self.eventType == NGPHistoryEvent.EVENT_TYPE.ALARM_NOTIFICATION:
            return AlarmNotificationEvent(self.eventData);
        elif self.eventType == NGPHistoryEvent.EVENT_TYPE.ALARM_CLEARED:
            return AlarmClearedEvent(self.eventData);
        elif self.eventType == NGPHistoryEvent.EVENT_TYPE.SENSOR_ALERT_SILENCE_STARTED:
            return SensorAlertSilenceStartedEvent(self.eventData);
        elif self.eventType == NGPHistoryEvent.EVENT_TYPE.SENSOR_ALERT_SILENCE_ENDED:
            return SensorAlertSilenceEndedEvent(self.eventData);
        elif self.eventType == NGPHistoryEvent.EVENT_TYPE.GENERAL_SENSOR_SETTINGS_CHANGE:
            return GeneralSensorSettingsChangeEvent(self.eventData);
        elif self.eventType == NGPHistoryEvent.EVENT_TYPE.DAILY_TOTALS:
            return DailyTotalsEvent(self.eventData);        
        elif self.eventType == NGPHistoryEvent.EVENT_TYPE.START_OF_DAY_MARKER:
            return StartOfDayMarkerEvent(self.eventData);        
        elif self.eventType == NGPHistoryEvent.EVENT_TYPE.END_OF_DAY_MARKER:
            return EndOfDayMarkerEvent(self.eventData);    
        elif self.eventType == NGPHistoryEvent.EVENT_TYPE.SOURCE_ID_CONFIGURATION:
            return SourceIdConfigurationEvent(self.eventData);    
        elif self.eventType == NGPHistoryEvent.EVENT_TYPE.NORMAL_BOLUS_PROGRAMMED:
            return NormalBolusProgrammedEvent(self.eventData)
        return self
#       case NGPHistoryEvent.EVENT_TYPE.OLD_BOLUS_WIZARD_BG_TARGETS:
#         return new OldBolusWizardBgTargetsEvent(this.eventData);
#       case NGPHistoryEvent.EVENT_TYPE.NEW_BOLUS_WIZARD_BG_TARGETS:
#         return new NewBolusWizardBgTargetsEvent(this.eventData);
#       case NGPHistoryEvent.EVENT_TYPE.OLD_BOLUS_WIZARD_INSULIN_SENSITIVITY:
#         return new OldBolusWizardInsulinSensitivityEvent(this.eventData);
#       case NGPHistoryEvent.EVENT_TYPE.NEW_BOLUS_WIZARD_INSULIN_SENSITIVITY:
#         return new NewBolusWizardInsulinSensitivityEvent(this.eventData);
#       case NGPHistoryEvent.EVENT_TYPE.OLD_BOLUS_WIZARD_INSULIN_TO_CARB_RATIOS:
#         return new OldBolusWizardCarbsRatiosEvent(this.eventData);
#       case NGPHistoryEvent.EVENT_TYPE.NEW_BOLUS_WIZARD_INSULIN_TO_CARB_RATIOS:
#         return new NewBolusWizardCarbsRatiosEvent(this.eventData);
#       case NGPHistoryEvent.EVENT_TYPE.BOLUS_WIZARD_SETTINGS_SUMMARY:
#         return this;
#       case NGPHistoryEvent.EVENT_TYPE.OLD_BASAL_PATTERN:
#         return new OldBasalPatternEvent(this.eventData);
#       case NGPHistoryEvent.EVENT_TYPE.NEW_BASAL_PATTERN:
#         return new NewBasalPatternEvent(this.eventData);
#       case NGPHistoryEvent.EVENT_TYPE.BASAL_PATTERN_SELECTED:
#         return new BasalPatternSelectedEvent(this.eventData);
#       case NGPHistoryEvent.EVENT_TYPE.USER_TIME_DATE_CHANGE:
#         return new UserTimeDateEvent(this.eventData);
#       case NGPHistoryEvent.EVENT_TYPE.LOW_RESERVOIR:
#         return new LowReservoirEvent(this.eventData);
#       case NGPHistoryEvent.EVENT_TYPE.BG_READING:
#         return new BloodGlucoseReadingEvent(this.eventData);
#       case NGPHistoryEvent.EVENT_TYPE.CLOSED_LOOP_BG_READING:
#         return new ClosedLoopBloodGlucoseReadingEvent(this.eventData);
#       case NGPHistoryEvent.EVENT_TYPE.BASAL_SEGMENT_START:
#         return new BasalSegmentStartEvent(this.eventData);
#       case NGPHistoryEvent.EVENT_TYPE.TEMP_BASAL_COMPLETE:
#         return new TempBasalCompleteEvent(this.eventData);
#       case NGPHistoryEvent.EVENT_TYPE.REWIND:
#         return new RewindEvent(this.eventData);
#       case NGPHistoryEvent.EVENT_TYPE.CANNULA_FILL_DELIVERED:
#         return new CannulaFillDeliveredEvent(this.eventData);
#       case NGPHistoryEvent.EVENT_TYPE.SQUARE_BOLUS_DELIVERED:
#         return new SquareBolusDeliveredEvent(this.eventData);
#       case NGPHistoryEvent.EVENT_TYPE.DUAL_BOLUS_PART_DELIVERED:
#         return new DualBolusPartDeliveredEvent(this.eventData);
#       case NGPHistoryEvent.EVENT_TYPE.BOLUS_WIZARD_ESTIMATE:
#         return new BolusWizardEstimateEvent(this.eventData);
#       default:
#         // Return a default NGPHistoryEvent
#         return this;
#     }

class BloodGlucoseReadingEvent(NGPHistoryEvent):
    def __init__(self, eventData):
        NGPHistoryEvent.__init__(self, eventData)
        
    def __str__(self):
        return '{0} {1}'.format(NGPHistoryEvent.__shortstr__(self), self.bgValue)


#    @property
#    def meterSerialNumber(self):
#     return this.eventData.slice(0x0F, this.eventData.length).toString().replace(' ', '').split('')
#       .reverse()
#       .join('');

#   See NGPUtil.NGPConstants.BG_SOURCE
#   get bgSource() {
#     return this.eventData[0x0E];
#   }

    @property
    def bgValue(self):
        # bgValue is always in mg/dL.
        return BinaryDataDecoder.readUInt16BE(self.eventData, 0x0C)#this.eventData.readUInt16BE(0x0C);

#   get bgUnits() {
#     // bgValue is always in mg/dL. bgUnits tells us which units the device is set in.
#     // eslint-disable-next-line no-bitwise
#     return this.eventData[0x0B] & 1 ?
#       NGPUtil.NGPConstants.BG_UNITS.MG_DL :
#       NGPUtil.NGPConstants.BG_UNITS.MMOL_L;
#   }
# 
#   get calibrationFlag() {
#     // eslint-disable-next-line no-bitwise
#     return (this.eventData[0x0B] & 2) === 2;
#   }
# 
#   get bgLinked() {
#     return this.meterSerialNumber !== '';
#   }
# 
#   get isCalibration() {
#     return (this.bgSource === NGPUtil.NGPConstants.BG_SOURCE.SENSOR_CAL || this.calibrationFlag);
#   }

class BolusDeliveredEvent(NGPHistoryEvent):
    def __init__(self, eventData):
        NGPHistoryEvent.__init__(self, eventData)
        self.programmedEvent = None
        
    def __str__(self):
        return '{0} Source:{1}, Number:{2}, presetBolusNumber:{3}'.format(NGPHistoryEvent.__shortstr__(self), self.bolusSource, self.bolusNumber, self.presetBolusNumber)

    @property
    def bolusSource(self):
        return BinaryDataDecoder.readByte(self.eventData, 0x0B)#return this.eventData[0x0B];

    @property
    def bolusNumber(self):
        return BinaryDataDecoder.readByte(self.eventData, 0x0C)#return this.eventData[0x0C];

    @property
    def presetBolusNumber(self):
        # See NGPUtil.NGPConstants.BOLUS_PRESET_NAME
        return BinaryDataDecoder.readByte(self.eventData, 0x0D)#return this.eventData[0x0D];

    def postProcess(self, histryEvents):
        matches = [x for x in histryEvents 
                   if isinstance(x, NormalBolusProgrammedEvent) 
                   and x.bolusNumber == self.bolusNumber
                   and x.timestamp < self.timestamp
                   and self.timestamp - x.timestamp < timedelta(minutes = 5)]
        if len(matches) == 1:
            self.programmedEvent = matches[0]


class NormalBolusDeliveredEvent(BolusDeliveredEvent):
    def __init__(self, eventData):
        BolusDeliveredEvent.__init__(self, eventData)
        
    def __str__(self):
        return '{0} Del:{1}, Prog:{2}, Active:{3}, Programmed: {4}'.format(NGPHistoryEvent.__shortstr__(self), self.deliveredAmount, self.programmedAmount, self.activeInsulin, self.programmedEvent)

    @property
    def deliveredAmount(self):
        return BinaryDataDecoder.readUInt32BE(self.eventData, 0x12) / 10000.0 #return this.eventData.readUInt32BE(0x12) / 10000.0;

    @property
    def programmedAmount(self):
        return BinaryDataDecoder.readUInt32BE(self.eventData, 0x0E) / 10000.0 #return this.eventData.readUInt32BE(0x12) / 10000.0;

    @property
    def activeInsulin(self):
        return BinaryDataDecoder.readUInt32BE(self.eventData, 0x16) / 10000.0 #return this.eventData.readUInt32BE(0x16) / 10000.0;
            
class BolusProgrammedEvent(NGPHistoryEvent):
    def __init__(self, eventData):
        NGPHistoryEvent.__init__(self, eventData)
        self.bolusWizardEvent = None
        
    def __str__(self):
        return '{0} Source:{1}, Number:{2}, presetBolusNumber:{3}'.format(NGPHistoryEvent.__str__(self), self.bolusSource, self.bolusNumber, self.presetBolusNumber)

    @property
    def bolusSource(self):
        return BinaryDataDecoder.readByte(self.eventData, 0x0B)#return this.eventData[0x0B];

    @property
    def bolusNumber(self):
        return BinaryDataDecoder.readByte(self.eventData, 0x0C)#return this.eventData[0x0C];

    @property
    def presetBolusNumber(self):
        # See NGPUtil.NGPConstants.BOLUS_PRESET_NAME
        return BinaryDataDecoder.readByte(self.eventData, 0x0D)#return this.eventData[0x0D];

class NormalBolusProgrammedEvent(BolusProgrammedEvent):
    def __init__(self, eventData):
        BolusProgrammedEvent.__init__(self, eventData)
        
    def __str__(self):
        return '{0} Prog:{1}, Active:{2}, Wizard: {3}'.format(BolusProgrammedEvent.__shortstr__(self), 
                                                              self.programmedAmount, 
                                                              self.activeInsulin, 
                                                              self.bolusWizardEvent)

    @property
    def programmedAmount(self):
        return BinaryDataDecoder.readUInt32BE(self.eventData, 0x0E) / 10000.0 #return this.eventData.readUInt32BE(0x12) / 10000.0;

    @property
    def activeInsulin(self):
        return BinaryDataDecoder.readUInt32BE(self.eventData, 0x12) / 10000.0 #return this.eventData.readUInt32BE(0x16) / 10000.0;

    def postProcess(self, histryEvents):
        matches = [x for x in histryEvents 
                   if isinstance(x, BolusWizardEstimateEvent) 
                   and x.timestamp < self.timestamp
                   and self.timestamp - x.timestamp < timedelta(minutes = 5)
                   and x.finalEstimate == self.programmedAmount]
        if len(matches) == 1:
            self.bolusWizardEvent = matches[0]
            self.bolusWizardEvent.programmed = True


class SensorGlucoseReadingsEvent(NGPHistoryEvent):
    def __init__(self, eventData):
        NGPHistoryEvent.__init__(self, eventData)
        
    def __str__(self):
        return '{0}'.format(NGPHistoryEvent.__shortstr__(self))    

    @property
    def minutesBetweenReadings(self):
        return BinaryDataDecoder.readByte(self.eventData, 0x0B)#return this.eventData[0x0B];

    @property
    def numberOfReadings(self):
        return BinaryDataDecoder.readByte(self.eventData, 0x0C)#return this.eventData[0x0C];

    @property
    def predictedSg(self):
        return BinaryDataDecoder.readUInt16BE(self.eventData, 0x0D)#return this.eventData.readUInt16BE(0x0D);
    
    def allNestedEvents(self):
        pos = 0x0F
        #if self.numberOfReadings > 1:
        #    logger.debug("MULTI_ITEM_HISTORY: {0} {1}".format(self.timestamp, self.numberOfReadings))
        for i in range(self.numberOfReadings - 1, -1, -1):
            #const timestamp = new NGPUtil.NGPTimestamp(this.timestamp.rtc - (i * this.minutesBetweenReadings * 60), this.timestamp.offset);
            timestamp = self.timestamp - timedelta(minutes = i * self.minutesBetweenReadings)
            payloadDecoded = struct.unpack( '>BBHBhBB', self.eventData[pos + i * 9: pos + (i + 1)* 9] )

            #const sg = ((this.eventData[pos] & 3) << 8) | this.eventData[pos + 1];
            sg = (payloadDecoded[0] & 0x03) << 8 | payloadDecoded[1]            
            #      const vctr = NGPUtil.make32BitIntFromNBitSignedInt((((this.eventData[pos] >> 2) & 3) << 8) | this.eventData[pos + 4], 10) / 100.0;
            # not sure what this value means so cannot say if it's correct
            vctr = NumberHelper.make32BitIntFromNBitSignedInt((((payloadDecoded[0] >> 0x02) & 0x03) << 8) | payloadDecoded[3], 10) / 100.0;
            
            #const isig = this.eventData.readInt16BE(pos + 2) / 100.0;
            isig = payloadDecoded[2] / 100.0;
            #const rateOfChange = this.eventData.readInt16BE(pos + 5) / 100.0;
            rateOfChange = payloadDecoded[4] / 100.0;
            #const readingStatus = this.eventData[pos + 8];
            readingStatus = payloadDecoded[6];
            #const sensorStatus = this.eventData[pos + 7];
            sensorStatus = payloadDecoded[5];
            
            #const backfilledData = (readingStatus & 1) === 1;
            backfilledData = (readingStatus & 0x01) == 0x01
            #const settingsChanged = (readingStatus & 2) === 1; #bug?
            settingsChanged = (readingStatus & 0x02) == 0x02
            #const noisyData = sensorStatus === 1;
            noisyData = sensorStatus == 1
            #const discardData = sensorStatus === 2;
            discardData = sensorStatus == 2
            #const sensorError = sensorStatus === 3;
            sensorError = sensorStatus == 3
            # TODO - handle all the error states where sg >= 769 (see ParseCGM.js)?
            
            #if self.numberOfReadings > 1:
            #    logger.debug("MULTI_ITEM_HISTORY ITEM: {0} {1} {2}".format(timestamp, i, sg))

            
            if sg > 0 and sg < 600:
                yield SensorGlucoseReading(timestamp = timestamp, 
                                           dynamicActionRequestor = self.dynamicActionRequestor, 
                                           sg = sg,
                                           predictedSg = self.predictedSg,
                                           noisyData = noisyData,
                                           discardData = discardData,
                                           sensorError = sensorError,
                                           backfilledData = backfilledData,
                                           settingsChanged = settingsChanged,
                                           isig = isig,
                                           rateOfChange = rateOfChange,
                                           vctr = vctr)


class SensorGlucoseReading(NGPHistoryEvent):
    def __init__(self, 
                 timestamp, 
                 dynamicActionRequestor, 
                 sg, 
                 predictedSg = 0, 
                 isig = 0, 
                 vctr = 0, 
                 rateOfChange = 0, 
                 backfilledData = False,
                 settingsChanged = False,
                 noisyData = False,
                 discardData = False,
                 sensorError = False):
        self._timestamp = timestamp
        self._dynamicActionRequestor = dynamicActionRequestor
        self.sg = sg
        self.predictedSg = predictedSg
        self.isig = isig
        self.vctr = vctr
        self.rateOfChange = rateOfChange
        self.backfilledData = backfilledData
        self.settingsChanged = settingsChanged
        self.noisyData = noisyData
        self.discardData = discardData
        self.sensorError = sensorError
    
    def __str__(self):
        return ("{0} SG:{1}, predictedSg:{2}, "
                "isig:{6}, rateOfChange:{7}, "
                "noisyData:{3}, discardData: {4}, sensorError:{5}").format(
            NGPHistoryEvent.__shortstr__(self), 
            self.sg, 
            self.predictedSg,        
            self.noisyData,
            self.discardData,
            self.sensorError,
            self.isig,
            self.rateOfChange)

    @property
    def source(self):
        return self._dynamicActionRequestor

    @property
    def dynamicActionRequestor(self):
        return self._dynamicActionRequestor

    @property
    def timestamp(self):
        return self._timestamp

    @property
    def size(self):
        return 0

    @property
    def eventType(self):
        return NGPHistoryEvent.EVENT_TYPE.GENERATED__SENSOR_GLUCOSE_READINGS_EXTENDED_ITEM

    def eventInstance(self):
        return self

class BolusWizardEstimateEvent(NGPHistoryEvent):
    def __init__(self, eventData):
        NGPHistoryEvent.__init__(self, eventData)
        self.programmed = False
        
    def __str__(self):
        return ("{0} BG Input:{1}, "
                "Carbs:{2}, "
                "Carb ratio: {4}, "
                "Food est.:{3}, "
                "Correction est.:{5}, "
                "Active insulin:{10}, "
                "Active insulin corr.:{11}, "
                "Wizard est.: {6}, "
                "User modif.: {7}, "
                "Final est.: {8}, "
                "Programmed: {12}, "
                ).format(NGPHistoryEvent.__shortstr__(self), 
                                                    self.bgInput, 
                                                    self.carbInput,
                                                    self.foodEstimate,
                                                    self.carbRatio,
                                                    self.correctionEstimate,
                                                    self.bolusWizardEstimate,
                                                    self.estimateModifiedByUser,
                                                    self.finalEstimate,
                                                    map(hex,map(ord, self.eventData[0x0B:])),
                                                    self.activeInsulin,
                                                    self.activeInsulinCorrection,
                                                    self.programmed)
    
    @property
    def bgUnits(self):
        # See NGPUtil.NGPConstants.BG_UNITS
        return BinaryDataDecoder.readByte(self.eventData, 0x0B)#return this.eventData[0x0B];

    @property
    def carbUnits(self):
        # See NGPUtil.NGPConstants.CARB_UNITS
        return BinaryDataDecoder.readByte(self.eventData, 0x0C)#return this.eventData[0x0C];
  
    @property
    def bolusStepSize(self):
        # See NGPUtil.NGPConstants.BOLUS_STEP_SIZE
        return BinaryDataDecoder.readByte(self.eventData, 0x2F)#return this.eventData[0x2F];

    @property
    def bgInput(self):
        bgInput  = BinaryDataDecoder.readUInt16BE(self.eventData, 0x0D)#this.eventData.readUInt16BE(0x0D);
        return bgInput if self.bgUnits == NGPConstants.BG_UNITS.MG_DL else bgInput  / 10.0
    
    @property
    def carbInput(self):
        carbs = BinaryDataDecoder.readUInt16BE(self.eventData, 0x0F)#this.eventData.readUInt16BE(0x0F)
        return carbs if self.carbUnits == NGPConstants.CARB_UNITS.GRAMS else carbs / 10.0

    @property
    def foodEstimate(self):
        return BinaryDataDecoder.readUInt32BE(self.eventData, 0x1F) / 10000.0;

    @property
    def carbRatio(self):
        carbRatio = BinaryDataDecoder.readUInt32BE(self.eventData, 0x13);
        return carbRatio / 10.0 if (self.carbUnits == NGPConstants.CARB_UNITS.GRAMS) else carbRatio / 1000.0

    @property
    def isf(self):
        isf = BinaryDataDecoder.readUInt16BE(self.eventData, 0x11);
        return isf if self.bgUnits == NGPConstants.BG_UNITS.MG_DL else isf / 10.0

    @property
    def lowBgTarget(self):
        bgTarget = BinaryDataDecoder.readUInt16BE(self.eventData, 0x17)
        return bgTarget if self.bgUnits == NGPConstants.BG_UNITS.MG_DL else bgTarget / 10.0


    @property
    def highBgTarget(self):
        bgTarget = BinaryDataDecoder.readUInt16BE(self.eventData, 0x19)
        return bgTarget if self.bgUnits == NGPConstants.BG_UNITS.MG_DL else bgTarget / 10.0;

    @property
    def correctionEstimate(self):
        return ((BinaryDataDecoder.readByte(self.eventData, 0x1B) << 8) |
                (BinaryDataDecoder.readByte(self.eventData, 0x1C) << 8) | 
                (BinaryDataDecoder.readByte(self.eventData, 0x1D) << 8) | 
                BinaryDataDecoder.readByte(self.eventData, 0x1E)) / 10000.0;

    @property
    def activeInsulin(self):
        return BinaryDataDecoder.readUInt32BE(self.eventData, 0x23) / 10000.0

    @property
    def activeInsulinCorrection(self):
        return BinaryDataDecoder.readUInt32BE(self.eventData, 0x27) / 10000.0

    @property
    def bolusWizardEstimate(self):
        return BinaryDataDecoder.readUInt32BE(self.eventData, 0x2B) / 10000.0

    @property
    def finalEstimate(self):
        return BinaryDataDecoder.readUInt32BE(self.eventData, 0x31) / 10000.0

    @property
    def estimateModifiedByUser(self):
        return (BinaryDataDecoder.readUInt32BE(self.eventData, 0x30) & 0x01) == 0x01;

class BasalSegmentStartEvent(NGPHistoryEvent):
    def __init__(self, eventData):
        NGPHistoryEvent.__init__(self, eventData)
        
    def __str__(self):
        return '{0} Basal Rate:{1}, Pattern#:{2} \'{4}\', Segment#:{3}'.format(NGPHistoryEvent.__shortstr__(self), 
                                                                    self.rate, 
                                                                    self.patternNumber,
                                                                    self.segmentNumber,
                                                                    self.patternName)

    @property
    def rate(self):
        return BinaryDataDecoder.readUInt32BE(self.eventData, 0x0D) / 10000.0 # return this.eventData.readUInt32BE(0x0D) / 10000.0;

    @property
    def patternNumber(self):
        # See NGPUtil.NGPConstants.CARB_UNITS
        return BinaryDataDecoder.readByte(self.eventData, 0x0B)#return this.eventData[0x0B];

    @property
    def segmentNumber(self):
        # See NGPUtil.NGPConstants.CARB_UNITS
        return BinaryDataDecoder.readByte(self.eventData, 0x0C)#return this.eventData[0x0C];

    @property 
    def patternName(self):
        return NGPConstants.BASAL_PATTERN_NAME[self.patternNumber - 1];


class InsulinDeliveryStoppedEvent(NGPHistoryEvent):
    def __init__(self, eventData):
        NGPHistoryEvent.__init__(self, eventData)
        
    def __str__(self):
        return '{0} Reason: {2} ({1})'.format(NGPHistoryEvent.__shortstr__(self), 
                                                                    self.suspendReason,
                                                                    self.suspendReasonText)
    @property
    def suspendReason(self):
        #See NGPUtil.NGPConstants.SUSPEND_REASON        
        return BinaryDataDecoder.readByte(self.eventData, 0x0B)#return this.eventData[0x0B];

    @property
    def suspendReasonText(self):
        return NGPConstants.SUSPEND_REASON_NAME[self.suspendReason]

    
class InsulinDeliveryRestartedEvent(NGPHistoryEvent):
    def __init__(self, eventData):
        NGPHistoryEvent.__init__(self, eventData)
        
    def __str__(self):
        return '{0} Reason: {2} ({1})'.format(NGPHistoryEvent.__shortstr__(self), 
                                                                    self.resumeReason,
                                                                    self.resumeReasonText)
    @property
    def resumeReason(self):
        #See See NGPUtil.NGPConstants.RESUME_REASON
        return BinaryDataDecoder.readByte(self.eventData, 0x0B)#return this.eventData[0x0B];

    @property
    def resumeReasonText(self):
        return NGPConstants.RESUME_REASON_NAME[self.resumeReason]

class PLGMControllerStateEvent(NGPHistoryEvent):
    def __str__(self):
        return '{0}'.format(NGPHistoryEvent.__str__(self))

class CalibrationCompleteEvent(NGPHistoryEvent):
    def __str__(self):
        return '{0}'.format(NGPHistoryEvent.__str__(self))

class AlarmNotificationEvent(NGPHistoryEvent):
    def __str__(self):
        return '{0}'.format(NGPHistoryEvent.__str__(self))

class AlarmClearedEvent(NGPHistoryEvent):
    def __str__(self):
        return '{0}'.format(NGPHistoryEvent.__str__(self))

class SensorAlertSilenceStartedEvent(NGPHistoryEvent):
    def __str__(self):
        return '{0}'.format(NGPHistoryEvent.__str__(self))

class SensorAlertSilenceEndedEvent(NGPHistoryEvent):
    def __str__(self):
        return '{0}'.format(NGPHistoryEvent.__str__(self))

class GeneralSensorSettingsChangeEvent(NGPHistoryEvent):
    def __str__(self):
        return '{0}'.format(NGPHistoryEvent.__str__(self))

class DailyTotalsEvent(NGPHistoryEvent):
    def __str__(self):
        return '{0}'.format(NGPHistoryEvent.__str__(self))

class SourceIdConfigurationEvent(NGPHistoryEvent):
    def __str__(self):
        return '{0}'.format(NGPHistoryEvent.__str__(self))

class StartOfDayMarkerEvent(NGPHistoryEvent):
    def __str__(self):
        return '{0}'.format(NGPHistoryEvent.__str__(self))

class EndOfDayMarkerEvent(NGPHistoryEvent):
    def __str__(self):
        return '{0}'.format(NGPHistoryEvent.__str__(self))

class TempBasalEvent(NGPHistoryEvent):
    def __init__(self, eventData):
        NGPHistoryEvent.__init__(self, eventData)

    def __str__(self):
        return ("{0} Preset:{1} {2}, "
                "Type: {3} {4}, "
                "percent: {5}, "
                "fixed rate: {6}, "
                "duration: {7} min."
                ).format(NGPHistoryEvent.__shortstr__(self), 
                         self.presetNumber, 
                         self.presetName,
                         self.type,
                         self.typeName,
                         self.percent,
                         self.fixedRate,
                         self.programmedDurationMin
                         )
        
    @property
    def presetNumber(self):
        return BinaryDataDecoder.readByte(self.eventData, 0x0B)

    @property
    def presetName(self):
        return NGPConstants.TEMP_BASAL_PRESET_NAME[self.presetNumber];

    @property
    def type(self):
        return BinaryDataDecoder.readByte(self.eventData, 0x0C)

    @property
    def typeName(self):
        return "PERCENT" if self.type == NGPConstants.TEMP_BASAL_TYPE.PERCENT else "ABSOLUTE"

    @property
    def fixedRate(self):
        return BinaryDataDecoder.readUInt32BE(self.eventData, 0x0D) / 10000.0

    @property
    def percent(self):
        return BinaryDataDecoder.readByte(self.eventData, 0x11)

    @property
    def programmedDurationMin(self):
        return BinaryDataDecoder.readUInt16BE(self.eventData, 0x12)

class TempBasalStartEvent(TempBasalEvent):
    def __init__(self, eventData):
        TempBasalEvent.__init__(self, eventData)

class TempBasalEndEvent(TempBasalEvent):
    def __init__(self, eventData):
        TempBasalEvent.__init__(self, eventData)

    def __str__(self):
        return ("{0}, "
                "Real duration: {1} min., "
                "Unknown: {2}"
                ).format(TempBasalEvent.__str__(self), 
                         self.realDurationMin, 
                         self.unknown
                         )

    @property
    def unknown(self):
        return BinaryDataDecoder.readByte(self.eventData, 0x14)

    @property
    def realDurationMin(self):
        return BinaryDataDecoder.readUInt16BE(self.eventData, 0x15)