eventespresso / event-espresso-core

core/domain/services/graphql/types/Attendee.php

Indentation +177 added lines, -177 removed lines

@@ -23,187 +23,187 @@
 class Attendee extends TypeBase
 {
 
-    /**
-     * Attendee constructor.
-     *
-     * @param EEM_Attendee $attendee_model
-     */
-    public function __construct(EEM_Attendee $attendee_model)
-    {
-        $this->setName($this->namespace . 'Attendee');
-        $this->setIsCustomPostType(false); // Set to false to use our model queries
-        parent::__construct($attendee_model);
-    }
+	/**
+	 * Attendee constructor.
+	 *
+	 * @param EEM_Attendee $attendee_model
+	 */
+	public function __construct(EEM_Attendee $attendee_model)
+	{
+		$this->setName($this->namespace . 'Attendee');
+		$this->setIsCustomPostType(false); // Set to false to use our model queries
+		parent::__construct($attendee_model);
+	}
 
 
-    /**
-     * @return GraphQLFieldInterface[]
-     */
-    public function getFields(): array
-    {
-        $fields = [
-            new GraphQLField(
-                'id',
-                ['non_null' => 'ID'],
-                null,
-                esc_html__('The globally unique ID for the object.', 'event_espresso')
-            ),
-            new GraphQLOutputField(
-                'dbId',
-                ['non_null' => 'Int'],
-                'ID',
-                esc_html__('The attendee ID.', 'event_espresso')
-            ),
-            new GraphQLOutputField(
-                'cacheId',
-                ['non_null' => 'String'],
-                null,
-                esc_html__('The cache ID of the object.', 'event_espresso')
-            ),
-            new GraphQLOutputField(
-                'address',
-                'String',
-                'address',
-                esc_html__('Address Part 1', 'event_espresso'),
-                null,
-                null,
-                ['ee_edit_contacts']
-            ),
-            new GraphQLOutputField(
-                'address2',
-                'String',
-                'address2',
-                esc_html__('Address Part 2', 'event_espresso'),
-                null,
-                null,
-                ['ee_edit_contacts']
-            ),
-            new GraphQLOutputField(
-                'avatar',
-                'String',
-                null,
-                esc_html__('User avatar URL', 'event_espresso'),
-                null,
-                [$this, 'getAvatar'],
-                ['ee_edit_contacts']
-            ),
-            new GraphQLOutputField(
-                'bio',
-                'String',
-                'bio',
-                esc_html__('Attendee Biography', 'event_espresso'),
-                null,
-                null,
-                ['ee_edit_contacts']
-            ),
-            new GraphQLOutputField(
-                'city',
-                'String',
-                'city',
-                esc_html__('City', 'event_espresso'),
-                null,
-                null,
-                ['ee_edit_contacts']
-            ),
-            new GraphQLOutputField(
-                'country',
-                $this->namespace . 'Country',
-                null,
-                esc_html__('Country', 'event_espresso'),
-                null,
-                null,
-                ['ee_edit_contacts']
-            ),
-            new GraphQLOutputField(
-                'email',
-                'String',
-                'email',
-                esc_html__('Email Address', 'event_espresso'),
-                null,
-                null,
-                ['ee_edit_contacts']
-            ),
-            new GraphQLOutputField(
-                'firstName',
-                'String',
-                'fname',
-                esc_html__('Attendee First Name', 'event_espresso')
-            ),
-            new GraphQLOutputField(
-                'fullName',
-                'String',
-                'full_name',
-                esc_html__('Attendee Name', 'event_espresso')
-            ),
-            new GraphQLOutputField(
-                'lastName',
-                'String',
-                'lname',
-                esc_html__('Attendee Last Name', 'event_espresso')
-            ),
-            new GraphQLOutputField(
-                'phone',
-                'String',
-                'phone',
-                esc_html__('Phone', 'event_espresso'),
-                null,
-                null,
-                ['ee_edit_contacts']
-            ),
-            new GraphQLOutputField(
-                'shortBio',
-                'String',
-                'short_bio',
-                esc_html__('Attendee Short Biography', 'event_espresso'),
-                null,
-                null,
-                ['ee_edit_contacts']
-            ),
-            new GraphQLOutputField(
-                'state',
-                $this->namespace . 'State',
-                null,
-                esc_html__('State', 'event_espresso'),
-                null,
-                null,
-                ['ee_edit_contacts']
-            ),
-            new GraphQLOutputField(
-                'zip',
-                'String',
-                'zip',
-                esc_html__('ZIP/Postal Code', 'event_espresso'),
-                null,
-                null,
-                ['ee_edit_contacts']
-            ),
-        ];
+	/**
+	 * @return GraphQLFieldInterface[]
+	 */
+	public function getFields(): array
+	{
+		$fields = [
+			new GraphQLField(
+				'id',
+				['non_null' => 'ID'],
+				null,
+				esc_html__('The globally unique ID for the object.', 'event_espresso')
+			),
+			new GraphQLOutputField(
+				'dbId',
+				['non_null' => 'Int'],
+				'ID',
+				esc_html__('The attendee ID.', 'event_espresso')
+			),
+			new GraphQLOutputField(
+				'cacheId',
+				['non_null' => 'String'],
+				null,
+				esc_html__('The cache ID of the object.', 'event_espresso')
+			),
+			new GraphQLOutputField(
+				'address',
+				'String',
+				'address',
+				esc_html__('Address Part 1', 'event_espresso'),
+				null,
+				null,
+				['ee_edit_contacts']
+			),
+			new GraphQLOutputField(
+				'address2',
+				'String',
+				'address2',
+				esc_html__('Address Part 2', 'event_espresso'),
+				null,
+				null,
+				['ee_edit_contacts']
+			),
+			new GraphQLOutputField(
+				'avatar',
+				'String',
+				null,
+				esc_html__('User avatar URL', 'event_espresso'),
+				null,
+				[$this, 'getAvatar'],
+				['ee_edit_contacts']
+			),
+			new GraphQLOutputField(
+				'bio',
+				'String',
+				'bio',
+				esc_html__('Attendee Biography', 'event_espresso'),
+				null,
+				null,
+				['ee_edit_contacts']
+			),
+			new GraphQLOutputField(
+				'city',
+				'String',
+				'city',
+				esc_html__('City', 'event_espresso'),
+				null,
+				null,
+				['ee_edit_contacts']
+			),
+			new GraphQLOutputField(
+				'country',
+				$this->namespace . 'Country',
+				null,
+				esc_html__('Country', 'event_espresso'),
+				null,
+				null,
+				['ee_edit_contacts']
+			),
+			new GraphQLOutputField(
+				'email',
+				'String',
+				'email',
+				esc_html__('Email Address', 'event_espresso'),
+				null,
+				null,
+				['ee_edit_contacts']
+			),
+			new GraphQLOutputField(
+				'firstName',
+				'String',
+				'fname',
+				esc_html__('Attendee First Name', 'event_espresso')
+			),
+			new GraphQLOutputField(
+				'fullName',
+				'String',
+				'full_name',
+				esc_html__('Attendee Name', 'event_espresso')
+			),
+			new GraphQLOutputField(
+				'lastName',
+				'String',
+				'lname',
+				esc_html__('Attendee Last Name', 'event_espresso')
+			),
+			new GraphQLOutputField(
+				'phone',
+				'String',
+				'phone',
+				esc_html__('Phone', 'event_espresso'),
+				null,
+				null,
+				['ee_edit_contacts']
+			),
+			new GraphQLOutputField(
+				'shortBio',
+				'String',
+				'short_bio',
+				esc_html__('Attendee Short Biography', 'event_espresso'),
+				null,
+				null,
+				['ee_edit_contacts']
+			),
+			new GraphQLOutputField(
+				'state',
+				$this->namespace . 'State',
+				null,
+				esc_html__('State', 'event_espresso'),
+				null,
+				null,
+				['ee_edit_contacts']
+			),
+			new GraphQLOutputField(
+				'zip',
+				'String',
+				'zip',
+				esc_html__('ZIP/Postal Code', 'event_espresso'),
+				null,
+				null,
+				['ee_edit_contacts']
+			),
+		];
 
-        return apply_filters(
-            'FHEE__EventEspresso_core_domain_services_graphql_types__attendee_fields',
-            $fields,
-            $this->name,
-            $this->model
-        );
-    }
+		return apply_filters(
+			'FHEE__EventEspresso_core_domain_services_graphql_types__attendee_fields',
+			$fields,
+			$this->name,
+			$this->model
+		);
+	}
 
 
-    /**
-     * @param EE_Attendee $source  The source that's passed down the GraphQL queries
-     * @param array       $args    The inputArgs on the field
-     * @param AppContext  $context The AppContext passed down the GraphQL tree
-     * @param ResolveInfo $info    The ResolveInfo passed down the GraphQL tree
-     * @return string|null
-     * @throws EE_Error
-     */
-    public function getAvatar(EE_Attendee $source, array $args, AppContext $context, ResolveInfo $info): ?string
-    {
-        $email = $source->email();
+	/**
+	 * @param EE_Attendee $source  The source that's passed down the GraphQL queries
+	 * @param array       $args    The inputArgs on the field
+	 * @param AppContext  $context The AppContext passed down the GraphQL tree
+	 * @param ResolveInfo $info    The ResolveInfo passed down the GraphQL tree
+	 * @return string|null
+	 * @throws EE_Error
+	 */
+	public function getAvatar(EE_Attendee $source, array $args, AppContext $context, ResolveInfo $info): ?string
+	{
+		$email = $source->email();
 
-        if (empty($email)) {
-            return get_avatar_url('', ['force_default' => true]);
-        }
-        $avatar = get_avatar_url($email);
-        return $avatar ?: null;
-    }
+		if (empty($email)) {
+			return get_avatar_url('', ['force_default' => true]);
+		}
+		$avatar = get_avatar_url($email);
+		return $avatar ?: null;
+	}
 }

Spacing +3 added lines, -3 removed lines

@@ -30,7 +30,7 @@ 
      */
     public function __construct(EEM_Attendee $attendee_model)
     {
-        $this->setName($this->namespace . 'Attendee');
+        $this->setName($this->namespace.'Attendee');
         $this->setIsCustomPostType(false); // Set to false to use our model queries
         parent::__construct($attendee_model);
     }
