StreamingSubsystem.h

이 파일의 문서화 페이지로 가기

// Fill out your copyright notice in the Description page of Project Settings.
 
#pragma once
 
#include "CoreMinimal.h"
#include "Situation/SituationTag.h"
#include "Subsystems/WorldSubsystem.h"
#include "StreamingSubsystem.generated.h"
 
class UConstellationBase;
class UConstellationSettings;
class USituationBase;
class UStageManifest;
 
// 성좌가 채팅창에 반응을 띄울 때. 채팅 UI 가 구독한다.
// 출력 대기열을 거쳐 실제로 화면에 올릴 한 줄이 확정됐을 때만 쏜다.
// bTagged 는 방송 태그에 반응한 태그 채팅인지(true), 평소의 일반 채팅인지(false)를 구분한다.
DECLARE_MULTICAST_DELEGATE_ThreeParams(FOnConstellationReaction, UConstellationBase* /*Constellation*/, const FText& /*ChatText*/, bool /*bTagged*/);
 
// 새 성좌가 시청자 목록에 합류할 때. 성좌 목록 패널이 구독한다.
DECLARE_MULTICAST_DELEGATE_OneParam(FOnConstellationRegistered, UConstellationBase* /*Constellation*/);
 
// 같은 태그가 기준 수만큼 모여 방송 제목이 확정될 때. 방송 진행 HUD 가 구독한다.
// 제목은 한 게임에 최대 하나뿐이라 이 델리게이트도 한 번만 쏜다.
DECLARE_MULTICAST_DELEGATE_OneParam(FOnBroadcastTitleConfirmed, ESituationTag /*ConfirmedTag*/);
 
 
USTRUCT()
struct FConstellationEntry
{
    GENERATED_BODY()
 
public:
    UPROPERTY(Transient)
    TObjectPtr<UConstellationBase> Constellation = nullptr;
};
 
 
USTRUCT()
struct FConstellationChatEntry
{
    GENERATED_BODY()
 
public:
    UPROPERTY(Transient)
    TObjectPtr<UConstellationBase> Constellation = nullptr;
 
    UPROPERTY(Transient)
    FText ChatText;
 
    // 대기열에 들어온 시각(초). 일반 채팅의 지연 판정에만 쓴다.
    float EnqueuedTime = 0.0f;
};
 
 
UCLASS(Blueprintable)
class CK_UE_API UStreamingSubsystem : public UWorldSubsystem
{
    GENERATED_BODY()
 
public:
    virtual void OnWorldBeginPlay(UWorld& InWorld) override;
    virtual void Deinitialize() override;
 
public:
    // 적 처치 시 호출. 성좌를 시청자 목록에 등록한다.
    void RegisterConstellation(UConstellationBase* Constellation);
 
    // 상황이 발동했을 때 호출. 그 카드에 묶인 후원 성좌가 대표로 태그 채팅을 낸다.
    void TriggerSituation(USituationBase* Situation);
 
    // 현재 시청 중인 성좌 전체. 성좌 목록 패널의 초기 채우기에 쓴다.
    TArray<UConstellationBase*> GetConstellations() const;
 
    // 해당 방송 태그에 반응하는 성좌만 추린다.
    TArray<UConstellationBase*> GetRespondingConstellations(ESituationTag BroadcastTags) const;
 
    // 해당 방송 태그에 반응하는 성좌를 Constellation_Master 에서 하나 뽑아 만든다.
    // 만들기만 하고 시청자 목록에는 넣지 않는다. 합류는 RegisterConstellation 이 맡는다.
    // 이미 시청 중인 성좌와 ExcludedIDs 에 든 성좌는 후보에서 뺀다.
    UConstellationBase* DrawConstellationForTags(ESituationTag BroadcastTags, const TArray<FName>& ExcludedIDs);
 
    // 이미 시청 중인 성좌 인스턴스. 없으면 nullptr.
    UConstellationBase* FindRegisteredConstellation(const FName& ConstellationID) const;
 
public:
    // 전투가 시작돼 채팅 생성 레인을 돌린다. 이미 돌고 있으면 아무것도 하지 않는다.
    void StartChatFlow();
 
    // 사망·전투 종료 등으로 채팅 생성을 멈추고 아직 출력되지 않은 대기열을 비운다.
    // 현재 반응 태그와 제목 확정 상태는 남겨, 리스폰 후 같은 상태로 재개할 수 있게 한다.
    void StopChatFlow();
 
