#include <MD_MAX72xx.h>
#include <WiFi.h>
#include <PubSubClient.h>

MD_MAX72XX mx = MD_MAX72XX(MD_MAX72XX::PAROLA_HW, 5, 4);
WiFiClient espClient;
PubSubClient client(espClient);

long r;
long r2;
bool pole[8][24];
const char* mqtt_server = "broker.hivemq.com";
char clientId[50];
int port = 1883;
int pocetbodov = 10;

void setup() 
{
  Serial.begin(115200);
  WiFi.begin("Wokwi-GUEST", "");
  while (WiFi.status() != WL_CONNECTED) 
  {
    delay(250);
    Serial.print(".");
  }
  Serial.println("WiFi connected");
  Serial.print("IP address: ");
  Serial.println(WiFi.localIP());
  
  mx.begin();
  mx.control(MD_MAX72XX::INTENSITY, MAX_INTENSITY / 2);
  mx.clear();

  //pripojenie na broker
  client.setServer(mqtt_server, port);
  client.setCallback(callback);  
}

void reconnect() 
{
  // bude sa opakovat az kym sa nepripoji
  while (!client.connected()) 
  {
    Serial.print("Attempting MQTT connection...");
    // pokusanie o pripojenie
    if (client.connect(clientId)) 
    {
      Serial.println("connected");
      // odoberanie zo servera
      client.subscribe("topic/konfig");
    } 
    else 
    {
      Serial.print("failed, rc=");
      Serial.print(client.state());
      Serial.println(" try again in 5 seconds");
      // pocka 5 sec potom znovu
      delay(5000);
    }
  }
}

void callback(char* topic, byte* message, unsigned int length) 
{
  //vypis info do serialu
  Serial.print("Message arrived on topic: ");
  Serial.print(topic);
  Serial.print(". Message: ");
  String stMessage;

  for (int i = 0; i < length; i++) 
  {
    Serial.print((char)message[i]);
    stMessage += (char)message[i];
  }
  Serial.println();

  if (String(topic) == "topic/konfig") 
  {
    pocetbodov = atoi(stMessage.c_str());
    Serial.print("Max Points in First Row set to: ");
    Serial.println(pocetbodov);  
  }
}

void loop() 
{
  delay(10);

  if (!client.connected()) 
  {
    reconnect();
  }
  client.loop();

  for(int i = 0; i < 24; i++)
  {
    mx.setPoint(0, i, false);
    pole[0][i] = false;
  }

  for(int j = 0; j < pocetbodov; j++)
  {
    r = random(0, 24);

    if(pole[0][r] != true)
    {
      pole[0][r] = true;
    }
    mx.setPoint(0, r, pole[0][r]);
  }

  mx.update();
//posuvanie po 500ms
  delay(500);

  for (int i = 0; i < 24; i++) 
  {    
    for (int j = 7; j > 0; j--) 
    {
      pole[j][i] = pole[j - 1][i];
      mx.setPoint(j, i, pole[j][i]);
      mx.update();
    }
  }
}