Class: Aircana::Contexts::Confluence

Inherits:
Object
  • Object
show all
Includes:
ConfluenceContent, ConfluenceHttp, ConfluenceLogging, ConfluenceSetup, HTTParty
Defined in:
lib/aircana/contexts/confluence.rb

Constant Summary collapse

LABEL_PREFIX = 
"global"

Instance Method Summary collapse

Methods included from ConfluenceSetup

#setup_httparty

Methods included from ConfluenceContent

#convert_to_markdown, #fetch_page_content, #log_pages_found, #preprocess_confluence_macros, #store_page_as_markdown

Methods included from ConfluenceHttp

#get_next_page_url, #get_page_content, #get_pages_for_label, #validate_response

Constructor Details

#initialize ⇒ Confluence

Returns a new instance of Confluence.



23
24
25
 
# File 'lib/aircana/contexts/confluence.rb', line 23

def initialize
  @local_storage = Local.new
end

Instance Method Details

#fetch_pages_for(kb_name:, label: nil) ⇒ Object 



27
28
29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/aircana/contexts/confluence.rb', line 27

def fetch_pages_for(kb_name:, label: nil)
  validate_configuration!
  setup_httparty

  label_to_search = label || kb_name
  pages = search_and_log_pages(label_to_search)
  return { pages_count: 0, sources: [] } if pages.empty?

  sources = process_pages_with_manifest(pages, kb_name, label_to_search)
  create_or_update_manifest(kb_name, sources)

  { pages_count: pages.size, sources: sources }
end

#process_pages(pages, kb_name) ⇒ Object 



76
77
78
79
80
 
# File 'lib/aircana/contexts/confluence.rb', line 76

def process_pages(pages, kb_name)
  ProgressTracker.with_batch_progress(pages, "Processing pages") do |page, _index|
    store_page_as_markdown(page, kb_name)
  end
end

#process_pages_with_manifest(pages, kb_name, label = nil) ⇒ Object 



82
83
84
85
86
87
88
89
90
91
92
 
# File 'lib/aircana/contexts/confluence.rb', line 82

def process_pages_with_manifest(pages, kb_name, label = nil)
  page_metadata = []
  existing_metadata = load_existing_page_metadata(kb_name)

  ProgressTracker.with_batch_progress(pages, "Processing pages") do |page, _index|
    store_page_as_markdown(page, kb_name)
    page_metadata << extract_page_metadata(page, kb_name, existing_metadata: existing_metadata)
  end

  build_source_metadata(kb_name, page_metadata, label)
end

#refresh_from_manifest(kb_name:) ⇒ Object 



41
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/aircana/contexts/confluence.rb', line 41

def refresh_from_manifest(kb_name:)
  sources = Manifest.sources_from_manifest(kb_name)
  return { pages_count: 0, sources: [] } if sources.empty?

  validate_configuration!
  setup_httparty

  confluence_sources = sources.select { |s| s["type"] == "confluence" }
  return { pages_count: 0, sources: [] } if confluence_sources.empty?

  all_pages = []
  labels_used = []

  confluence_sources.each do |source|
    label = source["label"] || kb_name
    labels_used << label
    pages = fetch_pages_by_label(label)
    all_pages.concat(pages)
  end

  return { pages_count: 0, sources: [] } if all_pages.empty?

  updated_sources = process_pages_with_manifest(all_pages, kb_name, labels_used.first)

  { pages_count: all_pages.size, sources: updated_sources }
end

#search_and_log_pages(label) ⇒ Object 



68
69
70
71
72
73
74
 
# File 'lib/aircana/contexts/confluence.rb', line 68

def search_and_log_pages(label)
  pages = ProgressTracker.("Searching for pages labeled '#{label}'") do
    fetch_pages_by_label(label)
  end
  log_pages_found(pages.size, label)
  pages
end