import stats from dcsbot

[mitch10593]

Demande de Zip: importer dans le site les données produites par DCS Bot.

• Analyser la structure de données
• Etablir un mapping des champs, format, identifier ce qui manque / ce qui est en trop
• Créer un script (commande CLI)

[mitch10593]

La structure de données de DCS Bot:

-- Table: public.statistics

-- DROP TABLE IF EXISTS public.statistics;

CREATE TABLE IF NOT EXISTS public.statistics
(
    mission_id integer NOT NULL,
    player_ucid text COLLATE pg_catalog."default" NOT NULL,
    slot text COLLATE pg_catalog."default" NOT NULL,
    side integer DEFAULT 0,
    kills integer DEFAULT 0,
    pvp integer DEFAULT 0,
    deaths integer DEFAULT 0,
    ejections integer DEFAULT 0,
    crashes integer DEFAULT 0,
    teamkills integer DEFAULT 0,
    kills_planes integer DEFAULT 0,
    kills_helicopters integer DEFAULT 0,
    kills_ships integer DEFAULT 0,
    kills_sams integer DEFAULT 0,
    kills_ground integer DEFAULT 0,
    deaths_pvp integer DEFAULT 0,
    deaths_planes integer DEFAULT 0,
    deaths_helicopters integer DEFAULT 0,
    deaths_ships integer DEFAULT 0,
    deaths_sams integer DEFAULT 0,
    deaths_ground integer DEFAULT 0,
    takeoffs integer DEFAULT 0,
    landings integer DEFAULT 0,
    hop_on timestamp without time zone NOT NULL DEFAULT (now() AT TIME ZONE 'utc'::text),
    hop_off timestamp without time zone,
    tail_no text COLLATE pg_catalog."default",
    CONSTRAINT statistics_pkey PRIMARY KEY (mission_id, player_ucid, slot, hop_on),
    CONSTRAINT statistics_mission_id_fkey FOREIGN KEY (mission_id)
        REFERENCES public.missions (id) MATCH SIMPLE
        ON UPDATE NO ACTION
        ON DELETE CASCADE,
    CONSTRAINT statistics_player_ucid_fkey FOREIGN KEY (player_ucid)
        REFERENCES public.players (ucid) MATCH SIMPLE
        ON UPDATE CASCADE
        ON DELETE CASCADE
)

TABLESPACE pg_default;

ALTER TABLE IF EXISTS public.statistics
    OWNER to dcsserverbot;
-- Index: idx_statistics_player_ucid

-- DROP INDEX IF EXISTS public.idx_statistics_player_ucid;

CREATE INDEX IF NOT EXISTS idx_statistics_player_ucid
    ON public.statistics USING btree
    (player_ucid COLLATE pg_catalog."default" ASC NULLS LAST)
    TABLESPACE pg_default;

[mitch10593]

Plan: Import DCS Bot Statistics vers Perun

Résumé

Créer une commande Symfony pour synchroniser les statistiques de vol depuis une base PostgreSQL DCS Bot vers la table Perun pe_LogStats existante (MySQL).

Décisions

