index.js

import {
  Bot,
  InlineQueryResultBuilder,
  webhookCallback,
} from 'grammy';
import { createServer } from 'node:http';
import 'dotenv/config';

const bot = new Bot(process.env.TOKEN);
const botUpdateOpts = {
  allowed_updates: ['message', 'inline_query'],
};

let profs = [];
async function update() {
  const resp = await fetch('https://classifikators.ru/assets/downloads/okved/okved.csv');
  if (!resp.ok || !resp.body) {
    console.error('KTHXBYE');
    return;
  }
  const newBody = resp.body
    .pipeThrough(new TextDecoderStream('windows-1251'))
    .pipeThrough(new TextEncoderStream());
  const data = await new Response(newBody).text();
  profs = data
    .split('\r\n')
    .filter(x => x != '')
    .map(x => x
         .split(';')[2]
         .replace(/^"(.+)"$/, '$1'));
}
await update();

const escMd = txt => txt.replace(/([_\*\[\]\(\)~\``>#\+\-=|\{\}\.!])/g, '\\$1');
function getProf() {
  if (profs.length == 0) {
    update();
    return 'Список профессий не был загружен…';
  }
  return profs[Math.floor(Math.random() * profs.length)];
}

bot.command('start', ctx => ctx.reply(
  'Привет! Этот бот поможет выбрать профессию по случайному выбору из ОКВЭД.' +
  `\nДля того, чтобы начать, введите /get_prof или используйте инлайн запросы, набрав @${bot.me.username} <пробел>, должна появиться кнопка.`
));

bot.command('get_prof', ctx => ctx.reply(getProf()));

bot.on('inline_query', async ctx => {
  const result = InlineQueryResultBuilder
    .article('prof', 'Познай свою профессию')
    .text(`_${escMd('В следующей жизни у меня будет профессия…')}_\n${escMd(getProf())}`,
      { parse_mode: 'MarkdownV2' });
  await ctx.answerInlineQuery([result], { cache_time: 0, is_personal: true });
});

console.log('let\'s go');
switch (process.env.MODE) {
  case 'debug':
    await bot.api.deleteWebhook();
    bot.start(botUpdateOpts);
    break;
  case 'prod': {
    await bot.api.setWebhook(process.env.WEBHOOK_URL, botUpdateOpts);
    const server = createServer(webhookCallback(bot, 'http'));
    server.listen(
      parseInt(process.env.SRV_PORT) || 8300,
      process.env.SRV_HOST || 'localhost',
      () => console.log('webhook is ready')
    );
    break;
  }
}