<?php
declare(strict_types=1);
namespace JKingWeb\NewsSync\Db;

class ResultSQLite3 implements Result {
    protected $st;
    protected $set;
    protected $pos = 0;
    protected $cur = null;
    protected $rows = 0;

    // actual public methods

    public function getValue() {
        $this->next();
        if($this->valid()) {
            $keys = array_keys($this->cur);
            return $this->cur[array_shift($keys)];
        }
        return null;
    }

    public function get() {
        $this->next();
        return ($this->valid() ? $this->cur : null);
    }

    public function getAll() {
        $out = [];
        foreach($this as $row) {
            $out [] = $row;
        }
        if(sizeof($out) < 1) return null;
        return $out;
    }

    public function changes() {
        return $this->rows;
    }

    // constructor/destructor

    public function __construct(\SQLite3Result $result, int $changes = 0, StatementSQLite3 $statement = null) {
        $this->st = $statement; //keeps the statement from being destroyed, invalidating the result set
        $this->set = $result;
        $this->rows = $changes;
    }

    public function __destruct() {
        $this->set->finalize();
        unset($this->set);
    }

    // PHP iterator methods

    public function valid() {
        $this->cur = $this->set->fetchArray(\SQLITE3_ASSOC);
        return ($this->cur !== false);
    }

    public function next() {
        $this->cur = null;
        $this->pos += 1;
    }

    public function current() {
        return $this->cur;
    }

    public function key() {
        return $this->pos;
    }

    public function rewind() {
        $this->pos = 0;
        $this->cur = null;
        $this->set->reset();
    }
}