#pragma once

#include <furi_hal_light.h>
#include <notification/notification_messages.h>

#include "pof_token.h"
#include "audio/g721.h"

#define SAMPLE_RATE 8000
#define POF_TOKEN_LIMIT 16
#define SAMPLES_COUNT 2048
#define SAMPLES_COUNT_BUFFERED SAMPLES_COUNT * 8

typedef enum {
    PoFHid,
    PoFXbox360
} PoFType;

typedef enum {
    EventExit = (1 << 0),
    EventReset = (1 << 1),
    EventRx = (1 << 2),
    EventTx = (1 << 3),
    EventTxComplete = (1 << 4),
    EventResetSio = (1 << 5),
    EventTxImmediate = (1 << 6),
    WavPlayerEventHalfTransfer = (1 << 2),
    WavPlayerEventFullTransfer = (1 << 3),

    EventAll = EventExit | EventReset | EventRx | EventTx | EventTxComplete | EventResetSio |
               EventTxImmediate,
} PoFEvent;

typedef struct {
    uint8_t r;
    uint8_t g;
    uint8_t b;
    uint8_t target_r;
    uint8_t target_g;
    uint8_t target_b;
    uint8_t last_r;
    uint8_t last_g;
    uint8_t last_b;
    uint16_t delay;
    uint32_t start_time;
    bool two_phase;
    bool running;
    int current_phase;
} VirtualPortalLed;

typedef struct {
    PoFToken* tokens[POF_TOKEN_LIMIT];
    uint8_t sequence_number;
    float volume;
    bool playing_audio;
    uint8_t audio_buffer[SAMPLES_COUNT];
    uint8_t current_audio_buffer[SAMPLES_COUNT_BUFFERED];
    uint8_t* head;
    uint8_t* tail;
    uint8_t* end;
    uint16_t count;
    uint8_t m;
    bool active;
    bool speaker;
    NotificationApp* notifications;
    PoFType type;
    VirtualPortalLed left;
    VirtualPortalLed right;
    VirtualPortalLed trap;
    FuriTimer* led_timer;
    FuriThread* thread;
    struct g72x_state state;
} VirtualPortal;

VirtualPortal* virtual_portal_alloc(NotificationApp* notifications);
void virtual_portal_set_type(VirtualPortal* virtual_portal, PoFType type);

void virtual_portal_free(VirtualPortal* virtual_portal);
void virtual_portal_cleanup(VirtualPortal* virtual_portal);
void virtual_portal_load_token(VirtualPortal* virtual_portal, PoFToken* pof_token);
void virtual_portal_tick();

int virtual_portal_process_message(
    VirtualPortal* virtual_portal,
    uint8_t* message,
    uint8_t* response);
void virtual_portal_process_audio(VirtualPortal* virtual_portal,
                                  uint8_t* message, uint8_t len);
void virtual_portal_process_audio_360(VirtualPortal* virtual_portal,
                                  uint8_t* message, uint8_t len);

int virtual_portal_send_status(VirtualPortal* virtual_portal, uint8_t* response);