implementing Push App

lib/composer/composer/autoload_classmap.php

@@ -363,6 +363,18 @@
  'OCP\\Preview\\IProvider' => $baseDir . '/lib/public/Preview/IProvider.php',
  'OCP\\Preview\\IProviderV2' => $baseDir . '/lib/public/Preview/IProviderV2.php',
  'OCP\\Preview\\IVersionedPreviewFile' => $baseDir . '/lib/public/Preview/IVersionedPreviewFile.php',
+ 'OCP\\Push\\Exceptions\\ItemNotFoundException' => $baseDir . '/lib/public/Push/Exceptions/ItemNotFoundException.php',
+ 'OCP\\Push\\Exceptions\\PushInstallException' => $baseDir . '/lib/public/Push/Exceptions/PushInstallException.php',
+ 'OCP\\Push\\Exceptions\\UnknownStreamTypeException' => $baseDir . '/lib/public/Push/Exceptions/UnknownStreamTypeException.php',
+ 'OCP\\Push\\Helper\\IPushHelper' => $baseDir . '/lib/public/Push/Helper/IPushHelper.php',
+ 'OCP\\Push\\IPushManager' => $baseDir . '/lib/public/Push/IPushManager.php',
+ 'OCP\\Push\\Model\\Helper\\IPushCallback' => $baseDir . '/lib/public/Push/Model/Helper/IPushCallback.php',
+ 'OCP\\Push\\Model\\Helper\\IPushEvent' => $baseDir . '/lib/public/Push/Model/Helper/IPushEvent.php',
+ 'OCP\\Push\\Model\\Helper\\IPushNotification' => $baseDir . '/lib/public/Push/Model/Helper/IPushNotification.php',
+ 'OCP\\Push\\Model\\IPushItem' => $baseDir . '/lib/public/Push/Model/IPushItem.php',
+ 'OCP\\Push\\Model\\IPushRecipients' => $baseDir . '/lib/public/Push/Model/IPushRecipients.php',
+ 'OCP\\Push\\Model\\IPushWrapper' => $baseDir . '/lib/public/Push/Model/IPushWrapper.php',
+ 'OCP\\Push\\Service\\IPushService' => $baseDir . '/lib/public/Push/Service/IPushService.php',
  'OCP\\Remote\\Api\\IApiCollection' => $baseDir . '/lib/public/Remote/Api/IApiCollection.php',
  'OCP\\Remote\\Api\\IApiFactory' => $baseDir . '/lib/public/Remote/Api/IApiFactory.php',
  'OCP\\Remote\\Api\\ICapabilitiesApi' => $baseDir . '/lib/public/Remote/Api/ICapabilitiesApi.php',
@@ -1056,6 +1068,13 @@
  'OC\\Preview\\Watcher' => $baseDir . '/lib/private/Preview/Watcher.php',
  'OC\\Preview\\WatcherConnector' => $baseDir . '/lib/private/Preview/WatcherConnector.php',
  'OC\\Preview\\XBitmap' => $baseDir . '/lib/private/Preview/XBitmap.php',
+ 'OC\\Push\\Model\\Helper\\PushCallback' => $baseDir . '/lib/private/Push/Model/Helper/PushCallback.php',
+ 'OC\\Push\\Model\\Helper\\PushEvent' => $baseDir . '/lib/private/Push/Model/Helper/PushEvent.php',
+ 'OC\\Push\\Model\\Helper\\PushNotification' => $baseDir . '/lib/private/Push/Model/Helper/PushNotification.php',
+ 'OC\\Push\\Model\\PushItem' => $baseDir . '/lib/private/Push/Model/PushItem.php',
+ 'OC\\Push\\Model\\PushRecipients' => $baseDir . '/lib/private/Push/Model/PushRecipients.php',
+ 'OC\\Push\\Model\\PushWrapper' => $baseDir . '/lib/private/Push/Model/PushWrapper.php',
+ 'OC\\Push\\PushManager' => $baseDir . '/lib/private/Push/PushManager.php',
  'OC\\RedisFactory' => $baseDir . '/lib/private/RedisFactory.php',
  'OC\\Remote\\Api\\ApiBase' => $baseDir . '/lib/private/Remote/Api/ApiBase.php',
  'OC\\Remote\\Api\\ApiCollection' => $baseDir . '/lib/private/Remote/Api/ApiCollection.php',

lib/composer/composer/autoload_static.php

@@ -397,6 +397,18 @@ class ComposerStaticInit53792487c5a8370acc0b06b1a864ff4c
  'OCP\\Preview\\IProvider' => __DIR__ . '/../../..' . '/lib/public/Preview/IProvider.php',
  'OCP\\Preview\\IProviderV2' => __DIR__ . '/../../..' . '/lib/public/Preview/IProviderV2.php',
  'OCP\\Preview\\IVersionedPreviewFile' => __DIR__ . '/../../..' . '/lib/public/Preview/IVersionedPreviewFile.php',
