unsupervised-scheduler/src/Registration/RegistrationGate.php

<?php
declare(strict_types=1);

namespace Unsupervised\Schedular\Registration;

use Unsupervised\Schedular\Policy\AcceptanceRepository;
use Unsupervised\Schedular\Policy\Policy;
use Unsupervised\Schedular\Policy\PolicyAcceptance;
use Unsupervised\Schedular\Policy\PolicyRepository;
use Unsupervised\Schedular\Policy\PolicyVersionRepository;

/**
 * Shared registration gate: validates and records the intake-question answers
 * and booking-scoped policy acceptances common to lesson bookings and group
 * enrolments.
 */
class RegistrationGate {

	public function __construct(
		private QuestionRepository $questions,
		private AnswerRepository $answers,
		private PolicyRepository $policies,
		private PolicyVersionRepository $versions,
		private AcceptanceRepository $acceptances,
	) {}

	/**
	 * Validate that required questions are answered and all booking-scoped
	 * published policies are accepted. Returns null when the gate passes.
	 *
	 * @param array<int, string> $answers            question_id => answer value
	 * @param list<int>          $acceptedVersionIds Accepted policy version IDs
	 */
	public function validate( int $offeringId, array $answers, array $acceptedVersionIds ): ?\WP_Error {
		foreach ( $this->questions->findByOffering( $offeringId, true ) as $question ) {
			if ( $question->isRequired && '' === trim( (string) ( $answers[ (int) $question->id ] ?? '' ) ) ) {
				return new \WP_Error(
					'missing_answer',
					__( 'Please answer all required questions.', 'unsupervised-schedular' ),
					[ 'status' => 400 ]
				);
			}
		}

		foreach ( $this->requiredPolicyVersionIds() as $versionId ) {
			if ( ! in_array( $versionId, $acceptedVersionIds, true ) ) {
				return new \WP_Error(
					'policy_required',
					__( 'You must accept all required policies.', 'unsupervised-schedular' ),
					[ 'status' => 400 ]
				);
			}
		}

		return null;
	}

	/**
	 * Persist answers and policy acceptances for a created registration.
	 *
	 * @param array<int, string> $answers            question_id => answer value
	 * @param list<int>          $acceptedVersionIds Accepted policy version IDs
	 */
	public function record( string $registrationType, int $registrationId, int $studentId, int $offeringId, array $answers, array $acceptedVersionIds, ?string $ipAddress = null ): void {
		foreach ( $this->questions->findByOffering( $offeringId, true ) as $question ) {
			$value = (string) ( $answers[ (int) $question->id ] ?? '' );
			if ( '' === $value ) {
				continue;
			}

			$this->answers->insert(
				new Answer(
					questionId:       (int) $question->id,
					registrationType: $registrationType,
					registrationId:   $registrationId,
					studentId:        $studentId,
					answerValue:      $value,
				)
			);
		}

		foreach ( $this->requiredPolicyVersionIds() as $versionId ) {
			if ( ! in_array( $versionId, $acceptedVersionIds, true ) ) {
				continue;
			}

			$this->acceptances->insert(
				new PolicyAcceptance(
					policyVersionId:  $versionId,
					studentId:        $studentId,
					registrationType: $registrationType,
					registrationId:   $registrationId,
					ipAddress:        $ipAddress,
				)
			);
		}
	}

	/**
	 * Current published version IDs of every booking-scoped policy.
	 *
	 * @return list<int>
	 */
	private function requiredPolicyVersionIds(): array {
		$ids = [];

		foreach ( $this->policies->findForScope( Policy::SCOPE_BOOKING ) as $policy ) {
			if ( null === $policy->currentVersionId ) {
				continue;
			}

			$version = $this->versions->findById( $policy->currentVersionId );
			if ( null !== $version && $version->isPublished() ) {
				$ids[] = (int) $version->id;
			}
		}

		return $ids;
	}
}