class Doing::TimingImport

Public Class Methods

import(wwid, path, options: {}) click to toggle source

Imports a Timing report

@param wwid [WWID] The wwid object @param path [String] Path to JSON report file @param options [Hash] Additional Options

# File lib/doing/plugins/import/timing_import.rb, line 25
def self.import(wwid, path, options: {})
  exit_now! 'Path to JSON report required' if path.nil?
  section = options[:section] || Doing.setting('current_section')
  options[:no_overlap] ||= false
  options[:autotag] ||= Doing.auto_tag
  wwid.content.add_section(section) unless wwid.content.section?(section)

  add_tags = options[:tag] ? options[:tag].split(/[ ,]+/).map { |t| t.sub(/^@?/, '') } : []
  prefix = options[:prefix] || '[Timing.app]'
  exit_now! 'File not found' unless File.exist?(File.expand_path(path))

  data = JSON.parse(IO.read(File.expand_path(path)))
  new_items = []
  data.each do |entry|
    # Only process task entries
    next if entry.key?('activityType') && entry['activityType'] != 'Task'
    # Only process entries with a start and end date
    next unless entry.key?('startDate') && entry.key?('endDate')

    # Round down seconds and convert UTC to local time
    start_time = Time.parse(entry['startDate'].sub(/:\d\dZ$/, ':00Z')).getlocal
    end_time = Time.parse(entry['endDate'].sub(/:\d\dZ$/, ':00Z')).getlocal
    next unless start_time && end_time

    tags = entry['project'].split(/ ▸ /).map { |proj| proj.gsub(/[^a-z0-9]+/i, '').downcase }
    tags.concat(add_tags)
    title = "#{prefix} "
    title += entry.key?('activityTitle') && entry['activityTitle'] != '(Untitled Task)' ? entry['activityTitle'] : 'Working on'
    tags.each do |tag|
      if title =~ /\b#{tag}\b/i
        title.sub!(/\b#{tag}\b/i, "@#{tag}")
      else
        title += " @#{tag}"
      end
    end
    title = wwid.autotag(title) if options[:autotag]
    title += " @done(#{end_time.strftime('%Y-%m-%d %H:%M')})"
    title.gsub!(/ +/, ' ')
    title.strip!
    new_item = Item.new(start_time, title, section)
    new_item.note.add(entry['notes']) if entry.key?('notes')

    is_match = true

    if options[:search]
      is_match = new_item.search(options[:search], case_type: options[:case], negate: options[:not])
    end

    if is_match && options[:date_filter]
      is_match = start_time > options[:date_filter][0] && start_time < options[:date_filter][1]
      is_match = options[:not] ? !is_match : is_match
    end

    new_items.push(new_item) if is_match
  end
  total = new_items.count
  skipped = data.count - total
  Doing.logger.debug('Skipped:' , %(#{skipped} items, invalid type or no time interval)) if skipped.positive?

  new_items = wwid.filter_items(new_items, opt: options)
  filtered = skipped - new_items.count
  Doing.logger.debug('Skipped:' , %(#{filtered} items that didn't match filter criteria)) if filtered.positive?

  new_items = wwid.dedup(new_items, no_overlap: options[:no_overlap])
  dups = filtered - new_items.count
  Doing.logger.debug('Skipped:' , %(#{dups} items with overlapping times)) if dups.positive?

  new_items.map { |item| Hooks.trigger :pre_entry_add, self, item }

  wwid.content.concat(new_items)

  new_items.map { |item| Hooks.trigger :post_entry_added, self, item }

  Doing.logger.info('Imported:', %(#{new_items.count} items to #{section}))
end
settings() click to toggle source
# File lib/doing/plugins/import/timing_import.rb, line 11
def self.settings
  {
    trigger: 'tim(?:ing)?'
  }
end