JarCastingtelegram4s
Telegram client for Scala
Quick start
If you use sbt add the following dependency to your build file:
libraryDependencies += "io.github.paoloboni" %% "telegram4s" % "<version>"
Example
import cats.effect.{ExitCode, IO, IOApp}
import log.effect.LogWriter
import org.telegram.api.updates.TLAbsUpdates
import org.telegram.bot.kernel.MainHandlerFactory
import org.telegram.bot.structure.IUser
import org.telegram4s.TelegramClient
object TelegramSampleApp extends IOApp {
private implicit val mainHandlerFactory: MainHandlerFactory[IO] = new MainHandlerFactory[IO]
private val log: LogWriter[IO] = implicitly
private val clientApiKey = 123455
private val clientApiHash = "6e6bc4e49dd477ebc98ef4046c067b5f"
private val phoneNumber = "+4407700000000"
val bob: IUser = ???
override def run(args: List[String]) = {
val program = for {
client <- TelegramClient.initialise(
clientApiKey = clientApiKey,
clientApiHash = clientApiHash,
phoneNumber = phoneNumber,
stateFilePath = "/tmp/api_state",
getAuthCode = getAuthCode
)
events <- client.getUpdatesStream
processEvents <- events
.map(eventHandler)
.evalMap(log.info(_))
.compile
.drain
.start
_ <- client.sendMessage(bob, "Hi Bob!")
_ <- processEvents.join
} yield ()
program.redeem(
{ t =>
t.printStackTrace()
ExitCode(1)
},
_ => ExitCode.Success
)
}
private def eventHandler(updates: TLAbsUpdates): String = {
// handle possible instances of org.telegram.api.updates.TLAbsUpdates
"event received"
}
private def getAuthCode: IO[String] =
for {
_ <- IO.pure(println(s"Enter authentication code: "))
authCode <- IO.pure(scala.io.StdIn.readLine())
} yield authCode
}