[pve-network.git] / PVE / API2 / Network / SDN / Subnets.pm

package PVE::API2::Network::SDN::Subnets;

use strict;
use warnings;

use PVE::SafeSyslog;
use PVE::Tools qw(extract_param);
use PVE::Cluster qw(cfs_read_file cfs_write_file);
use PVE::Exception qw(raise raise_param_exc);
use PVE::Network::SDN;
use PVE::Network::SDN::Subnets;
use PVE::Network::SDN::SubnetPlugin;
use PVE::Network::SDN::Vnets;
use PVE::Network::SDN::Zones;
use PVE::Network::SDN::Ipams;
use PVE::Network::SDN::Ipams::Plugin;

use Storable qw(dclone);
use PVE::JSONSchema qw(get_standard_option);
use PVE::RPCEnvironment;

use PVE::RESTHandler;

use base qw(PVE::RESTHandler);

my $api_sdn_subnets_config = sub {
    my ($cfg, $id) = @_;

    my $scfg = dclone(PVE::Network::SDN::Subnets::sdn_subnets_config($cfg, $id));
    $scfg->{subnet} = $id;
    $scfg->{cidr} = $id =~ s/-/\//r;
    $scfg->{digest} = $cfg->{digest};

    return $scfg;
};

__PACKAGE__->register_method ({
    name => 'index',
    path => '',
    method => 'GET',
    description => "SDN subnets index.",
    permissions => {
	description => "Only list entries where you have 'SDN.Audit' or 'SDN.Allocate' permissions on '/sdn/subnets/<subnet>'",
	user => 'all',
    },
    parameters => {
	additionalProperties => 0,
	properties => {
	    vnet => get_standard_option('pve-sdn-vnet-id'),
	    running => {
		type => 'boolean',
		optional => 1,
		description => "Display running config.",
	    },
	    pending => {
		type => 'boolean',
		optional => 1,
		description => "Display pending config.",
	    },
        },
    },
    returns => {
	type => 'array',
	items => {
	    type => "object",
	    properties => {},
	},
	links => [ { rel => 'child', href => "{subnet}" } ],
    },
    code => sub {
	my ($param) = @_;

	my $rpcenv = PVE::RPCEnvironment::get();
	my $authuser = $rpcenv->get_user();

        my $vnetid = $param->{vnet};

        my $cfg = {};
        if($param->{pending}) {
	    my $running_cfg = PVE::Network::SDN::config();
	    my $config = PVE::Network::SDN::Subnets::config();
	    $cfg = PVE::Network::SDN::pending_config($running_cfg, $config, 'subnets');
        } elsif ($param->{running}) {
	    my $running_cfg = PVE::Network::SDN::config();
	    $cfg = $running_cfg->{subnets};
        } else {
	    $cfg = PVE::Network::SDN::Subnets::config();
        }

	my @sids = PVE::Network::SDN::Subnets::sdn_subnets_ids($cfg);
	my $res = [];
	foreach my $id (@sids) {
	    my $privs = [ 'SDN.Audit', 'SDN.Allocate' ];
	    next if !$rpcenv->check_any($authuser, "/sdn/vnets/$vnetid/subnets/$id", $privs, 1);

	    my $scfg = &$api_sdn_subnets_config($cfg, $id);
	    next if !$scfg->{vnet} || $scfg->{vnet} ne $vnetid;
	    push @$res, $scfg;
	}

	return $res;
    }});

