CLK/Processors/6502Mk2/6502Mk2.hpp

//
//  6502Mk2.hpp
//  Clock Signal
//
//  Created by Thomas Harte on 18/10/2025.
//  Copyright © 2025 Thomas Harte. All rights reserved.
//

#pragma once

#include "Decoder.hpp"
#include "Model.hpp"
#include "Perform.hpp"
#include "Registers.hpp"

#include "ClockReceiver/ClockReceiver.hpp"
#include "Processors/Bus/Data.hpp"
#include "Processors/Bus/PartialAddresses.hpp"

#include <cassert>
#include <type_traits>

namespace CPU::MOS6502Mk2 {

// MARK: - Control bus.

enum class BusOperation {
	/// 6502: a read was signalled.
	/// 65816: a read was signalled with VDA.
	Read,
	/// 6502: a read was signalled with SYNC.
	/// 65816: a read was signalled with VDA and VPA.
	ReadOpcode,
	/// 6502: never signalled.
	/// 65816: a read was signalled with VPA.
	ReadProgram,
	/// 6502: never signalled.
	/// 65816: a read was signalled with VPB and VDA.
	ReadVector,
	/// 6502: never signalled.
	/// 65816: a read was signalled, but neither VDA nor VPA were active.
	InternalOperationRead,

	/// All processors: indicates that the processor is paused due to the RDY input.
	/// 65C02 and 65816: indicates a WAI is ongoing.
	Ready,
	// TODO: should ReadyRead be distinguished from ReadyWrite?

	/// 65C02 and 65816: indicates a STP condition.
	None,

	/// 6502: a write was signalled.
	/// 65816: a write was signalled with VDA.
	Write,
	/// 6502: never signalled.
	/// 65816: a write was signalled, but neither VDA nor VPA were active.
	InternalOperationWrite,
};

constexpr bool is_read(const BusOperation op) { return op <= BusOperation::InternalOperationRead; }
constexpr bool is_write(const BusOperation op) { return op >= BusOperation::Write; }
constexpr bool is_access(const BusOperation op) { return op <= BusOperation::ReadVector || op == BusOperation::Write; }
constexpr bool is_dataless(const BusOperation op) { return !is_read(op) && !is_write(op); }

constexpr Bus::Data::AccessType access_type(const BusOperation op) {
	if(is_read(op)) return Bus::Data::AccessType::Read;
	if(is_write(op)) return Bus::Data::AccessType::Write;
	return Bus::Data::AccessType::NoData;
}

enum class Line {
	Reset,
	IRQ,
	PowerOn,
	Overflow,
	NMI,
	Ready,
};

// MARK: - Address bus.

namespace Address {

using ZeroPage = Bus::Address::FixedPage<uint16_t, uint8_t, uint8_t, 0x00>;
using Stack = Bus::Address::FixedPage<uint16_t, uint8_t, uint8_t, 0x01>;
using Vector = Bus::Address::FixedPage<uint16_t, uint8_t, uint8_t, 0xff>;
using Literal = Bus::Address::Literal<uint16_t>;

}  // namespace Address

// MARK: - Data bus.

namespace Data {

using Writeable = Bus::Data::Writeable<uint8_t, true>;
using NoValue = Bus::Data::NoValue<uint8_t>;

}

template <BusOperation operation>
using data_t = Bus::Data::data_t<uint8_t, true, access_type(operation)>;

// MARK: - Storage.

/*!
	An opcode that is guaranteed to cause a 6502 to jam.
*/
constexpr uint8_t JamOpcode = 0xf2;

template <Model model, typename Traits, typename Enable = void> class Storage;
template <Model model, typename Traits> class Storage<model, Traits, std::enable_if_t<is_8bit(model)>> {
public:
	Storage(Traits::BusHandlerT &bus_handler) noexcept : bus_handler_(bus_handler) {}

	const Registers &registers() const { return registers_; }
	void set_registers(const Registers &registers) {
		registers_ = registers;
	}

	template <Line line> bool get() const;
	template <Line line> inline void set(const bool value) {
		const auto level_sample = [&](const Inputs::InterruptRequest request) {
			inputs_.interrupt_requests =
				(inputs_.interrupt_requests & ~request) |
				(value ? request : 0);
		};
		const auto edge_sample = [&](const Inputs::InterruptRequest request, bool &previous) {
			inputs_.interrupt_requests |= (previous != value && value) ? request : 0;
			previous = value;
		};

		switch(line) {
			// Fictitious.
			case Line::PowerOn:
				level_sample(Inputs::InterruptRequest::PowerOn);
				captured_interrupt_requests_ =
					(captured_interrupt_requests_ & ~Inputs::InterruptRequest::PowerOn) |
					(inputs_.interrupt_requests & Inputs::InterruptRequest::PowerOn);
			break;

			// Level triggered interrupts.
			case Line::Reset:		level_sample(Inputs::InterruptRequest::Reset);						break;
			case Line::IRQ:			level_sample(Inputs::InterruptRequest::IRQ);						break;

			// Edge triggered interrupts.
			case Line::NMI:			edge_sample(Inputs::InterruptRequest::NMI, inputs_.nmi);			break;

			// Leval-capturing state.
			case Line::Ready:		inputs_.ready = value;												break;

			// Edge-triggered state.
			case Line::Overflow:
				if(!inputs_.overflow && value) {
					registers_.flags.set_per<Flag::Overflow>(Flag::Overflow);
				}
				inputs_.overflow = value;
			break;

			default:
				__builtin_unreachable();
		}
	}

	/// Get whether the 6502 would reset at the next opportunity.
	bool is_resetting() const {
		return inputs_.interrupt_requests & (Inputs::InterruptRequest::PowerOn | Inputs::InterruptRequest::Reset);
	}

	/*!
		Queries whether the 6502 is now 'jammed'; i.e. has entered an invalid state
		such that it will not of itself perform any more meaningful processing.

		@returns @c true if the 6502 is jammed; @c false otherwise.
	*/
	bool is_jammed() const {
		return resume_point_ == ResumePoint::Jam;
	}

protected:
	Traits::BusHandlerT &bus_handler_;
	uint8_t opcode_, operand_;
	Instruction decoded_;

	Registers registers_;
	uint16_t operation_pc_;
	RegisterPair16 address_;
	bool did_adjust_top_;

	Cycles cycles_;

	enum ResumePoint {
		FetchDecode,
		Jam,
		Max,
	};
	int resume_point_ = ResumePoint::FetchDecode;

	struct Inputs {
		bool ready = false;
		bool nmi = false;
		bool overflow = false;

		enum InterruptRequest: uint8_t {
			Reset		= 0x80,
			IRQ			= Flag::Interrupt,
			NMI			= 0x20,

			PowerOn		= 0x10,
		};
		uint8_t interrupt_requests = InterruptRequest::PowerOn;
	} inputs_;
	uint8_t captured_interrupt_requests_ = Inputs::InterruptRequest::PowerOn;
};

// MARK: - Base.

enum class PausePrecision {
	BetweenInstructions,
	AnyCycle,
};

// TODO: concept to explain and verify Traits.
template <Model model, typename Traits>
struct Processor: public Storage<model, Traits> {
	inline void run_for(Cycles);

	/*!
		**FOR TEST CASES ONLY:** forces the processor into a state where
		the next thing it intends to do is fetch a new opcode.
	*/
	inline void restart_operation_fetch();
};

}

// MARK: - Implementations.
#include "Implementation/6502.hpp"