Compare commits

...

2 Commits

View File

@ -1,15 +1,30 @@
import fetch from 'node-fetch';
import { TelegramClient, Api as TgApi } from 'telegram';
import { StoreSession } from 'telegram/sessions/index.js';
import { StringSession } from 'telegram/sessions/index.js';
import 'dotenv/config';
import prompt from 'prompt';
import fs from 'fs/promises';
import path from 'path';
import { fileURLToPath } from 'url';
const __filename = fileURLToPath(import.meta.url);
const __dirname = path.dirname(__filename);
const apiId = parseInt(process.env.API_ID);
const apiHash = process.env.API_HASH;
const songPrefix = process.env.SONG_PREFIX || "";
console.log(process.env);
const sessionStore = new StoreSession("tg_session");
const sessionFile = path.join(__dirname, 'tg_session', 'session');
let sessionStore = new StringSession("");
try {
const readSession = await fs.readFile(sessionFile, "utf8");
if (readSession) {
sessionStore = new StringSession(readSession);
}
} catch (e) {
console.error(e);
}
async function getCurrentSong() {
return fetch('https://multi-scrobbler.riksolo.com/api/status').then((data) => {
@ -35,7 +50,8 @@ async function getCurrentSong() {
// if a player exists, get it's song
if (sortedPlayers.length !== 0) {
const playData = sortedPlayers[0].play.data;
const playData = sortedPlayers[0]?.play?.data;
if (!playData) return "";
nowPlaying = `${playData.artists.join(', ')} - ${playData.track}`;
}
@ -72,21 +88,18 @@ async function initTelegram() {
onError: (err) => console.error(err)
});
// save the session so we don't have to log in every time
client.session.save();
await fs.writeFile(sessionFile, sessionStore.save());
return client;
}
prompt.start();
// store client here
const tg = await initTelegram();
// do we actually have a client?
if (!!tg) {
let song = "";
@ -99,6 +112,8 @@ if (!!tg) {
console.log(`new song: ${song}`);
const ytURL = await getYoutube(song);
// update bio with new song
tg.invoke(new TgApi.account.UpdateProfile({
about: songPrefix + song