The implementation is based on the ideas from the article https://www.nginx.com/blog/nginx-plus-iot-security-encrypt-authenticate-mqtt/. The specification: https://docs.solace.com/API/MQTT-v50-Prtl-Conformance-Spec/mqtt-v50-3-control-packets.htm
The implementation supports MQTT 5.
| package com.example.util.logging | |
| import java.net.InetSocketAddress | |
| import cats.effect.{Concurrent, ContextShift, Resource, Sync, Timer} | |
| import cats.syntax.functor._ | |
| import cats.{Monad, MonadError} | |
| import fs2.io.tcp.{Socket, SocketGroup} | |
| import io.odin.LoggerMessage | |
| import io.odin.formatter.Formatter |
| java.lang.NoClassDefFoundError: scala/tools/scalap/scalax/rules/scalasig/Type | |
| at org.apache.livy.shaded.json4s.reflect.Reflector$ClassDescriptorBuilder$$anonfun$constructorsAndCompanion$3$$anonfun$13.apply(Reflector.scala:123) | |
| at org.apache.livy.shaded.json4s.reflect.Reflector$ClassDescriptorBuilder$$anonfun$constructorsAndCompanion$3$$anonfun$13.apply(Reflector.scala:122) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234) | |
| at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59) | |
| at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48) | |
| at scala.collection.TraversableLike$class.map(TraversableLike.scala:234) | |
| at scala.collection.AbstractTraversable.map(Traversable.scala:104) | |
| at org.apache.livy.shaded.json4s.reflect.Reflector$ClassDescriptorBuilder$$anonfun$constructorsAndCompanion$3.apply(Reflector.scala:122) |
| import cats.effect.{ExitCase, ExitCode, IO, IOApp} | |
| import cats.syntax.flatMap._ | |
| import cats.syntax.functor._ | |
| import scala.concurrent.duration._ | |
| object UncancelableApp extends IOApp { | |
| override def run(args: List[String]): IO[ExitCode] = { | |
| val job: IO[String] = for { |
| import com.timushev.sbt.updates.versions.{ValidVersion, Version} | |
| import sbt._ | |
| import scala.collection.immutable.SortedSet | |
| object DependenciesUpdate { | |
| def update( | |
| dependencyUpdates: Map[ModuleID, SortedSet[Version]], | |
| baseDirectory: File, |
| import java.util.regex.Pattern | |
| import net.logstash.logback.encoder.org.apache.commons.lang.StringEscapeUtils | |
| import scala.io.Source | |
| import scala.util.control.NonFatal | |
| object Main { |
