Twitch connector refactor and readiness

English

Finalization of a major Twitch connector refactor and readiness work.

Completed work

• Separated the Twitch message contracts into a shared module so payload structures can be reused by other projects.
• Reworked the connector to manage tracked channels dynamically through Kafka commands and local SQLite persistence instead of static connector configuration.
• Added a dedicated chat client, a stream status poller, and command consumption for join and leave actions.
• Switched Kafka payloads from JSON strings to real JSON objects.
• Improved Docker-based local execution with connector configuration helpers and a Kafka message viewer.
• Simplified several internal paths to reduce unnecessary indirection and improve readability.

Current state

The Twitch connector now produces structured chat and stream-status events, persists tracked channels locally, and is packaged as a buildable artifact with shared event contracts.

Next steps

• Continue tightening event correlation between moderation actions and the source messages that triggered them.
• Expand downstream consumers to use the shared Twitch event contracts directly.
• Complete deployment automation for server environments.

This worklog entry was summarized with AI assistance.

Français

Finalisation d’une refonte importante du connecteur Twitch et de sa mise en condition d’exploitation.

Travaux réalisés

• Séparation des contrats de messages Twitch dans un module partagé afin de réutiliser les structures de payload dans d’autres projets.
• Refonte du connecteur pour gérer dynamiquement les chaînes suivies via des commandes Kafka et une persistance SQLite locale, au lieu d’une configuration statique du connecteur.
• Ajout d’un client de chat dédié, d’un poller de statut de stream et de la consommation des commandes de join et leave.
• Bascule des payloads Kafka de chaînes JSON vers de vrais objets JSON.
• Amélioration de l’exécution locale sous Docker avec des helpers de configuration du connecteur et un visualiseur de messages Kafka.
• Simplification de plusieurs chemins internes pour réduire l’indirection inutile et améliorer la lisibilité.

État actuel

Le connecteur Twitch produit désormais des événements de chat et de statut de stream structurés, persiste localement les chaînes suivies et est empaqueté comme artefact buildable avec des contrats d’événements partagés.

Prochaines étapes

• Poursuivre l’amélioration de la corrélation entre les actions de modération et les messages d’origine qui ont déclenché ces sanctions.
• Étendre les consommateurs aval pour qu’ils utilisent directement les contrats d’événements Twitch partagés.
• Finaliser l’automatisation du déploiement pour les environnements serveur.

Cette entrée de journal a été résumée avec l’aide de l’IA.