Lição 30: Distribuindo conteúdo de um upstream para múltiplos sites downstream

Vamos imaginar que uma empresa de mídia possui uma rede de sites WordPress para diferentes regiões, com cada artigo sendo publicado em um site ou não apenas se for adequado para aquela região.

Para essa situação, faz sentido implementar uma arquitetura onde:

Todo o conteúdo é publicado (e editado) em um único site WordPress upstream, que funciona como a única fonte de verdade para o conteúdo
O conteúdo adequado é distribuído (mas não editado) para cada um dos sites WordPress downstream regionais

Esta lição do tutorial demonstrará como implementar essa arquitetura, com o site WordPress upstream precisando ter as extensões relevantes do Gato GraphQL ativas, enquanto os sites downstream precisam apenas do plugin gratuito do Gato GraphQL.

Query GraphQL para sincronizar conteúdo do upstream para os sites downstream

(Somente para os sites downstream) Para que esta query GraphQL funcione, a Configuração de Schema aplicada ao endpoint precisa ter as Mutations Aninhadas habilitadas

A query GraphQL abaixo é executada no site WordPress upstream, para sincronizar o conteúdo do post atualizado para os sites downstream relevantes, usando o slug do post como identificador comum entre os sites.

(A query pode ser adaptada para também sincronizar as outras propriedades — tags, categorias, autor e imagem destacada —, conforme explicado na lição anterior do tutorial.)

A query inclui lógica transacional, de modo que quando a atualização falha em qualquer site downstream, seja porque a requisição HTTP falhou (como quando o servidor está fora do ar) ou porque a query GraphQL produziu erros (como se não houver post com o slug fornecido), a mutation é então revertida em todos os sites downstream.

Para reverter o estado, a variável $previousPostContent deve ser fornecida. Podemos passar esse valor conectando-nos à action WordPress post_updated, no momento em que a query GraphQL é executada (conforme explicado em uma lição anterior do tutorial).

A query faz o seguinte:

Recebe o slug do post atualizado, e seu novo e anterior conteúdo
Recupera a propriedade meta "downstream_domains" do post, que contém um array com os domínios dos sites downstream para os quais o post deve ser distribuído
Se a propriedade meta não existir (ou seja, tiver valor null), recupera a opção "downstream_domains" da tabela wp_options, que contém a lista de todos os domínios downstream
Autentica o usuário em cada um dos sites downstream (usando o mesmo $username e $userPassword, por simplicidade) e executa a mutation para atualizar o conteúdo do post
Se algum site downstream produzir um erro, a mutation é revertida em todos os sites downstream

query InitializeDynamicVariables
  @configureWarningsOnExportingDuplicateVariable(enabled: false)
{
  initVariablesWithFalse: _echo(value: false)
    @export(as: "requestProducedErrors")
    @export(as: "anyErrorProduced")
    @export(as: "hasDownstreamDomains")
    @remove
}
 
query GetCustomDownstreamDomains($postSlug: String!)
  @depends(on: "InitializeDynamicVariables")
{
  post(by: { slug: $postSlug }, status: any)
    @fail(
      message: "There is no post in the upstream site with the provided slug"
      data: {
        slug: $postSlug
      }
    )
  {
    customDownstreamDomains: metaValues(key: "downstream_domains")
      @export(as: "downstreamDomains")
 
    hasDefinedCustomDownstreamDomains: _notNull(value: $__customDownstreamDomains)
      @export(as: "hasDefinedCustomDownstreamDomains")
      @remove
 
    hasCustomDownstreamDomains: _notEmpty(value: $__customDownstreamDomains)
      @export(as: "hasDownstreamDomains")
  }
 
  isMissingPostInUpstream: _isNull(value: $__post)
    @export(as: "isMissingPostInUpstream")
}
 
query GetAllDownstreamDomains
  @depends(on: "GetCustomDownstreamDomains")
  @skip(if: $isMissingPostInUpstream)
  @skip(if: $hasDefinedCustomDownstreamDomains)
{
  allDownstreamDomains: optionValues(name: "downstream_domains")
    @export(as: "downstreamDomains")
 
  hasAllDownstreamDomains: _notEmpty(value: $__allDownstreamDomains)
    @export(as: "hasDownstreamDomains")
}
 
############################################################
# (By default) Append "/graphql" to the domain, to point
# to that site's GraphQL single endpoint
############################################################
query ExportDownstreamGraphQLEndpointsAndQuery(
  $endpointPath: String! = "/graphql"
)
  @depends(on: "GetAllDownstreamDomains")
  @skip(if: $isMissingPostInUpstream)
  @include(if: $hasDownstreamDomains)
{
  downstreamGraphQLEndpoints: _echo(value: $downstreamDomains)
    @underEachArrayItem(
      passValueOnwardsAs: "domain"
    )
      @strAppend(string: $endpointPath)
    @export(as: "downstreamGraphQLEndpoints")
 
  query: _echo(value: """
    
mutation LoginUserAndUpdatePost(
  $username: String!
  $userPassword: String!
  $postSlug: String!
  $postContent: String!
) {
  loginUser(by: {
    credentials: {
      usernameOrEmail: $username,
      password: $userPassword
    }
  }) {
    userID
  }
 
  post(by: {slug: $postSlug})
    @fail(
      message: "There is no post in the downstream site with the provided slug"
      data: {
        slug: $postSlug
      }
    )
  {
    update(input: {
      contentAs: { html: $postContent },
    }) {
      status
      errors {
        __typename
        ...on ErrorPayload {
          message
        }
      }
      post {
        slug
        rawContent
      }
    }
  }
}
 
    """
  )
    @export(as: "query")
    @remove
}
 
