community-repo/community-contributions/joystreamtelegrambot/src/tests.ts

//import TelegramBot from "node-telegram-bot-api";
import { wsLocation } from "../config";

// types
import { Proposals } from "./types";
import { types } from "@joystream/types";
import { ApiPromise, WsProvider } from "@polkadot/api";
import { Header } from "@polkadot/types/interfaces";

// functions
import * as announce from "./lib/announcements";
import * as get from "./lib/getters";

const log = (msg: string): void => console.log(msg);
const sendMessage = log;

const main = async () => {
  const provider = new WsProvider(wsLocation);
  const api = await ApiPromise.create({ provider, types });
  await api.isReady;

  const [chain, node, version] = await Promise.all([
    api.rpc.system.chain(),
    api.rpc.system.name(),
    api.rpc.system.version()
  ]);
  log(`Connected to ${chain} on ${node} v${version}`);

  let lastBlock = 0;
  let proposals: Proposals = {
    last: 1,
    current: 2,
    active: [],
    pending: []
  };
  let categories = [0, 0];
  let posts = [0, 0];
  let threads = [0, 0];
  let channels = [0, 0];

  const unsubscribe = await api.rpc.chain.subscribeNewHeads(
    async (block: Header): Promise<void> => {
      // council
      if (lastBlock > 0) process.exit;
      lastBlock = block.number.toNumber();
      const currentBlock = block.number.toNumber();
      log("current council");
      announce.councils(api, currentBlock, sendMessage);

      log("first proposal");
      announce.proposals(api, proposals, sendMessage);

      log("last proposal");
      proposals.current = await get.proposalCount(api);
      proposals.last = proposals.current - 1;
      announce.proposals(api, proposals, sendMessage);

      log("first category");
      announce.categories(api, categories, sendMessage);

      log("last category");
      categories[1] = await get.currentCategoryId(api);
      categories[0] = categories[1] - 1;
      announce.categories(api, categories, sendMessage);

      log("first post");
      announce.posts(api, posts, sendMessage);

      log("last post");
      posts[1] = await get.currentPostId(api);
      posts[0] = posts[1] - 1;
      announce.posts(api, posts, sendMessage);

      log("first thread");
      announce.threads(api, threads, sendMessage);

      log("last thread");
      threads[1] = await get.currentThreadId(api);
      threads[0] = threads[1] - 1;
      announce.threads(api, threads, sendMessage);

      log("first channel");
      announce.channels(api, channels, sendMessage);

      log("last channel");
      channels[1] = await get.currentChannelId(api);
      channels[0] = channels[1] - 1;
      announce.channels(api, channels, sendMessage);
    }
  );
};

main();