<?php
/**
 * Open Source Social Network
 *
 * @package   (softlab24.com).ossn
 * @author    OSSN Core Team <info@softlab24.com>
 * @copyright (C) SOFTLAB24 LIMITED
 * @license   Open Source Social Network License (OSSN LICENSE)  http://www.opensource-socialnetwork.org/licence
 * @link      https://www.opensource-socialnetwork.org/
 */

/**
 * Ossn Add Relations
 *
 * @param integer $from Relation from guid
 * @param integer $to Relation to guid
 * @param string  $type Relation type
 *
 * @return boolean
 */
function ossn_add_relation($from, $to, $type) {
		if(!empty($from) && !empty($to) && !empty($type) && $type !== 0) {
				$add              = new OssnDatabase;
				$params['into']   = 'ossn_relationships';
				$params['names']  = array(
						'relation_from',
						'relation_to',
						'type',
						'time'
				);
				$params['values'] = array(
						$from,
						$to,
						$type,
						time()
				);
				if($add->insert($params)) {
						ossn_trigger_callback('relation', 'add', array(
								'from' => $from,
								'to' => $to,
								'type' => $type
						));
						return true;
				}
		}
		return false;
}
/**
 * Ossn relation exists
 *
 * @param integer $from Relation from guid
 * @param integer $to Relation to guid
 * @param string  $type Relation type
 *
 * @return boolean
 */
function ossn_relation_exists($from, $to, $type, $recursive = false) {
		if(!empty($from) && !empty($to) && !empty($type)) {
				$database           = new OssnDatabase;
				$params['from']     = 'ossn_relationships as r';
				$params['wheres']   = array();
				$params['wheres'][] = "r.relation_from='{$from}' AND r.relation_to='{$to}' AND r.type='{$type}'";
				if($recursive) {
						$params['joins']    = array(
								"JOIN ossn_relationships as r2"
						);
						$params['wheres'][] = "AND r2.relation_from='{$to}' AND r2.relation_to='{$from}' AND r2.type='{$type}'";
				}
				if($database->select($params)) {
						return true;
				}
		}
		return false;
}
/**
 * Ossn get relationships
 *
 * @param array $params A options
 *
 * @return objects
 */
function ossn_get_relationships(array $params = array()) {
		$wheres   = array();
		$vars     = array();
		$database = new OssnDatabase;
		if(isset($params['from']) && !empty($params['from'])) {
				if(isset($params['inverse'])) {
						$vars['joins'] = array(
								'JOIN ossn_relationships as r1 ON r1.relation_from=r.relation_to'
						);
						$wheres[]      = "r1.relation_to='{$params['to']}'";
				}
				$wheres[] = "r.relation_from='{$params['from']}'";
				if(is_array($params['type'])) {
						foreach($params['type'] as $titem) {
								$types[] = "'{$titem}'";
						}
						$type     = implode(',', $types);
						$wheres[] = "r.type IN ({$type})";
						if(isset($params['inverse'])) {
								$wheres[] = "r1.type IN ({$type})";
						}
				} else {
						$wheres[] = "r.type='{$params['type']}'";
						if(isset($params['inverse'])) {
								$wheres[] = "r1.type='{$params['type']}'";
						}
				}
		} elseif(isset($params['to']) && !empty($params['to'])) {
				if(isset($params['inverse'])) {
						$vars['joins'] = array(
								'JOIN ossn_relationships as r1 ON r1.relation_to=r.relation_from'
						);
						$wheres[]      = "r1.relation_from='{$params['to']}'";
				}
				$wheres[] = "r.relation_to='{$params['to']}'";
				
				if(is_array($params['type'])) {
						foreach($params['type'] as $titem) {
								$types[] = "'{$titem}'";
						}
						$type     = implode(',', $types);
						$wheres[] = "r.type IN ({$type})";
						if(isset($params['inverse'])) {
								$wheres[] = "r1.type IN ({$type})";
						}
				} else {
						$wheres[] = "r.type='{$params['type']}'";
						if(isset($params['inverse'])) {
								$wheres[] = "r1.type='{$params['type']}'";
						}
				}
		}
		if(empty($params['type'])) {
				return false;
		}
		$default = array(
				'page_limit' => 10,
				'limit' => false,
				'offset' => input('offset', '', 1)
		);
		$options = array_merge($default, $params);
		//validate offset values
		if(!empty($options['limit']) && !empty($options['page_limit'])) {
				$offset_vals = ceil($options['limit'] / $options['page_limit']);
				$offset_vals = abs($offset_vals);
				$offset_vals = range(1, $offset_vals);
				if(!in_array($options['offset'], $offset_vals)) {
						return false;
				}
		}
		//get only required result, don't bust your server memory
		$getlimit = $database->generateLimit($options['limit'], $options['page_limit'], $options['offset']);
		if($getlimit) {
				$vars['limit'] = $getlimit;
		} else {
				$vars['limit'] = $options['limit'];
		}
		$vars['from']   = 'ossn_relationships as r';
		$vars['wheres'] = array(
				$database->constructWheres($wheres)
		);
		if(isset($params['count']) && $params['count'] === true) {
				unset($vars['params']);
				unset($vars['limit']);
				$count['params'] = array(
						"count(*) as total"
				);
				$count           = array_merge($vars, $count);
				return $database->select($count)->total;
		}

		$vars['order_by'] = $options['order_by'];
		$data = $database->select($vars, true);
		if($data) {
				return $data;
		}
		return false;
}
/**
 * Ossn Delete Relation
 *
 * @param integer $id ID of the relationship
 *
 * @return boolean
 */
function ossn_delete_relationship_by_id($id) {
		if(!empty($id)) {
				$delete           = new OssnDatabase;
				$params['from']   = 'ossn_relationships';
				$params['wheres'] = array(
						"relation_id='{$id}'"
				);
				if($delete->delete($params)) {
						return true;
				}
		}
		return false;
}
/**
 * Ossn Delete Relation
 *
 * @param integer $id ID of the relationship
 *
 * @return boolean
 */
function ossn_delete_relationship(array $vars = array()) {
		if(empty($vars['from']) || empty($vars['to']) || empty($vars['type'])) {
				return false;
		}
		$wheres = array();
		$delete = new OssnDatabase;
		
		$wheres[] = "relation_from='{$vars['from']}' AND relation_to='{$vars['to']}' AND type='{$vars['type']}'";
		if(isset($vars['recursive'])) {
				$wheres[] = "relation_to='{$vars['from']}' AND relation_from='{$vars['to']}' AND type='{$vars['type']}'";
		}
		$params['from']   = 'ossn_relationships';
		$params['wheres'] = array(
				$delete->constructWheres($wheres)
		);
		if($delete->delete($params)) {
				return true;
		}
		return false;
}
/**
 * Delete user relations if user is deleted
 *
 * @param  OssnUser $user Entity of user 
 *
 * @return bool
 */
function ossn_delete_user_relations($user) {
		if($user) {
				$delete           = new OssnDatabase;
				$params['from']   = 'ossn_relationships';
				//delete friend requests and group member requests if user deleted
				$params['wheres'] = array(
						"relation_from='{$user->guid}' AND type='friend:request' OR",
						"relation_to='{$user->guid}' AND type='friend:request' OR",
						"relation_from='{$user->guid}' AND type='group:join' OR",
						"relation_to='{$user->guid}' AND type='group:join:approve'"
				);
				if($delete->delete($params)) {
						return true;
				}
		}
		return false;
}
/**
 * Delete group relations if user is deleted
 *
 * @param  (object) $group Group Entity
 *
 * @return bool
 */
function ossn_delete_group_relations($group) {
		if($group) {
				$delete           = new OssnDatabase;
				$params['from']   = 'ossn_relationships';
				//delete group member requests if group deleted
				$params['wheres'] = array(
						"relation_from='{$group->guid}' AND type='group:join:approve' OR",
						"relation_to='{$group->guid}' AND type='group:join'"
				);
				if($delete->delete($params)) {
						return true;
				}
		}
		return false;
}
