Peningkatan III: Reliabilitas
Sebelum memulai, pastikan kamu sudah memasang error handler yang sesuai dengan bot-mu. Semua error yang kemungkinan besar bisa terjadi (pemanggilan API yang gagal, koneksi yang tidak tersambung, query database yang gagal dilakukan, middleware yang tidak berjalan dengan baik, dsb) harus bisa ditangkap dan ditangani dengan baik.
Kamu juga sebaiknya menggunakan await di setiap promise. Jika masih bersikeras untuk tidak menggunakan await, setidaknya pasang catch sebagai gantinya. Pakai linting rule supaya kamu tidak lupa menggunakannya.
Graceful shutdown
Ada satu hal yang harus diperhatikan khusus untuk bot-bot yang menggunakan long polling. Sebelum mematikan bot atau instance yang sedang berjalan, kamu sebaiknya menangkap event SIGTERM dan SIGINT terlebih dahulu, kemudian panggil bot (built-in di long polling) atau hentikan bot menggunakan handle (grammY runner)
Long Polling Sederhana
import { Bot } from "grammy";
const bot = new Bot("");
// Hentikan bot ketika proses Node.js akan dimatikan
process.once("SIGINT", () => bot.stop());
process.once("SIGTERM", () => bot.stop());
await bot.start();2
3
4
5
6
7
8
9
const { Bot } = require("grammy");
const bot = new Bot("");
// Hentikan bot ketika proses Node.js akan dimatikan
process.once("SIGINT", () => bot.stop());
process.once("SIGTERM", () => bot.stop());
await bot.start();2
3
4
5
6
7
8
9
import { Bot } from "https://deno.land/x/grammy@v1.30.0/mod.ts";
const bot = new Bot("");
// Hentikan bot ketika proses Deno akan dimatikan
Deno.addSignalListener("SIGINT", () => bot.stop());
Deno.addSignalListener("SIGTERM", () => bot.stop());
await bot.start();2
3
4
5
6
7
8
9
Menggunakan grammY Runner
import { Bot } from "grammy";
import { run } from "@grammyjs/runner";
const bot = new Bot("");
const runner = run(bot);
// Hentikan bot ketika proses Node.js akan dimatikan
const stopRunner = () => runner.isRunning() && runner.stop();
process.once("SIGINT", stopRunner);
process.once("SIGTERM", stopRunner);2
3
4
5
6
7
8
9
10
11
const { Bot } = require("grammy");
const { run } = require("@grammyjs/runner");
const bot = new Bot("");
const runner = run(bot);
// Hentikan bot ketika proses Node.js akan dimatikan
const stopRunner = () => runner.isRunning() && runner.stop();
process.once("SIGINT", stopRunner);
process.once("SIGTERM", stopRunner);2
3
4
5
6
7
8
9
10
11
import { Bot } from "https://deno.land/x/grammy@v1.30.0/mod.ts";
import { run } from "https://deno.land/x/grammy_runner@v2.0.3/mod.ts";
const bot = new Bot("");
const runner = run(bot);
// Hentikan bot ketika proses Deno akan dimatikan
const stopRunner = () => runner.isRunning() && runner.stop();
Deno.addSignalListener("SIGINT", stopRunner);
Deno.addSignalListener("SIGTERM", stopRunner);2
3
4
5
6
7
8
9
10
11
Itulah tips-tips untuk menjaga reliabilitas bot kamu. Jika diterapkan dengan benar, seharusnya tidak akan terjadi crash lagi di bot kamu.
Menjamin Reliabilitas
Bagaimana jika suatu saat bot kamu sedang menangani transaksi pembayaran, lalu kamu dihadapkan skenario kill karena CPU tiba-tiba terbakar atau terjadi pemadaman listrik secara tiba-tiba. Masalah akan menjadi sedikit rumit ketika dihadapkan dengan kondisi yang mengharuskan proses bot dihentikan secara paksa di saat itu juga.
Akibatnya, bot tidak bisa menjamin eksekusi middleware kamu dijalankan tepat satu kali. Simak diskusi di Git
Apakah kamu cuma tertarik untuk membuat bot Telegram? Silahkan lewati sisa halaman ini
.
Webhook
Kalau kamu menjalankan bot menggunakan webhook, server API Bot akan terus mengirim ulang update ke bot kamu ketika ia tidak menerima respon OK. Itulah kenapa bot kamu akan mengirim pesan duplikat ketika ia dijalankan kembali dari proses penghentian yang tidak wajar. Kalau kamu ingin mencegah hal tersebut terjadi, kamu harus membuat pencegah duplikasimu sendiri berdasarkan update karena grammY belum menyediakan fitur tersebut. Tetapi, jika kamu merasa seseorang akan terbantu dengan pencegah duplikasi buatanmu, silahkan kirim pull request ke repositori kami.
Long Polling
Long polling lebih menarik lagi. Polling bawaan pada dasarnya memproses kembali batch update terbaru yang sebelumnya gagal diproses.
Perlu diingat bahwa jika kamu menghentikan bot menggunakan
bot, offset dari update tersebut akan disinkronkan dengan server Telegram dengan cara memanggil.stop getbeserta offset yang benar, namun data update-nya tidak diproses kembali.Updates
Dengan kata lain, kamu tidak akan kehilangan update sama sekali, tetapi besar kemungkinan bot kamu akan memproses 100 update yang sudah diproses sebelumnya. Karena pemanggilan send dilakukan sama persis, maka user akan menerima pesan duplikat dari bot kamu. Tetapi, dengan cara demikian setidaknya satu pemrosesan bisa terjamin.
grammY Runner
Kalau kamu menggunakan grammY runner di mode concurrent, pemanggilan get berikutnya berpotensi dilakukan sebelum middleware kamu selesai memproses update pertama dari batch tersebut. Itulah kenapa, update offset-nya terkonfirmasi sebelum waktunya. Ini adalah efek dari penggunaan concurrency secara maksimal, dan sayangnya, kita tidak bisa menghindarinya tanpa mengurangi responsifitas dan jumlah output-nya. Dampaknya, jika bot kamu dihentikan di momen yang tidak tepat, 100 update yang sebelumnya sudah diminta tetapi belum diproses, tidak bisa diminta lagi karena Telegram telah menandainya sebagai sudah diproses. Sehingga, data-data update tadi akan hilang selamanya.
Untuk menghindari hal tersebut terjadi, kamu harus menggunakan source dan sink dari package grammy runner untuk membuat jalur update-mu sendiri yang meneruskan semua update ke antrian pesan atau queue terlebih dahulu.
- Buat sebuah sink sebagai jalur untuk meneruskan update ke queue, lalu mulai satu runner yang bertugas menyuplai pesan-pesan tersebut ke queue.
- Kemudian, buat sebuah source untuk mengambil pesan dari queue.
Dengan begitu, kamu menjalankan dua instance grammY runner yang berbeda. Konsep tadi adalah sebuah ide berdasarkan pengetahuan yang kami punya, tetapi ide tersebut belum pernah diterapkan. Silahkan hubungi grup Telegram kami kalau kamu mempunyai beberapa pertanyaan atau bahkan kamu berhasil melakukannya dan ingin membagikannya ke kami.
Di sisi lain, kalau bot kamu sedang mengalami beban tinggi yang mengakibatkan polling update menjadi terlambat karena pembatasan beban yang dilakukan secara otomatis, maka kemungkinan besar beberapa update akan di-fetch lagi, yang mengakibatkan pemrosesan pesan duplikat. Oleh karena itu, efek yang dihasilkan dari penggunaan concurency secara penuh adalah tidak ada yang bisa menjamin pemrosesan dilakukan baik setidaknya sekali ataupun paling banyak sekali.