community-repo/community-contributions/joystreamvideobot/src/bot.ts

import { channelId, hydraLocation, waitFor, waitTimeUnit, createdAgo, createdAgoUnit } from "../config";
import { readFileSync } from 'fs';
import axios from 'axios';
import {IVideoResponse, LooseObject}  from './types';

const moment = require('moment');
const momentFormat = require("moment-duration-format");
const Discord = require("discord.js");
momentFormat(moment);

const delay = (ms: number | undefined) => new Promise(res => setTimeout(res, ms));

const queryParams = readFileSync('./query_params.json', 'utf-8');
const graphql = readFileSync('./videos_query.graphql', 'utf-8').replaceAll("\n", "\\n");
const httpRequestBody = readFileSync('./request.json', 'utf-8').replace('__PARAMS__', queryParams).replace('__QUERY__', graphql);
const licenses: LooseObject = JSON.parse(readFileSync('./licenses.json', 'utf-8'));


const main = async () => {

  const client = new Discord.Client();

  client.once("ready", async () => {
    console.log('Discord.js client ready');
    await client.channels.fetch(channelId);
  });
  
  await client.login(process.env.TOKEN); // environment variable TOKEN must be set
  console.log('Bot logged in successfully');

  let ids: any[] = [];

  do {
    const createdAt = moment().utc().subtract(createdAgo, createdAgoUnit); // current time minus some configurable number of time units
    const formattedDate = createdAt.format('YYYY-DD-MMMTHH:mm:ssZ');
    console.log(`Checking for new videos uploaded since ${formattedDate}`);

    await axios
      .post(hydraLocation, httpRequestBody.replace('__DATE_AFTER__', formattedDate), {headers: {'Content-Type': 'application/json'}})
      .then((res: any) => {
        let response: IVideoResponse = <IVideoResponse>res.data;
        if(response.data.videosConnection) {
          console.log(`${response.data.videosConnection.edges.length} new videos uploaded`)
          for (let edge of response.data.videosConnection.edges) {   
            if (!edge.node.thumbnailPhotoDataObject) {
              continue; // metadata for this video is not yet ready. Video will be announced in next iterations.
            }
            if (lookup(ids, edge.node.id)) {
              console.log(`Video ${edge.node.id} already announced. `);
            } else {
              const channel = client.channels.cache.get(channelId);
              const licenseKey = edge.node.license.code;
              const exampleEmbed = new Discord.MessageEmbed()
                .setColor('#4038FF') // official joystream blue, see https://www.joystream.org/brand/guides/
                .setTitle(edge.node.title)
                .setURL(`https://play.joystream.org/video/${edge.node.id}`)
                .setDescription(edge.node.description.substring(1, 200)) // cut off lengthy descriptions 
                .addFields(
                  { name: 'ID', value: edge.node.id, inline: true },
                  { name: 'Category', value: edge.node.category.name, inline: true},
                  { name: 'Duration', value: durationFormat(edge.node.duration), inline: true },
                  { name: 'Language', value: edge.node.language.iso, inline: true },
                  { name: 'License', value: licenses[licenseKey], inline: true },
                )
                .setImage(`${edge.node.thumbnailPhotoDataObject.liaison.metadata}asset/v0/${edge.node.thumbnailPhotoDataObject.joystreamContentId}`)
                .setTimestamp();
                if(edge.node.channel.avatarPhotoDataObject && edge.node.channel.avatarPhotoDataObject.liaison) {
                  const avatar = 
                        `${edge.node.channel.avatarPhotoDataObject.liaison.metadata}asset/v0/${edge.node.channel.avatarPhotoDataObject.joystreamContentId}`;
                  exampleEmbed.setAuthor(edge.node.channel.title, avatar, `https://play.joystream.org/channel/${edge.node.channel.id}`);
                } else {
                  exampleEmbed.setAuthor(edge.node.channel.title);
                }
              channel.send(exampleEmbed);
              ids.push({id: edge.node.id, createdAt: Date.parse(edge.node.createdAt)});
            }
          }  
          cleanup(ids, createdAt);
        }
      })
      .catch((error: any) => {
        console.error(error);
      });

      // waiting... 
      await delay(moment.duration(waitFor, waitTimeUnit).asMilliseconds());

  } while (true);

}

const cleanup = (ids: any[], cutoffDate: Date) => {
  console.log("Local storage cleaning in progress");
  let cleaned = 0;
  ids.reduceRight(function(acc, item, index, object) {
    if (item.createdAt < cutoffDate) {
      object.splice(index, 1);
      cleaned += 1;
    }
  }, []);
  if (cleaned > 0) {
    console.log(`Cleaned records: ${cleaned}`);
  }
}

const lookup = (ids: any[], id: string) => {
  for (let video of ids) {
    if (video.id == id) {
      return true;
    }
  }
  return false;
}

const durationFormat = (duration: number) => {
  if (duration < 60) {
    return `${duration}s.`
  } else {
     return moment.duration(duration, 'seconds').format("hh:mm:ss")
  }
}

main().catch(console.error).finally(() => process.exit());;