class TransactedGHTorrent

A version of the GHTorrent class that creates a transaction per processed item

Public Instance Methods

check_transaction() { |block| ... } click to toggle source
# File lib/ghtorrent/transacted_gh_torrent.rb, line 112
def check_transaction(&block)
  if get_db.in_transaction?
    yield block
  else
    transaction do
      yield block
    end
  end
end
ensure_commit(repo, sha, user, comments = true) click to toggle source
Calls superclass method GHTorrent::Mirror#ensure_commit
# File lib/ghtorrent/transacted_gh_torrent.rb, line 14
def ensure_commit(repo, sha, user, comments = true)
  check_transaction do
    super(repo, sha, user, comments)
  end
end
ensure_commit_comment(owner, repo, sha, comment_id) click to toggle source
Calls superclass method GHTorrent::Mirror#ensure_commit_comment
# File lib/ghtorrent/transacted_gh_torrent.rb, line 20
def ensure_commit_comment(owner, repo, sha, comment_id)
  check_transaction do
    super(owner, repo, sha, comment_id)
  end
end
ensure_fork(owner, repo, fork_id) click to toggle source
Calls superclass method GHTorrent::Mirror#ensure_fork
# File lib/ghtorrent/transacted_gh_torrent.rb, line 26
def ensure_fork(owner, repo, fork_id)
  check_transaction do
    super(owner, repo, fork_id)
  end
end
ensure_fork_commits(owner, repo, parent_owner, parent_repo) click to toggle source
Calls superclass method GHTorrent::Mirror#ensure_fork_commits
# File lib/ghtorrent/transacted_gh_torrent.rb, line 32
def ensure_fork_commits(owner, repo, parent_owner, parent_repo)
  check_transaction do
    super(owner, repo, parent_owner, parent_repo)
  end
end
ensure_issue(owner, repo, issue_id, events = true, comments = true, labels = true) click to toggle source
Calls superclass method GHTorrent::Mirror#ensure_issue
# File lib/ghtorrent/transacted_gh_torrent.rb, line 52
def ensure_issue(owner, repo, issue_id, events = true, comments = true, labels = true)
  check_transaction do
    super(owner, repo, issue_id, events, comments, labels)
  end
end
ensure_issue_comment(owner, repo, issue_id, comment_id, pull_req_id = nil) click to toggle source
Calls superclass method GHTorrent::Mirror#ensure_issue_comment
# File lib/ghtorrent/transacted_gh_torrent.rb, line 64
def ensure_issue_comment(owner, repo, issue_id, comment_id, pull_req_id = nil)
  check_transaction do
    super(owner, repo, issue_id, comment_id, pull_req_id)
  end
end
ensure_issue_event(owner, repo, issue_id, event_id) click to toggle source
Calls superclass method GHTorrent::Mirror#ensure_issue_event
# File lib/ghtorrent/transacted_gh_torrent.rb, line 58
def ensure_issue_event(owner, repo, issue_id, event_id)
  check_transaction do
    super(owner, repo, issue_id, event_id)
  end
end
ensure_issue_label(owner, repo, issue_id, name) click to toggle source
Calls superclass method GHTorrent::Mirror#ensure_issue_label
# File lib/ghtorrent/transacted_gh_torrent.rb, line 70
def ensure_issue_label(owner, repo, issue_id, name)
  check_transaction do
    super(owner, repo, issue_id, name)
  end
end
ensure_org(user, members = true) click to toggle source
Calls superclass method GHTorrent::Mirror#ensure_org
# File lib/ghtorrent/transacted_gh_torrent.rb, line 106
def ensure_org(user, members = true)
  check_transaction do
    super(user, members)
  end
end
ensure_orgs(user) click to toggle source
Calls superclass method GHTorrent::Mirror#ensure_orgs
# File lib/ghtorrent/transacted_gh_torrent.rb, line 100
def ensure_orgs(user)
  check_transaction do
    super(user)
  end
end
ensure_project_member(owner, repo, new_member, date_added) click to toggle source
Calls superclass method GHTorrent::Mirror#ensure_project_member
# File lib/ghtorrent/transacted_gh_torrent.rb, line 76
def ensure_project_member(owner, repo, new_member, date_added)
  check_transaction do
    super(owner, repo, new_member, date_added)
  end
end
ensure_pull_request(owner, repo, pullreq_id, comments = true, commits = true, history = true, state = nil, actor = nil, created_at = nil) click to toggle source
Calls superclass method GHTorrent::Mirror#ensure_pull_request
# File lib/ghtorrent/transacted_gh_torrent.rb, line 38
def ensure_pull_request(owner, repo, pullreq_id,
                        comments = true, commits = true, history = true,
                        state = nil, actor = nil, created_at = nil)
  check_transaction do
    super(owner, repo, pullreq_id, comments, commits, history, state, actor, created_at)
  end
end
ensure_pullreq_comment(owner, repo, pullreq_id, comment_id) click to toggle source
# File lib/ghtorrent/transacted_gh_torrent.rb, line 46
def ensure_pullreq_comment(owner, repo, pullreq_id, comment_id)
  check_transaction do
    super(owner, repo, pullreq_id, comment_id)
  end
end
ensure_repo(owner, repo, recursive = false) click to toggle source
Calls superclass method GHTorrent::Mirror#ensure_repo
# File lib/ghtorrent/transacted_gh_torrent.rb, line 8
def ensure_repo(owner, repo, recursive = false)
  check_transaction do
    super(owner, repo, recursive)
  end
end
ensure_repo_label(owner, repo, name) click to toggle source
Calls superclass method GHTorrent::Mirror#ensure_repo_label
# File lib/ghtorrent/transacted_gh_torrent.rb, line 88
def ensure_repo_label(owner, repo, name)
  check_transaction do
    super(owner, repo, name)
  end
end
ensure_user_followers(user) click to toggle source
Calls superclass method GHTorrent::Mirror#ensure_user_followers
# File lib/ghtorrent/transacted_gh_torrent.rb, line 94
def ensure_user_followers(user)
  check_transaction do
    super(user)
  end
end
ensure_watcher(owner, repo, watcher, date_added = nil) click to toggle source
Calls superclass method GHTorrent::Mirror#ensure_watcher
# File lib/ghtorrent/transacted_gh_torrent.rb, line 82
def ensure_watcher(owner, repo, watcher, date_added = nil)
  check_transaction do
    super(owner, repo, watcher, date_added)
  end
end