From 744e41c1791da980ad03c9a761cfdfbbbf27182f Mon Sep 17 00:00:00 2001
From: Ralph Bean <rbean@redhat.com>
Date: Mon, 19 Aug 2013 21:16:18 +0000
Subject: [PATCH] Add another cronjob for the libravatar badge to
 badges-backend01.

---
 .../files/cron/award-libravatar-badge         | 78 +++++++++++++++++++
 .../files/cron/award-libravatar-badge.cron    |  1 +
 roles/badges-backend/tasks/main.yml           |  2 +
 3 files changed, 81 insertions(+)
 create mode 100644 roles/badges-backend/files/cron/award-libravatar-badge
 create mode 100644 roles/badges-backend/files/cron/award-libravatar-badge.cron

diff --git a/roles/badges-backend/files/cron/award-libravatar-badge b/roles/badges-backend/files/cron/award-libravatar-badge
new file mode 100644
index 0000000000..b3f7fd9ea1
--- /dev/null
+++ b/roles/badges-backend/files/cron/award-libravatar-badge
@@ -0,0 +1,78 @@
+#!/usr/bin/env python
+
+import __main__
+__main__.__requires__ = __requires__ = ["tahrir-api", "sqlalchemy>=0.7"];
+import pkg_resources
+pkg_resources.require(__requires__)
+
+import hashlib
+import requests
+import time
+import transaction
+
+from tahrir_api.dbapi import TahrirDatabase
+from tahrir_api.model import Person
+
+import fedmsg
+import fedmsg.config
+
+fm_config = fedmsg.config.load_config()
+fm_config['cert_prefix'] = 'fedbadges'
+fm_config['name'] = 'relay_inbound'
+fm_config['active'] = True
+fedmsg.init(**fm_config)
+
+
+def main():
+    persons = tahrir.session.query(Person)\
+        .filter(Person.opt_out==False).all()
+
+    badge = tahrir.get_badge('mugshot')
+    already_has_it = [assertion.person for assertion in badge.assertions]
+
+    good, bad = [], []
+    for person in persons:
+
+        if person in already_has_it:
+            good.append(person)
+            print "Skipping %r" % person
+            continue
+
+        openid = "http://%s.id.fedoraproject.org/" % person.nickname
+        hash = hashlib.sha256(openid).hexdigest()
+        url = "https://seccdn.libravatar.org/avatar/%s?d=404" % hash
+        response = requests.get(url)
+
+        if response.status_code == 200:
+            print person.nickname, "totally gets the mugshot badge."
+            good.append(person)
+            try:
+                transaction.begin()
+                tahrir.add_assertion(badge.id, person.email, None)
+                transaction.commit()
+                fedmsg.publish(topic="badge.award",
+                    modname="fedbadges",
+                    msg=dict(
+                        badge=dict(
+                            name=badge.name,
+                            description=badge.description,
+                            image_url=badge.image,
+                        ),
+                        user=dict(
+                            username=person.nickname,
+                            badges_user_id=person.id,
+                        ),
+                ))
+                time.sleep(1)
+            except Exception as e:
+                transaction.abort()
+                print "Failure:", e
+        else:
+            bad.append(person)
+
+    print len(good), "good peoples"
+    print len(bad), "bad peoples"
+
+uri = fm_config['badges_global']['database_uri']
+tahrir = TahrirDatabase(uri)
+main()
diff --git a/roles/badges-backend/files/cron/award-libravatar-badge.cron b/roles/badges-backend/files/cron/award-libravatar-badge.cron
new file mode 100644
index 0000000000..35a9c1c0ea
--- /dev/null
+++ b/roles/badges-backend/files/cron/award-libravatar-badge.cron
@@ -0,0 +1 @@
+*/55 * * * * fedmsg /usr/share/badges/cronjobs/award-libravatar-badge
diff --git a/roles/badges-backend/tasks/main.yml b/roles/badges-backend/tasks/main.yml
index 5fa0624ded..ebfc4e277f 100644
--- a/roles/badges-backend/tasks/main.yml
+++ b/roles/badges-backend/tasks/main.yml
@@ -77,6 +77,7 @@
     mode=744
   with_items:
   - award-oldschool-badges
+  - award-libravatar-badge
   tags:
   - config
   - cron
@@ -89,6 +90,7 @@
     mode=644
   with_items:
   - award-oldschool-badges
+  - award-libravatar-badge
   tags:
   - config
   - cron