Email Power

import { DataPowers } from "@andi/powers";
import { ISkillActivity, ISkillContext } from "andiskills";

type OpportunityInfo = {
    name: string;
    url: string;
    totalLoanAmount: number;
    updateTimestamp: number;
}

// method to extract relevant information from the 
export function getOpportunityInfoFromEvent(skillContext: ISkillContext): OpportunityInfo {
    const applicationEvent = skillContext.powers.andi.event.getApplicationEvent();
    const applicationEventData = applicationEvent.applicationEventData;
    const opportunityData = applicationEventData.opportunityData;

    const opportunityInfo: OpportunityInfo = {
        name: opportunityData?.name,
        url: applicationEvent.eventMetaData.currentUrl,
        totalLoanAmount: opportunityData?.financialStatement?.loanAmount,
        updateTimestamp: Date.now()
    };
    return opportunityInfo;
}

async function storeOpportunityInfo(dataKey: string, opportunityInfo: OpportunityInfo): Promise {

    // use DataPowers to load existing data, if it's 
    // undefined then initialize it to an empty array
    let opportunityInfoList: OpportunityInfo[] = (await DataPowers.get<OpportunityInfo[]>(dataKey)) ?? [];
    opportunityInfoList.push(opportunityInfo);

    // filter out older duplicate opportunities
    const latestOpportunities = opportunityInfoList
        .reduce((results, currentOpportunity) => {
            // see if the current Opportunity exists 
            const found = results.find((item, index) => {
            if (item.url === currentOpportunity.url && 
                item.updateTimestamp < currentOpportunity.updateTimestamp) {
                    // replace older opportunity with latest
                    results[index] = currentOpportunity;
                    return currentOpportunity;
                } 
            });
            // if no match found then add to results
            if (!found) results.push(currentOpportunity);

            return results;
        }, [] as OpportunityInfo[]);

    // remove any older unwanted data so that our array 
    // is limited in size for performance
    const filterDate = new Date();
    filterDate.setMonth(filterDate.getMonth() - 1);
    const finalListOfOpportunities = latestOpportunities
      .filter((opp) => opp.updateTimestamp > filterDate.getTime());

    // update this array in data store
    await DataPowers.set(dataKey, finalListOfOpportunities);

    return opportunityInfoList.length;
}
 
export async function run(skillContext: ISkillContext) : Promise{
    // name for storing data, we will use this key 
    // name for retrieving data while building report later    
    const dataKey = `Email-Report-OppSaved-Weekly`;
    const precisionLenderPowers = skillContext.powers.precisionLender;
    const opportunityPowers = precisionLenderPowers.opportunity;
    const andiPowers = skillContext.powers.andi;
    const chatPowers = andiPowers.chat;
    
    // logic to accumulate data for report on
    // `OpportunitySavedClickEvent` unique key 
    const opportunityInfo = getOpportunityInfoFromEvent(skillContext);
    const numberOfOpportunities = await storeOpportunityInfo(dataKey, opportunityInfo);
    return chatPowers.sendSimpleHeader(`opportunityInfoList length: ${numberOfOpportunities}`);
}