You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

1684 lines
52 KiB

  1. #!/bin/sh
  2. # dns based ad/abuse domain blocking
  3. # Copyright (c) 2015-2020 Dirk Brenken (dev@brenken.org)
  4. # This is free software, licensed under the GNU General Public License v3.
  5. # set (s)hellcheck exceptions
  6. # shellcheck disable=1091,2010,2016,2034,2039,2059,2086,2091,2129,2143,2154,2181,2183,2188
  7. # set initial defaults
  8. #
  9. export LC_ALL=C
  10. export PATH="/usr/sbin:/usr/bin:/sbin:/bin"
  11. set -o pipefail
  12. adb_ver="4.0.7"
  13. adb_enabled=0
  14. adb_debug=0
  15. adb_forcedns=0
  16. adb_maxqueue=4
  17. adb_dnsfilereset=0
  18. adb_dnsflush=0
  19. adb_dnstimeout=20
  20. adb_safesearch=0
  21. adb_safesearchlist=""
  22. adb_safesearchmod=0
  23. adb_report=0
  24. adb_trigger=""
  25. adb_triggerdelay=0
  26. adb_backup=1
  27. adb_mail=0
  28. adb_mailcnt=0
  29. adb_jail=0
  30. adb_dns=""
  31. adb_dnsprefix="adb_list"
  32. adb_locallist="blacklist whitelist"
  33. adb_tmpbase="/tmp"
  34. adb_backupdir="/tmp"
  35. adb_reportdir="/tmp"
  36. adb_jaildir="/tmp"
  37. adb_pidfile="/var/run/adblock.pid"
  38. adb_blacklist="/etc/adblock/adblock.blacklist"
  39. adb_whitelist="/etc/adblock/adblock.whitelist"
  40. adb_ubusservice="/etc/adblock/adblock.monitor"
  41. adb_mailservice="/etc/adblock/adblock.mail"
  42. adb_dnsfile="${adb_dnsprefix}.overall"
  43. adb_dnsjail="${adb_dnsprefix}.jail"
  44. adb_srcarc="/etc/adblock/adblock.sources.gz"
  45. adb_srcfile="${adb_tmpbase}/adb_sources.json"
  46. adb_rtfile="${adb_tmpbase}/adb_runtime.json"
  47. adb_loggercmd="$(command -v logger)"
  48. adb_dumpcmd="$(command -v tcpdump)"
  49. adb_lookupcmd="$(command -v nslookup)"
  50. adb_fetchutil=""
  51. adb_portlist="53 853 5353"
  52. adb_repiface=""
  53. adb_replisten="53"
  54. adb_repchunkcnt="5"
  55. adb_repchunksize="1"
  56. adb_lookupdomain="example.com"
  57. adb_action="${1:-"start"}"
  58. adb_packages=""
  59. adb_sources=""
  60. adb_cnt=""
  61. # load & check adblock environment
  62. #
  63. f_load()
  64. {
  65. adb_sysver="$(ubus -S call system board 2>/dev/null | jsonfilter -e '@.model' -e '@.release.description' | \
  66. "${adb_awk}" 'BEGIN{ORS=", "}{print $0}' | "${adb_awk}" '{print substr($0,1,length($0)-2)}')"
  67. f_conf
  68. if [ "${adb_action}" != "report" ]
  69. then
  70. f_dns
  71. f_fetch
  72. fi
  73. if [ "${adb_enabled}" -eq 0 ]
  74. then
  75. f_extconf
  76. f_temp
  77. f_rmdns
  78. f_bgserv "stop"
  79. f_jsnup "disabled"
  80. f_log "info" "adblock is currently disabled, please set the config option 'adb_enabled' to '1' to use this service"
  81. exit 0
  82. fi
  83. }
  84. # check & set environment
  85. #
  86. f_env()
  87. {
  88. adb_starttime="$(date "+%s")"
  89. f_log "info" "adblock instance started ::: action: ${adb_action}, priority: ${adb_nice:-"0"}, pid: ${$}"
  90. f_jsnup "running"
  91. f_extconf
  92. f_temp
  93. if [ "${adb_dnsflush}" -eq 1 ]
  94. then
  95. printf "${adb_dnsheader}" > "${adb_dnsdir}/${adb_dnsfile}"
  96. f_dnsup
  97. fi
  98. if [ ! -r "${adb_srcfile}" ]
  99. then
  100. if [ -r "${adb_srcarc}" ]
  101. then
  102. zcat "${adb_srcarc}" > "${adb_srcfile}"
  103. else
  104. f_log "err" "adblock source archive not found"
  105. fi
  106. fi
  107. if [ -r "${adb_srcfile}" ]
  108. then
  109. json_load_file "${adb_srcfile}"
  110. else
  111. f_log "err" "adblock source file not found"
  112. fi
  113. }
  114. # load adblock config
  115. #
  116. f_conf()
  117. {
  118. local cnt=0 cnt_max=10
  119. if [ ! -r "/etc/config/adblock" ] || [ -z "$(uci -q show adblock.global.adb_safesearch)" ]
  120. then
  121. f_log "err" "no valid adblock config found, please re-install the package via opkg with the '--force-reinstall --force-maintainer' options"
  122. fi
  123. config_cb()
  124. {
  125. option_cb()
  126. {
  127. local option="${1}"
  128. local value="${2}"
  129. eval "${option}=\"${value}\""
  130. }
  131. list_cb()
  132. {
  133. local option="${1}"
  134. local value="${2}"
  135. if [ "${option}" = "adb_sources" ]
  136. then
  137. eval "${option}=\"$(printf "%s" "${adb_sources}") ${value}\""
  138. elif [ "${option}" = "adb_safesearchlist" ]
  139. then
  140. eval "${option}=\"$(printf "%s" "${adb_safesearchlist}") ${value}\""
  141. fi
  142. }
  143. }
  144. config_load adblock
  145. if [ -z "${adb_fetchutil}" ] || [ -z "${adb_dns}" ]
  146. then
  147. while [ -z "${adb_packages}" ] && [ "${cnt}" -le "${cnt_max}" ]
  148. do
  149. adb_packages="$(opkg list-installed 2>/dev/null)"
  150. cnt=$((cnt+1))
  151. sleep 1
  152. done
  153. if [ -z "${adb_packages}" ]
  154. then
  155. f_log "err" "local opkg package repository is not available, please set 'adb_fetchutil' and 'adb_dns' manually"
  156. fi
  157. fi
  158. }
  159. # load dns backend config
  160. #
  161. f_dns()
  162. {
  163. local util utils dns_up cnt=0
  164. if [ -z "${adb_dns}" ]
  165. then
  166. utils="knot-resolver named unbound dnsmasq raw"
  167. for util in ${utils}
  168. do
  169. if [ "${util}" = "raw" ] || [ -n "$(printf "%s" "${adb_packages}" | grep "^${util}")" ]
  170. then
  171. if [ "${util}" = "knot-resolver" ]
  172. then
  173. util="kresd"
  174. fi
  175. if [ "${util}" = "raw" ] || [ -x "$(command -v "${util}")" ]
  176. then
  177. adb_dns="${util}"
  178. uci_set adblock global adb_dns "${util}"
  179. f_uci "adblock"
  180. break
  181. fi
  182. fi
  183. done
  184. elif [ "${adb_dns}" != "raw" ] && [ ! -x "$(command -v "${adb_dns}")" ]
  185. then
  186. unset adb_dns
  187. fi
  188. if [ -n "${adb_dns}" ]
  189. then
  190. case "${adb_dns}" in
  191. "dnsmasq")
  192. adb_dnsinotify="${adb_dnsinotify:-"0"}"
  193. adb_dnsinstance="${adb_dnsinstance:-"0"}"
  194. adb_dnsuser="${adb_dnsuser:-"dnsmasq"}"
  195. adb_dnsdir="${adb_dnsdir:-"/tmp/dnsmasq.d"}"
  196. adb_dnsheader="${adb_dnsheader}"
  197. adb_dnsdeny="${adb_dnsdeny:-"${adb_awk} '{print \"address=/\"\$0\"/\"}'"}"
  198. adb_dnsallow="${adb_dnsallow:-"${adb_awk} '{print \"local=/\"\$0\"/#\"}'"}"
  199. adb_dnssafesearch="${adb_dnssafesearch:-"${adb_awk} -v item=\"\$item\" '{print \"address=/\"\$0\"/\"item\"\"}'"}"
  200. adb_dnsstop="${adb_dnsstop:-"address=/#/"}"
  201. ;;
  202. "unbound")
  203. adb_dnsinotify="${adb_dnsinotify:-"0"}"
  204. adb_dnsinstance="${adb_dnsinstance:-"0"}"
  205. adb_dnsuser="${adb_dnsuser:-"unbound"}"
  206. adb_dnsdir="${adb_dnsdir:-"/var/lib/unbound"}"
  207. adb_dnsheader="${adb_dnsheader}"
  208. adb_dnsdeny="${adb_dnsdeny:-"${adb_awk} '{print \"local-zone: \\042\"\$0\"\\042 static\"}'"}"
  209. adb_dnsallow="${adb_dnsallow:-"${adb_awk} '{print \"local-zone: \\042\"\$0\"\\042 transparent\"}'"}"
  210. adb_dnssafesearch="${adb_dnssafesearch:-"${adb_awk} -v item=\"\$item\" '{type=\"AAAA\";if(match(item,/^([0-9]{1,3}\.){3}[0-9]{1,3}$/)){type=\"A\"}}{print \"local-data: \\042\"\$0\" \"type\" \"item\"\\042\"}'"}"
  211. adb_dnsstop="${adb_dnsstop:-"local-zone: \".\" static"}"
  212. ;;
  213. "named")
  214. adb_dnsinotify="${adb_dnsinotify:-"0"}"
  215. adb_dnsinstance="${adb_dnsinstance:-"0"}"
  216. adb_dnsuser="${adb_dnsuser:-"bind"}"
  217. adb_dnsdir="${adb_dnsdir:-"/var/lib/bind"}"
  218. adb_dnsheader="${adb_dnsheader:-"\$TTL 2h\n@ IN SOA localhost. root.localhost. (1 6h 1h 1w 2h)\n IN NS localhost.\n"}"
  219. adb_dnsdeny="${adb_dnsdeny:-"${adb_awk} '{print \"\"\$0\" CNAME .\\n*.\"\$0\" CNAME .\"}'"}"
  220. adb_dnsallow="${adb_dnsallow:-"${adb_awk} '{print \"\"\$0\" CNAME rpz-passthru.\\n*.\"\$0\" CNAME rpz-passthru.\"}'"}"
  221. adb_dnssafesearch="${adb_dnssafesearch:-"${adb_awk} -v item=\"\$item\" '{print \"\"\$0\" CNAME \"item\".\\n*.\"\$0\" CNAME \"item\".\"}'"}"
  222. adb_dnsstop="${adb_dnsstop:-"* CNAME ."}"
  223. ;;
  224. "kresd")
  225. adb_dnsinotify="${adb_dnsinotify:-"0"}"
  226. adb_dnsinstance="${adb_dnsinstance:-"0"}"
  227. adb_dnsuser="${adb_dnsuser:-"root"}"
  228. adb_dnsdir="${adb_dnsdir:-"/etc/kresd"}"
  229. adb_dnsheader="${adb_dnsheader:-"\$TTL 2h\n@ IN SOA localhost. root.localhost. (1 6h 1h 1w 2h)\n"}"
  230. adb_dnsdeny="${adb_dnsdeny:-"${adb_awk} '{print \"\"\$0\" CNAME .\\n*.\"\$0\" CNAME .\"}'"}"
  231. adb_dnsallow="${adb_dnsallow:-"${adb_awk} '{print \"\"\$0\" CNAME rpz-passthru.\\n*.\"\$0\" CNAME rpz-passthru.\"}'"}"
  232. adb_dnssafesearch="${adb_dnssafesearch:-"${adb_awk} -v item=\"\$item\" '{type=\"AAAA\";if(match(item,/^([0-9]{1,3}\.){3}[0-9]{1,3}$/)){type=\"A\"}}{print \"\"\$0\" \"type\" \"item\"\"}'"}"
  233. adb_dnsstop="${adb_dnsstop:-"* CNAME ."}"
  234. ;;
  235. "raw")
  236. adb_dnsinotify="${adb_dnsinotify:-"0"}"
  237. adb_dnsinstance="${adb_dnsinstance:-"0"}"
  238. adb_dnsuser="${adb_dnsuser:-"root"}"
  239. adb_dnsdir="${adb_dnsdir:-"/tmp"}"
  240. adb_dnsheader="${adb_dnsheader}"
  241. adb_dnsdeny="${adb_dnsdeny:-"0"}"
  242. adb_dnsallow="${adb_dnsallow:-"1"}"
  243. adb_dnssafesearch="${adb_dnssafesearch:-"0"}"
  244. adb_dnsstop="${adb_dnsstop:-"0"}"
  245. ;;
  246. esac
  247. fi
  248. if [ "${adb_dns}" != "raw" ] && { [ -z "${adb_dns}" ] || [ ! -x "$(command -v "${adb_dns}")" ]; }
  249. then
  250. f_log "err" "dns backend not found, please set 'adb_dns' manually"
  251. fi
  252. if [ "${adb_dns}" != "raw" ] && { [ "${adb_dnsdir}" = "${adb_tmpbase}" ] || [ "${adb_dnsdir}" = "${adb_backupdir}" ] || \
  253. [ "${adb_dnsdir}" = "${adb_reportdir}" ] || [ "${adb_dnsdir}" = "${adb_jaildir}" ]; }
  254. then
  255. f_log "err" "dns directory '${adb_dnsdir}' has been misconfigured, it must not point to the 'adb_tmpbase', 'adb_backupdir', 'adb_reportdir' or 'adb_jaildir'"
  256. fi
  257. if [ "${adb_action}" = "start" ] && [ -z "${adb_trigger}" ]
  258. then
  259. sleep ${adb_triggerdelay}
  260. fi
  261. if [ "${adb_dns}" != "raw" ] && [ "${adb_action}" != "stop" ]
  262. then
  263. while [ "${cnt}" -le 30 ]
  264. do
  265. dns_up="$(ubus -S call service list "{\"name\":\"${adb_dns}\"}" 2>/dev/null | jsonfilter -l1 -e "@[\"${adb_dns}\"].instances.*.running" 2>/dev/null)"
  266. if [ "${dns_up}" = "true" ]
  267. then
  268. break
  269. fi
  270. sleep 1
  271. cnt=$((cnt+1))
  272. done
  273. if [ -n "${adb_dnsdir}" ] && [ ! -d "${adb_dnsdir}" ]
  274. then
  275. mkdir -p "${adb_dnsdir}"
  276. if [ "${?}" -eq 0 ]
  277. then
  278. f_log "info" "dns backend directory '${adb_dnsdir}' created"
  279. else
  280. f_log "err" "dns backend directory '${adb_dnsdir}' could not be created"
  281. fi
  282. fi
  283. if [ ! -f "${adb_dnsdir}/${adb_dnsfile}" ]
  284. then
  285. printf "${adb_dnsheader}" > "${adb_dnsdir}/${adb_dnsfile}"
  286. fi
  287. if [ "${dns_up}" != "true" ]
  288. then
  289. f_dnsup 4
  290. if [ "${?}" -ne 0 ]
  291. then
  292. f_log "err" "dns backend '${adb_dns}' not running or executable"
  293. fi
  294. fi
  295. if [ "${adb_backup}" -eq 1 ] && [ -n "${adb_backupdir}" ] && [ ! -d "${adb_backupdir}" ]
  296. then
  297. mkdir -p "${adb_backupdir}"
  298. if [ "${?}" -eq 0 ]
  299. then
  300. f_log "info" "backup directory '${adb_backupdir}' created"
  301. else
  302. f_log "err" "backup backend directory '${adb_backupdir}' could not be created"
  303. fi
  304. fi
  305. if [ -n "${adb_jaildir}" ] && [ ! -d "${adb_jaildir}" ]
  306. then
  307. mkdir -p "${adb_jaildir}"
  308. if [ "${?}" -eq 0 ]
  309. then
  310. f_log "info" "jail directory '${adb_jaildir}' created"
  311. else
  312. f_log "err" "jail directory '${adb_jaildir}' could not be created"
  313. fi
  314. fi
  315. fi
  316. f_log "debug" "f_dns ::: dns: ${adb_dns}, dns_dir: ${adb_dnsdir}, dns_file: ${adb_dnsfile}, dns_user: ${adb_dnsuser}, dns_inotify: ${adb_dnsinotify}, dns_instance: ${adb_dnsinstance}, backup: ${adb_backup}, backup_dir: ${adb_backupdir}, jail_dir: ${adb_jaildir}"
  317. }
  318. # load fetch utility
  319. #
  320. f_fetch()
  321. {
  322. local util utils cnt=0
  323. if [ -z "${adb_fetchutil}" ]
  324. then
  325. utils="aria2c curl wget uclient-fetch"
  326. for util in ${utils}
  327. do
  328. if { [ "${util}" = "uclient-fetch" ] && [ -n "$(printf "%s" "${adb_packages}" | grep "^libustream-")" ]; } || \
  329. { [ "${util}" = "wget" ] && [ -n "$(printf "%s" "${adb_packages}" | grep "^wget -")" ]; } || \
  330. [ "${util}" = "curl" ] || [ "${util}" = "aria2c" ]
  331. then
  332. if [ -x "$(command -v "${util}")" ]
  333. then
  334. adb_fetchutil="${util}"
  335. uci_set adblock global adb_fetchutil "${util}"
  336. f_uci "adblock"
  337. break
  338. fi
  339. fi
  340. done
  341. elif [ ! -x "$(command -v "${adb_fetchutil}")" ]
  342. then
  343. unset adb_fetchutil
  344. fi
  345. case "${adb_fetchutil}" in
  346. "aria2c")
  347. adb_fetchparm="${adb_fetchparm:-"--timeout=20 --allow-overwrite=true --auto-file-renaming=false --check-certificate=true --log-level=warn --dir=/ -o"}"
  348. ;;
  349. "curl")
  350. adb_fetchparm="${adb_fetchparm:-"--connect-timeout 20 --silent --show-error --location -o"}"
  351. ;;
  352. "uclient-fetch")
  353. adb_fetchparm="${adb_fetchparm:-"--timeout=20 -O"}"
  354. ;;
  355. "wget")
  356. adb_fetchparm="${adb_fetchparm:-"--no-cache --no-cookies --max-redirect=0 --timeout=20 -O"}"
  357. ;;
  358. esac
  359. if [ -n "${adb_fetchutil}" ] && [ -n "${adb_fetchparm}" ]
  360. then
  361. adb_fetchutil="$(command -v "${adb_fetchutil}")"
  362. else
  363. f_log "err" "download utility with SSL support not found, please install 'uclient-fetch' with a 'libustream-*' variant or another download utility like 'wget', 'curl' or 'aria2'"
  364. fi
  365. f_log "debug" "f_fetch ::: fetch_util: ${adb_fetchutil:-"-"}, fetch_parm: ${adb_fetchparm:-"-"}"
  366. }
  367. # create temporary files, directories and set dependent options
  368. #
  369. f_temp()
  370. {
  371. local cpu core cores
  372. cpu="$(grep -c '^processor' /proc/cpuinfo 2>/dev/null)"
  373. core="$(grep -cm1 '^core id' /proc/cpuinfo 2>/dev/null)"
  374. if [ "${cpu}" -eq 0 ]
  375. then
  376. cpu=1
  377. fi
  378. if [ "${core}" -eq 0 ]
  379. then
  380. core=1
  381. fi
  382. cores=$((cpu*core))
  383. if [ -d "${adb_tmpbase}" ]
  384. then
  385. adb_tmpdir="$(mktemp -p "${adb_tmpbase}" -d)"
  386. adb_tmpload="$(mktemp -p "${adb_tmpdir}" -tu)"
  387. adb_tmpfile="$(mktemp -p "${adb_tmpdir}" -tu)"
  388. adb_srtopts="--temporary-directory=${adb_tmpdir} --compress-program=gzip --batch-size=32 --parallel=${cores}"
  389. else
  390. f_log "err" "the temp base directory '${adb_tmpbase}' does not exist/is not mounted yet, please create the directory or raise the 'adb_triggerdelay' to defer the adblock start"
  391. fi
  392. if [ ! -s "${adb_pidfile}" ]
  393. then
  394. printf "%s" "${$}" > "${adb_pidfile}"
  395. fi
  396. f_log "debug" "f_temp ::: tmp_base: ${adb_tmpbase:-"-"}, tmp_dir: ${adb_tmpdir:-"-"}, cores: ${cores:-"-"}, sort_options: ${adb_srtopts}, pid_file: ${adb_pidfile:-"-"}"
  397. }
  398. # remove temporary files and directories
  399. #
  400. f_rmtemp()
  401. {
  402. if [ -d "${adb_tmpdir}" ]
  403. then
  404. rm -rf "${adb_tmpdir}"
  405. fi
  406. rm -f "${adb_srcfile}"
  407. > "${adb_pidfile}"
  408. f_log "debug" "f_rmtemp ::: tmp_dir: ${adb_tmpdir:-"-"}, src_file: ${adb_srcfile:-"-"}, pid_file: ${adb_pidfile:-"-"}"
  409. }
  410. # remove dns related files
  411. #
  412. f_rmdns()
  413. {
  414. local status
  415. status="$(ubus -S call service list '{"name":"adblock"}' 2>/dev/null | jsonfilter -l1 -e '@["adblock"].instances.*.running' 2>/dev/null)"
  416. if [ "${adb_dns}" = "raw" ] || { [ -n "${adb_dns}" ] && [ -n "${status}" ]; }
  417. then
  418. > "${adb_rtfile}"
  419. if [ "${adb_backup}" -eq 1 ]
  420. then
  421. rm -f "${adb_backupdir}/${adb_dnsprefix}".*.gz
  422. fi
  423. printf "${adb_dnsheader}" > "${adb_dnsdir}/${adb_dnsfile}"
  424. f_dnsup 4
  425. fi
  426. f_rmtemp
  427. f_log "debug" "f_rmdns ::: dns: ${adb_dns}, status: ${status:-"-"}, dns_dir: ${adb_dnsdir}, dns_file: ${adb_dnsfile}, rt_file: ${adb_rtfile}, backup_dir: ${adb_backupdir:-"-"}"
  428. }
  429. # commit uci changes
  430. #
  431. f_uci()
  432. {
  433. local change config="${1}"
  434. if [ -n "${config}" ]
  435. then
  436. change="$(uci -q changes "${config}" | "${adb_awk}" '{ORS=" "; print $0}')"
  437. if [ -n "${change}" ]
  438. then
  439. uci_commit "${config}"
  440. case "${config}" in
  441. "firewall")
  442. "/etc/init.d/firewall" reload >/dev/null 2>&1
  443. ;;
  444. "resolver")
  445. printf "${adb_dnsheader}" > "${adb_dnsdir}/${adb_dnsfile}"
  446. f_count
  447. f_jsnup "running"
  448. "/etc/init.d/${adb_dns}" reload >/dev/null 2>&1
  449. ;;
  450. esac
  451. fi
  452. f_log "debug" "f_uci ::: config: ${config}, change: ${change}"
  453. fi
  454. }
  455. # get list counter
  456. #
  457. f_count()
  458. {
  459. local file mode="${1}" name="${2}"
  460. adb_cnt=0
  461. case "${mode}" in
  462. "blacklist")
  463. if [ -s "${adb_tmpfile}.${name}" ]
  464. then
  465. adb_cnt="$(wc -l 2>/dev/null < "${adb_tmpfile}.${name}")"
  466. fi
  467. ;;
  468. "whitelist")
  469. if [ -s "${adb_tmpdir}/tmp.raw.${name}" ]
  470. then
  471. adb_cnt="$(wc -l 2>/dev/null < "${adb_tmpdir}/tmp.raw.${name}")"
  472. rm -f "${adb_tmpdir}/tmp.raw.${name}"
  473. fi
  474. ;;
  475. "safesearch")
  476. if [ -s "${adb_tmpdir}/tmp.safesearch.${name}" ]
  477. then
  478. adb_cnt="$(wc -l 2>/dev/null < "${adb_tmpdir}/tmp.safesearch.${name}")"
  479. fi
  480. ;;
  481. "merge")
  482. if [ -s "${adb_tmpdir}/${adb_dnsfile}" ]
  483. then
  484. adb_cnt="$(wc -l 2>/dev/null < "${adb_tmpdir}/${adb_dnsfile}")"
  485. fi
  486. ;;
  487. "download"|"backup"|"restore")
  488. if [ -s "${src_tmpfile}" ]
  489. then
  490. adb_cnt="$(wc -l 2>/dev/null < "${src_tmpfile}")"
  491. fi
  492. ;;
  493. "final")
  494. if [ -s "${adb_dnsdir}/${adb_dnsfile}" ]
  495. then
  496. adb_cnt="$(wc -l 2>/dev/null < "${adb_dnsdir}/${adb_dnsfile}")"
  497. if [ -s "${adb_tmpdir}/tmp.add.whitelist" ]
  498. then
  499. adb_cnt=$((adb_cnt-$(wc -l 2>/dev/null < "${adb_tmpdir}/tmp.add.whitelist")))
  500. fi
  501. for file in "${adb_tmpdir}/tmp.safesearch".*
  502. do
  503. if [ -r "${file}" ]
  504. then
  505. adb_cnt=$((adb_cnt-$(wc -l 2>/dev/null < "${file}")))
  506. fi
  507. done
  508. if [ -n "${adb_dnsheader}" ]
  509. then
  510. adb_cnt=$(((adb_cnt-$(printf "${adb_dnsheader}" | grep -c "^"))/2))
  511. fi
  512. fi
  513. ;;
  514. esac
  515. }
  516. # set external config options
  517. #
  518. f_extconf()
  519. {
  520. local config config_dir config_file port fwcfg
  521. case "${adb_dns}" in
  522. "dnsmasq")
  523. config="dhcp"
  524. config_dir="$(uci_get dhcp "@dnsmasq[${adb_dnsinstance}]" confdir | grep -Fo "${adb_dnsdir}")"
  525. if [ "${adb_enabled}" -eq 1 ] && [ -z "${config_dir}" ]
  526. then
  527. uci_set dhcp "@dnsmasq[${adb_dnsinstance}]" confdir "${adb_dnsdir}" 2>/dev/null
  528. fi
  529. ;;
  530. "kresd")
  531. config="resolver"
  532. config_file="$(uci_get resolver kresd rpz_file | grep -Fo "${adb_dnsdir}/${adb_dnsfile}")"
  533. if [ "${adb_enabled}" -eq 1 ] && [ -z "${config_file}" ]
  534. then
  535. uci -q add_list resolver.kresd.rpz_file="${adb_dnsdir}/${adb_dnsfile}"
  536. elif [ "${adb_enabled}" -eq 0 ] && [ -n "${config_file}" ]
  537. then
  538. uci -q del_list resolver.kresd.rpz_file="${adb_dnsdir}/${adb_dnsfile}"
  539. fi
  540. ;;
  541. esac
  542. f_uci "${config}"
  543. config="firewall"
  544. fwcfg="$(uci -qNX show "${config}")"
  545. if [ "${adb_enabled}" -eq 1 ] && [ "${adb_forcedns}" -eq 1 ] && \
  546. [ "$(/etc/init.d/firewall enabled; printf "%u" ${?})" -eq 0 ]
  547. then
  548. for port in ${adb_portlist}
  549. do
  550. if [ -z "$(printf "%s" "${fwcfg}" | grep -Fo -m1 "adblock_dns_${port}")" ]
  551. then
  552. uci -q batch <<-EOC
  553. set firewall."adblock_dns_${port}"="redirect"
  554. set firewall."adblock_dns_${port}".name="Adblock DNS, port ${port}"
  555. set firewall."adblock_dns_${port}".src="lan"
  556. set firewall."adblock_dns_${port}".proto="tcp udp"
  557. set firewall."adblock_dns_${port}".src_dport="${port}"
  558. set firewall."adblock_dns_${port}".dest_port="${port}"
  559. set firewall."adblock_dns_${port}".target="DNAT"
  560. EOC
  561. fi
  562. done
  563. elif [ "${adb_enabled}" -eq 0 ] || [ "${adb_forcedns}" -eq 0 ]
  564. then
  565. for port in ${adb_portlist}
  566. do
  567. if [ -n "$(printf "%s" "${fwcfg}" | grep -Fo -m1 "adblock_dns_${port}")" ]
  568. then
  569. uci_remove firewall "adblock_dns_${port}"
  570. fi
  571. done
  572. fi
  573. f_uci "${config}"
  574. }
  575. # restart dns backend
  576. #
  577. f_dnsup()
  578. {
  579. local dns_service dns_up dns_pid dns_procfile restart_rc cnt=0 out_rc=4 in_rc="${1:-0}"
  580. if [ "${adb_dns}" = "raw" ] || { [ "${in_rc}" -eq 0 ] && [ "${adb_dnsinotify}" -eq 1 ]; }
  581. then
  582. out_rc=0
  583. else
  584. "/etc/init.d/${adb_dns}" restart >/dev/null 2>&1
  585. restart_rc="${?}"
  586. fi
  587. if [ "${restart_rc}" = "0" ]
  588. then
  589. while [ "${cnt}" -le "${adb_dnstimeout}" ]
  590. do
  591. dns_service="$(ubus -S call service list "{\"name\":\"${adb_dns}\"}")"
  592. dns_up="$(printf "%s" "${dns_service}" | jsonfilter -l1 -e "@[\"${adb_dns}\"].instances.*.running")"
  593. dns_pid="$(printf "%s" "${dns_service}" | jsonfilter -l1 -e "@[\"${adb_dns}\"].instances.*.pid")"
  594. dns_procfile="$(ls -l "/proc/${dns_pid}/fd" 2>/dev/null | grep -Fo "${adb_dnsdir}/${adb_dnsfile}")"
  595. if [ "${dns_up}" = "true" ] && [ -n "${dns_pid}" ] && [ -z "${dns_procfile}" ]
  596. then
  597. if [ -x "${adb_lookupcmd}" ] && [ "${adb_lookupdomain}" != "false" ]
  598. then
  599. "${adb_lookupcmd}" "${adb_lookupdomain}" >/dev/null 2>&1
  600. if [ "${?}" -eq 0 ]
  601. then
  602. out_rc=0
  603. break
  604. fi
  605. else
  606. sleep ${adb_dnstimeout}
  607. cnt=${adb_dnstimeout}
  608. out_rc=0
  609. break
  610. fi
  611. fi
  612. cnt=$((cnt+1))
  613. sleep 1
  614. done
  615. fi
  616. f_log "debug" "f_dnsup ::: lookup_util: ${adb_lookupcmd:-"-"}, lookup_domain: ${adb_lookupdomain:-"-"}, restart_rc: ${restart_rc:-"-"}, dns_timeout: ${adb_dnstimeout}, dns_cnt: ${cnt}, in_rc: ${in_rc}, out_rc: ${out_rc}"
  617. return "${out_rc}"
  618. }
  619. # backup/restore/remove blocklists
  620. #
  621. f_list()
  622. {
  623. local hold file rset item array safe_url safe_ips safe_cname safe_domains out_rc mode="${1}" src_name="${2:-"${src_name}"}" in_rc="${src_rc:-0}" cnt=1 ffiles="-maxdepth 1 -name ${adb_dnsprefix}.*.gz"
  624. case "${mode}" in
  625. "blacklist"|"whitelist")
  626. src_name="${mode}"
  627. if [ "${src_name}" = "blacklist" ] && [ -s "${adb_blacklist}" ]
  628. then
  629. rset="/^([[:alnum:]_-]{1,63}\\.)+[[:alpha:]]+([[:space:]]|$)/{print tolower(\$1)}"
  630. "${adb_awk}" "${rset}" "${adb_blacklist}" | \
  631. "${adb_awk}" 'BEGIN{FS="."}{for(f=NF;f>1;f--)printf "%s.",$f;print $1}' > "${adb_tmpdir}/tmp.raw.${src_name}"
  632. sort ${adb_srtopts} -u "${adb_tmpdir}/tmp.raw.${src_name}" 2>/dev/null > "${adb_tmpfile}.${src_name}"
  633. out_rc="${?}"
  634. rm -f "${adb_tmpdir}/tmp.raw.${src_name}"
  635. elif [ "${src_name}" = "whitelist" ] && [ -s "${adb_whitelist}" ]
  636. then
  637. rset="/^([[:alnum:]_-]{1,63}\\.)+[[:alpha:]]+([[:space:]]|$)/{print tolower(\$1)}"
  638. "${adb_awk}" "${rset}" "${adb_whitelist}" > "${adb_tmpdir}/tmp.raw.${src_name}"
  639. out_rc="${?}"
  640. if [ "${out_rc}" -eq 0 ]
  641. then
  642. rset="/^([[:alnum:]_-]{1,63}\\.)+[[:alpha:]]+([[:space:]]|$)/{gsub(\"\\\\.\",\"\\\\.\",\$1);print tolower(\"^(|.*\\\\.)\"\$1\"$\")}"
  643. "${adb_awk}" "${rset}" "${adb_tmpdir}/tmp.raw.${src_name}" > "${adb_tmpdir}/tmp.rem.${src_name}"
  644. out_rc="${?}"
  645. if [ "${out_rc}" -eq 0 ] && [ "${adb_dnsallow}" != "1" ]
  646. then
  647. eval "${adb_dnsallow}" "${adb_tmpdir}/tmp.raw.${src_name}" > "${adb_tmpdir}/tmp.add.${src_name}"
  648. out_rc="${?}"
  649. if [ "${out_rc}" -eq 0 ] && [ "${adb_jail}" = "1" ] && [ "${adb_dnsstop}" != "0" ]
  650. then
  651. > "${adb_jaildir}/${adb_dnsjail}"
  652. if [ -n "${adb_dnsheader}" ]
  653. then
  654. printf "${adb_dnsheader}" >> "${adb_jaildir}/${adb_dnsjail}"
  655. fi
  656. cat "${adb_tmpdir}/tmp.add.${src_name}" >> "${adb_jaildir}/${adb_dnsjail}"
  657. printf "%s\n" "${adb_dnsstop}" >> "${adb_jaildir}/${adb_dnsjail}"
  658. fi
  659. fi
  660. fi
  661. fi
  662. ;;
  663. "safesearch")
  664. case "${src_name}" in
  665. "google")
  666. rset="/^(\\.[[:alnum:]_-]{1,63}\\.)+[[:alpha:]]+([[:space:]]|$)/{printf \"%s\n%s\n\",tolower(\"www\"\$1),tolower(substr(\$1,2,length(\$1)))}"
  667. safe_url="https://www.google.com/supported_domains"
  668. safe_cname="forcesafesearch.google.com"
  669. safe_domains="${adb_tmpdir}/tmp.load.safesearch.${src_name}"
  670. if [ "${adb_backup}" -eq 1 ] && [ -s "${adb_backupdir}/safesearch.${src_name}.gz" ]
  671. then
  672. zcat "${adb_backupdir}/safesearch.${src_name}.gz" > "${safe_domains}"
  673. out_rc="${?}"
  674. else
  675. "${adb_fetchutil}" ${adb_fetchparm} "${safe_domains}" "${safe_url}" 2>/dev/null
  676. out_rc="${?}"
  677. if [ "${adb_backup}" -eq 1 ] && [ "${out_rc}" -eq 0 ]
  678. then
  679. gzip -cf "${safe_domains}" > "${adb_backupdir}/safesearch.${src_name}.gz"
  680. fi
  681. fi
  682. if [ "${out_rc}" -eq 0 ]
  683. then
  684. if [ -x "${adb_lookupcmd}" ]
  685. then
  686. safe_ips="$("${adb_lookupcmd}" "${safe_cname}" 2>/dev/null | "${adb_awk}" '/^Address[ 0-9]*: /{ORS=" ";print $NF}')"
  687. if [ -n "${safe_ips}" ]
  688. then
  689. "${adb_awk}" "${rset}" "${safe_domains}" > "${adb_tmpdir}/tmp.raw.safesearch.${src_name}"
  690. fi
  691. fi
  692. out_rc="${?}"
  693. fi
  694. ;;
  695. "bing")
  696. safe_cname="strict.bing.com"
  697. safe_domains="www.bing.com"
  698. if [ -x "${adb_lookupcmd}" ]
  699. then
  700. safe_ips="$("${adb_lookupcmd}" "${safe_cname}" 2>/dev/null | "${adb_awk}" '/^Address[ 0-9]*: /{ORS=" ";print $NF}')"
  701. if [ -n "${safe_ips}" ]
  702. then
  703. printf "%s\n" ${safe_domains} > "${adb_tmpdir}/tmp.raw.safesearch.${src_name}"
  704. fi
  705. fi
  706. out_rc="${?}"
  707. ;;
  708. "duckduckgo")
  709. safe_cname="safe.duckduckgo.com"
  710. safe_domains="duckduckgo.com"
  711. if [ -x "${adb_lookupcmd}" ]
  712. then
  713. safe_ips="$("${adb_lookupcmd}" "${safe_cname}" 2>/dev/null | "${adb_awk}" '/^Address[ 0-9]*: /{ORS=" ";print $NF}')"
  714. if [ -n "${safe_ips}" ]
  715. then
  716. printf "%s\n" ${safe_domains} > "${adb_tmpdir}/tmp.raw.safesearch.${src_name}"
  717. fi
  718. fi
  719. out_rc="${?}"
  720. ;;
  721. "pixabay")
  722. safe_cname="safesearch.pixabay.com"
  723. safe_domains="pixabay.com"
  724. if [ -x "${adb_lookupcmd}" ]
  725. then
  726. safe_ips="$("${adb_lookupcmd}" "${safe_cname}" 2>/dev/null | "${adb_awk}" '/^Address[ 0-9]*: /{ORS=" ";print $NF}')"
  727. if [ -n "${safe_ips}" ]
  728. then
  729. printf "%s\n" ${safe_domains} > "${adb_tmpdir}/tmp.raw.safesearch.${src_name}"
  730. fi
  731. fi
  732. out_rc="${?}"
  733. ;;
  734. "yandex")
  735. safe_cname="familysearch.yandex.ru"
  736. safe_domains="ya.ru yandex.ru yandex.com yandex.com.tr yandex.ua yandex.by yandex.ee yandex.lt yandex.lv yandex.md yandex.uz yandex.tm yandex.tj yandex.az"
  737. if [ -x "${adb_lookupcmd}" ]
  738. then
  739. safe_ips="$("${adb_lookupcmd}" "${safe_cname}" 2>/dev/null | "${adb_awk}" '/^Address[ 0-9]*: /{ORS=" ";print $NF}')"
  740. if [ -n "${safe_ips}" ]
  741. then
  742. printf "%s\n" ${safe_domains} > "${adb_tmpdir}/tmp.raw.safesearch.${src_name}"
  743. fi
  744. fi
  745. out_rc="${?}"
  746. ;;
  747. "youtube")
  748. if [ "${adb_safesearchmod}" -eq 0 ]
  749. then
  750. safe_cname="restrict.youtube.com"
  751. else
  752. safe_cname="restrictmoderate.youtube.com"
  753. fi
  754. safe_domains="www.youtube.com m.youtube.com youtubei.googleapis.com youtube.googleapis.com www.youtube-nocookie.com"
  755. if [ -x "${adb_lookupcmd}" ]
  756. then
  757. safe_ips="$("${adb_lookupcmd}" "${safe_cname}" 2>/dev/null | "${adb_awk}" '/^Address[ 0-9]*: /{ORS=" ";print $NF}')"
  758. if [ -n "${safe_ips}" ]
  759. then
  760. printf "%s\n" ${safe_domains} > "${adb_tmpdir}/tmp.raw.safesearch.${src_name}"
  761. fi
  762. fi
  763. out_rc="${?}"
  764. ;;
  765. esac
  766. if [ "${out_rc}" -eq 0 ] && [ -s "${adb_tmpdir}/tmp.raw.safesearch.${src_name}" ]
  767. then
  768. > "${adb_tmpdir}/tmp.safesearch.${src_name}"
  769. if [ "${adb_dns}" = "named" ]
  770. then
  771. array="${safe_cname}"
  772. else
  773. array="${safe_ips}"
  774. fi
  775. for item in ${array}
  776. do
  777. eval "${adb_dnssafesearch}" "${adb_tmpdir}/tmp.raw.safesearch.${src_name}" >> "${adb_tmpdir}/tmp.safesearch.${src_name}"
  778. if [ "${?}" -ne 0 ]
  779. then
  780. rm -f "${adb_tmpdir}/tmp.safesearch.${src_name}"
  781. break
  782. fi
  783. done
  784. out_rc="${?}"
  785. rm -f "${adb_tmpdir}/tmp.raw.safesearch.${src_name}"
  786. fi
  787. ;;
  788. "backup")
  789. (
  790. gzip -cf "${src_tmpfile}" > "${adb_backupdir}/${adb_dnsprefix}.${src_name}.gz"
  791. out_rc="${?}"
  792. )&
  793. ;;
  794. "restore")
  795. if [ -n "${src_name}" ] && [ -s "${adb_backupdir}/${adb_dnsprefix}.${src_name}.gz" ]
  796. then
  797. zcat "${adb_backupdir}/${adb_dnsprefix}.${src_name}.gz" > "${src_tmpfile}"
  798. out_rc="${?}"
  799. elif [ -z "${src_name}" ]
  800. then
  801. for file in "${adb_backupdir}/${adb_dnsprefix}".*.gz
  802. do
  803. if [ -r "${file}" ]
  804. then
  805. name="${file##*/}"
  806. name="${name%.*}"
  807. zcat "${file}" > "${adb_tmpfile}.${name}" &
  808. hold=$((cnt%adb_maxqueue))
  809. if [ "${hold}" -eq 0 ]
  810. then
  811. wait
  812. fi
  813. cnt=$((cnt+1))
  814. fi
  815. done
  816. wait
  817. out_rc="${?}"
  818. else
  819. out_rc=4
  820. fi
  821. if [ "${adb_action}" != "start" ] && [ "${adb_action}" != "resume" ] && [ -n "${src_name}" ] && [ "${out_rc}" -ne 0 ]
  822. then
  823. adb_sources="${adb_sources/${src_name}}"
  824. fi
  825. ;;
  826. "remove")
  827. if [ "${adb_backup}" -eq 1 ]
  828. then
  829. rm "${adb_backupdir}/${adb_dnsprefix}.${src_name}.gz" 2>/dev/null
  830. fi
  831. out_rc="${?}"
  832. adb_sources="${adb_sources/${src_name}}"
  833. ;;
  834. "merge")
  835. if [ "${adb_backup}" -eq 1 ]
  836. then
  837. for src_name in ${adb_sources}
  838. do
  839. ffiles="${ffiles} -a ! -name ${adb_dnsprefix}.${src_name}.gz"
  840. done
  841. if [ "${adb_safesearch}" -eq 1 ] && [ "${adb_dnssafesearch}" != "0" ]
  842. then
  843. ffiles="${ffiles} -a ! -name safesearch.google.gz"
  844. fi
  845. find "${adb_backupdir}" ${ffiles} -print0 2>/dev/null | xargs -0 rm 2>/dev/null
  846. fi
  847. unset src_name
  848. sort ${adb_srtopts} -mu "${adb_tmpfile}".* 2>/dev/null > "${adb_tmpdir}/${adb_dnsfile}"
  849. out_rc="${?}"
  850. rm -f "${adb_tmpfile}".*
  851. ;;
  852. "final")
  853. unset src_name
  854. if [ -n "${adb_dnsheader}" ]
  855. then
  856. printf "${adb_dnsheader}" > "${adb_dnsdir}/${adb_dnsfile}"
  857. else
  858. > "${adb_dnsdir}/${adb_dnsfile}"
  859. fi
  860. if [ -s "${adb_tmpdir}/tmp.add.whitelist" ]
  861. then
  862. cat "${adb_tmpdir}/tmp.add.whitelist" >> "${adb_dnsdir}/${adb_dnsfile}"
  863. fi
  864. for file in "${adb_tmpdir}/tmp.safesearch".*
  865. do
  866. if [ -r "${file}" ]
  867. then
  868. cat "${file}" >> "${adb_dnsdir}/${adb_dnsfile}"
  869. fi
  870. done
  871. if [ "${adb_dnsdeny}" != "0" ]
  872. then
  873. eval "${adb_dnsdeny}" "${adb_tmpdir}/${adb_dnsfile}" >> "${adb_dnsdir}/${adb_dnsfile}"
  874. else
  875. mv "${adb_tmpdir}/${adb_dnsfile}" "${adb_dnsdir}/${adb_dnsfile}"
  876. fi
  877. out_rc="${?}"
  878. ;;
  879. esac
  880. f_count "${mode}" "${src_name}"
  881. out_rc="${out_rc:-"${in_rc}"}"
  882. f_log "debug" "f_list ::: name: ${src_name:-"-"}, mode: ${mode}, cnt: ${adb_cnt}, in_rc: ${in_rc}, out_rc: ${out_rc}"
  883. return "${out_rc}"
  884. }
  885. # top level domain compression
  886. #
  887. f_tld()
  888. {
  889. local cnt cnt_tld source="${1}" temp_tld="${1}.tld"
  890. "${adb_awk}" '{if(NR==1){tld=$NF};while(getline){if(index($NF,tld".")==0){print tld;tld=$NF}}print tld}' "${source}" | \
  891. "${adb_awk}" 'BEGIN{FS="."}{for(f=NF;f>1;f--)printf "%s.",$f;print $1}' > "${temp_tld}"
  892. if [ "${?}" -eq 0 ]
  893. then
  894. mv -f "${temp_tld}" "${source}"
  895. cnt_tld="$(wc -l 2>/dev/null < "${source}")"
  896. else
  897. rm -f "${temp_tld}"
  898. fi
  899. f_log "debug" "f_tld ::: source: ${source}, cnt: ${adb_cnt:-"-"}, cnt_tld: ${cnt_tld:-"-"}"
  900. }
  901. # suspend/resume adblock processing
  902. #
  903. f_switch()
  904. {
  905. local status entry done="false" mode="${1}"
  906. json_load_file "${adb_rtfile}" >/dev/null 2>&1
  907. json_select "data" >/dev/null 2>&1
  908. json_get_var status "adblock_status"
  909. if [ "${mode}" = "suspend" ] && [ "${status}" = "enabled" ]
  910. then
  911. f_env
  912. printf "${adb_dnsheader}" > "${adb_dnsdir}/${adb_dnsfile}"
  913. f_count
  914. done="true"
  915. elif [ "${mode}" = "resume" ] && [ "${status}" = "paused" ]
  916. then
  917. f_env
  918. f_main
  919. done="true"
  920. fi
  921. if [ "${done}" = "true" ]
  922. then
  923. if [ "${mode}" = "suspend" ]
  924. then
  925. f_bgserv "stop"
  926. f_dnsup
  927. fi
  928. if [ "${mode}" = "resume" ]
  929. then
  930. f_bgserv "start"
  931. fi
  932. f_jsnup "${mode}"
  933. f_log "info" "${mode} adblock processing"
  934. fi
  935. f_rmtemp
  936. }
  937. # query blocklist for certain (sub-)domains
  938. #
  939. f_query()
  940. {
  941. local search result prefix suffix field query_start query_end query_timeout=30 domain="${1}" tld="${1#*.}"
  942. if [ -z "${domain}" ] || [ "${domain}" = "${tld}" ]
  943. then
  944. printf "%s\\n" "::: invalid input, please submit a single (sub-)domain :::"
  945. else
  946. case "${adb_dns}" in
  947. "dnsmasq")
  948. prefix=".*[\\/\\.]"
  949. suffix="(\\/)"
  950. field=2
  951. ;;
  952. "unbound")
  953. prefix=".*[\"\\.]"
  954. suffix="(static)"
  955. field=3
  956. ;;
  957. "named")
  958. prefix="[^\\*].*[\\.]"
  959. suffix="( \\.)"
  960. field=1
  961. ;;
  962. "kresd")
  963. prefix="[^\\*].*[\\.]"
  964. suffix="( \\.)"
  965. field=1
  966. ;;
  967. "raw")
  968. prefix=".*[\\.]"
  969. suffix=""
  970. field=1
  971. ;;
  972. esac
  973. query_start="$(date "+%s")"
  974. if [ "${adb_dnsfilereset}" -eq 0 ]
  975. then
  976. while [ "${domain}" != "${tld}" ]
  977. do
  978. search="${domain//[+*~%\$&\"\']/}"
  979. search="${search//./\\.}"
  980. result="$("${adb_awk}" -F '/|\"|\t| ' "/^(${search}|${prefix}+${search}.*${suffix})$/{i++;if(i<=9){printf \" + %s\\n\",\$${field}}else if(i==10){printf \" + %s\\n\",\"[...]\";exit}}" "${adb_dnsdir}/${adb_dnsfile}")"
  981. printf "%s\\n%s\\n%s\\n" ":::" "::: domain '${domain}' in active blocklist" ":::"
  982. printf "%s\\n\\n" "${result:-" - no match"}"
  983. domain="${tld}"
  984. tld="${domain#*.}"
  985. done
  986. fi
  987. if [ "${adb_backup}" -eq 1 ] && [ -d "${adb_backupdir}" ]
  988. then
  989. search="${1//[+*~%\$&\"\']/}"
  990. search="${search//./\\.}"
  991. printf "%s\\n%s\\n%s\\n" ":::" "::: domain '${1}' in backups and black-/whitelist" ":::"
  992. for file in "${adb_backupdir}/${adb_dnsprefix}".*.gz "${adb_blacklist}" "${adb_whitelist}"
  993. do
  994. suffix="${file##*.}"
  995. if [ "${suffix}" = "gz" ]
  996. then
  997. zcat "${file}" 2>/dev/null | \
  998. "${adb_awk}" 'BEGIN{FS="."}{for(f=NF;f>1;f--)printf "%s.",$f;print $1}' | "${adb_awk}" -v f="${file##*/}" "BEGIN{rc=1};/^($search|.*\\.${search})$/{i++;if(i<=3){printf \" + %-30s%s\\n\",f,\$1;rc=0}else if(i==4){printf \" + %-30s%s\\n\",f,\"[...]\"}};END{exit rc}"
  999. else
  1000. "${adb_awk}" -v f="${file##*/}" "BEGIN{rc=1};/^($search|.*\\.${search})$/{i++;if(i<=3){printf \" + %-30s%s\\n\",f,\$1;rc=0}else if(i==4){printf \" + %-30s%s\\n\",f,\"[...]\"}};END{exit rc}" "${file}"
  1001. fi
  1002. if [ "${?}" -eq 0 ]
  1003. then
  1004. result="true"
  1005. query_end="$(date "+%s")"
  1006. if [ "$((query_end-query_start))" -gt "${query_timeout}" ]
  1007. then
  1008. printf "%s\\n\\n" " - [...]"
  1009. break
  1010. fi
  1011. fi
  1012. done
  1013. if [ "${result}" != "true" ]
  1014. then
  1015. printf "%s\\n\\n" " - no match"
  1016. fi
  1017. fi
  1018. fi
  1019. }
  1020. # update runtime information
  1021. #
  1022. f_jsnup()
  1023. {
  1024. local runtime utils memory bg_pid status="${1:-"enabled"}"
  1025. case "${status}" in
  1026. "enabled"|"error")
  1027. adb_endtime="$(date "+%s")"
  1028. memory="$("${adb_awk}" '/^MemTotal|^MemFree|^MemAvailable/{ORS="/"; print int($2/1000)}' "/proc/meminfo" 2>/dev/null | "${adb_awk}" '{print substr($0,1,length($0)-1)}')"
  1029. if [ "$(( (adb_endtime-adb_starttime)/60 ))" -lt 60 ]
  1030. then
  1031. runtime="${adb_action}, $(( (adb_endtime-adb_starttime)/60 ))m $(( (adb_endtime-adb_starttime)%60 ))s, ${memory:-0}, $(date "+%d.%m.%Y %H:%M:%S")"
  1032. else
  1033. runtime="${adb_action}, n/a, ${memory:-0}, $(date "+%d.%m.%Y %H:%M:%S")"
  1034. fi
  1035. if [ "${status}" = "error" ]
  1036. then
  1037. adb_cnt=0
  1038. fi
  1039. ;;
  1040. "suspend")
  1041. status="paused"
  1042. ;;
  1043. "resume")
  1044. status=""
  1045. ;;
  1046. esac
  1047. json_load_file "${adb_rtfile}" >/dev/null 2>&1
  1048. json_select "data" >/dev/null 2>&1
  1049. if [ "${?}" -eq 0 ]
  1050. then
  1051. if [ -z "${adb_fetchutil}" ] || [ -z "${adb_awk}" ]
  1052. then
  1053. json_get_var utils "utilities"
  1054. else
  1055. utils="${adb_fetchutil}, ${adb_awk}"
  1056. fi
  1057. if [ -z "${adb_cnt}" ]
  1058. then
  1059. json_get_var adb_cnt "blocked_domains"
  1060. adb_cnt="${adb_cnt%% *}"
  1061. fi
  1062. if [ -z "${runtime}" ]
  1063. then
  1064. json_get_var runtime "last_run"
  1065. fi
  1066. fi
  1067. > "${adb_rtfile}"
  1068. json_load_file "${adb_rtfile}" >/dev/null 2>&1
  1069. json_init
  1070. json_add_object "data"
  1071. json_add_string "adblock_status" "${status:-"enabled"}"
  1072. json_add_string "adblock_version" "${adb_ver}"
  1073. json_add_string "blocked_domains" "${adb_cnt:-0}"
  1074. json_add_array "active_sources"
  1075. for entry in ${adb_sources}
  1076. do
  1077. json_add_object
  1078. json_add_string "source" "${entry}"
  1079. json_close_object
  1080. done
  1081. json_close_array
  1082. json_add_string "dns_backend" "${adb_dns:-"-"}, ${adb_dnsdir:-"-"}"
  1083. json_add_string "run_utils" "${utils:-"-"}"
  1084. json_add_string "run_ifaces" "trigger: ${adb_trigger:-"-"}, report: ${adb_repiface:-"-"}"
  1085. json_add_string "run_directories" "base: ${adb_tmpbase}, backup: ${adb_backupdir}, report: ${adb_reportdir}, jail: ${adb_jaildir}"
  1086. json_add_string "run_flags" "backup: ${adb_backup}, reset: ${adb_dnsfilereset}, flush: ${adb_dnsflush}, force: ${adb_forcedns}, search: ${adb_safesearch}, report: ${adb_report}, mail: ${adb_mail}, jail: ${adb_jail}"
  1087. json_add_string "last_run" "${runtime:-"-"}"
  1088. json_add_string "system" "${adb_sysver}"
  1089. json_close_object
  1090. json_dump > "${adb_rtfile}"
  1091. if [ "${adb_mail}" -eq 1 ] && [ -x "${adb_mailservice}" ] && \
  1092. { [ "${status}" = "error" ] || { [ "${status}" = "enabled" ] && [ "${adb_cnt}" -le "${adb_mailcnt}" ]; } }
  1093. then
  1094. ( "${adb_mailservice}" "${adb_ver}" >/dev/null 2>&1 )&
  1095. bg_pid="${!}"
  1096. fi
  1097. f_log "debug" "f_jsnup ::: status: ${status:-"-"}, cnt: ${adb_cnt}, mail: ${adb_mail}, mail_service: ${adb_mailservice}, mail_cnt: ${adb_mailcnt}, mail_pid: ${bg_pid:-"-"}"
  1098. }
  1099. # write to syslog
  1100. #
  1101. f_log()
  1102. {
  1103. local class="${1}" log_msg="${2}"
  1104. if [ -n "${log_msg}" ] && { [ "${class}" != "debug" ] || [ "${adb_debug}" -eq 1 ]; }
  1105. then
  1106. if [ -x "${adb_loggercmd}" ]
  1107. then
  1108. "${adb_loggercmd}" -p "${class}" -t "adblock-${adb_ver}[${$}]" "${log_msg}"
  1109. else
  1110. printf "%s %s %s\\n" "${class}" "adblock-${adb_ver}[${$}]" "${log_msg}"
  1111. fi
  1112. if [ "${class}" = "err" ]
  1113. then
  1114. f_rmdns
  1115. f_bgserv "stop"
  1116. f_jsnup "error"
  1117. exit 1
  1118. fi
  1119. fi
  1120. }
  1121. # start ubus monitor service to trace dns backend events
  1122. #
  1123. f_bgserv()
  1124. {
  1125. local bg_pid status="${1}"
  1126. bg_pid="$(pgrep -f "^/bin/sh ${adb_ubusservice}.*|^/bin/ubus -S -M r -m invoke monitor|^grep -qF \"method\":\"set\",\"data\":\\{\"name\":\"${adb_dns}\"" | "${adb_awk}" '{ORS=" "; print $1}')"
  1127. if [ "${adb_dns}" != "raw" ] && [ -z "${bg_pid}" ] && [ "${status}" = "start" ] \
  1128. && [ -x "${adb_ubusservice}" ] && [ "${adb_dnsfilereset}" -eq 1 ]
  1129. then
  1130. ( "${adb_ubusservice}" "${adb_ver}" & )
  1131. elif [ -n "${bg_pid}" ] && [ "${status}" = "stop" ]
  1132. then
  1133. kill -HUP "${bg_pid}" 2>/dev/null
  1134. fi
  1135. f_log "debug" "f_bgserv ::: status: ${status:-"-"}, bg_pid: ${bg_pid:-"-"}, dns_filereset: ${adb_dnsfilereset:-"-"}, ubus_service: ${adb_ubusservice:-"-"}"
  1136. }
  1137. # main function for blocklist processing
  1138. #
  1139. f_main()
  1140. {
  1141. local src_tmpload src_tmpfile src_name src_rset src_url src_log src_arc src_cat src_item src_list src_entries src_suffix src_rc entry keylist memory cnt=1
  1142. memory="$("${adb_awk}" '/^MemTotal|^MemFree|^MemAvailable/{ORS="/"; print int($2/1000)}' "/proc/meminfo" 2>/dev/null | "${adb_awk}" '{print substr($0,1,length($0)-1)}')"
  1143. f_log "debug" "f_main ::: memory: ${memory:-0}, max_queue: ${adb_maxqueue}, safe_search: ${adb_safesearch}, force_dns: ${adb_forcedns}, awk: ${adb_awk}"
  1144. # white- and blacklist preparation
  1145. #
  1146. for entry in ${adb_locallist}
  1147. do
  1148. ( f_list "${entry}" "${entry}" )&
  1149. done
  1150. # safe search preparation
  1151. #
  1152. if [ "${adb_safesearch}" -eq 1 ] && [ "${adb_dnssafesearch}" != "0" ]
  1153. then
  1154. if [ -z "${adb_safesearchlist}" ]
  1155. then
  1156. adb_safesearchlist="google bing duckduckgo pixabay yandex youtube"
  1157. fi
  1158. for entry in ${adb_safesearchlist}
  1159. do
  1160. ( f_list safesearch "${entry}" )&
  1161. done
  1162. fi
  1163. wait
  1164. # main loop
  1165. #
  1166. for src_name in ${adb_sources}
  1167. do
  1168. json_select "${src_name}" >/dev/null 2>&1
  1169. if [ "${?}" -ne 0 ]
  1170. then
  1171. adb_sources="${adb_sources/${src_name}}"
  1172. continue
  1173. fi
  1174. json_get_var src_url "url" >/dev/null 2>&1
  1175. json_get_var src_rset "rule" >/dev/null 2>&1
  1176. json_get_values src_cat "categories" >/dev/null 2>&1
  1177. json_select ..
  1178. src_tmpload="${adb_tmpload}.${src_name}.load"
  1179. src_tmpsort="${adb_tmpload}.${src_name}.sort"
  1180. src_tmpfile="${adb_tmpfile}.${src_name}"
  1181. src_rc=4
  1182. # basic pre-checks
  1183. #
  1184. if [ -z "${src_url}" ] || [ -z "${src_rset}" ]
  1185. then
  1186. f_list remove
  1187. continue
  1188. fi
  1189. # backup mode
  1190. #
  1191. if [ "${adb_backup}" -eq 1 ] && { [ "${adb_action}" = "start" ] || [ "${adb_action}" = "resume" ]; }
  1192. then
  1193. f_list restore
  1194. if [ "${?}" -eq 0 ] && [ -s "${src_tmpfile}" ]
  1195. then
  1196. continue
  1197. fi
  1198. fi
  1199. # download queue processing
  1200. #
  1201. if [ -n "${src_cat}" ]
  1202. then
  1203. (
  1204. src_arc="${adb_tmpdir}/${src_url##*/}"
  1205. src_log="$("${adb_fetchutil}" ${adb_fetchparm} "${src_arc}" "${src_url}" 2>&1)"
  1206. src_rc="${?}"
  1207. if [ "${src_rc}" -eq 0 ] && [ -s "${src_arc}" ]
  1208. then
  1209. unset src_entries
  1210. src_suffix="$(eval printf "%s" \"\$\{adb_src_suffix_${src_name}:-\"domains\"\}\")"
  1211. src_list="$(tar -tzf "${src_arc}" 2>/dev/null)"
  1212. for src_item in ${src_cat}
  1213. do
  1214. src_entries="${src_entries} $(printf "%s" "${src_list}" | grep -E "${src_item}/${src_suffix}$")"
  1215. done
  1216. if [ -n "${src_entries}" ]
  1217. then
  1218. tar -xOzf "${src_arc}" ${src_entries} 2>/dev/null > "${src_tmpload}"
  1219. src_rc="${?}"
  1220. fi
  1221. rm -f "${src_arc}"
  1222. else
  1223. src_log="$(printf "%s" "${src_log}" | "${adb_awk}" '{ORS=" ";print $0}')"
  1224. f_log "info" "download of '${src_name}' failed, url: ${src_url}, rule: ${src_rset:-"-"}, categories: ${src_cat:-"-"}, rc: ${src_rc}, log: ${src_log:-"-"}"
  1225. fi
  1226. if [ "${src_rc}" -eq 0 ] && [ -s "${src_tmpload}" ]
  1227. then
  1228. if [ -s "${adb_tmpdir}/tmp.rem.whitelist" ]
  1229. then
  1230. "${adb_awk}" "${src_rset}" "${src_tmpload}" | sed "s/\r//g" | \
  1231. grep -Evf "${adb_tmpdir}/tmp.rem.whitelist" | "${adb_awk}" 'BEGIN{FS="."}{for(f=NF;f>1;f--)printf "%s.",$f;print $1}' > "${src_tmpsort}"
  1232. else
  1233. "${adb_awk}" "${src_rset}" "${src_tmpload}" | sed "s/\r//g" | \
  1234. "${adb_awk}" 'BEGIN{FS="."}{for(f=NF;f>1;f--)printf "%s.",$f;print $1}' > "${src_tmpsort}"
  1235. fi
  1236. rm -f "${src_tmpload}"
  1237. sort ${adb_srtopts} -u "${src_tmpsort}" 2>/dev/null > "${src_tmpfile}"
  1238. src_rc="${?}"
  1239. rm -f "${src_tmpsort}"
  1240. if [ "${src_rc}" -eq 0 ] && [ -s "${src_tmpfile}" ]
  1241. then
  1242. f_list download
  1243. if [ "${adb_backup}" -eq 1 ]
  1244. then
  1245. f_list backup
  1246. fi
  1247. elif [ "${adb_backup}" -eq 1 ] && [ "${adb_action}" != "start" ]
  1248. then
  1249. f_log "info" "archive preparation of '${src_name}' failed, categories: ${src_cat:-"-"}, entries: ${src_entries}, rc: ${src_rc}"
  1250. f_list restore
  1251. rm -f "${src_tmpfile}"
  1252. fi
  1253. elif [ "${adb_backup}" -eq 1 ] && [ "${adb_action}" != "start" ]
  1254. then
  1255. f_log "info" "archive extraction of '${src_name}' failed, categories: ${src_cat:-"-"}, entries: ${src_entries}, rc: ${src_rc}"
  1256. f_list restore
  1257. fi
  1258. )&
  1259. continue
  1260. else
  1261. (
  1262. src_log="$("${adb_fetchutil}" ${adb_fetchparm} "${src_tmpload}" "${src_url}" 2>&1)"
  1263. src_rc="${?}"
  1264. if [ "${src_rc}" -eq 0 ] && [ -s "${src_tmpload}" ]
  1265. then
  1266. if [ -s "${adb_tmpdir}/tmp.rem.whitelist" ]
  1267. then
  1268. "${adb_awk}" "${src_rset}" "${src_tmpload}" | sed "s/\r//g" | \
  1269. grep -Evf "${adb_tmpdir}/tmp.rem.whitelist" | "${adb_awk}" 'BEGIN{FS="."}{for(f=NF;f>1;f--)printf "%s.",$f;print $1}' > "${src_tmpsort}"
  1270. else
  1271. "${adb_awk}" "${src_rset}" "${src_tmpload}" | sed "s/\r//g" | \
  1272. "${adb_awk}" 'BEGIN{FS="."}{for(f=NF;f>1;f--)printf "%s.",$f;print $1}' > "${src_tmpsort}"
  1273. fi
  1274. rm -f "${src_tmpload}"
  1275. sort ${adb_srtopts} -u "${src_tmpsort}" 2>/dev/null > "${src_tmpfile}"
  1276. src_rc="${?}"
  1277. rm -f "${src_tmpsort}"
  1278. if [ "${src_rc}" -eq 0 ] && [ -s "${src_tmpfile}" ]
  1279. then
  1280. f_list download
  1281. if [ "${adb_backup}" -eq 1 ]
  1282. then
  1283. f_list backup
  1284. fi
  1285. elif [ "${adb_backup}" -eq 1 ] && [ "${adb_action}" != "start" ]
  1286. then
  1287. f_log "info" "preparation of '${src_name}' failed, rc: ${src_rc}"
  1288. f_list restore
  1289. rm -f "${src_tmpfile}"
  1290. fi
  1291. else
  1292. src_log="$(printf "%s" "${src_log}" | "${adb_awk}" '{ORS=" ";print $0}')"
  1293. f_log "info" "download of '${src_name}' failed, url: ${src_url}, rule: ${src_rset:-"-"}, categories: ${src_cat:-"-"}, rc: ${src_rc}, log: ${src_log:-"-"}"
  1294. if [ "${adb_backup}" -eq 1 ] && [ "${adb_action}" != "start" ]
  1295. then
  1296. f_list restore
  1297. fi
  1298. fi
  1299. )&
  1300. fi
  1301. hold=$((cnt%adb_maxqueue))
  1302. if [ "${hold}" -eq 0 ]
  1303. then
  1304. wait
  1305. fi
  1306. cnt=$((cnt+1))
  1307. done
  1308. wait
  1309. f_list merge
  1310. # tld compression and dns restart
  1311. #
  1312. if [ "${?}" -eq 0 ] && [ -s "${adb_tmpdir}/${adb_dnsfile}" ]
  1313. then
  1314. f_tld "${adb_tmpdir}/${adb_dnsfile}"
  1315. f_list final
  1316. else
  1317. printf "${adb_dnsheader}" > "${adb_dnsdir}/${adb_dnsfile}"
  1318. fi
  1319. chown "${adb_dnsuser}" "${adb_dnsdir}/${adb_dnsfile}" 2>/dev/null
  1320. f_dnsup
  1321. if [ "${?}" -eq 0 ]
  1322. then
  1323. if [ "${adb_action}" != "resume" ]
  1324. then
  1325. f_jsnup "enabled"
  1326. fi
  1327. if [ "${adb_dns}" != "raw" ] && [ "${adb_dnsfilereset}" -eq 1 ]
  1328. then
  1329. printf "${adb_dnsheader}" > "${adb_dnsdir}/${adb_dnsfile}"
  1330. f_log "info" "blocklist with overall ${adb_cnt} blocked domains loaded successfully and reset afterwards (${adb_sysver})"
  1331. f_bgserv "start"
  1332. else
  1333. f_log "info" "blocklist with overall ${adb_cnt} blocked domains loaded successfully (${adb_sysver})"
  1334. fi
  1335. else
  1336. f_log "err" "dns backend restart with adblock blocklist failed"
  1337. fi
  1338. f_rmtemp
  1339. }
  1340. # trace dns queries via tcpdump and prepare a report
  1341. #
  1342. f_report()
  1343. {
  1344. local iface bg_pid status total start end blocked percent top_list top array item index hold ports cnt=0 search="${1}" count="${2}" process="${3}" print="${4}"
  1345. if [ "${adb_report}" -eq 1 ] && [ ! -x "${adb_dumpcmd}" ]
  1346. then
  1347. f_log "info" "Please install the package 'tcpdump' or 'tcpdump-mini' to use the reporting feature"
  1348. elif [ "${adb_report}" -eq 0 ] && [ "${adb_action}" = "report" ]
  1349. then
  1350. f_log "info" "Please enable the 'DNS Report' option to use the reporting feature"
  1351. fi
  1352. if [ -x "${adb_dumpcmd}" ]
  1353. then
  1354. bg_pid="$(pgrep -f "^${adb_dumpcmd}.*adb_report\\.pcap$" | "${adb_awk}" '{ORS=" "; print $1}')"
  1355. if [ "${adb_report}" -eq 0 ] || { [ -n "${bg_pid}" ] && { [ "${adb_action}" = "stop" ] || [ "${adb_action}" = "restart" ]; } }
  1356. then
  1357. if [ -n "${bg_pid}" ]
  1358. then
  1359. kill -HUP "${bg_pid}" 2>/dev/null
  1360. while $(kill -0 "${bg_pid}" 2>/dev/null)
  1361. do
  1362. sleep 1
  1363. done
  1364. unset bg_pid
  1365. fi
  1366. fi
  1367. fi
  1368. if [ -x "${adb_dumpcmd}" ] && [ "${adb_report}" -eq 1 ]
  1369. then
  1370. if [ -z "${bg_pid}" ] && [ "${adb_action}" != "report" ] && [ "${adb_action}" != "stop" ]
  1371. then
  1372. for port in ${adb_replisten}
  1373. do
  1374. if [ -z "${ports}" ]
  1375. then
  1376. ports="port ${port}"
  1377. else
  1378. ports="${ports} or port ${port}"
  1379. fi
  1380. done
  1381. if [ -z "${adb_repiface}" ]
  1382. then
  1383. network_get_device iface "lan"
  1384. if [ -n "${iface}" ]
  1385. then
  1386. adb_repiface="${iface}"
  1387. else
  1388. network_get_physdev iface "lan"
  1389. if [ -n "${iface}" ]
  1390. then
  1391. adb_repiface="${iface}"
  1392. fi
  1393. fi
  1394. if [ -n "${adb_repiface}" ]
  1395. then
  1396. uci_set adblock global adb_repiface "${adb_repiface}"
  1397. f_uci "adblock"
  1398. fi
  1399. fi
  1400. if [ -n "${adb_reportdir}" ] && [ ! -d "${adb_reportdir}" ]
  1401. then
  1402. mkdir -p "${adb_reportdir}"
  1403. f_log "info" "report directory '${adb_reportdir}' created"
  1404. fi
  1405. if [ -n "${adb_repiface}" ] && [ -d "${adb_reportdir}" ]
  1406. then
  1407. ( "${adb_dumpcmd}" -nn -s0 -l -i ${adb_repiface} ${ports} -C${adb_repchunksize} -W${adb_repchunkcnt} -w "${adb_reportdir}/adb_report.pcap" >/dev/null 2>&1 & )
  1408. bg_pid="$(pgrep -f "^${adb_dumpcmd}.*adb_report\\.pcap$" | "${adb_awk}" '{ORS=" "; print $1}')"
  1409. else
  1410. f_log "info" "Please set the name of the reporting network device 'adb_repiface' manually"
  1411. fi
  1412. fi
  1413. if [ "${adb_action}" = "report" ] && [ "${process}" = "true" ]
  1414. then
  1415. > "${adb_reportdir}/adb_report.raw"
  1416. for file in "${adb_reportdir}/adb_report.pcap"*
  1417. do
  1418. (
  1419. "${adb_dumpcmd}" -tttt -r "${file}" 2>/dev/null | \
  1420. "${adb_awk}" -v cnt="${cnt}" '!/\.lan\. |PTR\? | SOA\? /&&/ A[\? ]+|NXDomain|0\.0\.0\.0/{a=$1;b=substr($2,0,8);c=$4;sub(/\.[0-9]+$/,"",c);gsub(/[^[:alnum:]\.:-]/,"",c);d=cnt $7;sub(/\*$/,"",d);
  1421. e=$(NF-1);sub(/[0-9]\/[0-9]\/[0-9]|0\.0\.0\.0/,"NX",e);sub(/\.$/,"",e);sub(/([0-9]{1,3}\.){3}[0-9]{1,3}/,"OK",e);gsub(/[^[:alnum:]\.-]/,"",e);if(e==""){e="err"};printf "%s\t%s\t%s\t%s\t%s\n",d,e,a,b,c}' >> "${adb_reportdir}/adb_report.raw"
  1422. )&
  1423. hold=$((cnt%adb_maxqueue))
  1424. if [ "${hold}" -eq 0 ]
  1425. then
  1426. wait
  1427. fi
  1428. cnt=$((cnt+1))
  1429. done
  1430. wait
  1431. if [ -s "${adb_reportdir}/adb_report.raw" ]
  1432. then
  1433. sort ${adb_srtopts} -k1 -k3 -k4 -k5 -k1 -ur "${adb_reportdir}/adb_report.raw" | \
  1434. "${adb_awk}" '{currA=($1+0);currB=$1;currC=substr($1,length($1),1);if(reqA==currB){reqA=0;printf "%s\t%s\n",d,$2}else if(currC=="+"){reqA=currA;d=$3"\t"$4"\t"$5"\t"$2}}' | \
  1435. sort ${adb_srtopts} -k1 -k2 -k3 -k4 -ur > "${adb_reportdir}/adb_report.srt"
  1436. rm -f "${adb_reportdir}/adb_report.raw"
  1437. fi
  1438. if [ -s "${adb_reportdir}/adb_report.srt" ]
  1439. then
  1440. start="$("${adb_awk}" 'END{printf "%s_%s",$1,$2}' "${adb_reportdir}/adb_report.srt")"
  1441. end="$("${adb_awk}" 'NR==1{printf "%s_%s",$1,$2}' "${adb_reportdir}/adb_report.srt")"
  1442. total="$(wc -l < "${adb_reportdir}/adb_report.srt")"
  1443. blocked="$("${adb_awk}" '{if($5=="NX")cnt++}END{printf "%s",cnt}' "${adb_reportdir}/adb_report.srt")"
  1444. percent="$("${adb_awk}" -v t="${total}" -v b="${blocked}" 'BEGIN{printf "%.2f%s",b/t*100,"%"}')"
  1445. > "${adb_reportdir}/adb_report.json"
  1446. printf "%s" "{ \"data\": { " >> "${adb_reportdir}/adb_report.json"
  1447. printf "%s" "\"start_date\": \"${start%_*}\", " >> "${adb_reportdir}/adb_report.json"
  1448. printf "%s" "\"start_time\": \"${start#*_}\", " >> "${adb_reportdir}/adb_report.json"
  1449. printf "%s" "\"end_date\": \"${end%_*}\", " >> "${adb_reportdir}/adb_report.json"
  1450. printf "%s" "\"end_time\": \"${end#*_}\", " >> "${adb_reportdir}/adb_report.json"
  1451. printf "%s" "\"total\": \"${total}\", " >> "${adb_reportdir}/adb_report.json"
  1452. printf "%s" "\"blocked\": \"${blocked}\", " >> "${adb_reportdir}/adb_report.json"
  1453. printf "%s" "\"percent\": \"${percent}\", " >> "${adb_reportdir}/adb_report.json"
  1454. top_list="top_clients top_domains top_blocked"
  1455. for top in ${top_list}
  1456. do
  1457. printf "%s" " \"${top}\": [ " >> "${adb_reportdir}/adb_report.json"
  1458. case "${top}" in
  1459. "top_clients")
  1460. "${adb_awk}" '{print $3}' "${adb_reportdir}/adb_report.srt" | sort ${adb_srtopts} | uniq -c | \
  1461. sort ${adb_srtopts} -nr | "${adb_awk}" '{ORS=" ";if(NR==1)printf "{ \"count\": \"%s\", \"address\": \"%s\" }",$1,$2; else if(NR<10)printf ", { \"count\": \"%s\", \"address\": \"%s\" }",$1,$2}' >> "${adb_reportdir}/adb_report.json"
  1462. ;;
  1463. "top_domains")
  1464. "${adb_awk}" '{if($5!="NX")print $4}' "${adb_reportdir}/adb_report.srt" | sort ${adb_srtopts} | uniq -c | \
  1465. sort ${adb_srtopts} -nr | "${adb_awk}" '{ORS=" ";if(NR==1)printf "{ \"count\": \"%s\", \"address\": \"%s\" }",$1,$2; else if(NR<10)printf ", { \"count\": \"%s\", \"address\": \"%s\" }",$1,$2}' >> "${adb_reportdir}/adb_report.json"
  1466. ;;
  1467. "top_blocked")
  1468. "${adb_awk}" '{if($5=="NX")print $4}' "${adb_reportdir}/adb_report.srt" | sort ${adb_srtopts} | uniq -c | \
  1469. sort ${adb_srtopts} -nr | "${adb_awk}" '{ORS=" ";if(NR==1)printf "{ \"count\": \"%s\", \"address\": \"%s\" }",$1,$2; else if(NR<10)printf ", { \"count\": \"%s\", \"address\": \"%s\" }",$1,$2}' >> "${adb_reportdir}/adb_report.json"
  1470. ;;
  1471. esac
  1472. printf "%s" " ], " >> "${adb_reportdir}/adb_report.json"
  1473. done
  1474. search="${search//./\\.}"
  1475. search="${search//[+*~%\$&\"\' ]/}"
  1476. "${adb_awk}" "BEGIN{i=0;printf \"\\\"requests\\\": [ \" }/(${search})/{i++;if(i==1)printf \"{ \\\"date\\\": \\\"%s\\\", \\\"time\\\": \\\"%s\\\", \\\"client\\\": \\\"%s\\\", \\\"domain\\\": \\\"%s\\\", \\\"rc\\\": \\\"%s\\\" }\",\$1,\$2,\$3,\$4,\$5;else if(i<=${count})printf \", { \\\"date\\\": \\\"%s\\\", \\\"time\\\": \\\"%s\\\", \\\"client\\\": \\\"%s\\\", \\\"domain\\\": \\\"%s\\\", \\\"rc\\\": \\\"%s\\\" }\",\$1,\$2,\$3,\$4,\$5}END{printf \" ] } }\n\"}" "${adb_reportdir}/adb_report.srt" >> "${adb_reportdir}/adb_report.json"
  1477. rm -f "${adb_reportdir}/adb_report.srt"
  1478. fi
  1479. fi
  1480. if [ -s "${adb_reportdir}/adb_report.json" ]
  1481. then
  1482. if [ "${print}" = "cli" ]
  1483. then
  1484. printf "%s\\n%s\\n%s\\n" ":::" "::: Adblock DNS-Query Report" ":::"
  1485. json_load_file "${adb_reportdir}/adb_report.json"
  1486. json_select "data"
  1487. json_get_keys keylist
  1488. for key in ${keylist}
  1489. do
  1490. json_get_var value "${key}"
  1491. eval "${key}=\"${value}\""
  1492. done
  1493. printf " + %s\\n + %s\\n" "Start ::: ${start_date}, ${start_time}" "End ::: ${end_date}, ${end_time}"
  1494. printf " + %s\\n + %s %s\\n" "Total ::: ${total}" "Blocked ::: ${blocked}" "(${percent})"
  1495. top_list="top_clients top_domains top_blocked requests"
  1496. for top in ${top_list}
  1497. do
  1498. case "${top}" in
  1499. "top_clients")
  1500. item="::: Top 10 Clients"
  1501. ;;
  1502. "top_domains")
  1503. item="::: Top 10 Domains"
  1504. ;;
  1505. "top_blocked")
  1506. item="::: Top 10 Blocked Domains"
  1507. ;;
  1508. esac
  1509. if json_get_type status "${top}" && [ "${top}" != "requests" ] && [ "${status}" = "array" ]
  1510. then
  1511. printf "%s\\n%s\\n%s\\n" ":::" "${item}" ":::"
  1512. json_select "${top}"
  1513. index=1
  1514. while json_get_type status "${index}" && [ "${status}" = "object" ]
  1515. do
  1516. json_get_values item "${index}"
  1517. printf " + %-9s::: %s\\n" ${item}
  1518. index=$((index+1))
  1519. done
  1520. elif json_get_type status "${top}" && [ "${top}" = "requests" ] && [ "${status}" = "array" ]
  1521. then
  1522. printf "%s\\n%s\\n%s\\n" ":::" "::: Latest DNS Queries" ":::"
  1523. printf "%-15s%-15s%-45s%-80s%s\\n" "Date" "Time" "Client" "Domain" "Answer"
  1524. json_select "${top}"
  1525. index=1
  1526. while json_get_type status "${index}" && [ "${status}" = "object" ]
  1527. do
  1528. json_get_values item "${index}"
  1529. printf "%-15s%-15s%-45s%-80s%s\\n" ${item}
  1530. index=$((index+1))
  1531. done
  1532. fi
  1533. json_select ".."
  1534. done
  1535. elif [ "${print}" = "json" ]
  1536. then
  1537. cat "${adb_reportdir}/adb_report.json"
  1538. fi
  1539. fi
  1540. fi
  1541. f_log "debug" "f_report ::: action: ${adb_action}, report: ${adb_report}, search: ${1}, count: ${2}, process: ${3}, print: ${4}, dump_util: ${adb_dumpcmd}, repdir: ${adb_reportdir}, repiface: ${adb_repiface:-"-"}, replisten: ${adb_replisten}, repchunksize: ${adb_repchunksize}, repchunkcnt: ${adb_repchunkcnt}, bg_pid: ${bg_pid}"
  1542. }
  1543. # awk selection
  1544. #
  1545. adb_awk="$(command -v gawk)"
  1546. if [ -z "${adb_awk}" ]
  1547. then
  1548. adb_awk="$(command -v awk)"
  1549. fi
  1550. # source required system libraries
  1551. #
  1552. if [ -r "/lib/functions.sh" ] && [ -r "/lib/functions/network.sh" ] && [ -r "/usr/share/libubox/jshn.sh" ]
  1553. then
  1554. . "/lib/functions.sh"
  1555. . "/lib/functions/network.sh"
  1556. . "/usr/share/libubox/jshn.sh"
  1557. else
  1558. f_log "err" "system libraries not found"
  1559. fi
  1560. # version information
  1561. #
  1562. if [ "${adb_action}" = "version" ]
  1563. then
  1564. printf "%s\n" "${adb_ver}"
  1565. exit 0
  1566. fi
  1567. # handle different adblock actions
  1568. #
  1569. f_load
  1570. case "${adb_action}" in
  1571. "stop")
  1572. f_bgserv "stop"
  1573. f_report "+" "50" "false" "false"
  1574. f_rmdns
  1575. ;;
  1576. "restart")
  1577. f_bgserv "stop"
  1578. f_report "+" "50" "false" "false"
  1579. f_rmdns
  1580. f_env
  1581. f_main
  1582. ;;
  1583. "suspend")
  1584. if [ "${adb_dns}" != "raw" ]
  1585. then
  1586. f_switch suspend
  1587. fi
  1588. ;;
  1589. "resume")
  1590. if [ "${adb_dns}" != "raw" ]
  1591. then
  1592. f_switch resume
  1593. fi
  1594. ;;
  1595. "report")
  1596. f_report "${2}" "${3}" "${4}" "${5}"
  1597. ;;
  1598. "query")
  1599. f_query "${2}"
  1600. ;;
  1601. "start"|"reload")
  1602. f_bgserv "stop"
  1603. f_report "+" "50" "false" "false"
  1604. f_env
  1605. f_main
  1606. ;;
  1607. esac