mirror of https://github.com/MISP/PyMISP
commit
6aab2717e2
|
@ -5,4 +5,5 @@ misp_url = 'https://<your MISP URL>/'
|
||||||
misp_key = 'Your MISP auth key' # The MISP auth key can be found on the MISP web interface under the automation section
|
misp_key = 'Your MISP auth key' # The MISP auth key can be found on the MISP web interface under the automation section
|
||||||
misp_verifycert = True
|
misp_verifycert = True
|
||||||
misp_client_cert = ''
|
misp_client_cert = ''
|
||||||
proofpoint_key = 'Your Proofpoint TAP auth key'
|
proofpoint_sp = '<proofpoint service principal>' # Service Principal from TAP (https://threatinsight.proofpoint.com/<custID>/settings/connected-applications)
|
||||||
|
proofpoint_secret = '<proofpoint secret>'
|
|
@ -1,7 +1,14 @@
|
||||||
import requests
|
import requests
|
||||||
|
from requests.auth import HTTPBasicAuth
|
||||||
import json
|
import json
|
||||||
from pymisp import ExpandedPyMISP, MISPEvent, MISPOrganisation
|
from pymisp import ExpandedPyMISP, MISPEvent
|
||||||
from keys import misp_url, misp_key, misp_verifycert, proofpoint_key
|
from keys import misp_url, misp_key, misp_verifycert, proofpoint_sp, proofpoint_secret
|
||||||
|
import urllib3
|
||||||
|
urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)
|
||||||
|
|
||||||
|
if proofpoint_secret == '<proofpoint secret>':
|
||||||
|
print('Set the proofpoint_secret in keys.py before running. Exiting...')
|
||||||
|
quit()
|
||||||
|
|
||||||
# initialize PyMISP and set url for Panorama
|
# initialize PyMISP and set url for Panorama
|
||||||
misp = ExpandedPyMISP(url=misp_url, key=misp_key, ssl=misp_verifycert)
|
misp = ExpandedPyMISP(url=misp_url, key=misp_key, ssl=misp_verifycert)
|
||||||
|
@ -16,24 +23,19 @@ queryString = {
|
||||||
"format": "json"
|
"format": "json"
|
||||||
}
|
}
|
||||||
|
|
||||||
# auth to api needs to be set as a header, not as part of the query string
|
|
||||||
headers = {
|
|
||||||
'Authorization': "Basic " + proofpoint_key
|
|
||||||
}
|
|
||||||
|
|
||||||
responseSiem = requests.request("GET", urlSiem, headers=headers, params=queryString)
|
|
||||||
|
responseSiem = requests.request("GET", urlSiem, params=queryString, auth=HTTPBasicAuth(proofpoint_sp, proofpoint_secret))
|
||||||
|
if 'Credentials authentication failed' in responseSiem.text:
|
||||||
|
print('Credentials invalid, please edit keys.py and try again')
|
||||||
|
quit()
|
||||||
|
|
||||||
jsonDataSiem = json.loads(responseSiem.text)
|
jsonDataSiem = json.loads(responseSiem.text)
|
||||||
|
|
||||||
for alert in alertType:
|
for alert in alertType:
|
||||||
for messages in jsonDataSiem[alert]:
|
for messages in jsonDataSiem[alert]:
|
||||||
orgc = MISPOrganisation()
|
|
||||||
orgc.name = 'Proofpoint'
|
|
||||||
orgc.id = '#{ORGC.ID}' # organisation id
|
|
||||||
orgc.uuid = '#{ORGC.UUID}' # organisation uuid
|
|
||||||
# initialize and set MISPEvent()
|
# initialize and set MISPEvent()
|
||||||
event = MISPEvent()
|
event = MISPEvent()
|
||||||
event.Orgc = orgc
|
|
||||||
if alert == "messagesDelivered" or alert == "messagesBlocked":
|
if alert == "messagesDelivered" or alert == "messagesBlocked":
|
||||||
if alert == "messagesDelivered":
|
if alert == "messagesDelivered":
|
||||||
event.info = alert
|
event.info = alert
|
||||||
|
@ -112,7 +114,7 @@ for alert in alertType:
|
||||||
# get campaignID from each TAP alert and query campaign API
|
# get campaignID from each TAP alert and query campaign API
|
||||||
if threatInfo["campaignID"] is not None and threatInfo["campaignID"] != "":
|
if threatInfo["campaignID"] is not None and threatInfo["campaignID"] != "":
|
||||||
urlCampaign = "https://tap-api-v2.proofpoint.com/v2/campaign/" + threatInfo["campaignID"]
|
urlCampaign = "https://tap-api-v2.proofpoint.com/v2/campaign/" + threatInfo["campaignID"]
|
||||||
responseCampaign = requests.request("GET", urlCampaign, headers=headers)
|
responseCampaign = requests.request("GET", urlCampaign, auth=HTTPBasicAuth(proofpoint_sp, proofpoint_secret))
|
||||||
|
|
||||||
jsonDataCampaign = json.loads(responseCampaign.text)
|
jsonDataCampaign = json.loads(responseCampaign.text)
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue