brantje / nextnote

lib/Db/OwnNoteMapper.php

<?php
/**
 * Nextcloud - ownnote
 *
 * @copyright Copyright (c) 2015, Ben Curtis <ownclouddev@nosolutions.com>
 * @copyright Copyright (c) 2017, Sander Brand (brantje@gmail.com)
 * @license GNU AGPL version 3 or any later version
 *
 * 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 <http://www.gnu.org/licenses/>.
 *
 */

namespace OCA\OwnNote\Db;

use \OCA\OwnNote\Utility\Utils;
use OCP\AppFramework\Db\Entity;
use OCP\IDBConnection;
use OCP\AppFramework\Db\Mapper;

class OwnNoteMapper extends Mapper {
	private $utils;

	public function __construct(IDBConnection $db, Utils $utils) {
		parent::__construct($db, 'ownnote');
		$this->utils = $utils;
	}


	/**
	 * @param $note_id
	 * @param null $user_id
	 * @return OwnNote if not found
	 */
	public function find($note_id, $user_id = null) {

This method seems to be duplicated in your project.

		$params = [$note_id];
		$uidSql = '';
		if($user_id){
			$params[] = $user_id;
			$uidSql = 'and n.uid = ?';
		}
		$sql = "SELECT n.id, n.uid, n.name, n.grouping, n.shared, n.mtime, n.deleted, p.pid, GROUP_CONCAT(p.note SEPARATOR '') as note FROM *PREFIX*ownnote n INNER JOIN *PREFIX*ownnote_parts p ON n.id = p.id WHERE n.id= ? $uidSql and n.deleted = 0 GROUP BY p.id";
		$results = [];
		foreach($this->execute($sql, $params)->fetchAll() as $item){
			$note = new OwnNote();
			$note->setId($item['id']);
			$note->setName($item['name']);
			$note->setGrouping($item['grouping']);
			$note->setMtime($item['mtime']);
			$note->setDeleted($item['deleted']);
			$note->setNote($item['note']);
			$note->setUid($item['uid']);
			$results[] = $note;
		}
		return array_shift($results);
	}


	/**
	 * @throws \OCP\AppFramework\Db\DoesNotExistException if not found
	 * @throws \OCP\AppFramework\Db\MultipleObjectsReturnedException if more than one result
	 * @return OwnNote[]
	 */
	public function findNotesFromUser($userId) {
		$params = [$userId];
		$sql = "SELECT n.uid, n.id, n.name, n.grouping, n.shared, n.mtime, n.deleted, p.pid, GROUP_CONCAT(p.note SEPARATOR '') as note FROM *PREFIX*ownnote n INNER JOIN *PREFIX*ownnote_parts p ON n.id = p.id WHERE `uid` = ? and n.deleted = 0 GROUP BY p.id";
		$results = [];
		foreach($this->execute($sql, $params)->fetchAll() as $item){
			$note = new OwnNote();
			$note->setId($item['id']);
			$note->setName($item['name']);
			$note->setGrouping($item['grouping']);
			$note->setMtime($item['mtime']);
			$note->setDeleted($item['deleted']);
			$note->setNote($item['note']);
			$note->setUid($item['uid']);
			$results[] = $note;
		}
		return $results;
	}
	/**
	 * @throws \OCP\AppFramework\Db\DoesNotExistException if not found
	 * @throws \OCP\AppFramework\Db\MultipleObjectsReturnedException if more than one result
	 * @return OwnNote[]
	 */
	public function findNotesByGroup($group, $userId) {

This method seems to be duplicated in your project.

		$params = [$group];
		$uidSql = '';
		if($userId){
			$params[] = $userId;
			$uidSql = 'and n.uid = ?';
		}
		$sql = "SELECT n.uid, n.id, n.name, n.grouping, n.shared, n.mtime, n.deleted, p.pid, GROUP_CONCAT(p.note SEPARATOR '') as note FROM *PREFIX*ownnote n INNER JOIN *PREFIX*ownnote_parts p ON n.id = p.id WHERE n.deleted = 0 $uidSql and n.grouping = ? GROUP BY p.id";
		$results = [];
		foreach($this->execute($sql, $params)->fetchAll() as $item){
			$note = new OwnNote();
			$note->setId($item['id']);
			$note->setName($item['name']);
			$note->setGrouping($item['grouping']);
			$note->setMtime($item['mtime']);
			$note->setDeleted($item['deleted']);
			$note->setNote($item['note']);
			$note->setUid($item['uid']);
			$results[] = $note;
		}
		return $results;
	}

	/**
	 * Creates a note
	 *
	 * @param OwnNote $note
	 * @return OwnNote|Entity
	 * @internal param $userId
	 */
	public function create($note) {

This method seems to be duplicated in your project.

		$parts = $this->utils->splitContent($note->getNote());
		$note->setNote('');

		/**
		 * @var $note OwnNote
		 */
		$note = parent::insert($note);

It seems like you call parent on a different method (insert() instead of create()). Are you sure this is correct? If so, you might want to change this to $this->insert().

		foreach ($parts as $part) {
			$this->createNotePart($note, $part);
		}

		$note->setNote(implode('', $parts));

		return $note;
	}

	/**
	 * Update note
	 *
	 * @param OwnNote $note
	 * @return OwnNote|Entity
	 */
	public function updateNote($note) {

This method seems to be duplicated in your project.

		$parts = $this->utils->splitContent($note->getNote());
		$this->deleteNoteParts($note);

		foreach ($parts as $part) {
			$this->createNotePart($note, $part);
		}
		$note->setNote('');
		/**
		 * @var $note OwnNote
		 */
		$note = parent::update($note);

It seems like you call parent on a different method (update() instead of updateNote()). Are you sure this is correct? If so, you might want to change this to $this->update().

		$note->setNote(implode('', $parts));
		return $note;
	}

	/**
	 * @param OwnNote $note
	 * @param $content
	 */
	public function createNotePart(OwnNote $note, $content) {
		$sql = "INSERT INTO *PREFIX*ownnote_parts VALUES (NULL, ?, ?);";
		$this->execute($sql, array($note->getId(), $content));
	}

	/**
	 * Delete the note parts
	 *
	 * @param OwnNote $note
	 */
	public function deleteNoteParts(OwnNote $note) {
		$sql = 'DELETE FROM *PREFIX*ownnote_parts where id = ?';
		$this->execute($sql, array($note->getId()));
	}

	/**
	 * @param OwnNote $note
	 * @return bool
	 */
	public function deleteNote(OwnNote $note) {
		$this->deleteNoteParts($note);
		$this->delete($note);
		return true;
	}
}