Sha256: 69fc74283e34939cc18cc04a6cc7d62803b065e16a43986a42e94ac189c746ba
Contents?: true
Size: 1.66 KB
Versions: 8
Compression:
Stored size: 1.66 KB
Contents
require 'faraday'
require 'json'
module SearchKit
module Clients
class Subscribers
attr_reader :connection, :token
def initialize
uri = [ SearchKit.config.app_uri, "subscribers" ].join("/")
@connection = Faraday.new(uri)
@token = SearchKit.config.app_token
end
def create(options = {})
options = { data: { type: 'subscribers', attributes: options } }
response = connection.post("", options)
body = JSON.parse(response.body, symbolize_names: true)
fail Errors::BadRequest if response.status == 400
fail Errors::Unprocessable if response.status == 422
SearchKit::Models::Subscriber.new body.fetch(:data, {})
end
def info
response = connection.get("", token: token)
body = JSON.parse(response.body, symbolize_names: true)
fail Errors::Unauthorized if response.status == 401
fail Errors::SubscriberNotFound if response.status == 404
SearchKit::Models::Subscriber.new body.fetch(:data, {})
end
def update(options = {})
options = {
token: token, data: { type: 'subscribers', attributes: options }
}
response = connection.patch("", options)
body = JSON.parse(response.body, symbolize_names: true)
fail Errors::BadRequest if response.status == 400
fail Errors::Unauthorized if response.status == 401
fail Errors::SubscriberNotFound if response.status == 404
fail Errors::Unprocessable if response.status == 422
SearchKit::Models::Subscriber.new body.fetch(:data, {})
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems