From 10f706c9657058ca72a5cdaefdc0b9a172faf6b8 Mon Sep 17 00:00:00 2001
From: Yuri Kuznetsov <yurak@list.ru>
Date: Mon, 13 Jan 2014 16:44:04 +0200
Subject: [PATCH] stream

---
 application/Espo/Controllers/Note.php         |  8 +++
 application/Espo/Controllers/Stream.php       | 16 +++++
 application/Espo/Core/Acl.php                 |  5 ++
 application/Espo/Core/ControllerManager.php   |  3 +-
 application/Espo/Entities/Attachment.php      |  8 +++
 application/Espo/Entities/Note.php            |  8 +++
 .../Resources/layouts/Note/detailSmall.json   | 13 ++++
 application/Espo/Resources/routes.json        | 11 +++
 application/Espo/Services/Record.php          |  2 +-
 application/Espo/Services/Stream.php          | 72 +++++++++++++++++++
 10 files changed, 144 insertions(+), 2 deletions(-)
 create mode 100644 application/Espo/Controllers/Note.php
 create mode 100644 application/Espo/Entities/Attachment.php
 create mode 100644 application/Espo/Entities/Note.php
 create mode 100644 application/Espo/Resources/layouts/Note/detailSmall.json
 create mode 100644 application/Espo/Services/Stream.php

diff --git a/application/Espo/Controllers/Note.php b/application/Espo/Controllers/Note.php
new file mode 100644
index 0000000000..bf08634fc1
--- /dev/null
+++ b/application/Espo/Controllers/Note.php
@@ -0,0 +1,8 @@
+<?php
+
+namespace Espo\Controllers;
+
+class Note extends \Espo\Core\Controllers\Record
+{
+
+}
diff --git a/application/Espo/Controllers/Stream.php b/application/Espo/Controllers/Stream.php
index 5e44774dd2..bd3b0bdcef 100644
--- a/application/Espo/Controllers/Stream.php
+++ b/application/Espo/Controllers/Stream.php
@@ -10,6 +10,22 @@ class Stream extends \Espo\Core\Controllers\Base
 
     public function actionList($params, $data, $request)
 	{
+		$scope = $params['scope'];
+		$id = $params['id'];
 		
+		$offset = intval($request->get('offset'));
+		$maxSize = intval($request->get('maxSize'));
+		
+		$service = $this->getService('\\Espo\\Services\\Stream');		
+		
+		$result = $service->find($scope, $id, array(
+			'offset' => $offset,
+			'maxSize' => $maxSize
+		));
+		
+		return array(
+			'total' => $result['total'],
+			'list' => $result['collection']->toArray()
+		);
 	}
 }
diff --git a/application/Espo/Core/Acl.php b/application/Espo/Core/Acl.php
index 09437afa4a..f887d20c6d 100644
--- a/application/Espo/Core/Acl.php
+++ b/application/Espo/Core/Acl.php
@@ -170,6 +170,11 @@ class Acl
 			'delete' => 'no',					
 		);
 		$this->data['Role'] = false;
+		$this->data['Note'] = array(
+			'read' => 'own',
+			'edit' => 'own',
+			'delete' => 'own',					
+		);
 	}
 
 	private function merge($tables)
diff --git a/application/Espo/Core/ControllerManager.php b/application/Espo/Core/ControllerManager.php
index da87cb9be6..77272d2933 100644
--- a/application/Espo/Core/ControllerManager.php
+++ b/application/Espo/Core/ControllerManager.php
@@ -47,7 +47,8 @@ class ControllerManager
 				$controllerClassName = '\\Espo\\Controllers\\' . Util::normilizeClassName($controllerName);
 			}
 		}
-				
+		
+			
 		if ($data) {
 			$data = json_decode($data, true);
 		}		
