Skip to content

Commit bd438ee

Browse files
just3wsjust3ws
committed
Merge pull request #186 from seuros/mongo_grave
Mongo grave
2 parents 9066b2c + 2e778cd commit bd438ee

32 files changed

+518
-152
lines changed

‎Gemfile

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -122,6 +122,9 @@ gem 'simple_form'
122122
gem 'tweet-button'
123123
gem 'local_time'
124124

125+
gem 'elasticsearch-model'
126+
gem 'elasticsearch-rails'
127+
125128
# DROP BEFORE RAILS 4
126129
# Mongo
127130
gem 'mongoid'
@@ -174,6 +177,7 @@ group :test do
174177
gem 'timecop'
175178
gem 'vcr'
176179
gem 'webmock', '<1.16'
180+
gem 'stripe-ruby-mock', git: 'https://github.com/rebelidealist/stripe-ruby-mock', branch: 'live-tests'
177181
end
178182

179183
group :production do

‎Gemfile.lock

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,16 @@ GIT
3838
mime-types (>= 1.25, < 3.0)
3939
rest-client (~> 1.4)
4040

41+
GIT
42+
remote: https://github.com/rebelidealist/stripe-ruby-mock
43+
revision: f4229cbe762bc2a5a302cdd83088c283881e9c5a
44+
branch: live-tests
45+
specs:
46+
stripe-ruby-mock (1.10.1.7)
47+
dante (>= 0.2.0)
48+
jimson-temp
49+
stripe (>= 1.15.0)
50+
4151
GEM
4252
remote: https://rubygems.org/
4353
remote: https://rails-assets.org/
@@ -106,6 +116,7 @@ GEM
106116
rack (>= 0.9.0)
107117
binding_of_caller (0.7.2)
108118
debug_inspector (>= 0.0.1)
119+
blankslate (3.1.3)
109120
bson (1.10.2)
110121
bson_ext (1.10.2)
111122
bson (~> 1.10.2)
@@ -173,6 +184,7 @@ GEM
173184
httparty (~> 0.10)
174185
json
175186
curb (0.8.6)
187+
dante (0.2.0)
176188
database_cleaner (1.3.0)
177189
debug_inspector (0.0.2)
178190
debugger-linecache (1.2.0)
@@ -192,6 +204,19 @@ GEM
192204
execjs
193205
eco-source (1.1.0.rc.1)
194206
ejs (1.1.1)
207+
elasticsearch (1.0.4)
208+
elasticsearch-api (= 1.0.4)
209+
elasticsearch-transport (= 1.0.4)
210+
elasticsearch-api (1.0.4)
211+
multi_json
212+
elasticsearch-model (0.1.4)
213+
activesupport (> 3)
214+
elasticsearch (> 0.4)
215+
hashie
216+
elasticsearch-rails (0.1.4)
217+
elasticsearch-transport (1.0.4)
218+
faraday
219+
multi_json
195220
em-http-request (1.1.2)
196221
addressable (>= 2.3.4)
197222
cookiejar
@@ -321,6 +346,11 @@ GEM
321346
jbuilder (2.1.3)
322347
activesupport (>= 3.0.0, < 5)
323348
multi_json (~> 1.2)
349+
jimson-temp (0.9.5)
350+
blankslate (>= 3.1.2)
351+
multi_json (~> 1.0)
352+
rack (~> 1.4)
353+
rest-client (~> 1.0)
324354
journey (1.0.4)
325355
jquery-rails (2.0.3)
326356
railties (>= 3.1.0, < 5.0)
@@ -727,6 +757,8 @@ DEPENDENCIES
727757
createsend
728758
database_cleaner
729759
dotenv-rails
760+
elasticsearch-model
761+
elasticsearch-rails
730762
ember-rails!
731763
fabrication-rails
732764
faraday (~> 0.8.1)
@@ -806,6 +838,7 @@ DEPENDENCIES
806838
spring-commands-rspec
807839
squeel (= 1.0.1)
808840
stripe!
841+
stripe-ruby-mock!
809842
strong_parameters
810843
syntax
811844
timecop

‎app/jobs/refresh_user_job.rb

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -7,10 +7,6 @@ def perform(user_id, full=false)
77

88
user = User.find(user_id)
99

10-
if user.github_id
11-
user.destroy_github_cache
12-
end
13-
1410
return if !full && user.last_refresh_at > 3.days.ago
1511

