<?php

declare(strict_types=0);

/**
 * vim:set softtabstop=4 shiftwidth=4 expandtab:
 *
 * LICENSE: GNU Affero General Public License, version 3 (AGPL-3.0-or-later)
 * Copyright Ampache.org, 2001-2026
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <https://www.gnu.org/licenses/>.
 *
 */

namespace Ampache\Repository\Model;

use Ampache\Module\System\Dba;

/**
 * UserPlaylist Class
 *
 * This class handles the user playlists in Ampache. It handles the
 * user_playlist table creating a global play queue for each user
 */
class User_Playlist extends database_object
{
    protected const DB_TABLENAME = 'user_playlist';

    public int $user;

    public string $client;

    /**
     * Constructor
     * This takes a user_id as an optional argument and gathers the
     * information.  If no user_id is passed or the requested one isn't
     * found, return false.
     */
    public function __construct(
        ?int $user_id = 0,
        ?string $client = null
    ) {
        if (!$user_id) {
            return;
        }

        $client ??= $this->get_latest();
        if (empty($client)) {
            return;
        }

        $this->user   = (int)$user_id;
        $this->client = substr($client, 0, 254);
    }

    /**
     * get_current_object
     * This returns the next object in the user_playlist.
     * @return array{}|array{
     *     object_type: string,
     *     object_id: int,
     *     track: int,
     *     track_id: int,
     *     current_track: int,
     *     current_time: int
     * }
     */
    public function get_current_object(): array
    {
        $items = [];
        // Select the current object for this user
        $sql        = "SELECT `object_type`, `object_id`, `track`, `current_track`, `current_time` FROM `user_playlist` WHERE `user` = ? AND `current_track` = 1 LIMIT 1";
        $db_results = Dba::read($sql, [$this->user]);

        while ($results = Dba::fetch_assoc($db_results)) {
            $items = [
                'object_type' => $results['object_type'],
                'object_id' => (int)$results['object_id'],
                'track_id' => (int)$results['object_id'],
                'track' => (int)$results['track'],
                'current_track' => (int)$results['current_track'],
                'current_time' => (int)$results['current_time'],
            ];
        }

        return $items;
    }

    /**
     * set_current_object
     * set the active object in the user_playlist.
     */
    public function set_current_object(string $object_type, int $object_id, int $position): void
    {
        // remove the old current
        $sql = "UPDATE `user_playlist` SET `current_track` = 0, `current_time` = 0 WHERE `user` = ?";
        Dba::write($sql, [$this->user]);
        // set the new one
        $sql = "UPDATE `user_playlist` SET `current_track` = 1, `current_time` = ? WHERE `object_type` = ? AND `object_id` = ? AND `user` = ? LIMIT 1";
        Dba::write($sql, [$position, $object_type, $object_id, $this->user]);
    }

    /**
     * set_current_id
     * set the active object using the row id in user_playlist.
     */
    public function set_current_id(string $object_type, int $track, int $position): void
    {
        // remove the old current
        $sql = "UPDATE `user_playlist` SET `current_track` = 0, `current_time` = 0 WHERE `user` = ?";
        Dba::write($sql, [$this->user]);
        // set the new one
        $sql = "UPDATE `user_playlist` SET `current_track` = 1, `current_time` = ? WHERE `object_type` = ? AND `track` = ? AND `user` = ? LIMIT 1";
        Dba::write($sql, [$position, $object_type, $track, $this->user]);
    }

    /**
     * get_count
     * This returns a count of the total number of tracks that are in this playlist
     */
    public function get_count(): int
    {
        $sql        = "SELECT MAX(`track`) AS `count` FROM `user_playlist` WHERE `user` = ? AND `playqueue_client` = ?";
        $db_results = Dba::read($sql, [$this->user, $this->client]);
        $results    = Dba::fetch_assoc($db_results);

        return (int)$results['count'];
    }

    /**
     * get_time
     * This returns a count of the total number of tracks that are in this playlist
     */
    public function get_time(): int
    {
        $sql        = "SELECT DISTINCT(`playqueue_time`) AS `time` FROM `user_playlist` WHERE `user` = ? AND `playqueue_client` = ?";
        $db_results = Dba::read($sql, [$this->user, $this->client]);
        $results    = Dba::fetch_assoc($db_results);
        if ($results === []) {
            return time();
        }

        return (int)$results['time'];
    }

    /**
     * get_latest
     * get the most recent playqueue for the user
     */
    public function get_latest(): string
    {
        $sql        = "SELECT MAX(`playqueue_time`) AS `time`, `playqueue_client`, `user` FROM `user_playlist` WHERE `user` = ? GROUP BY `playqueue_client`, `user`";
        $db_results = Dba::read($sql, [$this->user]);
        $results    = Dba::fetch_assoc($db_results);

        return $results['playqueue_client'] ?? '';
    }

    /**
     * clear
     * This clears all the objects out of a user's playlist for that client
     */
    public function clear(): void
    {
        $sql = "DELETE FROM `user_playlist` WHERE `user` = ? AND `playqueue_client` = ?";
        Dba::write($sql, [$this->user, $this->client]);
    }

    /**
     * add_items
     * Add an array of songs to the playlist
     */
    public function add_items(array $data, int $time): void
    {
        $sql    = 'INSERT INTO `user_playlist` (`playqueue_time`, `playqueue_client`, `user`, `object_type`, `object_id`, `track`) VALUES ';
        $values = [];
        foreach ($data as $row) {
            if (in_array($row['object_type'], ['song','live_stream','video','podcast_episode'])) {
                $sql .= '(?, ?, ?, ?, ?, ?),';
                $values[] = $time;
                $values[] = $this->client;
                $values[] = $this->user;
                $values[] = $row['object_type'];
                $values[] = $row['object_id'];
                $values[] = $row['track'];
            }
        }

        // remove last comma
        $sql = substr($sql, 0, -1) . ';';
        Dba::write($sql, $values);
    }

    /**
     * get_items
     * Returns an array of all object_ids currently in this User_Playlist.
     * @return list<array{
     *     object_type: string,
     *     object_id: int,
     *     track: int,
     *     track_id: int,
     *     current_track: int,
     *     current_time: int
     * }>
     */
    public function get_items(): array
    {
        $items = [];
        // Select all objects from this user
        $sql        = "SELECT `object_type`, `object_id`, `track`, `current_track`, `current_time` FROM `user_playlist` WHERE `user` = ? AND `playqueue_client` = ? ORDER BY `track`";
        $db_results = Dba::read($sql, [$this->user, $this->client]);

        while ($results = Dba::fetch_assoc($db_results)) {
            $items[] = [
                'object_type' => $results['object_type'],
                'object_id' => $results['object_id'],
                'track_id' => $results['object_id'],
                'track' => $results['track'],
                'current_track' => $results['current_track'],
                'current_time' => $results['current_time'],
            ];
        }

        return $items;
    }
}