• Direction: Unidirectionnelle (DCS Bot → Perun, lecture seule depuis DCS Bot)
• Stratégie: Import incrémental basé sur hop_off timestamp
• Champs manquants: Laissés à zéro/null (DCS Bot n'a pas tous les champs Perun)
• Missions: Ignorer le lien mission (champ mission à null)

Mapping des champs

DCS Bot (statistics)	LogStat (pe_LogStats)	Notes
player_ucid	player (FK)	Recherche/création Player par ucid
slot	type (FK)	Recherche/création DataType par name
hop_off	datetime	Fin de session
hop_off - hop_on	time	Durée en secondes
kills	killsX	Total kills
pvp	pvp	Direct
deaths	deaths	Direct
ejections	ejections	Direct
crashes	crashes	Direct
teamkills	teamKills	Direct
kills_planes	killsPlanes	Direct
kills_helicopters	killsHelicopters	Direct
kills_ships	killsShips	Direct
kills_sams	killsAirDefense	SAM → Air Defense
kills_ground	killsArmor	Ground → Armor
takeoffs	otherTakeoffs	Agrégé dans "other"
landings	otherLandings	Agrégé dans "other"
-	mission	null
-	status	null
-	autres kills/takeoffs	0

Fichiers à créer

1. Configuration Doctrine pour connexion DCS Bot

Fichier: config/packages/doctrine.yaml

Ajouter une seconde connexion DBAL pour PostgreSQL (lecture seule, pas de mapping ORM):

doctrine:
    dbal:
        default_connection: perun
        connections:
            perun:
                url: '%env(resolve:DATABASE_PERUN_URL)%'
                mapping_types:
                    enum: string
            dcsbot:
                url: '%env(resolve:DATABASE_DCSBOT_URL)%'
                driver: 'pdo_pgsql'

2. Variable d'environnement

Fichier: .env.dist (ou .env.local)

DATABASE_DCSBOT_URL=postgresql://user:password@host:5432/dcs_bot

3. DTO pour les statistiques DCS Bot

Fichier: src/Perun/DTO/DcsBotStatistic.php

• Factory method fromRow(array $row): self
• Méthode getSessionDuration(): int (calcul hop_off - hop_on)
• Getters pour tous les champs

4. Entité pour l'état de synchronisation

Fichier: src/Perun/Entity/DcsBotSyncState.php

/**
 * @ORM\Table(name="pe_DcsBotSyncState")
 * @ORM\Entity
 */
class DcsBotSyncState
{
    /** @ORM\Id @ORM\Column(type="string", length=50) */
    private string $serverId;

    /** @ORM\Column(type="datetime") */
    private \DateTime $lastSyncAt;

    /** @ORM\Column(type="integer", options={"default": 0}) */
    private int $recordsImported = 0;
}

5. Service d'import

Fichier: src/Perun/Service/DcsBotImportService.php

• Injecte EntityManagerInterface et Connection $dcsBotConnection
• Méthode import(string $serverId, OutputInterface $output): void
• Récupère le timestamp de dernière synchro
• Requête SQL vers DCS Bot: SELECT * FROM statistics WHERE hop_off > :since AND hop_off IS NOT NULL
• Pour chaque ligne:
  • Recherche/crée Player par ucid
  • Recherche/crée DataType par slot name
  • Crée LogStat avec mapping des champs
• Flush par batch de 100
• Met à jour DcsBotSyncState

6. Commande console

Fichier: src/Command/DcsBotImportCommand.php

./scripts/console.sh app:dcsbot:import [server]

• Argument optionnel server (défaut: "default") pour identifier le serveur
• Option --dry-run pour tester sans persister
• Affiche progression et temps d'exécution

7. Configuration service

Fichier: config/services.yaml

App\Perun\Service\DcsBotImportService:
    arguments:
        $dcsBotConnection: '@doctrine.dbal.dcsbot_connection'

Fichiers à modifier

1. LogStat - Ajouter les setters manquants

Fichier: src/Perun/Entity/LogStat.php

Ajouter les méthodes setter pour:

• setType(DataType $type)
• setMasterSlot(int $masterSlot)
• setSeat(int $seat)
• setKillsX(int $killsX)
• setPvp(int $pvp)
• setDeaths(int $deaths)
• setEjections(int $ejections)
• setCrashes(int $crashes)
• setTeamKills(int $teamKills)
• setKillsPlanes(int $killsPlanes)
• setKillsHelicopters(int $killsHelicopters)
• setKillsAirDefense(int $killsAirDefense)
• setKillsArmor(int $killsArmor)
• setKillsUnarmed(int $killsUnarmed)
• setKillsInfantry(int $killsInfantry)
• setKillsShips(int $killsShips)
• setKillsFortification(int $killsFortification)
• setKillsArtillery(int $killsArtillery)
• setKillsOther(int $killsOther)
• setAirfieldTakeoffs(int $airfieldTakeoffs)
• setAirfieldLandings(int $airfieldLandings)
• setShipTakeoffs(int $shipTakeoffs)
• setShipLandings(int $shipLandings)
• setFarpTakeoffs(int $farpTakeoffs)
• setFarpLandings(int $farpLandings)
• setOtherTakeoffs(int $otherTakeoffs)
• setOtherLandings(int $otherLandings)
• setStatus(?string $status)

Séquence d'implémentation

1. Modifier doctrine.yaml - ajouter connexion dcsbot
2. Ajouter variable DATABASE_DCSBOT_URL dans .env.dist
3. Ajouter setters manquants à LogStat
4. Créer entité DcsBotSyncState
5. Générer migration: ./scripts/console.sh doctrine:migrations:diff
6. Créer DTO DcsBotStatistic
7. Créer service DcsBotImportService
8. Ajouter config dans services.yaml
9. Créer commande DcsBotImportCommand
10. Exécuter migration: ./scripts/console.sh doctrine:migrations:migrate
11. Tester: ./scripts/console.sh app:dcsbot:import --dry-run

Tests

Tests unitaires

• tests/Unit/Perun/DTO/DcsBotStatisticTest.php - Test du DTO et calcul de durée

Tests d'intégration

• tests/Integration/Perun/Service/DcsBotImportServiceTest.php - Test du service complet

Gestion des erreurs

• Sessions sans hop_off (en cours): ignorées
• Player inconnu: créé automatiquement
• DataType (slot) inconnu: créé automatiquement
• Erreur de connexion PostgreSQL: exception avec message clair
• Doublons: vérification optionnelle par clé composite (player_ucid + slot + hop_on)

[mitch10593]

Note pour la MEP: prévoir d'ajouter une entrée dans la table, pour éviter d'avoir les données en double entre les stats de perun et les stats de dcsserverbot:

INSERT INTO dcsbot_sync_state (server_id, last_sync_at, records_imported) VALUES
('default', '2025-12-24 10:46:54', 9435);