query ExportSendGraphQLHTTPRequestInputs(
  $username: String!
  $userPassword: String!
  $postSlug: String!
  $newPostContent: String!
)
  @depends(on: "ExportDownstreamGraphQLEndpointsAndQuery")
  @skip(if: $isMissingPostInUpstream)
  @include(if: $hasDownstreamDomains)
{
  sendGraphQLHTTPRequestInputs: _echo(value: $downstreamGraphQLEndpoints)
    @underEachArrayItem(
      passValueOnwardsAs: "endpoint"
    )
      @applyField(
        name: "_echo",
        arguments: {
          value: {
            endpoint: $endpoint,
            query: $query,
            variables: [
              {
                name: "username",
                value: $username
              },
              {
                name: "userPassword",
                value: $userPassword
              },
              {
                name: "postSlug",
                value: $postSlug
              },
              {
                name: "postContent",
                value: $newPostContent
              }
            ]
          }
        },
        setResultInResponse: true
      )
    @export(as: "sendGraphQLHTTPRequestInputs")
    @remove
}
 
query SendGraphQLHTTPRequests
  @depends(on: "ExportSendGraphQLHTTPRequestInputs")
  @skip(if: $isMissingPostInUpstream)
  @include(if: $hasDownstreamDomains)
{
  downstreamGraphQLResponses: _sendGraphQLHTTPRequests(
    inputs: $sendGraphQLHTTPRequestInputs
  )
    @export(as: "downstreamGraphQLResponses")
 
  requestProducedErrors: _isNull(value: $__downstreamGraphQLResponses)
    @export(as: "requestProducedErrors")
    @export(as: "anyErrorProduced")
    @remove
}
 
query ExportGraphQLResponsesHaveErrors
  @depends(on: "SendGraphQLHTTPRequests")
  @skip(if: $isMissingPostInUpstream)
  @skip(if: $requestProducedErrors)
  @include(if: $hasDownstreamDomains)
{
  graphQLResponsesHaveErrors: _echo(value: $downstreamGraphQLResponses)    
    # Check if any GraphQL response has the "errors" entry
    @underEachArrayItem(
      passValueOnwardsAs: "response"
      affectDirectivesUnderPos: [1, 2]
    )
      @applyField(
        name: "_propertyIsSetInJSONObject"
        arguments: {
          object: $response
          by: {
            key: "errors"
          }
        }
        setResultInResponse: true
      )
    @export(as: "graphQLResponsesHaveErrors")
    @remove
}
 
query ValidateGraphQLResponsesHaveErrors
  @depends(on: "ExportGraphQLResponsesHaveErrors")
  @skip(if: $isMissingPostInUpstream)
  @skip(if: $requestProducedErrors)
  @include(if: $hasDownstreamDomains)
{
  anyGraphQLResponseHasErrors: _or(values: $graphQLResponsesHaveErrors)
    @export(as: "anyErrorProduced")
    @remove
}
 
query ExportRevertGraphQLHTTPRequestInputs(
  $username: String!
  $userPassword: String!
  $postSlug: String!
  $previousPostContent: String!
)
  @depends(on: "ValidateGraphQLResponsesHaveErrors")
  @include(if: $hasDownstreamDomains)
  @include(if: $anyErrorProduced)
{
  revertGraphQLHTTPRequestInputs: _echo(value: $downstreamGraphQLEndpoints)
    @underEachArrayItem(
      passValueOnwardsAs: "endpoint"
    )
      @applyField(
        name: "_echo",
        arguments: {
          value: {
            endpoint: $endpoint,
            query: $query,
            variables: [
              {
                name: "username",
                value: $username
              },
              {
                name: "userPassword",
                value: $userPassword
              },
              {
                name: "postSlug",
                value: $postSlug
              },
              {
                name: "postContent",
                value: $previousPostContent
              }
            ]
          }
        },
        setResultInResponse: true
      )
    @export(as: "revertGraphQLHTTPRequestInputs")
    @remove
}
 
query RevertGraphQLHTTPRequests
  @depends(on: "ExportRevertGraphQLHTTPRequestInputs")
  @skip(if: $isMissingPostInUpstream)
  @include(if: $hasDownstreamDomains)
  @include(if: $anyErrorProduced)
{
  revertGraphQLResponses: _sendGraphQLHTTPRequests(
    inputs: $sendGraphQLHTTPRequestInputs
  )
}
 
query ExecuteAll
  @depends(on: "RevertGraphQLHTTPRequests")
{
  id @remove
}

Na query GraphQL acima, um post não será distribuído para nenhum site downstream quando sua propriedade meta "downstream_domains" estiver definida com um array vazio como valor.

Isso é possível por causa da diferença entre os campos de função _notNull e _notEmpty (fornecidos pela extensão PHP Functions via Schema):

Se a propriedade meta "downstream_domains" não estiver definida, seu valor é null, e tanto _notNull quanto _notEmpty avaliam como false
Se a propriedade meta "downstream_domains" estiver definida como um array vazio, seu valor é [], e apenas _notEmpty avalia como false

​Query GraphQL para sincronizar conteúdo do upstream para os sites downstream

Query GraphQL para sincronizar conteúdo do upstream para os sites downstream