[WIP] split config schema

inc/Config/DataSource/DataSourceConnection.php

@@ -0,0 +1,108 @@
+<?php declare(strict_types = 1);
+
+namespace RemoteDataBlocks\Config\DataSource;
+
+use RemoteDataBlocks\Config\ArraySerializable;
+use RemoteDataBlocks\Validation\ConfigSchemas;
+use RemoteDataBlocks\Validation\Validator;
+use WP_Error;
+
+/**
+ * Base class for data source connection configurations.
+ * 
+ * This class represents the authentication and connection information
+ * for a data source, separate from the query-specific parameters.
+ */
+abstract class DataSourceConnection extends ArraySerializable implements DataSourceConnectionInterface {
+	/**
+	 * @inheritDoc
+	 */
+	public static function preprocess_config( array $config ): array|WP_Error {
+		$service_config = $config['service_config'] ?? [];
+		$validator = new Validator( static::get_service_config_schema() );
+		$validated = $validator->validate( $service_config );
+
+		if ( is_wp_error( $validated ) ) {
+			return $validated;
+		}
+
+		return [
+			'service' => static::get_service_name(),
+			'uuid' => $config['uuid'] ?? null,
+			'service_config' => $service_config,
+			'queries' => $config['queries'] ?? [],
+		];
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public static function migrate_config( array $config ): array|WP_Error {
+		return $config;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function to_array(): array {
+		return array_merge(
+			$this->config,
+			[
+				self::CLASS_REF_ATTRIBUTE => static::class,
+				'service' => static::get_service_name(),
+			]
+		);
+	}
+
+	public function get_service_config(): array {
+		return $this->config['service_config'];
+	}
+
+	/**
+	 * Get the schema for validating the data source configuration.
+	 *
+	 * @return array The schema for validating the data source configuration.
+	 */
+	public static function get_config_schema(): array {
+		return ConfigSchemas::get_data_source_connection_config_schema();
+	}
+
+	/**
+	 * Get the schema for validating the service-specific configuration.
+	 *
+	 * @return array The schema for validating the service-specific configuration.
+	 */
+	abstract public static function get_service_config_schema(): array;
+
+	/**
+	 * Get the UUID of the connection.
+	 *
+	 * @return string The UUID.
+	 */
+	public function get_uuid(): string {
+		return $this->config['uuid'];
+	}
+
+	/**
+	 * Get the display name of the data source.
+	 *
+	 * @return string The display name.
+	 */
+	public function get_display_name(): string {
+		return $this->config['service_config']['display_name'];
+	}
+
+	/**
+	 * Get the service name.
+	 *
+	 * @return string The service name.
+	 */
+	abstract public static function get_service_name(): string;
+
+	/**
+	 * Get the queries for the data source.
+	 *
+	 * @return array The queries.
+	 */
+	abstract public function get_queries(): array;
+}

inc/Config/DataSource/DataSourceConnectionInterface.php

@@ -0,0 +1,18 @@
+<?php declare(strict_types = 1);
+
+namespace RemoteDataBlocks\Config\DataSource;
+
+use RemoteDataBlocks\Config\ArraySerializableInterface;
+
+/**
+ * Interface for data source connection configurations.
+ * 
+ * This interface represents the authentication and connection information
+ * for a data source, separate from the query-specific parameters.
+ */
+interface DataSourceConnectionInterface extends ArraySerializableInterface {
+	public function get_uuid(): string;
+	public function get_display_name(): string;
+	public static function get_service_name(): string;
+	public function get_service_config(): array;
+}

inc/Config/DataSource/DataSourceQuery.php

@@ -0,0 +1,106 @@
+<?php declare(strict_types = 1);
+
+namespace RemoteDataBlocks\Config\DataSource;
+
+use RemoteDataBlocks\Config\ArraySerializable;
+use RemoteDataBlocks\Validation\ConfigSchemas;
+use RemoteDataBlocks\Validation\Validator;
+use WP_Error;
+
+/**
+ * Base class for data source query configurations.
+ * 
+ * This class represents the query-specific parameters for a data source,
+ * separate from the connection/authentication information.
+ */
+abstract class DataSourceQuery extends ArraySerializable implements DataSourceQueryInterface {
+	/**
+	 * @inheritDoc
+	 */
+	public static function preprocess_config( array $config ): array|WP_Error {
+		$service_config = $config['service_config'] ?? [];
+		$validator = new Validator( static::get_service_config_schema() );
+		$validated = $validator->validate( $service_config );
+
+		if ( is_wp_error( $validated ) ) {
+			return $validated;
+		}
+
+		return [
+			'service' => static::get_service_name(),
+			'uuid' => $config['uuid'] ?? null,
+			'connection_uuid' => $config['connection_uuid'] ?? null,
+			'service_config' => $service_config,
+		];
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public static function migrate_config( array $config ): array|WP_Error {
+		return $config;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function to_array(): array {
+		return array_merge(
+			$this->config,
+			[
+				self::CLASS_REF_ATTRIBUTE => static::class,
+				'service' => static::get_service_name(),
+			]
+		);
+	}
+
+	/**
+	 * Get the schema for validating the query configuration.
+	 *
+	 * @return array The schema for validating the query configuration.
+	 */
+	public static function get_config_schema(): array {
+		return ConfigSchemas::get_data_source_query_config_schema();
+	}
+
+	/**
+	 * Get the schema for validating the service-specific configuration.
+	 *
+	 * @return array The schema for validating the service-specific configuration.
+	 */
+	abstract public static function get_service_config_schema(): array;
+
+	/**
+	 * Get the UUID of the query.
+	 *
+	 * @return string The UUID.
+	 */
+	public function get_uuid(): string {
+		return $this->config['uuid'];
+	}
+
+	/**
+	 * Get the UUID of the associated data source connection.
+	 *
+	 * @return string|null The connection UUID.
+	 */
+	public function get_connection_uuid(): string|null {
+		return $this->config['connection_uuid'];
+	}
+
+	/**
+	 * Get the display name of the query.
+	 *
+	 * @return string The display name.
+	 */
+	public function get_display_name(): string {
+		return $this->config['service_config']['display_name'];
+	}
+
+	/**
+	 * Get the service name.
+	 *
+	 * @return string The service name.
+	 */
+	abstract public static function get_service_name(): string;
+} 

inc/Config/DataSource/DataSourceQueryInterface.php

@@ -0,0 +1,19 @@
+<?php declare(strict_types = 1);
+
+namespace RemoteDataBlocks\Config\DataSource;
+
+use RemoteDataBlocks\Config\ArraySerializableInterface;
+
+/**
+ * Interface for data source query configurations.
+ * 
+ * This interface represents the query-specific parameters for a data source,
+ * separate from the connection/authentication information.
+ */
+interface DataSourceQueryInterface extends ArraySerializableInterface {
+	public function get_uuid(): string;
+	public function get_connection_uuid(): string|null;
+	public function get_display_name(): string;
+	public static function get_service_name(): string;
+	public function get_service_config(): array;
+}

inc/Integrations/constants.php

@@ -28,3 +28,6 @@
 	REMOTE_DATA_BLOCKS_SHOPIFY_SERVICE => \RemoteDataBlocks\Integrations\Shopify\ShopifyDataSource::class,
 	REMOTE_DATA_BLOCKS_MOCK_SERVICE => \RemoteDataBlocks\Tests\Mocks\MockDataSource::class,
 ];
+
+const REMOTE_DATA_BLOCKS__DATA_SOURCE_CONNECTION_CONFIG_CLASSMAP = [];
+const REMOTE_DATA_BLOCKS__DATA_SOURCE_QUERY_CONFIG_CLASSMAP = [];

inc/Validation/ConfigSchemas.php

@@ -73,6 +73,26 @@ public static function get_remote_data_block_attribute_config_schema(): array {
 		return $schema;
 	}
 
+	public static function get_data_source_connection_config_schema(): array {
+		static $schema = null;
+
+		if ( null === $schema ) {
+			$schema = self::generate_data_source_connection_config_schema();
+		}
+
+		return $schema;
+	}
+
+	public static function get_data_source_query_config_schema(): array {
+		static $schema = null;
+
+		if ( null === $schema ) {
+			$schema = self::generate_data_source_query_config_schema();
+		}
+
+		return $schema;
+	}
+
 	private static function generate_remote_data_block_config_schema(): array {
 		return Types::object( [
 			'icon' => Types::nullable( Types::string() ),
@@ -401,4 +421,25 @@ private static function generate_remote_data_block_attribute_config_schema(): ar
 			),
 		] );
 	}
+
+	private static function generate_data_source_connection_config_schema(): array {
+		return Types::object( [
+			'uuid' => Types::nullable( Types::uuid() ),
+			'service' => Types::string(),
+			'service_config' => Types::record( Types::string(), Types::any() ),
+			'queries' => Types::list_of( Types::record( Types::string(), Types::any() ) ),
+			'__metadata' => Types::nullable( Types::record( Types::string(), Types::any() ) ),
+		] );
+	}
+
+	private static function generate_data_source_query_config_schema(): array {
+		return Types::object( [
+			'uuid' => Types::nullable( Types::uuid() ),
+			'service' => Types::string(),
+			'service_config' => Types::record( Types::string(), Types::any() ),
+			'connection_uuid' => Types::nullable( Types::uuid() ),
+			'connection' => Types::nullable( Types::record( Types::string(), Types::any() ) ),
+			'__metadata' => Types::nullable( Types::record( Types::string(), Types::any() ) ),
+		] );
+	}
 }

inc/WpdbStorage/DataSourceConnectionCrud.php

@@ -0,0 +1,28 @@
+<?php declare(strict_types = 1);
+
+namespace RemoteDataBlocks\WpdbStorage;
+
+/**
+ * CRUD operations for data source connections stored in WordPress options.
+ */
+class DataSourceConnectionCrud extends WpOptionsConfigStore {
+	protected static function get_error_code_prefix(): string {
+		return 'data_source_connection';
+	}
+
+	protected static function get_error_message_prefix(): string {
+		return 'data source connection';
+	}
+
+	protected static function get_option_name(): string {
+		return 'remote_data_blocks_data_source_connections';
+	}
+
+	protected static function get_config_class_map(): array {
+		if ( defined( 'REMOTE_DATA_BLOCKS__DATA_SOURCE_CONNECTION_CLASSMAP' ) ) {
+			return constant( 'REMOTE_DATA_BLOCKS__DATA_SOURCE_CONNECTION_CLASSMAP' );
+		}
+
+		return [];
+	}
+}

inc/WpdbStorage/DataSourceQueryCrud.php

@@ -0,0 +1,28 @@
+<?php declare(strict_types = 1);
+
+namespace RemoteDataBlocks\WpdbStorage;
+
+/**
+ * CRUD operations for data source queries stored in WordPress options.
+ */
+class DataSourceQueryCrud extends WpOptionsConfigStore {
+	protected static function get_error_code_prefix(): string {
+		return 'data_source_query';
+	}
+
+	protected static function get_error_message_prefix(): string {
+		return 'data source query';
+	}
+
+	protected static function get_option_name(): string {
+		return 'remote_data_blocks_data_source_queries';
+	}
+
+	protected static function get_config_class_map(): array {
+		if ( defined( 'REMOTE_DATA_BLOCKS__DATA_SOURCE_QUERY_CLASSMAP' ) ) {
+			return constant( 'REMOTE_DATA_BLOCKS__DATA_SOURCE_QUERY_CLASSMAP' );
+		}
+
+		return [];
+	}
+}