Method SyncClientSharedTaskWithPersistedState

zone/task_manager.cpp:1630–1716

}

void TaskManager::SyncClientSharedTaskWithPersistedState(Client *c, ClientTaskState *cts)
{
	auto character_tasks = CharacterTasksRepository::GetWhere(
		database,
		fmt::format("charid = {} ORDER BY acceptedtime", c->CharacterID())
	);

	for (auto &character_task: character_tasks) {
		if (character_task.type == TASK_TYPE_SHARED) {
			auto st = SharedTaskMembersRepository::GetWhere(
				database,
				fmt::format(
					"character_id = {}",
					c->CharacterID()
				)
			);

			if (!st.empty()) {
				int64 shared_task_id = st[0].shared_task_id;
				auto  activities     = SharedTaskActivityStateRepository::GetWhere(
					database,
					fmt::format(
						"shared_task_id = {}",
						shared_task_id
					)
				);

				ClientTaskInformation *shared_task = nullptr;
				shared_task = &cts->m_active_shared_task;

				// has active shared task
				if (cts->HasActiveSharedTask()) {

					LogTasksDetail(
						"[SyncClientSharedTaskWithPersistedState] Client [{}] has shared_task, sync with database",
						c->GetCleanName()
					);

					bool      fell_behind_state = false;
					for (auto &a: activities) {

						LogTasksDetail(
							"shared_task loop local [{}] shared [{}]",
							shared_task->activity[a.activity_id].done_count,
							a.done_count
						);

						// we're behind shared task state, update self
						if (shared_task->activity[a.activity_id].done_count < a.done_count) {

							// update done count
							shared_task->activity[a.activity_id].done_count = a.done_count;

							// activity state
							shared_task->activity[a.activity_id].activity_state =
								(a.completed_time > 0 ? ActivityCompleted : ActivityHidden);

							// flag to update character_activities table entry on save