unsupervised-scheduler/src/Offering/OfferingRepository.php

<?php
declare(strict_types=1);

namespace Unsupervised\Schedular\Offering;

class OfferingRepository {

	private string $table;

	public function __construct( private \wpdb $db ) {
		$this->table = $db->prefix . 'us_offerings';
	}

	/**
	 * Column formats aligned to {@see columns()} (instructor_id, kind, title,
	 * description, duration_minutes, price, currency, billing_mode, allow_weekly,
	 * capacity, term_start, term_end, schedule_note, etransfer_email,
	 * cancellation_cutoff_hours, access_mode, is_active).
	 *
	 * @var list<string>
	 */
	private const COLUMN_FORMATS = [ '%d', '%s', '%s', '%s', '%d', '%f', '%s', '%s', '%d', '%d', '%s', '%s', '%s', '%s', '%d', '%s', '%d' ];

	public function insert( Offering $offering ): int {
		$this->db->insert(
			$this->table,
			$this->columns( $offering ) + [ 'created_at' => current_time( 'mysql' ) ],
			[ ...self::COLUMN_FORMATS, '%s' ]
		);

		return $this->db->insert_id;
	}

	public function update( int $id, Offering $offering ): bool {
		return false !== $this->db->update(
			$this->table,
			$this->columns( $offering ),
			[ 'id' => $id ],
			self::COLUMN_FORMATS,
			[ '%d' ]
		);
	}

	/**
	 * Column values shared by insert and update (excludes created_at).
	 *
	 * @return array<string, mixed>
	 */
	private function columns( Offering $offering ): array {
		return [
			'instructor_id'             => $offering->instructorId,
			'kind'                      => $offering->kind,
			'title'                     => $offering->title,
			'description'               => $offering->description,
			'duration_minutes'          => $offering->durationMinutes,
			'price'                     => $offering->price,
			'currency'                  => $offering->currency,
			'billing_mode'              => $offering->billingMode,
			'allow_weekly'              => $offering->allowWeekly ? 1 : 0,
			'capacity'                  => $offering->capacity,
			'term_start'                => $offering->termStart,
			'term_end'                  => $offering->termEnd,
			'schedule_note'             => $offering->scheduleNote,
			'etransfer_email'           => $offering->etransferEmail,
			'cancellation_cutoff_hours' => $offering->cancellationCutoffHours,
			'access_mode'               => $offering->accessMode,
			'is_active'                 => $offering->isActive ? 1 : 0,
		];
	}

	/**
	 * Find offerings, optionally filtered by instructor, kind, active state, and
	 * access mode (e.g. `Offering::ACCESS_PUBLIC` to exclude invite-only classes
	 * from the public catalogue).
	 *
	 * @return list<Offering>
	 */
	public function findAll( int $instructorId = 0, string $kind = '', ?bool $activeOnly = null, ?string $accessMode = null ): array {
		$where  = [ '1 = 1' ];
		$params = [];

		if ( $instructorId > 0 ) {
			$where[]  = 'instructor_id = %d';
			$params[] = $instructorId;
		}

		if ( '' !== $kind ) {
			$where[]  = 'kind = %s';
			$params[] = $kind;
		}

		if ( null !== $activeOnly ) {
			$where[]  = 'is_active = %d';
			$params[] = $activeOnly ? 1 : 0;
		}

		if ( null !== $accessMode ) {
			$where[]  = 'access_mode = %s';
			$params[] = $accessMode;
		}

		$whereClause = implode( ' AND ', $where );
		$sql         = "SELECT * FROM %i WHERE {$whereClause} ORDER BY title ASC";

		$rows = $this->db->get_results(
			$this->db->prepare( $sql, array_merge( [ $this->table ], $params ) )
		);

		return array_map( Offering::fromRow( ... ), $rows ?? [] );
	}

	public function findById( int $id ): ?Offering {
		$row = $this->db->get_row(
			$this->db->prepare( 'SELECT * FROM %i WHERE id = %d', $this->table, $id )
		);

		return $row ? Offering::fromRow( $row ) : null;
	}

	public function delete( int $id ): bool {
		return (bool) $this->db->delete(
			$this->table,
			[ 'id' => $id ],
			[ '%d' ]
		);
	}
}