Case Study - JITAI Notifications

npm install uuid jsonwebtoken luxon

let serviceHeaders = {
    'Content-Type': 'application/json',
    'Accept': 'application/json',
    'Authorization': `Bearer ${serviceAccessToken}`
};

const projectId = '1cd23328-5964-46f4-a918-9f9331e09810';
const segmentId = 'a22bffc3-66c0-44bc-92b7-504e09b16bf0';

let allParticipants = [];
let participantPage;
let pageNum = 0;
do {
    participantPage = await fetch(`${baseUrl}/api/v1/administration/projects/${projectId}/participants?segmentId=${segmentId}&pageNumber=${pageNum}&pageSize=100`, {
        method: 'get',
        headers: serviceHeaders
    }).then(res => res.json());
    allParticipants = allParticipants.concat(participantPage.participants);
    pageNum += 1;
} while (allParticipants.length < participantPage.totalParticipants);

console.log(allParticipants);

allParticipants = allParticipants.filter(p => isTimeWithinLastMinute(p.customFields.MorningTime, p.demographics.timeZone)
    || isTimeWithinLastMinute(p.customFields.LunchTime, p.demographics.timeZone)
    || isTimeWithinLastMinute(p.customFields.AfternoonTime, p.demographics.timeZone)
    || isTimeWithinLastMinute(p.customFields.DinnerTime, p.demographics.timeZone));

// ...

function isTimeWithinLastMinute(timeStr, timeZone) {

    const inputTime = DateTime.fromFormat(timeStr, 'h:mm a', { zone: timeZone }).set({
        year: DateTime.local().year,
        month: DateTime.local().month,
        day: DateTime.local().day
    });
    const currentTime = DateTime.local().setZone(timeZone);

    const diff = Math.abs(currentTime.diff(inputTime, 'minutes').minutes);

    return diff <= 1;
}

const weekAgo = DateTime.local().setZone(participant.demographics.timeZone).minus({ days: 7 });

let bloodPressureQueryResponse = await fetch(`${baseUrl}/api/v1/administration/projects/${projectId}/devicedatapoints?participantIdentifier=${participant.participantIdentifier}&namespace=Omron&type=BloodPressureDiastolic,BloodPressureSystolic&observedAfter=${weekAgo}`, {
    method: 'get',
    headers: serviceHeaders
}).then(res => res.json());

let bloodPressureDeviceDataPoints = bloodPressureQueryResponse.deviceDataPoints;

let dailyStepsQueryResponse = await fetch(`${baseUrl}/api/v1/administration/projects/${projectId}/devicedatapoints?participantIdentifier=${p.participantIdentifier}&namespace=Fitbit&type=Steps&observedAfter=${weekAgo}`, {
    method: 'get',
    headers: serviceHeaders
}).then(res => res.json());

let dailySteps = dailyStepsQueryResponse.deviceDataPoints;

let notificationBank = [{
    notificationIdentifier: "project-meds-user-morning-6",
    morning: true,
    afternoon: false,
    lunch: true,
    dinner: false,
    user: true,
    standard: false,
    activity: false,
    planning: false
}, {
    notificationIdentifier: "project-physical-planning-7",
    morning: false,
    afternoon: false,
    lunch: false,
    dinner: true,
    user: false,
    standard: false,
    activity: false,
    planning: true
},
// ...
];

let timeOfDay = isTimeWithinLastMinute(participant.customFields.MorningTime, participant.demographics.timeZone) ? "morning" :
    isTimeWithinLastMinute(participant.customFields.LunchTime, participant.demographics.timeZone) ? "lunch" :
        isTimeWithinLastMinute(participant.customFields.AfternoonTime, participant.demographics.timeZone) ? "afternoon" :
            isTimeWithinLastMinute(participant.customFields.DinnerTime, participant.demographics.timeZone) ? "dinner" : "error";

if (
    bloodPressureDeviceDataPoints.some(d => (d.type === "BloodPressureSystolic" && parseInt(d.value) > 130) || (d.type === "BloodPressureDiastolic" && parseInt(d.value) > 80))
    && parseInt(participant.customFields.MedicationAdherenceLastWeek) < 21
    && dailyStepsDeviceDataPoints.map(ddp => parseInt(ddp.value)).reduce((a, b) => a + b, 0) / dailyStepsDeviceDataPoints.length < parseInt(participant.customFields.StepsGoalLastWeek)
) {
    // 1st dice roll - 66% meds 33% physical activity
    let firstDiceRoll = Math.random() <= 0.666666 ? "meds" : "physical";

    let secondDiceRoll;
    if (firstDiceRoll === "meds") {
        // 2nd dice roll for meds - 66% user 33% standard
        secondDiceRoll = Math.random() <= 0.666666 ? "user" : "standard";
    }
    else {
        // 2nd dice roll for physical activity - 66% planning 33% activity
        secondDiceRoll = Math.random() <= 0.666666 ? "planning" : "activity";
    }

    // 3rd dice roll - randomization - send or don't send
    let thirdDiceRoll = Math.random() <= 0.375 ? "1" : "0";

    // Select which notification to send from the ones that qualify
    let qualifyingNotifications = notificationBank.filter(n => n[timeOfDay] && n[firstDiceRoll] && n[secondDiceRoll]);
    let selectedNotification = qualifyingNotifications[Math.floor(Math.random() * qualifyingNotifications.length)];

    let diceRoll = `${firstDiceRoll}-${secondDiceRoll}-${thirdDiceRoll}`;

    deviceDataPointsToPersist.push({
        participantIdentifier: participant.participantIdentifier,
        type: `${timeOfDay}NotificationDiceRoll`,
        observationDate: DateTime.local().toISO(),
        value: diceRoll
    });

    if (thirdDiceRoll === "1") {
        notificationsToSend.push({
            participantIdentifier: participant.participantIdentifier,
            notificationIdentifier: selectedNotification.notificationIdentifier
        });
    }
}

let persistDiceRollsResponse = await fetch(`${baseUrl}/api/v1/administration/projects/${projectId}/devicedatapoints`, {
    method: 'post',
    headers: serviceHeaders,
    body: JSON.stringify(deviceDataPointsToPersist)
}).then(res => res.json());

let sendNotificationsResponse = await fetch(`${baseUrl}/api/v1/administration/projects/${projectId}/notifications`, {
    method: 'post',
    headers: serviceHeaders,
    body: JSON.stringify(notificationsToSend)
}).then(res => res.json());