mirror of https://github.com/MISP/misp-modules
Merge pull request #5 from passivetotal/master
Rewrote the entire PassiveTotal extensionpull/7/head
commit
c1dcb8be6b
|
|
@ -11,7 +11,7 @@ MISP modules support is included in MISP starting from version 2.4.28.
|
|||
|
||||
* [CVE](modules/expansion/cve.py) - a hover module to give more information about a vulnerability (CVE).
|
||||
* [DNS](modules/expansion/dns.py) - a simple module to resolve MISP attributes like hostname and domain to expand IP addresses attributes.
|
||||
* [passivetotal](modules/expansion/passivetotal.py) - a [passivetotal](https://www.passivetotal.org/) module to query the passivetotal passive DNS interface.
|
||||
* [passivetotal](modules/expansion/passivetotal.py) - a [passivetotal](https://www.passivetotal.org/) module that queries a number of different PassiveTotal datasets.
|
||||
* [sourcecache](modules/expansion/sourcecache.py) - a module to cache a specific link from a MISP instance.
|
||||
|
||||
## How to install and start MISP modules?
|
||||
|
|
|
|||
|
|
@ -2,3 +2,4 @@ tornado
|
|||
dnspython3
|
||||
requests
|
||||
urlarchiver
|
||||
passivetotal
|
||||
|
|
|
|||
|
|
@ -1,63 +1,340 @@
|
|||
import json
|
||||
import requests
|
||||
import logging
|
||||
import sys
|
||||
|
||||
from passivetotal.common.utilities import is_ip
|
||||
|
||||
|
||||
log = logging.getLogger('passivetotal')
|
||||
log.setLevel(logging.DEBUG)
|
||||
ch = logging.StreamHandler(sys.stdout)
|
||||
ch.setLevel(logging.DEBUG)
|
||||
formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
|
||||
ch.setFormatter(formatter)
|
||||
log.addHandler(ch)
|
||||
|
||||
misperrors = {'error': 'Error'}
|
||||
mispattributes = {'input': ['hostname', 'domain', 'ip-src', 'ip-dst'], 'output': ['ip-src', 'ip-dst', 'hostname', 'domain']}
|
||||
moduleinfo = {'version': '0.1', 'author': 'Alexandre Dulaunoy', 'description': 'PassiveTotal expansion service to expand values with multiple Passive DNS sources', 'module-type': ['expansion']}
|
||||
moduleconfig = ['username', 'password']
|
||||
passivetotal_url = 'https://api.passivetotal.org/v2/dns/passive?query='
|
||||
mispattributes = {
|
||||
'input': ['hostname', 'domain', 'ip-src', 'ip-dst',
|
||||
'x509-fingerprint-sha1', 'email-src', 'email-dst',
|
||||
'target-email', 'whois-registrant-email',
|
||||
'whois-registrant-phone', 'text', 'whois-registrant-name',
|
||||
'whois-registrar', 'whois-creation-date'],
|
||||
'output': ['hostname', 'domain', 'ip-src', 'ip-dst',
|
||||
'x509-fingerprint-sha1', 'email-src', 'email-dst',
|
||||
'target-email', 'whois-registrant-email',
|
||||
'whois-registrant-phone', 'text', 'whois-registrant-name',
|
||||
'whois-registrar', 'whois-creation-date', 'md5', 'sha1',
|
||||
'sha256', 'link']
|
||||
}
|
||||
moduleinfo = {
|
||||
'version': '1.0',
|
||||
'author': 'Brandon Dixon',
|
||||
'description': 'The PassiveTotal MISP expansion module brings the datasets derived from Internet scanning directly into your MISP instance. This module supports passive DNS, historic SSL, WHOIS, and host attributes. In order to use the module, you must have a valid PassiveTotal account username and API key. Registration is free and can be done by visiting https://www.passivetotal.org/register',
|
||||
'module-type': ['expansion', 'hover']
|
||||
}
|
||||
moduleconfig = ['username', 'api_key']
|
||||
query_playbook = [
|
||||
{'inputs': ['ip-src', 'ip-dst', 'hostname', 'domain'],
|
||||
'services': ['whois', 'ssl', 'dns', 'enrichment'],
|
||||
'name': 'generic'},
|
||||
{'inputs': ['whois-registrant-email', 'whois-registrant-phone',
|
||||
'whois-registrant-name', 'email-src', 'email-dst',
|
||||
'target-email'],
|
||||
'services': ['whois'],
|
||||
'name': 'reverse-whois'},
|
||||
{'inputs': ['x509-fingerprint-sha1'],
|
||||
'services': ['ssl'],
|
||||
'name': 'ssl-history'},
|
||||
]
|
||||
|
||||
|
||||
def query_finder(request):
|
||||
"""Find the query value in the client request."""
|
||||
for item in mispattributes['input']:
|
||||
if not request.get(item, None):
|
||||
continue
|
||||
|
||||
playbook = None
|
||||
for x in query_playbook:
|
||||
if item not in x['inputs']:
|
||||
continue
|
||||
playbook = x
|
||||
break
|
||||
|
||||
return {'type': item, 'value': request.get(item), 'playbook': playbook}
|
||||
|
||||
|
||||
def build_profile(request):
|
||||
"""Check the incoming request for a valid configuration."""
|
||||
output = {'success': False}
|
||||
config = request.get('config', None)
|
||||
if not config:
|
||||
misperrors['error'] = "Configuration is missing from the request."
|
||||
return output
|
||||
|
||||
for item in moduleconfig:
|
||||
if config.get(item, None):
|
||||
continue
|
||||
misperrors['error'] = "PassiveTotal authentication is missing."
|
||||
return output
|
||||
|
||||
profile = {'success': True, 'config': config}
|
||||
profile.update(query_finder(request))
|
||||
|
||||
return profile
|
||||
|
||||
|
||||
def _generate_request_instance(conf, request_type):
|
||||
"""Automatically generate a request instance to use.
|
||||
|
||||
In the end, this saves us from having to load each request class in a
|
||||
explicit way. Loading via a string is helpful to reduce the code per
|
||||
call.
|
||||
|
||||
:param request_type: Type of client to load
|
||||
:return: Loaded PassiveTotal client
|
||||
"""
|
||||
pt_username = conf.get('username')
|
||||
pt_api_key = conf.get('api_key')
|
||||
|
||||
class_lookup = {'dns': 'DnsRequest', 'whois': 'WhoisRequest',
|
||||
'ssl': 'SslRequest', 'enrichment': 'EnrichmentRequest',
|
||||
'attributes': 'AttributeRequest'}
|
||||
class_name = class_lookup[request_type]
|
||||
mod = __import__('passivetotal.libs.%s' % request_type,
|
||||
fromlist=[class_name])
|
||||
loaded = getattr(mod, class_name)
|
||||
headers = {'PT-INTEGRATION': 'MISP'}
|
||||
authenticated = loaded(pt_username, pt_api_key, headers=headers)
|
||||
return authenticated
|
||||
|
||||
|
||||
def _has_error(results):
|
||||
"""Check to see if there's an error in place and log it."""
|
||||
if 'error' in results:
|
||||
msg = "%s - %s" % (results['error']['message'],
|
||||
results['error']['developer_message'])
|
||||
misperrors['error'] = msg
|
||||
return True
|
||||
|
||||
return False
|
||||
|
||||
|
||||
def process_ssl_details(instance, query):
|
||||
"""Process details for a specific certificate."""
|
||||
log.debug("SSL Details: starting")
|
||||
values = list()
|
||||
_ = instance.get_ssl_certificate_details(query=query)
|
||||
err = _has_error(_)
|
||||
if err:
|
||||
raise Exception("We hit an error, time to bail!")
|
||||
|
||||
for key, value in _.items():
|
||||
if not value:
|
||||
continue
|
||||
values.append(value)
|
||||
txt = [{'types': ['ssl-cert-attributes'], 'values': list(set(values))}]
|
||||
log.debug("SSL Details: ending")
|
||||
|
||||
return txt
|
||||
|
||||
|
||||
def process_ssl_history(instance, query):
|
||||
"""Process the history for an SSL certificate."""
|
||||
log.debug("SSL History: starting")
|
||||
|
||||
type_map = {
|
||||
'ip': ['ip-src', 'ip-dst'],
|
||||
'domain': ['domain', 'hostname'],
|
||||
'sha1': ['x509-fingerprint-sha1']
|
||||
}
|
||||
|
||||
hits = {'ip': list(), 'sha1': list(), 'domain': list()}
|
||||
_ = instance.get_ssl_certificate_history(query=query)
|
||||
err = _has_error(_)
|
||||
if err:
|
||||
raise Exception("We hit an error, time to bail!")
|
||||
|
||||
for item in _.get('results', []):
|
||||
hits['ip'] += item.get('ipAddresses', [])
|
||||
hits['sha1'].append(item['sha1'])
|
||||
hits['domain'] += item.get('domains', [])
|
||||
|
||||
tmp = list()
|
||||
for key, value in hits.items():
|
||||
txt = {'types': type_map[key], 'values': list(set(value))}
|
||||
tmp.append(txt)
|
||||
|
||||
log.debug("SSL Details: ending")
|
||||
|
||||
return tmp
|
||||
|
||||
|
||||
def process_whois_details(instance, query):
|
||||
"""Process the detail from the WHOIS record."""
|
||||
log.debug("WHOIS Details: starting")
|
||||
tmp = list()
|
||||
_ = instance.get_whois_details(query=query, compact_record=True)
|
||||
err = _has_error(_)
|
||||
if err:
|
||||
raise Exception("We hit an error, time to bail!")
|
||||
|
||||
if _.get('contactEmail', None):
|
||||
tmp.append({'types': ['whois-registrant-email'], 'values': [_.get('contactEmail')]})
|
||||
phones = _['compact']['telephone']['raw']
|
||||
tmp.append({'types': ['whois-registrant-phone'], 'values': phones})
|
||||
names = _['compact']['name']['raw']
|
||||
tmp.append({'types': ['whois-registrant-name'], 'values': names})
|
||||
if _.get('registrar', None):
|
||||
tmp.append({'types': ['whois-registrar'], 'values': [_.get('registrar')]})
|
||||
if _.get('registered', None):
|
||||
tmp.append({'types': ['whois-creation-date'], 'values': [_.get('registered')]})
|
||||
log.debug("WHOIS Details: ending")
|
||||
|
||||
return tmp
|
||||
|
||||
|
||||
def process_whois_search(instance, query, qtype):
|
||||
"""Process a WHOIS search for a specific field value."""
|
||||
log.debug("WHOIS Search: starting")
|
||||
if qtype in ['whois-registrant-email', 'email-src', 'email-dst', 'target-email']:
|
||||
field_type = 'email'
|
||||
if qtype in ['whois-registrant-phone']:
|
||||
field_type = 'phone'
|
||||
if qtype in ['whois-registrant-name']:
|
||||
field_type = 'name'
|
||||
|
||||
domains = list()
|
||||
_ = instance.search_whois_by_field(field=field_type, query=query)
|
||||
err = _has_error(_)
|
||||
if err:
|
||||
raise Exception("We hit an error, time to bail!")
|
||||
|
||||
for item in _.get('results', []):
|
||||
domain = item.get('domain', None)
|
||||
if not domain:
|
||||
continue
|
||||
domains.append(domain)
|
||||
|
||||
tmp = [{'types': ['hostname', 'domain'], 'values': list(set(domains))}]
|
||||
log.debug("WHOIS Search: ending")
|
||||
|
||||
return tmp
|
||||
|
||||
|
||||
def process_passive_dns(instance, query):
|
||||
"""Process passive DNS data."""
|
||||
log.debug("Passive DNS: starting")
|
||||
tmp = list()
|
||||
_ = instance.get_unique_resolutions(query=query)
|
||||
err = _has_error(_)
|
||||
if err:
|
||||
raise Exception("We hit an error, time to bail!")
|
||||
|
||||
if is_ip(query):
|
||||
tmp = [{'types': ['domain', 'hostname'], 'values': _.get('results', [])}]
|
||||
else:
|
||||
tmp = [{'types': ['ip-src', 'ip-dst'], 'values': _.get('results', [])}]
|
||||
log.debug("Passive DNS: ending")
|
||||
|
||||
return tmp
|
||||
|
||||
|
||||
def process_osint(instance, query):
|
||||
"""Process OSINT links."""
|
||||
log.debug("OSINT: starting")
|
||||
urls = list()
|
||||
_ = instance.get_osint(query=query)
|
||||
err = _has_error(_)
|
||||
if err:
|
||||
raise Exception("We hit an error, time to bail!")
|
||||
|
||||
for item in _.get('results', []):
|
||||
urls.append(item['sourceUrl'])
|
||||
|
||||
tmp = [{'types': ['link'], 'values': urls}]
|
||||
log.debug("OSINT: ending")
|
||||
|
||||
return tmp
|
||||
|
||||
|
||||
def process_malware(instance, query):
|
||||
"""Process malware samples."""
|
||||
log.debug("Malware: starting")
|
||||
content = {'hashes': list(), 'urls': list()}
|
||||
_ = instance.get_malware(query=query)
|
||||
err = _has_error(_)
|
||||
if err:
|
||||
raise Exception("We hit an error, time to bail!")
|
||||
|
||||
for item in _.get('results', []):
|
||||
content['hashes'].append(item['sample'])
|
||||
content['urls'].append(item['sourceUrl'])
|
||||
|
||||
tmp = [{'types': ['link'], 'values': content['urls']}]
|
||||
hashes = {'md5': list(), 'sha1': list(), 'sha256': list()}
|
||||
for h in content['hashes']:
|
||||
if len(h) == 32:
|
||||
hashes['md5'].append(h)
|
||||
elif len(h) == 41:
|
||||
hashes['sha1'].append(h)
|
||||
elif len(h) == 64:
|
||||
hashes['sha256'].append(h)
|
||||
tmp += [{'types': ['md5'], 'values': hashes['md5']}]
|
||||
tmp += [{'types': ['sha1'], 'values': hashes['sha1']}]
|
||||
tmp += [{'types': ['sha256'], 'values': hashes['sha256']}]
|
||||
log.debug("Malware: ending")
|
||||
|
||||
return tmp
|
||||
|
||||
|
||||
def handler(q=False):
|
||||
if q is False:
|
||||
return False
|
||||
if not q:
|
||||
return q
|
||||
|
||||
request = json.loads(q)
|
||||
|
||||
if (request.get('config')):
|
||||
if (request['config'].get('username') is None) or (request['config'].get('password') is None):
|
||||
misperrors['error'] = 'Passivetotal authentication is missing'
|
||||
profile = build_profile(request)
|
||||
if not profile['success']:
|
||||
log.error(misperrors['error'])
|
||||
return misperrors
|
||||
|
||||
output = {'results': list()}
|
||||
|
||||
instances = dict()
|
||||
for service in profile['playbook']['services']:
|
||||
instances[service] = _generate_request_instance(
|
||||
profile['config'], service)
|
||||
|
||||
play_type = profile['playbook']['name']
|
||||
query = profile['value']
|
||||
qtype = profile['type']
|
||||
try:
|
||||
if play_type == 'generic':
|
||||
results = process_passive_dns(instances['dns'], query)
|
||||
output['results'] += results
|
||||
results = process_whois_details(instances['whois'], query)
|
||||
output['results'] += results
|
||||
results = process_ssl_history(instances['ssl'], query)
|
||||
output['results'] += results
|
||||
results = process_osint(instances['enrichment'], query)
|
||||
output['results'] += results
|
||||
results = process_malware(instances['enrichment'], query)
|
||||
output['results'] += results
|
||||
elif play_type == 'reverse-whois':
|
||||
results = process_whois_search(instances['whois'], query, qtype)
|
||||
output['results'] += results
|
||||
elif play_type == 'ssl-history':
|
||||
results = process_ssl_details(instances['ssl'], query)
|
||||
output['results'] += results
|
||||
results = process_ssl_history(instances['ssl'], query)
|
||||
output['results'] += results
|
||||
else:
|
||||
misperrors['error'] = 'config is missing'
|
||||
log.error("Unsupported query pattern issued.")
|
||||
except:
|
||||
return misperrors
|
||||
if request.get('hostname'):
|
||||
toquery = request['hostname']
|
||||
queryhost = True
|
||||
elif request.get('domain'):
|
||||
toquery = request['domain']
|
||||
queryhost = True
|
||||
elif request.get('ip-src'):
|
||||
toquery = request['ip-src']
|
||||
queryhost = False
|
||||
elif request.get('ip-dst'):
|
||||
toquery = request['ip-dst']
|
||||
queryhost = False
|
||||
else:
|
||||
return False
|
||||
|
||||
r = requests.get(passivetotal_url+toquery, auth=(request['config'].get('username'),request['config'].get('password')))
|
||||
if r.status_code == 200:
|
||||
x = json.loads(r.text)
|
||||
a = []
|
||||
if queryhost:
|
||||
mispattributes['output'] = ['ip-src', 'ip-dst']
|
||||
else:
|
||||
mispattributes['output'] = ['hostname']
|
||||
|
||||
for y in x['results']:
|
||||
if queryhost:
|
||||
a.append(y['resolve'])
|
||||
else:
|
||||
a.append(y['resolve'])
|
||||
elif r.status_code >= 400 and r.status_code < 404 :
|
||||
misperrors['error'] = 'Passivetotal.org incorrect authentication'
|
||||
return misperrors['error']
|
||||
else:
|
||||
misperrors['error'] = 'Passivetotal.org is not reachable'
|
||||
return misperrors['error']
|
||||
|
||||
r = {'results': [{'types': mispattributes['output'], 'values': a}]}
|
||||
return r
|
||||
return output
|
||||
|
||||
|
||||
def introspection():
|
||||
|
|
@ -67,3 +344,4 @@ def introspection():
|
|||
def version():
|
||||
moduleinfo['config'] = moduleconfig
|
||||
return moduleinfo
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue