src/api/rescuetime.ts

import { config, cosmicSync } from "@anandchowdhary/cosmic";
import axios from "axios";
import dayjs from "dayjs";
import week from "dayjs/plugin/weekOfYear";
import { lstat, pathExists, readdir, readJson } from "fs-extra";
import { join } from "path";
import { integrationConfig, write } from "../common";
import type { Integration } from "../integration";
dayjs.extend(week);
cosmicSync("stethoscope");

interface RescueTimeDaily {
  id: number;
  date: string;
  productivity_pulse: number;
  very_productive_percentage: number;
  productive_percentage: number;
  neutral_percentage: number;
  distracting_percentage: number;
  very_distracting_percentage: number;
  all_productive_percentage: number;
  all_distracting_percentage: number;
  total_duration_formatted: string;
  very_productive_duration_formatted: string;
  productive_duration_formatted: string;
  neutral_duration_formatted: string;
  distracting_duration_formatted: string;
  very_distracting_duration_formatted: string;
  all_productive_duration_formatted: string;
  all_distracting_duration_formatted: string;
}

interface RescueTimeWeeklySummary {
  row_headers: [string, string, string, string, string, string];
  rows: Array<[number, number, number, string, string, number]>;
}

const updateRescueTimeDailyData = async (date: Date) => {
  const year = dayjs(date).format("YYYY");
  const month = dayjs(date).format("MM");
  const day = dayjs(date).format("DD");
  const formattedDate = dayjs(date).format("YYYY-MM-DD");

  if (integrationConfig("rescuetime", "top-categories")) {
    console.log("RescueTime: Adding data for", date);
    const topCategories = (
      await axios.get(
        `https://www.rescuetime.com/anapi/data?format=json&key=${config(
          "rescuetimeApiKey"
        )}&restrict_kind=category&restrict_begin=${formattedDate}&restrict_end=${formattedDate}`
      )
    ).data as RescueTimeWeeklySummary;
    const topCategoriesHeaders = topCategories.row_headers;
    const topCategoriesItems = topCategories.rows;
    const topCategoriesData: any = [];
    topCategoriesItems.forEach((item) => {
      const details: any = {};
      topCategoriesHeaders.forEach((header, index) => {
        details[header] = item[index];
      });
      topCategoriesData.push(details);
    });
    await write(
      join(".", "data", "rescuetime-time-tracking", "daily", year, month, day, "top-categories.json"),
      JSON.stringify(topCategoriesData, null, 2)
    );
  }
  if (integrationConfig("rescuetime", "top-activities")) {
    const topActivities = (
      await axios.get(
        `https://www.rescuetime.com/anapi/data?format=json&key=${config(
          "rescuetimeApiKey"
        )}&restrict_kind=activity&restrict_begin=${formattedDate}&restrict_end=${formattedDate}`
      )
    ).data as RescueTimeWeeklySummary;
    const topActivitiesHeaders = topActivities.row_headers;
    const topActivitiesItems = topActivities.rows;
    const topActivitiesData: any = [];
    topActivitiesItems.forEach((item) => {
      const details: any = {};
      topActivitiesHeaders.forEach((header, index) => {
        details[header] = item[index];
      });
      topActivitiesData.push(details);
    });
    await write(
      join(".", "data", "rescuetime-time-tracking", "daily", year, month, day, "top-activities.json"),
      JSON.stringify(topActivitiesData, null, 2)
    );
  }

  if (integrationConfig("rescuetime", "overview")) {
    const topOverview = (
      await axios.get(
        `https://www.rescuetime.com/anapi/data?format=json&key=${config(
          "rescuetimeApiKey"
        )}&restrict_kind=overview&restrict_begin=${formattedDate}&restrict_end=${formattedDate}`
      )
    ).data as RescueTimeWeeklySummary;
    const topOverviewHeaders = topOverview.row_headers;
    const topOverviewItems = topOverview.rows;
    const topOverviewData: any = [];
    topOverviewItems.forEach((item) => {
      const details: any = {};
      topOverviewHeaders.forEach((header, index) => {
        details[header] = item[index];
      });
      topOverviewData.push(details);
    });
    await write(
      join(".", "data", "rescuetime-time-tracking", "daily", year, month, day, "top-overview.json"),
      JSON.stringify(topOverviewData, null, 2)
    );
  }
};

interface CategoryData {
  [index: string]: number;
}

export default class RescueTime implements Integration {
  name = "rescuetime";
  cli = {};

