Turn vendor security advisories into Jira tickets

import feedparser
from clickruntime import on_trigger, credentials, http, notify, state, report_fetched

JIRA, SITE = "https://api.atlassian.com/ex/jira/your-cloud-id", "https://acme.atlassian.net/browse/"
adf = lambda text: {"type": "doc", "version": 1, "content": [{"type": "paragraph", "content": [{"type": "text", "text": text}]}]}

def jira(method, path, **kw):
    resp = http.request(method, JIRA + path, headers={"Authorization": f"Bearer {credentials.connection('jira', 'work')}", "Accept": "application/json"}, **kw)
    return resp.raise_for_status() or (resp.json() if resp.content else None)

FEEDS = ["https://vendor-one.example/security/rss", "https://vendor-two.example/advisories.atom"]

@on_trigger
def run(event):
    seen = state.get("seen")
    entries = [e for url in FEEDS for e in feedparser.parse(http.get(url).content).entries]
    new = [e for e in entries if seen is not None and e.link not in seen]
    report_fetched(len(new))
    if not new and seen is not None:
        return {"new": 0}
    created = []
    for e in new:
        t = jira("POST", "/rest/api/3/issue", json={"fields": {"project": {"key": "SEC"}, "issuetype": {"name": "Task"},
                 "summary": f"Advisory: {e.title}"[:250], "labels": ["vendor-advisory"], "description": adf(f"{e.get('published', '')}\n{e.link}")}})
        created.append(f"{t['key']} {e.title}")
    if created:
        notify.email_me(f"{len(created)} new security advisories", "\n".join(created))
    state.set("seen", sorted({e.link for e in entries} | set(seen or [])))
    return {"new": len(created)}