Example of a more complicated EventStore projection using GitHub API data

cURLs.sh

# Push an IssuesEvent into ES (with known issue number)
curl -i -L -d @example-issues-event.json http://127.0.0.1:2113/streams/github-IssuesEvent -H "Content-Type:application/json" -H "ES-EventType:IssuesEvent" -u "admin:changeit"

# Push a PushEvent into ES (has a commit description with required match)
curl -i -L -d @example-push-event.json http://127.0.0.1:2113/streams/github-PushEvent -H "Content-Type:application/json" -H "ES-EventType:PushEvent" -u "admin:changeit"

# Push a DeploymentEvent into ES (has a description with required match)
curl -i -L -d @example-DeploymentEvent-desc.json http://127.0.0.1:2113/streams/github-DeploymentEvent -H "Content-Type:application/json" -H "ES-EventType:DeploymentEvent" -u "admin:changeit"

# Push a DeploymentEvent into eS (does not have description with match, relies on date precedence)
curl -i -L -d @example-DeploymentEvent-nodesc.json http://127.0.0.1:2113/streams/github-DeploymentEvent -H "Content-Type:application/json" -H "ES-EventType:DeploymentEvent" -u "admin:changeit"

example-DeploymentEvent-desc.json

{
  "deployment": {
    "url": "https://api.github.com/repos/ianbattersby/public-repo/deployments/710692",
    "id": 9910692,
    "sha": "9049f1265b7d61be4a8904a9a27120d2064dab3b",
    "ref": "master",
    "task": "deploy",
    "payload": {
    },
    "environment": "production",
    "description": "This deployment fixes #223.",
    "creator": {
      "login": "ianbattersby",
      "id": 6752317,
      "avatar_url": "https://avatars.githubusercontent.com/u/6752317?v=3",
      "gravatar_id": "",
      "url": "https://api.github.com/users/ianbattersby",
      "html_url": "https://github.com/ianbattersby",
      "followers_url": "https://api.github.com/users/ianbattersby/followers",
      "following_url": "https://api.github.com/users/ianbattersby/following{/other_user}",
      "gists_url": "https://api.github.com/users/ianbattersby/gists{/gist_id}",
      "starred_url": "https://api.github.com/users/ianbattersby/starred{/owner}{/repo}",
      "subscriptions_url": "https://api.github.com/users/ianbattersby/subscriptions",
      "organizations_url": "https://api.github.com/users/ianbattersby/orgs",
      "repos_url": "https://api.github.com/users/ianbattersby/repos",
      "events_url": "https://api.github.com/users/ianbattersby/events{/privacy}",
      "received_events_url": "https://api.github.com/users/ianbattersby/received_events",
      "type": "User",
      "site_admin": false
    },
    "created_at": "2015-11-28T23:40:38Z",
    "updated_at": "2015-11-28T23:40:38Z",
    "statuses_url": "https://api.github.com/repos/ianbattersby/public-repo/deployments/710692/statuses",
    "repository_url": "https://api.github.com/repos/ianbattersby/public-repo"
  },
  "repository": {
    "id": 47172074,
    "name": "public-repo",
    "full_name": "ianbattersby/public-repo",
    "owner": {
      "login": "ianbattersby",
      "id": 6752317,
      "avatar_url": "https://avatars.githubusercontent.com/u/6752317?v=3",
      "gravatar_id": "",
      "url": "https://api.github.com/users/ianbattersby",
      "html_url": "https://github.com/ianbattersby",
      "followers_url": "https://api.github.com/users/ianbattersby/followers",
      "following_url": "https://api.github.com/users/ianbattersby/following{/other_user}",
      "gists_url": "https://api.github.com/users/ianbattersby/gists{/gist_id}",
      "starred_url": "https://api.github.com/users/ianbattersby/starred{/owner}{/repo}",
      "subscriptions_url": "https://api.github.com/users/ianbattersby/subscriptions",
      "organizations_url": "https://api.github.com/users/ianbattersby/orgs",
      "repos_url": "https://api.github.com/users/ianbattersby/repos",
      "events_url": "https://api.github.com/users/ianbattersby/events{/privacy}",
      "received_events_url": "https://api.github.com/users/ianbattersby/received_events",
      "type": "User",
      "site_admin": false
    },
    "private": false,
    "html_url": "https://github.com/ianbattersby/public-repo",
    "description": "",
    "fork": false,
    "url": "https://api.github.com/repos/ianbattersby/public-repo",
    "forks_url": "https://api.github.com/repos/ianbattersby/public-repo/forks",
    "keys_url": "https://api.github.com/repos/ianbattersby/public-repo/keys{/key_id}",
    "collaborators_url": "https://api.github.com/repos/ianbattersby/public-repo/collaborators{/collaborator}",
    "teams_url": "https://api.github.com/repos/ianbattersby/public-repo/teams",
    "hooks_url": "https://api.github.com/repos/ianbattersby/public-repo/hooks",
    "issue_events_url": "https://api.github.com/repos/ianbattersby/public-repo/issues/events{/number}",
    "events_url": "https://api.github.com/repos/ianbattersby/public-repo/events",
    "assignees_url": "https://api.github.com/repos/ianbattersby/public-repo/assignees{/user}",
    "branches_url": "https://api.github.com/repos/ianbattersby/public-repo/branches{/branch}",
    "tags_url": "https://api.github.com/repos/ianbattersby/public-repo/tags",
    "blobs_url": "https://api.github.com/repos/ianbattersby/public-repo/git/blobs{/sha}",
    "git_tags_url": "https://api.github.com/repos/ianbattersby/public-repo/git/tags{/sha}",
    "git_refs_url": "https://api.github.com/repos/ianbattersby/public-repo/git/refs{/sha}",
    "trees_url": "https://api.github.com/repos/ianbattersby/public-repo/git/trees{/sha}",
    "statuses_url": "https://api.github.com/repos/ianbattersby/public-repo/statuses/{sha}",
    "languages_url": "https://api.github.com/repos/ianbattersby/public-repo/languages",
    "stargazers_url": "https://api.github.com/repos/ianbattersby/public-repo/stargazers",
    "contributors_url": "https://api.github.com/repos/ianbattersby/public-repo/contributors",
    "subscribers_url": "https://api.github.com/repos/ianbattersby/public-repo/subscribers",
    "subscription_url": "https://api.github.com/repos/ianbattersby/public-repo/subscription",
    "commits_url": "https://api.github.com/repos/ianbattersby/public-repo/commits{/sha}",
    "git_commits_url": "https://api.github.com/repos/ianbattersby/public-repo/git/commits{/sha}",
    "comments_url": "https://api.github.com/repos/ianbattersby/public-repo/comments{/number}",
    "issue_comment_url": "https://api.github.com/repos/ianbattersby/public-repo/issues/comments{/number}",
    "contents_url": "https://api.github.com/repos/ianbattersby/public-repo/contents/{+path}",
    "compare_url": "https://api.github.com/repos/ianbattersby/public-repo/compare/{base}...{head}",
    "merges_url": "https://api.github.com/repos/ianbattersby/public-repo/merges",
    "archive_url": "https://api.github.com/repos/ianbattersby/public-repo/{archive_format}{/ref}",
    "downloads_url": "https://api.github.com/repos/ianbattersby/public-repo/downloads",
    "issues_url": "https://api.github.com/repos/ianbattersby/public-repo/issues{/number}",
    "pulls_url": "https://api.github.com/repos/ianbattersby/public-repo/pulls{/number}",
    "milestones_url": "https://api.github.com/repos/ianbattersby/public-repo/milestones{/number}",
    "notifications_url": "https://api.github.com/repos/ianbattersby/public-repo/notifications{?since,all,participating}",
    "labels_url": "https://api.github.com/repos/ianbattersby/public-repo/labels{/name}",
    "releases_url": "https://api.github.com/repos/ianbattersby/public-repo/releases{/id}",
    "created_at": "2015-05-05T23:40:12Z",
    "updated_at": "2015-05-05T23:40:30Z",
    "pushed_at": "2015-05-05T23:40:38Z",
    "git_url": "git://github.com/ianbattersby/public-repo.git",
    "ssh_url": "git@github.com:ianbattersby/public-repo.git",
    "clone_url": "https://github.com/ianbattersby/public-repo.git",
    "svn_url": "https://github.com/ianbattersby/public-repo",
    "homepage": null,
    "size": 0,
    "stargazers_count": 0,
    "watchers_count": 0,
    "language": null,
    "has_issues": true,
    "has_downloads": true,
    "has_wiki": true,
    "has_pages": true,
    "forks_count": 0,
    "mirror_url": null,
    "open_issues_count": 2,
    "forks": 0,
    "open_issues": 2,
    "watchers": 0,
    "default_branch": "master"
  },
  "sender": {
    "login": "ianbattersby",
    "id": 6752317,
    "avatar_url": "https://avatars.githubusercontent.com/u/6752317?v=3",
    "gravatar_id": "",
    "url": "https://api.github.com/users/ianbattersby",
    "html_url": "https://github.com/ianbattersby",
    "followers_url": "https://api.github.com/users/ianbattersby/followers",
    "following_url": "https://api.github.com/users/ianbattersby/following{/other_user}",
    "gists_url": "https://api.github.com/users/ianbattersby/gists{/gist_id}",
    "starred_url": "https://api.github.com/users/ianbattersby/starred{/owner}{/repo}",
    "subscriptions_url": "https://api.github.com/users/ianbattersby/subscriptions",
    "organizations_url": "https://api.github.com/users/ianbattersby/orgs",
    "repos_url": "https://api.github.com/users/ianbattersby/repos",
    "events_url": "https://api.github.com/users/ianbattersby/events{/privacy}",
    "received_events_url": "https://api.github.com/users/ianbattersby/received_events",
    "type": "User",
    "site_admin": false
  }
}