__PACKAGE__->register_method ({
    name => 'read',
    path => '{subnet}',
    method => 'GET',
    description => "Read sdn subnet configuration.",
    permissions => {
	check => ['perm', '/sdn/vnets/{vnet}/subnets/{subnet}', ['SDN.Allocate']],
   },

    parameters => {
	additionalProperties => 0,
	properties => {
	    vnet => get_standard_option('pve-sdn-vnet-id'),
	    subnet => get_standard_option('pve-sdn-subnet-id', {
		completion => \&PVE::Network::SDN::Subnets::complete_sdn_subnets,
	    }),
	    running => {
		type => 'boolean',
		optional => 1,
		description => "Display running config.",
	    },
	    pending => {
		type => 'boolean',
		optional => 1,
		description => "Display pending config.",
	    },
        },
    },
    returns => { type => 'object' },
    code => sub {
	my ($param) = @_;

        my $cfg = {};
        if($param->{pending}) {
	    my $running_cfg = PVE::Network::SDN::config();
	    my $config = PVE::Network::SDN::Subnets::config();
	    $cfg = PVE::Network::SDN::pending_config($running_cfg, $config, 'subnets');
        } elsif ($param->{running}) {
	    my $running_cfg = PVE::Network::SDN::config();
	    $cfg = $running_cfg->{subnets};
        } else {
	    $cfg = PVE::Network::SDN::Subnets::config();
        }

        my $scfg = &$api_sdn_subnets_config($cfg, $param->{subnet});

	raise_param_exc({ vnet => "wrong vnet"}) if $param->{vnet} ne $scfg->{vnet};

	return $scfg;
    }});

__PACKAGE__->register_method ({
    name => 'create',
    protected => 1,
    path => '',
    method => 'POST',
    description => "Create a new sdn subnet object.",
    permissions => {
	check => ['perm', '/sdn/vnets/{vnet}/subnets', ['SDN.Allocate']],
    },
    parameters => PVE::Network::SDN::SubnetPlugin->createSchema(),
    returns => { type => 'null' },
    code => sub {
	my ($param) = @_;

	my $type = extract_param($param, 'type');
	my $cidr = extract_param($param, 'subnet');
	my $id = $cidr =~ s/\//-/r;

	# create /etc/pve/sdn directory
	PVE::Cluster::check_cfs_quorum();
	mkdir("/etc/pve/sdn") if ! -d '/etc/pve/sdn';

        PVE::Network::SDN::lock_sdn_config(
	    sub {

		my $cfg = PVE::Network::SDN::Subnets::config();
		my $zone_cfg = PVE::Network::SDN::Zones::config();
		my $vnet_cfg = PVE::Network::SDN::Vnets::config();
		my $vnet = $param->{vnet};
		my $zoneid = $vnet_cfg->{ids}->{$vnet}->{zone};
		my $zone = $zone_cfg->{ids}->{$zoneid};      

		my $opts = PVE::Network::SDN::SubnetPlugin->check_config($id, $param, 1, 1);

		my $scfg = undef;
		if ($scfg = PVE::Network::SDN::Subnets::sdn_subnets_config($cfg, $id, 1)) {
		    die "sdn subnet object ID '$id' already defined\n";
		}

		$cfg->{ids}->{$id} = $opts;
		PVE::Network::SDN::SubnetPlugin->on_update_hook($zone, $id, $opts);

		PVE::Network::SDN::Subnets::write_config($cfg);

	    }, "create sdn subnet object failed");

	return undef;
    }});

__PACKAGE__->register_method ({
    name => 'update',
    protected => 1,
    path => '{subnet}',
    method => 'PUT',
    description => "Update sdn subnet object configuration.",
    permissions => {
	check => ['perm', '/sdn/vnets/{vnet}/subnets', ['SDN.Allocate']],
    },
    parameters => PVE::Network::SDN::SubnetPlugin->updateSchema(),
    returns => { type => 'null' },
    code => sub {
	my ($param) = @_;

	my $id = extract_param($param, 'subnet');
	my $digest = extract_param($param, 'digest');

        PVE::Network::SDN::lock_sdn_config(
	 sub {

	    my $cfg = PVE::Network::SDN::Subnets::config();
	    my $zone_cfg = PVE::Network::SDN::Zones::config();
	    my $vnet_cfg = PVE::Network::SDN::Vnets::config();
	    my $vnet = $param->{vnet};
	    my $zoneid = $vnet_cfg->{ids}->{$vnet}->{zone};
	    my $zone = $zone_cfg->{ids}->{$zoneid};

	    my $scfg = &$api_sdn_subnets_config($cfg, $id);

	    PVE::SectionConfig::assert_if_modified($cfg, $digest);

	    my $opts = PVE::Network::SDN::SubnetPlugin->check_config($id, $param, 0, 1);
	    $cfg->{ids}->{$id} = $opts;

	    raise_param_exc({ ipam => "you can't change ipam"}) if $opts->{ipam} && $scfg->{ipam} && $opts->{ipam} ne $scfg->{ipam};

	    PVE::Network::SDN::SubnetPlugin->on_update_hook($zone, $id, $opts, $scfg);

	    PVE::Network::SDN::Subnets::write_config($cfg);

	    }, "update sdn subnet object failed");

	return undef;
    }});