+ 'OCP\\Push\\Exceptions\\ItemNotFoundException' => __DIR__ . '/../../..' . '/lib/public/Push/Exceptions/ItemNotFoundException.php',
+ 'OCP\\Push\\Exceptions\\PushInstallException' => __DIR__ . '/../../..' . '/lib/public/Push/Exceptions/PushInstallException.php',
+ 'OCP\\Push\\Exceptions\\UnknownStreamTypeException' => __DIR__ . '/../../..' . '/lib/public/Push/Exceptions/UnknownStreamTypeException.php',
+ 'OCP\\Push\\Helper\\IPushHelper' => __DIR__ . '/../../..' . '/lib/public/Push/Helper/IPushHelper.php',
+ 'OCP\\Push\\IPushManager' => __DIR__ . '/../../..' . '/lib/public/Push/IPushManager.php',
+ 'OCP\\Push\\Model\\Helper\\IPushCallback' => __DIR__ . '/../../..' . '/lib/public/Push/Model/Helper/IPushCallback.php',
+ 'OCP\\Push\\Model\\Helper\\IPushEvent' => __DIR__ . '/../../..' . '/lib/public/Push/Model/Helper/IPushEvent.php',
+ 'OCP\\Push\\Model\\Helper\\IPushNotification' => __DIR__ . '/../../..' . '/lib/public/Push/Model/Helper/IPushNotification.php',
+ 'OCP\\Push\\Model\\IPushItem' => __DIR__ . '/../../..' . '/lib/public/Push/Model/IPushItem.php',
+ 'OCP\\Push\\Model\\IPushRecipients' => __DIR__ . '/../../..' . '/lib/public/Push/Model/IPushRecipients.php',
+ 'OCP\\Push\\Model\\IPushWrapper' => __DIR__ . '/../../..' . '/lib/public/Push/Model/IPushWrapper.php',
+ 'OCP\\Push\\Service\\IPushService' => __DIR__ . '/../../..' . '/lib/public/Push/Service/IPushService.php',
  'OCP\\Remote\\Api\\IApiCollection' => __DIR__ . '/../../..' . '/lib/public/Remote/Api/IApiCollection.php',
  'OCP\\Remote\\Api\\IApiFactory' => __DIR__ . '/../../..' . '/lib/public/Remote/Api/IApiFactory.php',
  'OCP\\Remote\\Api\\ICapabilitiesApi' => __DIR__ . '/../../..' . '/lib/public/Remote/Api/ICapabilitiesApi.php',
@@ -1090,6 +1102,13 @@ class ComposerStaticInit53792487c5a8370acc0b06b1a864ff4c
  'OC\\Preview\\Watcher' => __DIR__ . '/../../..' . '/lib/private/Preview/Watcher.php',
  'OC\\Preview\\WatcherConnector' => __DIR__ . '/../../..' . '/lib/private/Preview/WatcherConnector.php',
  'OC\\Preview\\XBitmap' => __DIR__ . '/../../..' . '/lib/private/Preview/XBitmap.php',
+ 'OC\\Push\\Model\\Helper\\PushCallback' => __DIR__ . '/../../..' . '/lib/private/Push/Model/Helper/PushCallback.php',
+ 'OC\\Push\\Model\\Helper\\PushEvent' => __DIR__ . '/../../..' . '/lib/private/Push/Model/Helper/PushEvent.php',
+ 'OC\\Push\\Model\\Helper\\PushNotification' => __DIR__ . '/../../..' . '/lib/private/Push/Model/Helper/PushNotification.php',
+ 'OC\\Push\\Model\\PushItem' => __DIR__ . '/../../..' . '/lib/private/Push/Model/PushItem.php',
+ 'OC\\Push\\Model\\PushRecipients' => __DIR__ . '/../../..' . '/lib/private/Push/Model/PushRecipients.php',
+ 'OC\\Push\\Model\\PushWrapper' => __DIR__ . '/../../..' . '/lib/private/Push/Model/PushWrapper.php',
+ 'OC\\Push\\PushManager' => __DIR__ . '/../../..' . '/lib/private/Push/PushManager.php',
  'OC\\RedisFactory' => __DIR__ . '/../../..' . '/lib/private/RedisFactory.php',
  'OC\\Remote\\Api\\ApiBase' => __DIR__ . '/../../..' . '/lib/private/Remote/Api/ApiBase.php',
  'OC\\Remote\\Api\\ApiCollection' => __DIR__ . '/../../..' . '/lib/private/Remote/Api/ApiCollection.php',

lib/private/Push/Model/Helper/PushCallback.php

