example.rb

# frozen_string_literal: true

require 'dapr/proto/runtime/v1/dapr_services_pb'

port = ENV.fetch('DAPR_GRPC_PORT', '5001')
dapr_uri = "localhost:#{port}"

client = Dapr::Proto::Runtime::V1::Dapr::Stub.new(dapr_uri, :this_channel_is_insecure)
client.publish_event(Dapr::Proto::Runtime::V1::PublishEventRequest.new(pubsub_name: 'pubsub', topic: 'sith',
                                                                       data: 'lala'))
puts('Published')

key = 'mykey'
store_name = 'statestore'
state = Dapr::Proto::Common::V1::StateItem.new(key:, value: 'my state')
req = Dapr::Proto::Runtime::V1::SaveStateRequest.new(store_name:, states: [state])
client.save_state(req)
puts('Saved!')

resp = client.get_state(Dapr::Proto::Runtime::V1::GetStateRequest.new(store_name:, key:))
puts('Got state!')
puts(resp)

client.delete_state(Dapr::Proto::Runtime::V1::DeleteStateRequest.new(store_name:, key:))
puts('Deleted!')