example-DeploymentEvent-nodesc.json

{
  "deployment": {
    "url": "https://api.github.com/repos/ianbattersby/public-repo/deployments/710692",
    "id": 9910692,
    "sha": "9049f1265b7d61be4a8904a9a27120d2064dab3b",
    "ref": "master",
    "task": "deploy",
    "payload": {
    },
    "environment": "production",
    "description": null,
    "creator": {
      "login": "ianbattersby",
      "id": 6752317,
      "avatar_url": "https://avatars.githubusercontent.com/u/6752317?v=3",
      "gravatar_id": "",
      "url": "https://api.github.com/users/ianbattersby",
      "html_url": "https://github.com/ianbattersby",
      "followers_url": "https://api.github.com/users/ianbattersby/followers",
      "following_url": "https://api.github.com/users/ianbattersby/following{/other_user}",
      "gists_url": "https://api.github.com/users/ianbattersby/gists{/gist_id}",
      "starred_url": "https://api.github.com/users/ianbattersby/starred{/owner}{/repo}",
      "subscriptions_url": "https://api.github.com/users/ianbattersby/subscriptions",
      "organizations_url": "https://api.github.com/users/ianbattersby/orgs",
      "repos_url": "https://api.github.com/users/ianbattersby/repos",
      "events_url": "https://api.github.com/users/ianbattersby/events{/privacy}",
      "received_events_url": "https://api.github.com/users/ianbattersby/received_events",
      "type": "User",
      "site_admin": false
    },
    "created_at": "2015-11-28T23:40:38Z",
    "updated_at": "2015-11-28T23:40:38Z",
    "statuses_url": "https://api.github.com/repos/ianbattersby/public-repo/deployments/710692/statuses",
    "repository_url": "https://api.github.com/repos/ianbattersby/public-repo"
  },
  "repository": {
    "id": 47172074,
    "name": "public-repo",
    "full_name": "ianbattersby/public-repo",
    "owner": {
      "login": "ianbattersby",
      "id": 6752317,
      "avatar_url": "https://avatars.githubusercontent.com/u/6752317?v=3",
      "gravatar_id": "",
      "url": "https://api.github.com/users/ianbattersby",
      "html_url": "https://github.com/ianbattersby",
      "followers_url": "https://api.github.com/users/ianbattersby/followers",
      "following_url": "https://api.github.com/users/ianbattersby/following{/other_user}",
      "gists_url": "https://api.github.com/users/ianbattersby/gists{/gist_id}",
      "starred_url": "https://api.github.com/users/ianbattersby/starred{/owner}{/repo}",
      "subscriptions_url": "https://api.github.com/users/ianbattersby/subscriptions",
      "organizations_url": "https://api.github.com/users/ianbattersby/orgs",
      "repos_url": "https://api.github.com/users/ianbattersby/repos",
      "events_url": "https://api.github.com/users/ianbattersby/events{/privacy}",
      "received_events_url": "https://api.github.com/users/ianbattersby/received_events",
      "type": "User",
      "site_admin": false
    },
    "private": false,
    "html_url": "https://github.com/ianbattersby/public-repo",
    "description": "",
    "fork": false,
    "url": "https://api.github.com/repos/ianbattersby/public-repo",
    "forks_url": "https://api.github.com/repos/ianbattersby/public-repo/forks",
    "keys_url": "https://api.github.com/repos/ianbattersby/public-repo/keys{/key_id}",
    "collaborators_url": "https://api.github.com/repos/ianbattersby/public-repo/collaborators{/collaborator}",
    "teams_url": "https://api.github.com/repos/ianbattersby/public-repo/teams",
    "hooks_url": "https://api.github.com/repos/ianbattersby/public-repo/hooks",
    "issue_events_url": "https://api.github.com/repos/ianbattersby/public-repo/issues/events{/number}",
    "events_url": "https://api.github.com/repos/ianbattersby/public-repo/events",
    "assignees_url": "https://api.github.com/repos/ianbattersby/public-repo/assignees{/user}",
    "branches_url": "https://api.github.com/repos/ianbattersby/public-repo/branches{/branch}",
    "tags_url": "https://api.github.com/repos/ianbattersby/public-repo/tags",
    "blobs_url": "https://api.github.com/repos/ianbattersby/public-repo/git/blobs{/sha}",
    "git_tags_url": "https://api.github.com/repos/ianbattersby/public-repo/git/tags{/sha}",
    "git_refs_url": "https://api.github.com/repos/ianbattersby/public-repo/git/refs{/sha}",
    "trees_url": "https://api.github.com/repos/ianbattersby/public-repo/git/trees{/sha}",
    "statuses_url": "https://api.github.com/repos/ianbattersby/public-repo/statuses/{sha}",
    "languages_url": "https://api.github.com/repos/ianbattersby/public-repo/languages",
    "stargazers_url": "https://api.github.com/repos/ianbattersby/public-repo/stargazers",
    "contributors_url": "https://api.github.com/repos/ianbattersby/public-repo/contributors",
    "subscribers_url": "https://api.github.com/repos/ianbattersby/public-repo/subscribers",
    "subscription_url": "https://api.github.com/repos/ianbattersby/public-repo/subscription",
    "commits_url": "https://api.github.com/repos/ianbattersby/public-repo/commits{/sha}",
    "git_commits_url": "https://api.github.com/repos/ianbattersby/public-repo/git/commits{/sha}",
    "comments_url": "https://api.github.com/repos/ianbattersby/public-repo/comments{/number}",
    "issue_comment_url": "https://api.github.com/repos/ianbattersby/public-repo/issues/comments{/number}",
    "contents_url": "https://api.github.com/repos/ianbattersby/public-repo/contents/{+path}",
    "compare_url": "https://api.github.com/repos/ianbattersby/public-repo/compare/{base}...{head}",
    "merges_url": "https://api.github.com/repos/ianbattersby/public-repo/merges",
    "archive_url": "https://api.github.com/repos/ianbattersby/public-repo/{archive_format}{/ref}",
    "downloads_url": "https://api.github.com/repos/ianbattersby/public-repo/downloads",
    "issues_url": "https://api.github.com/repos/ianbattersby/public-repo/issues{/number}",
    "pulls_url": "https://api.github.com/repos/ianbattersby/public-repo/pulls{/number}",
    "milestones_url": "https://api.github.com/repos/ianbattersby/public-repo/milestones{/number}",
    "notifications_url": "https://api.github.com/repos/ianbattersby/public-repo/notifications{?since,all,participating}",
    "labels_url": "https://api.github.com/repos/ianbattersby/public-repo/labels{/name}",
    "releases_url": "https://api.github.com/repos/ianbattersby/public-repo/releases{/id}",
    "created_at": "2015-05-05T23:40:12Z",
    "updated_at": "2015-05-05T23:40:30Z",
    "pushed_at": "2015-05-05T23:40:38Z",
    "git_url": "git://github.com/ianbattersby/public-repo.git",
    "ssh_url": "git@github.com:ianbattersby/public-repo.git",
    "clone_url": "https://github.com/ianbattersby/public-repo.git",
    "svn_url": "https://github.com/ianbattersby/public-repo",
    "homepage": null,
    "size": 0,
    "stargazers_count": 0,
    "watchers_count": 0,
    "language": null,
    "has_issues": true,
    "has_downloads": true,
    "has_wiki": true,
    "has_pages": true,
    "forks_count": 0,
    "mirror_url": null,
    "open_issues_count": 2,
    "forks": 0,
    "open_issues": 2,
    "watchers": 0,
    "default_branch": "master"
  },
  "sender": {
    "login": "ianbattersby",
    "id": 6752317,
    "avatar_url": "https://avatars.githubusercontent.com/u/6752317?v=3",
    "gravatar_id": "",
    "url": "https://api.github.com/users/ianbattersby",
    "html_url": "https://github.com/ianbattersby",
    "followers_url": "https://api.github.com/users/ianbattersby/followers",
    "following_url": "https://api.github.com/users/ianbattersby/following{/other_user}",
    "gists_url": "https://api.github.com/users/ianbattersby/gists{/gist_id}",
    "starred_url": "https://api.github.com/users/ianbattersby/starred{/owner}{/repo}",
    "subscriptions_url": "https://api.github.com/users/ianbattersby/subscriptions",
    "organizations_url": "https://api.github.com/users/ianbattersby/orgs",
    "repos_url": "https://api.github.com/users/ianbattersby/repos",
    "events_url": "https://api.github.com/users/ianbattersby/events{/privacy}",
    "received_events_url": "https://api.github.com/users/ianbattersby/received_events",
    "type": "User",
    "site_admin": false
  }
}

example-IssuesEvent.json

{
    "id": "9386735572",
    "type": "IssuesEvent",
    "actor": {
        "id": 508260,
        "login": "matthill",
        "gravatar_id": "",
        "url": "https://api.github.com/users/matthill",
        "avatar_url": "https://avatars.githubusercontent.com/u/508260?"
    },
    "repo": {
        "id": 47172074,
        "name": "openalpr/openalpr",
        "url": "https://api.github.com/repos/openalpr/openalpr"
    },
    "payload": {
        "action": "opened",
        "issue": {
            "url": "https://api.github.com/repos/openalpr/openalpr/issues/223",
            "labels_url": "https://api.github.com/repos/openalpr/openalpr/issues/223/labels{/name}",
            "comments_url": "https://api.github.com/repos/openalpr/openalpr/issues/223/comments",
            "events_url": "https://api.github.com/repos/openalpr/openalpr/issues/223/events",
            "html_url": "https://github.com/openalpr/openalpr/issues/223",
            "id": 118478322,
            "number": 223,
            "title": "Python 3 support",
            "user": {
                "login": "jk1ng",
                "id": 6633760,
                "avatar_url": "https://avatars.githubusercontent.com/u/6633760?v=3",
                "gravatar_id": "",
                "url": "https://api.github.com/users/jk1ng",
                "html_url": "https://github.com/jk1ng",
                "followers_url": "https://api.github.com/users/jk1ng/followers",
                "following_url": "https://api.github.com/users/jk1ng/following{/other_user}",
                "gists_url": "https://api.github.com/users/jk1ng/gists{/gist_id}",
                "starred_url": "https://api.github.com/users/jk1ng/starred{/owner}{/repo}",
                "subscriptions_url": "https://api.github.com/users/jk1ng/subscriptions",
                "organizations_url": "https://api.github.com/users/jk1ng/orgs",
                "repos_url": "https://api.github.com/users/jk1ng/repos",
                "events_url": "https://api.github.com/users/jk1ng/events{/privacy}",
                "received_events_url": "https://api.github.com/users/jk1ng/received_events",
                "type": "User",
                "site_admin": false
            },
            "labels": [],
            "state": "opened",
            "locked": false,
            "assignee": null,
            "milestone": null,
            "comments": 0,
            "created_at": "2015-11-23T21:38:18Z",
            "updated_at": "2015-11-27T20:40:51Z",
            "closed_at": "2015-11-27T20:40:51Z",
            "body": "Hi!\r\n\r\nIt seems that with Python 3, the current binding for OpenALPR in Python does not work.\r\n\r\nThis is because str/unicode in Python 2 have now become bytes/str in Python 3.\r\n\r\nThanks!"
        }
    },
    "public": true,
    "created_at": "2015-11-27T20:40:51Z",
    "org": {
        "id": 5896442,
        "login": "openalpr",
        "gravatar_id": "",
        "url": "https://api.github.com/orgs/openalpr",
        "avatar_url": "https://avatars.githubusercontent.com/u/5896442?"
    }
}

