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?
  Legion::Extensions::Identity::Entra::Helpers::TokenManager.respond_to?(:load_token)
rescue StandardError => e
  handle_exception(e, level: :debug, operation: 'MeetingIngest#enabled?')
  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 



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

def manual
  log.info('MeetingIngest polling for meetings')
  token = Legion::Extensions::Identity::Entra::Helpers::TokenManager.load_token(:delegated)
  return if token.nil?

  conn = graph_connection(token: token)
  response = conn.get("#{user_path('me')}/onlineMeetings")
  meetings = response.body&.dig('value') || []
  log.info("MeetingIngest 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
      handle_exception(e, level: :error, operation: 'MeetingIngest#manual',
                       meeting_id: meeting_id)
    end
  end
rescue StandardError => e
  handle_exception(e, level: :error, operation: 'MeetingIngest#manual')
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    = self.class

#runner_function ⇒ Object 



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

def runner_function = 'manual'

#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
    handle_exception(e, level: :debug, operation: 'MeetingIngest#time')
    {}
  end
  settings.dig(:meetings, :ingest_interval) || DEFAULT_INGEST_INTERVAL
end

#use_runner? ⇒ Boolean

Returns:

  • (Boolean) 


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

def use_runner?     = false