Я пытаюсь в режиме реального времени прослушивать новые списки, созданные из моего Vue.js применение.

Я следил за документацией graphql-ruby для подписок.

Когда я создаю новый список из rails console , я получаю сообщение об ошибке в журнале:

Журнал

 GraphqlChannel is transmitting the subscription confirmation
GraphqlChannel#execute({"query"=>"subscription listWasCreated {n  listWasCreated {n    list {n      titlen      __typenamen    }n    __typenamen  }n}n", "variables"=>{}, "operationName"=>"listWasCreated"})
GraphqlChannel transmitting {:result=>{"data"=>{}}, :more=>true}
GraphqlChannel is streaming from graphql-subscription:c56670f6-d59c-438a-896c-ba8c2d91d375
GraphqlChannel is streaming from graphql-event::listWasCreated:
  List Load (0.2ms)  SELECT "lists".* FROM "lists" WHERE "lists"."id" = $1 LIMIT $2  [["id", "0946b254-c86c-4a53-b6fc-b1b29e54fd70"], ["LIMIT", 1]]
There was an exception - RuntimeError(          Failed to implement ListWasCreated.list, tried:

          - `#<Class:0x00007fa0af083ed0>#list`, which did not exist
          - `List#list`, which did not exist
          - Looking up hash key `:list` or `"list"` on `#<List:0x00007fa0dfbdc748>`, but it wasn't a Hash

          To implement this field, define one of the methods above (and check for typos)
)
 

Код Ruby

 # app/graphql/types/subscription_type.rb
class Types::SubscriptionType < Types::BaseObject
  field :list_was_created, subscription: Subscriptions::ListWasCreated
end
 

 # app/graphql/subscriptions/list_was_created.rb
module Subscriptions
  class ListWasCreated < Subscriptions::BaseSubscription
    field :list, Types::ListType, null: false

    def list
      List.last
    end
  end
end
 

 # app/graphql/subscriptions/base_subscription.rb
module Subscriptions
  class BaseSubscription < GraphQL::Schema::Subscription
    # Hook up base classes
    object_class Types::BaseObject
    field_class Types::BaseField
    argument_class Types::BaseArgument
  end
end
 

 # app/graphql/types/list_type.rb
module Types
  class ListType < GraphQL::Schema::Object
    field :id, ID, null: false
    field :title, String, null: false
    field :status, String, null: false
  end
end
 

 # app/models/list.rb
class List < ApplicationRecord
  # Callbacks
  after_save :notify_subscriber

  def notify_subscriber
    ListouSchema.subscriptions.trigger(:list_was_created, {}, self)
  end
end
 

Подписка на запрос GQL

 subscription listWasCreated {
  listWasCreated {
    list {
      title
    }
  }
}
 

Мое неидеальное решение (слишком запутанное при нескольких подписках)

 # app/graphql/types/subscription_type.rb
class Types::SubscriptionType < Types::BaseObject
  field :list_was_created, Types::ListType, null: false
  def list_was_created
    List.last
  end
end
 

 subscription listWasCreated {
  listWasCreated {
    status
    title
  }
}
 

 GraphqlChannel is transmitting the subscription confirmation
GraphqlChannel#execute({"query"=>"subscription listWasCreated {n  listWasCreated {n    statusn    titlen    __typenamen  }n}n", "variables"=>{}, "operationName"=>"listWasCreated"})
  List Load (0.3ms)  SELECT "lists".* FROM "lists" ORDER BY "lists"."created_at" DESC LIMIT $1  [["LIMIT", 1]]
  ↳ app/graphql/types/subscription_type.rb:12:in `list_was_created'
GraphqlChannel transmitting {:result=>{"data"=>{"listWasCreated"=>{"status"=>"online", "title"=>"2021-01-31T18:29:44 01:00", "__typename"=>"List"}}}, :more=>true}
GraphqlChannel is streaming from graphql-subscription:edf5ce43-8838-4212-a9d8-8e660bafc4be
GraphqlChannel is streaming from graphql-event::listWasCreated:
  List Load (0.2ms)  SELECT "lists".* FROM "lists" WHERE "lists"."id" = $1 LIMIT $2  [["id", "e6561161-c15b-4cf3-8979-79085a1d1a94"], ["LIMIT", 1]]
  List Load (0.2ms)  SELECT "lists".* FROM "lists" ORDER BY "lists"."created_at" DESC LIMIT $1  [["LIMIT", 1]]
  ↳ app/graphql/types/subscription_type.rb:12:in `list_was_created'
[ActionCable] Broadcasting to graphql-subscription:edf5ce43-8838-4212-a9d8-8e660bafc4be: {:result=>{"data"=>{"listWasCreated"=>{"status"=>"online", "title"=>"2021-01-31T18:30:21 01:00", "__typename"=>"List"}}}, :more=>true}
GraphqlChannel transmitting {"result"=>{"data"=>{"listWasCreated"=>{"status"=>"online", "title"=>"2021-01-31T18:30:21 01:00", "__typename"=>"List"}}}, "more"=>true} (via streamed from graphql-subscription:edf5ce43-8838-4212-a9d8-8e660bafc4be)
 

Чего бы я хотел

Использование field :list_was_created, subscription: Subscriptions::ListWasCreated in app/graphql/types/subscription_type.rb , потому что это менее запутанно, и я могу добавить много полей

Я нашел решение…

Мне пришлось добавить методы subscribe и update

 # app/graphql/subscriptions/list_was_created.rb
module Subscriptions
  class ListWasCreated < Subscriptions::BaseSubscription
    field :list, Types::ListType, null: false

    def list
      List.last
    end

    def subscribe
      {
        list: list
      }
    end

    def update
      {
        list: list
      }
    end
  end
end