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

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

Constant Summary

Constants included from Helpers::ThrottleAware

Helpers::ThrottleAware::DEFAULT_DEFERRAL, Helpers::ThrottleAware::MAX_DEFERRAL

Instance Method Summary collapse

Methods included from Helpers::ThrottleAware

#defer_for, #reset_throttle_deferral, #throttle_remaining, #throttle_suppressed?, #throttled_until, #with_throttle_deferral

Methods included from Helpers::Client

#bot_connection, #graph_connection, #oauth_connection, #user_path

Constructor Details

#initialize(**opts) ⇒ MeetingIngest

Returns a new instance of MeetingIngest.



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

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

Instance Method Details

#check_subtask? ⇒ Boolean

Returns:

  • (Boolean) 


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

def check_subtask?  = false

#enabled? ⇒ Boolean

Returns:

  • (Boolean) 


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

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) 


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

def generate_task?  = false

#manual ⇒ Object 



43
44
45
46
47
48
49
50
51
 
# File 'lib/legion/extensions/microsoft_teams/actors/meeting_ingest.rb', line 43

def manual
  log.info('MeetingIngest polling for meetings')
  # Defer the next run when Graph throttles the meetings listing
  # (the first, fixed call every tick makes); per-meeting throttles
  # are handled by the inner rescue below and don't change cadence.
  with_throttle_deferral { ingest_meetings }
rescue StandardError => e
  handle_exception(e, level: :error, operation: 'MeetingIngest#manual')
end

#memory_available? ⇒ Boolean

Returns:

  • (Boolean) 


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

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

#memory_runner ⇒ Object 



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

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

#run_now? ⇒ Boolean

Returns:

  • (Boolean) 


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

def run_now?        = false

#runner_class ⇒ Object 



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

def runner_class    = self.class

#runner_function ⇒ Object 



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

def runner_function = 'manual'

#time ⇒ Object 



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

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

#use_runner? ⇒ Boolean

Returns:

  • (Boolean) 


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

def use_runner?     = false