Open Mercato Ruby SDK

# Your existing Spree / Solidus store creates an order in Open Mercato
def after_order_complete(order)
  OpenMercato::Resources::Sales::Order.create(
    channel_id:     ENV["MERCATO_CHANNEL_ID"],
    customer_email: order.email,
    lines:          order.line_items.map { |li| { sku: li.sku, qty: li.quantity } }
  )
end

OpenMercato::Webhooks::Handler.on("sales.orders.shipped") do |event|
  ShipmentNotifier.with(order_id: event.record_id).deliver_later
end

gem "open_mercato"

# config/initializers/open_mercato.rb
OpenMercato.configure do |config|
  config.api_url         = ENV["OPEN_MERCATO_URL"]
  config.api_key         = ENV["OPEN_MERCATO_API_KEY"]
  config.tenant_id       = ENV["OPEN_MERCATO_TENANT_ID"]
  config.organization_id = ENV["OPEN_MERCATO_ORG_ID"]
  config.webhook_secret  = ENV["OPEN_MERCATO_WEBHOOK_SECRET"]  # see Webhooks section

  # Optional
  config.timeout         = 30     # Request timeout (seconds)
  config.retry_count     = 3      # Retry on 429/5xx
  config.async_webhooks  = true   # Process webhooks via ActiveJob
  config.logger          = Rails.logger
end

# List products
products = OpenMercato::Resources::Catalog::Product.list(page: 1, page_size: 25)
products.each { |p| puts p.title }
products.total_pages  # => 5
products.next_page?   # => true

# Find a product
product = OpenMercato::Resources::Catalog::Product.find("uuid")

# Create a product
result = OpenMercato::Resources::Catalog::Product.create(
  title: "New Product",
  sku: "SKU-001",
  primary_currency_code: "USD"
)
# => { "id" => "new-uuid" }

# Update a product
OpenMercato::Resources::Catalog::Product.update("uuid", title: "Updated")

# Delete a product
OpenMercato::Resources::Catalog::Product.destroy("uuid")

# Other catalog resources
OpenMercato::Resources::Catalog::Variant.list
OpenMercato::Resources::Catalog::Price.list
OpenMercato::Resources::Catalog::Category.list
OpenMercato::Resources::Catalog::Offer.list
OpenMercato::Resources::Catalog::PriceKind.list
OpenMercato::Resources::Catalog::Tag.list

people = OpenMercato::Resources::Customers::Person.list
person = OpenMercato::Resources::Customers::Person.find("uuid")

companies = OpenMercato::Resources::Customers::Company.list
deals = OpenMercato::Resources::Customers::Deal.list
activities = OpenMercato::Resources::Customers::Activity.list

orders = OpenMercato::Resources::Sales::Order.list
order = OpenMercato::Resources::Sales::Order.find("uuid")

# Quotes with special actions
OpenMercato::Resources::Sales::Quote.accept("quote-id")
OpenMercato::Resources::Sales::Quote.convert_to_order("quote-id")
OpenMercato::Resources::Sales::Quote.send_quote("quote-id")

# Other sales resources
OpenMercato::Resources::Sales::OrderLine.list
OpenMercato::Resources::Sales::Payment.list
OpenMercato::Resources::Sales::Shipment.list
OpenMercato::Resources::Sales::Channel.list

results = OpenMercato::Resources::Search::Query.search("laptop", page: 1)
global_results = OpenMercato::Resources::Search::Query.global("laptop")
OpenMercato::Resources::Search::Query.reindex(entity_type: "products")

definitions = OpenMercato::Resources::Workflows::Definition.list
instances = OpenMercato::Resources::Workflows::Instance.list

# Signal a workflow instance
OpenMercato::Resources::Workflows::Instance.signal("instance-id", "approve", comment: "Looks good")

dictionaries = OpenMercato::Resources::Dictionaries::Dictionary.list
entries = OpenMercato::Resources::Dictionaries::Entry.list

# Filter with operators
products = OpenMercato::Resources::Catalog::Product.list(
  "filter[isActive][$eq]" => true,
  "filter[title][$ilike]" => "%laptop%",
  sort: "-created_at",
  page: 1,
  page_size: 50
)

# app/services/open_mercato_handlers.rb

# Exact match
OpenMercato::Webhooks::Handler.on("sales.orders.created") do |event|
  order_data = event.data
  event.record_id       # => "uuid"
  event.module_name     # => "sales"
  event.entity_name     # => "orders"
  event.action_name     # => "created"
  event.created?        # => true
  event.tenant_id       # => "tenant-uuid"
end

# Wildcard match (all sales events)
OpenMercato::Webhooks::Handler.on("sales.*") do |event|
  Rails.logger.info "Sales event: #{event.type}"
end

# Catch-all
OpenMercato::Webhooks::Handler.on("*") do |event|
  Rails.logger.info "Event: #{event.type}"
end

# Class-based handler
class OrderSyncHandler
  def call(event)
    Order.sync_from_mercato(event.data)
  end
end
OpenMercato::Webhooks::Handler.on("sales.orders.created", OrderSyncHandler.new)

begin
  OpenMercato::Resources::Catalog::Product.create(title: "")
rescue OpenMercato::ValidationError => e
  e.message       # => "Validation failed: title: can't be blank"
  e.field_errors  # => { "title" => ["can't be blank"] }
  e.details       # => [{ "path" => ["title"], "message" => "can't be blank" }]
rescue OpenMercato::AuthenticationError
  # 401 - invalid API key
rescue OpenMercato::ForbiddenError
  # 403 - insufficient permissions
rescue OpenMercato::NotFoundError
  # 404 - resource not found
rescue OpenMercato::RateLimitError
  # 429 - rate limited (auto-retried by default)
rescue OpenMercato::ServerError
  # 5xx - server error
rescue OpenMercato::Error => e
  # Base error class
end

# spec/rails_helper.rb or spec/spec_helper.rb
require "open_mercato/testing"

RSpec.configure do |config|
  config.include OpenMercato::Testing::RequestStubs
  config.include OpenMercato::Testing::WebhookHelpers

  config.before(:each) do
    OpenMercato::Testing.setup!
  end
end

RSpec.describe ProductSync do
  it "syncs products" do
    items = [OpenMercato::Testing::FakeResponses.product("title" => "Laptop")]
    stub_mercato_list("/api/catalog/products", items: items, "total" => 1)

    products = OpenMercato::Resources::Catalog::Product.list
    expect(products.first.title).to eq("Laptop")
  end

  it "handles creation" do
    stub_mercato_create("/api/catalog/products", response: { "id" => "new-uuid" })

    result = OpenMercato::Resources::Catalog::Product.create(title: "New")
    expect(result["id"]).to eq("new-uuid")
  end
end

RSpec.describe OrderHandler do
  include OpenMercato::Testing::WebhookHelpers

  it "processes order events" do
    received = nil
    OpenMercato::Webhooks::Handler.on("sales.orders.created") { |e| received = e }

    simulate_mercato_webhook("sales.orders.created", data: { "id" => "order-123" })

    expect(received.record_id).to eq("order-123")
  end

  it "generates signed requests" do
    request = signed_mercato_webhook_request("test.event", data: { "id" => "123" })
    # request[:payload] - JSON string
    # request[:headers] - Hash with X-OpenMercato-Signature and Content-Type
  end
end