OpenRCT2/src/openrct2/management/NewsItem.cpp

483 lines
13 KiB
C++

/*****************************************************************************
* Copyright (c) 2014-2020 OpenRCT2 developers
*
* For a complete list of all authors, please refer to contributors.md
* Interested in contributing? Visit https://github.com/OpenRCT2/OpenRCT2
*
* OpenRCT2 is licensed under the GNU General Public License version 3.
*****************************************************************************/
#include "NewsItem.h"
#include "../Context.h"
#include "../Input.h"
#include "../OpenRCT2.h"
#include "../audio/audio.h"
#include "../interface/Window.h"
#include "../interface/Window_internal.h"
#include "../localisation/Date.h"
#include "../localisation/Localisation.h"
#include "../management/Research.h"
#include "../ride/Ride.h"
#include "../util/Util.h"
#include "../windows/Intent.h"
#include "../world/Location.hpp"
#include "../world/Sprite.h"
News::ItemQueues gNewsItems;
News::Item& News::ItemQueues::Current()
{
return Recent.front();
}
const News::Item& News::ItemQueues::Current() const
{
return Recent.front();
}
bool News::IsValidIndex(int32_t index)
{
if (index >= News::MaxItems)
{
log_error("Tried to get news item past MAX_NEWS.");
return false;
}
return true;
}
News::Item* News::GetItem(int32_t index)
{
return gNewsItems.At(index);
}
News::Item& News::ItemQueues::operator[](size_t index)
{
return const_cast<News::Item&>(const_cast<const News::ItemQueues&>(*this)[index]);
}
const News::Item& News::ItemQueues::operator[](size_t index) const
{
if (index < Recent.capacity())
return Recent[index];
else
return Archived[index - Recent.capacity()];
}
News::Item* News::ItemQueues::At(int32_t index)
{
return const_cast<News::Item*>(const_cast<const News::ItemQueues&>(*this).At(index));
}
const News::Item* News::ItemQueues::At(int32_t index) const
{
if (News::IsValidIndex(index))
{
return &(*this)[index];
}
else
{
return nullptr;
}
}
bool News::IsQueueEmpty()
{
return gNewsItems.IsEmpty();
}
bool News::ItemQueues::IsEmpty() const
{
return Recent.empty();
}
/**
*
* rct2: 0x0066DF32
*/
void News::ItemQueues::Clear()
{
Recent.clear();
Archived.clear();
}
void News::InitQueue()
{
gNewsItems.Clear();
assert(gNewsItems.IsEmpty());
// Throttles for warning types (PEEP_*_WARNING)
for (auto& warningThrottle : gPeepWarningThrottle)
{
warningThrottle = 0;
}
auto intent = Intent(INTENT_ACTION_INVALIDATE_TICKER_NEWS);
context_broadcast_intent(&intent);
}
uint16_t News::ItemQueues::IncrementTicks()
{
return ++Current().Ticks;
}
static void TickCurrent()
{
int32_t ticks = gNewsItems.IncrementTicks();
// Only play news item sound when in normal playing mode
if (ticks == 1 && (gScreenFlags == SCREEN_FLAGS_PLAYING))
{
// Play sound
OpenRCT2::Audio::Play(OpenRCT2::Audio::SoundId::NewsItem, 0, context_get_width() / 2);
}
}
int32_t News::ItemQueues::RemoveTime() const
{
if (!Recent[5].IsEmpty() && !Recent[4].IsEmpty() && !Recent[3].IsEmpty() && !Recent[2].IsEmpty())
{
return 256;
}
return 320;
}
bool News::ItemQueues::CurrentShouldBeArchived() const
{
return Current().Ticks >= RemoveTime();
}
/**
*
* rct2: 0x0066E252
*/
void News::UpdateCurrentItem()
{
// Check if there is a current news item
if (gNewsItems.IsEmpty())
return;
auto intent = Intent(INTENT_ACTION_INVALIDATE_TICKER_NEWS);
context_broadcast_intent(&intent);
// Update the current news item
TickCurrent();
// Removal of current news item
if (gNewsItems.CurrentShouldBeArchived())
gNewsItems.ArchiveCurrent();
}
/**
*
* rct2: 0x0066E377
*/
void News::CloseCurrentItem()
{
gNewsItems.ArchiveCurrent();
}
void News::ItemQueues::ArchiveCurrent()
{
// Check if there is a current message
if (IsEmpty())
return;
Archived.push_back(Current());
// Invalidate the news window
window_invalidate_by_class(WC_RECENT_NEWS);
// Dequeue the current news item, shift news up
Recent.pop_front();
// Invalidate current news item bar
auto intent = Intent(INTENT_ACTION_INVALIDATE_TICKER_NEWS);
context_broadcast_intent(&intent);
}
/**
* Get the (x,y,z) coordinates of the subject of a news item.
* If the new item is no longer valid, return LOCATION_NULL in the x-coordinate
*
* rct2: 0x0066BA74
*/
std::optional<CoordsXYZ> News::GetSubjectLocation(News::ItemType type, int32_t subject)
{
std::optional<CoordsXYZ> subjectLoc{ std::nullopt };
switch (type)
{
case News::ItemType::Ride:
{
Ride* ride = get_ride(subject);
if (ride == nullptr || ride->overall_view.isNull())
{
break;
}
auto rideViewCentre = ride->overall_view.ToTileCentre();
subjectLoc = CoordsXYZ{ rideViewCentre, tile_element_height(rideViewCentre) };
break;
}
case News::ItemType::PeepOnRide:
{
auto peep = TryGetEntity<Peep>(subject);
if (peep == nullptr)
break;
subjectLoc = CoordsXYZ{ peep->x, peep->y, peep->z };
if (subjectLoc->x != LOCATION_NULL)
break;
if (peep->State != PeepState::OnRide && peep->State != PeepState::EnteringRide)
{
subjectLoc = std::nullopt;
break;
}
// Find which ride peep is on
Ride* ride = get_ride(peep->CurrentRide);
if (ride == nullptr || !(ride->lifecycle_flags & RIDE_LIFECYCLE_ON_TRACK))
{
subjectLoc = std::nullopt;
break;
}
// Find the first car of the train peep is on
auto sprite = TryGetEntity<Vehicle>(ride->vehicles[peep->CurrentTrain]);
// Find the actual car peep is on
for (int32_t i = 0; i < peep->CurrentCar && sprite != nullptr; i++)
{
sprite = TryGetEntity<Vehicle>(sprite->next_vehicle_on_train);
}
if (sprite != nullptr)
{
subjectLoc = CoordsXYZ{ sprite->x, sprite->y, sprite->z };
}
break;
}
case News::ItemType::Peep:
{
auto peep = TryGetEntity<Peep>(subject);
if (peep != nullptr)
{
subjectLoc = CoordsXYZ{ peep->x, peep->y, peep->z };
}
break;
}
case News::ItemType::Blank:
{
auto subjectUnsigned = static_cast<uint32_t>(subject);
auto subjectXY = CoordsXY{ static_cast<int16_t>(subjectUnsigned & 0xFFFF),
static_cast<int16_t>(subjectUnsigned >> 16) };
if (!subjectXY.isNull())
{
subjectLoc = CoordsXYZ{ subjectXY, tile_element_height(subjectXY) };
}
break;
}
default:
break;
}
return subjectLoc;
}
News::Item* News::ItemQueues::FirstOpenOrNewSlot()
{
for (auto emptySlots = Recent.capacity() - Recent.size(); emptySlots < 2; ++emptySlots)
{
ArchiveCurrent();
}
auto res = Recent.end();
// The for loop above guarantees there is always an extra element to use
assert(Recent.capacity() - Recent.size() >= 2);
auto newsItem = res + 1;
newsItem->Type = News::ItemType::Null;
return &*res;
}
/**
*
* rct2: 0x0066DF55
*/
News::Item* News::AddItemToQueue(News::ItemType type, rct_string_id string_id, uint32_t assoc, const Formatter& formatter)
{
utf8 buffer[256];
// overflows possible?
format_string(buffer, 256, string_id, formatter.Data());
return News::AddItemToQueue(type, buffer, assoc);
}
News::Item* News::AddItemToQueue(News::ItemType type, const utf8* text, uint32_t assoc)
{
News::Item* newsItem = gNewsItems.FirstOpenOrNewSlot();
newsItem->Type = type;
newsItem->Flags = 0;
newsItem->Assoc = assoc; // Make optional for Award, Money, Graph and Null
newsItem->Ticks = 0;
newsItem->MonthYear = static_cast<uint16_t>(gDateMonthsElapsed);
newsItem->Day = ((days_in_month[date_get_month(newsItem->MonthYear)] * gDateMonthTicks) >> 16) + 1;
safe_strcpy(newsItem->Text, text, sizeof(newsItem->Text));
return newsItem;
}
/**
* Checks if News::ItemType requires an assoc
* @return A boolean if assoc is required.
*/
bool News::CheckIfItemRequiresAssoc(News::ItemType type)
{
switch (type)
{
case News::ItemType::Null:
case News::ItemType::Award:
case News::ItemType::Money:
case News::ItemType::Graph:
return false;
default:
return true; // Everything else requires assoc
}
}
/**
* Opens the window/tab for the subject of the news item
*
* rct2: 0x0066EBE6
*
*/
void News::OpenSubject(News::ItemType type, int32_t subject)
{
switch (type)
{
case News::ItemType::Ride:
{
auto intent = Intent(WC_RIDE);
intent.putExtra(INTENT_EXTRA_RIDE_ID, subject);
context_open_intent(&intent);
break;
}
case News::ItemType::PeepOnRide:
case News::ItemType::Peep:
{
auto peep = TryGetEntity<Peep>(subject);
if (peep != nullptr)
{
auto intent = Intent(WC_PEEP);
intent.putExtra(INTENT_EXTRA_PEEP, peep);
context_open_intent(&intent);
}
break;
}
case News::ItemType::Money:
context_open_window(WC_FINANCES);
break;
case News::ItemType::Research:
{
auto item = ResearchItem(subject, ResearchCategory::Transport, 0);
if (item.type == Research::EntryType::Ride)
{
auto intent = Intent(INTENT_ACTION_NEW_RIDE_OF_TYPE);
intent.putExtra(INTENT_EXTRA_RIDE_TYPE, item.baseRideType);
intent.putExtra(INTENT_EXTRA_RIDE_ENTRY_INDEX, item.entryIndex);
context_open_intent(&intent);
break;
}
// Check if window is already open
auto window = window_bring_to_front_by_class(WC_SCENERY);
if (window == nullptr)
{
window = window_find_by_class(WC_TOP_TOOLBAR);
if (window != nullptr)
{
window->Invalidate();
if (!tool_set(window, WC_TOP_TOOLBAR__WIDX_SCENERY, TOOL_ARROW))
{
input_set_flag(INPUT_FLAG_6, true);
context_open_window(WC_SCENERY);
}
}
}
// Switch to new scenery tab
window = window_find_by_class(WC_SCENERY);
if (window != nullptr)
window_event_mouse_down_call(window, WC_SCENERY__WIDX_SCENERY_TAB_1 + subject);
break;
}
case News::ItemType::Peeps:
{
auto intent = Intent(WC_GUEST_LIST);
intent.putExtra(INTENT_EXTRA_GUEST_LIST_FILTER, static_cast<int32_t>(GuestListFilterType::GuestsThinkingX));
intent.putExtra(INTENT_EXTRA_RIDE_ID, subject);
context_open_intent(&intent);
break;
}
case News::ItemType::Award:
context_open_window_view(WV_PARK_AWARDS);
break;
case News::ItemType::Graph:
context_open_window_view(WV_PARK_RATING);
break;
case News::ItemType::Null:
case News::ItemType::Blank:
case News::ItemType::Count:
break;
}
}
/**
*
* rct2: 0x0066E407
*/
void News::DisableNewsItems(News::ItemType type, uint32_t assoc)
{
// TODO: write test invalidating windows
gNewsItems.ForeachRecentNews([type, assoc](auto& newsItem) {
if (type == newsItem.Type && assoc == newsItem.Assoc)
{
newsItem.SetFlags(News::ItemFlags::HasButton);
if (&newsItem == &gNewsItems.Current())
{
auto intent = Intent(INTENT_ACTION_INVALIDATE_TICKER_NEWS);
context_broadcast_intent(&intent);
}
}
});
gNewsItems.ForeachArchivedNews([type, assoc](auto& newsItem) {
if (type == newsItem.Type && assoc == newsItem.Assoc)
{
newsItem.SetFlags(News::ItemFlags::HasButton);
window_invalidate_by_class(WC_RECENT_NEWS);
}
});
}
void News::AddItemToQueue(News::Item* newNewsItem)
{
News::Item* newsItem = gNewsItems.FirstOpenOrNewSlot();
*newsItem = *newNewsItem;
}
void News::RemoveItem(int32_t index)
{
if (index < 0 || index >= News::MaxItems)
return;
// News item is already null, no need to remove it
if (gNewsItems[index].Type == News::ItemType::Null)
return;
size_t newsBoundary = index < News::ItemHistoryStart ? News::ItemHistoryStart : News::MaxItems;
for (size_t i = index; i < newsBoundary - 1; i++)
{
gNewsItems[i] = gNewsItems[i + 1];
}
gNewsItems[newsBoundary - 1].Type = News::ItemType::Null;
}