ynloultratech / graphql-bundle

src/Subscription/SubscriptionManager.php

Spacing +3 added lines, -3 removed lines

@@ -91,7 +91,7 @@ 
 
         array_walk_recursive(
             $data,
-            function (&$value, $key) {
+            function(&$value, $key) {
                 if (is_object($value)) {
                     throw new \RuntimeException(
                         sprintf('The object "%s" in key "%s" can\'t be part of publish data, only scalar values can be sent.', get_class($value), $key)
@@ -112,7 +112,7 @@ 
         $channels = array_keys($this->registry->getEndpoint()->getSubscriptionsResolvers());
         $this->pubSubHandler->consume(
             $channels,
-            function (SubscriptionMessage $message) use ($output, $debug) {
+            function(SubscriptionMessage $message) use ($output, $debug) {
                 /** @var Request $request */
                 $request = $message->getMeta()['request'];
                 $subscribedFilters = $message->getMeta()['arguments'] ?? [];
@@ -160,7 +160,7 @@ 
     {
         array_walk_recursive(
             $data,
-            function (&$value) {
+            function(&$value) {
                 if ($value instanceof NodeInterface) {
                     $value = IDEncoder::encode($value);
                 }

src/Subscription/SubscriptionLink.php

Indentation +1 added lines, -2 removed lines

@@ -19,8 +19,7 @@
 Can susbribe to a service using something like:
 
     new EventSource(subscription.url)
-
-**NOTE:** A subscription have a tll (Time to live), you must call a periodic request (heartbeat) to
+ **NOTE:** A subscription have a tll (Time to live), you must call a periodic request (heartbeat) to
 the `heartbeatUrl` in order to keep-alive the subscription. Otherwise the subscription will be not available
 after the specified ttl.
 ")

src/Subscription/PubSub/RedisPubSubHandler.php

Spacing +1 added lines, -1 removed lines

@@ -117,7 +117,7 @@
         try {
             $this->consumer->subscribe(
                 $channels,
-                function (\Redis $redis, $chan, $event) use ($dispatch) {
+                function(\Redis $redis, $chan, $event) use ($dispatch) {
                     while ($keys = $this->client->scan($iterator, "*$chan:*", 100)) {
                         [$filters, $data] = unserialize($event, [true]);
                         foreach ($keys as $key) {

src/DependencyInjection/Configuration.php

Indentation +106 added lines, -106 removed lines

@@ -51,51 +51,51 @@ 
     protected function configureSubscriptions(NodeBuilder $root)
     {
         $subscriptions = $root->arrayNode('subscriptions')
-                              ->info('Manage subscriptions settings')
-                              ->addDefaultsIfNotSet()
-                              ->children();
+                                ->info('Manage subscriptions settings')
+                                ->addDefaultsIfNotSet()
+                                ->children();
 
         $subscriptions->scalarNode('ttl')->defaultValue(Subscriber::DEFAULT_SUBSCRIPTION_TTL)
-                      ->info('Time to live for subscriptions. The subscription will be deleted after this time, a heartbeat is required to keep-alive');
+                        ->info('Time to live for subscriptions. The subscription will be deleted after this time, a heartbeat is required to keep-alive');
         $subscriptions->scalarNode('mercure_hub')->defaultValue('default');
         $subscriptions->scalarNode('pubsub_handler')->defaultValue(RedisPubSubHandler::class);
         $redis = $subscriptions->arrayNode('redis')->info('Configure redis server to use as subscription handler')
-                               ->addDefaultsIfNotSet()
-                               ->children();
+                                ->addDefaultsIfNotSet()
+                                ->children();
 
         $redis->scalarNode('host')->defaultValue('localhost');
         $redis->integerNode('port')->defaultValue(6379);
         $redis->integerNode('prefix')->defaultValue('GraphQLSubscription:')
-              ->info('Define custom prefix to avoid collisions between applications');
+                ->info('Define custom prefix to avoid collisions between applications');
     }
 
     protected function configureErrorHandling(NodeBuilder $root)
     {
         $errorHandling = $root->arrayNode('error_handling')
-                              ->info('It is important to handle errors and when possible, report these errors back to your users for information. ')
-                              ->addDefaultsIfNotSet()
-                              ->children();
+                                ->info('It is important to handle errors and when possible, report these errors back to your users for information. ')
+                                ->addDefaultsIfNotSet()
+                                ->children();
 
         $errorHandling->enumNode('validation_messages')
-                      ->values(['error', 'payload', 'both'])
-                      ->info('Where should be displayed validation messages.')
-                      ->defaultValue('error');
+                        ->values(['error', 'payload', 'both'])
+                        ->info('Where should be displayed validation messages.')
+                        ->defaultValue('error');
 
         //@deprecated since v1.1 snd should be deleted in 2.0, this is a compatibility flag
         $errorHandling->booleanNode('jwt_auth_failure_compatibility')
-                      ->info('Keep BC with oldest version of JWT Authentication errors')
-                      ->setDeprecated('Since v1.1 and will will be removed in the next mayor release')
-                      ->defaultFalse();
+                        ->info('Keep BC with oldest version of JWT Authentication errors')
+                        ->setDeprecated('Since v1.1 and will will be removed in the next mayor release')
+                        ->defaultFalse();
 
         $errorHandling->booleanNode('show_trace')->info('Show error trace in debug mode')->defaultFalse();
 
         $errorHandling->scalarNode('formatter')
-                      ->info('Formatter is responsible for converting instances of Error to an array')
-                      ->defaultValue(DefaultErrorFormatter::class);
+                        ->info('Formatter is responsible for converting instances of Error to an array')
+                        ->defaultValue(DefaultErrorFormatter::class);
 
         $errorHandling->scalarNode('handler')
-                      ->info('Handler is useful for error filtering and logging.')
-                      ->defaultValue(DefaultErrorHandler::class);
+                        ->info('Handler is useful for error filtering and logging.')
+                        ->defaultValue(DefaultErrorHandler::class);
 
         $controlledErrors = $errorHandling
             ->arrayNode('controlled_errors')
@@ -181,44 +181,44 @@ 
     protected function configureEndpoints(NodeBuilder $root)
     {
         $endpoints = $root->arrayNode('endpoints')
-                          ->useAttributeAsKey('name')
-                          ->validate()
-                          ->ifTrue(
-                              function ($v) {
-                                  return array_key_exists('default', $v);
-                              }
-                          )->thenInvalid('"default" can\'t be used as endpoint name, the system internally use this endpoint name to store the entire schema.')
-                          ->end()
-                          ->arrayPrototype()
-                          ->children();
+                            ->useAttributeAsKey('name')
+                            ->validate()
+                            ->ifTrue(
+                                function ($v) {
+                                    return array_key_exists('default', $v);
+                                }
+                            )->thenInvalid('"default" can\'t be used as endpoint name, the system internally use this endpoint name to store the entire schema.')
+                            ->end()
+                            ->arrayPrototype()
+                            ->children();
 
         $endpoints->arrayNode('roles')
-                  ->beforeNormalization()
-                  ->ifString()
-                  ->then(
-                      function ($v) {
-                          return preg_split('/\s*,\s*/', $v);
-                      }
-                  )
-                  ->end()
-                  ->prototype('scalar')
-                  ->end();
+                    ->beforeNormalization()
+                    ->ifString()
+                    ->then(
+                        function ($v) {
+                            return preg_split('/\s*,\s*/', $v);
+                        }
+                    )
+                    ->end()
+                    ->prototype('scalar')
+                    ->end();
 
         $endpoints->scalarNode('host')->example('^api\.backend\.');
         $endpoints->scalarNode('path')->example('/backend');
 
         $root->arrayNode('endpoint_alias')
-             ->info('Use alias to refer to multiple endpoints using only one name')
-             ->useAttributeAsKey('name')
-             ->beforeNormalization()
-             ->ifString()
-             ->then(
-                 function ($v) {
-                     return preg_split('/\s*,\s*/', $v);
-                 }
-             )
-             ->end()
-             ->variablePrototype();
+                ->info('Use alias to refer to multiple endpoints using only one name')
+                ->useAttributeAsKey('name')
+                ->beforeNormalization()
+                ->ifString()
+                ->then(
+                    function ($v) {
+                        return preg_split('/\s*,\s*/', $v);
+                    }
+                )
+                ->end()
+                ->variablePrototype();
 
         $root->scalarNode('endpoint_default')->info('Endpoint to apply to all definitions without explicit endpoint.');
 
@@ -229,7 +229,7 @@ 
         $graphiql = $root->arrayNode('graphiql')->addDefaultsIfNotSet()->children();
 
         $graphiql->scalarNode('title')
-                 ->defaultValue('GraphQL API Explorer');
+                    ->defaultValue('GraphQL API Explorer');
 
         $graphiql
             ->scalarNode('data_warning_message')
@@ -257,61 +257,61 @@ 
             ->defaultFalse();
 
         $authentication->scalarNode('login_message')
-                       ->defaultValue('Start exploring GraphQL API queries using your account’s data now.');
+                        ->defaultValue('Start exploring GraphQL API queries using your account’s data now.');
 
         $authenticationProvider = $authentication->arrayNode('provider')->children();
 
         //the updated version of `jwt` to use lexik authentication bundle
         $lexikJwt = $authenticationProvider->arrayNode('lexik_jwt')
-                                           ->canBeEnabled()
-                                           ->children();
+                                            ->canBeEnabled()
+                                            ->children();
 
         $lexikJwt->scalarNode('user_provider')
-                 ->isRequired()
-                 ->info('Name of the user provider to use');
+                    ->isRequired()
+                    ->info('Name of the user provider to use');
 
         $lexikJwt->scalarNode('username_label')
-                 ->defaultValue('Username');
+                    ->defaultValue('Username');
 
         $lexikJwt->scalarNode('password_label')
-                 ->defaultValue('Password');
+                    ->defaultValue('Password');
 
         $authenticationProvider->scalarNode('custom')
-                               ->defaultNull()
-                               ->info('Configure custom service to use as authentication provider');
+                                ->defaultNull()
+                                ->info('Configure custom service to use as authentication provider');
 
         //deprecated since v1.1 and should be deleted in v2.0
         $jwt = $authenticationProvider->arrayNode('jwt')
-                                      ->setDeprecated('Use lexik_jwt instead, this provider will be removed in the next mayor release.')
-                                      ->canBeEnabled()
-                                      ->children();
+                                        ->setDeprecated('Use lexik_jwt instead, this provider will be removed in the next mayor release.')
+                                        ->canBeEnabled()
+                                        ->children();
 
         $jwtLogin = $jwt->arrayNode('login')->children();
 
         $jwtLogin->scalarNode('url')
-                 ->info('Route name or URI to make the login process to retrieve the token.')
-                 ->isRequired();
+                    ->info('Route name or URI to make the login process to retrieve the token.')
+                    ->isRequired();
 
         $jwtLogin->scalarNode('username_parameter')
-                 ->defaultValue('username');
+                    ->defaultValue('username');
 
         $jwtLogin->scalarNode('username_label')
-                 ->defaultValue('Username');
+                    ->defaultValue('Username');
 
         $jwtLogin->scalarNode('password_parameter')
-                 ->defaultValue('password');
+                    ->defaultValue('password');
 
         $jwtLogin->scalarNode('password_label')
-                 ->defaultValue('Password');
+                    ->defaultValue('Password');
 
         $jwtLogin->enumNode('parameters_in')
-                 ->values(['form', 'query', 'header'])
-                 ->info('How pass parameters to request the token')
-                 ->defaultValue('form');
+                    ->values(['form', 'query', 'header'])
+                    ->info('How pass parameters to request the token')
+                    ->defaultValue('form');
 
         $jwtLogin->scalarNode('response_token_path')
-                 ->defaultValue('token')
-                 ->info('Where the token should be located in the response in case of JSON, set null if the response is the token.');
+                    ->defaultValue('token')
+                    ->info('Where the token should be located in the response in case of JSON, set null if the response is the token.');
 
         $jwtRequests = $jwt->arrayNode('requests')->addDefaultsIfNotSet()->children();
 
@@ -350,25 +350,25 @@ 
     {
         $pagination = $root->arrayNode('pagination')->addDefaultsIfNotSet()->children();
         $pagination->integerNode('limit')
-                   ->defaultValue(100)->info('Maximum limit allowed for all paginations');
+                    ->defaultValue(100)->info('Maximum limit allowed for all paginations');
     }
 
     protected function configurePluginNamespaceGlobalConfig(NodeBuilder $root)
     {
         $namespaces = $root->arrayNode('namespaces')
-                           ->info(
-                               'Group GraphQL schema using namespaced schemas. 
+                            ->info(
+                                'Group GraphQL schema using namespaced schemas. 
 On large schemas is  helpful to keep schemas grouped by bundle and node'
-                           )
-                           ->canBeEnabled()
-                           ->addDefaultsIfNotSet()
-                           ->children();
+                            )
+                            ->canBeEnabled()
+                            ->addDefaultsIfNotSet()
+                            ->children();
 
         $bundles = $namespaces->arrayNode('bundles')
-                              ->info('Group each bundle into a separate schema definition')
-                              ->canBeDisabled()
-                              ->addDefaultsIfNotSet()
-                              ->children();
+                                ->info('Group each bundle into a separate schema definition')
+                                ->canBeDisabled()
+                                ->addDefaultsIfNotSet()
+                                ->children();
 
         $bundles->scalarNode('query_suffix')
                 ->info('The following suffix will be used for bundle query groups')
@@ -403,29 +403,29 @@ 
                             ->children();
 
         $nodes->scalarNode('query_suffix')
-              ->info('The following suffix will be used to create the name for queries to the same node')
-              ->defaultValue('Query');
+                ->info('The following suffix will be used to create the name for queries to the same node')
+                ->defaultValue('Query');
 
         $nodes->scalarNode('mutation_suffix')
-              ->info('The following suffix will be used to create the name for mutations to the same node')
-              ->defaultValue('Mutation');
+                ->info('The following suffix will be used to create the name for mutations to the same node')
+                ->defaultValue('Mutation');
 
         $nodes->scalarNode('subscription_suffix')
-              ->info('The following suffix will be used to create the name for subscriptions to the same node')
-              ->defaultValue('Subscriptions');
+                ->info('The following suffix will be used to create the name for subscriptions to the same node')
+                ->defaultValue('Subscriptions');
 
         $nodes->variableNode('ignore')
-              ->info('The following nodes will be ignore for grouping, all definitions will be placed in the root query or mutation')
-              ->defaultValue(['Node']);
+                ->info('The following nodes will be ignore for grouping, all definitions will be placed in the root query or mutation')
+                ->defaultValue(['Node']);
 
         $nodes->arrayNode('aliases')
-              ->info(
-                  'Define aliases for nodes to set definitions inside other desired node name. 
+                ->info(
+                    'Define aliases for nodes to set definitions inside other desired node name. 
 Can be used to group multiple nodes or publish a node with a different group name'
-              )
-              ->example('InvoiceItem: Invoice')
-              ->useAttributeAsKey('name')
-              ->prototype('scalar');
+                )
+                ->example('InvoiceItem: Invoice')
+                ->useAttributeAsKey('name')
+                ->prototype('scalar');
     }
 
     private function configureSecurity(NodeBuilder $rootNode)
@@ -471,13 +471,13 @@ 
             ->children();
 
         $bcNode->variableNode('filters')
-               ->info('Keep deprecated "filters" argument in collections')
-               ->setDeprecated('v1.2')
-               ->defaultFalse();
+                ->info('Keep deprecated "filters" argument in collections')
+                ->setDeprecated('v1.2')
+                ->defaultFalse();
 
         $bcNode->variableNode('orderBy')
-               ->info('Keep deprecated "orderBy" argument in collections')
-               ->setDeprecated('v1.2')
-               ->defaultFalse();
+                ->info('Keep deprecated "orderBy" argument in collections')
+                ->setDeprecated('v1.2')
+                ->defaultFalse();
     }
 }

src/DependencyInjection/YnloGraphQLExtension.php

Indentation +12 added lines, -12 removed lines

@@ -105,7 +105,7 @@ 
         if ($config['graphiql']['authentication']['provider']['lexik_jwt']['enabled'] ?? false) {
             $providerName = sprintf('security.user.provider.concrete.%s', $config['graphiql']['authentication']['provider']['lexik_jwt']['user_provider']);
             $container->getDefinition(LexikJWTGraphiQLAuthenticator::class)
-                      ->setArgument(1, new Reference($providerName));
+                        ->setArgument(1, new Reference($providerName));
         } else {
             $container->removeDefinition(LexikJWTGraphiQLAuthenticator::class);
         }
@@ -114,14 +114,14 @@ 
 
         //build the ID encoder manager with configured encoder
         $container->getDefinition(IDEncoderManager::class)
-                  ->setPublic(true)
-                  ->replaceArgument(0, $container->getDefinition($config['id_encoder']));
+                    ->setPublic(true)
+                    ->replaceArgument(0, $container->getDefinition($config['id_encoder']));
 
 
         //endpoint definition
         $container->getDefinition(GraphQLEndpointController::class)
-                  ->addMethodCall('setErrorFormatter', [$container->getDefinition($config['error_handling']['formatter'])])
-                  ->addMethodCall('setErrorHandler', [$container->getDefinition($config['error_handling']['handler'])]);
+                    ->addMethodCall('setErrorFormatter', [$container->getDefinition($config['error_handling']['formatter'])])
+                    ->addMethodCall('setErrorHandler', [$container->getDefinition($config['error_handling']['handler'])]);
 
         $bundles = $container->getParameter('kernel.bundles');
         if (isset($bundles['MercureBundle'])) {
@@ -130,19 +130,19 @@ 
             $mercurePublisherReference = new Reference(sprintf('mercure.hub.%s.publisher', $mercureHub));
 
             $container->getDefinition(SubscriptionManager::class)
-                      ->addArgument($container->getDefinition($config['subscriptions']['pubsub_handler']))
-                      ->addArgument(new Parameter('kernel.secret'));
+                        ->addArgument($container->getDefinition($config['subscriptions']['pubsub_handler']))
+                        ->addArgument(new Parameter('kernel.secret'));
 
             $container->getDefinition(SubscriptionsController::class)
-                      ->addArgument($container->getDefinition($config['subscriptions']['pubsub_handler']))
-                      ->addMethodCall('setMercureHubUrl', [new Parameter('mercure.hubs'), $mercureHub]);
+                        ->addArgument($container->getDefinition($config['subscriptions']['pubsub_handler']))
+                        ->addMethodCall('setMercureHubUrl', [new Parameter('mercure.hubs'), $mercureHub]);
 
             $container->getDefinition(SubscriptionsHeartbeatController::class)
-                      ->addArgument($container->getDefinition($config['subscriptions']['pubsub_handler']))
-                      ->addMethodCall('setMercureHubUrl', [new Parameter('mercure.hubs'), $mercureHub]);
+                        ->addArgument($container->getDefinition($config['subscriptions']['pubsub_handler']))
+                        ->addMethodCall('setMercureHubUrl', [new Parameter('mercure.hubs'), $mercureHub]);
 
             $container->getDefinition(SubscriptionConsumerCommand::class)
-                      ->addArgument($mercurePublisherReference);
+                        ->addArgument($mercurePublisherReference);
 
             $container->getDefinition(GraphQLEndpointController::class)->addMethodCall('setPublisher', [$mercurePublisherReference]);
         } else {

Spacing +1 added lines, -1 removed lines

@@ -59,7 +59,7 @@
         $container->setParameter('graphql.namespaces', $config['namespaces'] ?? []);
         $container->setParameter('graphql.cors_config', $config['cors'] ?? []);
         $container->setParameter('graphql.graphiql', $config['graphiql'] ?? []);
-        $container->setParameter('graphql.graphiql_auth_jwt', $config['graphiql']['authentication']['provider']['jwt'] ?? []);//DEPRECATED
+        $container->setParameter('graphql.graphiql_auth_jwt', $config['graphiql']['authentication']['provider']['jwt'] ?? []); //DEPRECATED
         $container->setParameter('graphql.graphiql_auth_lexik_jwt', $config['graphiql']['authentication']['provider']['lexik_jwt'] ?? []);
         $container->setParameter('graphql.security.validation_rules', $config['security']['validation_rules'] ?? []);
         $container->setParameter('graphql.subscriptions.redis', $config['subscriptions']['redis'] ?? []);

src/Type/SubscriptionType.php

Spacing +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
     {
         $defaults = [
             'name' => 'Subscription',
-            'fields' => function () {
+            'fields' => function() {
                 $subscriptions = [];
                 foreach ($this->endpoint->allSubscriptions() as $subscription) {
                     $subscriptions[$subscription->getName()] = $this->getQueryConfig($subscription);

src/Type/Definition/UnionDefinitionType.php

Spacing +2 added lines, -2 removed lines

@@ -31,7 +31,7 @@ 
             [
                 'name' => $definition->getName(),
                 'description' => $definition->getDescription(),
-                'types' => function () use ($definition) {
+                'types' => function() use ($definition) {
                     $types = [];
                     $unionTypes = $definition->getTypes();
 
@@ -70,7 +70,7 @@ 
 
                     return $types;
                 },
-                'resolveType' => function ($value) {
+                'resolveType' => function($value) {
                     $type = TypeUtil::resolveObjectType($this->endpoint, $value);
                     if (!$type) {
                         throw new \RuntimeException(sprintf('Can`t resolve a valid type for object of class %s.', get_class($value)));

src/Type/Definition/InputObjectDefinitionType.php

Indentation +6 added lines, -6 removed lines

@@ -52,12 +52,12 @@
                 'resolveField' => function ($root, array $args, ResolverContext $context, ResolveInfo $resolveInfo) use ($definition) {
                     $resolver = new ObjectFieldResolver($this->container);
                     $context = ContextBuilder::create($context->getEndpoint())
-                                             ->setRoot($root)
-                                             ->setResolveInfo($resolveInfo)
-                                             ->setArgs($args)
-                                             ->setMetas($context->getMetas())
-                                             ->setDefinition($definition->getField($resolveInfo->fieldName))
-                                             ->build();
+                                                ->setRoot($root)
+                                                ->setResolveInfo($resolveInfo)
+                                                ->setArgs($args)
+                                                ->setMetas($context->getMetas())
+                                                ->setDefinition($definition->getField($resolveInfo->fieldName))
+                                                ->build();
 
 
                     return $resolver($root, $args, $context, $resolveInfo);

src/Type/Definition/ObjectDefinitionType.php

Indentation +6 added lines, -6 removed lines

@@ -41,12 +41,12 @@
                 'resolveField' => function ($root, array $args, ResolverContext $context, ResolveInfo $resolveInfo) use ($definition) {
                     $resolver = new ObjectFieldResolver($this->container);
                     $context = ContextBuilder::create($context->getEndpoint())
-                                             ->setRoot($root)
-                                             ->setResolveInfo($resolveInfo)
-                                             ->setArgs($args)
-                                             ->setMetas($context->getMetas())
-                                             ->setDefinition($definition->getField($resolveInfo->fieldName))
-                                             ->build();
+                                                ->setRoot($root)
+                                                ->setResolveInfo($resolveInfo)
+                                                ->setArgs($args)
+                                                ->setMetas($context->getMetas())
+                                                ->setDefinition($definition->getField($resolveInfo->fieldName))
+                                                ->build();
 
 
                     return $resolver($root, $args, $context, $resolveInfo);