package de.jgsoftwares.dnsserver.dao; import de.jgsoftwares.dnsserver.dao.interfaces.CrudMDNS; import de.jgsoftwares.dnsserver.model.MDNS; import java.io.BufferedWriter; import java.io.File; import java.io.FileWriter; import java.io.IOException; import java.util.List; import java.util.logging.Level; import java.util.logging.Logger; import static junit.runner.Version.id; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.context.annotation.Bean; import org.springframework.data.jpa.repository.JpaRepository; import org.springframework.jdbc.core.BeanPropertyRowMapper; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Repository; import de.jgsoftwares.dnsserver.dao.interfaces.JPAMDNS; @Repository public class DaoDnsEntry implements iDaoDnsEntry { // demodb @Autowired @Qualifier(value = "defaultJdbcTemplate") JdbcTemplate jtm; @Autowired JPAMDNS jpadb; @Autowired CrudMDNS crudmdns; public DaoDnsEntry() { } @Override public List getdnsentrys() { List ldnsentry = jtm.query("select * from dns", new BeanPropertyRowMapper(MDNS.class)); return ldnsentry; } @Override public List getforwarddnsentry() { List forwardlistdns = jtm.query("SELECT * FROM DNS where forwarddns is not null group by dnszone", new BeanPropertyRowMapper(MDNS.class)); return forwardlistdns; } @Override public List getreversednsentry() { List reverselistdns = jtm.query("SELECT * FROM DNS where reversedns is not null group by dnszone", new BeanPropertyRowMapper(MDNS.class)); return reverselistdns; } @Override public Long getForwarddnsCount() { Long forwardlistdnscount = jtm.queryForObject("select count(dnszone) from dns where forwarddns is not null group by dnszone", Long.class); return forwardlistdnscount; } /** * * @return */ @Override public Long getReversednsCount() { Long forwardlistdnscount = jtm.queryForObject("select count(dnszone) from dns where reversedns is not null group by dnszone", Long.class); return forwardlistdnscount; } /* write File to /etc/bind File name named.conf.options */ @Override public void createnamedconfoptions() { FileWriter fw; try { BufferedWriter bw = null; File file = new File("/etc/bind/named.conf.options"); String stcommend = new String(";namedconfoptions" + "\n" + "\n"); String stoptnamedconf = new String("options {\n" + " directory \"/etc/bind\";\n" + " recursion no;\n" + " listen-on port 53 { localhost; 192.168.178.0/24; };\n" + " allow-recursion { none; };\n" + " allow-query { localhost; 192.168.178.0/24; };\n" + " allow-query-cache { none; };\n" + " \n" + " forwarders {\n" + " 8.8.8.8;\n" + " 8.8.4.4;\n" + " };\n" + "};"); fw = new FileWriter(file); bw = new BufferedWriter(fw); bw.write (stcommend); // check that file is gernated // ;namedconfoptions bw.write(stoptnamedconf); bw.close(); } catch (IOException ex) { Logger.getLogger(DaoDnsEntry.class.getName()).log(Level.SEVERE, null, ex); } } /** * named.conf.local */ @Override public void createnamedconflocal() { /* get forward dns entry in free version it getīs only one entry the index is -> 0 */ List getdnsentry = null; if(getdnsentry == null) { getdnsentry = (List)getforwarddnsentry(); } // static wan ip String stindernetip = null; if(stindernetip == null) { stindernetip = getdnsentry.get(0).getForwarddns(); } else { stindernetip = "127.0.0.1"; } // fqdn of your email server // mail.demogitjava.de String stdomainmailserver = null; if(stdomainmailserver == null) { stdomainmailserver = "mail." + getdnsentry.get(0).getDnszone(); } else { stdomainmailserver = "mail.localhost.de"; } // fqdn of your internet address // demgitjava.de String stdomain = null; if(stdomain == null) { stdomain = (String) getdnsentry.get(0).getDnszone(); // domain name } else { stdomain = "localhost"; } /* create file named.conf.local path /etc/bind */ // /etc/bind/named.conf.local File file1 = new File("/etc/bind/named.conf.local"); FileWriter fw1; try { BufferedWriter bw1 = null; fw1 = new FileWriter(file1); bw1 = new BufferedWriter(fw1); String stzonename = new String("zone " + '"' + stdomain + '"'+ " {" + "\n" + " " + "type master;" + "\n" + " " + "file " + '"' + "/etc/bind/" + stdomain + '"' + ";" + "\n" + " " + "allow-query { none; }" + ";" +"\n" + " " + "allow-tranfer { none; }" + ";"+ "\n"+ "};"); bw1.write(stzonename); String stnewline = new String(); bw1.write(stnewline + "\n"); bw1.write(stnewline + "\n"); /* get reverse dns entry only one entry the index is -> 0 by query getreversednsentry(); */ String reservefilename = null; List resevelist = getreversednsentry(); // get name form query reservefilename = resevelist.get(0).getDnszone(); File reservefile = new File("/etc/bind/" + "reserve" + reservefilename); /* write reverse file data to file named.conf.local */ String streversezonename = new String("zone " + '"' + "reverse" + reservefilename + '"'+ " {" + "\n" + " " + "type master;" + "\n" + " " + "file " + '"' + "/etc/bind/" + "reverse" + reservefilename + '"' + ";" + "\n" + " " + "allow-query { none; }" + ";" +"\n" + " " + "allow-tranfer { none; }" + ";"+ "\n"+ "};"); bw1.write(streversezonename); File reservefilebind = new File("/etc/bind/" + "reverse" + reservefilename); createreversefile(); bw1.close(); fw1.close(); } catch (IOException ex) { Logger.getLogger(DaoDnsEntry.class.getName()).log(Level.SEVERE, null, ex); } /* create forward dns lookup zone from table DNS */ FileWriter fw; try { BufferedWriter bw = null; /* FORWARD FILE */ // db forward name // like db.demogitjava.de File file = new File("/etc/bind/" + stdomain); String stnamedconflocal = new String(";namedconflocal" + "\n" + "\n"); String sttl = new String("$TTL 86400 ; default TTL for this zone (this 1 day)" + "\n"); // TTL String storgin = new String("$ORIGIN " + stdomain +"." + "\n"); // base domain name String stsoa = new String( "@ IN SOA " + stdomain + ". " + "root." + stdomain + ". " + "(" + "\n" + " 2019011502" + "\n" + // Serial number " 604800" + "\n" + // Refesh " 86400" + "\n" + // Retry " 2419200" + "\n" + // Expire " 86400 " + ")" + "\n"); String stnameserver = new String("" + "@ IN NS " + stdomain + "." + "\n"); // nameserver String stmailserver = new String("@ IN MX " + stdomainmailserver + "." + "\n"); String starecords = new String("" + "@ IN A " + stindernetip + "\n" + "www IN A " + stindernetip + "\n" + "@ IN CNAME " + " " + stdomain + "\n"); // writer.append(' '); // String stoptnamedconf = new String(""); fw = new FileWriter(file); bw = new BufferedWriter(fw); bw.write (stnamedconflocal); // check that file is gernated bw.write(sttl); bw.write(storgin);// ;namedconflocal bw.write(stsoa); bw.write(stnameserver); bw.write(stmailserver); bw.write(starecords); bw.write(stoptnamedconf); bw.close(); fw.close(); } catch (IOException ex) { Logger.getLogger(DaoDnsEntry.class.getName()).log(Level.SEVERE, null, ex); } } /* File file1 = new File("/etc/bind/named.conf.local"); FileWriter fw1; try { BufferedWriter bw1 = null; fw1 = new FileWriter(file1); bw1 = new BufferedWriter(fw1); */ @Override public void createreversefile() { List reverselist = (List) getreversednsentry(); String stfilename = reverselist.get(0).getDnszone(); File reversefile = new File("/etc/bind/" + "reserve" + stfilename); FileWriter rfw; try { BufferedWriter rbw = null; rfw = new FileWriter(reversefile); rbw = new BufferedWriter(rfw); String sttl = new String("$TTL 86400 ; default TTL for this zone (this 1 day)" + "\n"); // TTL String stsoa = new String( "@ IN SOA " + stfilename + ". " + "root." + stfilename + ". " + "(" + "\n" + " 2019011502" + "\n" + // Serial number " 604800" + "\n" + // Refesh " 86400" + "\n" + // Retry " 2419200" + "\n" + // Expire " 86400 " + ")" + "\n"); String stnameserver = new String("" + "@ IN NS " + stfilename + "." + "\n"); // nameserver String stnameserver1 = new String("" + "100 IN PTR " + stfilename + "." + "\n"); // nameserver rfw = new FileWriter(reversefile); rbw = new BufferedWriter(rfw); rbw.write(sttl); rbw.write(stsoa); rbw.write(stnameserver); rbw.write(stnameserver1); rbw.close(); rfw.close(); } catch (Exception e) { System.out.print("Fehler " + e); } } /* save forward entity to table dns */ @Override public void saveforward(MDNS mdns) { Integer dnscount = (Integer) getdnscount(); if(dnscount == 0) { dnscount = Integer.valueOf(1); mdns.setId(dnscount); } else { dnscount = getdnscount() + 1; mdns.setId(dnscount); } jtm.update("insert into dns " + "(id, forwarddns, reversedns, dnszone, dnstype) " + "values (?, ?, ?, ?, ?)", mdns.getId(), mdns.getForwarddns(), mdns.getReversedns(), mdns.getDnszone(), mdns.getDnstype()); } @Override public void savereverse(MDNS mdns) { Integer dnscount = (Integer) getdnscount(); if(dnscount == 0) { dnscount = Integer.valueOf(1); mdns.setId(dnscount); } else { dnscount = getdnscount() + 1; mdns.setId(dnscount); } jtm.update("insert into dns " + "(id, forwarddns, reversedns, dnszone, dnstype) " + "values (?, ?, ?, ?, ?)", mdns.getId(), mdns.getForwarddns(), mdns.getReversedns(), mdns.getDnszone(), mdns.getDnstype()); } @Override public Integer getdnscount() { Integer dnscount = jtm.queryForObject("SELECT COUNT(*) from dns", Integer.class); return dnscount; } /** * * @return */ @Override public List findAllEntry() { return jpadb.findAll(); } }