old_contents: import os
  from time import sleep
  
  import stripe
  from salesforce_bulk import SalesforceBulk
  from simple_salesforce import Salesforce
  
  from config import STRIPE_KEYS
  
  stripe.api_key = STRIPE_KEYS['secret_key']
  
  # get Stripe emails
  customers = stripe.Customer.all(limit=100)
  stripe_emails = set((x['email'].lower() for x in customers.auto_paging_iter()))
  
  # then compare to SF
  query = 'SELECT All_In_One_EMail__c FROM Contact'
  
  SALESFORCE = {
      "USERNAME": os.getenv('SALESFORCE_USERNAME'),
      "PASSWORD": os.getenv('SALESFORCE_PASSWORD'),
      "HOST": os.getenv("SALESFORCE_HOST"),
      "TOKEN": os.getenv("SALESFORCE_TOKEN"),
      "CLIENT_ID": os.getenv("SALESFORCE_CLIENT_ID"),
      "CLIENT_SECRET": os.getenv("SALESFORCE_CLIENT_SECRET"),
  }
  
  USER = SALESFORCE['USERNAME']
  PASS = SALESFORCE['PASSWORD']
  TOKEN = SALESFORCE['TOKEN']
  HOST = SALESFORCE['HOST']
  
  sf = Salesforce(username=USER, password=PASS, security_token=TOKEN)
  
  bulk = SalesforceBulk(sessionId=sf.session_id, host=HOST)
  
  job = bulk.create_query_job("Contact", contentType='CSV')
  
  batch = bulk.query(job, query)
  while not bulk.is_batch_done(job, batch):
      sleep(3)
  bulk.close_job(job)
  
  rows = bulk.get_batch_result_iter(job, batch, parse_csv=True)
  foo = list(rows)
  email_list = []
  emails_sf = [x['All_In_One_EMail__c'] for x in foo]
  print ("The following email addresses appear in Stripe but not Salesforce: \n")
  for field in emails_sf:
      for email in field.split(','):
          if email != '':
              email_list.append(email.strip())
  diff = stripe_emails.difference(email_list)
  for item in diff:
      print (item)
  
new_contents: import os
  from time import sleep
  
  import stripe
  from salesforce_bulk import SalesforceBulk
  from simple_salesforce import Salesforce
  
  from config import STRIPE_KEYS
  
  stripe.api_key = STRIPE_KEYS['secret_key']
  
  # get Stripe emails
  customers = stripe.Customer.all(limit=100)
  stripe_emails = set((x['email'].lower() for x in customers.auto_paging_iter()))
  
  # then compare to SF
  query = 'SELECT All_In_One_EMail__c FROM Contact'
  
  SALESFORCE = {
      "USERNAME": os.getenv('SALESFORCE_USERNAME'),
      "PASSWORD": os.getenv('SALESFORCE_PASSWORD'),
      "HOST": os.getenv("SALESFORCE_HOST"),
      "TOKEN": os.getenv("SALESFORCE_TOKEN"),
      "CLIENT_ID": os.getenv("SALESFORCE_CLIENT_ID"),
      "CLIENT_SECRET": os.getenv("SALESFORCE_CLIENT_SECRET"),
  }
  
  USER = SALESFORCE['USERNAME']
  PASS = SALESFORCE['PASSWORD']
  TOKEN = SALESFORCE['TOKEN']
  HOST = SALESFORCE['HOST']
  
  sf = Salesforce(username=USER, password=PASS, security_token=TOKEN)
  
  bulk = SalesforceBulk(sessionId=sf.session_id, host=HOST)
  
  job = bulk.create_query_job("Contact", contentType='CSV')
  
  batch = bulk.query(job, query)
  while not bulk.is_batch_done(job, batch):
      sleep(3)
  bulk.close_job(job)
  
  rows = bulk.get_batch_result_iter(job, batch, parse_csv=True)
  bulk_email = list(rows)
  email_list = []
  emails_sf = [x['All_In_One_EMail__c'] for x in bulk_email]
  print ("The following email addresses appear in Stripe but not Salesforce: \n")
  for field in emails_sf:
      for email in field.split(','):
          if email != '':
              email_list.append(email.strip())
  diff = stripe_emails.difference(email_list)
  for item in diff:
      print (item)
  
subject: rename foo to bulk_email