Logo
スキーマチュートリアル
スキーマチュートリアルレッスン30：アップストリームから複数のダウンストリームサイトへのコンテンツ配信

レッスン30：アップストリームから複数のダウンストリームサイトへのコンテンツ配信

メディア企業が地域ごとにWordPressサイトのネットワークを持っており、各ニュース記事はその地域に適している場合にのみ、そのサイトに公開されるとします。

このような状況では、以下のアーキテクチャを実装することが合理的です。

  • すべてのコンテンツを単一のアップストリームWordPressサイトに公開（および編集）し、コンテンツの唯一の真実の情報源として機能させる
  • 適切なコンテンツを各地域のダウンストリームWordPressサイトに配信する（ただし編集はしない）

このチュートリアルレッスンでは、このアーキテクチャの実装方法を説明します。アップストリームWordPressサイトには関連するGato GraphQL拡張機能を有効にする必要がありますが、ダウンストリームサイトには無料のGato GraphQLプラグインのみが必要です。

アップストリームからダウンストリームサイトへコンテンツを同期するGraphQLクエリ

（ダウンストリームサイトのみ） このGraphQLクエリを機能させるには、エンドポイントに適用されるスキーマ設定でネストされたミューテーションを有効にする必要があります。

以下のGraphQLクエリはアップストリームWordPressサイト上で実行され、更新された投稿のコンテンツを関連するダウンストリームサイトに同期します。サイト間の共通識別子として投稿スラッグを使用します。

（このクエリは、前のチュートリアルレッスンで説明されているように、タグ、カテゴリー、著者、アイキャッチ画像などの他のプロパティも同期するように適応できます。）

このクエリにはトランザクションロジックが含まれており、HTTPリクエストが失敗した場合（サーバーがダウンしている場合など）やGraphQLクエリがエラーを生成した場合（指定されたスラッグを持つ投稿が存在しない場合など）、ダウンストリームサイトのいずれかで更新が失敗すると、すべてのダウンストリームサイトでミューテーションが元に戻されます。

状態を元に戻すには、変数 $previousPostContent を指定する必要があります。この値は、WordPressの post_updated アクションにフックして渡すことができます。このアクションが発生した際にGraphQLクエリが実行されます（前のチュートリアルレッスンで説明したとおり）。

このクエリは以下を行います。

  • 更新された投稿のスラッグと、その新しいコンテンツおよび以前のコンテンツを受け取る
  • 投稿からメタプロパティ "downstream_domains" を取得する。これには投稿を配信するダウンストリームサイトのドメインの配列が含まれる
  • メタプロパティが存在しない場合（つまり値が null の場合）、wp_options テーブルからオプション "downstream_domains" を取得する。これにはすべてのダウンストリームドメインのリストが含まれる
  • 各ダウンストリームサイトにユーザーをログインさせ（簡素化のため同じ $username と $userPassword を使用）、投稿コンテンツを更新するミューテーションを実行する
  • いずれかのダウンストリームサイトがエラーを生成した場合、すべてのダウンストリームサイトでミューテーションを元に戻す
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
}

上記のGraphQLクエリでは、投稿のメタプロパティ "downstream_domains" が空の配列として定義されている場合、その投稿はどのダウンストリームサイトにも配信されません。

これは、関数フィールド _notNull と _notEmpty の違いによって実現できます（PHP Functions via Schema 拡張機能によって提供されます）。

  • メタプロパティ "downstream_domains" が定義されていない場合、その値は null であり、_notNull と _notEmpty の両方が false と評価されます
  • メタプロパティ "downstream_domains" が空の配列として定義されている場合、その値は [] であり、_notEmpty のみが false と評価されます