export async function storeOutcome()

in projects/deliberation_at_scale/packages/orchestrator/src/utilities/outcomes.ts [14:64]
41 lines of code
10 McCabe index (conditional complexity)

export async function storeOutcome<PayloadType extends BaseRoomWorkerTaskPayload, ResultType>(options: StoreOutcomeOptions<PayloadType, ResultType>) {
    const { helpers, getOutcomeSourcesMessageIds, getOutcomeContent, getOutcomeType } = options;
    const { payload } = helpers;
    const { roomId } = payload;
    const messageIds = await getOutcomeSourcesMessageIds?.(helpers) ?? [];
    const outcomeContent = await getOutcomeContent?.(helpers);
    const outcomeType = await getOutcomeType?.(helpers);

    // guard: an outcome cannot exist with a credible source, in this case the messages
    if (!outcomeContent || !outcomeType || isEmpty(messageIds)) {
        helpers.helpers.logger.error(`Could not create an outcome with content ${outcomeContent} for job payload ${JSON.stringify(helpers.payload)}`);
        return;
    }

    // store the outcome to get the outcome ID to use for the outcome sources
    const { data: outcomeData } = await supabaseClient
        .from("outcomes")
        .insert({
            content: outcomeContent,
            type: outcomeType,
            room_id: roomId,
        })
        .select()
        .limit(1);
    const outcome = outcomeData?.[0];
    const outcomeId = outcome?.id;

    // guard: make sure there is an outcome
    if (!outcomeId) {
        helpers.helpers.logger.error(`Could not create an outcome with content ${outcomeContent} for job payload ${JSON.stringify(helpers.payload)}`);
        return;
    }

    const outcomeSourcesResult = await supabaseClient
        .from("outcome_sources")
        .insert(messageIds?.map((messageId) => {
            return {
                outcome_id: outcomeId,
                message_id: messageId,
            };
        }))
        .select();

    // check if all message references were stored
    if ((outcomeSourcesResult?.data?.length ?? 0) < messageIds.length) {
        helpers.helpers.logger.error(`Could not create all outcome sources for outcome: ${outcomeId}`);
    }

    helpers.helpers.logger.info(`Created outcome ${outcomeId} with content ${outcomeContent} for job payload ${JSON.stringify(helpers.payload)}`);
    return outcome;
}