@@ -107,7 +107,7 @@ 
             ),
             new GraphQLOutputField(
                 'country',
-                $this->namespace . 'Country',
+                $this->namespace.'Country',
                 null,
                 esc_html__('Country', 'event_espresso'),
                 null,
@@ -161,7 +161,7 @@ 
             ),
             new GraphQLOutputField(
                 'state',
-                $this->namespace . 'State',
+                $this->namespace.'State',
                 null,
                 esc_html__('State', 'event_espresso'),
                 null,

core/domain/services/graphql/connection_resolvers/FormSectionConnectionResolver.php

Indentation +123 added lines, -123 removed lines

@@ -14,127 +14,127 @@
  */
 class FormSectionConnectionResolver extends AbstractConnectionResolver
 {
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_loader_name(): string
-    {
-        return 'espresso_formSection';
-    }
-
-    /**
-     * @return EEM_Form_Section
-     * @throws EE_Error
-     * @throws InvalidArgumentException
-     * @throws InvalidDataTypeException
-     * @throws InvalidInterfaceException
-     * @throws ReflectionException
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_query(): EEM_Form_Section
-    {
-        return EEM_Form_Section::instance();
-    }
-
-
-    /**
-     * Return an array of item IDs from the query
-     *
-     * @return array
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_ids(): array
-    {
-        $results = $this->query->get_col($this->query_args);
-        return ! empty($results) ? $results : [];
-    }
-
-
-    /**
-     * Here, we map the args from the input, then we make sure that we're only querying
-     * for IDs. The IDs are then passed down the resolve tree, and deferred resolvers
-     * handle batch resolution of the posts.
-     *
-     * @return array
-     * @throws InvalidArgumentException
-     * @throws InvalidDataTypeException
-     * @throws InvalidInterfaceException
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_query_args(): array
-    {
-        $where_params = [];
-        $query_args   = [];
-
-        $query_args['limit'] = $this->getLimit();
-
-        // Avoid multiple entries by join.
-        $query_args['group_by'] = 'FSC_UUID';
-
-        /**
-         * Collect the input fields and sanitize them to prepare them for sending to the Query
-         */
-        $input_fields = [];
-        if (! empty($this->args['where'])) {
-            $input_fields = $this->sanitizeInputFields($this->args['where']);
-
-            // Use the proper operator.
-            if (! empty($input_fields['FSC_appliesTo']) && is_array($input_fields['FSC_appliesTo'])) {
-                $input_fields['FSC_appliesTo'] = ['IN', $input_fields['FSC_appliesTo']];
-            }
-            if (! empty($input_fields['FSC_belongsTo']) && is_array($input_fields['FSC_belongsTo'])) {
-                $input_fields['FSC_belongsTo'] = ['IN', $input_fields['FSC_belongsTo']];
-            }
-            if (! empty($input_fields['FSC_status']) && is_array($input_fields['FSC_status'])) {
-                $input_fields['FSC_status'] = ['IN', $input_fields['FSC_status']];
-            }
-        }
-
-        /**
-         * Merge the input_fields with the default query_args
-         */
-        if (! empty($input_fields)) {
-            $where_params = array_merge($where_params, $input_fields);
-        }
-
-        $where_params = apply_filters(
-            'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__form_section_where_params',
-            $where_params,
-            $this->source,
-            $this->args
-        );
-
-        if (! empty($where_params)) {
-            $query_args[] = $where_params;
-        }
-
-
-        /**
-         * Return the $query_args
-         */
-        return apply_filters(
-            'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__form_section_query_args',
-            $query_args,
-            $this->source,
-            $this->args
-        );
-    }
-
-
-    /**
-     * This sets up the "allowed" args, and translates the GraphQL-friendly keys to model
-     * friendly keys.
-     *
-     * @param array $where_args
-     * @return array
-     */
-    public function sanitizeInputFields(array $where_args): array
-    {
-        return $this->sanitizeWhereArgsForInputFields(
-            $where_args,
-            [
-                'appliesTo' => 'FSC_appliesTo',
-                'belongsTo' => 'FSC_belongsTo',
-                'status'    => 'FSC_status',
-            ]
-        );
-    }
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_loader_name(): string
+	{
+		return 'espresso_formSection';
+	}
+
+	/**
+	 * @return EEM_Form_Section
+	 * @throws EE_Error
+	 * @throws InvalidArgumentException
+	 * @throws InvalidDataTypeException
+	 * @throws InvalidInterfaceException
+	 * @throws ReflectionException
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_query(): EEM_Form_Section
+	{
+		return EEM_Form_Section::instance();
+	}
+
+
+	/**
+	 * Return an array of item IDs from the query
+	 *
+	 * @return array
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_ids(): array
+	{
+		$results = $this->query->get_col($this->query_args);
+		return ! empty($results) ? $results : [];
+	}
+
+
+	/**
+	 * Here, we map the args from the input, then we make sure that we're only querying
+	 * for IDs. The IDs are then passed down the resolve tree, and deferred resolvers
+	 * handle batch resolution of the posts.
+	 *
+	 * @return array
+	 * @throws InvalidArgumentException
+	 * @throws InvalidDataTypeException
+	 * @throws InvalidInterfaceException
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_query_args(): array
+	{
+		$where_params = [];
+		$query_args   = [];
+
+		$query_args['limit'] = $this->getLimit();
+
+		// Avoid multiple entries by join.
+		$query_args['group_by'] = 'FSC_UUID';
+
+		/**
+		 * Collect the input fields and sanitize them to prepare them for sending to the Query
+		 */
+		$input_fields = [];
+		if (! empty($this->args['where'])) {
+			$input_fields = $this->sanitizeInputFields($this->args['where']);
+
+			// Use the proper operator.
+			if (! empty($input_fields['FSC_appliesTo']) && is_array($input_fields['FSC_appliesTo'])) {
+				$input_fields['FSC_appliesTo'] = ['IN', $input_fields['FSC_appliesTo']];
+			}
+			if (! empty($input_fields['FSC_belongsTo']) && is_array($input_fields['FSC_belongsTo'])) {
+				$input_fields['FSC_belongsTo'] = ['IN', $input_fields['FSC_belongsTo']];
+			}
+			if (! empty($input_fields['FSC_status']) && is_array($input_fields['FSC_status'])) {
+				$input_fields['FSC_status'] = ['IN', $input_fields['FSC_status']];
+			}
+		}
+
+		/**
+		 * Merge the input_fields with the default query_args
+		 */
+		if (! empty($input_fields)) {
+			$where_params = array_merge($where_params, $input_fields);
+		}
+
+		$where_params = apply_filters(
+			'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__form_section_where_params',
+			$where_params,
+			$this->source,
+			$this->args
+		);
+
+		if (! empty($where_params)) {
+			$query_args[] = $where_params;
+		}
+
+
+		/**
+		 * Return the $query_args
+		 */
+		return apply_filters(
+			'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__form_section_query_args',
+			$query_args,
+			$this->source,
+			$this->args
+		);
+	}
+
+
+	/**
+	 * This sets up the "allowed" args, and translates the GraphQL-friendly keys to model
+	 * friendly keys.
+	 *
+	 * @param array $where_args
+	 * @return array
+	 */
+	public function sanitizeInputFields(array $where_args): array
+	{
+		return $this->sanitizeWhereArgsForInputFields(
+			$where_args,
+			[
+				'appliesTo' => 'FSC_appliesTo',
+				'belongsTo' => 'FSC_belongsTo',
+				'status'    => 'FSC_status',
+			]
+		);
+	}
 }

Spacing +6 added lines, -6 removed lines

@@ -73,17 +73,17 @@ 
          * Collect the input fields and sanitize them to prepare them for sending to the Query
          */
         $input_fields = [];
