Class: EventSource::Postgres::Get::Last
- Inherits:
-
Object
- Object
- EventSource::Postgres::Get::Last
show all
- Includes:
- Log::Dependency
- Defined in:
- lib/event_source/postgres/get/last.rb,
lib/event_source/postgres/get/last/select_statement.rb
Defined Under Namespace
Modules: Deserialize, Time
Classes: SelectStatement
Class Method Summary
collapse
Instance Method Summary
collapse
Class Method Details
.build(session: nil) ⇒ Object
9
10
11
12
13
|
# File 'lib/event_source/postgres/get/last.rb', line 9
def self.build(session: nil)
new.tap do |instance|
instance.configure(session: session)
end
end
|
.call(stream_name, session: nil) ⇒ Object
25
26
27
28
|
# File 'lib/event_source/postgres/get/last.rb', line 25
def self.call(stream_name, session: nil)
instance = build(session: session)
instance.(stream_name)
end
|
15
16
17
18
19
|
# File 'lib/event_source/postgres/get/last.rb', line 15
def self.configure(receiver, attr_name: nil, session: nil)
attr_name ||= :get_last
instance = build(session: session)
receiver.public_send "#{attr_name}=", instance
end
|
Instance Method Details
#__convert(records) ⇒ Object
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
# File 'lib/event_source/postgres/get/last.rb', line 73
def __convert(records)
logger.trace { "Converting records to event data (Records Count: #{records.ntuples})" }
events = records.map do |record|
record['data'] = Deserialize.data(record['data'])
record['metadata'] = Deserialize.metadata(record['metadata'])
record['time'] = Time.utc_coerced(record['time'])
EventData::Read.build record
break
end
logger.debug { "Converted records to event data (Event Data Count: #{events.length})" }
events
end
|
#call(stream_name) ⇒ Object
30
31
32
33
34
35
36
37
38
39
40
41
42
43
|
# File 'lib/event_source/postgres/get/last.rb', line 30
def call(stream_name)
logger.trace { "Getting last event data (Stream Name: #{stream_name})" }
record = get_record(stream_name)
return nil if record.nil?
event = convert(record)
logger.info { "Finished getting event data (Stream Name: #{stream_name})" }
logger.info(tags: [:data, :event_data]) { event.pretty_inspect }
event
end
|
21
22
23
|
# File 'lib/event_source/postgres/get/last.rb', line 21
def configure(session: nil)
Session.configure self, session: session
end
|
#convert(record) ⇒ Object
59
60
61
62
63
64
65
66
67
68
69
70
71
|
# File 'lib/event_source/postgres/get/last.rb', line 59
def convert(record)
logger.trace { "Converting record to event data" }
record['data'] = Deserialize.data(record['data'])
record['metadata'] = Deserialize.metadata(record['metadata'])
record['time'] = Time.utc_coerced(record['time'])
event = EventData::Read.build(record)
logger.debug { "Converted record to event data" }
event
end
|
#get_record(stream_name) ⇒ Object
45
46
47
48
49
50
51
52
53
54
55
56
57
|
# File 'lib/event_source/postgres/get/last.rb', line 45
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
|