76 Commits

Author SHA1 Message Date
kpcyrd
686e1e5119 Release v0.8.1 2019-01-13 01:04:03 +01:00
kpcyrd
913e9a9f4f Update feature list format 2019-01-13 01:02:55 +01:00
kpcyrd
7a1cf34646 Update readme table of contents 2019-01-12 11:42:49 +01:00
kpcyrd
ed5e913275 Merge pull request #58 from kpcyrd/dns-cache
Add a dns-cache
2019-01-12 11:37:52 +01:00
kpcyrd
be2e859efd Merge some examples 2019-01-12 09:58:30 +01:00
kpcyrd
ef711c4fae Bump dependencies 2019-01-12 09:30:50 +01:00
kpcyrd
e8a8072349 Travis: skip sqlite install on osx 2019-01-12 08:58:32 +01:00
kpcyrd
592d697888 Remove some unused code 2019-01-12 05:04:11 +01:00
kpcyrd
f8807b7a60 Use chrootable-https dns cache 2019-01-12 04:35:05 +01:00
kpcyrd
40b97d74b4 Fix san extension parser bug 2019-01-10 21:08:54 +01:00
kpcyrd
4b8cc88871 Document sandbox 2019-01-10 08:04:34 +01:00
kpcyrd
3136ed522e Update module versions 2019-01-10 01:07:09 +01:00
kpcyrd
5cb3460ef4 Release v0.8.0 2019-01-07 03:28:39 +01:00
kpcyrd
bfe589e5a0 Use x509 parser in ctlogs module 2019-01-07 02:41:30 +01:00
kpcyrd
a29d3b1739 Use alpine dockerfile again 2019-01-07 01:16:34 +01:00
kpcyrd
f01f299e02 Connect iwdump module to database 2019-01-06 21:33:46 +01:00
kpcyrd
b0f25110a3 Expose select to non-interactive mode 2019-01-06 21:24:00 +01:00
kpcyrd
494e503d84 Add CONTRIBUTING.md 2019-01-06 18:36:05 +01:00
kpcyrd
27608f9bdd Suggest running help on unknown command 2019-01-06 16:37:28 +01:00
kpcyrd
b429355a46 Add git webroot scanner 2019-01-06 16:32:42 +01:00
kpcyrd
0b9474fdbd Link to webirc 2019-01-04 01:30:26 +01:00
kpcyrd
97ea7daef8 Connect dhcpd parser to database 2019-01-02 04:18:00 +01:00
kpcyrd
a39c901b2f Merge pull request #57 from kpcyrd/options
Introduce an option system
2019-01-01 22:30:17 +01:00
kpcyrd
8ccccea367 Introduce an option system 2019-01-01 20:25:54 +01:00
kpcyrd
5df4f180e5 Add dhcpd and iw station dump parser 2019-01-01 06:43:59 +01:00
kpcyrd
b49d97e55c Merge pull request #53 from kpcyrd/networks
Add networks and devices
2019-01-01 05:52:49 +01:00
kpcyrd
570c6b4225 Generate readme toc from docs/ 2019-01-01 02:27:07 +01:00
kpcyrd
6fbebd8544 Document proxy config 2019-01-01 01:57:13 +01:00
kpcyrd
86c2b91c73 Exclude unneeded open syscall 2019-01-01 01:38:51 +01:00
kpcyrd
db2203b286 Merge pull request #56 from kpcyrd/socks5
Add socks5 support
2019-01-01 01:37:02 +01:00
kpcyrd
1772d8b9e3 Fix docker hub 2018-12-31 18:20:33 +01:00
kpcyrd
9814167212 Add docker usage instructions 2018-12-31 04:01:29 +01:00
kpcyrd
5b039fe0eb Add socks5 support 2018-12-31 03:49:50 +01:00
kpcyrd
9d414da7d4 Merge pull request #54 from kpcyrd/selftest
Add features to support selftest
2018-12-31 03:44:55 +01:00
kpcyrd
b828f2d6f0 Update description 2018-12-29 16:11:34 +01:00
kpcyrd
06ae0958ec Introduce help command
Resolve #55
2018-12-28 05:00:45 +01:00
kpcyrd
2747e5a1c5 Add table of contents to readme 2018-12-28 04:14:44 +01:00
kpcyrd
6e210acc90 Add features to support selftest 2018-12-26 14:37:18 +01:00
kpcyrd
653b1bd340 Add ipaddr to device table 2018-12-26 00:19:26 +01:00
kpcyrd
0b719b832c Add devices and networks 2018-12-25 14:55:11 +01:00
kpcyrd
7dcb950899 Add ieee iab and oui to repo 2018-12-25 13:10:48 +01:00
kpcyrd
41e8b4f047 Release v0.7.0 2018-12-24 02:43:39 +01:00
kpcyrd
145b6dfa9a Add reverse dns and description for ips 2018-12-24 01:14:02 +01:00
kpcyrd
5368ef3e52 Allow keyring as source argument 2018-12-23 23:44:48 +01:00
kpcyrd
a95ba52e97 Add phpmyadmin url bruteforce 2018-12-23 19:45:55 +01:00
kpcyrd
e578b4eea7 Merge pull request #50 from kpcyrd/phone
Support phonenumbers
2018-12-23 19:41:06 +01:00
kpcyrd
b9e920d890 Fix tests 2018-12-23 18:41:19 +01:00
kpcyrd
765a9d161c Refactor entity formatting 2018-12-23 17:17:25 +01:00
kpcyrd
fcd8867a15 clippy fixes 2018-12-23 17:17:25 +01:00
kpcyrd
0928ea12c6 Ask the user to grant access to credentials 2018-12-23 17:17:25 +01:00
kpcyrd
641f46892b Connect keyring to modules 2018-12-23 17:17:25 +01:00
kpcyrd
776d02e8cc Automatically encode input in log functions 2018-12-23 17:17:25 +01:00
kpcyrd
0db0dd263e Add twilio lookup prototype 2018-12-23 17:17:25 +01:00
kpcyrd
73ac953ee4 Rename and document accesskey command to keyring 2018-12-23 17:17:25 +01:00
kpcyrd
3b4381cf3b Add accesskey manager 2018-12-23 17:17:25 +01:00
kpcyrd
3c853b83d4 Add more fields to phonenumber table 2018-12-23 17:17:25 +01:00
kpcyrd
93d6fb12a7 Add phonenumbers to database 2018-12-23 17:17:25 +01:00
kpcyrd
2f4fa798c1 Refactor module loader 2018-12-21 03:07:09 +01:00
kpcyrd
426ec77eb3 Remove obsolete update command 2018-12-21 02:49:35 +01:00
kpcyrd
40efb237d7 Replace dockerfile with debian for now 2018-12-20 23:42:10 +01:00
kpcyrd
ffc8ce6a3c Bump some module versions 2018-12-20 20:43:33 +01:00
kpcyrd
8f16948443 Merge pull request #49 from kpcyrd/async-chrootable
Port to async chrootable-https
2018-12-12 01:59:02 +01:00
kpcyrd
3a84395551 Port to async chrootable-https 2018-12-12 00:25:40 +01:00
kpcyrd
d8923f4b46 Bump dependencies 2018-12-10 14:53:47 +01:00
kpcyrd
699c242136 Merge pull request #48 from kpcyrd/rocket-4
Port to rocket 0.4
2018-12-10 14:50:51 +01:00
kpcyrd
347da4825c Remove custom_derive feature 2018-12-10 03:43:43 +01:00
kpcyrd
55cba1e04d Improve error messages 2018-12-10 02:08:55 +01:00
kpcyrd
f6559668c2 Improve error handling 2018-12-10 02:08:55 +01:00
kpcyrd
b42323d63c Move cache-control headers to registry code 2018-12-10 02:08:55 +01:00
kpcyrd
e3ee1a7f20 Move security headers to registry code 2018-12-10 02:08:55 +01:00
kpcyrd
75c888c473 Port to latest rocket version 2018-12-10 02:08:55 +01:00
kpcyrd
5735af29b2 Merge pull request #47 from kpcyrd/2018
Port to rust 2018 edition
2018-12-10 02:07:05 +01:00
kpcyrd
212aa9601e Port sn0int-registry to 2018 edition 2018-12-09 15:27:42 +01:00
kpcyrd
5582892763 Port sn0int-common to 2018 edition 2018-12-09 15:19:27 +01:00
kpcyrd
7b91e6f872 Port to 2018 edition 2018-12-09 15:17:50 +01:00
kpcyrd
d77b2b39e0 cargo fix --edition 2018-12-09 15:17:50 +01:00
156 changed files with 36205 additions and 1763 deletions

View File

@@ -1,6 +1,9 @@
target
Dockerfile
.dockerignore
docker
docs
ci
.git
.gitignore
*.sw[op]

32
CONTRIBUTING.md Normal file
View File

@@ -0,0 +1,32 @@
# How to contribute
To contribute to sn0int, clone the repository and make sure both the build and
tests pass for you:
git clone https://github.com/kpcyrd/sn0int.git
cd sn0int
# build the project
cargo build
# run regular tests
cargo test
# run tests depending on the network
# these might fail if a service is down
cargo test -- --ignored
The project is loosely structured into a few folders:
- `src/models/` - database models
- `src/runtime/` - the stdlib that's exposed to lua
- `src/engine/` - code related to lua
- `src/sandbox/` - code related to sandboxing
- `src/cmd/` - cli commands
- `src/` - misc modules
After you're done, make sure the build completes without any warnings and both
tests pass successfully:
cargo test
cargo test -- --ignored
If you want to introduce a new feature feel free to open an issue first to make
sure your feature is a good fit for the project before implementing it.

1421
Cargo.lock generated

File diff suppressed because it is too large Load Diff

View File

@@ -1,12 +1,13 @@
[package]
name = "sn0int"
version = "0.6.0"
description = "OSINT framework and package manager"
version = "0.8.1"
description = "Semi-automatic OSINT framework and package manager"
authors = ["kpcyrd <git@rxv.cc>"]
license = "GPL-3.0"
repository = "https://github.com/kpcyrd/sn0int"
categories = ["command-line-utilities"]
readme = "README.md"
edition = "2018"
[badges]
travis-ci = { repository = "kpcyrd/sn0int" }
@@ -16,8 +17,8 @@ members = ["sn0int-registry/sn0int-common",
"sn0int-registry"]
[dependencies]
sn0int-common = { version="0.3.0", path="sn0int-registry/sn0int-common" }
rustyline = "2"
sn0int-common = { version="0.4.0", path="sn0int-registry/sn0int-common" }
rustyline = "3"
log = "0.4"
env_logger = "0.6"
hlua-badtouch = "0.4"
@@ -28,11 +29,13 @@ colored = "1.6"
lazy_static = "1.0"
shellwords = "1.0"
publicsuffix = { version="1.5", default-features=false }
diesel = { version = "1.0.0", features = ["sqlite"] }
diesel = { version = "1.0.0", features = ["sqlite", "chrono"] }
diesel_migrations = { version = "1.3.0", features = ["sqlite"] }
chrono = { version = "0.4", features = ["serde"] }
dirs = "1.0"
url = "1.7"
chrootable-https = "0.5.0"
#chrootable-https = { path = "../chrootable-https" }
chrootable-https = "0.8"
base64 = "0.10"
kuchiki = "0.7.2"
serde_urlencoded = "0.5"
@@ -47,7 +50,7 @@ maplit = "1.0.1"
sloppy-rfc4880 = "0.1.2"
regex = "1.0"
toml = "0.4"
maxminddb = "0.10.0"
maxminddb = "0.12"
tar = "0.4.17"
libflate = "0.1.14"
threadpool = "1.7"

View File

@@ -14,3 +14,8 @@ test:
(cd sn0int-registry; cargo test)
cargo test
cargo test -- --ignored
update:
get-oui -v -u http://standards-oui.ieee.org/oui/oui.txt -f data/ieee-oui.txt
get-iab -v -u http://standards-oui.ieee.org/iab/iab.txt -f data/ieee-iab.txt
rm -f data/ieee-*.txt.bak

102
README.md
View File