    // 카드 선택이 확정됐을 때 호출. 반응 태그를 갱신하고 첫 태그 채팅을 즉시 한 줄 출력한다.
    // 같은 태그가 기준 수만큼 모이면 방송 제목이 확정되고 이후 태그는 더 이상 바뀌지 않는다.
    void HandleSituationSelected(USituationBase* Situation);
 
    FORCEINLINE ESituationTag GetCurrentReactionTag() const
    {
        return CurrentReactionTag;
    }
 
    FORCEINLINE bool IsBroadcastTitleConfirmed() const
    {
        return bTitleConfirmed;
    }
 
public:
    FOnConstellationReaction OnConstellationReaction;
    FOnConstellationRegistered OnConstellationRegistered;
    FOnBroadcastTitleConfirmed OnBroadcastTitleConfirmed;
 
protected:
    // 성좌 하나가 상황에 반응한다. 반응 문구가 비어 있으면 아무것도 하지 않는다.
    void ReactToSituation(UConstellationBase* Constellation);
 
    // 성좌 추첨이 실패했을 때 무엇이 걸렸는지 한 번에 찍는다. 진단용.
    void DumpConstellationCandidates(const UStageManifest* Manifest, ESituationTag BroadcastTags, const TArray<FName>& ExcludedIDs) const;
 
protected:
    // 반응 태그를 갈아끼운다. 태그 레인의 대기열과 타이머만 초기화하고 일반 레인은 건드리지 않는다.
    void SetReactionTag(ESituationTag NewTag);
 
    // 1~3초 뒤 다음 채팅을 생성하도록 각 레인의 타이머를 다시 건다.
    void ScheduleNormalSpawn();
    void ScheduleTaggedSpawn();
 
    void SpawnNormalChat();
    void SpawnTaggedChat();
 
    // 출력 시점마다 호출. 지연 폐기 → 태그 우선 → 일반 순으로 한 줄만 내보낸다.
    void ProcessChatOutput();
 
    // 가장 오래된 일반 채팅이 기준 시간을 넘겼으면 일반 대기열을 통째로 비운다.
    void DiscardStaleNormalChats();
 
    // 다음 출력 시점을 지금부터 다시 센다. 즉시 출력 직후에도 호출한다.
    void RestartOutputTimer();
 
    void OutputChat(const FConstellationChatEntry& Entry, bool bTagged);
 
    // 성좌 하나로 대기열 항목을 만든다. 문구가 비어 있으면 false.
    bool BuildChatEntry(UConstellationBase* Constellation, bool bTagged, FConstellationChatEntry& OutEntry) const;
 
    // 시청 중인 성좌 가운데 해당 종류의 문구를 가진 성좌를 같은 확률로 하나 뽑는다.
    UConstellationBase* DrawChatSpeaker(bool bTagged) const;
 
    // 그 성좌가 이미 태그 대기열에 올라 있는지. 두 레인이 같은 성좌를 뽑았는지 판정에 쓴다.
    bool IsWaitingInTaggedQueue(const UConstellationBase* Constellation) const;
 
    // 시간 배율을 그대로 타는 월드 시각(초). 시간이 멈추면 대기 시간도 함께 멈춘다.
    float GetChatTime() const;
 
    static const UConstellationSettings* GetChatSettings();
 
protected:
    UPROPERTY(Transient)
    TArray<FConstellationEntry> Entries;
 
    // 아직 출력되지 않은 채팅. 태그 쪽이 항상 먼저 나간다.
    UPROPERTY(Transient)
    TArray<FConstellationChatEntry> TaggedQueue;
 
    UPROPERTY(Transient)
    TArray<FConstellationChatEntry> NormalQueue;
 
    // 고른 카드의 방송 태그 이력. 같은 태그가 몇 개 모였는지 세는 데만 쓴다.
    UPROPERTY(Transient)
    TArray<ESituationTag> SelectedTagHistory;
 
    // 지금 태그 채팅을 생성할 기준 태그. None 이면 태그 레인은 멈춘다.
    ESituationTag CurrentReactionTag = ESituationTag::None;
 
    // 방송 제목이 확정된 뒤에는 다른 카드를 골라도 반응 태그가 바뀌지 않는다.
    uint8 bTitleConfirmed : 1 = false;
 
    // 생성 레인이 도는 중인지. 사망·전투 종료로 내려간다.
    uint8 bChatFlowRunning : 1 = false;
 
private:
    FTimerHandle NormalSpawnTimerHandle;
    FTimerHandle TaggedSpawnTimerHandle;
    FTimerHandle OutputTimerHandle;
};