Module: CodexNotify::SessionLog

Defined in:
lib/codex_notify/session_log.rb

Class Method Summary collapse

Class Method Details

.find_latest_session_file(sessions_dir) ⇒ Object 



28
29
30
31
32
33
34
35
36
 
# File 'lib/codex_notify/session_log.rb', line 28

def find_latest_session_file(sessions_dir)
  root = Pathname(sessions_dir)
  return nil unless root.exist?

  files = root.glob('**/*.jsonl').select(&:file?)
  return nil if files.empty?

  files.max_by { |path| path.stat.mtime.to_f }
end

.iter_follow_lines(path, poll_sec: 1.0, once: false, start_at_end: true, sleep_func: Kernel.method(:sleep)) ⇒ Object 



10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
 
# File 'lib/codex_notify/session_log.rb', line 10

def iter_follow_lines(path, poll_sec: 1.0, once: false, start_at_end: true, sleep_func: Kernel.method(:sleep))
  return enum_for(__method__, path, poll_sec:, once:, start_at_end:, sleep_func:) unless block_given?

  Pathname(path).open('r:utf-8') do |handle|
    handle.seek(0, IO::SEEK_END) if start_at_end
    loop do
      line = handle.gets
      if line
        yield line
        next
      end
      break if once

      sleep_func.call(poll_sec)
    end
  end
end

.session_id_from_log(path) ⇒ Object 



38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
 
# File 'lib/codex_notify/session_log.rb', line 38

def session_id_from_log(path)
  pathname = Pathname(path)
  return nil unless pathname.exist?

  pathname.open('r:utf-8') do |handle|
    handle.each_line do |raw|
      line = raw.strip
      next if line.empty?

      event = JSON.parse(line)
      session_id = CodexNotify::LogEventParser.extract_session_id(event)
      return session_id if session_id
    rescue JSON::ParserError
      next
    end
  end

  nil
end

.session_id_from_path(path) ⇒ Object 



58
59
60
61
 
# File 'lib/codex_notify/session_log.rb', line 58

def session_id_from_path(path)
  pathname = Pathname(path)
  pathname.basename('.jsonl').to_s
end