Contents

# frozen_string_literal: true

require 'dapr/proto/runtime/v1/appcallback_services_pb'
require 'json'

class AppCallbackService < Dapr::Proto::Runtime::V1::AppCallback::Service
  Any = Google::Protobuf::Any
  Protocol = Dapr::Proto::Runtime::V1

  def on_invoke(invoke, _call)
    # Be careful! method() is a builtin method in Ruby
    method = invoke['method']
    raw_data = invoke.data
    puts "invoked method '#{method}' with data '#{raw_data}'!"
    data = JSON.parse(raw_data.value) if raw_data&.value
    result = { method:, data: }
    Dapr::Proto::Common::V1::InvokeResponse.new(data: Any.new(value: result.to_json))
  rescue StandardError => e
    Dapr::Proto::Common::V1::InvokeResponse.new(data: Any.new(value: { error: e.inspect }.to_json))
  end

  def list_topic_subscriptions(_empty, _call)
    puts 'topics requested!'
    pubsub_name = 'pubsub'
    Protocol::ListTopicSubscriptionsResponse
      .new(subscriptions: Array(Protocol::TopicSubscription.new(pubsub_name:, topic: 'example')))
  end

  def list_input_bindings(_empty, _call)
    puts 'bindings requested!'
    bindings = %w[binding]
    Protocol::ListInputBindingsResponse.new(bindings:)
  end

  def on_binding_event(binding_event, _call)
    puts 'binding event!'
    name = binding_event.name
    raw_data = binding_event.data
    _metadata = binding_event.metadata
    puts "Binding Event: name:#{name}, data: #{raw_data}"
    Protocol::BindingEventResponse.new # data: Any.new(value:)
  end

  def on_topic_event(topic_event, _call)
    puts 'topic event!'
    topic = topic_event.topic
    raw_data = topic_event.data
    puts "Topic Event: topic:#{topic}, data: #{raw_data}"
    Google::Protobuf::Empty.new
  rescue StandardError => e
    puts e.inspect
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
dapr-ruby-1.14.4	examples/app-callback/app_callback_service.rb
dapr-ruby-0.4.5	examples/app-callback/app_callback_service.rb
dapr-ruby-0.4.4	examples/app-callback/app_callback_service.rb
dapr-ruby-0.4.3	examples/app-callback/app_callback_service.rb