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

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.



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

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

Instance Method Details

#check_subtask? ⇒ Boolean

Returns:

  • (Boolean) 


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

def check_subtask?  = false

#enabled? ⇒ Boolean

Returns:

  • (Boolean) 


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

def enabled?
  settings.dig(:meeting_ingest, :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) 


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

def generate_task?  = false

#manual ⇒ Object 



42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/legion/extensions/microsoft_teams/actors/meeting_ingest.rb', line 42

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) 


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

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

#memory_runner ⇒ Object 



38
39
40
 
# File 'lib/legion/extensions/microsoft_teams/actors/meeting_ingest.rb', line 38

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

#run_now? ⇒ Boolean

Returns:

  • (Boolean) 


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

def run_now?        = false

#runner_class ⇒ Object 



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

def runner_class    = self.class

#runner_function ⇒ Object 



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

def runner_function = 'manual'

#time ⇒ Object 



22
23
24
 
# File 'lib/legion/extensions/microsoft_teams/actors/meeting_ingest.rb', line 22

def time
  settings.dig(:meeting_ingest, :interval)
end

#use_runner? ⇒ Boolean

Returns:

  • (Boolean) 


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

def use_runner?     = false