Notify of new Github repo stars

import * as wmill from "https://deno.land/x/[email protected]/index.ts";

import { Octokit } from "https://cdn.skypack.dev/octokit?dts";

import { WebClient } from "https://deno.land/x/[email protected]/mod.ts";

export async function main(

    gh_auth: wmill.Resource<"github">,

    owner: string,

    repo: string,

    channel: string,

    username: string

) {

    const octokit = new Octokit(gh_auth);

    const response = await octokit.rest.repos.get({

        owner,

        repo,

    });

    let repo_list = {};

    repo_list[response.data.name] = response.data.stargazers_count;

    const before = await wmill.getInternalState();

    const key = Object.keys(repo_list)[0];

    await wmill.setInternalState({ [key]: repo_list[key] });

    const after = await wmill.getInternalState();

    const before_val: number = Object.values(before)[0];

    const after_val: number = Object.values(after)[0];

    let notification_list = [];

    let notification: string =

        `No new Github stars on the following repo: \n ${key} : ${before_val} Stars`;

    if (after_val > before_val) {

        const difference: number = after_val - before_val;

        notification =

            `You have received ${difference} new Github stars on the following repo:\n${key} `;

        notification_list.push(notification);

    }

    return notification_list;

}

import {

  setState,

  getState,

} from "https://deno.land/x/[email protected]/mod.ts";

import { Octokit } from "npm:@octokit/[email protected]";

const MAX_ITEMS = 500;

/**

 * @returns A list of starrers in descending order of when they starred.

 * The maximum number of returned items is 500.

 */

type Github = {

  token: string;

};

export async function main(auth: Github, owner: string, repo: string) {

  const octokit = new Octokit({

    auth: auth.token,

  });

  const lastUpdate = (await getState()) || 0;

  const starCount = (await octokit.repos.get({ owner, repo })).data

    .stargazers_count;

  let lastPage =

    +(starCount / 100).toFixed(0) + (starCount % 100 === 0 ? 0 : 1);

  const newStarrers: Starrer[] = [];

  await setState(Date.now());

  let runLoop = true;

  do {

    const response = await octokit.activity.listStargazersForRepo({

      owner,

      repo,

      per_page: 100,

      page: lastPage--,

      headers: {

        accept: "application/vnd.github.star+json",

      },

    });

    for (let i = response.data.length - 1; i >= 0; i--) {

      const entry = response.data[i];

      if (!entry || !entry.user) continue;

      const starredAt = new Date(entry.starred_at).getTime();

      if (starredAt < lastUpdate) {

        runLoop = false;

        break;

      }

      const { id, login, type, url, email, name } = entry.user;

      newStarrers.push({ id, starredAt, login, type, url, email, name });

      if (newStarrers.length >= MAX_ITEMS) {

        await setState(newStarrers.at(-1)?.starredAt);

        runLoop = false;

        break;

      }

    }

  } while (runLoop);

  console.log(newStarrers.length);

  return newStarrers;

}

interface Starrer {

  id: number;

  login: string;

  type: string;

  url: string;

  starredAt: number;

  email?: string | null;

  name?: string | null;

}

import { setState, getState } from "windmill-client@1";

import { Octokit } from "@octokit/[email protected]";

const MAX_ITEMS = 500;

/**

 * @returns A list of starrers in descending order of when they starred.

 * The maximum number of returned items is 500.

 */

type Github = {

  token: string;

};

export async function main(auth: Github, owner: string, repo: string) {

  const octokit = new Octokit({

    auth: auth.token,

  });

  const lastUpdate = (await getState()) || 0;

  const starCount = (await octokit.repos.get({ owner, repo })).data

    .stargazers_count;

  let lastPage =

    +(starCount / 100).toFixed(0) + (starCount % 100 === 0 ? 0 : 1);

  const newStarrers: Starrer[] = [];

  await setState(Date.now());

  let runLoop = true;

  do {

    const response = await octokit.activity.listStargazersForRepo({

      owner,

      repo,

      per_page: 100,

      page: lastPage--,

      headers: {

        accept: "application/vnd.github.star+json",

      },

    });

    for (let i = response.data.length - 1; i >= 0; i--) {

      const entry = response.data[i];

      if (!entry || !entry.user) continue;

      const starredAt = new Date(entry.starred_at).getTime();

      if (starredAt < lastUpdate) {

        runLoop = false;

        break;

      }

      const { id, login, type, url, email, name } = entry.user;

      newStarrers.push({ id, starredAt, login, type, url, email, name });

      if (newStarrers.length >= MAX_ITEMS) {

        await setState(newStarrers.at(-1)?.starredAt);

        runLoop = false;

        break;

      }

    }

  } while (runLoop);

  console.log(newStarrers.length);

  return newStarrers;

}

interface Starrer {

  id: number;

  login: string;

  type: string;

  url: string;

  starredAt: number;

  email?: string | null;

  name?: string | null;

}