Class: Krakow::FrameType Abstract

Inherits:

Object

• Object
• Krakow::FrameType

show all

Extended by:

Utils::Lazy::ClassMethods

Includes:

Utils::Lazy, Utils::Lazy::InstanceMethods

Defined in:

lib/krakow/frame_type.rb,
lib/krakow/frame_type/error.rb,
lib/krakow/frame_type/message.rb,
lib/krakow/frame_type/response.rb

Overview

Defined Under Namespace

Classes: Error, Message, Response

Constant Summary

FRAME_TYPE_MAP =

Registered frame types

[
  FrameType::Response,
  FrameType::Error,
  FrameType::Message
]

SIZE_BYTES =

Size bytes

4

Instance Attribute Summary (collapse)

• - (Hash) arguments included from Utils::Lazy::InstanceMethods readonly

  Argument hash.

Class Method Summary (collapse)

• + (nil) attribute(name, type, options = {}) extended from Utils::Lazy::ClassMethods

  Add new attributes to class.

• + (Array<Hash>) attributes(*args) extended from Utils::Lazy::ClassMethods

  Return attributes.

• + (FrameType) build(args = {})

  Build proper FrameType instance based on args.

• + (Hash) decode(bytes)

  Information about incoming frame.

• + (TrueClass) set_attributes(attrs) extended from Utils::Lazy::ClassMethods

  Directly set attribute hash.

Instance Method Summary (collapse)

• - (String) content

  Content of message.

• - (Object) initialize(args = {}) (also: #super_init) included from Utils::Lazy::InstanceMethods

  Create new instance.

• - (String) inspect included from Utils::Lazy::InstanceMethods
• - (Logger^?) log(*args) included from Utils::Logging

  Log message.

• - (String) to_s included from Utils::Lazy::InstanceMethods

41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

# File 'lib/krakow/frame_type.rb', line 41

def build(args={})
  klass = FRAME_TYPE_MAP[args[:type].to_i]
  if(klass == FrameType::Response)
    klass.new(:response => args[:data])
  elsif(klass == FrameType::Error)
    klass.new(:error => args[:data])
  elsif(klass == FrameType::Message)
    unpacked = args[:data].unpack("Q>s>a16a#{args[:size]}")
    klass.new(
      Hash[*([:timestamp, :attempts, :message_id, :message].zip(unpacked).flatten)]
    )
  else
    raise TypeError.new "Unknown frame type received: #{args[:type].inspect} - #{klass.inspect}"
  end
end

30
31
32
33

# File 'lib/krakow/frame_type.rb', line 30

def decode(bytes)
  size, type = bytes.unpack('l>l>')
  {:size => size - SIZE_BYTES, :type => type}
end

61
62
63

# File 'lib/krakow/frame_type.rb', line 61

def content
  raise NotImplementedError.new 'Content method not properly defined!'
end