__PACKAGE__->register_method ({
    name => 'delete',
    protected => 1,
    path => '{subnet}',
    method => 'DELETE',
    description => "Delete sdn subnet object configuration.",
    permissions => {
	check => ['perm', '/sdn/vnets/{vnet}/subnets', ['SDN.Allocate']],
    },
    parameters => {
	additionalProperties => 0,
	properties => {
            vnet => get_standard_option('pve-sdn-vnet-id'),
	    subnet => get_standard_option('pve-sdn-subnet-id', {
                completion => \&PVE::Network::SDN::Subnets::complete_sdn_subnets,
            }),
	},
    },
    returns => { type => 'null' },
    code => sub {
	my ($param) = @_;

	my $id = extract_param($param, 'subnet');

        PVE::Network::SDN::lock_sdn_config(
	    sub {
		my $cfg = PVE::Network::SDN::Subnets::config();

		my $scfg = PVE::Network::SDN::Subnets::sdn_subnets_config($cfg, $id);

		my $subnets_cfg = PVE::Network::SDN::Subnets::config();
		my $vnets_cfg = PVE::Network::SDN::Vnets::config();

		PVE::Network::SDN::SubnetPlugin->on_delete_hook($id, $subnets_cfg, $vnets_cfg);

		my $ipam_cfg = PVE::Network::SDN::Ipams::config();
		my $ipam = $cfg->{ids}->{$id}->{ipam};
		if ($ipam) {
		    raise_param_exc({ ipam => "$ipam not existing"}) if !$ipam_cfg->{ids}->{$ipam};
		    my $plugin_config = $ipam_cfg->{ids}->{$ipam};
		    my $plugin = PVE::Network::SDN::Ipams::Plugin->lookup($plugin_config->{type});
		    $plugin->del_subnet($plugin_config, $id, $scfg);
		}

		delete $cfg->{ids}->{$id};

		PVE::Network::SDN::Subnets::write_config($cfg);

	    }, "delete sdn subnet object failed");


	return undef;
    }});

1;
Commit	Line	Data
c33dd818 AD	1	package PVE::API2::Network::SDN::Subnets;
	2
	3	use strict;
	4	use warnings;
	5
	6	use PVE::SafeSyslog;
	7	use PVE::Tools qw(extract_param);
	8	use PVE::Cluster qw(cfs_read_file cfs_write_file);
70b03506	9	use PVE::Exception qw(raise raise_param_exc);
c33dd818 AD	10	use PVE::Network::SDN;
	11	use PVE::Network::SDN::Subnets;
	12	use PVE::Network::SDN::SubnetPlugin;
58a7773a	13	use PVE::Network::SDN::Vnets;
4ad78442	14	use PVE::Network::SDN::Zones;
70b03506 AD	15	use PVE::Network::SDN::Ipams;
70b03506 AD	16	use PVE::Network::SDN::Ipams::Plugin;
c33dd818 AD	17
	18	use Storable qw(dclone);
	19	use PVE::JSONSchema qw(get_standard_option);
	20	use PVE::RPCEnvironment;
	21
	22	use PVE::RESTHandler;
	23
	24	use base qw(PVE::RESTHandler);
	25
	26	my $api_sdn_subnets_config = sub {
	27	my ($cfg, $id) = @_;
	28
	29	my $scfg = dclone(PVE::Network::SDN::Subnets::sdn_subnets_config($cfg, $id));
	30	$scfg->{subnet} = $id;
	31	$scfg->{cidr} = $id =~ s/-/\//r;
	32	$scfg->{digest} = $cfg->{digest};
	33
	34	return $scfg;
	35	};
	36
	37	__PACKAGE__->register_method ({
	38	name => 'index',
	39	path => '',
	40	method => 'GET',
	41	description => "SDN subnets index.",
	42	permissions => {
	43	description => "Only list entries where you have 'SDN.Audit' or 'SDN.Allocate' permissions on '/sdn/subnets/<subnet>'",
	44	user => 'all',
	45	},
	46	parameters => {
	47	additionalProperties => 0,
3926d9a7 AD	48	properties => {
3926d9a7 AD	49	vnet => get_standard_option('pve-sdn-vnet-id'),
6f5f42e4 AD	50	running => {
	51	type => 'boolean',
	52	optional => 1,
	53	description => "Display running config.",
	54	},
	55	pending => {
	56	type => 'boolean',
	57	optional => 1,
	58	description => "Display pending config.",
	59	},
	60	},
c33dd818 AD	61	},
	62	returns => {
	63	type => 'array',
	64	items => {
	65	type => "object",
	66	properties => {},
	67	},
	68	links => [ { rel => 'child', href => "{subnet}" } ],
	69	},
	70	code => sub {
	71	my ($param) = @_;
	72
	73	my $rpcenv = PVE::RPCEnvironment::get();
	74	my $authuser = $rpcenv->get_user();
	75
3926d9a7	76	my $vnetid = $param->{vnet};
c33dd818	77
6f5f42e4 AD	78	my $cfg = {};
	79	if($param->{pending}) {
	80	my $running_cfg = PVE::Network::SDN::config();
	81	my $config = PVE::Network::SDN::Subnets::config();
	82	$cfg = PVE::Network::SDN::pending_config($running_cfg, $config, 'subnets');
	83	} elsif ($param->{running}) {
	84	my $running_cfg = PVE::Network::SDN::config();
	85	$cfg = $running_cfg->{subnets};
	86	} else {
	87	$cfg = PVE::Network::SDN::Subnets::config();
	88	}
c33dd818 AD	89
	90	my @sids = PVE::Network::SDN::Subnets::sdn_subnets_ids($cfg);
	91	my $res = [];
	92	foreach my $id (@sids) {
	93	my $privs = [ 'SDN.Audit', 'SDN.Allocate' ];
3926d9a7	94	next if !$rpcenv->check_any($authuser, "/sdn/vnets/$vnetid/subnets/$id", $privs, 1);
c33dd818 AD	95
c33dd818 AD	96	my $scfg = &$api_sdn_subnets_config($cfg, $id);
3926d9a7	97	next if !$scfg->{vnet} \|\| $scfg->{vnet} ne $vnetid;
c33dd818 AD	98	push @$res, $scfg;
	99	}
	100
	101	return $res;
	102	}});
	103
	104	__PACKAGE__->register_method ({
	105	name => 'read',
	106	path => '{subnet}',
	107	method => 'GET',
	108	description => "Read sdn subnet configuration.",
	109	permissions => {
3926d9a7	110	check => ['perm', '/sdn/vnets/{vnet}/subnets/{subnet}', ['SDN.Allocate']],
c33dd818 AD	111	},
	112
	113	parameters => {
	114	additionalProperties => 0,
	115	properties => {
3926d9a7	116	vnet => get_standard_option('pve-sdn-vnet-id'),
c33dd818 AD	117	subnet => get_standard_option('pve-sdn-subnet-id', {
	118	completion => \&PVE::Network::SDN::Subnets::complete_sdn_subnets,
	119	}),
6f5f42e4 AD	120	running => {
	121	type => 'boolean',
	122	optional => 1,
	123	description => "Display running config.",
	124	},
	125	pending => {
	126	type => 'boolean',
	127	optional => 1,
	128	description => "Display pending config.",
	129	},
	130	},
c33dd818 AD	131	},
	132	returns => { type => 'object' },
	133	code => sub {
	134	my ($param) = @_;
	135
6f5f42e4 AD	136	my $cfg = {};
	137	if($param->{pending}) {
	138	my $running_cfg = PVE::Network::SDN::config();
	139	my $config = PVE::Network::SDN::Subnets::config();
	140	$cfg = PVE::Network::SDN::pending_config($running_cfg, $config, 'subnets');
	141	} elsif ($param->{running}) {
	142	my $running_cfg = PVE::Network::SDN::config();
	143	$cfg = $running_cfg->{subnets};
	144	} else {
	145	$cfg = PVE::Network::SDN::Subnets::config();
	146	}
	147
3926d9a7 AD	148	my $scfg = &$api_sdn_subnets_config($cfg, $param->{subnet});
	149
	150	raise_param_exc({ vnet => "wrong vnet"}) if $param->{vnet} ne $scfg->{vnet};
c33dd818	151
3926d9a7	152	return $scfg;
c33dd818 AD	153	}});
	154
	155	__PACKAGE__->register_method ({
	156	name => 'create',
	157	protected => 1,
	158	path => '',
	159	method => 'POST',
	160	description => "Create a new sdn subnet object.",
	161	permissions => {
3926d9a7	162	check => ['perm', '/sdn/vnets/{vnet}/subnets', ['SDN.Allocate']],
c33dd818 AD	163	},
	164	parameters => PVE::Network::SDN::SubnetPlugin->createSchema(),
	165	returns => { type => 'null' },
	166	code => sub {
	167	my ($param) = @_;
	168
	169	my $type = extract_param($param, 'type');
	170	my $cidr = extract_param($param, 'subnet');
	171	my $id = $cidr =~ s/\//-/r;
	172
	173	# create /etc/pve/sdn directory
	174	PVE::Cluster::check_cfs_quorum();
	175	mkdir("/etc/pve/sdn") if ! -d '/etc/pve/sdn';
	176
	177	PVE::Network::SDN::lock_sdn_config(
	178	sub {
	179
	180	my $cfg = PVE::Network::SDN::Subnets::config();
4ad78442 AD	181	my $zone_cfg = PVE::Network::SDN::Zones::config();
	182	my $vnet_cfg = PVE::Network::SDN::Vnets::config();
	183	my $vnet = $param->{vnet};
	184	my $zoneid = $vnet_cfg->{ids}->{$vnet}->{zone};
	185	my $zone = $zone_cfg->{ids}->{$zoneid};
	186
c33dd818 AD	187	my $opts = PVE::Network::SDN::SubnetPlugin->check_config($id, $param, 1, 1);
	188
	189	my $scfg = undef;
	190	if ($scfg = PVE::Network::SDN::Subnets::sdn_subnets_config($cfg, $id, 1)) {
	191	die "sdn subnet object ID '$id' already defined\n";
	192	}
	193
	194	$cfg->{ids}->{$id} = $opts;
4ad78442	195	PVE::Network::SDN::SubnetPlugin->on_update_hook($zone, $id, $opts);
70b03506	196
c33dd818	197	PVE::Network::SDN::Subnets::write_config($cfg);
c33dd818 AD	198
	199	}, "create sdn subnet object failed");
	200
	201	return undef;
	202	}});
	203
	204	__PACKAGE__->register_method ({
	205	name => 'update',
	206	protected => 1,
	207	path => '{subnet}',
	208	method => 'PUT',
	209	description => "Update sdn subnet object configuration.",
	210	permissions => {
3926d9a7	211	check => ['perm', '/sdn/vnets/{vnet}/subnets', ['SDN.Allocate']],
c33dd818 AD	212	},
	213	parameters => PVE::Network::SDN::SubnetPlugin->updateSchema(),
	214	returns => { type => 'null' },
	215	code => sub {
	216	my ($param) = @_;
	217
	218	my $id = extract_param($param, 'subnet');
	219	my $digest = extract_param($param, 'digest');
	220
	221	PVE::Network::SDN::lock_sdn_config(
	222	sub {
	223
	224	my $cfg = PVE::Network::SDN::Subnets::config();
4ad78442 AD	225	my $zone_cfg = PVE::Network::SDN::Zones::config();
	226	my $vnet_cfg = PVE::Network::SDN::Vnets::config();
	227	my $vnet = $param->{vnet};
	228	my $zoneid = $vnet_cfg->{ids}->{$vnet}->{zone};
	229	my $zone = $zone_cfg->{ids}->{$zoneid};
	230
70b03506	231	my $scfg = &$api_sdn_subnets_config($cfg, $id);
c33dd818 AD	232
	233	PVE::SectionConfig::assert_if_modified($cfg, $digest);
	234
	235	my $opts = PVE::Network::SDN::SubnetPlugin->check_config($id, $param, 0, 1);
	236	$cfg->{ids}->{$id} = $opts;
	237
9dfa9202 AD	238	raise_param_exc({ ipam => "you can't change ipam"}) if $opts->{ipam} && $scfg->{ipam} && $opts->{ipam} ne $scfg->{ipam};
9dfa9202 AD	239
4ad78442	240	PVE::Network::SDN::SubnetPlugin->on_update_hook($zone, $id, $opts, $scfg);
70b03506	241
c33dd818	242	PVE::Network::SDN::Subnets::write_config($cfg);
c33dd818 AD	243
	244	}, "update sdn subnet object failed");
	245
	246	return undef;
	247	}});
	248
	249	__PACKAGE__->register_method ({
	250	name => 'delete',
	251	protected => 1,
	252	path => '{subnet}',
	253	method => 'DELETE',
	254	description => "Delete sdn subnet object configuration.",
	255	permissions => {
3926d9a7	256	check => ['perm', '/sdn/vnets/{vnet}/subnets', ['SDN.Allocate']],
c33dd818 AD	257	},
	258	parameters => {
	259	additionalProperties => 0,
	260	properties => {
3926d9a7	261	vnet => get_standard_option('pve-sdn-vnet-id'),
c33dd818 AD	262	subnet => get_standard_option('pve-sdn-subnet-id', {
	263	completion => \&PVE::Network::SDN::Subnets::complete_sdn_subnets,
	264	}),
	265	},
	266	},
	267	returns => { type => 'null' },
	268	code => sub {
	269	my ($param) = @_;
	270
	271	my $id = extract_param($param, 'subnet');
	272
	273	PVE::Network::SDN::lock_sdn_config(
	274	sub {
c33dd818 AD	275	my $cfg = PVE::Network::SDN::Subnets::config();
	276
	277	my $scfg = PVE::Network::SDN::Subnets::sdn_subnets_config($cfg, $id);
	278
58a7773a AD	279	my $subnets_cfg = PVE::Network::SDN::Subnets::config();
58a7773a AD	280	my $vnets_cfg = PVE::Network::SDN::Vnets::config();
c33dd818	281
58a7773a	282	PVE::Network::SDN::SubnetPlugin->on_delete_hook($id, $subnets_cfg, $vnets_cfg);
70b03506 AD	283
	284	my $ipam_cfg = PVE::Network::SDN::Ipams::config();
	285	my $ipam = $cfg->{ids}->{$id}->{ipam};
	286	if ($ipam) {
	287	raise_param_exc({ ipam => "$ipam not existing"}) if !$ipam_cfg->{ids}->{$ipam};
	288	my $plugin_config = $ipam_cfg->{ids}->{$ipam};
	289	my $plugin = PVE::Network::SDN::Ipams::Plugin->lookup($plugin_config->{type});
	290	$plugin->del_subnet($plugin_config, $id, $scfg);
	291	}
	292
	293	delete $cfg->{ids}->{$id};
	294
c33dd818	295	PVE::Network::SDN::Subnets::write_config($cfg);
c33dd818 AD	296
	297	}, "delete sdn subnet object failed");
	298
	299
	300	return undef;
	301	}});
	302
	303	1;