-        if (! empty($this->args['where'])) {
+        if ( ! empty($this->args['where'])) {
             $input_fields = $this->sanitizeInputFields($this->args['where']);
 
             // Use the proper operator.
-            if (! empty($input_fields['FSC_appliesTo']) && is_array($input_fields['FSC_appliesTo'])) {
+            if ( ! empty($input_fields['FSC_appliesTo']) && is_array($input_fields['FSC_appliesTo'])) {
                 $input_fields['FSC_appliesTo'] = ['IN', $input_fields['FSC_appliesTo']];
             }
-            if (! empty($input_fields['FSC_belongsTo']) && is_array($input_fields['FSC_belongsTo'])) {
+            if ( ! empty($input_fields['FSC_belongsTo']) && is_array($input_fields['FSC_belongsTo'])) {
                 $input_fields['FSC_belongsTo'] = ['IN', $input_fields['FSC_belongsTo']];
             }
-            if (! empty($input_fields['FSC_status']) && is_array($input_fields['FSC_status'])) {
+            if ( ! empty($input_fields['FSC_status']) && is_array($input_fields['FSC_status'])) {
                 $input_fields['FSC_status'] = ['IN', $input_fields['FSC_status']];
             }
         }
@@ -91,7 +91,7 @@ 
         /**
          * Merge the input_fields with the default query_args
          */
-        if (! empty($input_fields)) {
+        if ( ! empty($input_fields)) {
             $where_params = array_merge($where_params, $input_fields);
         }
 
@@ -102,7 +102,7 @@ 
             $this->args
         );
 
-        if (! empty($where_params)) {
+        if ( ! empty($where_params)) {
             $query_args[] = $where_params;
         }
 

core/domain/services/graphql/connection_resolvers/FormElementConnectionResolver.php

Indentation +118 added lines, -118 removed lines

@@ -14,122 +14,122 @@
  */
 class FormElementConnectionResolver extends AbstractConnectionResolver
 {
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_loader_name(): string
-    {
-        return 'espresso_formElement';
-    }
-
-    /**
-     * @return EEM_Form_Input
-     * @throws EE_Error
-     * @throws InvalidArgumentException
-     * @throws InvalidDataTypeException
-     * @throws InvalidInterfaceException
-     * @throws ReflectionException
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_query(): EEM_Form_Input
-    {
-        return EEM_Form_Input::instance();
-    }
-
-
-    /**
-     * Return an array of item IDs from the query
-     *
-     * @return array
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_ids(): array
-    {
-        $results = $this->query->get_col($this->query_args);
-        return ! empty($results) ? $results : [];
-    }
-
-
-    /**
-     * Here, we map the args from the input, then we make sure that we're only querying
-     * for IDs. The IDs are then passed down the resolve tree, and deferred resolvers
-     * handle batch resolution of the posts.
-     *
-     * @return array
-     * @throws InvalidArgumentException
-     * @throws InvalidDataTypeException
-     * @throws InvalidInterfaceException
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_query_args(): array
-    {
-        $where_params = [];
-        $query_args   = [];
-
-        $query_args['limit'] = $this->getLimit();
-
-        // Avoid multiple entries by join.
-        $query_args['group_by'] = 'FIN_UUID';
-
-        /**
-        * Collect the input fields and sanitize them to prepare them for sending to the Query
-        */
-        $input_fields = [];
-        if (! empty($this->args['where'])) {
-            $input_fields = $this->sanitizeInputFields($this->args['where']);
-
-            // Use the proper operator.
-            if (! empty($input_fields['FIN_belongsTo']) && is_array($input_fields['FIN_belongsTo'])) {
-                $input_fields['FIN_belongsTo'] = ['IN', $input_fields['FIN_belongsTo']];
-            }
-            if (! empty($input_fields['FIN_status']) && is_array($input_fields['FIN_status'])) {
-                $input_fields['FIN_status'] = ['IN', $input_fields['FIN_status']];
-            }
-        }
-
-        /**
-         * Merge the input_fields with the default query_args
-         */
-        if (! empty($input_fields)) {
-            $where_params = array_merge($where_params, $input_fields);
-        }
-
-        $where_params = apply_filters(
-            'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__form_element_where_params',
-            $where_params,
-            $this->source,
-            $this->args
-        );
-
-        if (! empty($where_params)) {
-            $query_args[] = $where_params;
-        }
-
-
-        /**
-         * Return the $query_args
-         */
-        return apply_filters(
-            'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__form_element_query_args',
-            $query_args,
-            $this->source,
-            $this->args
-        );
-    }
-
-    /**
-     * This sets up the "allowed" args, and translates the GraphQL-friendly keys to model
-     * friendly keys.
-     *
-     * @param array $where_args
-     * @return array
-     */
-    public function sanitizeInputFields(array $where_args): array
-    {
-        return $this->sanitizeWhereArgsForInputFields(
-            $where_args,
-            [
-                'belongsTo' => 'FIN_belongsTo',
-                'status'    => 'FIN_status',
-            ]
-        );
-    }
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_loader_name(): string
+	{
+		return 'espresso_formElement';
+	}
+
+	/**
+	 * @return EEM_Form_Input
+	 * @throws EE_Error
+	 * @throws InvalidArgumentException
+	 * @throws InvalidDataTypeException
+	 * @throws InvalidInterfaceException
+	 * @throws ReflectionException
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_query(): EEM_Form_Input
+	{
+		return EEM_Form_Input::instance();
+	}
+
+
+	/**
+	 * Return an array of item IDs from the query
+	 *
+	 * @return array
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_ids(): array
+	{
+		$results = $this->query->get_col($this->query_args);
+		return ! empty($results) ? $results : [];
+	}
+
+
+	/**
+	 * Here, we map the args from the input, then we make sure that we're only querying
+	 * for IDs. The IDs are then passed down the resolve tree, and deferred resolvers
+	 * handle batch resolution of the posts.
+	 *
+	 * @return array
+	 * @throws InvalidArgumentException
+	 * @throws InvalidDataTypeException
+	 * @throws InvalidInterfaceException
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_query_args(): array
+	{
+		$where_params = [];
+		$query_args   = [];
+
+		$query_args['limit'] = $this->getLimit();
+
+		// Avoid multiple entries by join.
+		$query_args['group_by'] = 'FIN_UUID';
+
+		/**
+		 * Collect the input fields and sanitize them to prepare them for sending to the Query
+		 */
+		$input_fields = [];
+		if (! empty($this->args['where'])) {
+			$input_fields = $this->sanitizeInputFields($this->args['where']);
+
+			// Use the proper operator.
+			if (! empty($input_fields['FIN_belongsTo']) && is_array($input_fields['FIN_belongsTo'])) {
+				$input_fields['FIN_belongsTo'] = ['IN', $input_fields['FIN_belongsTo']];
+			}
+			if (! empty($input_fields['FIN_status']) && is_array($input_fields['FIN_status'])) {
+				$input_fields['FIN_status'] = ['IN', $input_fields['FIN_status']];
+			}
+		}
+
+		/**
+		 * Merge the input_fields with the default query_args
+		 */
+		if (! empty($input_fields)) {
+			$where_params = array_merge($where_params, $input_fields);
+		}
+
+		$where_params = apply_filters(
+			'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__form_element_where_params',
+			$where_params,
+			$this->source,
+			$this->args
+		);
+
+		if (! empty($where_params)) {
+			$query_args[] = $where_params;
+		}
+
+
+		/**
+		 * Return the $query_args
+		 */
+		return apply_filters(
+			'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__form_element_query_args',
+			$query_args,
+			$this->source,
+			$this->args
+		);
+	}
+
+	/**
+	 * This sets up the "allowed" args, and translates the GraphQL-friendly keys to model
+	 * friendly keys.
+	 *
+	 * @param array $where_args
+	 * @return array
+	 */
+	public function sanitizeInputFields(array $where_args): array
+	{
+		return $this->sanitizeWhereArgsForInputFields(
+			$where_args,
+			[
+				'belongsTo' => 'FIN_belongsTo',
+				'status'    => 'FIN_status',
+			]
+		);
+	}
 }

Spacing +5 added lines, -5 removed lines

@@ -73,14 +73,14 @@ 
         * Collect the input fields and sanitize them to prepare them for sending to the Query
         */
         $input_fields = [];
-        if (! empty($this->args['where'])) {
+        if ( ! empty($this->args['where'])) {
             $input_fields = $this->sanitizeInputFields($this->args['where']);
 
             // Use the proper operator.
-            if (! empty($input_fields['FIN_belongsTo']) && is_array($input_fields['FIN_belongsTo'])) {
+            if ( ! empty($input_fields['FIN_belongsTo']) && is_array($input_fields['FIN_belongsTo'])) {
                 $input_fields['FIN_belongsTo'] = ['IN', $input_fields['FIN_belongsTo']];
             }
-            if (! empty($input_fields['FIN_status']) && is_array($input_fields['FIN_status'])) {
+            if ( ! empty($input_fields['FIN_status']) && is_array($input_fields['FIN_status'])) {
                 $input_fields['FIN_status'] = ['IN', $input_fields['FIN_status']];
             }
         }
@@ -88,7 +88,7 @@ 
         /**
          * Merge the input_fields with the default query_args
          */
-        if (! empty($input_fields)) {
+        if ( ! empty($input_fields)) {
             $where_params = array_merge($where_params, $input_fields);
         }
 
@@ -99,7 +99,7 @@ 
             $this->args
         );
 
-        if (! empty($where_params)) {
+        if ( ! empty($where_params)) {
             $query_args[] = $where_params;
         }
 

core/domain/services/graphql/connection_resolvers/AttendeeConnectionResolver.php

Indentation +173 added lines, -173 removed lines

@@ -16,177 +16,177 @@
  */
 class AttendeeConnectionResolver extends AbstractConnectionResolver
 {
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_loader_name(): string
-    {
-        return 'espresso_attendee';
-    }
-
-    /**
-     * @return EEM_Attendee
-     * @throws EE_Error
-     * @throws InvalidArgumentException
-     * @throws InvalidDataTypeException
-     * @throws InvalidInterfaceException
-     * @throws ReflectionException
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_query(): EEM_Attendee
-    {
-        return EEM_Attendee::instance();
-    }
-
-
-    /**
-     * Return an array of item IDs from the query
-     *
-     * @return array
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_ids(): array
-    {
-        $results = $this->query->get_col($this->query_args);
-
-        return ! empty($results) ? $results : [];
-    }
-
-
-    /**
-     * Here, we map the args from the input, then we make sure that we're only querying
-     * for IDs. The IDs are then passed down the resolve tree, and deferred resolvers
-     * handle batch resolution of the posts.
-     *
-     * @return array
-     * @throws InvalidArgumentException
-     * @throws InvalidDataTypeException
-     * @throws InvalidInterfaceException
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_query_args(): array
-    {
-        $where_params = [];
-        $query_args   = [];
-
-        $query_args['limit'] = $this->getLimit();
-
-        // Avoid multiple entries by join.
-        $query_args['group_by'] = 'ATT_ID';
-
-        $query_args['default_where_conditions'] = 'minimum';
-
-        /**
-         * Collect the input_fields and sanitize them to prepare them for sending to the Query
-         */
-        $input_fields = [];
-        if (! empty($this->args['where'])) {
-            $input_fields = $this->sanitizeInputFields($this->args['where']);
-
-            // Since we do not have any falsy values in query params
-            // Lets get rid of empty values
-            $input_fields = array_filter($input_fields);
-
-            // Use the proper operator.
-            if (! empty($input_fields['Registration.Event.EVT_ID']) && is_array($input_fields['Registration.Event.EVT_ID'])) {
-                $input_fields['Registration.Event.EVT_ID'] = ['IN', $input_fields['Registration.Event.EVT_ID']];
-            }
-            if (! empty($input_fields['Registration.Ticket.TKT_ID']) && is_array($input_fields['Registration.Ticket.TKT_ID'])) {
-                $input_fields['Registration.Ticket.TKT_ID'] = ['IN', $input_fields['Registration.Ticket.TKT_ID']];
-            }
-            // If Ticket param is passed, it will have preference over Datetime param
-            // So, use Datetime param only if a Ticket param is not passed
-            if (! empty($input_fields['Datetime.DTT_ID']) && empty($input_fields['Registration.Ticket.TKT_ID'])) {
-                $datetimeIds = $input_fields['Datetime.DTT_ID'];
-                // Make sure it's an array, ready for "IN" operator
-                $datetimeIds = is_array($datetimeIds) ? $datetimeIds : [$datetimeIds];
-
-                try {
-                    // Get related ticket IDs for the given dates
-                    $ticketIds = EEM_Ticket::instance()->get_col([
-                        [
-                            'Datetime.DTT_ID' => ['IN', $datetimeIds],
-                            'TKT_deleted'     => ['IN', [true, false]],
-                        ],
-                        'default_where_conditions' => 'minimum',
-                    ]);
-                } catch (Throwable $th) {
-                    $ticketIds = [];
-                }
-
-                if (!empty($ticketIds)) {
-                    $input_fields['Registration.Ticket.TKT_ID'] = ['IN', $ticketIds];
-                }
-            }
-            // Since there is no relation between Attendee and Datetime, we need to remove it
-            unset($input_fields['Datetime.DTT_ID']);
-        }
-
-        /**
-         * Merge the input_fields with the default query_args
-         */
-        if (! empty($input_fields)) {
-            $where_params = array_merge($where_params, $input_fields);
-        }
-
-        [$query_args, $where_params] = $this->mapOrderbyInputArgs($query_args, $where_params, 'ATT_ID');
-
-        $search = $this->getSearchKeywords($this->args['where']);
-
-        if (! empty($search)) {
-            // use OR operator to search in any of the fields
-            $where_params['OR'] = array(
-                'ATT_full_name' => array('LIKE', '%' . $search . '%'),
-                'ATT_bio'       => array('LIKE', '%' . $search . '%'),
-                'ATT_short_bio' => array('LIKE', '%' . $search . '%'),
-            );
-        }
-
-        $where_params = apply_filters(
-            'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__attendee_where_params',
-            $where_params,
-            $this->source,
-            $this->args
-        );
-
-        $query_args[] = $where_params;
-
-        /**
-         * Return the $query_args
-         */
-        return apply_filters(
-            'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__attendee_query_args',
-            $query_args,
-            $this->source,
-            $this->args
-        );
-    }
-
-
-    /**
-     * This sets up the "allowed" args, and translates the GraphQL-friendly keys to model
-     * friendly keys.
-     *
-     * @param array $where_args
-     * @return array
-     */
-    public function sanitizeInputFields(array $where_args): array
-    {
-        $arg_mapping = [
-            // There is no direct relation between Attendee and Datetime
-            // But we will handle it via Tickets related to given dates
-            'datetime'      => 'Datetime.DTT_ID',
-            'datetimeIn'    => 'Datetime.DTT_ID',
-            'event'         => 'Registration.Event.EVT_ID',
-            'eventIn'       => 'Registration.Event.EVT_ID',
-            'regTicket'     => 'Registration.Ticket.TKT_ID',
-            'regTicketIn'   => 'Registration.Ticket.TKT_ID',
-            'regTicketIdIn' => 'Registration.Ticket.TKT_ID',
-            'regTicketId'   => 'Registration.Ticket.TKT_ID', // priority.
-            'regStatus'     => 'Registration.Status.STS_ID',
-        ];
-        return $this->sanitizeWhereArgsForInputFields(
-            $where_args,
-            $arg_mapping,
-            ['datetime', 'datetimeIn', 'event', 'eventIn', 'regTicket', 'regTicketIn']
-        );
-    }
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_loader_name(): string
+	{
+		return 'espresso_attendee';
+	}
+
+	/**
+	 * @return EEM_Attendee
+	 * @throws EE_Error
+	 * @throws InvalidArgumentException
+	 * @throws InvalidDataTypeException
+	 * @throws InvalidInterfaceException
+	 * @throws ReflectionException
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_query(): EEM_Attendee
+	{
+		return EEM_Attendee::instance();
+	}
+
+
+	/**
+	 * Return an array of item IDs from the query
+	 *
+	 * @return array
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_ids(): array
+	{
+		$results = $this->query->get_col($this->query_args);
+
+		return ! empty($results) ? $results : [];
+	}
+
+
+	/**
+	 * Here, we map the args from the input, then we make sure that we're only querying
+	 * for IDs. The IDs are then passed down the resolve tree, and deferred resolvers
+	 * handle batch resolution of the posts.
+	 *
+	 * @return array
+	 * @throws InvalidArgumentException
+	 * @throws InvalidDataTypeException
+	 * @throws InvalidInterfaceException
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_query_args(): array
+	{
+		$where_params = [];
+		$query_args   = [];
+
+		$query_args['limit'] = $this->getLimit();
+
+		// Avoid multiple entries by join.
+		$query_args['group_by'] = 'ATT_ID';
+
+		$query_args['default_where_conditions'] = 'minimum';
+
+		/**
+		 * Collect the input_fields and sanitize them to prepare them for sending to the Query
+		 */
+		$input_fields = [];
+		if (! empty($this->args['where'])) {
+			$input_fields = $this->sanitizeInputFields($this->args['where']);
+
+			// Since we do not have any falsy values in query params
+			// Lets get rid of empty values
+			$input_fields = array_filter($input_fields);
+
+			// Use the proper operator.
+			if (! empty($input_fields['Registration.Event.EVT_ID']) && is_array($input_fields['Registration.Event.EVT_ID'])) {
+				$input_fields['Registration.Event.EVT_ID'] = ['IN', $input_fields['Registration.Event.EVT_ID']];
+			}
+			if (! empty($input_fields['Registration.Ticket.TKT_ID']) && is_array($input_fields['Registration.Ticket.TKT_ID'])) {
+				$input_fields['Registration.Ticket.TKT_ID'] = ['IN', $input_fields['Registration.Ticket.TKT_ID']];
+			}
+			// If Ticket param is passed, it will have preference over Datetime param
+			// So, use Datetime param only if a Ticket param is not passed
+			if (! empty($input_fields['Datetime.DTT_ID']) && empty($input_fields['Registration.Ticket.TKT_ID'])) {
+				$datetimeIds = $input_fields['Datetime.DTT_ID'];
+				// Make sure it's an array, ready for "IN" operator
+				$datetimeIds = is_array($datetimeIds) ? $datetimeIds : [$datetimeIds];
+
+				try {
+					// Get related ticket IDs for the given dates
+					$ticketIds = EEM_Ticket::instance()->get_col([
+						[
+							'Datetime.DTT_ID' => ['IN', $datetimeIds],
+							'TKT_deleted'     => ['IN', [true, false]],
+						],
+						'default_where_conditions' => 'minimum',
+					]);
+				} catch (Throwable $th) {
+					$ticketIds = [];
+				}
+
+				if (!empty($ticketIds)) {
+					$input_fields['Registration.Ticket.TKT_ID'] = ['IN', $ticketIds];
+				}
+			}
+			// Since there is no relation between Attendee and Datetime, we need to remove it
+			unset($input_fields['Datetime.DTT_ID']);
+		}
+
+		/**
+		 * Merge the input_fields with the default query_args
+		 */
+		if (! empty($input_fields)) {
+			$where_params = array_merge($where_params, $input_fields);
+		}
+
+		[$query_args, $where_params] = $this->mapOrderbyInputArgs($query_args, $where_params, 'ATT_ID');
+
+		$search = $this->getSearchKeywords($this->args['where']);
+
+		if (! empty($search)) {
+			// use OR operator to search in any of the fields
+			$where_params['OR'] = array(
+				'ATT_full_name' => array('LIKE', '%' . $search . '%'),
+				'ATT_bio'       => array('LIKE', '%' . $search . '%'),
+				'ATT_short_bio' => array('LIKE', '%' . $search . '%'),
+			);
+		}
+
+		$where_params = apply_filters(
+			'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__attendee_where_params',
+			$where_params,
+			$this->source,
+			$this->args
+		);
+
+		$query_args[] = $where_params;
+
+		/**
+		 * Return the $query_args
+		 */
+		return apply_filters(
+			'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__attendee_query_args',
+			$query_args,
+			$this->source,
+			$this->args
+		);
+	}
+
+
+	/**
+	 * This sets up the "allowed" args, and translates the GraphQL-friendly keys to model
+	 * friendly keys.
+	 *
+	 * @param array $where_args
+	 * @return array
+	 */
+	public function sanitizeInputFields(array $where_args): array
+	{
+		$arg_mapping = [
+			// There is no direct relation between Attendee and Datetime
+			// But we will handle it via Tickets related to given dates
+			'datetime'      => 'Datetime.DTT_ID',
+			'datetimeIn'    => 'Datetime.DTT_ID',
+			'event'         => 'Registration.Event.EVT_ID',
+			'eventIn'       => 'Registration.Event.EVT_ID',
+			'regTicket'     => 'Registration.Ticket.TKT_ID',
+			'regTicketIn'   => 'Registration.Ticket.TKT_ID',
+			'regTicketIdIn' => 'Registration.Ticket.TKT_ID',
+			'regTicketId'   => 'Registration.Ticket.TKT_ID', // priority.
+			'regStatus'     => 'Registration.Status.STS_ID',
+		];
+		return $this->sanitizeWhereArgsForInputFields(
+			$where_args,
+			$arg_mapping,
+			['datetime', 'datetimeIn', 'event', 'eventIn', 'regTicket', 'regTicketIn']
+		);
+	}
 }

core/domain/services/graphql/connection_resolvers/PriceConnectionResolver.php

Indentation +215 added lines, -215 removed lines

@@ -17,219 +17,219 @@
  */
 class PriceConnectionResolver extends AbstractConnectionResolver
 {
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_loader_name(): string
-    {
-        return 'espresso_price';
-    }
-
-    /**
-     * @return EEM_Price
-     * @throws EE_Error
-     * @throws InvalidArgumentException
-     * @throws InvalidDataTypeException
-     * @throws InvalidInterfaceException
-     * @throws ReflectionException
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_query(): EEM_Price
-    {
-        return EEM_Price::instance();
-    }
-
-
-    /**
-     * Return an array of item IDs from the query
-     *
-     * @return array
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_ids(): array
-    {
-        $results = $this->query->get_col($this->query_args);
-
-        return ! empty($results) ? $results : [];
-    }
-
-
-    /**
-     * Here, we map the args from the input, then we make sure that we're only querying
-     * for IDs. The IDs are then passed down the resolve tree, and deferred resolvers
-     * handle batch resolution of the posts.
-     *
-     * @return array
-     * @throws EE_Error
-     * @throws InvalidArgumentException
-     * @throws ReflectionException
-     * @throws InvalidDataTypeException
-     * @throws InvalidInterfaceException
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_query_args(): array
-    {
-        $where_params = [];
-        $query_args   = [];
-
-        $query_args['limit'] = $this->getLimit();
-
-        // Avoid multiple entries by join.
-        $query_args['group_by'] = 'PRC_ID';
-
-        $query_args['default_where_conditions'] = 'minimum';
-
-        /**
-         * Collect the input_fields and sanitize them to prepare them for sending to the Query
-         */
-        $input_fields = [];
-        if (! empty($this->args['where'])) {
-            $input_fields = $this->sanitizeInputFields($this->args['where']);
-
-            // Use the proper operator.
-            if (! empty($input_fields['PRC_ID']) && is_array($input_fields['PRC_ID'])) {
-                $input_fields['PRC_ID'] = ['in', $input_fields['PRC_ID']];
-            }
-            if (! empty($input_fields['Ticket.TKT_ID']) && is_array($input_fields['Ticket.TKT_ID'])) {
-                $input_fields['Ticket.TKT_ID'] = ['in', $input_fields['Ticket.TKT_ID']];
-            }
-            if (! empty($input_fields['Price_Type.PBT_ID']) && is_array($input_fields['Price_Type.PBT_ID'])) {
-                $input_fields['Price_Type.PBT_ID'] = ['in', $input_fields['Price_Type.PBT_ID']];
-            }
-            if (! empty($input_fields['Price_Type.PRT_ID']) && is_array($input_fields['Price_Type.PRT_ID'])) {
-                $input_fields['Price_Type.PRT_ID'] = ['in', $input_fields['Price_Type.PRT_ID']];
-            }
-            // if event ID is passed but not a ticket ID
-            if (! isset($input_fields['Ticket.TKT_ID']) && isset($input_fields['Event.EVT_ID'])) {
-                $event_id = $input_fields['Event.EVT_ID'];
-                // Ensure that this doesn't go to the query.
-                // After all there is no DB relation between event and price
-                unset($input_fields['Event.EVT_ID']);
-                // get all the datetimeIds of the event
-                $event_datetime_ids = EEM_Datetime::instance()->get_col([
-                    [
-                        'EVT_ID'      => $event_id,
-                    ],
-                    'default_where_conditions' => 'minimum'
-                ]);
-                // get all the related ticket Ids
-                $ticket_ids = EEM_Ticket::instance()->get_col([
-                    [
-                        'Datetime.DTT_ID' => ['IN', $event_datetime_ids],
-                    ],
-                    'default_where_conditions' => 'minimum'
-                ]);
-
-                // add tickets relation to the query
-                $input_fields['Ticket.TKT_ID'] = ['IN', $ticket_ids];
-            }
-        }
-
-        /**
-         * Determine where we're at in the Graph and adjust the query context appropriately.
-         */
-        if ($this->source instanceof EE_Ticket) {
-            $where_params['Ticket.TKT_ID'] = $this->source->ID();
-        }
-
-        /**
-         * Merge the input_fields with the default query_args
-         */
-        if (! empty($input_fields)) {
-            $where_params = array_merge($where_params, $input_fields);
-        }
-
-        [$query_args, $where_params] = $this->mapOrderbyInputArgs($query_args, $where_params, 'PRC_ID');
-
-        $default_prices_params = [];
-
-        // If default ticket prices should be included.
-        if (! empty($this->args['where']['includeDefaultTicketsPrices'])) {
-            $default_ticket_ids = EEM_Ticket::instance()->get_col([
-                [
-                    'TKT_is_default' => 1,
-                ],
-                'default_where_conditions' => 'minimum'
-            ]);
-
-            // if we have default tickets
-            if (! empty($default_ticket_ids)) {
-                $default_prices_params['OR'] = [
-                    'Ticket.TKT_ID' => ['IN', $default_ticket_ids],
-                ];
-            }
-        }
-
-        // If default prices should be included.
-        if (! empty($this->args['where']['includeDefaultPrices'])) {
-            $default_prices_params['AND'] = [
-                'PRC_deleted'    => 0,
-                'PRC_is_default' => 1,
-            ];
-        }
-
-        if (! empty($default_prices_params)) {
-            if (empty($where_params)) {
-                $where_params['OR'] = $default_prices_params;
-            } else {
-                $where_params = [
-                    'OR' => [
-                        'OR'  => $default_prices_params,
-                        'AND' => $where_params,
-                    ],
-                ];
-            }
-        }
-
-        $where_params = apply_filters(
-            'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__price_where_params',
-            $where_params,
-            $this->source,
-            $this->args
-        );
-
-        $query_args[] = $where_params;
-
-        /**
-         * Return the $query_args
-         */
-        return apply_filters(
-            'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__price_query_args',
-            $query_args,
-            $this->source,
-            $this->args
-        );
-    }
-
-
-    /**
-     * This sets up the "allowed" args, and translates the GraphQL-friendly keys to model
-     * friendly keys.
-     *
-     * @param array $where_args
-     * @return array
-     */
-    public function sanitizeInputFields(array $where_args): array
-    {
-        $arg_mapping = [
-            'in'              => 'PRC_ID',
-            'idIn'            => 'PRC_ID',
-            'isDefault'       => 'PRC_is_default',
-            'event'           => 'Event.EVT_ID',
-            'eventId'         => 'Event.EVT_ID', // priority.
-            'ticket'          => 'Ticket.TKT_ID',
-            'ticketIn'        => 'Ticket.TKT_ID',
-            'ticketIdIn'      => 'Ticket.TKT_ID',
-            'ticketId'        => 'Ticket.TKT_ID', // priority.
-            'priceType'       => 'Price_Type.PRT_ID',
-            'priceTypeIn'     => 'Price_Type.PRT_ID',
-            'priceTypeIdIn'   => 'Price_Type.PRT_ID',
-            'priceTypeId'     => 'Price_Type.PRT_ID', // priority.
-            'priceBaseType'   => 'Price_Type.PBT_ID',
-            'priceBaseTypeIn' => 'Price_Type.PBT_ID',
-        ];
-        return $this->sanitizeWhereArgsForInputFields(
-            $where_args,
-            $arg_mapping,
-            ['in', 'event', 'ticket', 'ticketIn', 'priceType', 'priceTypeIn']
-        );
-    }
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_loader_name(): string
+	{
+		return 'espresso_price';
+	}
+
+	/**
+	 * @return EEM_Price
+	 * @throws EE_Error
+	 * @throws InvalidArgumentException
+	 * @throws InvalidDataTypeException
+	 * @throws InvalidInterfaceException
+	 * @throws ReflectionException
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_query(): EEM_Price
+	{
+		return EEM_Price::instance();
+	}
+
+
+	/**
+	 * Return an array of item IDs from the query
+	 *
+	 * @return array
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_ids(): array
+	{
+		$results = $this->query->get_col($this->query_args);
+
+		return ! empty($results) ? $results : [];
+	}
+
+
+	/**
+	 * Here, we map the args from the input, then we make sure that we're only querying
+	 * for IDs. The IDs are then passed down the resolve tree, and deferred resolvers
+	 * handle batch resolution of the posts.
+	 *
+	 * @return array
+	 * @throws EE_Error
+	 * @throws InvalidArgumentException
+	 * @throws ReflectionException
+	 * @throws InvalidDataTypeException
+	 * @throws InvalidInterfaceException
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_query_args(): array
+	{
+		$where_params = [];
+		$query_args   = [];
+
+		$query_args['limit'] = $this->getLimit();
+
+		// Avoid multiple entries by join.
+		$query_args['group_by'] = 'PRC_ID';
+
+		$query_args['default_where_conditions'] = 'minimum';
+
+		/**
+		 * Collect the input_fields and sanitize them to prepare them for sending to the Query
+		 */
+		$input_fields = [];
+		if (! empty($this->args['where'])) {
+			$input_fields = $this->sanitizeInputFields($this->args['where']);
+
+			// Use the proper operator.
+			if (! empty($input_fields['PRC_ID']) && is_array($input_fields['PRC_ID'])) {
+				$input_fields['PRC_ID'] = ['in', $input_fields['PRC_ID']];
+			}
+			if (! empty($input_fields['Ticket.TKT_ID']) && is_array($input_fields['Ticket.TKT_ID'])) {
+				$input_fields['Ticket.TKT_ID'] = ['in', $input_fields['Ticket.TKT_ID']];
+			}
+			if (! empty($input_fields['Price_Type.PBT_ID']) && is_array($input_fields['Price_Type.PBT_ID'])) {
+				$input_fields['Price_Type.PBT_ID'] = ['in', $input_fields['Price_Type.PBT_ID']];
+			}
+			if (! empty($input_fields['Price_Type.PRT_ID']) && is_array($input_fields['Price_Type.PRT_ID'])) {
+				$input_fields['Price_Type.PRT_ID'] = ['in', $input_fields['Price_Type.PRT_ID']];
+			}
+			// if event ID is passed but not a ticket ID
+			if (! isset($input_fields['Ticket.TKT_ID']) && isset($input_fields['Event.EVT_ID'])) {
+				$event_id = $input_fields['Event.EVT_ID'];
+				// Ensure that this doesn't go to the query.
+				// After all there is no DB relation between event and price
+				unset($input_fields['Event.EVT_ID']);
+				// get all the datetimeIds of the event
+				$event_datetime_ids = EEM_Datetime::instance()->get_col([
+					[
+						'EVT_ID'      => $event_id,
+					],
+					'default_where_conditions' => 'minimum'
+				]);
+				// get all the related ticket Ids
+				$ticket_ids = EEM_Ticket::instance()->get_col([
+					[
+						'Datetime.DTT_ID' => ['IN', $event_datetime_ids],
+					],
+					'default_where_conditions' => 'minimum'
+				]);
+
+				// add tickets relation to the query
+				$input_fields['Ticket.TKT_ID'] = ['IN', $ticket_ids];
+			}
+		}
+
+		/**
+		 * Determine where we're at in the Graph and adjust the query context appropriately.
+		 */
+		if ($this->source instanceof EE_Ticket) {
+			$where_params['Ticket.TKT_ID'] = $this->source->ID();
+		}
+
+		/**
+		 * Merge the input_fields with the default query_args
+		 */
+		if (! empty($input_fields)) {
+			$where_params = array_merge($where_params, $input_fields);
+		}
+
+		[$query_args, $where_params] = $this->mapOrderbyInputArgs($query_args, $where_params, 'PRC_ID');
+
+		$default_prices_params = [];
+
+		// If default ticket prices should be included.
+		if (! empty($this->args['where']['includeDefaultTicketsPrices'])) {
+			$default_ticket_ids = EEM_Ticket::instance()->get_col([
+				[
+					'TKT_is_default' => 1,
+				],
+				'default_where_conditions' => 'minimum'
+			]);
+
+			// if we have default tickets
+			if (! empty($default_ticket_ids)) {
+				$default_prices_params['OR'] = [
+					'Ticket.TKT_ID' => ['IN', $default_ticket_ids],
+				];
+			}
+		}
+
+		// If default prices should be included.
+		if (! empty($this->args['where']['includeDefaultPrices'])) {
+			$default_prices_params['AND'] = [
+				'PRC_deleted'    => 0,
+				'PRC_is_default' => 1,
+			];
+		}
+
+		if (! empty($default_prices_params)) {
+			if (empty($where_params)) {
+				$where_params['OR'] = $default_prices_params;
+			} else {
+				$where_params = [
+					'OR' => [
+						'OR'  => $default_prices_params,
+						'AND' => $where_params,
+					],
+				];
+			}
+		}
+
+		$where_params = apply_filters(
+			'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__price_where_params',
+			$where_params,
+			$this->source,
+			$this->args
+		);
+
+		$query_args[] = $where_params;
+
+		/**
+		 * Return the $query_args
+		 */
+		return apply_filters(
+			'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__price_query_args',
+			$query_args,
+			$this->source,
+			$this->args
+		);
+	}
+
+
+	/**
+	 * This sets up the "allowed" args, and translates the GraphQL-friendly keys to model
+	 * friendly keys.
+	 *
+	 * @param array $where_args
+	 * @return array
+	 */
+	public function sanitizeInputFields(array $where_args): array
+	{
+		$arg_mapping = [
+			'in'              => 'PRC_ID',
+			'idIn'            => 'PRC_ID',
+			'isDefault'       => 'PRC_is_default',
+			'event'           => 'Event.EVT_ID',
+			'eventId'         => 'Event.EVT_ID', // priority.
+			'ticket'          => 'Ticket.TKT_ID',
+			'ticketIn'        => 'Ticket.TKT_ID',
+			'ticketIdIn'      => 'Ticket.TKT_ID',
+			'ticketId'        => 'Ticket.TKT_ID', // priority.
+			'priceType'       => 'Price_Type.PRT_ID',
+			'priceTypeIn'     => 'Price_Type.PRT_ID',
+			'priceTypeIdIn'   => 'Price_Type.PRT_ID',
+			'priceTypeId'     => 'Price_Type.PRT_ID', // priority.
+			'priceBaseType'   => 'Price_Type.PBT_ID',
+			'priceBaseTypeIn' => 'Price_Type.PBT_ID',
+		];
+		return $this->sanitizeWhereArgsForInputFields(
+			$where_args,
+			$arg_mapping,
+			['in', 'event', 'ticket', 'ticketIn', 'priceType', 'priceTypeIn']
+		);
+	}
 }

core/domain/services/graphql/connection_resolvers/TicketConnectionResolver.php

Indentation +174 added lines, -174 removed lines

@@ -15,178 +15,178 @@
  */
 class TicketConnectionResolver extends AbstractConnectionResolver
 {
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_loader_name(): string
-    {
-        return 'espresso_ticket';
-    }
-
-    /**
-     * @return EEM_Ticket
-     * @throws EE_Error
-     * @throws InvalidArgumentException
-     * @throws InvalidDataTypeException
-     * @throws InvalidInterfaceException
-     * @throws ReflectionException
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_query(): EEM_Ticket
-    {
-        return EEM_Ticket::instance();
-    }
-
-
-    /**
-     * Return an array of item IDs from the query
-     *
-     * @return array
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_ids(): array
-    {
-        $results = $this->query->get_col($this->query_args);
-
-        return ! empty($results) ? $results : [];
-    }
-
-
-    /**
-     * Here, we map the args from the input, then we make sure that we're only querying
-     * for IDs. The IDs are then passed down the resolve tree, and deferred resolvers
-     * handle batch resolution of the posts.
-     *
-     * @return array
-     * @throws EE_Error
-     * @throws InvalidArgumentException
-     * @throws ReflectionException
-     * @throws InvalidDataTypeException
-     * @throws InvalidInterfaceException
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_query_args(): array
-    {
-        $where_params = ['TKT_deleted' => ['IN', [true, false]]];
-        $query_args   = [];
-
-        $query_args['limit'] = $this->getLimit();
-
-        // Avoid multiple entries by join.
-        $query_args['group_by'] = 'TKT_ID';
-
-        $query_args['default_where_conditions'] = 'minimum';
-
-        /**
-         * Collect the input_fields and sanitize them to prepare them for sending to the Query
-         */
-        $input_fields = [];
-        if (! empty($this->args['where'])) {
-            $input_fields = $this->sanitizeInputFields($this->args['where']);
-
-            // Use the proper operator.
-            if (! empty($input_fields['Datetime.DTT_ID']) && is_array($input_fields['Datetime.DTT_ID'])) {
-                $input_fields['Datetime.DTT_ID'] = ['IN', $input_fields['Datetime.DTT_ID']];
-            }
-            if (! empty($input_fields['Datetime.EVT_ID']) && is_array($input_fields['Datetime.EVT_ID'])) {
-                $input_fields['Datetime.EVT_ID'] = ['IN', $input_fields['Datetime.EVT_ID']];
-            }
-        }
-
-        /**
-         * Determine where we're at in the Graph and adjust the query context appropriately.
-         */
-        if ($this->source instanceof EE_Datetime) {
-            $where_params['Datetime.DTT_ID'] = $this->source->ID();
-        }
-
-        /**
-         * Merge the input_fields with the default query_args
-         */
-        if (! empty($input_fields)) {
-            $where_params = array_merge($where_params, $input_fields);
-        }
-
-        [$query_args, $where_params] = $this->mapOrderbyInputArgs($query_args, $where_params, 'TKT_ID');
-
-        $search = isset($this->args['where']) ? $this->getSearchKeywords($this->args['where']) : '';
-
-        if (! empty($search)) {
-            // use OR operator to search in any of the fields
-            $where_params['OR'] = array(
-                'TKT_name'        => array('LIKE', '%' . $search . '%'),
-                'TKT_description' => array('LIKE', '%' . $search . '%'),
-            );
-        }
-
-        // If default tickets should be included.
-        if (! empty($this->args['where']['includeDefaultTickets'])) {
-            /**
-             * We need to get each ticket that
-             * - satisfies $where_params above
-             * OR
-             * - it's a default ticket
-             */
-            $where_params = [
-                'OR' => [
-                    // use extra OR instead of AND to avoid it getting overridden
-                    'OR' => [
-                        'AND' => [
-                            'TKT_deleted'    => ['IN', [true, false]],
-                            'TKT_is_default' => 1,
-                        ]
-                    ],
-                    'AND' => $where_params,
-                ],
-            ];
-        }
-
-        $where_params = apply_filters(
-            'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__ticket_where_params',
-            $where_params,
-            $this->source,
-            $this->args
-        );
-
-        $query_args[] = $where_params;
-
-        /**
-         * Return the $query_args
-         */
-        return apply_filters(
-            'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__ticket_query_args',
-            $query_args,
-            $this->source,
-            $this->args
-        );
-    }
-
-
-    /**
-     * This sets up the "allowed" args, and translates the GraphQL-friendly keys to model
-     * friendly keys.
-     *
-     * @param array $where_args
-     * @return array
-     */
-    public function sanitizeInputFields(array $where_args): array
-    {
-        $arg_mapping = [
-            'event'        => 'Datetime.EVT_ID',
-            'eventIn'      => 'Datetime.EVT_ID',
-            'eventIdIn'    => 'Datetime.EVT_ID',
-            'eventId'      => 'Datetime.EVT_ID', // priority.
-            'datetime'     => 'Datetime.DTT_ID',
-            'datetimeIn'   => 'Datetime.DTT_ID',
-            'datetimeIdIn' => 'Datetime.DTT_ID',
-            'datetimeId'   => 'Datetime.DTT_ID', // priority.
-            'isDefault'    => 'TKT_is_default',
-            'isRequired'   => 'TKT_required',
-            'isTaxable'    => 'TKT_taxable',
-            'isTrashed'    => 'TKT_deleted',
-        ];
-        return $this->sanitizeWhereArgsForInputFields(
-            $where_args,
-            $arg_mapping,
-            ['datetime', 'datetimeIn', 'event', 'eventIn']
-        );
-    }
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_loader_name(): string
+	{
+		return 'espresso_ticket';
+	}
+
+	/**
+	 * @return EEM_Ticket
+	 * @throws EE_Error
+	 * @throws InvalidArgumentException
+	 * @throws InvalidDataTypeException
+	 * @throws InvalidInterfaceException
+	 * @throws ReflectionException
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_query(): EEM_Ticket
+	{
+		return EEM_Ticket::instance();
+	}
+
+
+	/**
+	 * Return an array of item IDs from the query
+	 *
+	 * @return array
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_ids(): array
+	{
+		$results = $this->query->get_col($this->query_args);
+
+		return ! empty($results) ? $results : [];
+	}
+
+
+	/**
+	 * Here, we map the args from the input, then we make sure that we're only querying
+	 * for IDs. The IDs are then passed down the resolve tree, and deferred resolvers
+	 * handle batch resolution of the posts.
+	 *
+	 * @return array
+	 * @throws EE_Error
+	 * @throws InvalidArgumentException
+	 * @throws ReflectionException
+	 * @throws InvalidDataTypeException
+	 * @throws InvalidInterfaceException
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_query_args(): array
+	{
+		$where_params = ['TKT_deleted' => ['IN', [true, false]]];
+		$query_args   = [];
+
+		$query_args['limit'] = $this->getLimit();
+
+		// Avoid multiple entries by join.
+		$query_args['group_by'] = 'TKT_ID';
+
+		$query_args['default_where_conditions'] = 'minimum';
+
+		/**
+		 * Collect the input_fields and sanitize them to prepare them for sending to the Query
+		 */
+		$input_fields = [];
+		if (! empty($this->args['where'])) {
+			$input_fields = $this->sanitizeInputFields($this->args['where']);
+
+			// Use the proper operator.
+			if (! empty($input_fields['Datetime.DTT_ID']) && is_array($input_fields['Datetime.DTT_ID'])) {
+				$input_fields['Datetime.DTT_ID'] = ['IN', $input_fields['Datetime.DTT_ID']];
+			}
+			if (! empty($input_fields['Datetime.EVT_ID']) && is_array($input_fields['Datetime.EVT_ID'])) {
+				$input_fields['Datetime.EVT_ID'] = ['IN', $input_fields['Datetime.EVT_ID']];
+			}
+		}
+
+		/**
+		 * Determine where we're at in the Graph and adjust the query context appropriately.
+		 */
+		if ($this->source instanceof EE_Datetime) {
+			$where_params['Datetime.DTT_ID'] = $this->source->ID();
+		}
+
+		/**
+		 * Merge the input_fields with the default query_args
+		 */
+		if (! empty($input_fields)) {
+			$where_params = array_merge($where_params, $input_fields);
+		}
+
+		[$query_args, $where_params] = $this->mapOrderbyInputArgs($query_args, $where_params, 'TKT_ID');
+
+		$search = isset($this->args['where']) ? $this->getSearchKeywords($this->args['where']) : '';
+
+		if (! empty($search)) {
+			// use OR operator to search in any of the fields
+			$where_params['OR'] = array(
+				'TKT_name'        => array('LIKE', '%' . $search . '%'),
+				'TKT_description' => array('LIKE', '%' . $search . '%'),
+			);
+		}
+
+		// If default tickets should be included.
+		if (! empty($this->args['where']['includeDefaultTickets'])) {
+			/**
+			 * We need to get each ticket that
+			 * - satisfies $where_params above
+			 * OR
+			 * - it's a default ticket
+			 */
+			$where_params = [
+				'OR' => [
+					// use extra OR instead of AND to avoid it getting overridden
+					'OR' => [
+						'AND' => [
+							'TKT_deleted'    => ['IN', [true, false]],
+							'TKT_is_default' => 1,
+						]
+					],
+					'AND' => $where_params,
+				],
+			];
+		}
+
+		$where_params = apply_filters(
+			'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__ticket_where_params',
+			$where_params,
+			$this->source,
+			$this->args
+		);
+
+		$query_args[] = $where_params;
+
+		/**
+		 * Return the $query_args
+		 */
+		return apply_filters(
+			'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__ticket_query_args',
+			$query_args,
+			$this->source,
+			$this->args
+		);
+	}
+
+
+	/**
+	 * This sets up the "allowed" args, and translates the GraphQL-friendly keys to model
+	 * friendly keys.
+	 *
+	 * @param array $where_args
+	 * @return array
+	 */
+	public function sanitizeInputFields(array $where_args): array
+	{
+		$arg_mapping = [
+			'event'        => 'Datetime.EVT_ID',
+			'eventIn'      => 'Datetime.EVT_ID',
+			'eventIdIn'    => 'Datetime.EVT_ID',
+			'eventId'      => 'Datetime.EVT_ID', // priority.
+			'datetime'     => 'Datetime.DTT_ID',
+			'datetimeIn'   => 'Datetime.DTT_ID',
+			'datetimeIdIn' => 'Datetime.DTT_ID',
+			'datetimeId'   => 'Datetime.DTT_ID', // priority.
+			'isDefault'    => 'TKT_is_default',
+			'isRequired'   => 'TKT_required',
+			'isTaxable'    => 'TKT_taxable',
+			'isTrashed'    => 'TKT_deleted',
+		];
+		return $this->sanitizeWhereArgsForInputFields(
+			$where_args,
+			$arg_mapping,
+			['datetime', 'datetimeIn', 'event', 'eventIn']
+		);
+	}
 }

core/domain/services/graphql/connection_resolvers/AbstractConnectionResolver.php

Indentation +168 added lines, -168 removed lines

@@ -20,172 +20,172 @@
 {
 
 
-    /**
-     * @var Utilities
-     */
-    private $utilities;
-
-
-    /**
-     * @return Utilities
-     */
-    public function getUtilities(): Utilities
-    {
-        if (! $this->utilities instanceof Utilities) {
-            $this->utilities = LoaderFactory::getLoader()->getShared(Utilities::class);
-        }
-        return $this->utilities;
-    }
-
-    /**
-     * Determine whether the Query should execute. If it's determined that the query should
-     * not be run based on context such as, but not limited to, who the user is, where in the
-     * ResolveTree the Query is, the relation to the node the Query is connected to, etc
-     * Return false to prevent the query from executing.
-     *
-     * @return bool
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function should_execute(): bool
-    {
-        return $this->should_execute;
-    }
-
-
-    /**
-     * Set limit the highest value of first and last, with a (filterable) max of 100
-     *
-     * @return int
-     */
-    protected function getLimit(): int
-    {
-        $first = ! empty($this->args['first'])
-            ? absint($this->args['first'])
-            : null;
-        $last  = ! empty($this->args['last'])
-            ? absint($this->args['last'])
-            : null;
-
-        $limit = min(
-            max($first, $last, 100),
-            $this->query_amount
-        );
-        $limit++;
-        return $limit;
-    }
-
-    /**
-     * Get_amount_requested
-     *
-     * This checks the $args to determine the amount requested
-     *
-     * @return int|null
-     * @throws Exception
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_amount_requested(): ?int
-    {
-        $amount_requested = parent::get_amount_requested();
-
-        /**
-         * If both first & last are used in the input args, throw an exception as that won't
-         * work properly
-         */
-        if (empty($this->args['first']) && empty($this->args['last']) && $amount_requested === 10) {
-            return 100; // default.
-        }
-
-        return $amount_requested;
-    }
-
-    /**
-     * Determine whether or not the the offset is valid, i.e the entity corresponding to the
-     * offset exists. Offset is equivalent to entity ID. So this function is equivalent to
-     * checking if the entity with the given ID exists.
-     *
-     * @param int $offset The ID of the node used for the cursor offset
-     * @return bool
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function is_valid_offset($offset): bool
-    {
-        $entity = $this->get_query()->get_one_by_ID($offset);
-
-        return $entity instanceof EE_Base_Class;
-    }
-
-    /**
-     * Validates Model.
-     *
-     * @param array $model Entity node.
-     * @return bool
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    protected function is_valid_model($model): bool
-    {
-        return $model instanceof EE_Base_Class;
-    }
-
-
-    /**
-     * This sets up the "allowed" args, and translates the GraphQL-friendly keys to model
-     * friendly keys.
-     *
-     * @param array  $query_args
-     * @param array  $where_params
-     * @param string $primary_key
-     * @return array
-     */
-    protected function mapOrderbyInputArgs(array $query_args, array $where_params, string $primary_key): array
-    {
-        // ID of the current offset
-        $offset = $this->get_offset();
-        /**
-         * Map the orderby inputArgs to the WP_Query
-         */
-        if (! empty($this->args['where']['orderby']) && is_array($this->args['where']['orderby'])) {
-            $query_args['order_by'] = [];
-            foreach ($this->args['where']['orderby'] as $orderby_input) {
-                $query_args['order_by'][ $orderby_input['field'] ] = $orderby_input['order'];
-            }
-        } elseif ($offset) {
-            $compare = $this->args['last'] ? '<' : '>';
-            $where_params[ $primary_key ] = [$compare, $offset];
-        }
-        return [$query_args, $where_params];
-    }
-
-
-    /**
-     * This sets up the "allowed" args, and translates the GraphQL-friendly keys to model
-     * friendly keys.
-     *
-     * @param array $where_args
-     * @param array $arg_mapping
-     * @param array $id_fields The fields to convert from global IDs to DB IDs.
-     * @return array
-     */
-    protected function sanitizeWhereArgsForInputFields(array $where_args, array $arg_mapping, array $id_fields = []): array
-    {
-        $query_args = $this->getUtilities()->sanitizeWhereArgs($where_args, $arg_mapping, $id_fields);
-        return ! empty($query_args) && is_array($query_args)
-            ? $query_args
-            : [];
-    }
-
-
-    /**
-     * This returns the sanitized "search" keywords from where_args
-     *
-     * @param array $where_args
-     * @return string
-     */
-    protected function getSearchKeywords(array $where_args): string
-    {
-        $search = '';
-        if (! empty($where_args['search'])) {
-            $search = sanitize_text_field($where_args['search']);
-        }
-        return esc_sql($search);
-    }
+	/**
+	 * @var Utilities
+	 */
+	private $utilities;
+
+
+	/**
+	 * @return Utilities
+	 */
+	public function getUtilities(): Utilities
+	{
+		if (! $this->utilities instanceof Utilities) {
+			$this->utilities = LoaderFactory::getLoader()->getShared(Utilities::class);
+		}
+		return $this->utilities;
+	}
+
+	/**
+	 * Determine whether the Query should execute. If it's determined that the query should
+	 * not be run based on context such as, but not limited to, who the user is, where in the
+	 * ResolveTree the Query is, the relation to the node the Query is connected to, etc
+	 * Return false to prevent the query from executing.
+	 *
+	 * @return bool
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function should_execute(): bool
+	{
+		return $this->should_execute;
+	}
+
+
+	/**
+	 * Set limit the highest value of first and last, with a (filterable) max of 100
+	 *
+	 * @return int
+	 */
+	protected function getLimit(): int
+	{
+		$first = ! empty($this->args['first'])
+			? absint($this->args['first'])
+			: null;
+		$last  = ! empty($this->args['last'])
+			? absint($this->args['last'])
+			: null;
+
+		$limit = min(
+			max($first, $last, 100),
+			$this->query_amount
+		);
+		$limit++;
+		return $limit;
+	}
+
+	/**
+	 * Get_amount_requested
+	 *
+	 * This checks the $args to determine the amount requested
+	 *
+	 * @return int|null
+	 * @throws Exception
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_amount_requested(): ?int
+	{
+		$amount_requested = parent::get_amount_requested();
+
+		/**
+		 * If both first & last are used in the input args, throw an exception as that won't
+		 * work properly
+		 */
+		if (empty($this->args['first']) && empty($this->args['last']) && $amount_requested === 10) {
+			return 100; // default.
+		}
+
+		return $amount_requested;
+	}
+
+	/**
+	 * Determine whether or not the the offset is valid, i.e the entity corresponding to the
+	 * offset exists. Offset is equivalent to entity ID. So this function is equivalent to
+	 * checking if the entity with the given ID exists.
+	 *
+	 * @param int $offset The ID of the node used for the cursor offset
+	 * @return bool
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function is_valid_offset($offset): bool
+	{
+		$entity = $this->get_query()->get_one_by_ID($offset);
+
+		return $entity instanceof EE_Base_Class;
+	}
+
+	/**
+	 * Validates Model.
+	 *
+	 * @param array $model Entity node.
+	 * @return bool
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	protected function is_valid_model($model): bool
+	{
+		return $model instanceof EE_Base_Class;
+	}
+
+
+	/**
+	 * This sets up the "allowed" args, and translates the GraphQL-friendly keys to model
+	 * friendly keys.
+	 *
+	 * @param array  $query_args
+	 * @param array  $where_params
+	 * @param string $primary_key
+	 * @return array
+	 */
+	protected function mapOrderbyInputArgs(array $query_args, array $where_params, string $primary_key): array
+	{
+		// ID of the current offset
+		$offset = $this->get_offset();
+		/**
+		 * Map the orderby inputArgs to the WP_Query
+		 */
+		if (! empty($this->args['where']['orderby']) && is_array($this->args['where']['orderby'])) {
+			$query_args['order_by'] = [];
+			foreach ($this->args['where']['orderby'] as $orderby_input) {
+				$query_args['order_by'][ $orderby_input['field'] ] = $orderby_input['order'];
+			}
+		} elseif ($offset) {
+			$compare = $this->args['last'] ? '<' : '>';
+			$where_params[ $primary_key ] = [$compare, $offset];
+		}
+		return [$query_args, $where_params];
+	}
+
+
+	/**
+	 * This sets up the "allowed" args, and translates the GraphQL-friendly keys to model
+	 * friendly keys.
+	 *
+	 * @param array $where_args
+	 * @param array $arg_mapping
+	 * @param array $id_fields The fields to convert from global IDs to DB IDs.
+	 * @return array
+	 */
+	protected function sanitizeWhereArgsForInputFields(array $where_args, array $arg_mapping, array $id_fields = []): array
+	{
+		$query_args = $this->getUtilities()->sanitizeWhereArgs($where_args, $arg_mapping, $id_fields);
+		return ! empty($query_args) && is_array($query_args)
+			? $query_args
+			: [];
+	}
+
+
+	/**
+	 * This returns the sanitized "search" keywords from where_args
+	 *
+	 * @param array $where_args
+	 * @return string
+	 */
+	protected function getSearchKeywords(array $where_args): string
+	{
+		$search = '';
+		if (! empty($where_args['search'])) {
+			$search = sanitize_text_field($where_args['search']);
+		}
+		return esc_sql($search);
+	}
 }

