#yuru-kit

#Packages

#Reading chat

///|
async fn main {
  @sources.set_log_prefix("my-app")
  let twitch = @sources.TwitchSource::new("somechannel")
  twitch.run(comment => println("\{comment.author}: \{comment.text}"))
}

///|
pub(open) trait ChatSource {
  async fn run(Self, emit : async (Comment) -> Unit) -> Unit
}

• Twitch connects anonymously (justinfan<digits>, no OAuth) over TLS 6697 and falls back to plain 6667. It reconnects with exponential backoff (1 s up to 60 s; back to 1 s after a connection that lasted 60 s or more).
• YouTube reads chat without an API key by default, the way the browser does (youtube.com/live_chat and youtubei/v1/live_chat/get_live_chat). This is unofficial and can break when YouTube changes its pages. Pass api_key to use the official Data API v3 instead (it consumes quota).
• stdin reads participant-id<TAB>text lines.

#Talking to Jev

///|
async fn judge(text : String) -> Json {
  let client = @jev.JevClient::from_env() // JEV_URL, JEV_API_KEY, JEV_MODEL
  client.systemone({
    "state": text,
    "model": client.model,
    "questions": {
      "q": { "type": "noul", "instructions": "Is this a question?" },
    },
  })
}

#Testing

moon check --target all && moon test --target all

#Acknowledgments

• naoto24kawa/moonqr (Apache-2.0) — QR encoding, and its decoder in tests.
• moonbitlang/async (Apache-2.0) — event loop, sockets, TLS, HTTP client.