@@ -7,20 +7,22 @@
[docs-img]: https://readthedocs.org/projects/sn0int/badge/?version=latest
[docs]: https://sn0int.readthedocs.io/en/latest/?badge=latest
sn0int is an OSINT framework and package manager. It was built for IT security
professionals and bug hunters to gather intelligence about a given target or
about yourself. sn0int is enumerating attack surface by semi-automatically
processing public information and mapping the results in a unified format for
followup investigations.
sn0int is a semi-automatic OSINT framework and package manager. It was built
for IT security professionals and bug hunters to gather intelligence about a
given target or about yourself. sn0int is enumerating attack surface by
semi-automatically processing public information and mapping the results in a
unified format for followup investigations.
Among other things, sn0int is currently able to:
- [X] Harvest subdomains from certificate transparency logs
- [X] Harvest subdomains from various passive dns logs
- [X] Sift through subdomain results for publicly accessible websites
- [X] Harvest emails from pgp keyservers
- [X] Enrich ip addresses with ASN and geoip info
- [X] Harvest subdomains from the wayback machine
- Harvest subdomains from certificate transparency logs
- Harvest subdomains from various passive dns logs
- Sift through subdomain results for publicly accessible websites
- Harvest emails from pgp keyservers
- Enrich ip addresses with ASN and geoip info
- Harvest subdomains from the wayback machine
- Gather information about phonenumbers
- Bruteforce interesting urls
sn0int is heavily inspired by recon-ng and maltego, but remains more flexible
and is fully opensource. None of the investigations listed above are hardcoded
@@ -30,17 +32,81 @@ them with other users by publishing them to the sn0int registry. This allows
you to ship updates for your modules on your own since you don't need to send a
pull request.
Join us on IRC: <ircs://irc.hackint.org/#sn0int>
Join us on IRC: [irc.hackint.org:6697/#sn0int](https://webirc.hackint.org/#irc://irc.hackint.org/#sn0int)
[![asciicast](https://asciinema.org/a/shZ3TVY1o0opGFln3Oi2DAMCB.svg)](https://asciinema.org/a/shZ3TVY1o0opGFln3Oi2DAMCB)
## Installation
## Getting started
- Archlinux: `pacman -S sn0int`
- Alpine: `apk add --no-cache sqlite-dev libseccomp-dev cargo` + build from source
- Debian: `apt install libsqlite3-dev libseccomp-dev` + build from source
- OpenBSD: `pkg_add sqlite3` + build from source
- OSX: `brew install sqlite3` + build from source
- [Installation](https://sn0int.readthedocs.io/en/latest/install.html)
- [Archlinux](https://sn0int.readthedocs.io/en/latest/install.html#archlinux)
- [Debian/Ubuntu/Kali](https://sn0int.readthedocs.io/en/latest/install.html#debian-ubuntu-kali)
- [Alpine](https://sn0int.readthedocs.io/en/latest/install.html#alpine)
- [Docker](https://sn0int.readthedocs.io/en/latest/install.html#docker)
- [OpenBSD](https://sn0int.readthedocs.io/en/latest/install.html#openbsd)
- [Mac OSX](https://sn0int.readthedocs.io/en/latest/install.html#mac-osx)
- [Windows](https://sn0int.readthedocs.io/en/latest/install.html#windows)
- [Running your first investigation](https://sn0int.readthedocs.io/en/latest/usage.html)
- [Installing the default modules](https://sn0int.readthedocs.io/en/latest/usage.html#installing-the-default-modules)
- [Adding something to scope](https://sn0int.readthedocs.io/en/latest/usage.html#adding-something-to-scope)
- [Running a module](https://sn0int.readthedocs.io/en/latest/usage.html#running-a-module)
- [Running followup modules on the results](https://sn0int.readthedocs.io/en/latest/usage.html#running-followup-modules-on-the-results)
- [Unscoping entities](https://sn0int.readthedocs.io/en/latest/usage.html#unscoping-entities)
- [Scripting](https://sn0int.readthedocs.io/en/latest/scripting.html)
- [Write your first module](https://sn0int.readthedocs.io/en/latest/scripting.html#write-your-first-module)
- [Publish your module](https://sn0int.readthedocs.io/en/latest/scripting.html#publish-your-module)
- [Database](https://sn0int.readthedocs.io/en/latest/database.html)
- [db_add](https://sn0int.readthedocs.io/en/latest/database.html#db-add)
- [db_update](https://sn0int.readthedocs.io/en/latest/database.html#db-update)
- [db_select](https://sn0int.readthedocs.io/en/latest/database.html#db-select)
- [Keyring](https://sn0int.readthedocs.io/en/latest/keyring.html)
- [Managing the keyring](https://sn0int.readthedocs.io/en/latest/keyring.html#managing-the-keyring)
- [Using access keys in scripts](https://sn0int.readthedocs.io/en/latest/keyring.html#using-access-keys-in-scripts)
- [Using access keys as source argument](https://sn0int.readthedocs.io/en/latest/keyring.html#using-access-keys-as-source-argument)
- [Configuration](https://sn0int.readthedocs.io/en/latest/config.html)
- [Configuring a proxy](https://sn0int.readthedocs.io/en/latest/config.html#configuring-a-proxy)
- [Sandbox](https://sn0int.readthedocs.io/en/latest/sandbox.html)
- [Linux](https://sn0int.readthedocs.io/en/latest/sandbox.html#linux)
- [OpenBSD](https://sn0int.readthedocs.io/en/latest/sandbox.html#openbsd)
- [IPC Protocol](https://sn0int.readthedocs.io/en/latest/sandbox.html#ipc-protocol)
- [Limitations](https://sn0int.readthedocs.io/en/latest/sandbox.html#limitations)
- [Function reference](https://sn0int.readthedocs.io/en/latest/reference.html)
- [clear_err](https://sn0int.readthedocs.io/en/latest/reference.html#clear-err)
- [db_add](https://sn0int.readthedocs.io/en/latest/reference.html#db-add)
- [db_select](https://sn0int.readthedocs.io/en/latest/reference.html#db-select)
- [db_update](https://sn0int.readthedocs.io/en/latest/reference.html#db-update)
- [dns](https://sn0int.readthedocs.io/en/latest/reference.html#dns)
- [error](https://sn0int.readthedocs.io/en/latest/reference.html#error)
- [asn_lookup](https://sn0int.readthedocs.io/en/latest/reference.html#asn-lookup)
- [geoip_lookup](https://sn0int.readthedocs.io/en/latest/reference.html#geoip-lookup)
- [html_select](https://sn0int.readthedocs.io/en/latest/reference.html#html-select)
- [html_select_list](https://sn0int.readthedocs.io/en/latest/reference.html#html-select-list)
- [http_mksession](https://sn0int.readthedocs.io/en/latest/reference.html#http-mksession)
- [http_request](https://sn0int.readthedocs.io/en/latest/reference.html#http-request)
- [http_send](https://sn0int.readthedocs.io/en/latest/reference.html#http-send)
- [info](https://sn0int.readthedocs.io/en/latest/reference.html#info)
- [json_decode](https://sn0int.readthedocs.io/en/latest/reference.html#json-decode)
- [json_decode_stream](https://sn0int.readthedocs.io/en/latest/reference.html#json-decode-stream)
- [json_encode](https://sn0int.readthedocs.io/en/latest/reference.html#json-encode)
- [keyring](https://sn0int.readthedocs.io/en/latest/reference.html#keyring)
- [last_err](https://sn0int.readthedocs.io/en/latest/reference.html#last-err)
- [pgp_pubkey](https://sn0int.readthedocs.io/en/latest/reference.html#pgp-pubkey)
- [pgp_pubkey_armored](https://sn0int.readthedocs.io/en/latest/reference.html#pgp-pubkey-armored)
- [print](https://sn0int.readthedocs.io/en/latest/reference.html#print)
- [psl_domain_from_dns_name](https://sn0int.readthedocs.io/en/latest/reference.html#psl-domain-from-dns-name)
- [regex_find](https://sn0int.readthedocs.io/en/latest/reference.html#regex-find)
- [regex_find_all](https://sn0int.readthedocs.io/en/latest/reference.html#regex-find-all)
- [sleep](https://sn0int.readthedocs.io/en/latest/reference.html#sleep)
- [status](https://sn0int.readthedocs.io/en/latest/reference.html#status)
- [stdin_readline](https://sn0int.readthedocs.io/en/latest/reference.html#stdin-readline)
- [url_decode](https://sn0int.readthedocs.io/en/latest/reference.html#url-decode)
- [url_encode](https://sn0int.readthedocs.io/en/latest/reference.html#url-encode)
- [url_escape](https://sn0int.readthedocs.io/en/latest/reference.html#url-escape)
- [url_join](https://sn0int.readthedocs.io/en/latest/reference.html#url-join)
- [url_parse](https://sn0int.readthedocs.io/en/latest/reference.html#url-parse)
- [url_unescape](https://sn0int.readthedocs.io/en/latest/reference.html#url-unescape)
- [utf8_decode](https://sn0int.readthedocs.io/en/latest/reference.html#utf8-decode)
- [x509_parse_pem](https://sn0int.readthedocs.io/en/latest/reference.html#x509-parse-pem)
## License

View File

@@ -9,8 +9,8 @@ case "$1" in
ci/run.sh build
wget https://geolite.maxmind.com/download/geoip/database/GeoLite2-City.tar.gz \
https://geolite.maxmind.com/download/geoip/database/GeoLite2-ASN.tar.gz
cargo run --example maxmind-dl -- -e GeoLite2-City.tar.gz GeoLite2-City.mmdb GeoLite2-City.mmdb
cargo run --example maxmind-dl -- -e GeoLite2-ASN.tar.gz GeoLite2-ASN.mmdb GeoLite2-ASN.mmdb
cargo run --example maxmind -- dl -e GeoLite2-City.tar.gz GeoLite2-City.mmdb GeoLite2-City.mmdb
cargo run --example maxmind -- dl -e GeoLite2-ASN.tar.gz GeoLite2-ASN.mmdb GeoLite2-ASN.mmdb
cargo test --verbose
cargo test --verbose -- --ignored
;;

View File

@@ -5,9 +5,6 @@ case "$1" in
sudo apt update
sudo apt install libsqlite3-dev libseccomp-dev
;;
osx)
brew install sqlite3
;;
windows)
curl -fsS --retry 3 --retry-connrefused -o sqlite3.zip https://sqlite.org/2017/sqlite-dll-win64-x64-3160200.zip
7z e sqlite3.zip -y

View File

@@ -0,0 +1,15 @@
FROM alpine:edge
RUN apk add --no-cache sqlite-dev libseccomp-dev
RUN apk add --no-cache --virtual .build-rust rust cargo
WORKDIR /usr/src/sn0int
COPY . .
RUN cargo build --release --verbose
RUN strip target/release/sn0int
FROM alpine:edge
RUN apk add --no-cache libgcc sqlite-libs libseccomp
COPY --from=0 /usr/src/sn0int/target/release/sn0int /usr/local/bin/sn0int
VOLUME ["/data", "/cache"]
ENV XDG_DATA_HOME=/data \
XDG_CACHE_HOME=/cache
ENTRYPOINT ["sn0int"]

View File

@@ -0,0 +1,16 @@
FROM rust
RUN apt-get update -q && apt-get install -yq libsqlite3-dev libseccomp-dev \
&& rm -rf /var/lib/apt/lists/*
WORKDIR /usr/src/sn0int
COPY . .
RUN cargo build --release --verbose
RUN strip target/release/sn0int
FROM debian
RUN apt-get update -q && apt-get install -yq libsqlite3-dev libseccomp-dev \
&& rm -rf /var/lib/apt/lists/*
COPY --from=0 /usr/src/sn0int/target/release/sn0int /usr/local/bin/sn0int
VOLUME ["/data", "/cache"]
ENV XDG_DATA_HOME=/data \
XDG_CACHE_HOME=/cache
ENTRYPOINT ["sn0int"]

2
contrib/html-toc2md.sh Executable file
View File

@@ -0,0 +1,2 @@
#!/bin/sh
perl -n -e '/toctree-l(\d).*href="([^"]+)">(.+)<\/a/ && print $1==2?" ":"", "- [$3](https://sn0int.readthedocs.io/en/latest/$2)\n"' < docs/_build/html/index.html

0
data/.gitkeep Normal file
View File

4595
data/ieee-iab.txt Normal file

File diff suppressed because it is too large Load Diff

25800
data/ieee-oui.txt Normal file

File diff suppressed because it is too large Load Diff

View File

@@ -138,7 +138,7 @@ latex_documents = [
# One entry per manual page. List of tuples
# (source start file, name, description, authors, manual section).
man_pages = [
('man', 'sn0int', 'OSINT framework and package manager',
('man', 'sn0int', 'Semi-automatic OSINT framework and package manager',
[author], 1)
]

17
docs/config.rst Normal file
View File

@@ -0,0 +1,17 @@
Configuration
=============
This file documents the config file at ``~/.config/sn0int.toml``. By default
this file does not exist and a default configuration is used instead.
Configuring a proxy
-------------------
To enable a proxy, add the following to your config file::
[network]
proxy = "127.0.0.1:9050"
This forces everything through tor and restricts all other functions that
depend on the network. For example the ``dns`` function is fully disabled if a
proxy is configured.

View File

@@ -1,20 +1,22 @@
sn0int
======
sn0int is an OSINT framework and package manager. It was built for IT security
professionals and bug hunters to gather intelligence about a given target or
about yourself. sn0int is enumerating attack surface by semi-automatically
processing public information and mapping the results in a unified format for
followup investigations.
sn0int is a semi-automatic OSINT framework and package manager. It was built
for IT security professionals and bug hunters to gather intelligence about a
given target or about yourself. sn0int is enumerating attack surface by
semi-automatically processing public information and mapping the results in a
unified format for followup investigations.
Among other things, sn0int is currently able to:
- [X] Harvest subdomains from certificate transparency logs
- [X] Harvest subdomains from various passive dns logs
- [X] Sift through subdomain results for publicly accessible websites
- [X] Harvest emails from pgp keyservers
- [X] Enrich ip addresses with ASN and geoip info
- [X] Harvest subdomains from the wayback machine
- Harvest subdomains from certificate transparency logs
- Harvest subdomains from various passive dns logs
- Sift through subdomain results for publicly accessible websites
- Harvest emails from pgp keyservers
- Enrich ip addresses with ASN and geoip info
- Harvest subdomains from the wayback machine
- Gather information about phonenumbers
- Bruteforce interesting urls
sn0int is heavily inspired by recon-ng and maltego, but remains more flexible
and is fully opensource. None of the investigations listed above are hardcoded
@@ -24,7 +26,7 @@ them with other users by publishing them to the sn0int registry. This allows
you to ship updates for your modules on your own since you don't need to send a
pull request.
Join us on IRC: ircs://irc.hackint.org/#sn0int
Join us on IRC: `irc.hackint.org:6697/#sn0int <https://webirc.hackint.org/#irc://irc.hackint.org/#sn0int>`_
Getting Started
---------------
@@ -37,4 +39,7 @@ Getting Started
usage
scripting
database
keyring
config
sandbox
reference

View File

@@ -30,6 +30,13 @@ Alpine
$ cd sn0int
$ cargo install -f
Docker
------
.. code-block:: bash
$ docker run --rm --init -it -v $PWD/.cache:/cache -v $PWD/.data:/data kpcyrd/sn0int
OpenBSD
-------
@@ -45,7 +52,6 @@ Mac OSX
.. code-block:: bash
$ brew install sqlite3
$ git clone https://github.com/kpcyrd/sn0int.git
$ cd sn0int
$ cargo install -f

73
docs/keyring.rst Normal file
View File

@@ -0,0 +1,73 @@
Keyring
=======
A common problem is that you need either an api key or a username/password
combination. Instead of hardcoding it in the script you should request them
from the keyring. In order to do this you need to request permissions to those
credentials.
Managing the keyring
--------------------
The keyring is a simple namespaced key-value store::
[sn0int][default] > keyring add aws:AKIAIOSFODNN7EXAMPLE
Secretkey: keep-this-secret
[sn0int][default] > keyring list
aws:AKIAIOSFODNN7EXAMPLE
[sn0int][default] >
[sn0int][default] > keyring list aws
aws:AKIAIOSFODNN7EXAMPLE
[sn0int][default] > keyring list instagram
[sn0int][default] >
[sn0int][default] > keyring get aws:AKIAIOSFODNN7EXAMPLE
Namespace: "aws"
Access Key: "AKIAIOSFODNN7EXAMPLE"
Secret: "keep-this-secret"
[sn0int][default] >
If the service uses a username-password combination, set the username as the
access key and the password as the secret.
If the service uses only a secret key for the api, set the secret key as the
access key and leave the secret blank.
A script doesn't automatically get access to requested keyring namespaces.
Instead the user is asked to confirm those requests to limit abusive scripts.
Using access keys in scripts
----------------------------
We can request all keys of a certain namespace in our script metadata. This is
going to prompt the user to grant the script access. This can be done for
multiple namespaces in the same script:
.. code-block:: lua
-- Keyring-Access: aws
-- Keyring-Access: asdf
If the user granted us access to those keys we can read them with ``keyring``:
.. code-block:: lua
creds = keyring('aws')
print(creds[1]['accesskey'])
print(creds[1]['secretkey'])
This returns a list of all keys in that namespace. Any empty list is returned
if the user doesn't have any keys in that namespace.
Using access keys as source argument
------------------------------------
We can also use the access keys as source argument. This is useful if each
account has access to different things and we want to read through all of them.
Since access key permissions are granted per namespace we need to specify which
credentials we want to use.
.. code-block:: lua
-- Keyring-Access: aws
-- Source: keyring:aws

View File

@@ -10,4 +10,5 @@ todo
:glob:
usage
config
reference

View File

@@ -73,15 +73,20 @@ This function accepts the following options:
.. code-block:: lua
x = dns('example.com', {
record='A'
records = dns('example.com', {
record='A',
})
if last_err() then return end
if records['error'] ~= nil then return end
records = records['answers']
.. note::
DNS replies with an error code set are not causing a change to
``last_err()``. You have to test for this explicitly.
.. note::
This function is unavailable if a socks5 proxy is configured.
error
-----
@@ -261,10 +266,23 @@ Encode a datastructure into a string.
})
print(x)
keyring
-------
Request all keys from a given namespace. See the `keyring <keyring.html>`__
section for details.
.. code-block:: lua
creds = keyring('aws')
print(creds[1]['accesskey'])
print(creds[1]['secretkey'])
last_err
--------
Returns infos about the last error we've observed, if any. Returns ``nil`` otherwise.
Returns infos about the last error we've observed, if any. Returns ``nil``
otherwise.
.. code-block:: lua
@@ -416,6 +434,40 @@ Read a line from stdin. The final newline is not removed.
.. note::
This only works with `sn0int run --stdin`.
url_decode
----------
Parse a query string into a map. For raw percent decoding see url_unescape_.
.. code-block:: lua
v = url_decode('a=b&c=d')
print(v['a'] == 'b')
print(v['c'] == 'd')
url_encode
----------
Encode a map into a query string. For raw percent encoding see url_escape_.
.. code-block:: lua
v = url_encode({
a='b',
c='d',
})
print(v == 'a=b&c=d')
url_escape
----------
Apply url escaping to a string.
.. code-block:: lua
v = url_escape('foo bar?')
print(v == 'foo%20bar%3F')
url_join
--------
@@ -445,11 +497,21 @@ Parse a url into its components. The following components are returned:
.. code-block:: lua
url = url_parse("https://example.com")
url = url_parse('https://example.com')
print(url['scheme'] == 'https')
print(url['host'] == 'example.com')
print(url['path'] == '/')
url_unescape
------------
Remove url escaping of a string.
.. code-block:: lua
v = url_unescape('foo%20bar%3F')
print(v == 'foo bar?')
utf8_decode
-----------

113
docs/sandbox.rst Normal file
View File

@@ -0,0 +1,113 @@
Sandbox
=======
Scripts are generally considered to be untrusted and executed exclusively in a
child process. It's important to note that there's a basic sandbox that's
active on every operating system, and there's a second line of defense on
supported operating systems.
The first line of defense is the restrictive stdlib. It's assumed that and
attacker gains full control over the lua code and is able to call any function
with arbitrary arguments. The stdlib only provides functions that are
considered safe, so for example it's not possible to start a process or open a
file.
The second line of defense is supposed to make sure the system isn't
compromised even if the first layer is fully broken and an attacker gains full
control over the child process.
Right now this is only supported on linux and openbsd.
Linux
-----
On linux we use seccomp to filter all syscalls that we don't need. We also use
chroot to disable filesystem access. It's recommended to install the sn0int
binary with ``cap_sys_chroot`` to make sure unprivileged users can use chroot.
The chroot location is hard coded and all capabilities are removed after the
chroot is done or if no chroot is going to happen.
OpenBSD
-------
On openbsd we're using ``pledge`` to restrict syscalls and ``unveil`` to
restrict filesystem access.
IPC Protocol
------------
The parent process and the child process communicate using an IPC protocol that
is line-based json.
For a simple hello world the parent process is only going to send a single line
to the child process. This line contains:
- The function argument
- The dns config
- Keys that the module has been given access to
- The module metadata and code
- Options, if any
- A socks5 proxy, if any
- The log level
.. code-block:: json
{"arg":null,"dns_config":{"ns":["1.1.1.1:53","1.0.0.1:53"],"tcp":false,"timeout":{"nanos":0,"secs":3}},"keyring":[],"module":{"author":"anonymous","description":"basic selftest","keyring_access":[],"name":"selftest","script":{"code":"-- Description: basic selftest\n-- Version: 0.1.0\n-- License: GPL-3.0\n\nfunction run()\n -- nothing to do here\nend\n"},"source":null,"version":"0.1.0"},"options":{},"proxy":null,"verbose":2}
Saving this line in a file called ``start.json`` and sending it to a sandbox
process should result in the following output::
$ sn0int sandbox foobar < start.json
{"Exit":"Ok"}
$
This line tells us that the script terminated successfully.
There are some functions that cause a notification to the parent process. We
are going to add a call to the ``info()`` function to our module:
.. code-block:: json
{"arg":null,"dns_config":{"ns":["1.1.1.1:53","1.0.0.1:53"],"tcp":false,"timeout":{"nanos":0,"secs":3}},"keyring":[],"module":{"author":"anonymous","description":"basic selftest","keyring_access":[],"name":"selftest","script":{"code":"-- Description: basic selftest\n-- Version: 0.1.0\n-- License: GPL-3.0\n\nfunction run()\n info('ohai')\nend\n"},"source":null,"version":"0.1.0"},"options":{},"proxy":null,"verbose":2}
This is going to print an additional event::
$ sn0int sandbox foobar < start2.json
{"Log":{"Info":"\"ohai\""}}
{"Exit":"Ok"}
$
There are some functions that block the child process until the parent process
sent a reply. These functions are mostly database related functions, since the
child doesn't have direct database access. To demonstrate this, we're going to
write two lines to our file this time, one is the init line and the second one
is the reply for the database event:
.. code-block:: json
{"arg":null,"dns_config":{"ns":["1.1.1.1:53","1.0.0.1:53"],"tcp":false,"timeout":{"nanos":0,"secs":3}},"keyring":[],"module":{"author":"anonymous","description":"basic selftest","keyring_access":[],"name":"selftest","script":{"code":"-- Description: basic selftest\n-- Version: 0.1.0\n-- License: GPL-3.0\n\nfunction run()\n x = db_add('domain', {value=\"example.com\"})\n info(x)\nend\n"},"source":null,"version":"0.1.0"},"options":{},"proxy":null,"verbose":2}
{"Ok":1337}
Results in the following output::
$ target/release/sn0int sandbox foobar < start3.json
{"Database":{"Insert":{"Domain":{"value":"example.com"}}}}
{"Log":{"Info":"1337.0"}}
{"Exit":"Ok"}
$
The first line is a database event and indicates that the child wants to insert
data. After printing this line the child tries to read a line from stdin, this
is why we needed to write two lines to our json file this time. In the second
line the child learns if the insert was successful and which id was assigned to
that entity.
Limitations
-----------
There are some limitations that you should be aware:
- Network access is available and network namespaces aren't isolated. This
means scripts have access to your local network, the internet and also your
localhost loopback interface.
- If chroot is unavailable an attacker could connect to unix domain sockets.

View File

@@ -125,7 +125,7 @@ our scope and set it to resolvable if ``error`` is ``nil``.
if last_err() then return end
if records['error'] == nil then
db_add('subdomain', arg, {
db_add('subdomain', {
domain_id=arg['id'],
value=subdomain,
resolvable=true,
@@ -159,7 +159,7 @@ After putting everything together, our final module looks like this:
if last_err() then return end
if records['success'] ~= nil then
db_add('subdomain', arg, {
db_add('subdomain', {
domain_id=arg['id'],
value=subdomain,
resolvable=true,

View File

@@ -1,32 +0,0 @@
extern crate sn0int;
extern crate env_logger;
extern crate maxminddb;
use std::env;
use sn0int::errors::*;
use sn0int::geoip::{AsnDB, Maxmind};
fn run() -> Result<()> {
let asndb = AsnDB::open_or_download()?;
for arg in env::args().skip(1) {
let ip = arg.parse()?;
let asn = asndb.lookup(ip)?;
println!("{:#?}", asn);
}
Ok(())
}
fn main() {
env_logger::init();
if let Err(err) = run() {
eprintln!("Error: {}", err);
for cause in err.iter_chain().skip(1) {
eprintln!("Because: {}", cause);
}
std::process::exit(1);
}
}

View File

@@ -1,31 +0,0 @@
extern crate sn0int;
extern crate env_logger;
use std::env;
use sn0int::errors::*;
use sn0int::geoip::{GeoIP, Maxmind};
fn run() -> Result<()> {
let geoip = GeoIP::open_or_download()?;
for arg in env::args().skip(1) {
let ip = arg.parse()?;
let lookup = geoip.lookup(ip)?;
println!("{:#?}", lookup);
}
Ok(())
}
fn main() {
env_logger::init();
if let Err(err) = run() {
eprintln!("Error: {}", err);
for cause in err.iter_chain().skip(1) {
eprintln!("Because: {}", cause);
}
std::process::exit(1);
}
}

View File

@@ -1,50 +0,0 @@
extern crate sn0int;
extern crate env_logger;
extern crate chrootable_https;
#[macro_use] extern crate log;
// workaround for rustc 1.29.2 support
#[cfg(not(target_os = "openbsd"))]
extern crate structopt;
#[cfg(target_os = "openbsd")]
#[macro_use] extern crate structopt;
use sn0int::errors::*;
use sn0int::geoip::{GeoIP, Maxmind};
use sn0int::paths;
use std::fs;
use structopt::StructOpt;
#[derive(Debug, StructOpt)]
pub struct Args {
url: String,
filter: String,
target: String,
#[structopt(short="e", long="extract-only")]
extract_only: bool,
}
fn run() -> Result<()> {
let args = Args::from_args();
debug!("{:?}", args);
let path = paths::cache_dir()?.join(&args.target);
if args.extract_only {
let body = fs::read(&args.url)?;
sn0int::archive::extract(&mut &body[..], &args.filter, path)?;
} else {
GeoIP::download(path, &args.filter, &args.url)?;
}
Ok(())
}
fn main() {
env_logger::init();
if let Err(err) = run() {
eprintln!("Error: {}", err);
for cause in err.iter_chain().skip(1) {
eprintln!("Because: {}", cause);
}
std::process::exit(1);
}
}

104
examples/maxmind.rs Normal file
View File

@@ -0,0 +1,104 @@
extern crate sn0int;
extern crate env_logger;
extern crate chrootable_https;
#[macro_use] extern crate log;
// workaround for rustc 1.29.2 support
#[cfg(not(target_os = "openbsd"))]
extern crate structopt;
#[cfg(target_os = "openbsd")]
#[macro_use] extern crate structopt;
use sn0int::errors::*;
use sn0int::geoip::{AsnDB, GeoIP, Maxmind};
use sn0int::paths;
use std::fs;
use std::net::IpAddr;
use structopt::StructOpt;
#[derive(Debug, StructOpt)]
pub enum Args {
#[structopt(name="dl")]
Download(Download),
#[structopt(name="asn")]
Asn(AsnArgs),
#[structopt(name="geoip")]
GeoIP(GeoIPArgs),
}
#[derive(Debug, StructOpt)]
pub struct Download {
url: String,
filter: String,
target: String,
#[structopt(short="e", long="extract-only")]
extract_only: bool,
}
impl Download {
fn run(&self) -> Result<()> {
let path = paths::cache_dir()?.join(&self.target);
if self.extract_only {
let body = fs::read(&self.url)?;
sn0int::archive::extract(&mut &body[..], &self.filter, path)?;
} else {
GeoIP::download(path, &self.filter, &self.url)?;
}
Ok(())
}
}
#[derive(Debug, StructOpt)]
pub struct AsnArgs {
ip: IpAddr,
}
impl AsnArgs {
fn run(&self) -> Result<()> {
let asndb = AsnDB::open_or_download()?;
let asn = asndb.lookup(self.ip)?;
println!("{:#?}", asn);
Ok(())
}
}
#[derive(Debug, StructOpt)]
pub struct GeoIPArgs {
ip: IpAddr,
}
impl GeoIPArgs {
fn run(&self) -> Result<()> {
let geoip = GeoIP::open_or_download()?;
let lookup = geoip.lookup(self.ip)?;
println!("{:#?}", lookup);
Ok(())
}
}
fn run() -> Result<()> {
let args = Args::from_args();
debug!("{:?}", args);
match args {
Args::Download(args) => args.run(),
Args::Asn(args) => args.run(),
Args::GeoIP(args) => args.run(),
}
}
fn main() {
env_logger::init();
if let Err(err) = run() {
eprintln!("Error: {}", err);
for cause in err.iter_chain().skip(1) {
eprintln!("Because: {}", cause);
}
std::process::exit(1);
}
}

View File

@@ -1,20 +1,67 @@
extern crate sn0int;
use std::env;
use std::thread;
use std::time::Duration;
use sn0int::term::{SPINNERS, Spinner};
use sn0int::term::{SPINNERS, Spinner, StackedSpinners};
use structopt::StructOpt;
#[derive(Debug, StructOpt)]
pub enum Args {
#[structopt(name="single")]
Single(Single),
#[structopt(name="stacked")]
Stacked(Stacked),
}
#[derive(Debug, StructOpt)]
pub struct Single {
idx: usize,
#[structopt(long="ticks", default_value="100")]
ticks: usize,
}
impl Single {
fn run(&self) {
let mut s = Spinner::new(SPINNERS[self.idx], "Demo".to_string());
for _ in 0..self.ticks {
thread::sleep(Duration::from_millis(100));
s.tick();
}
s.finish("Done".to_string());
}
}
#[derive(Debug, StructOpt)]
pub struct Stacked {
}
impl Stacked {
fn run(&self) {
let mut stack = StackedSpinners::new();
stack.add("1".into(), String::from("spinner1"));
stack.add("2".into(), String::from("spinner2"));
stack.add("3".into(), String::from("spinner3"));
for x in 1..=3 {
for _ in 0..50 {
thread::sleep(Duration::from_millis(100));
stack.tick();
}
// stack.log("ohai");
stack.remove(&x.to_string());
}
stack.clear();
// stack.finish("Done".to_string());
}
}
fn main() {
let idx = env::args().skip(1).next().expect("Expected argv[1]");
let idx = idx.parse::<usize>().expect("argv[1] is not a number");
let mut s = Spinner::new(SPINNERS[idx], "Demo".to_string());
for _ in 0..100 {
thread::sleep(Duration::from_millis(100));
s.tick();
let args = Args::from_args();
match args {
Args::Single(args) => args.run(),
Args::Stacked(args) => args.run(),
}
s.finish("Done".to_string());
}

View File

@@ -1,25 +0,0 @@
extern crate sn0int;
use sn0int::term::StackedSpinners;
use std::thread;
use std::time::Duration;
fn main() {
let mut stack = StackedSpinners::new();
stack.add("1".into(), String::from("spinner1"));
stack.add("2".into(), String::from("spinner2"));
stack.add("3".into(), String::from("spinner3"));
for x in 1..=3 {
for _ in 0..50 {
thread::sleep(Duration::from_millis(100));
stack.tick();
}
// stack.log("ohai");
stack.remove(&x.to_string());
}
stack.clear();
// stack.finish("Done".to_string());
}

View File

@@ -0,0 +1 @@
DROP TABLE phonenumbers;

View File

@@ -0,0 +1,16 @@
CREATE TABLE phonenumbers (
id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
value VARCHAR NOT NULL,
name VARCHAR,
unscoped BOOLEAN DEFAULT 0 NOT NULL,
valid BOOLEAN,
last_online DATETIME,
country VARCHAR,
carrier VARCHAR,
line VARCHAR,
is_ported BOOLEAN,
last_ported DATETIME,
caller_name VARCHAR,
caller_type VARCHAR,
CONSTRAINT phonenumber_unique UNIQUE (value)
);

View File

@@ -0,0 +1,27 @@
PRAGMA foreign_keys=off;
CREATE TABLE _ipaddrs_new (
id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
family VARCHAR NOT NULL,
value VARCHAR NOT NULL,
unscoped BOOLEAN DEFAULT 0 NOT NULL,
continent VARCHAR,
continent_code VARCHAR,
country VARCHAR,
country_code VARCHAR,
city VARCHAR,
latitude FLOAT,
longitude FLOAT,
asn INTEGER,
as_org VARCHAR,
CONSTRAINT ipaddr_unique UNIQUE (value)
);
INSERT INTO _ipaddrs_new (id, family, value, unscoped, continent, continent_code, city, latitude, longitude, asn, as_org)
SELECT id, family, value, unscoped, continent, continent_code, city, latitude, longitude, asn, as_org
FROM ipaddrs;
DROP TABLE ipaddrs;
ALTER TABLE _ipaddrs_new RENAME TO ipaddrs;
PRAGMA foreign_keys=on;

View File

@@ -0,0 +1,2 @@
ALTER TABLE ipaddrs ADD COLUMN description VARCHAR;
ALTER TABLE ipaddrs ADD COLUMN reverse_dns VARCHAR;

View File

@@ -0,0 +1,3 @@
DROP TABLE network_devices;
DROP TABLE networks;
DROP TABLE devices;

View File

@@ -0,0 +1,30 @@
CREATE TABLE networks (
id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
value VARCHAR NOT NULL,
unscoped BOOLEAN DEFAULT 0 NOT NULL,
latitude FLOAT,
longitude FLOAT,
CONSTRAINT network_unique UNIQUE (value)
);
CREATE TABLE devices (
id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
value VARCHAR NOT NULL,
name VARCHAR,
hostname VARCHAR,
vendor VARCHAR,
unscoped BOOLEAN DEFAULT 0 NOT NULL,
last_seen DATETIME,
CONSTRAINT device_unique UNIQUE (value)
);
CREATE TABLE network_devices (
id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
network_id INTEGER NOT NULL,
device_id INTEGER NOT NULL,
ipaddr VARCHAR,
last_seen DATETIME,
FOREIGN KEY(network_id) REFERENCES networks(id) ON DELETE CASCADE,
FOREIGN KEY(device_id) REFERENCES devices(id) ON DELETE CASCADE,
CONSTRAINT network_device_unique UNIQUE (network_id, device_id)
);

View File

@@ -1,10 +1,20 @@
-- Description: Parse arp-scan output
-- Version: 0.1.0
-- Version: 0.2.0
-- License: GPL-3.0
-- sudo arp-scan -qglI wlp3s0
function run()
network = getopt('network')
if not network then
return 'network option is missing'
end
network_id = db_select('network', network)
if not network_id then
return 'network not found in database'
end
while true do
x = stdin_readline()
if x == nil then
@@ -13,9 +23,21 @@ function run()
m = regex_find('(.+)\t(.+)', x)
if m ~= nil then
ip = m[2]
ipaddr = m[2]
mac = m[3]
info(json_encode({ip, mac}))
device_id = db_add('device', {
value=mac,
})
if last_err() then return end
-- TODO: add last_seen
db_add('network-device', {
network_id=network_id,
device_id=device_id,
ipaddr=ipaddr,
})
if last_err() then return end
end
end
end

View File

@@ -1,5 +1,5 @@
-- Description: Try a zone transfer for subdomains
-- Version: 0.1.0
-- Version: 0.2.0
-- Source: domains
-- License: GPL-3.0
@@ -39,7 +39,7 @@ end
function iter_axfr(zone, arg)
local name, r, m, domain
debug(json_encode(arg))
debug(arg)
name = arg[1]
r = arg[2]

View File

@@ -1,5 +1,5 @@
-- Description: Query for CNAMES to find subdomains
-- Version: 0.1.0
-- Version: 0.2.0
-- Source: subdomains
-- License: GPL-3.0

View File

@@ -1,11 +1,59 @@
-- Description: Query certificate transparency logs to discover subdomains
-- Version: 0.1.0
-- Version: 0.3.0
-- Source: domains
-- License: GPL-3.0
function run(arg)
session = http_mksession()
function each_name(name)
local domain_id, psl_domain
if seen[name] == 1 then
return
end
seen[name] = 1
debug(name)
if name:find('*.') == 1 then
-- ignore wildcard domains
return
end
-- the cert might be valid for subdomains that do not belong to the
-- domain we started with
psl_domain = psl_domain_from_dns_name(name)
domain_id = domains[psl_domain]
if domain_id == nil then
if any_domain then
-- unknown domains should be added to database
domain_id = db_add('domain', {
value=psl_domain,
})
else
-- only use domains that are already in scope
domain_id = db_select('domain', psl_domain)
end
-- if we didn't get a valid id, skip
if domain_id == nil then
return
end
domains[psl_domain] = domain_id
end
db_add('subdomain', {
domain_id=domain_id,
value=name,
})
end
function run(arg)
full = getopt('full') ~= nil
any_domain = getopt('any-domain') ~= nil
domains = {}
domains[arg['value']] = arg['id']
session = http_mksession()
req = http_request(session, 'GET', 'https://crt.sh/', {
query={
q='%.' .. arg['value'],
@@ -17,7 +65,7 @@ function run(arg)
if last_err() then return end
if resp['status'] ~= 200 then return 'http error: ' .. resp['status'] end
certs = json_decode_stream(resp['text'])
certs = json_decode(resp['text'])
if last_err() then return end
seen = {}
@@ -25,22 +73,32 @@ function run(arg)
i = 1
while i <= #certs do
c = certs[i]
-- print(c)
debug(c)
name = c['name_value']
debug(json_encode(name))
if name:find("*.") == 1 then
-- ignore wildcard domains
seen[name] = 1
end
if seen[name] == nil then
db_add('subdomain', {
domain_id=arg['id'],
value=name,
if full then
-- fetch certificate
id = c['min_cert_id']
req = http_request(session, 'GET', 'https://crt.sh/', {
query={
d=id .. '', -- TODO: find nicer way for tostring
}
})
seen[name] = 1
resp = http_send(req)
if last_err() then return end
if resp['status'] ~= 200 then return 'http error: ' .. resp['status'] end
-- iterate over all valid names
crt = x509_parse_pem(resp['text'])
if last_err() then return end
names = crt['valid_names']
j = 1
while j <= #names do
each_name(names[j])
j = j+1
end
else
each_name(c['name_value'])
end
i = i+1

32
modules/dev/dns-ptr.lua Normal file
View File

@@ -0,0 +1,32 @@
-- Description: Run reverse dns lookups
-- Version: 0.1.0
-- Source: ipaddrs
-- License: GPL-3.0
function run(arg)
if arg['family'] == '4' then
m = regex_find('^(\\d+)\\.(\\d+)\\.(\\d+)\\.(\\d+)$', arg['value'])
q = m[5] .. '.' .. m[4] .. '.' .. m[3] .. '.' .. m[2] .. '.in-addr.arpa'
debug('Resolving: ' .. q)
records = dns(q, {
record='PTR',
})
if last_err() then return end
if records['error'] ~= nil then return end
records = records['answers']
i = 1
while records[i] ~= nil do
r = records[i][2]
if r['PTR'] then
db_update('ipaddr', arg, {
reverse_dns=r['PTR'],
})
if last_err() then return end
end
i = i+1
end
end
end

View File

@@ -1,5 +1,5 @@
-- Description: Query subdomains to discovery ip addresses and verify the record is visible
-- Version: 0.1.0
-- Version: 0.2.0
-- Source: subdomains
-- License: GPL-3.0

View File

@@ -0,0 +1,28 @@
-- Description: Search for git checkouts in webroot
-- Version: 0.1.0
-- Source: urls
-- License: GPL-3.0
function run(arg)
url = url_join(arg['value'], '.git/HEAD')
session = http_mksession()
req = http_request(session, 'GET', url, {})
reply = http_send(req)
if last_err() then return end
if reply['status'] ~= 200 then
return
end
if not regex_find('^ref: ', reply['text']) then
return
end
db_add('url', {
subdomain_id=arg['subdomain_id'],
value=url,
status=reply['status'],
body=reply['text'],
})
end

View File

@@ -0,0 +1,75 @@
-- Description: Parse isc-dhcpd dhcpd.leases(5)
-- Version: 0.1.0
-- License: GPL-3.0
-- cat /var/lib/dhcpd/dhcpd.leases
function add(lease)
if not lease['active'] then return end
device_id = db_add('device', {
value=lease['mac'],
hostname=lease['hostname'],
})
if last_err() then return end
-- TODO: add last_seen
db_add('network-device', {
network_id=network_id,
device_id=device_id,
ipaddr=lease['ipaddr'],
})
if last_err() then return end
end
function each_line(x)
debug(x)
m = regex_find('^lease (\\S+) \\{\n$', x)
if m then
lease = {}
debug('ipaddr=' .. m[2])
lease['ipaddr'] = m[2]
end
m = regex_find('^\\s*hardware ethernet (\\S+);\n$', x)
if m then
debug('mac=' .. m[2])
lease['mac'] = m[2]
end
m = regex_find('^\\s*client-hostname \"(.+)\";\n$', x)
if m then
debug('hostname=' .. m[2])
lease['hostname'] = m[2]
end
m = regex_find('^\\s*binding state active;\n$', x)
if m then
debug('active=true')
lease['active'] = true
end
m = regex_find('^\\}\n$', x)
if m then
add(lease)
end
end
function run()
network = getopt('network')
if not network then
return 'network option is missing'
end
network_id = db_select('network', network)
if not network_id then
return 'network not found in database'
end
while true do
x = stdin_readline()
if x == nil then
break
end
if not regex_find('^\\s*(#.*|\\s*)\n$', x) then
each_line(x)
end
end
end

View File

@@ -0,0 +1,74 @@
-- Description: Parse iw station dump
-- Version: 0.1.0
-- License: GPL-3.0
-- iw dev wlan0 station dump
function add(client)
if
client['authenticated'] == 'yes' and
client['authorized'] == 'yes' and
client['mac']
then
debug(client)
device_id = db_add('device', {
value=client['mac'],
})
if last_err() then return end
-- TODO: add last_seen
db_add('network-device', {
network_id=network_id,
device_id=device_id,
})
if last_err() then return end
end
client = nil
end
function each_line(x)
debug(x)
m = regex_find('^Station (\\S+)', x)
if m then
if client then
add(client)
end
client = {}
client['mac'] = m[2]
debug('mac=' .. m[2])
end
m = regex_find('^\\s+([^:]+):\\s*(.+)\n$', x)
if m and client then
client[m[2]] = m[3]
debug(m[2] .. '=' .. m[3])
end
end
function run()
network = getopt('network')
if not network then
return 'network option is missing'
end
network_id = db_select('network', network)
if not network_id then
return 'network not found in database'
end
client = nil
while true do
x = stdin_readline()
if x == nil then
break
end
each_line(x)
end
if client then
add(client)
end
end

View File

@@ -1,5 +1,5 @@
-- Description: Query alienvault otx passive dns for subdomains of a domain
-- Version: 0.1.0
-- Version: 0.2.0
-- Source: domains
-- License: GPL-3.0

106
modules/dev/phpmyadmin.lua Normal file
View File

@@ -0,0 +1,106 @@
-- Description: Search for phpmyadmin
-- Version: 0.1.0
-- Source: urls
-- License: GPL-3.0
function run(arg)
paths = {
"phpmyadmin/index.php",
"phpMyAdmin/index.php",
"pmd/index.php",
"pma/index.php",
"PMA/index.php",
"PMA2/index.php",
"pmamy/index.php",
"pmamy2/index.php",
"mysql/index.php",
"admin/index.php",
"db/index.php",
"dbadmin/index.php",
"web/phpMyAdmin/index.php",
"admin/pma/index.php",
"admin/PMA/index.php",
"admin/mysql/index.php",
"admin/mysql2/index.php",
"admin/phpmyadmin/index.php",
"admin/phpMyAdmin/index.php",
"admin/phpmyadmin2/index.php",
"mysqladmin/index.php",
"mysql-admin/index.php",
"mysql_admin/index.php",
"phpadmin/index.php",
"phpAdmin/index.php",
"phpmyadmin0/index.php",
"phpmyadmin1/index.php",
"phpmyadmin2/index.php",
"phpMyAdmin-4.4.0/index.php",
"myadmin/index.php",
"myadmin2/index.php",
"xampp/phpmyadmin/index.php",
"phpMyadmin_bak/index.php",
"www/phpMyAdmin/index.php",
"tools/phpMyAdmin/index.php",
"phpmyadmin-old/index.php",
"phpMyAdminold/index.php",
"phpMyAdmin.old/index.php",
"pma-old/index.php",
"claroline/phpMyAdmin/index.php",
"typo3/phpmyadmin/index.php",
"phpma/index.php",
"phpmyadmin/phpmyadmin/index.php",
"phpMyAdmin/phpMyAdmin/index.php",
"phpMyAbmin/index.php",
"phpMyAdmin__/index.php",
"phpMyAdmin+++---/index.php",
"v/index.php",
"phpmyadm1n/index.php",
"phpMyAdm1n/index.php",
"shaAdmin/index.php",
"phpMyadmi/index.php",
"phpMyAdmion/index.php",
"MyAdmin/index.php",
"phpMyAdmin1/index.php",
"phpMyAdmin123/index.php",
"pwd/index.php",
"phpMyAdmina/index.php",
"program/index.php",
"shopdb/index.php",
"phppma/index.php",
"phpmy/index.php",
"mysql/admin/index.php",
"mysql/dbadmin/index.php",
"mysql/sqlmanager/index.php",
"mysql/mysqlmanager/index.php",
"wp-content/plugins/portable-phpmyadmin/wp-pma-mod/index.php",
}
session = http_mksession()
i = 1
while i <= #paths do
p = paths[i]
url = url_join(arg['value'], p)
debug(url)
req = http_request(session, 'GET', url, {
timeout=5000
})
reply = http_send(req)
debug(reply)
if last_err() then
clear_err()
else
if reply['status'] == 200 then
db_add('url', {
subdomain_id=arg['subdomain_id'],
value=url,
status=reply['status'],
body=reply['text'],
})
end
end
i = i+1
end
end

View File

@@ -1,5 +1,5 @@
-- Description: Query ThreatMiner passive dns for subdomains of an ip address
-- Version: 0.1.0
-- Version: 0.2.0
-- Source: ipaddrs
-- License: GPL-3.0

View File

@@ -1,5 +1,5 @@
-- Description: Query ThreatMiner passive dns for subdomains of a domain
-- Version: 0.1.0
-- Version: 0.2.0
-- Source: domains
-- License: GPL-3.0

View File

@@ -0,0 +1,48 @@
-- Description: Retrieve additional information about a phone number
-- Version: 0.1.0
-- Source: phonenumbers
-- Keyring-Access: twilio
-- License: GPL-3.0
function run(arg)
number = url_escape(arg['value'])
--url = 'https://lookups.twilio.com/v1/PhoneNumbers/' .. number
url = 'https://lookups.twilio.com/v1/PhoneNumbers/' .. number .. '?Type=carrier&Type=caller-name'
--debug(url)
key = keyring('twilio')[1]
if not key then
return 'Missing required twilio access key'
end
session = http_mksession()
req = http_request(session, 'GET', url, {
basic_auth={key['access_key'], key['secret_key']},
})
reply = http_send(req)
if last_err() then return end
if reply['status'] ~= 200 then
return 'api returned error'
end
v = json_decode(reply['text'])
if last_err() then return end
debug(v)
update = {}
update['country'] = v['country_code']
if v['carrier'] then
update['carrier'] = v['carrier']['name']
update['line'] = v['carrier']['type']
end
if v['caller_name'] then
update['caller_name'] = v['caller_name']['caller_name']
update['caller_type'] = v['caller_name']['caller_type']
end
db_update('phonenumber', arg, update)
end

View File

@@ -1,5 +1,5 @@
-- Description: Scan subdomains for websites
-- Version: 0.1.0
-- Version: 0.2.0
-- Source: subdomains
-- License: GPL-3.0
@@ -29,9 +29,9 @@ function request(subdomain_id, url)
db_add('url', obj)
-- info(json_encode(reply['status']))
-- info(json_encode(reply['headers']['location']))
-- info(json_encode(reply['text']))
-- debug(reply['status'])
-- debug(reply['headers']['location'])
-- debug(reply['text'])
end
function run(arg)

View File

@@ -1,5 +1,5 @@
-- Description: Discover subdomains from wayback machine
-- Version: 0.1.0
-- Version: 0.3.0
-- Source: domains
-- License: GPL-3.0
@@ -32,7 +32,7 @@ function run(arg)
i = 2
while o[i] do
url = o[i][3]
debug(json_encode(url))
debug(url)
parts = url_parse(url)
if last_err() then

View File

@@ -1,6 +1,5 @@
-- Description: Test error handling
-- Version: 0.1.0
-- Source: domains
-- License: GPL-3.0
function run()

15
modules/harness/ip.lua Normal file
View File

@@ -0,0 +1,15 @@
-- Description: Show your ip
-- Version: 0.1.0
-- License: GPL-3.0
function get(url)
req = http_request(session, 'GET', url, {})
r = http_send(req)
info(r['text'])
end
function run()
session = http_mksession()
get('https://icanhazip.com')
get('https://icanhazptr.com')
end

View File

@@ -0,0 +1,9 @@
-- Description: Request access to keyring
-- Version: 0.1.0
-- Keyring-Access: twilio
-- License: GPL-3.0
function run(arg)
keys = keyring('twilio')
debug(keys)
end

View File

@@ -0,0 +1,9 @@
-- Description: Request access to keyring
-- Version: 0.1.0
-- Source: keyring:twilio
-- Keyring-Access: twilio
-- License: GPL-3.0
function run(arg)
info(arg)
end

View File

@@ -0,0 +1,7 @@
-- Description: Read an option
-- Version: 0.1.0
-- License: GPL-3.0
function run()
info(getopt('hello'))
end

View File

@@ -0,0 +1,7 @@
-- Description: basic selftest
-- Version: 0.1.0
-- License: GPL-3.0
function run()
-- nothing to do here
end

View File

@@ -8,6 +8,6 @@ function run()
if x == nil then
break
end
info(json_encode(x))
info(x)
end
end

View File

@@ -1,16 +1,17 @@
[package]
name = "sn0int-registry"
version = "0.4.0"
version = "0.5.0"
description = "sn0int registry"
authors = ["kpcyrd <git@rxv.cc>"]
license = "GPL-3.0"
repository = "https://github.com/kpcyrd/sn0int"
edition = "2018"
[dependencies]
sn0int-common = { version="0.3.0", path="sn0int-common" }
rocket = "0.3.16"
rocket_codegen = "0.3.16"
rocket_contrib = { version = "0.3.16", features = ["handlebars_templates"] }
sn0int-common = { version="0.4.0", path="sn0int-common" }
rocket = "0.4"
rocket_failure = { version = "0.1", features = ["with-rocket"] }
rocket_contrib = { version = "0.4", features = ["handlebars_templates"] }
diesel = { version = "1.3", features = ["postgres", "r2d2"] }
diesel_migrations = { version = "1.3.0", features = ["postgres"] }

View File

@@ -1,13 +1,16 @@
[package]
name = "sn0int-common"
version = "0.3.0"
version = "0.4.0"
description = "Common code for sn0int"
authors = ["kpcyrd <git@rxv.cc>"]
license = "GPL-3.0"
repository = "https://github.com/kpcyrd/sn0int"
edition = "2018"
[dependencies]
serde = "1.0"
serde_derive = "1.0"
#rocket_failure = { path = "../../../rocket_failure" }
rocket_failure = "0.1.1"
failure = "0.1"
nom = "4.0"

View File

@@ -1,23 +1,3 @@
use errors::*;
#[derive(Debug, Serialize, Deserialize)]
pub enum ApiResponse<T> {
#[serde(rename="success")]
Success(T),
#[serde(rename="error")]
Error(String),
}
impl<T> ApiResponse<T> {
pub fn success(self) -> Result<T> {
match self {
ApiResponse::Success(x) => Ok(x),
ApiResponse::Error(err) => bail!("Api returned error: {:?}", err),
}
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct WhoamiResponse {
pub user: String,

View File

@@ -1,7 +1,9 @@
use errors::*;
use crate::errors::*;
use nom;
use nom::types::CompleteStr;
use serde::{de, Serialize, Serializer, Deserialize, Deserializer};
use std::fmt;
use std::result;
use std::str::FromStr;
@@ -32,7 +34,7 @@ named!(module<CompleteStr, ModuleID>, do_parse!(
named!(token<CompleteStr, CompleteStr>, take_while1!(valid_char));
#[derive(Debug, PartialEq)]
#[derive(Debug, PartialEq, Eq, Hash)]
pub struct ModuleID {
pub author: String,
pub name: String,
@@ -54,6 +56,24 @@ impl FromStr for ModuleID {
}
}
impl Serialize for ModuleID {
fn serialize<S>(&self, serializer: S) -> result::Result<S::Ok, S::Error>
where
S: Serializer,
{
serializer.serialize_str(&self.to_string())
}
}
impl<'de> Deserialize<'de> for ModuleID {
fn deserialize<D>(deserializer: D) -> result::Result<Self, D::Error>
where D: Deserializer<'de>
{
let s = String::deserialize(deserializer)?;
FromStr::from_str(&s).map_err(de::Error::custom)
}
}
#[cfg(test)]
mod tests {
use super::*;

View File

@@ -4,10 +4,12 @@
pub mod api;
pub mod errors;
pub use errors::*;
pub use crate::errors::*;
pub mod metadata;
pub mod id;
pub use id::*;
pub use crate::id::*;
pub use rocket_failure::StrictApiResponse as ApiResponse;
#[cfg(test)]
mod tests {

View File

@@ -1,4 +1,4 @@
use errors::*;
use crate::errors::*;
use std::str::FromStr;
@@ -8,6 +8,7 @@ pub enum EntryType {
Description,
Version,
Source,
KeyringAccess,
License,
}
@@ -19,6 +20,7 @@ impl FromStr for EntryType {
"Description" => Ok(EntryType::Description),
"Version" => Ok(EntryType::Version),
"Source" => Ok(EntryType::Source),
"Keyring-Access" => Ok(EntryType::KeyringAccess),
"License" => Ok(EntryType::License),
x => bail!("Unknown EntryType: {:?}", x),
}
@@ -32,19 +34,31 @@ pub enum Source {
IpAddrs,
Urls,
Emails,
PhoneNumbers,
KeyRing(String),
}
impl FromStr for Source {
type Err = Error;
fn from_str(s: &str) -> Result<Source> {
match s {
"domains" => Ok(Source::Domains),
"subdomains" => Ok(Source::Subdomains),
"ipaddrs" => Ok(Source::IpAddrs),
"urls" => Ok(Source::Urls),
"emails" => Ok(Source::Emails),
x => bail!("Unknown Source: {:?}", x),
let (key, param) = if let Some(idx) = s.find(':') {
let (a, b) = s.split_at(idx);
(a, Some(&b[1..]))
} else {
(s, None)
};
match (key, param) {
("domains", None) => Ok(Source::Domains),
("subdomains", None) => Ok(Source::Subdomains),
("ipaddrs", None) => Ok(Source::IpAddrs),
("urls", None) => Ok(Source::Urls),
("emails", None) => Ok(Source::Emails),
("phonenumbers", None) => Ok(Source::PhoneNumbers),
("keyring", Some(param)) => Ok(Source::KeyRing(param.to_string())),
(x, Some(param)) => bail!("Unknown Source: {:?} ({:?})", x, param),
(x, None) => bail!("Unknown Source: {:?}", x),
}
}
}
@@ -80,6 +94,7 @@ pub struct Metadata {
pub description: String,
pub version: String,
pub source: Option<Source>,
pub keyring_access: Vec<String>,
pub license: License,
}
@@ -97,6 +112,7 @@ impl FromStr for Metadata {
EntryType::Description => data.description = Some(v),
EntryType::Version => data.version = Some(v),
EntryType::Source => data.source = Some(v),
EntryType::KeyringAccess => data.keyring_access.push(v),
EntryType::License => data.license = Some(v),
}
}
@@ -110,6 +126,7 @@ pub struct NewMetadata<'a> {
pub description: Option<&'a str>,
pub version: Option<&'a str>,
pub source: Option<&'a str>,
pub keyring_access: Vec<&'a str>,
pub license: Option<&'a str>,
}
@@ -121,6 +138,9 @@ impl<'a> NewMetadata<'a> {
Some(x) => Some(x.parse()?),
_ => None,
};
let keyring_access = self.keyring_access.into_iter()
.map(String::from)
.collect();
let license = self.license.ok_or_else(|| format_err!("License is required"))?;
let license = license.parse()?;
@@ -128,6 +148,7 @@ impl<'a> NewMetadata<'a> {
description: description.to_string(),
version: version.to_string(),
source,
keyring_access,
license,
})
}
@@ -168,6 +189,7 @@ mod tests {
version: "1.0.0".to_string(),
license: License::WTFPL,
source: Some(Source::Domains),
keyring_access: Vec::new(),
});
}
@@ -183,6 +205,7 @@ mod tests {
version: "1.0.0".to_string(),
license: License::WTFPL,
source: None,
keyring_access: Vec::new(),
});
}
@@ -206,4 +229,19 @@ mod tests {
"#);
assert!(metadata.is_err());
}
#[test]
fn verify_keyring_source() {
let x = Source::from_str("keyring:foo").unwrap();
assert_eq!(x, Source::KeyRing("foo".to_string()));
let x = Source::from_str("keyring:").unwrap();
assert_eq!(x, Source::KeyRing("".to_string()));
}
#[test]
fn verify_invalid_keyring_source() {
let x = Source::from_str("keyring");
assert!(x.is_err());
}
}

View File

@@ -2,12 +2,12 @@ use blake2::{Blake2b, Digest};
pub static FAVICON: &[u8] = include_bytes!("../assets/favicon.ico");
pub static STYLE_SHEET: &str = include_str!("../assets/style.css");
pub static STYLE_SHEET: &[u8] = include_bytes!("../assets/style.css");
lazy_static! {
pub static ref ASSET_REV: String = {
let mut h = Blake2b::new();
h.input(STYLE_SHEET.as_bytes());
h.input(STYLE_SHEET);
hex::encode(&h.result()[0..8])
};
}

View File

@@ -1,10 +1,10 @@
use errors::*;
use crate::errors::*;
use diesel::pg::PgConnection;
use oauth2::basic::BasicClient;
use oauth2::prelude::*;
use oauth2::{AuthUrl, AuthorizationCode, ClientId, ClientSecret, CsrfToken, RedirectUrl, TokenUrl};
use github::GithubAuthenticator;
use models::AuthToken;
use crate::github::GithubAuthenticator;
use crate::models::AuthToken;
use url::Url;
use std::env;

View File

@@ -1,10 +1,10 @@
use errors::*;
use models::AuthToken;
use db::Connection;
use crate::errors::*;
use crate::models::AuthToken;
use crate::db::Connection;
use rocket::http::Status;
use rocket::{Request, Outcome};
use rocket::request::{self, FromRequest};
use github::GithubAuthenticator;
use crate::github::GithubAuthenticator;
pub struct AuthHeader(String);

View File

@@ -1,4 +1,4 @@
use errors::*;
use crate::errors::*;
use std::io;
use std::thread;
use std::time::Duration;

View File

@@ -1,30 +1,4 @@
pub use failure::{Error, ResultExt};
pub type Result<T> = ::std::result::Result<T, Error>;
use rocket::Request;
use rocket::http::Status;
use rocket::response::{self, Responder};
#[derive(Debug)]
pub struct ApiError(Error);
#[derive(Serialize)]
pub struct ErrorResponse {
pub status: &'static str,
pub message: String,
}
pub type ApiResult<T> = ::std::result::Result<T, ApiError>;
impl<'r> Responder<'r> for ApiError {
fn respond_to(self, _: &Request) -> response::Result<'static> {
error!("Error: {:?}", self.0);
Err(Status::InternalServerError)
}
}
impl From<Error> for ApiError {
fn from(error: Error) -> ApiError {
ApiError(error)
}
}
pub use rocket_failure::errors::*;

View File

@@ -1,4 +1,4 @@
use errors::*;
use crate::errors::*;
use std::env;
use reqwest;

View File

@@ -1,15 +1,10 @@
#![allow(proc_macro_derive_resolution_fallback)]
#![warn(unused_extern_crates)]
#![feature(plugin)]
#![feature(custom_derive)]
#![plugin(rocket_codegen)]
#![feature(proc_macro_hygiene, decl_macro)]
extern crate sn0int_common;
extern crate rocket;
#[macro_use] extern crate rocket;
#[macro_use] extern crate rocket_contrib;
extern crate dotenv;
extern crate blake2;
extern crate serde_json;
#[macro_use] extern crate rocket_failure;
#[macro_use] extern crate serde_derive;
#[macro_use] extern crate log;
#[macro_use] extern crate maplit;
@@ -17,17 +12,15 @@ extern crate serde_json;
#[macro_use] extern crate failure;
#[macro_use] extern crate diesel;
#[macro_use] extern crate diesel_migrations;
extern crate diesel_full_text_search;
extern crate oauth2;
extern crate url;
extern crate reqwest;
extern crate semver;
use rocket_contrib::{Json, Value, Template};
use rocket::fairing::AdHoc;
use rocket::http::Header;
use rocket_contrib::json::{Json, JsonValue};
use rocket_contrib::templates::Template;
use dotenv::dotenv;
use std::env;
use errors::*;
use crate::errors::*;
pub mod assets;
pub mod auth;
@@ -42,21 +35,21 @@ pub mod schema;
#[catch(400)]
fn bad_request() -> Json<Value> {
fn bad_request() -> Json<JsonValue> {
Json(json!({
"error": "Bad request"
}))
}
#[catch(404)]
fn not_found() -> Json<Value> {
fn not_found() -> Json<JsonValue> {
Json(json!({
"error": "Resource was not found"
}))
}
#[catch(500)]
fn internal_error() -> Json<Value> {
fn internal_error() -> Json<JsonValue> {
Json(json!({
"error": "Internal server error"
}))
@@ -74,6 +67,15 @@ fn run() -> Result<()> {
rocket::ignite()
.manage(db::init(&database_url))
.attach(Template::fairing())
.attach(AdHoc::on_response("Security Headers", |_, resp| {
resp.set_header(Header::new("Strict-Transport-Security", "max-age=63072000; includeSubDomains; preload"));
resp.set_header(Header::new("Content-Security-Policy", "style-src 'self'"));
resp.set_header(Header::new("Feature-Policy", "geolocation 'none'; midi 'none'; notifications 'none'; push 'none'; sync-xhr 'none'; microphone 'none'; camera 'none'; magnetometer 'none'; gyroscope 'none'; speaker 'none'; vibrate 'none'; fullscreen 'none'; payment 'none'"));
resp.set_header(Header::new("X-Frame-Options", "deny"));
resp.set_header(Header::new("X-XSS-Protection", "1; mode=block"));
resp.set_header(Header::new("X-Content-Type-Options", "nosniff"));
resp.set_header(Header::new("Referrer-Policy", "same-origin"));
}))
.mount("/api/v0", routes![
routes::api::quickstart,
routes::api::search,
@@ -92,12 +94,12 @@ fn run() -> Result<()> {
routes::assets::favicon,
routes::assets::style,
])
.catch(catchers![
bad_request,
not_found,
internal_error,
])
.launch();
.register(catchers![
bad_request,
not_found,
internal_error,
])
.launch();
Ok(())
}

View File

@@ -1,9 +1,9 @@
use errors::*;
use crate::errors::*;
use diesel::prelude::*;
use diesel::pg::PgConnection;
use diesel::sql_types::BigInt;
use diesel_full_text_search::{plainto_tsquery, TsQueryExtensions};
use schema::*;
use crate::schema::*;
#[derive(AsChangeset, Serialize, Deserialize, Queryable, Insertable)]

View File

@@ -1,19 +1,20 @@
use errors::*;
use auth2::AuthHeader;
use db;
use crate::errors::*;
use crate::auth2::AuthHeader;
use crate::db;
use crate::models::*;
use diesel::Connection;
use rocket::request::Form;
use rocket_contrib::json::Json;
use semver::Version;
use sn0int_common::api::*;
use sn0int_common::id;
use sn0int_common::metadata::Metadata;
use rocket_contrib::Json;
use models::*;
#[get("/quickstart")]
fn quickstart(connection: db::Connection) -> ApiResult<Json<ApiResponse<Vec<Module>>>> {
pub fn quickstart(connection: db::Connection) -> ApiResult<ApiResponse<Vec<Module>>> {
let modules = Module::quickstart(&connection)?;
Ok(Json(ApiResponse::Success(modules)))
Ok(ApiResponse::Success(modules))
}
#[derive(Debug, FromForm)]
@@ -21,8 +22,8 @@ pub struct Search {
q: String,
}
#[get("/search?<q>")]
fn search(q: Search, connection: db::Connection) -> ApiResult<Json<ApiResponse<Vec<SearchResponse>>>> {
#[get("/search?<q..>")]
pub fn search(q: Form<Search>, connection: db::Connection) -> ApiResult<ApiResponse<Vec<SearchResponse>>> {
info!("Searching: {:?}", q.q);
let modules = Module::search(&q.q, &connection)?;
@@ -39,85 +40,99 @@ fn search(q: Search, connection: db::Connection) -> ApiResult<Json<ApiResponse<V
})
.collect();
Ok(Json(ApiResponse::Success(modules)))
Ok(ApiResponse::Success(modules))
}
#[get("/info/<author>/<name>", format="application/json")]
fn info(author: String, name: String, connection: db::Connection) -> ApiResult<Json<ApiResponse<ModuleInfoResponse>>> {
pub fn info(author: String, name: String, connection: db::Connection) -> ApiResult<ApiResponse<ModuleInfoResponse>> {
info!("Querying {:?}/{:?}", author, name);
let module = Module::find(&author, &name, &connection)?;
let module = Module::find(&author, &name, &connection)
.not_found()
.public_context("Module does not exist")?;
Ok(Json(ApiResponse::Success(ModuleInfoResponse {
Ok(ApiResponse::Success(ModuleInfoResponse {
author: module.author,
name: module.name,
description: module.description,
latest: module.latest,
})))
}))
}
#[get("/dl/<author>/<name>/<version>", format="application/json")]
fn download(author: String, name: String, version: String, connection: db::Connection) -> ApiResult<Json<ApiResponse<DownloadResponse>>> {
pub fn download(author: String, name: String, version: String, connection: db::Connection) -> ApiResult<ApiResponse<DownloadResponse>> {
info!("Downloading {:?}/{:?} ({:?})", author, name, version);
let module = Module::find(&author, &name, &connection)?;
let module = Module::find(&author, &name, &connection)
.not_found()
.public_context("Module does not exist")?;
debug!("Module: {:?}", module);
let release = Release::find(module.id, &version, &connection)?;
let release = Release::find(module.id, &version, &connection)
.not_found()
.public_context("Release does not exist")?;
debug!("Release: {:?}", release);
release.bump_downloads(&connection)?;
Ok(Json(ApiResponse::Success(DownloadResponse {
Ok(ApiResponse::Success(DownloadResponse {
author,
name,
version,
code: release.code,
})))
}))
}
#[post("/publish/<name>", format="application/json", data="<upload>")]
fn publish(name: String, upload: Json<PublishRequest>, session: AuthHeader, connection: db::Connection) -> ApiResult<Json<ApiResponse<PublishResponse>>> {
let user = session.verify(&connection)?;
pub fn publish(name: String, upload: Json<PublishRequest>, session: AuthHeader, connection: db::Connection) -> ApiResult<ApiResponse<PublishResponse>> {
let user = session.verify(&connection)
.bad_request()
.public_context("Invalid auth token")?;
id::valid_name(&user)
.context("Username is invalid")
.map_err(Error::from)?;
.bad_request()
.public_context("Username is invalid")?;
id::valid_name(&name)
.context("Module name is invalid")
.map_err(Error::from)?;
.bad_request()
.public_context("Module name is invalid")?;
let metadata = upload.code.parse::<Metadata>()?;
let metadata = upload.code.parse::<Metadata>()
.bad_request()
.public_context("Failed to parse module metadata")?;
let version = metadata.version.clone();
Version::parse(&version)
.context("Version is invalid")
.map_err(Error::from)?;
.bad_request()
.public_context("Version is invalid")?;
connection.transaction::<_, Error, _>(|| {
let module = Module::update_or_create(&user, &name, &metadata.description, &connection)?;
connection.transaction::<_, WebError, _>(|| {
let module = Module::update_or_create(&user, &name, &metadata.description, &connection)
.private_context("Failed to write module metadata")?;
match Release::try_find(module.id, &version, &connection)? {
Some(release) => {
// if the code is identical, pretend we published the version
if release.code != upload.code {
bail!("Version number already in use")
bad_request!("Version number already in use")
}
},
None => module.add_version(&version, &upload.code, &connection)?,
None => module.add_version(&version, &upload.code, &connection)
.private_context("Failed to add release")?,
}
Ok(())
})?;
Ok(Json(ApiResponse::Success(PublishResponse {
Ok(ApiResponse::Success(PublishResponse {
author: user,
name,
version,
})))
}))
}
#[get("/whoami")]
fn whoami(session: AuthHeader, connection: db::Connection) -> ApiResult<Json<ApiResponse<WhoamiResponse>>> {
let user = session.verify(&connection)?;
Ok(Json(ApiResponse::Success(WhoamiResponse {
pub fn whoami(session: AuthHeader, connection: db::Connection) -> ApiResult<ApiResponse<WhoamiResponse>> {
let user = session.verify(&connection)
.bad_request()
.public_context("Invalid auth token")?;
Ok(ApiResponse::Success(WhoamiResponse {
user,
})))
}))
}

View File

@@ -1,25 +1,60 @@
use crate::assets::{ASSET_REV, FAVICON, STYLE_SHEET};
use rocket::http::ContentType;
use rocket::http::Status;
use rocket::response::content;
use rocket_contrib::Template;
use assets::{ASSET_REV, FAVICON, STYLE_SHEET};
use rocket::http::hyper::header::{CacheControl, CacheDirective};
use rocket_contrib::templates::Template;
#[get("/")]
fn index() -> Template {
pub fn index() -> Template {
Template::render("index", hashmap!{
"ASSET_REV" => ASSET_REV.as_str(),
})
}
#[derive(Responder)]
pub struct CachableResponder {
inner: Vec<u8>,
content_type: ContentType,
cache: CacheControl,
}
impl CachableResponder {
pub fn new<I: Into<Vec<u8>>>(inner: I, content_type: ContentType, max_age: u32) -> CachableResponder {
let cache = CacheControl(vec![
CacheDirective::Public,
CacheDirective::MaxAge(max_age),
]);
CachableResponder {
inner: inner.into(),
content_type,
cache,
}
}
pub fn immutable<I: Into<Vec<u8>>>(inner: I, content_type: ContentType) -> CachableResponder {
let cache = CacheControl(vec![
CacheDirective::Public,
CacheDirective::MaxAge(31536000),
CacheDirective::Extension("immutable".into(), None),
]);
CachableResponder {
inner: inner.into(),
content_type,
cache,
}
}
}
#[get("/favicon.ico")]
fn favicon() -> Vec<u8> {
FAVICON.to_vec()
pub fn favicon() -> CachableResponder {
CachableResponder::new(FAVICON, ContentType::Binary, 3600)
}
#[get("/assets/<rev>/style.css")]
fn style(rev: String) -> Result<content::Css<&'static str>, Status> {
pub fn style(rev: String) -> Result<CachableResponder, Status> {
if rev == *ASSET_REV {
Ok(content::Css(STYLE_SHEET))
Ok(CachableResponder::immutable(STYLE_SHEET, ContentType::CSS))
} else {
Err(Status::NotFound)
}

View File

@@ -1,15 +1,16 @@
use errors::*;
use auth::Authenticator;
use db;
use crate::errors::*;
use crate::auth::Authenticator;
use crate::db;
use rocket::request::Form;
use rocket::response::Redirect;
use rocket_contrib::Template;
use assets::ASSET_REV;
use rocket_contrib::templates::Template;
use crate::assets::ASSET_REV;
use serde_json::{self, Value};
#[get("/?<auth>")]
pub fn get(auth: OAuth) -> Template {
#[get("/?<auth..>")]
pub fn get(auth: Form<OAuth>) -> Template {
let auth = auth.into_inner();
let mut auth = serde_json::to_value(&auth).expect("OAuth serialization failed");
if let Value::Object(ref mut map) = auth {
map.insert("ASSET_REV".to_string(), Value::String(ASSET_REV.to_string()));
@@ -21,7 +22,9 @@ pub fn get(auth: OAuth) -> Template {
pub fn post(auth: Form<OAuth>, connection: db::Connection) -> ApiResult<Template> {
let (code, state) = auth.into_inner().extract()?;
let client = Authenticator::from_env()?;
client.store_code(code, state, &connection)?;
client.store_code(code, state, &connection)
.bad_request()
.public_context("Authentication failed")?;
Ok(Template::render("auth-done", hashmap!{
"ASSET_REV" => ASSET_REV.as_str(),
@@ -29,10 +32,10 @@ pub fn post(auth: Form<OAuth>, connection: db::Connection) -> ApiResult<Template
}
#[get("/<session>")]
fn login(session: String) -> ApiResult<Redirect> {
pub fn login(session: String) -> ApiResult<Redirect> {
let client = Authenticator::from_env()?;
let (url, _csrf) = client.request_auth(session);
Ok(Redirect::to(&url.to_string()))
Ok(Redirect::to(url.to_string()))
}
#[derive(Debug, FromForm, Serialize, Deserialize)]

View File

@@ -1,10 +1,10 @@
{{#*inline "page"}}
<p>
This is the registry server of sn0int, an OSINT framework and package manager.
It was built for IT security professionals and bug hunters to gather
intelligence about a given target or about yourself. sn0int is enumerating
attack surface by semi-automatically processing public information and mapping
the results in a unified format for followup investigations.
This is the registry server of sn0int, a semi-automatic OSINT framework and
package manager. It was built for IT security professionals and bug hunters to
gather intelligence about a given target or about yourself. sn0int is
enumerating attack surface by semi-automatically processing public information
and mapping the results in a unified format for followup investigations.
</p>
<p>
@@ -12,12 +12,14 @@ Among other things, sn0int is currently able to:
</p>
<ul class="list-unstyled">
<li>[X] Harvest subdomains from certificate transparency logs</li>
<li>[X] Harvest subdomains from various passive dns logs</li>
<li>[X] Sift through subdomain results for publicly accessible websites</li>
<li>[X] Harvest emails from pgp keyservers</li>
<li>[X] Enrich ip addresses with ASN and geoip info</li>
<li>[X] Harvest subdomains from the wayback machine</li>
<li>- Harvest subdomains from certificate transparency logs</li>
<li>- Harvest subdomains from various passive dns logs</li>
<li>- Sift through subdomain results for publicly accessible websites</li>
<li>- Harvest emails from pgp keyservers</li>
<li>- Enrich ip addresses with ASN and geoip info</li>
<li>- Harvest subdomains from the wayback machine</li>
<li>- Gather information about phonenumbers</li>
<li>- Bruteforce interesting urls</li>
</ul>
<p>

View File

@@ -1,6 +1,6 @@
use errors::*;
use crate::errors::*;
use std::fmt;
use config::Config;
use crate::config::Config;
use chrootable_https::{self, HttpClient, Body, Request, Uri};
use chrootable_https::http::request::Builder as RequestBuilder;
use chrootable_https::header::CONTENT_TYPE;
@@ -10,8 +10,8 @@ use serde::de::DeserializeOwned;
use serde::ser::Serialize;
use serde_json;
use sn0int_common::api::*;
use sn0int_common::ModuleID;
use web;
use sn0int_common::{ModuleID, ApiResponse};
use crate::web;
pub struct Client {
@@ -22,7 +22,10 @@ pub struct Client {
impl Client {
pub fn new(config: &Config) -> Result<Client> {
let client = chrootable_https::Client::with_system_resolver()?;
let client = match config.network.proxy {
Some(proxy) => chrootable_https::Client::with_socks5(proxy),
_ => chrootable_https::Client::with_system_resolver()?,
};
Ok(Client {
server: config.core.registry.clone(),
client,
@@ -46,7 +49,8 @@ impl Client {
let request = request.body(body)?;
let resp = self.client.request(request)?;
let resp = self.client.request(request)
.wait_for_response()?;
info!("response: {:?}", resp);
let reply = serde_json::from_slice::<ApiResponse<T>>(&resp.body)?;

View File

@@ -1,4 +1,4 @@
use errors::*;
use crate::errors::*;
use tar;
use libflate::gzip;
use std::io;

View File

@@ -1,6 +1,8 @@
use structopt::clap::{AppSettings, Shell};
use sn0int_common::ModuleID;
use workspaces::Workspace;
use crate::cmd;
use crate::options;
use crate::workspaces::Workspace;
#[derive(Debug, StructOpt)]
@@ -44,6 +46,9 @@ pub enum SubCommand {
#[structopt(author="", name="search")]
/// Search in the registry
Search(Search),
#[structopt(author="", name="select")]
/// Select from the database
Select(cmd::select_cmd::Args),
#[structopt(author="", name="completions")]
/// Generate shell completions
Completions(Completions),
@@ -66,6 +71,21 @@ pub struct Run {
#[structopt(long="stdin")]
/// Expose stdin to modules
pub stdin: bool,
#[structopt(long="grant")]
/// Automatically grant access to a keyring namespace
pub grants: Vec<String>,
#[structopt(long="grant-full-keyring")]
/// Automatically grant access to all requested keys
pub grant_full_keyring: bool,
#[structopt(long="deny-keyring")]
/// Automatically deny access to all requested keys
pub deny_keyring: bool,
#[structopt(short="x", long="exit-on-error")]
/// Exit on first error and set exit code
pub exit_on_error: bool,
#[structopt(short="o", long="option")]
/// Set an option
pub options: Vec<options::Opt>,
}
#[derive(Debug, StructOpt)]

View File

@@ -1,12 +1,12 @@
use errors::*;
use crate::errors::*;
use opener;
use std::fs;
use std::thread;
use std::time::Duration;
use api::Client;
use config::Config;
use paths;
use term;
use crate::api::Client;
use crate::config::Config;
use crate::paths;
use crate::term;
pub fn load_token() -> Result<String> {

View File

@@ -1,12 +1,15 @@
use errors::*;
use crate::errors::*;
use models::*;
use shell::Readline;
use crate::models::*;
use crate::shell::Readline;
use structopt::StructOpt;
use utils;
use structopt::clap::AppSettings;
use crate::utils;
#[derive(Debug, StructOpt)]
#[structopt(author = "",
raw(global_settings = "&[AppSettings::ColoredHelp]"))]
pub enum Args {
#[structopt(name="domain")]
Domain(AddDomain),
@@ -14,6 +17,12 @@ pub enum Args {
Subdomain(AddSubdomain),
#[structopt(name="email")]
Email(AddEmail),
#[structopt(name="phonenumber")]
PhoneNumber(AddPhoneNumber),
#[structopt(name="device")]
Device(AddDevice),
#[structopt(name="network")]
Network(AddNetwork),
}
#[derive(Debug, StructOpt)]
@@ -31,12 +40,34 @@ pub struct AddEmail {
email: Option<String>,
}
#[derive(Debug, StructOpt)]
pub struct AddPhoneNumber {
phonenumber: Option<String>,
name: Option<String>,
}
#[derive(Debug, StructOpt)]
pub struct AddDevice {
mac: Option<String>,
name: Option<String>,
}
#[derive(Debug, StructOpt)]
pub struct AddNetwork {
network: Option<String>,
latitude: Option<f32>,
longitude: Option<f32>,
}
pub fn run(rl: &mut Readline, args: &[String]) -> Result<()> {
let args = Args::from_iter_safe(args)?;
match args {
Args::Domain(args) => add_domain(rl, args),
Args::Subdomain(args) => add_subdomain(rl, args),
Args::Email(args) => add_email(rl, args),
Args::PhoneNumber(args) => add_phonenumber(rl, args),
Args::Device(args) => add_device(rl, args),
Args::Network(args) => add_network(rl, args),
}
}
@@ -103,3 +134,75 @@ fn add_email(rl: &mut Readline, args: AddEmail) -> Result<()> {
Ok(())
}
fn add_phonenumber(rl: &mut Readline, args: AddPhoneNumber) -> Result<()> {
let (phonenumber, name) = match args.phonenumber {
Some(phonenumber) => {
(phonenumber, args.name)
},
_ => {
let phonenumber = utils::question("Phone Number")?;
let name = utils::question_opt("Name")?;
(phonenumber, name)
},
};
rl.db().insert_struct(NewPhoneNumber {
value: &phonenumber,
name: name.as_ref(),
valid: None,
last_online: None,
country: None,
carrier: None,
line: None,
is_ported: None,
last_ported: None,
caller_name: None,
caller_type: None,
})?;
Ok(())
}
fn add_device(rl: &mut Readline, args: AddDevice) -> Result<()> {
let (mac, name) = match args.mac {
Some(mac) => {
(mac, args.name)
},
_ => {
let mac = utils::question("Mac address")?;
let name = utils::question_opt("Name")?;
(mac, name)
},
};
rl.db().insert_struct(NewDevice {
value: &mac,
name: name.as_ref(),
hostname: None,
vendor: None,
last_seen: None,
})?;
Ok(())
}
fn add_network(rl: &mut Readline, args: AddNetwork) -> Result<()> {
let (network, latitude, longitude) = match args.network {
Some(network) => (network, args.latitude, args.longitude),
_ => {
let network = utils::question("Network")?;
let latitude = utils::question_typed_opt("Latitude")?;
let longitude = utils::question_typed_opt("Longitude")?;
(network, latitude, longitude)
}
};
rl.db().insert_struct(NewNetwork {
value: &network,
latitude,
longitude,
})?;
Ok(())
}

View File

@@ -1,13 +1,16 @@
use errors::*;
use crate::errors::*;
use db;
use shell::Readline;
use crate::db;
use crate::shell::Readline;
use structopt::StructOpt;
use models::*;
use term;
use structopt::clap::AppSettings;
use crate::models::*;
use crate::term;
#[derive(Debug, StructOpt)]
#[structopt(author = "",
raw(global_settings = "&[AppSettings::ColoredHelp]"))]
pub enum Args {
#[structopt(name="domains")]
Domains(Filter),
@@ -19,6 +22,12 @@ pub enum Args {
Urls(Filter),
#[structopt(name="emails")]
Emails(Filter),
#[structopt(name="phonenumbers")]
PhoneNumbers(Filter),
#[structopt(name="devices")]
Devices(Filter),
#[structopt(name="networks")]
Networks(Filter),
}
#[derive(Debug, StructOpt)]
@@ -40,6 +49,9 @@ pub fn run(rl: &mut Readline, args: &[String]) -> Result<()> {
Args::IpAddrs(filter) => delete::<IpAddr>(rl, &filter),
Args::Urls(filter) => delete::<Url>(rl, &filter),
Args::Emails(filter) => delete::<Email>(rl, &filter),
Args::PhoneNumbers(filter) => delete::<PhoneNumber>(rl, &filter),
Args::Devices(filter) => delete::<Device>(rl, &filter),
Args::Networks(filter) => delete::<Network>(rl, &filter),
}?;
term::info(&format!("Deleted {} rows", rows));
Ok(())

30
src/cmd/help_cmd.rs Normal file
View File

@@ -0,0 +1,30 @@
use crate::errors::*;
use crate::shell::Readline;
#[inline]
fn help(name: &str, descr: &str) {
println!(" \x1b[32m{:13}\x1b[0m {}", name, descr);
}
pub fn run(_rl: &mut Readline, _args: &[String]) -> Result<()> {
println!("\n\x1b[33mCOMMANDS:\x1b[0m");
help("add", "Add new entities to the database");
help("delete", "Delete entities from the database");
help("keyring", "Manage saved credentials");
help("mod", "Manage installed modules");
help("noscope", "Exclude entities from scope");
help("quickstart", "Install all featured modules");
help("run", "Run the currently selected module");
help("scope", "Include entities in the scope again");
help("select", "Select entities from the database");
help("target", "Preview targeted entities or narrow them down");
help("use", "Select a module");
help("workspace", "Switch to a different workspace");
help("help", "Prints this message");
println!("\nRun <command> -h for more help.\n");
Ok(())
}

105
src/cmd/keyring_cmd.rs Normal file
View File

@@ -0,0 +1,105 @@
use crate::errors::*;
use crate::keyring::{KeyName, KeyRing};
use crate::shell::Readline;
use structopt::StructOpt;
use structopt::clap::AppSettings;
use crate::utils;
#[derive(Debug, StructOpt)]
#[structopt(author = "",
raw(global_settings = "&[AppSettings::ColoredHelp]"))]
pub enum Args {
#[structopt(name="add")]
/// Add a new key to the keyring
Add(KeyRingAdd),
#[structopt(name="delete")]
/// Delete a key from the keyring
Delete(KeyRingDelete),
#[structopt(name="get")]
/// Get a key from the keyring
Get(KeyRingGet),
#[structopt(name="list")]
/// List keys in the keyring
List(KeyRingList),
}
#[derive(Debug, StructOpt)]
pub struct KeyRingAdd {
key: KeyName,
secret: Option<String>,
}
#[derive(Debug, StructOpt)]
pub struct KeyRingDelete {
key: KeyName,
}
#[derive(Debug, StructOpt)]
pub struct KeyRingGet {
key: KeyName,
#[structopt(short="q",
long="quiet")]
/// Only output secret key
quiet: bool,
}
#[derive(Debug, StructOpt)]
pub struct KeyRingList {
namespace: Option<String>,
}
pub fn run(rl: &mut Readline, args: &[String]) -> Result<()> {
let args = Args::from_iter_safe(args)?;
match args {
Args::Add(add) => keyring_add(rl.keyring_mut(), add),
Args::Delete(delete) => keyring_delete(rl.keyring_mut(), delete),
Args::Get(get) => keyring_get(rl.keyring(), &get),
Args::List(list) => keyring_list(rl.keyring(), list),
}
}
fn keyring_add(keyring: &mut KeyRing, add: KeyRingAdd) -> Result<()> {
// TODO: there's no non-interactive way to add a key without a secret key
let secret = match add.secret {
Some(secret) => Some(secret),
None => utils::question_opt("Secretkey")?,
};
keyring.insert(add.key, secret)
}
fn keyring_delete(keyring: &mut KeyRing, delete: KeyRingDelete) -> Result<()> {
keyring.delete(delete.key)
}
fn keyring_get(keyring: &KeyRing, get: &KeyRingGet) -> Result<()> {
if let Some(key) = keyring.get(&get.key) {
if get.quiet {
if let Some(secret_key) = key.secret_key {
println!("{}", secret_key);
}
} else {
println!("Namespace: {:?}", get.key.namespace);
println!("Access Key: {:?}", get.key.name);
if let Some(secret_key) = key.secret_key {
println!("Secret: {:?}", secret_key);
}
}
}
Ok(())
}
fn keyring_list(keyring: &KeyRing, list: KeyRingList) -> Result<()> {
let list = match list.namespace {
Some(namespace) => keyring.list_for(&namespace),
None => keyring.list(),
};
for key in list {
println!("{}:{}", key.namespace, key.name);
}
Ok(())
}

View File

@@ -1,10 +1,26 @@
use crate::errors::*;
use crate::shell::Readline;
pub trait Cmd: structopt::StructOpt + Sized {
fn run(&self, rl: &mut Readline) -> Result<()>;
#[inline]
fn run_str(rl: &mut Readline, args: &[String]) -> Result<()> {
let args = Self::from_iter_safe(args)?;
args.run(rl)
}
}
pub mod add_cmd;
pub mod delete_cmd;
pub mod help_cmd;
pub mod run_cmd;
pub mod use_cmd;
pub mod select_cmd;
pub mod keyring_cmd;
pub mod mod_cmd;
pub mod noscope_cmd;
pub mod set_cmd;
pub mod scope_cmd;
pub mod target_cmd;
pub mod quickstart_cmd;

View File

@@ -1,19 +1,22 @@
use errors::*;
use crate::errors::*;
use args;
use args::Install;
use api::Client;
use config::Config;
use crate::args;
use crate::args::Install;
use crate::api::Client;
use crate::config::Config;
use colored::Colorize;
use engine::Module;
use registry;
use shell::Readline;
use crate::engine::Module;
use crate::registry;
use crate::shell::Readline;
use structopt::StructOpt;
use term;
use worker;
use structopt::clap::AppSettings;
use crate::term;
use crate::worker;
#[derive(Debug, StructOpt)]
#[structopt(author = "",
raw(global_settings = "&[AppSettings::ColoredHelp]"))]
pub struct Args {
#[structopt(subcommand)]
pub subcommand: SubCommand,

View File

@@ -1,13 +1,16 @@
use errors::*;
use crate::errors::*;
use db;
use shell::Readline;
use crate::db;
use crate::shell::Readline;
use structopt::StructOpt;
use models::*;
use term;
use structopt::clap::AppSettings;
use crate::models::*;
use crate::term;
#[derive(Debug, StructOpt)]
#[structopt(author = "",
raw(global_settings = "&[AppSettings::ColoredHelp]"))]
pub enum Args {
#[structopt(name="domains")]
Domains(Filter),
@@ -19,6 +22,8 @@ pub enum Args {
Urls(Filter),
#[structopt(name="emails")]
Emails(Filter),
#[structopt(name="phonenumbers")]
PhoneNumbers(Filter),
}
#[derive(Debug, StructOpt)]
@@ -40,6 +45,7 @@ pub fn run(rl: &mut Readline, args: &[String]) -> Result<()> {
Args::IpAddrs(filter) => noscope::<IpAddr>(rl, &filter),
Args::Urls(filter) => noscope::<Url>(rl, &filter),
Args::Emails(filter) => noscope::<Email>(rl, &filter),
Args::PhoneNumbers(filter) => noscope::<PhoneNumber>(rl, &filter),
}?;
term::info(&format!("Updated {} rows", rows));
Ok(())

View File

@@ -1,16 +1,18 @@
use errors::*;
use crate::errors::*;
use args::Install;
use api::Client;
// use colored::Colorize;
use cmd::mod_cmd;
use registry;
use shell::Readline;
use crate::args::Install;
use crate::api::Client;
use crate::cmd::mod_cmd;
use crate::registry;
use crate::shell::Readline;
use structopt::StructOpt;
use structopt::clap::AppSettings;
use sn0int_common::ModuleID;
#[derive(Debug, StructOpt)]
#[structopt(author = "",
raw(global_settings = "&[AppSettings::ColoredHelp]"))]
pub struct Args {
}

View File

@@ -1,17 +1,25 @@
use errors::*;
use crate::errors::*;
use db::{Database, Filter};
use sn0int_common::metadata::Source;
use crate::args;
use crate::db::{Database, Filter};
use crate::engine::Module;
use crate::models::*;
use crate::shell::Readline;
use crate::keyring::KeyRing;
use crate::term;
use crate::utils;
use crate::worker;
use serde::Serialize;
use serde_json;
use shell::Readline;
use sn0int_common::metadata::Source;
use std::collections::HashMap;
use structopt::StructOpt;
use models::*;
use term;
use worker;
use structopt::clap::AppSettings;
#[derive(Debug, StructOpt)]
#[structopt(author = "",
raw(global_settings = "&[AppSettings::ColoredHelp]"))]
pub struct Args {
#[structopt(short="j", long="threads", default_value="1")]
threads: usize,
@@ -19,6 +27,45 @@ pub struct Args {
verbose: u64,
}
#[derive(Debug, Clone)]
pub struct Params<'a> {
pub threads: usize,
pub verbose: u64,
pub stdin: bool,
pub grants: &'a [String],
pub grant_full_keyring: bool,
pub deny_keyring: bool,
pub exit_on_error: bool,
}
impl<'a> From<&'a args::Run> for Params<'a> {
fn from(args: &args::Run) -> Params {
Params {
threads: args.threads,
verbose: args.verbose,
stdin: args.stdin,
grants: &args.grants,
grant_full_keyring: args.grant_full_keyring,
deny_keyring: args.deny_keyring,
exit_on_error: args.exit_on_error,
}
}
}
impl From<Args> for Params<'static> {
fn from(args: Args) -> Params<'static> {
Params {
threads: args.threads,
verbose: args.verbose,
stdin: false,
grants: &[],
grant_full_keyring: false,
deny_keyring: false,
exit_on_error: false,
}
}
}
fn prepare_arg<T: Serialize + Model>(x: T) -> Result<(serde_json::Value, Option<String>)> {
let pretty = x.to_string();
let arg = serde_json::to_value(x)?;
@@ -32,11 +79,36 @@ fn prepare_args<T: Scopable + Serialize + Model>(db: &Database, filter: &Filter)
.collect()
}
pub fn execute(rl: &mut Readline, threads: usize, verbose: u64, has_stdin: bool) -> Result<()> {
fn prepare_keyring(keyring: &mut KeyRing, module: &Module, params: &Params) -> Result<()> {
for namespace in keyring.unauthorized_namespaces(&module) {
let grant_access = if params.deny_keyring {
false
} else if params.grant_full_keyring || params.grants.contains(namespace) {
true
} else {
let msg = format!("Grant access to {:?} credentials?", namespace);
utils::no_else_yes(&msg)?
};
if grant_access {
keyring.grant_access(&module, namespace.to_string());
term::info(&format!("Granted access to {:?}", namespace));
}
}
keyring.save()
.context("Failed to write keyring")?;
Ok(())
}
pub fn execute(rl: &mut Readline, params: Params, options: HashMap<String, String>) -> Result<()> {
let module = rl.module()
.map(|m| m.to_owned())
.ok_or_else(|| format_err!("No module selected"))?;
prepare_keyring(rl.keyring_mut(), &module, &params)?;
let filter = rl.scoped_targets();
let args = match module.source() {
@@ -45,19 +117,46 @@ pub fn execute(rl: &mut Readline, threads: usize, verbose: u64, has_stdin: bool)
Some(Source::IpAddrs) => prepare_args::<IpAddr>(rl.db(), &filter),
Some(Source::Urls) => prepare_args::<Url>(rl.db(), &filter),
Some(Source::Emails) => prepare_args::<Email>(rl.db(), &filter),
Some(Source::PhoneNumbers) => prepare_args::<PhoneNumber>(rl.db(), &filter),
Some(Source::KeyRing(namespace)) => {
let keyring = rl.keyring();
if keyring.is_access_granted(&module, &namespace) {
keyring.get_all_for(&namespace).into_iter()
.map(|key| {
let pretty = format!("{}:{}", key.namespace, key.access_key);
let arg = serde_json::to_value(key)?;
Ok((arg, Some(pretty)))
})
.collect::<Result<Vec<_>>>()
} else {
Ok(vec![])
}
},
None => Ok(vec![(serde_json::Value::Null, None)]),
}?;
rl.signal_register().catch_ctrl();
worker::spawn(rl, &module, args, threads, verbose, has_stdin);
let errors = worker::spawn(rl, &module, args, &params, rl.config().network.proxy.clone(), options);
rl.signal_register().reset_ctrlc();
term::info(&format!("Finished {}", module.canonical()));
if errors > 0 {
term::info(&format!("Finished {} ({} errors)", module.canonical(), errors));
if params.exit_on_error {
bail!("Some scripts failed");
}
} else {
term::info(&format!("Finished {}", module.canonical()));
}
Ok(())
}
pub fn run(rl: &mut Readline, args: &[String]) -> Result<()> {
let args = Args::from_iter_safe(args)?;
execute(rl, args.threads, args.verbose, false)
let options = match rl.options_mut() {
Some(options) => options.clone(),
_ => HashMap::new(),
};
execute(rl, args.into(), options)
}

View File

@@ -1,13 +1,16 @@
use errors::*;
use crate::errors::*;
use db;
use shell::Readline;
use crate::db;
use crate::shell::Readline;
use structopt::StructOpt;
use models::*;
use term;
use structopt::clap::AppSettings;
use crate::models::*;
use crate::term;
#[derive(Debug, StructOpt)]
#[structopt(author = "",
raw(global_settings = "&[AppSettings::ColoredHelp]"))]
pub enum Args {
#[structopt(name="domains")]
Domains(Filter),
@@ -19,6 +22,8 @@ pub enum Args {
Urls(Filter),
#[structopt(name="emails")]
Emails(Filter),
#[structopt(name="phonenumbers")]
PhoneNumbers(Filter),
}
#[derive(Debug, StructOpt)]
@@ -40,6 +45,7 @@ pub fn run(rl: &mut Readline, args: &[String]) -> Result<()> {
Args::IpAddrs(filter) => scope::<IpAddr>(rl, &filter),
Args::Urls(filter) => scope::<Url>(rl, &filter),
Args::Emails(filter) => scope::<Email>(rl, &filter),
Args::PhoneNumbers(filter) => scope::<PhoneNumber>(rl, &filter),
}?;
term::info(&format!("Updated {} rows", rows));
Ok(())

View File

@@ -1,23 +1,41 @@
use errors::*;
use crate::errors::*;
use db;
use shell::Readline;
use crate::cmd::Cmd;
use crate::db;
use crate::shell::Readline;
use structopt::StructOpt;
use models::*;
use structopt::clap::AppSettings;
use crate::models::*;
#[derive(Debug, StructOpt)]
#[structopt(author = "",
raw(global_settings = "&[AppSettings::ColoredHelp]"))]
pub enum Args {
#[structopt(name="domains")]
/// Select domains
Domains(Filter),
#[structopt(name="subdomains")]
/// Select subdomains
Subdomains(Filter),
#[structopt(name="ipaddrs")]
/// Select ipaddrs
IpAddrs(Filter),
#[structopt(name="urls")]
/// Select urls
Urls(Filter),
#[structopt(name="emails")]
/// Select emails
Emails(Filter),
#[structopt(name="phonenumbers")]
/// Select phone numbers
PhoneNumbers(Filter),
#[structopt(name="devices")]
/// Select devices
Devices(Filter),
#[structopt(name="networks")]
/// Select networks
Networks(Filter),
}
#[derive(Debug, StructOpt)]
@@ -31,17 +49,26 @@ impl Filter {
}
}
pub fn run(rl: &mut Readline, args: &[String]) -> Result<()> {
let args = Args::from_iter_safe(args)?;
match args {
Args::Domains(filter) => select::<Domain>(rl, &filter),
Args::Subdomains(filter) => select::<Subdomain>(rl, &filter),
Args::IpAddrs(filter) => select::<IpAddr>(rl, &filter),
Args::Urls(filter) => select::<Url>(rl, &filter),
Args::Emails(filter) => select::<Email>(rl, &filter),
impl Cmd for Args {
fn run(&self, rl: &mut Readline) -> Result<()> {
match self {
Args::Domains(filter) => select::<Domain>(rl, &filter),
Args::Subdomains(filter) => select::<Subdomain>(rl, &filter),
Args::IpAddrs(filter) => select::<IpAddr>(rl, &filter),
Args::Urls(filter) => select::<Url>(rl, &filter),
Args::Emails(filter) => select::<Email>(rl, &filter),
Args::PhoneNumbers(filter) => select::<PhoneNumber>(rl, &filter),
Args::Devices(filter) => select::<Device>(rl, &filter),
Args::Networks(filter) => select::<Network>(rl, &filter),
}
}
}
#[inline]
pub fn run(rl: &mut Readline, args: &[String]) -> Result<()> {
Args::run_str(rl, args)
}
fn select<T: Model + Detailed>(rl: &mut Readline, filter: &Filter) -> Result<()> {
for obj in rl.db().filter::<T>(&filter.parse()?)? {
println!("{}", obj.detailed(rl.db())?);

42
src/cmd/set_cmd.rs Normal file
View File

@@ -0,0 +1,42 @@
use crate::errors::*;
use crate::shell::Readline;
use structopt::StructOpt;
use structopt::clap::AppSettings;
#[derive(Debug, StructOpt)]
#[structopt(author = "",
raw(global_settings = "&[AppSettings::ColoredHelp]"))]
pub struct Args {
key: Option<String>,
value: Option<String>,
}
// TODO: maybe introduce global settings
// TODO: maybe allow setting jobs here as well in addition to -j
pub fn run(rl: &mut Readline, args: &[String]) -> Result<()> {
let args = Args::from_iter_safe(args)?;
let options = rl.options_mut()
.ok_or_else(|| format_err!("Module needs to be selected first"))?;
match (args.key, args.value) {
(None, None) => {
for (key, value) in options.iter() {
println!("{}={:?}", key, value);
}
},
(Some(key), None) => {
if let Some(value) = options.get(&key) {
println!("{:?}", value);
}
},
(Some(key), Some(value)) => {
options.insert(key, value);
},
(None, Some(_)) => unreachable!(),
}
Ok(())
}

View File

@@ -1,14 +1,17 @@
use errors::*;
use crate::errors::*;
use db;
use shell::Readline;
use crate::db;
use crate::shell::Readline;
use sn0int_common::metadata::Source;
use structopt::StructOpt;
use term;
use models::*;
use structopt::clap::AppSettings;
use crate::term;
use crate::models::*;
#[derive(Debug, StructOpt)]
#[structopt(author = "",
raw(global_settings = "&[AppSettings::ColoredHelp]"))]
pub struct Args {
// TODO: target -p # print current filter
// TODO: target -c # clear filter
@@ -33,6 +36,12 @@ pub fn run(rl: &mut Readline, args: &[String]) -> Result<()> {
Source::IpAddrs => select::<IpAddr>(rl)?,
Source::Urls => select::<Url>(rl)?,
Source::Emails => select::<Email>(rl)?,
Source::PhoneNumbers => select::<PhoneNumber>(rl)?,
Source::KeyRing(namespace) => {
for key in rl.keyring().list_for(&namespace) {
println!("{}:{}", key.namespace, key.name);
}
},
}
} else {
debug!("Setting filter to {:?}", args.filter);
@@ -54,6 +63,8 @@ fn count_selected(rl: &mut Readline, source: &Source) -> Result<usize> {
Source::IpAddrs => db.filter::<IpAddr>(&filter)?.len(),
Source::Urls => db.filter::<Url>(&filter)?.len(),
Source::Emails => db.filter::<Email>(&filter)?.len(),
Source::PhoneNumbers => db.filter::<PhoneNumber>(&filter)?.len(),
Source::KeyRing(namespace) => rl.keyring().list_for(&namespace).len(),
};
Ok(num)
}

View File

@@ -1,10 +1,13 @@
use errors::*;
use crate::errors::*;
use shell::Readline;
use crate::shell::Readline;
use structopt::StructOpt;
use structopt::clap::AppSettings;
#[derive(Debug, StructOpt)]
#[structopt(author = "",
raw(global_settings = "&[AppSettings::ColoredHelp]"))]
pub struct Args {
module: String,
}

View File

@@ -1,12 +1,15 @@
use errors::*;
use crate::errors::*;
use db::Database;
use shell::Readline;
use crate::db::Database;
use crate::shell::Readline;
use structopt::StructOpt;
use workspaces::{self, Workspace};
use structopt::clap::AppSettings;
use crate::workspaces::{self, Workspace};
#[derive(Debug, StructOpt)]
#[structopt(author = "",
raw(global_settings = "&[AppSettings::ColoredHelp]"))]
pub struct Args {
workspace: Option<Workspace>,
}

View File

@@ -1,5 +1,5 @@
use args::{Args, Completions};
use errors::*;
use crate::args::{Args, Completions};
use crate::errors::*;
use rustyline;
use rustyline::completion::Completer;
use rustyline::highlight::Highlighter;
@@ -9,8 +9,8 @@ use std::borrow::Cow::{self, Borrowed, Owned};
use std::str::FromStr;
use std::io::stdout;
use structopt::StructOpt;
use shell::Command;
use workspaces;
use crate::shell::Command;
use crate::workspaces;
#[derive(Debug, Default)]
@@ -30,7 +30,10 @@ impl CmdCompleter {
"subdomains",
"ipaddrs",
"urls",
"emails"];
"emails",
"phonenumbers",
"devices",
"networks"];
let results: Vec<String> = options.iter()
.filter(|x| x.starts_with(arg))
@@ -86,7 +89,11 @@ impl Completer for CmdCompleter {
let arg = &cmd[1];
let options = &["domain",
"subdomain"];
"subdomain",
"email",
"phonenumber",
"device",
"network"];
let results: Vec<String> = options.iter()
.filter(|x| x.starts_with(arg))
@@ -96,6 +103,25 @@ impl Completer for CmdCompleter {
}
},
Command::Delete => self.filter("delete", &cmd),
Command::Keyring => {
// we can only complete the 2nd argument
if args != 2 {
Ok((0, vec![]))
} else {
let arg = &cmd[1];
let options = &["add",
"delete",
"get",
"list"];
let results: Vec<String> = options.iter()
.filter(|x| x.starts_with(arg))
.map(|x| format!("keyring {} ", x))
.collect();
Ok((0, results))
}
},
Command::Mod => {
// we can only complete the 2nd argument
if args != 2 {
@@ -106,7 +132,8 @@ impl Completer for CmdCompleter {
let options = &["list",
"install",
"search",
"reload"];
"reload",
"update"];
let results: Vec<String> = options.iter()
.filter(|x| x.starts_with(arg))

View File

@@ -1,13 +1,17 @@
use dirs;
use errors::*;
use crate::errors::*;
use std::fs;
use std::path::{Path, PathBuf};
use std::net::SocketAddr;
use toml;
#[derive(Debug, Default, Clone, Serialize, Deserialize)]
pub struct Config {
#[serde(default)]
pub core: CoreConfig,
#[serde(default)]
pub network: NetworkConfig,
}
impl Config {
@@ -60,3 +64,8 @@ impl Default for CoreConfig {
fn default_registry() -> String {
String::from("https://sn0int.com")
}
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct NetworkConfig {
pub proxy: Option<SocketAddr>,
}

View File

@@ -1,10 +1,10 @@
use errors::*;
use crate::errors::*;
use x509_parser;
use der_parser::{DerObject, DerObjectContent};
use der_parser::oid::Oid;
use std::collections::HashSet;
use std::net::{IpAddr, Ipv4Addr, Ipv6Addr};
use nom::be_u8;
#[derive(Debug, PartialEq)]
@@ -13,69 +13,56 @@ pub enum AlternativeName {
IpAddr(IpAddr),
}
named!(san_extension<&[u8], Vec<AlternativeName>>, do_parse!(
_tag: tag!(b"\x30") >>
len: be_u8 >>
values: take!(len) >>
({
let mut bytes = values;
let mut values = Vec::new();
while !bytes.is_empty() {
let (rem, v) = san_value(bytes)?;
match v {
Ok(v) => values.push(v),
Err(e) => warn!("Unknown field in SAN extension: {}", e),
}
bytes = rem;
}
values
})
));
pub fn san_extension(i: &[u8]) -> Result<Vec<AlternativeName>> {
let (rem, seq) = der_parser::parse_der_sequence(i)
.map_err(|_| format_err!("Failed to parse san extension"))?;
named!(san_value<&[u8], Result<AlternativeName>>,
switch!(be_u8,
0x82 => call!(san_value_dns) |
0x87 => call!(san_value_ipaddr) |
k => call!(san_value_unknown, k)
)
);
if !rem.is_empty() {
bail!("san extension has trailing garbage");
}
named!(san_value_dns<&[u8], Result<AlternativeName>>, do_parse!(
len: be_u8 >>
value: take!(len) >>
({
String::from_utf8(value.to_vec())
.map(|v| AlternativeName::DnsName(v))
.map_err(Error::from)
})
));
debug!("Decoded sequence: {:?}", seq);
if let DerObjectContent::Sequence(seq) = seq.content {
seq.into_iter()
.map(san_value)
.collect()
} else {
bail!("Expected der sequence");
}
}
named!(san_value_ipaddr<&[u8], Result<AlternativeName>>, do_parse!(
len: be_u8 >>
v: take!(len) >>
({
match len {
4 => Ok(AlternativeName::IpAddr(Ipv4Addr::from([
v[0], v[1], v[2], v[3],
]).into())),
16 => Ok(AlternativeName::IpAddr(Ipv6Addr::from([
v[0], v[1], v[2], v[3],
v[4], v[5], v[6], v[7],
v[8], v[9], v[10], v[11],
v[12], v[13], v[14], v[15],
]).into())),
_ => Err(format_err!("Invalid ipaddr")),
}
})
));
pub fn san_value(o: DerObject) -> Result<AlternativeName> {
debug!("DER object in SAN extension: {:?}", o);
named_args!(san_value_unknown(key: u8)<&[u8], Result<AlternativeName>>, do_parse!(
len: be_u8 >>
v: take!(len) >>
({
Err(format_err!("Unexpected type {:?} => {:?}", key, v))
})
));
match (o.class, o.tag, &o.content) {
(2, 2, DerObjectContent::Unknown(value)) => san_value_dns(value),
(2, 7, DerObjectContent::Unknown(value)) => san_value_ipaddr(value),
_ => bail!("Unexpected object: {:?}", o),
}
}
pub fn san_value_dns(v: &[u8]) -> Result<AlternativeName> {
debug!("Reading as dns name: {:?}", v);
String::from_utf8(v.to_vec())
.map(AlternativeName::DnsName)
.map_err(Error::from)
}
pub fn san_value_ipaddr(v: &[u8]) -> Result<AlternativeName> {
debug!("Reading as ipaddr: {:?}", v);
match v.len() {
4 => Ok(AlternativeName::IpAddr(Ipv4Addr::from([
v[0], v[1], v[2], v[3],
]).into())),
16 => Ok(AlternativeName::IpAddr(Ipv6Addr::from([
v[0], v[1], v[2], v[3],
v[4], v[5], v[6], v[7],
v[8], v[9], v[10], v[11],
v[12], v[13], v[14], v[15],
]).into())),
_ => Err(format_err!("Invalid ipaddr")),
}
}
#[derive(Debug, PartialEq, Serialize, Deserialize)]
pub struct Certificate {
@@ -138,15 +125,7 @@ impl Certificate {
}
debug!("Found san extension: {:?}", x.value);
let values = match san_extension(x.value) {
Ok((remaining, values)) => {
if !remaining.is_empty() {
bail!("san extension has trailing garbage");
}
values
},
Err(_) => bail!("Failed to parse san extension"),
};
let values = san_extension(x.value)?;
for v in values {
match v {
@@ -168,6 +147,7 @@ impl Certificate {
#[cfg(test)]
mod tests {
use super::*;
use der_parser::parse_der;
#[test]
fn test_parse_pem_github() {
@@ -265,33 +245,154 @@ ZkZZmqNn2Q8=
#[test]
fn test_san_extension() {
let (rem, ext) = san_extension(&[48, 28,
let ext = san_extension(&[48, 28,
130, 10, 103, 105, 116, 104, 117, 98, 46, 99, 111, 109,
130, 14, 119, 119, 119, 46, 103, 105, 116, 104, 117, 98, 46, 99, 111, 109
])
.expect("Failed to parse extension");
assert!(rem.is_empty());
assert_eq!(ext, vec![
AlternativeName::DnsName(String::from("github.com")),
AlternativeName::DnsName(String::from("www.github.com")),
]);
}
#[test]
fn test_long_san_extension() {
let mut x = Certificate::parse_pem(r#"-----BEGIN CERTIFICATE-----
MIII3jCCB8agAwIBAgIQAp1dOviF3mpYKKObx4fjxjANBgkqhkiG9w0BAQsFADBe
MQswCQYDVQQGEwJVUzEVMBMGA1UEChMMRGlnaUNlcnQgSW5jMRkwFwYDVQQLExB3
d3cuZGlnaWNlcnQuY29tMR0wGwYDVQQDExRHZW9UcnVzdCBSU0EgQ0EgMjAxODAe
Fw0xOTAxMDMwMDAwMDBaFw0xOTA3MzAxMjAwMDBaMIGCMQswCQYDVQQGEwJERTEl
MCMGA1UECBMcRnJlaWUgdW5kIEhhbnNlc3RhZHQgSGFtYnVyZzEQMA4GA1UEBxMH
SGFtYnVyZzEXMBUGA1UEChMOQWJvdXQgWW91IEdtYkgxCzAJBgNVBAsTAklUMRQw
EgYDVQQDEwthYm91dHlvdS5kZTCCASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoC
ggEBALG6ZjY9TtJmN18p5KlJMtzdZMhw3mz6dGOYoSMTaQCDnw7RW14H8JX9Dz51
dTM4Ig1rPka5DjujNG8BKETGknRzQMEo7x08qZirzdQIz9QCnYDQ3/6l9tDfQ16X
pctnQRY156H8jyjhkaT+dWJIHaPwz+g6117plfv0F6iOcupNtF4rnZK7vpcyb/Fm
F985uHdBVXJKVt7BMUjUO6fdm8865fTyL8lb1ocEgbN91KdI7Bt9wUqxgOR7BJRJ
YQAC+Y6wqE8BwOGH11QaNGKQ8xGdBd3eC4tAuif1y+4WVPDAlhmJJR/FcnsiLVbX
zg4sgE+4kLOayCJY6MfN2MRtchkCAwEAAaOCBXEwggVtMB8GA1UdIwQYMBaAFJBY
/7CcdahRVHex7fKjQxY4nmzFMB0GA1UdDgQWBBTPNzAGXJdERAKW8w3kFNJ88MLO
qjCCAuIGA1UdEQSCAtkwggLVggthYm91dHlvdS5kZYIRY2RuLnlvdWFuZGlkb2wu
ZGWCDWNkbi5lZGl0ZWQuZGWCE2Nkbi5hYm91dHN0YXRpYy5jb22CDW0uYWJvdXR5
b3UuZGWCE3N0YXRpYzMuYWJvdXR5b3UuZGWCFmltYWdlcy5hYm91dHN0YXRpYy5j
b22CE3N0YXRpYzUuYWJvdXR5b3UuZGWCEGNvLXQuYWJvdXR5b3UuZGWCDXQuYWJv
dXR5b3UuZGWCDmNvLmFib3V0eW91LmRlggllZGl0ZWQuZGWCE2NvLW1hcHAuYWJv
dXR5b3UuZGWCE3N0YXRpYzQuYWJvdXR5b3UuZGWCEW1lZGlhLmFib3V0eW91LmRl
giZ3aXR0LXdlaWRlbi5kYW0uc3RhZ2luZy5hYm91dHlvdS5jbG91ZIISc3RhdGlj
LmFib3V0eW91LmRlghBjZG40LmFib3V0eW91LmRlghNzdGF0aWMyLmFib3V0eW91
LmRlgiN3aXR0LXdlaWRlbi5kYW0uYWNtZS5hYm91dHlvdS5jbG91ZIIXY2RuLmFi
b3V0eW91LXN0YWdpbmcuZGWCD2Nkbi5hYm91dHlvdS5kZYIQY2RuMy5hYm91dHlv
dS5kZYIQY2RuMi5hYm91dHlvdS5kZYIQY2RuNS5hYm91dHlvdS5kZYISYXNzZXRz
LmFib3V0eW91LmRlghBjZG4xLmFib3V0eW91LmRlghpzdGF0aWNtYWlsLWNkbi5h
Ym91dHlvdS5kZYIPd3d3LmFib3V0eW91LmRlghNzdGF0aWMxLmFib3V0eW91LmRl
ghRtLWFzc2V0cy5hYm91dHlvdS5kZYIQY2RuLm1hcnktcGF1bC5kZYIQY28tbS5h
Ym91dHlvdS5kZYIVZmlsZXMuYWJvdXRzdGF0aWMuY29tghNpbWcuYWJvdXRzdGF0
aWMuY29tgg9pbWcuYWJvdXR5b3UuZGUwDgYDVR0PAQH/BAQDAgWgMB0GA1UdJQQW
MBQGCCsGAQUFBwMBBggrBgEFBQcDAjA+BgNVHR8ENzA1MDOgMaAvhi1odHRwOi8v
Y2RwLmdlb3RydXN0LmNvbS9HZW9UcnVzdFJTQUNBMjAxOC5jcmwwTAYDVR0gBEUw
QzA3BglghkgBhv1sAQEwKjAoBggrBgEFBQcCARYcaHR0cHM6Ly93d3cuZGlnaWNl
cnQuY29tL0NQUzAIBgZngQwBAgIwdQYIKwYBBQUHAQEEaTBnMCYGCCsGAQUFBzAB
hhpodHRwOi8vc3RhdHVzLmdlb3RydXN0LmNvbTA9BggrBgEFBQcwAoYxaHR0cDov
L2NhY2VydHMuZ2VvdHJ1c3QuY29tL0dlb1RydXN0UlNBQ0EyMDE4LmNydDAJBgNV
HRMEAjAAMIIBBAYKKwYBBAHWeQIEAgSB9QSB8gDwAHcAY/Lbzeg7zCzPC3KEJ1dr
M6SNYXePvXWmOLHHaFRL2I0AAAFoE/H84wAABAMASDBGAiEAh8Q7LXUzhsbiuxCS
VoeRmnPtLEZcjNFg3R+eBK5FkQMCIQD+Ic1QErzzP1B76BPLcaBgOxULpLQ2Ib4M
b38fMU5GhwB1AId1v+dZfPiMQ5lfvfNu/1aNR1Y2/0q1YMG06v9eoIMPAAABaBPx
/dQAAAQDAEYwRAIgDcWLzLdGGG7d3EV3y809H8MwEojfEXT0DS75TchCvB0CIBno
kC5/KGjNdQdsqJX4NJbQ06RAbHLeGwX5ccmaKbQ3MA0GCSqGSIb3DQEBCwUAA4IB
AQC81DWjm2PklQzIGSIf/tRm2GtjlL6Vi7rMGkSbiV0k1FnoptdHfQIs55tTBD7c
TheMOk62JL6z0FKpAgPUIU+HrKJ/fAcBmQo+yqn0vRT0yhDrDGEFl6Sm2HyI0oKG
XryhpFLQkHuDkyA4uKOLuefPBgdjVZW9LqxmZhFPaZY6BSa/neZopVNwC1c+4Xwu
mAlnYDoB0Mj2UIPvIeftkDfF6sURmmZb0/+AMbFDCQYHvZFPI8DFgcagy8og5XJZ
gQ+70UdJdM3RWyrd9R66aZwNGkcS6C2wtKCRhztWDMru/wNuyOsYS6JttoTYxRsh
z/6Vy8Ga9kigYVsa8ZFMR+Ex
-----END CERTIFICATE-----
"#).expect("Failed to parse cert");
x.valid_names.sort();
x.valid_ipaddrs.sort();
assert_eq!(x, Certificate {
valid_names: vec![
"aboutyou.de".into(),
"assets.aboutyou.de".into(),
"cdn.aboutstatic.com".into(),
"cdn.aboutyou-staging.de".into(),
"cdn.aboutyou.de".into(),
"cdn.edited.de".into(),
"cdn.mary-paul.de".into(),
"cdn.youandidol.de".into(),
"cdn1.aboutyou.de".into(),
"cdn2.aboutyou.de".into(),
"cdn3.aboutyou.de".into(),
"cdn4.aboutyou.de".into(),
"cdn5.aboutyou.de".into(),
"co-m.aboutyou.de".into(),
"co-mapp.aboutyou.de".into(),
"co-t.aboutyou.de".into(),
"co.aboutyou.de".into(),
"edited.de".into(),
"files.aboutstatic.com".into(),
"images.aboutstatic.com".into(),
"img.aboutstatic.com".into(),
"img.aboutyou.de".into(),
"m-assets.aboutyou.de".into(),
"m.aboutyou.de".into(),
"media.aboutyou.de".into(),
"static.aboutyou.de".into(),
"static1.aboutyou.de".into(),
"static2.aboutyou.de".into(),
"static3.aboutyou.de".into(),
"static4.aboutyou.de".into(),
"static5.aboutyou.de".into(),
"staticmail-cdn.aboutyou.de".into(),
"t.aboutyou.de".into(),
"witt-weiden.dam.acme.aboutyou.cloud".into(),
"witt-weiden.dam.staging.aboutyou.cloud".into(),
"www.aboutyou.de".into(),
],
valid_ipaddrs: vec![],
});
}
#[test]
fn test_san_value_dns() {
let (rem, v) = san_value(&[130, 10, 103, 105, 116, 104, 117, 98, 46, 99, 111, 109])
let (rem, v) = parse_der(&[130, 10, 103, 105, 116, 104, 117, 98, 46, 99, 111, 109])
.expect("Failed to parse san value");
let v = v.expect("Extension contains invalid data");
assert!(rem.is_empty());
println!("{:?}", v);
assert_eq!(v, DerObject {
class: 2,
structured: 0,
tag: 2,
content: DerObjectContent::Unknown(&[103, 105, 116, 104, 117, 98, 46, 99, 111, 109])
});
let content = match v.content {
DerObjectContent::Unknown(v) => v,
_ => panic!("Wrong DerObjectContent"),
};
let v = san_value_dns(content)
.expect("Failed to process san value");
assert_eq!(v, AlternativeName::DnsName(String::from("github.com")));
}
#[test]
fn test_san_value_ipaddr() {
let (rem, v) = san_value(&[135, 4, 1, 1, 1, 1])
let (rem, v) = parse_der(&[135, 4, 1, 1, 1, 1])
.expect("Failed to parse san value");
let v = v.expect("Extension contains invalid data");
assert!(rem.is_empty());
println!("{:?}", v);
assert_eq!(v, DerObject {
class: 2,
structured: 0,
tag: 7,
content: DerObjectContent::Unknown(&[1, 1, 1, 1])
});
let content = match v.content {
DerObjectContent::Unknown(v) => v,
_ => panic!("Wrong DerObjectContent"),
};
let v = san_value_ipaddr(content)
.expect("Failed to process san value");
assert_eq!(v, AlternativeName::IpAddr("1.1.1.1".parse().unwrap()));
}
}

115
src/db.rs
View File

@@ -1,17 +1,17 @@
use errors::*;
use crate::errors::*;
use diesel;
use diesel::expression::SqlLiteral;
use diesel::expression::sql_literal::sql;
use diesel::sql_types::Bool;
use diesel::prelude::*;
use models::*;
use schema::*;
use crate::models::*;
use crate::schema::*;
use std::str::FromStr;
use paths;
use migrations;
use worker;
use workspaces::Workspace;
use crate::paths;
use crate::migrations;
use crate::worker;
use crate::workspaces::Workspace;
#[derive(Debug)]
@@ -38,6 +38,10 @@ pub enum Family {
SubdomainIpAddr,
Url,
Email,
PhoneNumber,
Device,
Network,
NetworkDevice,
}
impl FromStr for Family {
@@ -51,6 +55,10 @@ impl FromStr for Family {
"subdomain-ipaddr" => Family::SubdomainIpAddr,
"url" => Family::Url,
"email" => Family::Email,
"phonenumber" => Family::PhoneNumber,
"device" => Family::Device,
"network" => Family::Network,
"network-device" => Family::NetworkDevice,
_ => bail!("Unknown object family"),
})
}
@@ -114,6 +122,8 @@ impl Database {
latitude: object.latitude,
asn: object.asn,
as_org: object.as_org.as_ref(),
description: object.description.as_ref(),
reverse_dns: object.reverse_dns.as_ref(),
}),
Insert::SubdomainIpAddr(object) => self.insert_subdomain_ipaddr_struct(&NewSubdomainIpAddr {
subdomain_id: object.subdomain_id,
@@ -133,6 +143,37 @@ impl Database {
value: &object.value,
valid: object.valid,
}),
Insert::PhoneNumber(object) => self.insert_struct(NewPhoneNumber {
value: &object.value,
name: object.name.as_ref(),
valid: object.valid,
last_online: object.last_online,
country: object.country.as_ref(),
carrier: object.carrier.as_ref(),
line: object.line.as_ref(),
is_ported: object.is_ported,
last_ported: object.last_ported,
caller_name: object.caller_name.as_ref(),
caller_type: object.caller_type.as_ref(),
}),
Insert::Device(object) => self.insert_struct(NewDevice {
value: &object.value,
name: object.name.as_ref(),
hostname: object.hostname.as_ref(),
vendor: object.vendor.as_ref(),
last_seen: object.last_seen,
}),
Insert::Network(object) => self.insert_struct(NewNetwork {
value: &object.value,
latitude: object.latitude,
longitude: object.longitude,
}),
Insert::NetworkDevice(object) => self.insert_network_device_struct(&NewNetworkDevice {
network_id: object.network_id,
device_id: object.device_id,
ipaddr: object.ipaddr.as_ref(),
last_seen: object.last_seen,
}),
}
}
@@ -170,6 +211,18 @@ impl Database {
}
}
pub fn insert_network_device_struct(&self, network_device: &NewNetworkDevice) -> Result<Option<(DbChange, i32)>> {
if let Some(subdomain_ipaddr_id) = NetworkDevice::get_id_opt(self, &(network_device.network_id, network_device.device_id))? {
Ok(Some((DbChange::None, subdomain_ipaddr_id)))
} else {
diesel::insert_into(network_devices::table)
.values(network_device)
.execute(&self.db)?;
let id = NetworkDevice::get_id(self, &(network_device.network_id, network_device.device_id))?;
Ok(Some((DbChange::Insert, id)))
}
}
//
pub fn update_generic(&self, object: &Update) -> Result<i32> {
@@ -178,11 +231,15 @@ impl Database {
Update::IpAddr(object) => self.update_ipaddr(object),
Update::Url(object) => self.update_url(object),
Update::Email(object) => self.update_email(object),
Update::PhoneNumber(object) => self.update_phonenumber(object),
Update::Device(object) => self.update_device(object),
Update::Network(object) => self.update_network(object),
Update::NetworkDevice(object) => self.update_network_device(object),
}
}
pub fn update_subdomain(&self, subdomain: &SubdomainUpdate) -> Result<i32> {
use schema::subdomains::columns::*;
use crate::schema::subdomains::columns::*;
diesel::update(subdomains::table.filter(id.eq(subdomain.id)))
.set(subdomain)
.execute(&self.db)?;
@@ -190,7 +247,7 @@ impl Database {
}
pub fn update_ipaddr(&self, ipaddr: &IpAddrUpdate) -> Result<i32> {
use schema::ipaddrs::columns::*;
use crate::schema::ipaddrs::columns::*;
diesel::update(ipaddrs::table.filter(id.eq(ipaddr.id)))
.set(ipaddr)
.execute(&self.db)?;
@@ -198,7 +255,7 @@ impl Database {
}
pub fn update_url(&self, url: &UrlUpdate) -> Result<i32> {
use schema::urls::columns::*;
use crate::schema::urls::columns::*;
diesel::update(urls::table.filter(id.eq(url.id)))
.set(url)
.execute(&self.db)?;
@@ -206,13 +263,45 @@ impl Database {
}
pub fn update_email(&self, email: &EmailUpdate) -> Result<i32> {
use schema::emails::columns::*;
use crate::schema::emails::columns::*;
diesel::update(emails::table.filter(id.eq(email.id)))
.set(email)
.execute(&self.db)?;
Ok(email.id)
}
pub fn update_phonenumber(&self, phonenumber: &PhoneNumberUpdate) -> Result<i32> {
use crate::schema::phonenumbers::columns::*;
diesel::update(phonenumbers::table.filter(id.eq(phonenumber.id)))
.set(phonenumber)
.execute(&self.db)?;
Ok(phonenumber.id)
}
pub fn update_device(&self, device: &DeviceUpdate) -> Result<i32> {
use crate::schema::devices::columns::*;
diesel::update(devices::table.filter(id.eq(device.id)))
.set(device)
.execute(&self.db)?;
Ok(device.id)
}
pub fn update_network(&self, network: &NetworkUpdate) -> Result<i32> {
use crate::schema::networks::columns::*;
diesel::update(networks::table.filter(id.eq(network.id)))
.set(network)
.execute(&self.db)?;
Ok(network.id)
}
pub fn update_network_device(&self, network_device: &NetworkDeviceUpdate) -> Result<i32> {
use crate::schema::network_devices::columns::*;
diesel::update(network_devices::table.filter(id.eq(network_device.id)))
.set(network_device)
.execute(&self.db)?;
Ok(network_device.id)
}
fn get_opt_typed<T: Model + Scopable>(&self, value: &T::ID) -> Result<Option<i32>> {
match T::get_opt(self, &value)? {
Some(ref obj) if obj.scoped() => Ok(Some(obj.id())),
@@ -228,6 +317,10 @@ impl Database {
Family::SubdomainIpAddr => bail!("Unsupported operation"),
Family::Url => self.get_opt_typed::<Url>(&value),
Family::Email => self.get_opt_typed::<Email>(&value),
Family::PhoneNumber => self.get_opt_typed::<PhoneNumber>(&value),
Family::Device => self.get_opt_typed::<Device>(&value),
Family::Network => self.get_opt_typed::<Network>(&value),
Family::NetworkDevice => bail!("Unsupported operation"),
}
}

View File

@@ -1,19 +1,21 @@
use errors::*;
use crate::errors::*;
use db::Family;
use engine::{Environment, Reporter};
use geoip::{GeoIP, AsnDB};
use hlua::{self, AnyLuaValue};
use models::{Insert, Update};
use psl::Psl;
use runtime;
use crate::db::Family;
use crate::engine::{Environment, Reporter};
use crate::geoip::{GeoIP, AsnDB};
use crate::hlua::{self, AnyLuaValue};
use crate::keyring::KeyRingEntry;
use crate::models::{Insert, Update};
use crate::psl::Psl;
use crate::runtime;
use chrootable_https::{self, Resolver};
use serde_json;
use std::collections::HashMap;
use std::result;
use std::net::SocketAddr;
use std::sync::{Arc, Mutex};
use chrootable_https::dns::Resolver;
use web::{HttpSession, HttpRequest, RequestOptions};
use worker::{Event, LogEvent, DatabaseEvent, StdioEvent};
use crate::web::{HttpSession, HttpRequest, RequestOptions};
use crate::worker::{Event, LogEvent, DatabaseEvent, StdioEvent};
pub trait State {
@@ -23,8 +25,6 @@ pub trait State {
fn set_error(&self, err: Error) -> Error;
fn set_logger(&self, tx: Arc<Mutex<Box<Reporter>>>);
fn send(&self, msg: &Event);
fn recv(&self) -> Result<serde_json::Value>;
@@ -80,13 +80,21 @@ pub trait State {
reply.map_err(|err| format_err!("Failed to read stdin: {:?}", err))
}
fn dns_config(&self) -> Arc<Resolver>;
fn keyring(&self, namespace: &str) -> Vec<&KeyRingEntry>;
fn psl(&self) -> Arc<Psl>;
fn dns_config(&self) -> &Resolver;
fn geoip(&self) -> Arc<GeoIP>;
fn proxy(&self) -> Option<&SocketAddr>;
fn asn(&self) -> Arc<AsnDB>;
fn getopt(&self, key: &str) -> Option<&String>;
fn psl(&self) -> &Psl;
fn geoip(&self) -> &GeoIP;
fn asn(&self) -> &AsnDB;
fn http(&self) -> &chrootable_https::Client<Resolver>;
fn http_mksession(&self) -> String;
@@ -95,16 +103,20 @@ pub trait State {
fn register_in_jar(&self, session: &str, key: String, value: String);
}
#[derive(Debug, Clone)]
#[derive(Debug)]
pub struct LuaState {
error: Arc<Mutex<Option<Error>>>,
logger: Arc<Mutex<Option<Arc<Mutex<Box<Reporter>>>>>>,
http_sessions: Arc<Mutex<HashMap<String, HttpSession>>>,
error: Mutex<Option<Error>>,
logger: Arc<Mutex<Box<Reporter>>>,
http_sessions: Mutex<HashMap<String, HttpSession>>,
http: chrootable_https::Client<Resolver>,
verbose: u64,
dns_config: Arc<Resolver>,
psl: Arc<Psl>,
geoip: Arc<GeoIP>,
asn: Arc<AsnDB>,
keyring: Vec<KeyRingEntry>, // TODO: maybe hashmap
dns_config: Resolver,
psl: Psl,
geoip: GeoIP,
asn: AsnDB,
proxy: Option<SocketAddr>,
options: HashMap<String, String>,
}
impl State for LuaState {
@@ -125,47 +137,52 @@ impl State for LuaState {
cp
}
fn set_logger(&self, tx: Arc<Mutex<Box<Reporter>>>) {
let mut mtx = self.logger.lock().unwrap();
*mtx = Some(tx);
}
fn send(&self, msg: &Event) {
let mtx = self.logger.lock().unwrap();
if let Some(mtx) = &*mtx {
let mut tx = mtx.lock().unwrap();
tx.send(msg).expect("Failed to write event");
}
let mut tx = self.logger.lock().unwrap();
tx.send(msg).expect("Failed to write event");
}
fn recv(&self) -> Result<serde_json::Value> {
let mtx = self.logger.lock().unwrap();
if let Some(mtx) = &*mtx {
let mut tx = mtx.lock().unwrap();
tx.recv()
} else {
bail!("Failed to read from reporter, non available");
}
let mut tx = self.logger.lock().unwrap();
tx.recv()
}
fn verbose(&self) -> u64 {
self.verbose
}
fn dns_config(&self) -> Arc<Resolver> {
self.dns_config.clone()
fn keyring(&self, namespace: &str) -> Vec<&KeyRingEntry> {
self.keyring.iter()
.filter(|x| x.namespace == namespace)
.collect()
}
fn psl(&self) -> Arc<Psl> {
self.psl.clone()
fn dns_config(&self) -> &Resolver {
&self.dns_config
}
fn geoip(&self) -> Arc<GeoIP> {
self.geoip.clone()
fn proxy(&self) -> Option<&SocketAddr> {
self.proxy.as_ref()
}
fn asn(&self) -> Arc<AsnDB> {
self.asn.clone()
fn getopt(&self, key: &str) -> Option<&String> {
self.options.get(key)
}
fn psl(&self) -> &Psl {
&self.psl
}
fn geoip(&self) -> &GeoIP {
&self.geoip
}
fn asn(&self) -> &AsnDB {
&self.asn
}
fn http(&self) -> &chrootable_https::Client<Resolver> {
&self.http
}
fn http_mksession(&self) -> String {
@@ -195,20 +212,33 @@ pub struct Script {
code: String,
}
fn ctx<'a>(env: Environment) -> (hlua::Lua<'a>, Arc<LuaState>) {
fn ctx<'a>(env: Environment, logger: Arc<Mutex<Box<Reporter>>>) -> (hlua::Lua<'a>, Arc<LuaState>) {
debug!("Creating lua context");
let mut lua = hlua::Lua::new();
lua.open_string();
let http = match env.proxy {
Some(proxy) => chrootable_https::Client::with_socks5(proxy),
_ => {
let resolver = env.dns_config.clone();
chrootable_https::Client::new(resolver)
},
};
let state = Arc::new(LuaState {
error: Arc::new(Mutex::new(None)),
logger: Arc::new(Mutex::new(None)),
http_sessions: Arc::new(Mutex::new(HashMap::new())),
error: Mutex::new(None),
logger,
http_sessions: Mutex::new(HashMap::new()),
http,
verbose: env.verbose,
dns_config: Arc::new(env.dns_config),
psl: Arc::new(env.psl),
geoip: Arc::new(env.geoip),
asn: Arc::new(env.asn),
keyring: env.keyring,
dns_config: env.dns_config,
psl: env.psl,
geoip: env.geoip,
asn: env.asn,
proxy: env.proxy,
options: env.options,
});
runtime::clear_err(&mut lua, state.clone());
@@ -220,6 +250,7 @@ fn ctx<'a>(env: Environment) -> (hlua::Lua<'a>, Arc<LuaState>) {
runtime::error(&mut lua, state.clone());
runtime::asn_lookup(&mut lua, state.clone());
runtime::geoip_lookup(&mut lua, state.clone());
runtime::getopt(&mut lua, state.clone());
runtime::html_select(&mut lua, state.clone());
runtime::html_select_list(&mut lua, state.clone());
runtime::http_mksession(&mut lua, state.clone());
@@ -229,6 +260,7 @@ fn ctx<'a>(env: Environment) -> (hlua::Lua<'a>, Arc<LuaState>) {
runtime::json_decode(&mut lua, state.clone());
runtime::json_decode_stream(&mut lua, state.clone());
runtime::json_encode(&mut lua, state.clone());
runtime::keyring(&mut lua, state.clone());
runtime::last_err(&mut lua, state.clone());
runtime::pgp_pubkey(&mut lua, state.clone());
runtime::pgp_pubkey_armored(&mut lua, state.clone());
@@ -239,8 +271,12 @@ fn ctx<'a>(env: Environment) -> (hlua::Lua<'a>, Arc<LuaState>) {
runtime::sleep(&mut lua, state.clone());
runtime::status(&mut lua, state.clone());
runtime::stdin_readline(&mut lua, state.clone());
runtime::url_decode(&mut lua, state.clone());
runtime::url_encode(&mut lua, state.clone());
runtime::url_escape(&mut lua, state.clone());
runtime::url_join(&mut lua, state.clone());
runtime::url_parse(&mut lua, state.clone());
runtime::url_unescape(&mut lua, state.clone());
runtime::utf8_decode(&mut lua, state.clone());
runtime::x509_parse_pem(&mut lua, state.clone());
@@ -273,13 +309,11 @@ impl Script {
tx: Arc<Mutex<Box<Reporter>>>,
arg: AnyLuaValue
) -> Result<()> {
let (mut lua, state) = ctx(env);
let (mut lua, state) = ctx(env, tx);
debug!("Initializing lua module");
lua.execute::<()>(&self.code)?;
state.set_logger(tx);
let run: Result<_> = lua.get("run")
.ok_or_else(|| format_err!( "run undefined"));
let mut run: hlua::LuaFunction<_> = run?;
@@ -294,7 +328,7 @@ impl Script {
return Err(err);
}
use hlua::AnyLuaValue::*;
use crate::hlua::AnyLuaValue::*;
match result {
LuaString(x) => bail!("Script returned error: {:?}", x),
_ => Ok(())
@@ -303,20 +337,25 @@ impl Script {
#[cfg(test)]
pub fn test(&self) -> Result<()> {
use engine::tests::DummyReporter;
use geoip::Maxmind;
use crate::engine::tests::DummyReporter;
use crate::geoip::Maxmind;
let keyring = Vec::new();
let dns_config = Resolver::from_system()?;
let psl = Psl::from_str(r#"
let proxy = None;
let psl = r#"
// ===BEGIN ICANN DOMAINS===
com
// ===END ICANN DOMAINS===
"#)?;
"#.parse::<Psl>()?;
let geoip = GeoIP::open_or_download()?;
let asn = AsnDB::open_or_download()?;
let env = Environment {
verbose: 0,
keyring,
dns_config,
proxy,
options: HashMap::new(),
psl,
geoip,
asn,

Some files were not shown because too many files have changed in this diff Show More