class SearchKit::CLI::Events
Public Instance Methods
client()
click to toggle source
# File lib/search_kit/cli/events.rb, line 12 def client @client ||= SearchKit::Clients::Events.new end
complete(id)
click to toggle source
# File lib/search_kit/cli/events.rb, line 22 def complete(id) client.complete(id) messages.info I18n.t('cli.events.complete.success', id: id) rescue Errors::EventNotFound messages.not_found rescue Faraday::ConnectionFailed messages.no_service end
messages()
click to toggle source
# File lib/search_kit/cli/events.rb, line 16 def messages @messages ||= SearchKit::Messages.new end
pending(channel = nil)
click to toggle source
# File lib/search_kit/cli/events.rb, line 32 def pending(channel = nil) events = channel ? client.pending(channel) : client.index message_path = %w(cli events pending success) message_path << (channel ? 'filtered' : 'index') message_path << (events.any? ? 'discovered' : 'empty') message = I18n.t(message_path.join('.'), channel: channel) messages.info(message) events.each { |event| messages.info(event.to_json) } rescue Errors::BadRequest messages.bad_request rescue Errors::Unauthorized messages.unauthorized rescue Errors::Unprocessable messages.unprocessable rescue Faraday::ConnectionFailed messages.no_service end
publish(channel, payload)
click to toggle source
# File lib/search_kit/cli/events.rb, line 53 def publish(channel, payload) payload = JSON.parse(payload, symbolize_names: true) event = client.publish(channel, payload) message = I18n.t('cli.events.publish.success', channel: channel, id: event.id ) messages.info(message) rescue Errors::BadRequest messages.bad_request rescue Errors::Unauthorized messages.unauthorized rescue Errors::Unprocessable messages.unprocessable rescue Faraday::ConnectionFailed messages.no_service rescue JSON::ParserError messages.json_parse_error end
status(id)
click to toggle source
# File lib/search_kit/cli/events.rb, line 76 def status(id) event = client.show(id) status = event.state message = I18n.t('cli.events.status.success', id: id, status: status) messages.info(message) rescue Errors::EventNotFound messages.not_found rescue Faraday::ConnectionFailed messages.no_service end