tip4commit/app/models/project.rb at master · tip4commit/tip4commit · GitHub

Repository navigation

History

246 lines (196 loc) · 6.3 KB

Raw

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

# frozen_string_literal: true

class Project < ApplicationRecord

acts_as_paranoid

belongs_to :wallet

has_many :deposits # TODO: only confirmed deposits

has_many :tips, inverse_of: :project

accepts_nested_attributes_for :tips

has_many :collaborators, autosave: true

has_one :tipping_policies_text, inverse_of: :project

accepts_nested_attributes_for :tipping_policies_text

validates :full_name, :github_id, uniqueness: true, presence: true

validates :host, inclusion: %w[github bitbucket], presence: true

search_syntax do

search_by :text do |scope, phrases|

columns = %i[full_name host description language]

scope.where_like(columns => phrases)

end

after_create :generate_bitcoin_address

# before_save :check_tips_to_pay_against_avaiable_amount

def update_repository_info(repo)

self.github_id = repo.id

self.name = repo.name

self.full_name = repo.full_name

self.source_full_name = begin

repo.source.full_name

rescue StandardError

end

self.description = repo.description

self.watchers_count = repo.watchers_count

self.language = repo.language

self.avatar_url = repo.organization.rels[:avatar].href if repo.organization.present?

save!

end

def update_collaborators(repo_collaborators)

existing_collaborators = collaborators

repo_logins = repo_collaborators

existing_logins = existing_collaborators.map(&:login)

existing_collaborators.each do |existing_collaborator|

existing_collaborator.mark_for_destruction unless repo_logins.include?(existing_collaborator.login)

end

repo_collaborators.each do |repo_collaborator|

collaborators.build(login: repo_collaborator) unless existing_logins.include?(repo_collaborator)

end

save!

end

def repository_client

host.classify.constantize.new if host.present?

end

def github_url

repository_client.repository_url self

end

def source_github_url

repository_client.source_repository_url self

end

def raw_commits

repository_client.commits self

end

def repository_info

repository_client.repository_info self

end

def collaborators_info

repository_client.collaborators_info self

end

def branches

repository_client.branches self

end

def new_commits

begin

commits = Timeout.timeout(90) do

raw_commits.

# Filter merge request

reject { |c| (c.commit.message =~ /^(Merge\s|auto\smerge)/) }.

# Filter fake emails

select { |c| c.commit.author.email =~ Devise.email_regexp }.

# Filter commited after t4c project creation

select { |c| c.commit.committer.date > deposits.first.created_at }

.to_a.

# tip for older commits first

reverse

end

rescue Octokit::BadGateway, Octokit::NotFound, Octokit::InternalServerError, Octokit::Forbidden,

Errno::ETIMEDOUT, Net::ReadTimeout, Faraday::ConnectionFailed => e

Rails.logger.info "Project ##{id}: #{e.class} happened"

rescue StandardError => e

Airbrake.notify(e)

end

sleep(1)

commits || []

end

def tip_commits

new_commits.each do |commit|

Project.transaction do

tip_for commit

update_attribute :last_commit, commit.sha

end

def tip_for(commit)

return unless next_tip_amount.positive?

return if Tip.exists?(commit: commit.sha)

user = User.find_by_commit(commit)

return if user.nil?

user.update(nickname: commit.author.login) if commit.author.try(:login)

amount = if hold_tips

nil

else

next_tip_amount

end

# create a tip

tip = tips.create(

user:,

amount:,

commit: commit.sha,

commit_message: commit.commit.message

)

Rails.logger.info " Tip created #{tip.inspect}"

end

def donated

deposits.confirmed.map(&:available_amount).sum

end

def available_amount

donated - tips_paid_amount

end

def unconfirmed_amount

deposits.unconfirmed.where('created_at > ?', 7.days.ago).map(&:available_amount).sum

end

def tips_paid_amount

tips.decided.non_refunded.sum(:amount)

end

def tips_paid_unclaimed_amount

tips.decided.non_refunded.unclaimed.sum(:amount)

end

def next_tip_amount

next_tip_amount = (CONFIG['tip'] * available_amount).ceil

next_tip_amount = [next_tip_amount, CONFIG['min_tip']].max if CONFIG['min_tip']

[next_tip_amount, available_amount].min

end

def update_cache

update available_amount_cache: available_amount

end

def self.update_cache

find_each(&:update_cache)

end

def update_info

update_repository_info(repository_info)

update_collaborators(collaborators_info)

rescue Octokit::BadGateway, Octokit::NotFound, Octokit::InternalServerError, Octokit::Forbidden,

Errno::ETIMEDOUT, Net::ReadTimeout, Faraday::ConnectionFailed => e

Rails.logger.info "Project ##{id}: #{e.class} happened"

rescue StandardError => e

Airbrake.notify(e)

end

def amount_to_pay

tips.to_pay.sum(:amount)

end

def has_undecided_tips?

tips.undecided.any?

end

def commit_url(commit)

repository_client.commit_url(self, commit)

end

def check_tips_to_pay_against_avaiable_amount

raise "Not enough funds to pay the pending tips on #{inspect} (#{available_amount} < 0)" if available_amount.negative?

end

def self.find_or_create_by_url(project_url)

project_name = project_url

.gsub(%r{https?://github.com/}, '')

.gsub(/\#.+$/, '')

.gsub(' ', '')

Github.new.find_or_create_project project_name

end

def self.find_by_url(project_url)

project_name = project_url

.gsub(%r{https?://github.com/}, '')

.gsub(/\#.+$/, '')

.gsub(' ', '')

Github.new.find_project project_name

end

def generate_bitcoin_address

wallet = Wallet.order(created_at: :asc).last

return unless wallet

self.wallet = wallet

self.bitcoin_address = wallet.generate_address

save

end

class << self

def export_labels

pluck(:bitcoin_address, :full_name).to_h.to_json

end

def find_by_service_and_repo(service, repo)

where(host: service).find_by('lower(`full_name`) = ?', repo.downcase)

end

tip4commit/app/models/project.rb at master · tip4commit/tip4commit · GitHub

Repository navigation

Expand file tree

Breadcrumbs

project.rb

Latest commit

History

Breadcrumbs

project.rb

File metadata and controls