diff --git a/application/Espo/Entities/Attachment.php b/application/Espo/Entities/Attachment.php
new file mode 100644
index 0000000000..c13b9de8ad
--- /dev/null
+++ b/application/Espo/Entities/Attachment.php
@@ -0,0 +1,8 @@
+<?php
+
+namespace Espo\Entities;
+
+class Attachment extends \Espo\Core\ORM\Entity
+{
+
+}
diff --git a/application/Espo/Entities/Note.php b/application/Espo/Entities/Note.php
new file mode 100644
index 0000000000..a3e848388b
--- /dev/null
+++ b/application/Espo/Entities/Note.php
@@ -0,0 +1,8 @@
+<?php
+
+namespace Espo\Entities;
+
+class Note extends \Espo\Core\ORM\Entity
+{
+
+}
diff --git a/application/Espo/Resources/layouts/Note/detailSmall.json b/application/Espo/Resources/layouts/Note/detailSmall.json
new file mode 100644
index 0000000000..df2e9546ba
--- /dev/null
+++ b/application/Espo/Resources/layouts/Note/detailSmall.json
@@ -0,0 +1,13 @@
+[
+	{
+		"label":"",
+		"rows": [
+			[
+				{"name":"message"}
+			],
+			[
+				{"name":"attachments"}
+			]
+		]
+	}
+]
diff --git a/application/Espo/Resources/routes.json b/application/Espo/Resources/routes.json
index 0aa460e770..fa90dc88d8 100644
--- a/application/Espo/Resources/routes.json
+++ b/application/Espo/Resources/routes.json
@@ -161,6 +161,17 @@
 		"id":":id"
     }
   },
+  
+  {
+  	"route":"/:controller/:id/stream",
+    "method":"get",
+    "params":{
+        "controller":"Stream",
+		"action":"list",
+		"id":":id",
+		"scope":":controller"
+    }
+  },
 
   {
   	"route":"/:controller/:id/:link",
diff --git a/application/Espo/Services/Record.php b/application/Espo/Services/Record.php
index 541c85a179..ab1f8adc50 100644
--- a/application/Espo/Services/Record.php
+++ b/application/Espo/Services/Record.php
@@ -163,7 +163,7 @@ class Record extends \Espo\Core\Services\Base
     	return array(
     		'total' => $this->getRepository()->count($selectParams),
     		'collection' => $collection,
-    	); 	    	
+    	);
 	}
 
     public function findLinkedEntities($id, $link, $params)
diff --git a/application/Espo/Services/Stream.php b/application/Espo/Services/Stream.php
new file mode 100644
index 0000000000..35e21b61a0
--- /dev/null
+++ b/application/Espo/Services/Stream.php
@@ -0,0 +1,72 @@
+<?php
+
+namespace Espo\Services;
+
+use \Espo\Core\Exceptions\Forbidden;
+use \Espo\Core\Exceptions\NotFound;
+
+class Stream extends \Espo\Core\Services\Base
+{	
+	static public $dependencies = array(
+		'entityManager',
+		'user',
+		'metadata',
+		'acl'
+	);
+
+	protected function getEntityManager()
+	{
+		return $this->injections['entityManager'];
+	}
+
+	protected function getUser()
+	{
+		return $this->injections['user'];
+	}
+	
+	protected function getAcl()
+	{
+		return $this->injections['acl'];
+	}
+	
+	protected function getMetadata()
+	{
+		return $this->injections['metadata'];
+	}
+	
+	public function find($scope, $id, $params)
+	{
+		$entity = $this->getEntityManager()->getEntity($scope, $id);
+		
+		if (empty($entity)) {
+			throw new NotFound();
+		}
+		
+		if (!$this->getAcl($entity, 'read')) {
+			throw new Forbidden();
+		}
+		
+		$where = array(
+			'parentType' => $scope,
+			'parentId' => $id
+		);
+		
+		$collection = $this->getEntityManager()->getRepository('Note')->find(array(
+			'whereClause' => $where,
+			'offset' => $params['offset'],
+			'limit' => $params['maxSize'],
+			'orderBy' => 'createdAt',
+			'order' => 'DESC'
+		));
+		
+		$count = $this->getEntityManager()->getRepository('Note')->count(array(
+			'whereClause' => $where,
+		));
+		
+    	return array(
+    		'total' => $count,
+    		'collection' => $collection,
+    	);		
+	}
+}
+