1612
begin
@@ -21,7 +17,6 @@ def perform(user_id, full=false)
2117
user.calculate_score!
2218
ensure
2319
user.touch(:last_refresh_at)
24-
user.destroy_github_cache
2520
end
2621
end
2722
end

‎app/jobs/team_migrator_batch_job.rb

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
#TODO DELETE ME
2+
class TeamMigratorBatchJob
3+
include Sidekiq::Worker
4+
5+
def perform
6+
Team.each do |team|
7+
TeamMigratorJob.perform_async(team.id.to_s)
8+
end
9+
end
10+
end

‎app/jobs/team_migrator_job.rb

Lines changed: 169 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,169 @@
1+
#TODO DELETE ME
2+
class TeamMigratorJob
3+
include Sidekiq::Worker
4+
5+
sidekiq_options backtrace: true
6+
7+
def perform(id)
8+
team = Team.find(id)
9+
if pgteam = find_or_initialize_team(id, team)
10+
extract_account(pgteam, team)
11+
12+
extract_locations(pgteam, team)
13+
extract_links(pgteam, team)
14+
add_members(pgteam)
15+
add_jobs(pgteam)
16+
convert_followers(pgteam)
17+
add_pending_requests(pgteam, team)
18+
end
19+
end
20+
21+
22+
private
23+
24+
def find_or_initialize_team(id, team)
25+
begin
26+
PgTeam.find_or_initialize_by_mongo_id(id) do |pgteam|
27+
pgteam.name = team.name
28+
pgteam.slug = team.slug
29+
pgteam.created_at = team.created_at
30+
pgteam.updated_at = team.updated_at
31+
pgteam.website = team.website
32+
pgteam.about = team.about
33+
pgteam.total = team.total
34+
pgteam.size = team.size
35+
pgteam.mean = team.mean
36+
pgteam.median = team.median
37+
pgteam.score = team.score
38+
pgteam.twitter = team.twitter
39+
pgteam.facebook = team.facebook
40+
pgteam.premium = team.premium
41+
pgteam.analytics = team.analytics
42+
pgteam.valid_jobs = team.valid_jobs
43+
pgteam.hide_from_featured = team.hide_from_featured
44+
pgteam.preview_code = team.preview_code
45+
pgteam.youtube_url = team.youtube_url
46+
pgteam.github = team.github
47+
pgteam.highlight_tags = team.highlight_tags
48+
pgteam.branding = team.branding
49+
pgteam.headline = team.headline
50+
pgteam.big_quote = team.big_quote
51+
pgteam.big_image = team.big_image
52+
pgteam.featured_banner_image = team.featured_banner_image
53+
pgteam.benefit_name_1 = team.benefit_name_1
54+
pgteam.benefit_description_1 = team.benefit_description_1
55+
pgteam.benefit_name_2 = team.benefit_name_2
56+
pgteam.benefit_description_2 = team.benefit_description_2
57+
pgteam.benefit_name_3 = team.benefit_name_3
58+
pgteam.benefit_description_3 = team.benefit_description_3
59+
pgteam.reason_name_1 = team.reason_name_1
60+
pgteam.reason_description_1 = team.reason_description_1
61+
pgteam.reason_name_2 = team.reason_name_2
62+
pgteam.reason_description_2 = team.reason_description_2
63+
pgteam.reason_name_3 = team.reason_name_3
64+
pgteam.reason_description_3 = team.reason_description_3
65+
pgteam.why_work_image = team.why_work_image
66+
pgteam.organization_way = team.organization_way
67+
pgteam.organization_way_name = team.organization_way_name
68+
pgteam.organization_way_photo = team.organization_way_photo
69+
pgteam.office_photos = team.office_photos
70+
pgteam.upcoming_events = team.upcoming_events
71+
pgteam.featured_links_title = team.featured_links_title
72+
pgteam.blog_feed = team.blog_feed
73+
pgteam.our_challenge = team.our_challenge
74+
pgteam.your_impact = team.your_impact
75+
pgteam.interview_steps = team.interview_steps
76+
pgteam.hiring_tagline = team.hiring_tagline
77+
pgteam.link_to_careers_page = team.link_to_careers_page
78+
# pgteam.avatar = team.avatar
79+
pgteam.achievement_count = team.achievement_count
80+
pgteam.endorsement_count = team.endorsement_count
81+
pgteam.invited_emails = team.invited_emails
82+
pgteam.pending_join_requests = team.pending_join_requests
83+
pgteam.upgraded_at = team.upgraded_at
84+
pgteam.paid_job_posts = team.paid_job_posts
85+
pgteam.monthly_subscription = team.monthly_subscription
86+
pgteam.stack_list = team.stack_list
87+
pgteam.number_of_jobs_to_show = team.number_of_jobs_to_show
88+
pgteam.location = team.location
89+
pgteam.country_id = team.country_id
90+
pgteam.github_organization_name = team.github_organization_name
91+
pgteam.save!
92+
93+
end
94+
rescue ActiveRecord::RecordInvalid
95+
false
96+
end
97+
end
98+
99+
def extract_account(pgteam, team)
100+
return unless account = team.account
101+
return if pgteam.account
102+
begin
103+
pgaccount = pgteam.build_account(
104+
stripe_card_token: account.stripe_card_token,
105+
stripe_customer_token: account.stripe_customer_token,
106+
admin_id: account.admin_id
107+
)
108+
pgaccount.plans << Plan.where(id: account.plan_ids)
109+
pgaccount.save!
110+
rescue ActiveRecord::RecordInvalid => e
111+
# @just3ws, uncomment the following line and get all ID of the corrupted accounts
112+
# raise e
113+
false
114+
end
115+
116+
end
117+
118+
def extract_locations(pgteam, team)
119+
locations = team.team_locations
120+
return unless locations.any?
121+
return if pgteam.locations.any?
122+
locations.each do |location|
123+
pgteam.locations.create! name: location.name,
124+
description: location.description,
125+
address: location.address,
126+
city: location.city,
127+
state_code: location.state_code,
128+
country: location.country
129+
130+
end
131+
end
132+
133+
def extract_links(pgteam, team)
134+
links = team.featured_links
135+
return if links.empty?
136+
return if pgteam.links.any?
137+
links.each do |link|
138+
pgteam.links.create! name: link.name,
139+
url: link.url
140+
end
141+
end
142+
143+
def add_members(pgteam)
144+
users = User.where(team_document_id: pgteam.mongo_id)
145+
users.each do |user|
146+
pgteam.members.create! user: user, state: 'active'
147+
end
148+
users.update_all(team_id: pgteam.id)
149+
end
150+
151+
def add_jobs(pgteam)
152+
Opportunity.where(team_document_id: pgteam.mongo_id).update_all(team_id: pgteam.id)
153+
end
154+
155+
def convert_followers(pgteam)
156+
FollowedTeam.where(team_document_id: pgteam.mongo_id).update_all(team_id: pgteam.id)
157+
end
158+
159+
def add_pending_requests(pgteam, team)
160+
pending_team_members = team.pending_team_members
161+
return if pending_team_members.empty?
162+
pending_team_members.each do |pending_team_member|
163+
user = User.find pending_team_member.user_id
164+
pgteam.members.create user: user,
165+
created_at: pending_team_member.created_at,
166+
updated_at: pending_team_member.updated_at
167+
end
168+
end
169+
end