example-PushEvent.json

{
  "id": "9386735597",
  "type": "PushEvent",
  "actor": {
    "id": 293685,
    "login": "mattbellis",
    "gravatar_id": "",
    "url": "https://api.github.com/users/mattbellis",
    "avatar_url": "https://avatars.githubusercontent.com/u/293685?"
  },
  "repo": {
    "id": 47172074,
    "name": "particle-physics-playground/playground",
    "url": "https://api.github.com/repos/particle-physics-playground/playground"
  },
  "payload": {
    "push_id": 882178636,
    "size": 1,
    "distinct_size": 1,
    "ref": "refs/heads/master",
    "head": "0c35be9660a1ea300559a82b25b3776038028a12",
    "before": "cbba8b2441cff4142b4546347ad4907509812db5",
    "commits": [
      {
        "sha": "0c35be9660a1ea300559a82b25b3776038028a12",
        "author": {
          "email": "matthew.bellis@gmail.com",
          "name": "Matthew Bellis"
        },
        "message": "Fixed #223 new URL for downloading data.",
        "distinct": true,
        "url": "https://api.github.com/repos/particle-physics-playground/playground/commits/0c35be9660a1ea300559a82b25b3776038028a12"
      }
    ]
  },
  "public": true,
  "created_at": "2015-11-27T20:40:52Z",
  "org": {
    "id": 10271404,
    "login": "particle-physics-playground",
    "gravatar_id": "",
    "url": "https://api.github.com/orgs/particle-physics-playground",
    "avatar_url": "https://avatars.githubusercontent.com/u/10271404?"
  }
}

