Mibew/first-message-plugin
1
0
Fork 0
mirror of https://github.com/Mibew/first-message-plugin.git synced 2025-10-31 18:41:06 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

Remove messages for closed threads

Browse Source
This commit is contained in:
Dmitriy Simushev 2015-06-19 13:17:02 +00:00
parent 694af48235
commit 117a17dc33
1 changed files with 23 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
Plugin.php
View File

@ -30,8 +30,6 @@ use Mibew\Thread;
/** /**
* Represents the plugin. * Represents the plugin.
*
* @todo First messages cleaning for closed threads.
*/ */
class Plugin extends \Mibew\Plugin\AbstractPlugin implements \Mibew\Plugin\PluginInterface class Plugin extends \Mibew\Plugin\AbstractPlugin implements \Mibew\Plugin\PluginInterface
{ {
@ -68,6 +66,7 @@ class Plugin extends \Mibew\Plugin\AbstractPlugin implements \Mibew\Plugin\Plugi
// Attach CSS and JS files of the plugin to chat window. // Attach CSS and JS files of the plugin to chat window.
$dispatcher = EventDispatcher::getInstance(); $dispatcher = EventDispatcher::getInstance();
$dispatcher->attachListener(Events::THREAD_USER_IS_READY, $this, 'sendFirstMessage'); $dispatcher->attachListener(Events::THREAD_USER_IS_READY, $this, 'sendFirstMessage');
$dispatcher->attachListener(Events::THREAD_CLOSE, $this, 'removeOldMessage');
} }
/** /**
@ -102,6 +101,28 @@ class Plugin extends \Mibew\Plugin\AbstractPlugin implements \Mibew\Plugin\Plugi
} }
} }
/**
* Removes messages for threads that are closed.
*
* It's a listener of {@link \Mibew\EventDispatcher\Events::THREAD_CLOSE}
* event.
*
* @param array $args List of arguments that is passed to the event.
*/
public function removeOldMessage(&$args)
{
$thread = $args['thread'];
if ($thread->userId) {
$message = Message::loadByUserId($thread->userId);
if ($message) {
// There is a first message associated with the user ID. Delete
// it because the thread is closed now and the message cannot be
// used anymore.
$message->delete();
}
}
}
/** /**
* Specify version of the plugin. * Specify version of the plugin.
* *