Class: Legion::Extensions::MicrosoftTeams::Actor::MeetingIngest

Inherits:
Actors::Every
  • Object
show all
Includes:
Helpers::Client
Defined in:
lib/legion/extensions/microsoft_teams/actors/meeting_ingest.rb

Constant Summary collapse

DEFAULT_INGEST_INTERVAL = 
300

Instance Method Summary collapse

Methods included from Helpers::Client

#bot_connection, #graph_connection, #oauth_connection, #user_path

Constructor Details

#initialize(**opts) ⇒ MeetingIngest

Returns a new instance of MeetingIngest.



19
20
21
22
 
# File 'lib/legion/extensions/microsoft_teams/actors/meeting_ingest.rb', line 19

def initialize(**opts)
  @processed_meetings = Set.new
  super
end

Instance Method Details

#check_subtask? ⇒ Boolean

Returns:

  • (Boolean) 


16
 
# File 'lib/legion/extensions/microsoft_teams/actors/meeting_ingest.rb', line 16

def check_subtask?  = false

#enabled? ⇒ Boolean

Returns:

  • (Boolean) 


34
35
36
37
38
39
 
# File 'lib/legion/extensions/microsoft_teams/actors/meeting_ingest.rb', line 34

def enabled?
  defined?(Legion::Extensions::MicrosoftTeams::Helpers::TokenCache)
rescue StandardError => e
  log.debug("MeetingIngest#enabled?: #{e.message}")
  false
end

#generate_task? ⇒ Boolean

Returns:

  • (Boolean) 


17
 
# File 'lib/legion/extensions/microsoft_teams/actors/meeting_ingest.rb', line 17

def generate_task?  = false

#manual ⇒ Object 



53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
 
# File 'lib/legion/extensions/microsoft_teams/actors/meeting_ingest.rb', line 53

def manual
  log.info('MeetingIngest polling for meetings')
  token = token_cache.cached_delegated_token
  return if token.nil?

  conn = graph_connection(token: token)
  response = conn.get("#{user_path('me')}/onlineMeetings")
  meetings = response.body&.dig('value') || []
  log.info("Found #{meetings.length} online meeting(s)")

  meetings.each do |meeting|
    meeting_id = meeting['id']
    next if @processed_meetings.include?(meeting_id)

    begin
      process_meeting(meeting_id: meeting_id, subject: meeting['subject'], token: token)
      @processed_meetings.add(meeting_id)
    rescue StandardError => e
      log.error("Failed to process meeting #{meeting_id}: #{e.message}")
    end
  end
rescue StandardError => e
  log.error("MeetingIngest: #{e.message}")
end

#memory_available? ⇒ Boolean

Returns:

  • (Boolean) 


41
42
43
 
# File 'lib/legion/extensions/microsoft_teams/actors/meeting_ingest.rb', line 41

def memory_available?
  defined?(Legion::Extensions::Agentic::Memory::Trace::Runners::Traces)
end

#memory_runner ⇒ Object 



45
46
47
 
# File 'lib/legion/extensions/microsoft_teams/actors/meeting_ingest.rb', line 45

def memory_runner
  @memory_runner ||= Object.new.extend(Legion::Extensions::Agentic::Memory::Trace::Runners::Traces)
end

#run_now? ⇒ Boolean

Returns:

  • (Boolean) 


14
 
# File 'lib/legion/extensions/microsoft_teams/actors/meeting_ingest.rb', line 14

def run_now?        = false

#runner_class ⇒ Object 



12
 
# File 'lib/legion/extensions/microsoft_teams/actors/meeting_ingest.rb', line 12

def runner_class    = Legion::Extensions::MicrosoftTeams::Helpers::TokenCache

#runner_function ⇒ Object 



13
 
# File 'lib/legion/extensions/microsoft_teams/actors/meeting_ingest.rb', line 13

def runner_function = 'cached_delegated_token'

#time ⇒ Object 



24
25
26
27
28
29
30
31
32
 
# File 'lib/legion/extensions/microsoft_teams/actors/meeting_ingest.rb', line 24

def time
  settings = begin
    Legion::Settings[:microsoft_teams] || {}
  rescue StandardError => e
    log.debug("MeetingIngest#time: #{e.message}")
    {}
  end
  settings.dig(:meetings, :ingest_interval) || DEFAULT_INGEST_INTERVAL
end

#token_cache ⇒ Object 



49
50
51
 
# File 'lib/legion/extensions/microsoft_teams/actors/meeting_ingest.rb', line 49

def token_cache
  Legion::Extensions::MicrosoftTeams::Helpers::TokenCache.instance
end

#use_runner? ⇒ Boolean

Returns:

  • (Boolean) 


15
 
# File 'lib/legion/extensions/microsoft_teams/actors/meeting_ingest.rb', line 15

def use_runner?     = false