Exporting API Consumer Billing Data

mutation generateFile($input: generateFileInput!) {
  generateFile(input: $input) {
		id
		action_name
		action_status
		result_file_link
  }
}

{
  "input": {
    "from": "2023-09-01T00:00:00.000Z",
    "to": "2023-09-30T23:59:59.999Z",
    "actionName": "SUBSCRIPTIONS"
  }
}

query getFileDetails($id: ID!) {
  getFileDetails(id: $id) {
		id
		action_name
		action_status
		result_file_link
  }
} 

{
  "id": "id_that_was_provided_in_previous_mutation_a16a5e74-35e3-4ed8..."
}

const fs = require('fs');
const csv = require("csvtojson");

const calculateOverCharge = (
  subscription,
  quotasBySubscriptionId
) => {
  const {
    subscription_id,
    object_id,
    object_limit_type,
    object_name,
    object_overage_cost,
    object_quota_limit,
    object_quota_type,
  } = subscription;

  const currentObjectQuotas = quotasBySubscriptionId[subscription_id]?.[object_id];

  if (!currentObjectQuotas) {
    return
  }
  // if overCharge is zero there is no sense to calculate it
  if (Number(object_overage_cost) === 0) {
    return;
  }

  let over_usage_amount = 0;
  let over_usage_total_price = 0;

  if (object_quota_type === 'MONTHLY') {
    const sumOfAllQuotas = currentObjectQuotas.reduce((result, currentQuota) => {
      return result + Number(currentQuota.object_usage)
    }, 0);
    const delta = sumOfAllQuotas - Number(object_quota_limit)
    over_usage_amount = delta > 0 ? delta : 0;
    over_usage_total_price = over_usage_amount * Number(object_overage_cost);
  } else {
    const sumOfAllQuotas = currentObjectQuotas.reduce((result, currentQuota) => {
      const delta = Number(currentQuota.object_usage) - Number(object_quota_limit);

      return delta > 0 ? result + delta : result
    }, 0);

    over_usage_amount = sumOfAllQuotas;
    over_usage_total_price = over_usage_amount * Number(object_overage_cost);
  }

  // there is no over usage
  if (over_usage_amount === 0) {
    return;
  }

  return {
    object_id,
    object_limit_type,
    object_name,
    object_overage_cost: +object_overage_cost,
    object_quota_limit: +object_quota_limit,
    object_quota_type,
    over_usage_total_price,
    over_usage_amount,
  }
}

const run = async () => {
  const quotas = await csv().fromFile('./quotas.csv');

  const quotasBySubscriptionId = quotas.reduce((result, quota) => {
    const currentSubscription = result[quota.subscription_id];

    if (!quota.object_id) {
      return result;
    }

    return {
      ...result,
      [quota.subscription_id]: {
        ...currentSubscription,
        [quota.object_id]: [...(currentSubscription?.[quota.object_id] || []), quota],
      }
    }

  }, {});

  const subscriptions = await csv().fromFile('./subscriptions.csv');

  const subscriptionsByConsumerIDs = {};

  subscriptions.forEach(subscription => {
    const subscriptionConsumerID = subscription.subscription_owner_id;
    const subscriptionID = subscription.subscription_id;

    // consumer not yet populated in the subscriptionsByConsumerIDs object
    if (!subscriptionsByConsumerIDs[subscriptionConsumerID]) {
      const {
        // Subscription data
        subscription_owner_id,
        subscription_owner_org_email,
        subscription_owner_org_id,
        subscription_owner_org_name,
        subscription_owner_team_name,
        subscription_owner_type,
        subscription_owner_user_email,
        subscription_owner_user_name,
      } = subscription;

      subscriptionsByConsumerIDs[subscriptionConsumerID] = {
        consumerData: {
          subscription_owner_id,
          subscription_owner_org_email,
          subscription_owner_org_id,
          subscription_owner_org_name,
          subscription_owner_team_name,
          subscription_owner_type,
          subscription_owner_user_email,
          subscription_owner_user_name,
        },
        subscriptions: {},
      }
    }

    // the current subscription not yet populated in the subscriptions object
    if (!subscriptionsByConsumerIDs[subscriptionConsumerID].subscriptions[subscriptionID]) {
      const {
        // API data
        api_id,
        api_name,
        api_owner_id,
        api_owner_org_email,
        api_owner_org_id,
        api_owner_org_name,
        api_owner_team_name,
        api_owner_type,
        api_owner_user_email,
        api_owner_user_name,
        api_version_id,
        api_version_name,
        // Plan details
        api_billing_plan_name,
        api_billing_plan_plan_type,
        api_billing_plan_price,
        api_billing_plan_version_id,
        //subscription data
        subscription_created_date,
        subscription_deleted_date,
      } = subscription;

      subscriptionsByConsumerIDs[subscriptionConsumerID].subscriptions[subscriptionID] = {
        created_date: subscription_created_date,
        deleted_date: subscription_deleted_date,
        plan: {
          api_billing_plan_name,
          api_billing_plan_plan_type,
          api_billing_plan_price: api_billing_plan_price ? Number(api_billing_plan_price) : 0,
          api_billing_plan_version_id,
        },
        api: {
          api_id,
          api_name,
          api_owner_id,
          api_owner_org_email,
          api_owner_org_id,
          api_owner_org_name,
          api_owner_team_name,
          api_owner_type,
          api_owner_user_email,
          api_owner_user_name,
          api_version_id,
          api_version_name,
        },
        overUsage: []
      }
    }

    const calculatedOverCharge = calculateOverCharge(
      subscription,
      quotasBySubscriptionId
    )
    if (calculatedOverCharge) {
      subscriptionsByConsumerIDs[subscriptionConsumerID].subscriptions[subscriptionID].overUsage.push(calculatedOverCharge)
    }
  })
  return subscriptionsByConsumerIDs;
}