proj.repo-id.js

// When want to process issues and ideally by their repository's own tracked
// issue number, so it makes sense to split this data into per-repository 
// streams; thus all events for a certain repository end up in their own stream.
fromCategory("github")
  .foreachStream()
  .when({
      "IssuesEvent": function(s,e) {
          // In an ideal world we'd use linkTo here but it causes a problem
          // when consumingn with foreachStream, the problem being it doesn't
          // maintain the state correctly (TBC eventstore-guys).
          emit("repo-" + e.data.repo.id, e.eventType, e.data);
          return s;
      },
      "PushEvent": function(s,e) {
          // You will notice with an emit (opposed to a linkTo) we need to pass
          // the ES-EventType and the data object (not the whole event object).
          emit("repo-" + e.data.repo.id, e.eventType, e.data);
          return s;
      },
      "DeploymentEvent": function(s,e) {
          // This is hypothetical based on GitHubAPI documentation - as it's 
          // a trigger-only event so likely never comes through events API.
          emit("repo-" + e.data.repository.id, e.eventType, e.data);
          return s;
      }
  });

proj.repoLeaderBoard.js

// How do we match descriptions that close issues/etc?
var closingCommitRegEx = new RegExp("(((close|resolve)(s|d)?)|fix(e(s|d))?) #(\\d+)", "i");

