Sha256: ab2b66de3da00c1ebccac0712dc99a786785c07c887d20e768aa0d3ca6992884

Contents?: true

Size: 514 Bytes

Versions: 38

Compression:

Stored size: 514 Bytes

Contents

module Rpush
  module Daemon
    module Rpc
      class Client
        def initialize(pid)
          @socket = UNIXSocket.open(Rpc.socket_path(pid))
        end

        def status
          call(:status)
        end

        def close
          @socket.close
        rescue StandardError # rubocop:disable Lint/HandleExceptions
        end

        private

        def call(cmd, args = {})
          @socket.puts(JSON.dump([cmd, args]))
          JSON.parse(@socket.gets)
        end
      end
    end
  end
end

Version data entries

38 entries across 38 versions & 2 rubygems

Version Path
rpush-9.2.0 lib/rpush/daemon/rpc/client.rb
rpush-9.1.0 lib/rpush/daemon/rpc/client.rb
rpush-9.0.0 lib/rpush/daemon/rpc/client.rb
rpush-8.0.0 lib/rpush/daemon/rpc/client.rb
rpush-7.0.1 lib/rpush/daemon/rpc/client.rb
rpush-7.0.0 lib/rpush/daemon/rpc/client.rb
rpush-6.0.1 lib/rpush/daemon/rpc/client.rb
rpush-6.0.0 lib/rpush/daemon/rpc/client.rb
rpush-5.4.0 lib/rpush/daemon/rpc/client.rb
rpush-5.3.0 lib/rpush/daemon/rpc/client.rb
rpush-5.2.0 lib/rpush/daemon/rpc/client.rb
rpush-5.1.0 lib/rpush/daemon/rpc/client.rb
rpush-5.0.0 lib/rpush/daemon/rpc/client.rb
rpush-4.2.0 lib/rpush/daemon/rpc/client.rb
rpush-4.1.1 lib/rpush/daemon/rpc/client.rb
rpush-4.1.0 lib/rpush/daemon/rpc/client.rb
rpush-4.0.1 lib/rpush/daemon/rpc/client.rb
rpush-4.0.0 lib/rpush/daemon/rpc/client.rb
rpush-3.3.1 lib/rpush/daemon/rpc/client.rb
rpush-3.3.0 lib/rpush/daemon/rpc/client.rb