AppCameraStream.cpp

//
// Created by codexzier on 07.07.26.
//

#include "AppCameraStream.h"


void AppCameraStream::initExtend() {

    _applicationName = "Camera Stream";
}

void AppCameraStream::drawUpdate() {

    if (_hasDraw) {
        return;
    }

    _tft->setFont(FontDefault);
    _tft->setTextColor(_colorOn, _tft->C_BLACK);

    if (_wlanConnected) {

        _tft->setCursor(50, 50);
        _tft->print(WiFi.localIP());
        _tft->print(":");
        char buffer[12];
        sprintf(buffer, "%d", _port);
        _tft->print(buffer);
        _tft->setCursor(50, 70);
        _tft->print("Warte auf Client!");
        _client = _server.accept();

        _tft->writeBuffer();

        if (_client) {
            _tft->setCursor(50, 50);
            _tft->print(WiFi.localIP());
            _tft->setCursor(50, 70);
            _tft->print("Client verbunden!");
            _tft->writeBuffer();

            bool onlyOneTimeTftWrite = false;
            bool pictureError = false;
            while (_client.connected()) {

                if (onlyOneTimeTftWrite) {
                    _tft->setCursor(50, 90);
                    _tft->print("Stream aktiv...");
                    _tft->writeBuffer();
                    onlyOneTimeTftWrite = true;
                }

                // call camera buffer
                CameraRecordResult camRec = _cameraManager->getPictureFast();
                if (!camRec.Success || camRec.Buffer == nullptr || camRec.Length == 0) {
                    _tft->setCursor(50, 110);
                    _tft->print("Bildfehler!");
                    _tft->writeBuffer();
                    delay(10);
                    continue;
                }

                size_t written = _client.write(camRec.Buffer, camRec.Length);

                //Serial.print("write returned: ");
                //Serial.print(written);
                //Serial.print(" / ");
                //Serial.println(camRec.Length);

                //_client.flush();

                delay(10);
            }

            _client.stop();
            
            _tft->setCursor(50, 70);
            _tft->print("Getrennt!");
            _tft->setCursor(50, 90);
            _tft->print("Stream aus!");
            _tft->setCursor(50, 110);
            _tft->print(WiFi.localIP());

            delay(1000);
            return;
        }
        else {
            _tft->setCursor(50, 90);
            _tft->print("Keine Verbindung!");
            _tft->setCursor(20, 110);
            _tft->print("Warte 5 für neuen Versuch!");

            _tft->setCursor(50, 130);
            for (int sec = 0; sec < 5; sec++) {
                sprintf(buffer, "%d", sec);
                _tft->setCursor(50, 130);
                _tft->print(buffer);
                _tft->print(" Sekunden");
                _tft->writeBuffer();
                delay(1000);
            }

            _tft->clearBuffer();
            _tft->fillScreen(_tft->C_BLACK);
            return;
        }
    }
    else {
        _tft->setCursor(20, 110);
        _tft->print("Keine Verbindung");
        _tft->setCursor(20, 130);
        _tft->print("hergestellt!");
    }

    _hasDraw = true;
}

bool writeAll(WiFiClient& client, const uint8_t* buffer, size_t length)
{
    size_t sent = 0;
    unsigned long lastProgress = millis();

    while (sent < length) {
        if (!client.connected()) {
            Serial.println("Client nicht mehr verbunden");
            return false;
        }

        size_t n = client.write(buffer + sent, length - sent);

        if (n > 0) {
            sent += n;
            lastProgress = millis();
            continue;
        }

        if (millis() - lastProgress > 2000) {
            Serial.println("Timeout beim Senden");
            return false;
        }

        delay(1);
    }

    client.flush();
    return true;
}

void AppCameraStream::setButton2() {

    _tft->clearBuffer();
    _tft->fillScreen(_tft->C_BLACK);
    _tft->setFont(FontDefault);
    _tft->setTextColor(_colorOn, _tft->C_BLACK);

    WiFi.mode(WIFI_STA);
    Serial.print("SSID: "); Serial.println(wd.getSsid());
    Serial.print("Password: "); Serial.println(wd.getPassword());

    int posX = 40;
    int posY = 45;
    _tft->setCursor(posX, posY);
    _tft->print("Verbinde mit WLAN");
    _tft->setCursor(posX, posY + 20);
    _tft->print(wd.getSsid());

    WiFi.begin(wd.getSsid(), wd.getPassword());

    int count = 0;
    Serial.println("Connecting to WiFi ..");
    _tft->writeBuffer();

    while (WiFi.status() != WL_CONNECTED) {

        _tft->setCursor(posX, posY + 40);
        _tft->print(WiFi.status());
        _tft->setCursor(posX, posY + 40);
        _tft->print(WiFi.getHostname());
        _tft->setCursor(posX, posY + 60);
        _tft->print("MAC: ");
        _tft->print(WiFi.macAddress());
        _tft->setCursor(posX, posY + 80);
        _tft->print("Auto-Reconnect:");
        _tft->print(WiFi.getAutoReconnect());

        if(count < 100) {
            Serial.print('.');
            count++;
        }
        else {
            _tft->drawFastHLine(20, posY + 100, count * 2, _tft->C_BLACK);
            _tft->drawFastHLine(20, posY + 101, count * 2, _tft->C_BLACK);
            _tft->drawFastHLine(20, posY + 102, count * 2, _tft->C_BLACK);
            count = 0;
            Serial.println("");
        }

        _tft->drawFastHLine(20, posY + 100, count * 2, _colorOn);
        _tft->drawFastHLine(20, posY + 101, count * 2, _colorOn);
        _tft->drawFastHLine(20, posY + 102, count * 2, _colorOn);
        _tft->writeBuffer();
        delay(50);
    }

    Serial.print("WiFi connected! ");
    Serial.println(WiFi.localIP());

    _tft->setCursor(posX, posY + 130);
    _tft->print("WiFi connected!");
    _tft->setCursor(posX, posY + 150);
    _tft->print(WiFi.localIP());

    _tft->writeBuffer();

    delay(2000);
    _tft->clearBuffer();

    // TCP-Server anlegen
    _server.begin(_port);
    _wifiServerRun = true;

    _hasDraw = false;
    _wlanConnected = true;
}