// How do we tell the difference between two ISO8601 date strings?
function iso8601StringDateDiffInDays(date1, date2) {
    var msPerDay = 1000 * 60 * 60 * 24;
    var a = new Date(date1);
    var b = new Date(date2);
    var utc1 = Date.UTC(a.getFullYear(), a.getMonth(), a.getDate());
    var utc2 = Date.UTC(b.getFullYear(), b.getMonth(), b.getDate());

    return Math.floor((utc2 - utc1) / msPerDay);
}

// Some operating variables
var starRepositoryEventQualifiesInDays = 5;
var superRepositoryEventQualifiesInDays = 3;
var emitToStream = "proj.repoLeaderBoard";

// The projection
fromCategory("repo")
    .foreachStream()
    .when({
        $init: function() {
            return {
                trackedIssues: []
            };
        },
        "IssuesEvent": function(s, e) {
            if (e.data.payload.action && e.data.payload.action === "opened" && e.data.payload.issue.number) {
                s.trackedIssues[e.data.payload.issue.number] = {
                    createdOn: e.data.payload.issue.created_at,
                    fixedOn: null,
                    deployedOn: null
                };
            }

            return s;
        },
        "PushEvent": function(s, e) {
            if (s.trackedIssues.length > 0 && e.data.payload.commits && e.data.payload.commits.length > 0) {
                for (var i = 0; i < e.data.payload.commits.length; i++) {
                    if (e.data.payload.commits[i].message && closingCommitRegEx.test(e.data.payload.commits[i].message)) {
                        var issueNumber = closingCommitRegEx.exec(e.data.payload.commits[i].message).reverse()[0];

                        //Are we tracking this issue?
                        if (s.trackedIssues[issueNumber] !== undefined && s.trackedIssues[issueNumber] !== null && s.trackedIssues[issueNumber].createdOn !== null) {
                          //s.trackedIssues[issueNumber].fixedOn = e.data.payload.commits[i].timestamp;
                          s.trackedIssues[issueNumber].fixedOn = e.data.created_at;

                            if (iso8601StringDateDiffInDays(s.trackedIssues[issueNumber].createdOn, s.trackedIssues[issueNumber].fixedOn) <= starRepositoryEventQualifiesInDays) {
                                emit(emitToStream, "StarRepositoryEvent", e.data);
                                break;
                            }
                        } else {
                            // Is it possible we'll encounter the issue after the push? Erm.
                            // If we decide to do this we'll need to remove the length condition
                            // above so we get in here.
                        }
                    }
                }
            }

            return s;
        },
        "DeploymentEvent": function(s, e) {
            if (e.data.deployment.environment === "production") {
                var thisDeploymentDate = e.data.deployment.created_at;

                if (e.data.deployment.description && closingCommitRegEx.test(e.data.deployment.description)) {
                    var issueNumber = closingCommitRegEx.exec(e.data.deployment.description).reverse()[0];

                    //Are we tracking this issue?
                    if (s.trackedIssues[issueNumber] !== undefined && s.trackedIssues[issueNumber] !== null) {
                        s.trackedIssues[issueNumber].deployedOn = thisDeploymentDate;
                        if (iso8601StringDateDiffInDays(s.trackedIssues[issueNumber].fixedOn, thisDeploymentDate) <= superRepositoryEventQualifiesInDays) {
                            emit(emitToStream, "SuperDuperRepositoryEvent", e.data);
                        }
                    }
                } else {
                    // Could be we don't have a description :-(
                    for (var idx in s.trackedIssues) {
                        if (s.trackedIssues.hasOwnProperty(idx)) {
                            if (s.trackedIssues[idx] !== undefined && s.trackedIssues[idx] !== null && s.trackedIssues[idx].fixedOn !== null && thisDeploymentDate > s.trackedIssues[idx].fixedOn) {
                                //We'll assume any issues we are tracking or deployed if this is after they were fixed!
                                s.trackedIssues[idx].deployedOn = thisDeploymentDate;
                                if (iso8601StringDateDiffInDays(s.trackedIssues[idx].fixedOn, thisDeploymentDate) <= superRepositoryEventQualifiesInDays) {
                                    emit(emitToStream, "SuperRepositoryEvent", e.data);
                                }
                            }
                        }
                    }
                }
            }

            return s;
        }
    });