PVE/Network/SDN/Dns/Plugin.pm

   1 package PVE::Network::SDN::Dns::Plugin;
   2
   3 use strict;
   4 use warnings;
   5
   6 use PVE::Tools qw(run_command);
   7 use PVE::JSONSchema;
   8 use PVE::Cluster;
   9 use HTTP::Request;
  10 use LWP::UserAgent;
  11 use JSON;
  12
  13 use Data::Dumper;
  14 use PVE::JSONSchema qw(get_standard_option);
  15 use base qw(PVE::SectionConfig);
  16
  17 PVE::Cluster::cfs_register_file('sdn/dns.cfg',
  18                                  sub { __PACKAGE__->parse_config(@_); },
  19                                  sub { __PACKAGE__->write_config(@_); });
  20
  21 PVE::JSONSchema::register_standard_option('pve-sdn-dns-id', {
  22     description => "The SDN dns object identifier.",
  23     type => 'string', format => 'pve-sdn-dns-id',
  24 });
  25
  26 PVE::JSONSchema::register_format('pve-sdn-dns-id', \&parse_sdn_dns_id);
  27 sub parse_sdn_dns_id {
  28     my ($id, $noerr) = @_;
  29
  30     if ($id !~ m/^[a-z][a-z0-9]*[a-z0-9]$/i) {
  31         return undef if $noerr;
  32         die "dns ID '$id' contains illegal characters\n";
  33     }
  34     return $id;
  35 }
  36
  37 my $defaultData = {
  38
  39     propertyList => {
  40         type => {
  41             description => "Plugin type.",
  42             type => 'string', format => 'pve-configid',
  43         },
  44         ttl => { type => 'integer', optional => 1 },
  45         dns => get_standard_option('pve-sdn-dns-id',
  46             { completion => \&PVE::Network::SDN::Dns::complete_sdn_dns }),
  47     },
  48 };
  49
  50 sub private {
  51     return $defaultData;
  52 }
  53
  54 sub parse_section_header {
  55     my ($class, $line) = @_;
  56
  57     if ($line =~ m/^(\S+):\s*(\S+)\s*$/) {
  58         my ($type, $id) = (lc($1), $2);
  59         my $errmsg = undef; # set if you want to skip whole section
  60         eval { PVE::JSONSchema::pve_verify_configid($type); };
  61         $errmsg = $@ if $@;
  62         my $config = {}; # to return additional attributes
  63         return ($type, $id, $errmsg, $config);
  64     }
  65     return undef;
  66 }
  67
  68
  69 sub add_a_record {
  70     my ($class, $plugin_config, $type, $zone, $reversezone, $hostname, $ip) = @_;
  71 }
  72
  73 sub del_a_record {
  74     my ($class, $plugin_config, $hostname, $ip) = @_;
  75 }
  76
  77 sub on_update_hook {
  78     my ($class, $plugin_config) = @_;
  79 }
  80
  81 #helpers
  82 sub api_request {
  83     my ($method, $url, $headers, $data) = @_;
  84
  85     my $encoded_data = to_json($data) if $data;
  86
  87     my $req = HTTP::Request->new($method,$url, $headers, $encoded_data);
  88
  89     my $ua = LWP::UserAgent->new(protocols_allowed => ['http', 'https'], timeout => 30);
  90     my $proxy = undef;
  91
  92     if ($proxy) {
  93         $ua->proxy(['http', 'https'], $proxy);
  94     } else {
  95         $ua->env_proxy;
  96     }
  97
  98     $ua->ssl_opts(verify_hostname => 0, SSL_verify_mode => 0x00);
  99
 100     my $response = $ua->request($req);
 101     my $code = $response->code;
 102
 103     if ($code !~ /^2(\d+)$/) {
 104         my $msg = $response->message || 'unknown';
 105         die "Invalid response from server: $code $msg\n";
 106     }
 107
 108     my $raw = '';
 109     if (defined($response->decoded_content)) {
 110         $raw = $response->decoded_content;
 111     } else {
 112         $raw = $response->content;
 113     }
 114     return from_json($raw) if $raw ne '';
 115 }
 116
 117 1;