marketing.rake

namespace:marketingdo
defsendgrid_client
Excon.new(
'https://api.sendgrid.com',
headers: {
"Authorization"=>"Bearer #{ENV.fetch('SENDGRID_KEY')}",
"Content-Type"=>"application/json"
},
)
end

defsendgrid(method,path,body=nil,options={})
params={method: method,path: "v3/#{path}"}
params[:body]=body.to_jsonifbody
response=sendgrid_client.request(params)
ifoptions[:check_status] != false && ![200,201,204].include?(response.status)
putsresponse.body
putsresponse.headers
raise"sendgrid #{path}#{response.status}"
end

JSON.parse(response.body)unlessresponse.body.blank?
end

defupsert_list(name)
resp=sendgrid('GET','contactdb/lists')
resp['lists'].find{|l| l['name'] == name} ||
sendgrid('POST','contactdb/lists',{name: name})
end

task:sync_lists=>:environmentdo
list_name=ENV.fetch('MARKETING_LIST')
list=upsert_list(list_name)

%w(usernamefull_name).eachdo |field|
sendgrid('POST','contactdb/custom_fields',{name: field,type: 'text'},check_status: false)
end

# add users to marketing list
User.where(marketing_list: nil,email_invalid_at: nil,receive_newsletter: true).find_in_batches(batch_size: 1000)do |group|
entries=group.mapdo |u|
{
email: u.email,
username: u.username,
full_name: u.name,
}
end

puts"creating #{entries.size} recipients"
response=sendgrid('POST','contactdb/recipients',entries)
putsresponse.slice('new_count','updated_count')
(response['errors'] || []).eachdo |error|
putserror['message']
puts(error['error_indices'] || []).map{|i| putsentries[i]}
iferror['message'] =~ /email.*is invalid/i
error['error_indices'].map{|i| group[i]}.eachdo |u|
u.update!email_invalid_at: Time.now
end
end
end

recipients=response['persisted_recipients']
puts"adding #{recipients.size} recipients to list #{list}"
sendgrid('POST',"contactdb/lists/#{list['id']}/recipients",recipients)

persisted_users=group.select.with_index{ |u,idx|
 !response['error_indices'].include?(idx)
}.map.with_index{|u,idx| [u,recipients[idx]]}


persisted_users.eachdo |user,recipient_id|
user.update!(marketing_list: list['id'])
end

sleep1# sendgrid rate limits
end

# remove users from marketing list
User.where.not(marketing_list: nil).where(receive_newsletter: false).find_eachdo |u|
response=sendgrid('GET',"contactdb/recipients/search?email=#{u.email}")
response['recipients'].eachdo |r|
sendgrid("DELETE","contactdb/lists/#{list['id']}/recipients/#{r['id']}")
u.update!(marketing_list: nil)
puts"unsubscribed #{r['email']}"
end
end
end
end