@@ -0,0 +1,126 @@
+<?php
+declare(strict_types=1);
+
+
+/**
+ * Push - Nextcloud Push Service
+ *
+ * This file is licensed under the Affero General Public License version 3 or
+ * later. See the COPYING file.
+ *
+ * @author Maxence Lange <maxence@artificial-owl.com>
+ * @copyright 2019, Maxence Lange <maxence@artificial-owl.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 OC\Push\Model\Helper;
+
+
+use daita\NcSmallPhpTools\Traits\TArrayTools;
+use JsonSerializable;
+use OC\Push\Model\PushRecipients;
+use OCP\Push\Model\Helper\IPushCallback;
+
+
+/**
+ * Class PushCallback
+ *
+ * @since 18.0.0
+ *
+ * @package OC\Push\Model\Helper
+ */
+class PushCallback extends PushRecipients implements IPushCallback, JsonSerializable {
+
+
+ use TArrayTools;
+
+
+ /** @var array */
+ private $payload = '';
+
+
+ /**
+ * PushCallback constructor.
+ *
+ * @param string $app
+ * @param string $source
+ *
+ * @since 18.0.0
+ */
+ public function __construct(string $app = '', string $source = '') {
+ $this->setApp($app);
+ $this->setSource($source);
+ }
+
+
+ /**
+ * @return array
+ *
+ * @since 18.0.0
+ */
+ public function getPayload(): array {
+ if ($this->payload instanceof JsonSerializable) {
+ return $this->payload->jsonSerialize();
+ }
+
+ return $this->payload;
+ }
+
+ /**
+ * @param array $payload
+ *
+ * @return IPushCallback
+ *
+ * @since 18.0.0
+ */
+ public function setPayload(array $payload): IPushCallback {
+ $this->payload = $payload;
+
+ return $this;
+ }
+
+ /**
+ * @param JsonSerializable $payload
+ *
+ * @return self
+ *
+ * @since 18.0.0
+ */
+ public function setPayloadSerializable(JsonSerializable $payload): IPushCallback {
+ $this->payload = $payload;
+
+ return $this;
+ }
+
+
+ /**
+ * @return array
+ */
+ public function jsonSerialize(): array {
+ return array_merge(
+ parent::jsonSerialize(),
+ [
+ 'app' => $this->getApp(),
+ 'source' => $this->getSource(),
+ 'payload' => $this->payload
+ ]
+ );
+ }
+
+}
+

lib/private/Push/Model/Helper/PushEvent.php

@@ -0,0 +1,151 @@
+<?php
+declare(strict_types=1);
+
+
+/**
+ * Push - Nextcloud Push Service
+ *
+ * This file is licensed under the Affero General Public License version 3 or
+ * later. See the COPYING file.
+ *
+ * @author Maxence Lange <maxence@artificial-owl.com>
+ * @copyright 2019, Maxence Lange <maxence@artificial-owl.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 OC\Push\Model\Helper;
+
+
+use daita\NcSmallPhpTools\Traits\TArrayTools;
+use JsonSerializable;
+use OC\Push\Model\PushRecipients;
+use OCP\Push\Model\Helper\IPushEvent;
+
+
+/**
+ * Class PushEvent
+ *
+ * @since 18.0.0
+ *
+ * @package OC\Push\Model\Helper
+ */
+class PushEvent extends PushRecipients implements IPushEvent, JsonSerializable {
+
+
+ use TArrayTools;
+
+ /** @var string */
+ private $command = '';
+
+ /** @var array */
+ private $payload = [];
+
+
+ /**
+ * PushEvent constructor.
+ *
+ * @param string $app
+ * @param string $command
+ *
+ * @since 18.0.0
+ */
+ public function __construct($app = '', $command = '') {
+ $this->setApp($app);
+ $this->command = $command;
+ }
+
+
+ /**
+ * @return string
+ *
+ * @since 18.0.0
+ */
+ public function getCommand(): string {
+ return $this->command;
+ }
+
+ /**
+ * @param string $command
+ *
+ * @return IPushEvent
+ *
+ * @since 18.0.0
+ */
+ public function setCommand(string $command): IPushEvent {
+ $this->command = $command;
+
+ return $this;
+ }
+
+
+ /**
+ * @return array
+ *
+ * @since 18.0.0
+ */
+ public function getPayload(): array {
+ if ($this->payload instanceof JsonSerializable) {
+ return $this->payload->jsonSerialize();
+ }
+
+ return $this->payload;
+ }
+
+ /**
+ * @param array $payload
+ *
+ * @return IPushEvent
+ *
+ * @since 18.0.0
+ */
+ public function setPayload(array $payload): IPushEvent {
+ $this->payload = $payload;
+
+ return $this;
+ }
+
+ /**
+ * @param JsonSerializable $payload
+ *
+ * @return IPushEvent
+ *
+ * @since 18.0.0
+ */
+ public function setPayloadSerializable(JsonSerializable $payload): IPushEvent {
+ $this->payload = $payload->jsonSerialize();
+
+ return $this;
+ }
+
+
+ /**
+ * @return array
+ */
+ public function jsonSerialize(): array {
+ return array_merge(
+ parent::jsonSerialize(),
+ [
+ 'app' => $this->getApp(),
+ 'command' => $this->getCommand(),
+ 'payload' => $this->getPayload()
+ ]
+ );
+ }
+
+}
+