Merge pull request #8 from codeccoop/feat/rocketchat

Feat/rocketchat

Author: orzocogorzo

forms-bridge/addons/rocketchat/assets/logo.png

@@ -0,0 +1,84 @@
+<?php
+/**
+ * Class Rocketchat_Addon
+ *
+ * @package formsbridge
+ */
+
+namespace FORMS_BRIDGE;
+
+if ( ! defined( 'ABSPATH' ) ) {
+	exit();
+}
+
+require_once 'class-rocketchat-form-bridge.php';
+require_once 'hooks.php';
+
+/**
+ * RocketChat addon class
+ */
+class Rocketchat_Addon extends Addon {
+	/**
+	 * Holds the addon's title.
+	 *
+	 * @var string
+	 */
+	public const TITLE = 'Rocket.Chat';
+
+	/**
+	 * Holds the addon's name.
+	 *
+	 * @var string
+	 */
+	public const NAME = 'rocketchat';
+
+	/**
+	 * Holds the addon's custom bridge class.
+	 *
+	 * @var string
+	 */
+	public const BRIDGE = '\FORMS_BRIDGE\Rocketchat_Form_Bridge';
+
+	/**
+	 * Performs a request against the backend to check the connexion status.
+	 *
+	 * @param string $backend Backend name.
+	 *
+	 * @return boolean
+	 */
+	public function ping( $backend ) {
+		$bridge = new Rocketchat_Form_Bridge(
+			array(
+				'name'     => '__rocketchat-' . time(),
+				'endpoint' => '/api/v1/users.list',
+				'method'   => 'GET',
+				'backend'  => $backend,
+			)
+		);
+
+		$response = $bridge->submit( array( 'status' => 'active' ) );
+
+		if ( is_wp_error( $response ) ) {
+			Logger::log( 'Rocket.Chat backend ping error response', Logger::ERROR );
+			Logger::log( $response, Logger::ERROR );
+			return false;
+		}
+
+		return true;
+	}
+
+	/**
+	 * Performs an introspection of the backend endpoint and returns API fields.
+	 *
+	 * @param string      $endpoint API endpoint.
+	 * @param string      $backend Backend name.
+	 * @param string|null $method HTTP method.
+	 *
+	 * @return array List of fields and content type of the endpoint.
+	 */
+	public function get_endpoint_schema( $endpoint, $backend, $method = null ) {
+		return array();
+	}
+}
+
+Rocketchat_Addon::setup();

forms-bridge/addons/rocketchat/class-rocketchat-addon.php

@@ -0,0 +1,78 @@
+<?php
+/**
+ * Class Rocketchat_Form_Bridge
+ *
+ * @package formsbridge
+ */
+
+namespace FORMS_BRIDGE;
+
+use FBAPI;
+use WP_Error;
+
+if ( ! defined( 'ABSPATH' ) ) {
+	exit();
+}
+
+/**
+ * Form bridge implementation for the Rocket.Chat API
+ */
+class Rocketchat_Form_Bridge extends Form_Bridge {
+	/**
+	 * Submits payload and attachments to the bridge's backend.
+	 *
+	 * @param array $payload Payload data.
+	 * @param array $attachments Submission's attached files.
+	 *
+	 * @return array|WP_Error Http request response.
+	 */
+	public function submit( $payload = array(), $attachments = array() ) {
+		$uploads = FBAPI::get_uploads();
+		$room_id = $payload['roomId'] ?? $payload['channel'] ?? null;
+
+		if ( ! empty( $uploads ) && $room_id ) {
+			$attachments = Forms_Bridge::attachments( $uploads );
+			$backend     = $this->backend();
+
+			$message_attachments = array();
+			foreach ( $attachments as $name => $path ) {
+				$info     = pathinfo( $path );
+				$filename = $info['basename'];
+
+				$response = $backend->post(
+					'/api/v1/rooms.media/' . $room_id,
+					array(
+						'msg' => $name,
+					),
+					array(
+						'Content-Type' => 'multipart/form-data',
+					),
+					array(
+						'file' => $path,
+					)
+				);
+
+				if ( is_wp_error( $response ) ) {
+					return $response;
+				}
+
+				if ( ! $response['data']['success'] ) {
+					return new WP_Error( 'rocketchat_upload', __( 'Can not upload a file to Rocket.Chat', 'forms-bridge' ), $response['data'] );
+				}
+
+				unset( $payload[ $name ] );
+				unset( $payload[ $name . '_filename' ] );
+
+				$message_attachments[] = array(
+					'title'               => $filename,
+					'title_link'          => $response['data']['file']['url'],
+					'title_link_download' => true,
+				);
+			}
+
+			$payload['attachments'] = $message_attachments;
+		}
+
+		return parent::submit( $payload, array() );
+	}
+}