  async update() {
    console.log("RescueTime: Starting...");
    for await (const day of [0, 1, 2, 3, 4]) {
      await updateRescueTimeDailyData(dayjs().subtract(day, "day").toDate());
      console.log("RescueTime: Added data");
    }
    console.log("RescueTime: Added daily summaries");
  }
  async legacy(start: string) {
    const startDate = dayjs(start);
    for await (const count of [...Array(dayjs().diff(startDate, "day")).keys()]) {
      const date = dayjs(startDate).add(count, "day");
      await updateRescueTimeDailyData(date.toDate());
    }
    console.log("Done!");
  }
  async summary() {
    if (
      (await pathExists(join(".", "data", "rescuetime-time-tracking", "daily"))) &&
      (await lstat(join(".", "data", "rescuetime-time-tracking", "daily"))).isDirectory()
    ) {
      for await (const file of ["top-categories.json", "top-overview.json"]) {
        const years = (await readdir(join(".", "data", "rescuetime-time-tracking", "daily"))).filter((i) =>
          /^\d+$/.test(i)
        );
        const yearData: { [index: string]: CategoryData } = {};
        const weeklyData: {
          [index: string]: { [index: string]: { [index: string]: CategoryData } };
        } = {};
        for await (const year of years) {
          let yearlySum: CategoryData = {};
          const monthlyData: { [index: string]: CategoryData } = {};
          [...Array(13).keys()].slice(1).forEach((val) => (monthlyData[val.toString()] = {}));
          const months = (await readdir(join(".", "data", "rescuetime-time-tracking", "daily", year))).filter((i) =>
            /^\d+$/.test(i)
          );
          for await (const month of months) {
            let monthlySum: CategoryData = {};
            const dailyData: { [index: string]: CategoryData } = {};
            [...Array(dayjs(`${year}-${month}-10`).daysInMonth()).keys()]
              .slice(1)
              .forEach((val) => (dailyData[val.toString()] = {}));
            const days = (
              await readdir(join(".", "data", "rescuetime-time-tracking", "daily", year, month))
            ).filter((i) => /^\d+$/.test(i));
            for await (const day of days) {
              let json: any[] = [];
              try {
                json = await readJson(join(".", "data", "rescuetime-time-tracking", "daily", year, month, day, file));
              } catch (error) {}
              let dailySum: CategoryData = {};
              if (Array.isArray(json) && json.length) {
                json.forEach((record: any) => {
                  if (record["Time Spent (seconds)"] && record.Category) {
                    dailySum[record.Category] = dailySum[record.Category] || 0;
                    dailySum[record.Category] += record["Time Spent (seconds)"];
                  }
                });
              }
              if (Object.keys(dailySum).length) dailyData[parseInt(day)] = dailySum;
              Object.keys(dailySum).forEach((key) => {
                monthlySum[key] = monthlySum[key] || 0;
                monthlySum[key] += dailySum[key];
                yearlySum[key] = yearlySum[key] || 0;
                yearlySum[key] += dailySum[key];
              });
            }

            Object.keys(dailyData).forEach((key) => {
              const weekNumber = dayjs(`${year}-${month}-${key}`).week();
              weeklyData[year] = weeklyData[year] || {};
              weeklyData[year][weekNumber] = weeklyData[year][weekNumber] || {};
              weeklyData[year][weekNumber][`${year}-${month}-${key}`] = dailyData[key];
            });

            if (Object.keys(dailyData).length)
              await write(
                join(
                  ".",
                  "data",
                  "rescuetime-time-tracking",
                  "summary",
                  file.replace(".json", ""),
                  "days",
                  year,
                  `${month}.json`
                ),
                JSON.stringify(dailyData, null, 2)
              );
            if (monthlySum) monthlyData[parseInt(month)] = monthlySum;
          }
          if (Object.keys(monthlyData).length)
            await write(
              join(
                ".",
                "data",
                "rescuetime-time-tracking",
                "summary",
                file.replace(".json", ""),
                "months",
                `${year}.json`
              ),
              JSON.stringify(monthlyData, null, 2)
            );
          if (yearlySum) yearData[parseInt(year)] = yearlySum;
        }
        if (Object.keys(yearData).length)
          await write(
            join(".", "data", "rescuetime-time-tracking", "summary", file.replace(".json", ""), "years.json"),
            JSON.stringify(yearData, null, 2)
          );
        for await (const year of Object.keys(weeklyData)) {
          for await (const week of Object.keys(weeklyData[year])) {
            if (
              Object.keys(weeklyData[year][week]).length &&
              Object.values(weeklyData[year][week]).reduce((a, b) => a + Object.keys(b).length, 0)
            )
              await write(
                join(
                  ".",
                  "data",
                  "rescuetime-time-tracking",
                  "summary",
                  file.replace(".json", ""),
                  "weeks",
                  year,
                  `${week}.json`
                ),
                JSON.stringify(weeklyData[year][week], null, 2)
              );
          }
        }
      }
    }
  }
}