Class: MessageStore::Postgres::Get::Last

Inherits:
Object
  • Object
show all
Includes:
Get::Last
Defined in:
lib/message_store/postgres/get/last.rb,
lib/message_store/postgres/get/last/select_statement.rb

Defined Under Namespace

Modules: Deserialize, Time Classes: SelectStatement

Instance Method Summary collapse

Instance Method Details

#__convert(records) ⇒ Object 



56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
 
# File 'lib/message_store/postgres/get/last.rb', line 56

def __convert(records)
  logger.trace { "Converting records to message data (Records Count: #{records.ntuples})" }

  messages = records.map do |record|
    record['data'] = Deserialize.data(record['data'])
    record['metadata'] = Deserialize.metadata(record['metadata'])
    record['time'] = Time.utc_coerced(record['time'])

    MessageData::Read.build record

    break
  end

  logger.debug { "Converted records to message data (Message Data Count: #{messages.length})" }

  messages
end

#call(stream_name) ⇒ Object 



13
14
15
16
17
18
19
20
21
22
23
24
25
26
 
# File 'lib/message_store/postgres/get/last.rb', line 13

def call(stream_name)
  logger.trace { "Getting last message data (Stream Name: #{stream_name})" }

  record = get_record(stream_name)

  return nil if record.nil?

  message_data = convert(record)

  logger.info { "Finished getting message data (Stream Name: #{stream_name})" }
  logger.info(tags: [:data, :message_data]) { message_data.pretty_inspect }

  message_data
end

#configure(session: nil) ⇒ Object 



9
10
11
 
# File 'lib/message_store/postgres/get/last.rb', line 9

def configure(session: nil)
  Session.configure(self, session: session)
end

#convert(record) ⇒ Object 



42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/message_store/postgres/get/last.rb', line 42

def convert(record)
  logger.trace { "Converting record to message data" }

  record['data'] = Deserialize.data(record['data'])
  record['metadata'] = Deserialize.metadata(record['metadata'])
  record['time'] = Time.utc_coerced(record['time'])

  message_data = MessageData::Read.build(record)

  logger.debug { "Converted record to message data" }

  message_data
end

#get_record(stream_name) ⇒ Object 



28
29
30
31
32
33
34
35
36
37
38
39
40
 
# File 'lib/message_store/postgres/get/last.rb', line 28

def get_record(stream_name)
  logger.trace { "Getting last record (Stream: #{stream_name})" }

  select_statement = SelectStatement.build(stream_name)

  records = session.execute(select_statement.sql)

  logger.debug { "Finished getting record (Stream: #{stream_name})" }

  return nil if records.ntuples == 0

  records[0]
end