Spacing +5 added lines, -5 removed lines

@@ -31,7 +31,7 @@ 
      */
     public function getUtilities(): Utilities
     {
-        if (! $this->utilities instanceof Utilities) {
+        if ( ! $this->utilities instanceof Utilities) {
             $this->utilities = LoaderFactory::getLoader()->getShared(Utilities::class);
         }
         return $this->utilities;
@@ -143,14 +143,14 @@ 
         /**
          * Map the orderby inputArgs to the WP_Query
          */
-        if (! empty($this->args['where']['orderby']) && is_array($this->args['where']['orderby'])) {
+        if ( ! empty($this->args['where']['orderby']) && is_array($this->args['where']['orderby'])) {
             $query_args['order_by'] = [];
             foreach ($this->args['where']['orderby'] as $orderby_input) {
-                $query_args['order_by'][ $orderby_input['field'] ] = $orderby_input['order'];
+                $query_args['order_by'][$orderby_input['field']] = $orderby_input['order'];
             }
         } elseif ($offset) {
             $compare = $this->args['last'] ? '<' : '>';
-            $where_params[ $primary_key ] = [$compare, $offset];
+            $where_params[$primary_key] = [$compare, $offset];
         }
         return [$query_args, $where_params];
     }
@@ -183,7 +183,7 @@ 
     protected function getSearchKeywords(array $where_args): string
     {
         $search = '';
-        if (! empty($where_args['search'])) {
+        if ( ! empty($where_args['search'])) {
             $search = sanitize_text_field($where_args['search']);
         }
         return esc_sql($search);

core/domain/services/graphql/connection_resolvers/VenueConnectionResolver.php

Indentation +126 added lines, -126 removed lines

@@ -16,130 +16,130 @@
  */
 class VenueConnectionResolver extends AbstractConnectionResolver
 {
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_loader_name(): string
-    {
-        return 'espresso_venue';
-    }
-
-    /**
-     * @return EEM_Venue
-     * @throws EE_Error
-     * @throws InvalidArgumentException
-     * @throws InvalidDataTypeException
-     * @throws InvalidInterfaceException
-     * @throws ReflectionException
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_query(): EEM_Venue
-    {
-        return EEM_Venue::instance();
-    }
-
-
-    /**
-     * Return an array of item IDs from the query
-     *
-     * @return array
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_ids(): array
-    {
-        $results = $this->query->get_col($this->query_args);
-
-        return ! empty($results) ? $results : [];
-    }
-
-
-    /**
-     * Here, we map the args from the input, then we make sure that we're only querying
-     * for IDs. The IDs are then passed down the resolve tree, and deferred resolvers
-     * handle batch resolution of the posts.
-     *
-     * @return array
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_query_args(): array
-    {
-        $where_params = [];
-        $query_args = [];
-
-        $query_args['limit'] = $this->getLimit();
-
-        // Avoid multiple entries by join.
-        $query_args['group_by'] = 'VNU_ID';
-
-        $query_args['default_where_conditions'] = 'minimum';
-
-        /**
-         * Collect the input_fields and sanitize them to prepare them for sending to the Query
-         */
-        $input_fields = [];
-        if (! empty($this->args['where'])) {
-            $input_fields = $this->sanitizeInputFields($this->args['where']);
-        }
-
-        /**
-         * Determine where we're at in the Graph and adjust the query context appropriately.
-         * For example, if we're querying for datetime as a field of event query, this will automatically
-         * set the query to pull datetimes that belong to that event.
-         * We can set more cases for other source types.
-         */
-        if (is_object($this->source)) {
-            switch (true) {
-                // Assumed to be an event
-                case $this->source instanceof Post:
-                    $where_params['Event.EVT_ID'] = $this->source->ID;
-                    break;
-                case $this->source instanceof EE_Event:
-                    $where_params['Event.EVT_ID'] = $this->source->ID();
-                    break;
-            }
-        }
-
-        /**
-         * Merge the input_fields with the default query_args
-         */
-        if (! empty($input_fields)) {
-            $where_params = array_merge($where_params, $input_fields);
-        }
-
-        [$query_args, $where_params] = $this->mapOrderbyInputArgs($query_args, $where_params, 'VNU_ID');
-
-        $where_params = apply_filters(
-            'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__venue_where_params',
-            $where_params,
-            $this->source,
-            $this->args
-        );
-
-        $query_args[] = $where_params;
-
-        /**
-         * Return the $query_args
-         */
-        return apply_filters(
-            'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__venue_query_args',
-            $query_args,
-            $this->source,
-            $this->args
-        );
-    }
-
-
-    /**
-     * This sets up the "allowed" args, and translates the GraphQL-friendly keys to model
-     * friendly keys.
-     *
-     * @param array $where_args
-     * @return array
-     */
-    public function sanitizeInputFields(array $where_args): array
-    {
-        return $this->sanitizeWhereArgsForInputFields(
-            $where_args,
-            [],
-            []
-        );
-    }
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_loader_name(): string
+	{
+		return 'espresso_venue';
+	}
+
+	/**
+	 * @return EEM_Venue
+	 * @throws EE_Error
+	 * @throws InvalidArgumentException
+	 * @throws InvalidDataTypeException
+	 * @throws InvalidInterfaceException
+	 * @throws ReflectionException
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_query(): EEM_Venue
+	{
+		return EEM_Venue::instance();
+	}
+
+
+	/**
+	 * Return an array of item IDs from the query
+	 *
+	 * @return array
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_ids(): array
+	{
+		$results = $this->query->get_col($this->query_args);
+
+		return ! empty($results) ? $results : [];
+	}
+
+
+	/**
+	 * Here, we map the args from the input, then we make sure that we're only querying
+	 * for IDs. The IDs are then passed down the resolve tree, and deferred resolvers
+	 * handle batch resolution of the posts.
+	 *
+	 * @return array
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_query_args(): array
+	{
+		$where_params = [];
+		$query_args = [];
+
+		$query_args['limit'] = $this->getLimit();
+
+		// Avoid multiple entries by join.
+		$query_args['group_by'] = 'VNU_ID';
+
+		$query_args['default_where_conditions'] = 'minimum';
+
+		/**
+		 * Collect the input_fields and sanitize them to prepare them for sending to the Query
+		 */
+		$input_fields = [];
+		if (! empty($this->args['where'])) {
+			$input_fields = $this->sanitizeInputFields($this->args['where']);
+		}
+
+		/**
+		 * Determine where we're at in the Graph and adjust the query context appropriately.
+		 * For example, if we're querying for datetime as a field of event query, this will automatically
+		 * set the query to pull datetimes that belong to that event.
+		 * We can set more cases for other source types.
+		 */
+		if (is_object($this->source)) {
+			switch (true) {
+				// Assumed to be an event
+				case $this->source instanceof Post:
+					$where_params['Event.EVT_ID'] = $this->source->ID;
+					break;
+				case $this->source instanceof EE_Event:
+					$where_params['Event.EVT_ID'] = $this->source->ID();
+					break;
+			}
+		}
+
+		/**
+		 * Merge the input_fields with the default query_args
+		 */
+		if (! empty($input_fields)) {
+			$where_params = array_merge($where_params, $input_fields);
+		}
+
+		[$query_args, $where_params] = $this->mapOrderbyInputArgs($query_args, $where_params, 'VNU_ID');
+
+		$where_params = apply_filters(
+			'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__venue_where_params',
+			$where_params,
+			$this->source,
+			$this->args
+		);
+
+		$query_args[] = $where_params;
+
+		/**
+		 * Return the $query_args
+		 */
+		return apply_filters(
+			'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__venue_query_args',
+			$query_args,
+			$this->source,
+			$this->args
+		);
+	}
+
+
+	/**
+	 * This sets up the "allowed" args, and translates the GraphQL-friendly keys to model
+	 * friendly keys.
+	 *
+	 * @param array $where_args
+	 * @return array
+	 */
+	public function sanitizeInputFields(array $where_args): array
+	{
+		return $this->sanitizeWhereArgsForInputFields(
+			$where_args,
+			[],
+			[]
+		);
+	}
 }

core/domain/services/graphql/connection_resolvers/PriceTypeConnectionResolver.php

Indentation +64 added lines, -64 removed lines

@@ -14,79 +14,79 @@
  */
 class PriceTypeConnectionResolver extends AbstractConnectionResolver
 {
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_loader_name(): string
-    {
-        return 'espresso_priceType';
-    }
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_loader_name(): string
+	{
+		return 'espresso_priceType';
+	}
 
-    /**
-     * @return EEM_Price_Type
-     * @throws EE_Error
-     * @throws InvalidArgumentException
-     * @throws InvalidDataTypeException
-     * @throws InvalidInterfaceException
-     * @throws ReflectionException
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_query(): EEM_Price_Type
-    {
-        return EEM_Price_Type::instance();
-    }
+	/**
+	 * @return EEM_Price_Type
+	 * @throws EE_Error
+	 * @throws InvalidArgumentException
+	 * @throws InvalidDataTypeException
+	 * @throws InvalidInterfaceException
+	 * @throws ReflectionException
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_query(): EEM_Price_Type
+	{
+		return EEM_Price_Type::instance();
+	}
 
 
-    /**
-     * Return an array of item IDs from the query
-     *
-     * @return array
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_ids(): array
-    {
-        $results = $this->query->get_col($this->query_args);
+	/**
+	 * Return an array of item IDs from the query
+	 *
+	 * @return array
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_ids(): array
+	{
+		$results = $this->query->get_col($this->query_args);
 
-        return ! empty($results) ? $results : [];
-    }
+		return ! empty($results) ? $results : [];
+	}
 
 
-    /**
-     * Here, we map the args from the input, then we make sure that we're only querying
-     * for IDs. The IDs are then passed down the resolve tree, and deferred resolvers
-     * handle batch resolution of the posts.
-     *
-     * @return array
-     * @throws InvalidArgumentException
-     * @throws InvalidDataTypeException
-     * @throws InvalidInterfaceException
-     */
-    // phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
-    public function get_query_args(): array
-    {
-        $where_params = [];
-        $query_args   = [];
+	/**
+	 * Here, we map the args from the input, then we make sure that we're only querying
+	 * for IDs. The IDs are then passed down the resolve tree, and deferred resolvers
+	 * handle batch resolution of the posts.
+	 *
+	 * @return array
+	 * @throws InvalidArgumentException
+	 * @throws InvalidDataTypeException
+	 * @throws InvalidInterfaceException
+	 */
+	// phpcs:ignore PSR1.Methods.CamelCapsMethodName.NotCamelCaps
+	public function get_query_args(): array
+	{
+		$where_params = [];
+		$query_args   = [];
 
-        $query_args['limit'] = $this->getLimit();
+		$query_args['limit'] = $this->getLimit();
 
-        // Avoid multiple entries by join.
-        $query_args['group_by'] = 'PRT_ID';
+		// Avoid multiple entries by join.
+		$query_args['group_by'] = 'PRT_ID';
 
-        $where_params = apply_filters(
-            'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__priceType_where_params',
-            $where_params,
-            $this->source,
-            $this->args
-        );
+		$where_params = apply_filters(
+			'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__priceType_where_params',
+			$where_params,
+			$this->source,
+			$this->args
+		);
 
-        $query_args[] = $where_params;
+		$query_args[] = $where_params;
 
-        /**
-         * Return the $query_args
-         */
-        return apply_filters(
-            'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__priceType_query_args',
-            $query_args,
-            $this->source,
-            $this->args
-        );
-    }
+		/**
+		 * Return the $query_args
+		 */
+		return apply_filters(
+			'FHEE__EventEspresso_core_domain_services_graphql_connection_resolvers__priceType_query_args',
+			$query_args,
+			$this->source,
+			$this->args
+		);
+	}
 }