‎app/models/concerns/team_migration.rb

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
module TeamMigration
2+
extend ActiveSupport::Concern
3+
4+
included do
5+
scope :zombies, -> { where(state: 'zombie') }
6+
end
7+
8+
module ClassMethods
9+
10+
def the_walking_deads
11+
active_teams_ids = Teams::Member.pluck(:team_id).uniq
12+
where('id not in (?)', active_teams_ids)
13+
end
14+
15+
def mark_the_walking_deads!
16+
the_walking_deads.update_all(state: 'zombie')
17+
end
18+
19+
def kill_zombies!
20+
zombies.destroy_all
21+
end
22+
23+
end
24+
end

‎app/models/concerns/team_search.rb

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
module TeamSearch
2+
extend ActiveSupport::Concern
3+
included do
4+
include Elasticsearch::Model
5+
6+
#TODO
7+
end
8+
end

‎app/models/followed_team.rb

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,16 @@
1+
# TODO, rename to Teams::Follower
12
class FollowedTeam < ActiveRecord::Base
3+
belongs_to :team, class_name: 'PgTeam'
4+
belongs_to :user
25
end
36

47
# == Schema Information
5-
# Schema version: 20140728214411
68
#
79
# Table name: followed_teams
810
#
911
# id :integer not null, primary key
1012
# user_id :integer
1113
# team_document_id :string(255)
12-
# created_at :datetime default(2014-02-20 22:39:11 UTC)
14+
# created_at :datetime default(2012-03-12 21:01:09 UTC)
15+
# team_id :integer
1316
#

0 commit comments

Comments
 (0)