<?php

class PAS_Users_Identities {

	private $db; // the mysqli database object
	private $tablePrefix;


	public function __construct( &$db, $tablePrefix = '' ) {
		$this->db = $db;
		$this->tablePrefix = $tablePrefix;
	}


	public function init() {
		// create database tables
	}


	public function get( $userId, $identity ) {
		$userId = (int) $userId;
		$identity = $this->db->real_escape_string( $identity );
		$sql = "SELECT is_owner
			FROM `{$this->tablePrefix}users_identities`
			WHERE user_id = {$userId} AND identity = '{$identity}'";
		$result = $this->db->query( $sql );
		if ( ! $result || ! $result->num_rows ) {
			return FALSE;
		}
		return $result->fetch_assoc();
	}


	public function select( $userId ) {
		$userId = (int) $userId;
		$sql = "SELECT identity, is_owner
			FROM `{$this->tablePrefix}users_identities`
			WHERE user_id = {$userId}";
		return $this->db->query( $sql );
	}


	public function create( $userId, $identity, $isOwner = FALSE ) {
		$userId = (int) $userId;
		$identity = $this->db->real_escape_string( $identity );
		$isOwner = $isOwner ? 1 : 0;
		$sql = "INSERT INTO `{$this->tablePrefix}users_identities` SET
			user_id = {$userId}, identity = '{$identity}', is_owner = {$isOwner}";
		if ( ! $this->db->query( $sql ) ) {
			return FALSE;
		}
		return TRUE;
	}


	public function delete( $userId, $identity ) {
		$userId = (int) $userId;
		$identity = $this->db->real_escape_string( $identity );
		$sql = "DELETE FROM `{$this->tablePrefix}users_identities
			WHERE user_id = {$userId} AND identity = '{$identity}'";
		if ( ! $this->db->query( $sql ) || ! $this->db->affected_rows ) {
			return FALSE;
		}
		return TRUE;
	}

}


// end of file pas_users_identities.class.php