123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117 |
- <?php
- declare(strict_types=1);
- namespace OC\Talk;
- use OC\AppFramework\Bootstrap\Coordinator;
- use OCP\IServerContainer;
- use OCP\Talk\Exceptions\NoBackendException;
- use OCP\Talk\IBroker;
- use OCP\Talk\IConversation;
- use OCP\Talk\IConversationOptions;
- use OCP\Talk\ITalkBackend;
- use Psr\Log\LoggerInterface;
- use RuntimeException;
- use Throwable;
- class Broker implements IBroker {
- private Coordinator $coordinator;
- private IServerContainer $container;
- private LoggerInterface $logger;
- private ?bool $hasBackend = null;
- private ?ITalkBackend $backend = null;
- public function __construct(Coordinator $coordinator,
- IServerContainer $container,
- LoggerInterface $logger) {
- $this->coordinator = $coordinator;
- $this->container = $container;
- $this->logger = $logger;
- }
- public function hasBackend(): bool {
- if ($this->hasBackend !== null) {
- return $this->hasBackend;
- }
- $context = $this->coordinator->getRegistrationContext();
- if ($context === null) {
-
- throw new RuntimeException("Not all apps have been registered yet");
- }
- $backendRegistration = $context->getTalkBackendRegistration();
- if ($backendRegistration === null) {
-
- return $this->hasBackend = false;
- }
- try {
- $this->backend = $this->container->get(
- $backendRegistration->getService()
- );
-
- return $this->hasBackend = true;
- } catch (Throwable $e) {
- $this->logger->error("Talk backend {class} could not be loaded: " . $e->getMessage(), [
- 'class' => $backendRegistration->getService(),
- 'exception' => $e,
- ]);
-
- return false;
- }
- }
- public function newConversationOptions(): IConversationOptions {
- return ConversationOptions::default();
- }
- public function createConversation(string $name,
- array $moderators,
- IConversationOptions $options = null): IConversation {
- if (!$this->hasBackend()) {
- throw new NoBackendException("The Talk broker has no registered backend");
- }
- return $this->backend->createConversation(
- $name,
- $moderators,
- $options ?? ConversationOptions::default()
- );
- }
- public function deleteConversation(string $id): void {
- if (!$this->hasBackend()) {
- throw new NoBackendException("The Talk broker has no registered backend");
- }
- $this->backend->deleteConversation($id);
- }
- }
|