]> git.proxmox.com Git - pve-common.git/blame - src/PVE/JSONSchema.pm
bump version to 5.0-29
[pve-common.git] / src / PVE / JSONSchema.pm
CommitLineData
e143e9d8
DM
1package PVE::JSONSchema;
2
e143e9d8 3use strict;
c36f332e 4use warnings;
e143e9d8
DM
5use Storable; # for dclone
6use Getopt::Long;
24197a9f
DM
7use Encode::Locale;
8use Encode;
e143e9d8 9use Devel::Cycle -quiet; # todo: remove?
e272bcb7 10use PVE::Tools qw(split_list $IPV6RE $IPV4RE);
e143e9d8
DM
11use PVE::Exception qw(raise);
12use HTTP::Status qw(:constants);
23b56245 13use Net::IP qw(:PROC);
bf27456b 14use Data::Dumper;
e143e9d8
DM
15
16use base 'Exporter';
17
18our @EXPORT_OK = qw(
19register_standard_option
20get_standard_option
21);
22
23# Note: This class implements something similar to JSON schema, but it is not 100% complete.
24# see: http://tools.ietf.org/html/draft-zyp-json-schema-02
25# see: http://json-schema.org/
26
27# the code is similar to the javascript parser from http://code.google.com/p/jsonschema/
28
29my $standard_options = {};
30sub register_standard_option {
31 my ($name, $schema) = @_;
32
33 die "standard option '$name' already registered\n"
34 if $standard_options->{$name};
35
36 $standard_options->{$name} = $schema;
37}
38
39sub get_standard_option {
40 my ($name, $base) = @_;
41
42 my $std = $standard_options->{$name};
3432ae0c 43 die "no such standard option '$name'\n" if !$std;
e143e9d8
DM
44
45 my $res = $base || {};
46
47 foreach my $opt (keys %$std) {
c38ac70f 48 next if defined($res->{$opt});
e143e9d8
DM
49 $res->{$opt} = $std->{$opt};
50 }
51
52 return $res;
53};
54
55register_standard_option('pve-vmid', {
56 description => "The (unique) ID of the VM.",
57 type => 'integer', format => 'pve-vmid',
58 minimum => 1
59});
60
61register_standard_option('pve-node', {
62 description => "The cluster node name.",
63 type => 'string', format => 'pve-node',
64});
65
66register_standard_option('pve-node-list', {
67 description => "List of cluster node names.",
68 type => 'string', format => 'pve-node-list',
69});
70
71register_standard_option('pve-iface', {
72 description => "Network interface name.",
73 type => 'string', format => 'pve-iface',
74 minLength => 2, maxLength => 20,
75});
76
28a2669d 77register_standard_option('pve-storage-id', {
05e787c5
DM
78 description => "The storage identifier.",
79 type => 'string', format => 'pve-storage-id',
80});
81
28a2669d 82register_standard_option('pve-config-digest', {
dc5eae7d
DM
83 description => 'Prevent changes if current configuration file has different SHA1 digest. This can be used to prevent concurrent modifications.',
84 type => 'string',
85 optional => 1,
86 maxLength => 40, # sha1 hex digest lenght is 40
87});
88
26bcdf92
WB
89register_standard_option('skiplock', {
90 description => "Ignore locks - only root is allowed to use this option.",
91 type => 'boolean',
92 optional => 1,
93});
94
28a2669d 95register_standard_option('extra-args', {
5851be88
WB
96 description => "Extra arguments as array",
97 type => 'array',
98 items => { type => 'string' },
99 optional => 1
100});
101
b21cf575
TL
102register_standard_option('fingerprint-sha256', {
103 description => "Certificate SHA 256 fingerprint.",
104 type => 'string',
105 pattern => '([A-Fa-f0-9]{2}:){31}[A-Fa-f0-9]{2}',
106});
107
e143e9d8
DM
108my $format_list = {};
109
110sub register_format {
111 my ($format, $code) = @_;
112
113 die "JSON schema format '$format' already registered\n"
114 if $format_list->{$format};
115
116 $format_list->{$format} = $code;
117}
118
2421fba1
WB
119sub get_format {
120 my ($format) = @_;
121 return $format_list->{$format};
122}
123
e143e9d8 124# register some common type for pve
8ba7c72b
DM
125
126register_format('string', sub {}); # allow format => 'string-list'
127
c77b4c96
WB
128register_format('urlencoded', \&pve_verify_urlencoded);
129sub pve_verify_urlencoded {
130 my ($text, $noerr) = @_;
131 if ($text !~ /^[-%a-zA-Z0-9_.!~*'()]*$/) {
132 return undef if $noerr;
133 die "invalid urlencoded string: $text\n";
134 }
135 return $text;
136}
137
e143e9d8
DM
138register_format('pve-configid', \&pve_verify_configid);
139sub pve_verify_configid {
140 my ($id, $noerr) = @_;
141
142 if ($id !~ m/^[a-z][a-z0-9_]+$/i) {
143 return undef if $noerr;
39ed3462 144 die "invalid configuration ID '$id'\n";
e143e9d8
DM
145 }
146 return $id;
147}
148
05e787c5
DM
149PVE::JSONSchema::register_format('pve-storage-id', \&parse_storage_id);
150sub parse_storage_id {
151 my ($storeid, $noerr) = @_;
152
153 if ($storeid !~ m/^[a-z][a-z0-9\-\_\.]*[a-z0-9]$/i) {
154 return undef if $noerr;
155 die "storage ID '$storeid' contains illegal characters\n";
156 }
157 return $storeid;
158}
159
160
e143e9d8
DM
161register_format('pve-vmid', \&pve_verify_vmid);
162sub pve_verify_vmid {
163 my ($vmid, $noerr) = @_;
164
50ae94c9 165 if ($vmid !~ m/^[1-9][0-9]{2,8}$/) {
e143e9d8
DM
166 return undef if $noerr;
167 die "value does not look like a valid VM ID\n";
168 }
169 return $vmid;
170}
171
172register_format('pve-node', \&pve_verify_node_name);
173sub pve_verify_node_name {
174 my ($node, $noerr) = @_;
175
e6db55c0 176 if ($node !~ m/^([a-zA-Z0-9]([a-zA-Z0-9\-]*[a-zA-Z0-9])?)$/) {
e143e9d8
DM
177 return undef if $noerr;
178 die "value does not look like a valid node name\n";
179 }
180 return $node;
181}
182
183register_format('ipv4', \&pve_verify_ipv4);
184sub pve_verify_ipv4 {
185 my ($ipv4, $noerr) = @_;
186
ed5880ac
DM
187 if ($ipv4 !~ m/^(?:$IPV4RE)$/) {
188 return undef if $noerr;
189 die "value does not look like a valid IPv4 address\n";
e143e9d8
DM
190 }
191 return $ipv4;
192}
a13c6f08 193
ed5880ac 194register_format('ipv6', \&pve_verify_ipv6);
93276209 195sub pve_verify_ipv6 {
ed5880ac
DM
196 my ($ipv6, $noerr) = @_;
197
198 if ($ipv6 !~ m/^(?:$IPV6RE)$/) {
199 return undef if $noerr;
200 die "value does not look like a valid IPv6 address\n";
201 }
202 return $ipv6;
203}
204
205register_format('ip', \&pve_verify_ip);
206sub pve_verify_ip {
207 my ($ip, $noerr) = @_;
208
209 if ($ip !~ m/^(?:(?:$IPV4RE)|(?:$IPV6RE))$/) {
210 return undef if $noerr;
211 die "value does not look like a valid IP address\n";
212 }
213 return $ip;
214}
215
a13c6f08
DM
216my $ipv4_mask_hash = {
217 '128.0.0.0' => 1,
218 '192.0.0.0' => 2,
219 '224.0.0.0' => 3,
220 '240.0.0.0' => 4,
221 '248.0.0.0' => 5,
222 '252.0.0.0' => 6,
223 '254.0.0.0' => 7,
224 '255.0.0.0' => 8,
225 '255.128.0.0' => 9,
226 '255.192.0.0' => 10,
227 '255.224.0.0' => 11,
228 '255.240.0.0' => 12,
229 '255.248.0.0' => 13,
230 '255.252.0.0' => 14,
231 '255.254.0.0' => 15,
232 '255.255.0.0' => 16,
233 '255.255.128.0' => 17,
234 '255.255.192.0' => 18,
235 '255.255.224.0' => 19,
236 '255.255.240.0' => 20,
237 '255.255.248.0' => 21,
238 '255.255.252.0' => 22,
239 '255.255.254.0' => 23,
240 '255.255.255.0' => 24,
241 '255.255.255.128' => 25,
242 '255.255.255.192' => 26,
243 '255.255.255.224' => 27,
244 '255.255.255.240' => 28,
245 '255.255.255.248' => 29,
e43faad9
WB
246 '255.255.255.252' => 30,
247 '255.255.255.254' => 31,
248 '255.255.255.255' => 32,
a13c6f08
DM
249};
250
e143e9d8
DM
251register_format('ipv4mask', \&pve_verify_ipv4mask);
252sub pve_verify_ipv4mask {
253 my ($mask, $noerr) = @_;
254
a13c6f08 255 if (!defined($ipv4_mask_hash->{$mask})) {
e143e9d8
DM
256 return undef if $noerr;
257 die "value does not look like a valid IP netmask\n";
258 }
259 return $mask;
260}
261
703c1f88
WB
262register_format('CIDRv6', \&pve_verify_cidrv6);
263sub pve_verify_cidrv6 {
e272bcb7
DM
264 my ($cidr, $noerr) = @_;
265
70ea2250 266 if ($cidr =~ m!^(?:$IPV6RE)(?:/(\d+))$! && ($1 > 7) && ($1 <= 128)) {
e272bcb7 267 return $cidr;
703c1f88
WB
268 }
269
270 return undef if $noerr;
271 die "value does not look like a valid IPv6 CIDR network\n";
272}
273
274register_format('CIDRv4', \&pve_verify_cidrv4);
275sub pve_verify_cidrv4 {
276 my ($cidr, $noerr) = @_;
277
0526cc2d 278 if ($cidr =~ m!^(?:$IPV4RE)(?:/(\d+))$! && ($1 > 7) && ($1 <= 32)) {
e272bcb7
DM
279 return $cidr;
280 }
281
282 return undef if $noerr;
703c1f88
WB
283 die "value does not look like a valid IPv4 CIDR network\n";
284}
285
286register_format('CIDR', \&pve_verify_cidr);
287sub pve_verify_cidr {
288 my ($cidr, $noerr) = @_;
289
290 if (!(pve_verify_cidrv4($cidr, 1) ||
291 pve_verify_cidrv6($cidr, 1)))
292 {
293 return undef if $noerr;
294 die "value does not look like a valid CIDR network\n";
295 }
296
297 return $cidr;
298}
299
300register_format('pve-ipv4-config', \&pve_verify_ipv4_config);
301sub pve_verify_ipv4_config {
302 my ($config, $noerr) = @_;
303
304 return $config if $config =~ /^(?:dhcp|manual)$/ ||
305 pve_verify_cidrv4($config, 1);
306 return undef if $noerr;
307 die "value does not look like a valid ipv4 network configuration\n";
308}
309
310register_format('pve-ipv6-config', \&pve_verify_ipv6_config);
311sub pve_verify_ipv6_config {
312 my ($config, $noerr) = @_;
313
314 return $config if $config =~ /^(?:auto|dhcp|manual)$/ ||
315 pve_verify_cidrv6($config, 1);
316 return undef if $noerr;
317 die "value does not look like a valid ipv6 network configuration\n";
e272bcb7
DM
318}
319
e143e9d8
DM
320register_format('email', \&pve_verify_email);
321sub pve_verify_email {
322 my ($email, $noerr) = @_;
323
87cb0e60
EK
324 # we use same regex as in Utils.js
325 if ($email !~ /^(\w+)([\-+.][\w]+)*@(\w[\-\w]*\.){1,5}([A-Za-z]){2,63}$/) {
e143e9d8
DM
326 return undef if $noerr;
327 die "value does not look like a valid email address\n";
328 }
329 return $email;
330}
331
34ebb226
DM
332register_format('dns-name', \&pve_verify_dns_name);
333sub pve_verify_dns_name {
334 my ($name, $noerr) = @_;
335
ce33e978 336 my $namere = "([a-zA-Z0-9]([a-zA-Z0-9\-]*[a-zA-Z0-9])?)";
34ebb226
DM
337
338 if ($name !~ /^(${namere}\.)*${namere}$/) {
339 return undef if $noerr;
340 die "value does not look like a valid DNS name\n";
341 }
342 return $name;
343}
344
e143e9d8
DM
345# network interface name
346register_format('pve-iface', \&pve_verify_iface);
347sub pve_verify_iface {
348 my ($id, $noerr) = @_;
349
350 if ($id !~ m/^[a-z][a-z0-9_]{1,20}([:\.]\d+)?$/i) {
351 return undef if $noerr;
352 die "invalid network interface name '$id'\n";
353 }
354 return $id;
355}
356
d07b7084
WB
357# general addresses by name or IP
358register_format('address', \&pve_verify_address);
359sub pve_verify_address {
360 my ($addr, $noerr) = @_;
361
362 if (!(pve_verify_ip($addr, 1) ||
363 pve_verify_dns_name($addr, 1)))
364 {
365 return undef if $noerr;
366 die "value does not look like a valid address: $addr\n";
367 }
368 return $addr;
369}
370
b944a22a
WB
371register_format('disk-size', \&pve_verify_disk_size);
372sub pve_verify_disk_size {
373 my ($size, $noerr) = @_;
374 if (!defined(parse_size($size))) {
375 return undef if $noerr;
376 die "value does not look like a valid disk size: $size\n";
377 }
378 return $size;
379}
380
f0a10afc
DM
381register_standard_option('spice-proxy', {
382 description => "SPICE proxy server. This can be used by the client to specify the proxy server. All nodes in a cluster runs 'spiceproxy', so it is up to the client to choose one. By default, we return the node where the VM is currently running. As resonable setting is to use same node you use to connect to the API (This is window.location.hostname for the JS GUI).",
d07b7084 383 type => 'string', format => 'address',
f0a10afc
DM
384});
385
386register_standard_option('remote-viewer-config', {
387 description => "Returned values can be directly passed to the 'remote-viewer' application.",
388 additionalProperties => 1,
389 properties => {
390 type => { type => 'string' },
391 password => { type => 'string' },
392 proxy => { type => 'string' },
393 host => { type => 'string' },
394 'tls-port' => { type => 'integer' },
395 },
396});
397
c70c3bbc 398register_format('pve-startup-order', \&pve_verify_startup_order);
b0edd8e6
DM
399sub pve_verify_startup_order {
400 my ($value, $noerr) = @_;
401
402 return $value if pve_parse_startup_order($value);
403
404 return undef if $noerr;
405
406 die "unable to parse startup options\n";
407}
408
2d167ad0
WB
409my %bwlimit_opt = (
410 optional => 1,
411 type => 'number', minimum => '0',
412 format_description => 'LIMIT',
413);
414
415my $bwlimit_format = {
416 default => {
417 %bwlimit_opt,
418 description => 'default bandwidth limit in MiB/s',
419 },
420 restore => {
421 %bwlimit_opt,
422 description => 'bandwidth limit in MiB/s for restoring guests from backups',
423 },
424 migration => {
425 %bwlimit_opt,
426 description => 'bandwidth limit in MiB/s for migrating guests',
427 },
428 clone => {
429 %bwlimit_opt,
430 description => 'bandwidth limit in MiB/s for cloning disks',
431 },
432 move => {
433 %bwlimit_opt,
434 description => 'bandwidth limit in MiB/s for moving disks',
435 },
436};
437register_format('bwlimit', $bwlimit_format);
438register_standard_option('bwlimit', {
439 description => "Set bandwidth/io limits various operations.",
440 optional => 1,
441 type => 'string',
442 format => $bwlimit_format,
443});
444
b0edd8e6
DM
445sub pve_parse_startup_order {
446 my ($value) = @_;
447
448 return undef if !$value;
449
450 my $res = {};
451
452 foreach my $p (split(/,/, $value)) {
453 next if $p =~ m/^\s*$/;
454
455 if ($p =~ m/^(order=)?(\d+)$/) {
456 $res->{order} = $2;
457 } elsif ($p =~ m/^up=(\d+)$/) {
458 $res->{up} = $1;
459 } elsif ($p =~ m/^down=(\d+)$/) {
460 $res->{down} = $1;
461 } else {
462 return undef;
463 }
464 }
465
466 return $res;
467}
468
469PVE::JSONSchema::register_standard_option('pve-startup-order', {
470 description => "Startup and shutdown behavior. Order is a non-negative number defining the general startup order. Shutdown in done with reverse ordering. Additionally you can set the 'up' or 'down' delay in seconds, which specifies a delay to wait before the next VM is started or stopped.",
471 optional => 1,
472 type => 'string', format => 'pve-startup-order',
473 typetext => '[[order=]\d+] [,up=\d+] [,down=\d+] ',
474});
475
e143e9d8 476sub check_format {
2f9e609a 477 my ($format, $value, $path) = @_;
e143e9d8 478
2f9e609a 479 return parse_property_string($format, $value, $path) if ref($format) eq 'HASH';
e143e9d8
DM
480 return if $format eq 'regex';
481
23dc9401 482 if ($format =~ m/^(.*)-a?list$/) {
e143e9d8
DM
483
484 my $code = $format_list->{$1};
485
486 die "undefined format '$format'\n" if !$code;
487
488 # Note: we allow empty lists
489 foreach my $v (split_list($value)) {
490 &$code($v);
491 }
492
493 } elsif ($format =~ m/^(.*)-opt$/) {
494
495 my $code = $format_list->{$1};
496
497 die "undefined format '$format'\n" if !$code;
498
499 return if !$value; # allow empty string
500
501 &$code($value);
502
503 } else {
504
505 my $code = $format_list->{$format};
506
507 die "undefined format '$format'\n" if !$code;
508
2f9e609a 509 return parse_property_string($code, $value, $path) if ref($code) eq 'HASH';
e143e9d8
DM
510 &$code($value);
511 }
512}
513
878fea8e
WB
514sub parse_size {
515 my ($value) = @_;
516
517 return undef if $value !~ m/^(\d+(\.\d+)?)([KMGT])?$/;
518 my ($size, $unit) = ($1, $3);
519 if ($unit) {
520 if ($unit eq 'K') {
521 $size = $size * 1024;
522 } elsif ($unit eq 'M') {
523 $size = $size * 1024 * 1024;
524 } elsif ($unit eq 'G') {
525 $size = $size * 1024 * 1024 * 1024;
526 } elsif ($unit eq 'T') {
527 $size = $size * 1024 * 1024 * 1024 * 1024;
528 }
529 }
530 return int($size);
531};
532
533sub format_size {
534 my ($size) = @_;
535
536 $size = int($size);
537
538 my $kb = int($size/1024);
539 return $size if $kb*1024 != $size;
540
541 my $mb = int($kb/1024);
542 return "${kb}K" if $mb*1024 != $kb;
543
544 my $gb = int($mb/1024);
545 return "${mb}M" if $gb*1024 != $mb;
546
547 my $tb = int($gb/1024);
548 return "${gb}G" if $tb*1024 != $gb;
549
550 return "${tb}T";
551};
552
1b71e564
WB
553sub parse_boolean {
554 my ($bool) = @_;
555 return 1 if $bool =~ m/^(1|on|yes|true)$/i;
556 return 0 if $bool =~ m/^(0|off|no|false)$/i;
557 return undef;
558}
559
095b88fd 560sub parse_property_string {
d1e490c1
WB
561 my ($format, $data, $path, $additional_properties) = @_;
562
563 # In property strings we default to not allowing additional properties
564 $additional_properties = 0 if !defined($additional_properties);
095b88fd 565
7c1617b0
WB
566 # Support named formats here, too:
567 if (!ref($format)) {
568 if (my $desc = $format_list->{$format}) {
569 $format = $desc;
570 } else {
571 die "unknown format: $format\n";
572 }
573 } elsif (ref($format) ne 'HASH') {
574 die "unexpected format value of type ".ref($format)."\n";
575 }
576
095b88fd
WB
577 my $default_key;
578
579 my $res = {};
580 foreach my $part (split(/,/, $data)) {
581 next if $part =~ /^\s*$/;
582
583 if ($part =~ /^([^=]+)=(.+)$/) {
584 my ($k, $v) = ($1, $2);
2d468b1a 585 die "duplicate key in comma-separated list property: $k\n" if defined($res->{$k});
095b88fd 586 my $schema = $format->{$k};
303a9b34 587 if (my $alias = $schema->{alias}) {
bf27456b
DM
588 if (my $key_alias = $schema->{keyAlias}) {
589 die "key alias '$key_alias' is already defined\n" if defined($res->{$key_alias});
590 $res->{$key_alias} = $k;
591 }
303a9b34
WB
592 $k = $alias;
593 $schema = $format->{$k};
594 }
bf27456b 595
2d468b1a 596 die "invalid key in comma-separated list property: $k\n" if !$schema;
095b88fd 597 if ($schema->{type} && $schema->{type} eq 'boolean') {
1b71e564 598 $v = parse_boolean($v) // $v;
095b88fd
WB
599 }
600 $res->{$k} = $v;
601 } elsif ($part !~ /=/) {
2d468b1a 602 die "duplicate key in comma-separated list property: $default_key\n" if $default_key;
095b88fd
WB
603 foreach my $key (keys %$format) {
604 if ($format->{$key}->{default_key}) {
605 $default_key = $key;
606 if (!$res->{$default_key}) {
607 $res->{$default_key} = $part;
608 last;
609 }
2d468b1a 610 die "duplicate key in comma-separated list property: $default_key\n";
095b88fd
WB
611 }
612 }
f0ba41a1 613 die "value without key, but schema does not define a default key\n" if !$default_key;
095b88fd 614 } else {
2d468b1a 615 die "missing key in comma-separated list property\n";
095b88fd
WB
616 }
617 }
618
619 my $errors = {};
d1e490c1 620 check_object($path, $format, $res, $additional_properties, $errors);
095b88fd 621 if (scalar(%$errors)) {
2d468b1a 622 raise "format error\n", errors => $errors;
095b88fd
WB
623 }
624
625 return $res;
626}
627
e143e9d8
DM
628sub add_error {
629 my ($errors, $path, $msg) = @_;
630
631 $path = '_root' if !$path;
632
633 if ($errors->{$path}) {
634 $errors->{$path} = join ('\n', $errors->{$path}, $msg);
635 } else {
636 $errors->{$path} = $msg;
637 }
638}
639
640sub is_number {
641 my $value = shift;
642
643 # see 'man perlretut'
644 return $value =~ /^[+-]?(\d+\.\d+|\d+\.|\.\d+|\d+)([eE][+-]?\d+)?$/;
645}
646
647sub is_integer {
648 my $value = shift;
649
650 return $value =~ m/^[+-]?\d+$/;
651}
652
653sub check_type {
654 my ($path, $type, $value, $errors) = @_;
655
656 return 1 if !$type;
657
658 if (!defined($value)) {
659 return 1 if $type eq 'null';
660 die "internal error"
661 }
662
663 if (my $tt = ref($type)) {
664 if ($tt eq 'ARRAY') {
665 foreach my $t (@$type) {
666 my $tmperr = {};
667 check_type($path, $t, $value, $tmperr);
668 return 1 if !scalar(%$tmperr);
669 }
670 my $ttext = join ('|', @$type);
671 add_error($errors, $path, "type check ('$ttext') failed");
672 return undef;
673 } elsif ($tt eq 'HASH') {
674 my $tmperr = {};
675 check_prop($value, $type, $path, $tmperr);
676 return 1 if !scalar(%$tmperr);
677 add_error($errors, $path, "type check failed");
678 return undef;
679 } else {
680 die "internal error - got reference type '$tt'";
681 }
682
683 } else {
684
685 return 1 if $type eq 'any';
686
687 if ($type eq 'null') {
688 if (defined($value)) {
689 add_error($errors, $path, "type check ('$type') failed - value is not null");
690 return undef;
691 }
692 return 1;
693 }
694
695 my $vt = ref($value);
696
697 if ($type eq 'array') {
698 if (!$vt || $vt ne 'ARRAY') {
699 add_error($errors, $path, "type check ('$type') failed");
700 return undef;
701 }
702 return 1;
703 } elsif ($type eq 'object') {
704 if (!$vt || $vt ne 'HASH') {
705 add_error($errors, $path, "type check ('$type') failed");
706 return undef;
707 }
708 return 1;
709 } elsif ($type eq 'coderef') {
710 if (!$vt || $vt ne 'CODE') {
711 add_error($errors, $path, "type check ('$type') failed");
712 return undef;
713 }
714 return 1;
88a490ff
WB
715 } elsif ($type eq 'string' && $vt eq 'Regexp') {
716 # qr// regexes can be used as strings and make sense for format=regex
717 return 1;
e143e9d8
DM
718 } else {
719 if ($vt) {
720 add_error($errors, $path, "type check ('$type') failed - got $vt");
721 return undef;
722 } else {
723 if ($type eq 'string') {
724 return 1; # nothing to check ?
725 } elsif ($type eq 'boolean') {
726 #if ($value =~ m/^(1|true|yes|on)$/i) {
727 if ($value eq '1') {
728 return 1;
729 #} elsif ($value =~ m/^(0|false|no|off)$/i) {
730 } elsif ($value eq '0') {
79501b2a 731 return 1; # return success (not value)
e143e9d8
DM
732 } else {
733 add_error($errors, $path, "type check ('$type') failed - got '$value'");
734 return undef;
735 }
736 } elsif ($type eq 'integer') {
737 if (!is_integer($value)) {
738 add_error($errors, $path, "type check ('$type') failed - got '$value'");
739 return undef;
740 }
741 return 1;
742 } elsif ($type eq 'number') {
743 if (!is_number($value)) {
744 add_error($errors, $path, "type check ('$type') failed - got '$value'");
745 return undef;
746 }
747 return 1;
748 } else {
749 return 1; # no need to verify unknown types
750 }
751 }
752 }
753 }
754
755 return undef;
756}
757
758sub check_object {
759 my ($path, $schema, $value, $additional_properties, $errors) = @_;
760
761 # print "Check Object " . Dumper($value) . "\nSchema: " . Dumper($schema);
762
763 my $st = ref($schema);
764 if (!$st || $st ne 'HASH') {
765 add_error($errors, $path, "Invalid schema definition.");
766 return;
767 }
768
769 my $vt = ref($value);
770 if (!$vt || $vt ne 'HASH') {
771 add_error($errors, $path, "an object is required");
772 return;
773 }
774
775 foreach my $k (keys %$schema) {
bf27456b 776 check_prop($value->{$k}, $schema->{$k}, $path ? "$path.$k" : $k, $errors);
e143e9d8
DM
777 }
778
779 foreach my $k (keys %$value) {
780
781 my $newpath = $path ? "$path.$k" : $k;
782
783 if (my $subschema = $schema->{$k}) {
784 if (my $requires = $subschema->{requires}) {
785 if (ref($requires)) {
786 #print "TEST: " . Dumper($value) . "\n", Dumper($requires) ;
787 check_prop($value, $requires, $path, $errors);
788 } elsif (!defined($value->{$requires})) {
789 add_error($errors, $path ? "$path.$requires" : $requires,
8b6e737a 790 "missing property - '$newpath' requires this property");
e143e9d8
DM
791 }
792 }
793
794 next; # value is already checked above
795 }
796
797 if (defined ($additional_properties) && !$additional_properties) {
798 add_error($errors, $newpath, "property is not defined in schema " .
799 "and the schema does not allow additional properties");
800 next;
801 }
802 check_prop($value->{$k}, $additional_properties, $newpath, $errors)
803 if ref($additional_properties);
804 }
805}
806
86425a09
WB
807sub check_object_warn {
808 my ($path, $schema, $value, $additional_properties) = @_;
809 my $errors = {};
810 check_object($path, $schema, $value, $additional_properties, $errors);
811 if (scalar(%$errors)) {
812 foreach my $k (keys %$errors) {
813 warn "parse error: $k: $errors->{$k}\n";
814 }
815 return 0;
816 }
817 return 1;
818}
819
e143e9d8
DM
820sub check_prop {
821 my ($value, $schema, $path, $errors) = @_;
822
823 die "internal error - no schema" if !$schema;
824 die "internal error" if !$errors;
825
826 #print "check_prop $path\n" if $value;
827
828 my $st = ref($schema);
829 if (!$st || $st ne 'HASH') {
830 add_error($errors, $path, "Invalid schema definition.");
831 return;
832 }
833
834 # if it extends another schema, it must pass that schema as well
835 if($schema->{extends}) {
836 check_prop($value, $schema->{extends}, $path, $errors);
837 }
838
839 if (!defined ($value)) {
840 return if $schema->{type} && $schema->{type} eq 'null';
445e8267 841 if (!$schema->{optional} && !$schema->{alias} && !$schema->{group}) {
e143e9d8
DM
842 add_error($errors, $path, "property is missing and it is not optional");
843 }
844 return;
845 }
846
847 return if !check_type($path, $schema->{type}, $value, $errors);
848
849 if ($schema->{disallow}) {
850 my $tmperr = {};
851 if (check_type($path, $schema->{disallow}, $value, $tmperr)) {
852 add_error($errors, $path, "disallowed value was matched");
853 return;
854 }
855 }
856
857 if (my $vt = ref($value)) {
858
859 if ($vt eq 'ARRAY') {
860 if ($schema->{items}) {
861 my $it = ref($schema->{items});
862 if ($it && $it eq 'ARRAY') {
863 #die "implement me $path: $vt " . Dumper($schema) ."\n". Dumper($value);
864 die "not implemented";
865 } else {
866 my $ind = 0;
867 foreach my $el (@$value) {
868 check_prop($el, $schema->{items}, "${path}[$ind]", $errors);
869 $ind++;
870 }
871 }
872 }
873 return;
874 } elsif ($schema->{properties} || $schema->{additionalProperties}) {
875 check_object($path, defined($schema->{properties}) ? $schema->{properties} : {},
876 $value, $schema->{additionalProperties}, $errors);
877 return;
878 }
879
880 } else {
881
882 if (my $format = $schema->{format}) {
2f9e609a 883 eval { check_format($format, $value, $path); };
e143e9d8
DM
884 if ($@) {
885 add_error($errors, $path, "invalid format - $@");
886 return;
887 }
888 }
889
890 if (my $pattern = $schema->{pattern}) {
891 if ($value !~ m/^$pattern$/) {
892 add_error($errors, $path, "value does not match the regex pattern");
893 return;
894 }
895 }
896
897 if (defined (my $max = $schema->{maxLength})) {
898 if (length($value) > $max) {
899 add_error($errors, $path, "value may only be $max characters long");
900 return;
901 }
902 }
903
904 if (defined (my $min = $schema->{minLength})) {
905 if (length($value) < $min) {
906 add_error($errors, $path, "value must be at least $min characters long");
907 return;
908 }
909 }
910
911 if (is_number($value)) {
912 if (defined (my $max = $schema->{maximum})) {
913 if ($value > $max) {
914 add_error($errors, $path, "value must have a maximum value of $max");
915 return;
916 }
917 }
918
919 if (defined (my $min = $schema->{minimum})) {
920 if ($value < $min) {
921 add_error($errors, $path, "value must have a minimum value of $min");
922 return;
923 }
924 }
925 }
926
927 if (my $ea = $schema->{enum}) {
928
929 my $found;
930 foreach my $ev (@$ea) {
931 if ($ev eq $value) {
932 $found = 1;
933 last;
934 }
935 }
936 if (!$found) {
937 add_error($errors, $path, "value '$value' does not have a value in the enumeration '" .
938 join(", ", @$ea) . "'");
939 }
940 }
941 }
942}
943
944sub validate {
945 my ($instance, $schema, $errmsg) = @_;
946
947 my $errors = {};
948 $errmsg = "Parameter verification failed.\n" if !$errmsg;
949
950 # todo: cycle detection is only needed for debugging, I guess
951 # we can disable that in the final release
952 # todo: is there a better/faster way to detect cycles?
953 my $cycles = 0;
954 find_cycle($instance, sub { $cycles = 1 });
955 if ($cycles) {
956 add_error($errors, undef, "data structure contains recursive cycles");
957 } elsif ($schema) {
958 check_prop($instance, $schema, '', $errors);
959 }
960
961 if (scalar(%$errors)) {
962 raise $errmsg, code => HTTP_BAD_REQUEST, errors => $errors;
963 }
964
965 return 1;
966}
967
968my $schema_valid_types = ["string", "object", "coderef", "array", "boolean", "number", "integer", "null", "any"];
969my $default_schema_noref = {
970 description => "This is the JSON Schema for JSON Schemas.",
971 type => [ "object" ],
972 additionalProperties => 0,
973 properties => {
974 type => {
975 type => ["string", "array"],
976 description => "This is a type definition value. This can be a simple type, or a union type",
977 optional => 1,
978 default => "any",
979 items => {
980 type => "string",
981 enum => $schema_valid_types,
982 },
983 enum => $schema_valid_types,
984 },
985 optional => {
986 type => "boolean",
987 description => "This indicates that the instance property in the instance object is not required.",
988 optional => 1,
989 default => 0
990 },
991 properties => {
992 type => "object",
993 description => "This is a definition for the properties of an object value",
994 optional => 1,
995 default => {},
996 },
997 items => {
998 type => "object",
999 description => "When the value is an array, this indicates the schema to use to validate each item in an array",
1000 optional => 1,
1001 default => {},
1002 },
1003 additionalProperties => {
1004 type => [ "boolean", "object"],
1005 description => "This provides a default property definition for all properties that are not explicitly defined in an object type definition.",
1006 optional => 1,
1007 default => {},
1008 },
1009 minimum => {
1010 type => "number",
1011 optional => 1,
1012 description => "This indicates the minimum value for the instance property when the type of the instance value is a number.",
1013 },
1014 maximum => {
1015 type => "number",
1016 optional => 1,
1017 description => "This indicates the maximum value for the instance property when the type of the instance value is a number.",
1018 },
1019 minLength => {
1020 type => "integer",
1021 description => "When the instance value is a string, this indicates minimum length of the string",
1022 optional => 1,
1023 minimum => 0,
1024 default => 0,
1025 },
1026 maxLength => {
1027 type => "integer",
1028 description => "When the instance value is a string, this indicates maximum length of the string.",
1029 optional => 1,
1030 },
1031 typetext => {
1032 type => "string",
1033 optional => 1,
1034 description => "A text representation of the type (used to generate documentation).",
1035 },
1036 pattern => {
1037 type => "string",
1038 format => "regex",
166e27c7 1039 description => "When the instance value is a string, this provides a regular expression that a instance string value should match in order to be valid.",
e143e9d8
DM
1040 optional => 1,
1041 default => ".*",
166e27c7 1042 },
e143e9d8
DM
1043 enum => {
1044 type => "array",
1045 optional => 1,
1046 description => "This provides an enumeration of possible values that are valid for the instance property.",
1047 },
1048 description => {
1049 type => "string",
1050 optional => 1,
1051 description => "This provides a description of the purpose the instance property. The value can be a string or it can be an object with properties corresponding to various different instance languages (with an optional default property indicating the default description).",
1052 },
32f8e0c7
DM
1053 verbose_description => {
1054 type => "string",
1055 optional => 1,
1056 description => "This provides a more verbose description.",
1057 },
d5d10f85
WB
1058 format_description => {
1059 type => "string",
1060 optional => 1,
1061 description => "This provides a shorter (usually just one word) description for a property used to generate descriptions for comma separated list property strings.",
1062 },
166e27c7
WB
1063 title => {
1064 type => "string",
e143e9d8 1065 optional => 1,
166e27c7
WB
1066 description => "This provides the title of the property",
1067 },
1068 requires => {
1069 type => [ "string", "object" ],
e143e9d8 1070 optional => 1,
166e27c7
WB
1071 description => "indicates a required property or a schema that must be validated if this property is present",
1072 },
1073 format => {
2f9e609a 1074 type => [ "string", "object" ],
e143e9d8 1075 optional => 1,
166e27c7
WB
1076 description => "This indicates what format the data is among some predefined formats which may include:\n\ndate - a string following the ISO format \naddress \nschema - a schema definition object \nperson \npage \nhtml - a string representing HTML",
1077 },
095b88fd
WB
1078 default_key => {
1079 type => "boolean",
1080 optional => 1,
1081 description => "Whether this is the default key in a comma separated list property string.",
1082 },
303a9b34
WB
1083 alias => {
1084 type => 'string',
1085 optional => 1,
1086 description => "When a key represents the same property as another it can be an alias to it, causing the parsed datastructure to use the other key to store the current value under.",
1087 },
bf27456b 1088 keyAlias => {
445e8267
WB
1089 type => 'string',
1090 optional => 1,
bf27456b
DM
1091 description => "Allows to store the current 'key' as value of another property. Only valid if used together with 'alias'.",
1092 requires => 'alias',
445e8267 1093 },
e143e9d8
DM
1094 default => {
1095 type => "any",
1096 optional => 1,
1097 description => "This indicates the default for the instance property."
1098 },
166e27c7 1099 completion => {
7829989f
DM
1100 type => 'coderef',
1101 description => "Bash completion function. This function should return a list of possible values.",
1102 optional => 1,
166e27c7
WB
1103 },
1104 disallow => {
1105 type => "object",
e143e9d8 1106 optional => 1,
166e27c7 1107 description => "This attribute may take the same values as the \"type\" attribute, however if the instance matches the type or if this value is an array and the instance matches any type or schema in the array, then this instance is not valid.",
e143e9d8 1108 },
166e27c7
WB
1109 extends => {
1110 type => "object",
e143e9d8 1111 optional => 1,
166e27c7 1112 description => "This indicates the schema extends the given schema. All instances of this schema must be valid to by the extended schema also.",
e143e9d8 1113 default => {},
166e27c7
WB
1114 },
1115 # this is from hyper schema
1116 links => {
1117 type => "array",
1118 description => "This defines the link relations of the instance objects",
1119 optional => 1,
e143e9d8 1120 items => {
166e27c7
WB
1121 type => "object",
1122 properties => {
1123 href => {
1124 type => "string",
1125 description => "This defines the target URL for the relation and can be parameterized using {propertyName} notation. It should be resolved as a URI-reference relative to the URI that was used to retrieve the instance document",
1126 },
1127 rel => {
1128 type => "string",
1129 description => "This is the name of the link relation",
1130 optional => 1,
1131 default => "full",
1132 },
e143e9d8 1133 method => {
166e27c7
WB
1134 type => "string",
1135 description => "For submission links, this defines the method that should be used to access the target resource",
1136 optional => 1,
1137 default => "GET",
e143e9d8
DM
1138 },
1139 },
1140 },
1141 },
1142 }
1143};
1144
1145my $default_schema = Storable::dclone($default_schema_noref);
1146
1147$default_schema->{properties}->{properties}->{additionalProperties} = $default_schema;
1148$default_schema->{properties}->{additionalProperties}->{properties} = $default_schema->{properties};
1149
1150$default_schema->{properties}->{items}->{properties} = $default_schema->{properties};
1151$default_schema->{properties}->{items}->{additionalProperties} = 0;
1152
1153$default_schema->{properties}->{disallow}->{properties} = $default_schema->{properties};
1154$default_schema->{properties}->{disallow}->{additionalProperties} = 0;
1155
1156$default_schema->{properties}->{requires}->{properties} = $default_schema->{properties};
1157$default_schema->{properties}->{requires}->{additionalProperties} = 0;
1158
1159$default_schema->{properties}->{extends}->{properties} = $default_schema->{properties};
1160$default_schema->{properties}->{extends}->{additionalProperties} = 0;
1161
1162my $method_schema = {
1163 type => "object",
1164 additionalProperties => 0,
1165 properties => {
1166 description => {
1167 description => "This a description of the method",
1168 optional => 1,
1169 },
1170 name => {
1171 type => 'string',
1172 description => "This indicates the name of the function to call.",
1173 optional => 1,
1174 requires => {
1175 additionalProperties => 1,
1176 properties => {
1177 name => {},
1178 description => {},
1179 code => {},
1180 method => {},
1181 parameters => {},
1182 path => {},
1183 parameters => {},
1184 returns => {},
1185 }
1186 },
1187 },
1188 method => {
1189 type => 'string',
1190 description => "The HTTP method name.",
1191 enum => [ 'GET', 'POST', 'PUT', 'DELETE' ],
1192 optional => 1,
1193 },
1194 protected => {
1195 type => 'boolean',
1196 description => "Method needs special privileges - only pvedaemon can execute it",
1197 optional => 1,
1198 },
62a8f27b
DM
1199 download => {
1200 type => 'boolean',
1201 description => "Method downloads the file content (filename is the return value of the method).",
1202 optional => 1,
1203 },
e143e9d8
DM
1204 proxyto => {
1205 type => 'string',
1206 description => "A parameter name. If specified, all calls to this method are proxied to the host contained in that parameter.",
1207 optional => 1,
1208 },
031efdd0
DM
1209 proxyto_callback => {
1210 type => 'coderef',
1211 description => "A function which is called to resolve the proxyto attribute. The default implementaion returns the value of the 'proxyto' parameter.",
1212 optional => 1,
1213 },
e143e9d8
DM
1214 permissions => {
1215 type => 'object',
1216 description => "Required access permissions. By default only 'root' is allowed to access this method.",
1217 optional => 1,
1218 additionalProperties => 0,
1219 properties => {
b18d1722
DM
1220 description => {
1221 description => "Describe access permissions.",
1222 optional => 1,
1223 },
e143e9d8 1224 user => {
b18d1722 1225 description => "A simply way to allow access for 'all' authenticated users. Value 'world' is used to allow access without credentials.",
e143e9d8 1226 type => 'string',
b18d1722 1227 enum => ['all', 'world'],
e143e9d8
DM
1228 optional => 1,
1229 },
b18d1722
DM
1230 check => {
1231 description => "Array of permission checks (prefix notation).",
1232 type => 'array',
1233 optional => 1
1234 },
e143e9d8
DM
1235 },
1236 },
1237 match_name => {
1238 description => "Used internally",
1239 optional => 1,
1240 },
1241 match_re => {
1242 description => "Used internally",
1243 optional => 1,
1244 },
1245 path => {
1246 type => 'string',
1247 description => "path for URL matching (uri template)",
1248 },
1249 fragmentDelimiter => {
1250 type => 'string',
1251 description => "A ways to override the default fragment delimiter '/'. This onyl works on a whole sub-class. You can set this to the empty string to match the whole rest of the URI.",
1252 optional => 1,
1253 },
1254 parameters => {
1255 type => 'object',
1256 description => "JSON Schema for parameters.",
1257 optional => 1,
1258 },
1259 returns => {
1260 type => 'object',
1261 description => "JSON Schema for return value.",
1262 optional => 1,
1263 },
1264 code => {
1265 type => 'coderef',
1266 description => "method implementaion (code reference)",
1267 optional => 1,
1268 },
1269 subclass => {
1270 type => 'string',
1271 description => "Delegate call to this class (perl class string).",
1272 optional => 1,
1273 requires => {
1274 additionalProperties => 0,
1275 properties => {
1276 subclass => {},
1277 path => {},
1278 match_name => {},
1279 match_re => {},
1280 fragmentDelimiter => { optional => 1 }
1281 }
1282 },
1283 },
1284 },
1285
1286};
1287
1288sub validate_schema {
1289 my ($schema) = @_;
1290
1291 my $errmsg = "internal error - unable to verify schema\n";
1292 validate($schema, $default_schema, $errmsg);
1293}
1294
1295sub validate_method_info {
1296 my $info = shift;
1297
1298 my $errmsg = "internal error - unable to verify method info\n";
1299 validate($info, $method_schema, $errmsg);
1300
1301 validate_schema($info->{parameters}) if $info->{parameters};
1302 validate_schema($info->{returns}) if $info->{returns};
1303}
1304
1305# run a self test on load
1306# make sure we can verify the default schema
1307validate_schema($default_schema_noref);
1308validate_schema($method_schema);
1309
1310# and now some utility methods (used by pve api)
1311sub method_get_child_link {
1312 my ($info) = @_;
1313
1314 return undef if !$info;
1315
1316 my $schema = $info->{returns};
1317 return undef if !$schema || !$schema->{type} || $schema->{type} ne 'array';
1318
1319 my $links = $schema->{links};
1320 return undef if !$links;
1321
1322 my $found;
1323 foreach my $lnk (@$links) {
1324 if ($lnk->{href} && $lnk->{rel} && ($lnk->{rel} eq 'child')) {
1325 $found = $lnk;
1326 last;
1327 }
1328 }
1329
1330 return $found;
1331}
1332
1333# a way to parse command line parameters, using a
1334# schema to configure Getopt::Long
1335sub get_options {
0ce82909 1336 my ($schema, $args, $arg_param, $fixed_param, $pwcallback) = @_;
e143e9d8
DM
1337
1338 if (!$schema || !$schema->{properties}) {
1339 raise("too many arguments\n", code => HTTP_BAD_REQUEST)
1340 if scalar(@$args) != 0;
1341 return {};
1342 }
1343
0ce82909
DM
1344 my $list_param;
1345 if ($arg_param && !ref($arg_param)) {
1346 my $pd = $schema->{properties}->{$arg_param};
1347 die "expected list format $pd->{format}"
1348 if !($pd && $pd->{format} && $pd->{format} =~ m/-list/);
1349 $list_param = $arg_param;
1350 }
1351
e143e9d8
DM
1352 my @getopt = ();
1353 foreach my $prop (keys %{$schema->{properties}}) {
1354 my $pd = $schema->{properties}->{$prop};
aab47b58 1355 next if $list_param && $prop eq $list_param;
0ce82909 1356 next if defined($fixed_param->{$prop});
e143e9d8
DM
1357
1358 if ($prop eq 'password' && $pwcallback) {
1359 # we do not accept plain password on input line, instead
1360 # we turn this into a boolean option and ask for password below
1361 # using $pwcallback() (for security reasons).
1362 push @getopt, "$prop";
1363 } elsif ($pd->{type} eq 'boolean') {
1364 push @getopt, "$prop:s";
1365 } else {
23dc9401 1366 if ($pd->{format} && $pd->{format} =~ m/-a?list/) {
8ba7c72b
DM
1367 push @getopt, "$prop=s@";
1368 } else {
1369 push @getopt, "$prop=s";
1370 }
e143e9d8
DM
1371 }
1372 }
1373
1068aeb3
WB
1374 Getopt::Long::Configure('prefix_pattern=(--|-)');
1375
e143e9d8
DM
1376 my $opts = {};
1377 raise("unable to parse option\n", code => HTTP_BAD_REQUEST)
1378 if !Getopt::Long::GetOptionsFromArray($args, $opts, @getopt);
1d21344c 1379
5851be88 1380 if (@$args) {
0ce82909
DM
1381 if ($list_param) {
1382 $opts->{$list_param} = $args;
1383 $args = [];
1384 } elsif (ref($arg_param)) {
5851be88
WB
1385 foreach my $arg_name (@$arg_param) {
1386 if ($opts->{'extra-args'}) {
1387 raise("internal error: extra-args must be the last argument\n", code => HTTP_BAD_REQUEST);
1388 }
1389 if ($arg_name eq 'extra-args') {
1390 $opts->{'extra-args'} = $args;
1391 $args = [];
1392 next;
1393 }
1394 raise("not enough arguments\n", code => HTTP_BAD_REQUEST) if !@$args;
1395 $opts->{$arg_name} = shift @$args;
0ce82909 1396 }
5851be88 1397 raise("too many arguments\n", code => HTTP_BAD_REQUEST) if @$args;
0ce82909
DM
1398 } else {
1399 raise("too many arguments\n", code => HTTP_BAD_REQUEST)
1400 if scalar(@$args) != 0;
1401 }
1d21344c
DM
1402 }
1403
e143e9d8
DM
1404 if (my $pd = $schema->{properties}->{password}) {
1405 if ($pd->{type} ne 'boolean' && $pwcallback) {
1406 if ($opts->{password} || !$pd->{optional}) {
1407 $opts->{password} = &$pwcallback();
1408 }
1409 }
1410 }
815b2aba 1411
c9902568 1412 # decode after Getopt as we are not sure how well it handles unicode
24197a9f 1413 foreach my $p (keys %$opts) {
c9902568
TL
1414 if (!ref($opts->{$p})) {
1415 $opts->{$p} = decode('locale', $opts->{$p});
1416 } elsif (ref($opts->{$p}) eq 'ARRAY') {
1417 my $tmp = [];
1418 foreach my $v (@{$opts->{$p}}) {
1419 push @$tmp, decode('locale', $v);
1420 }
1421 $opts->{$p} = $tmp;
1422 } elsif (ref($opts->{$p}) eq 'SCALAR') {
1423 $opts->{$p} = decode('locale', $$opts->{$p});
1424 } else {
1425 raise("decoding options failed, unknown reference\n", code => HTTP_BAD_REQUEST);
1426 }
24197a9f 1427 }
815b2aba 1428
e143e9d8
DM
1429 foreach my $p (keys %$opts) {
1430 if (my $pd = $schema->{properties}->{$p}) {
1431 if ($pd->{type} eq 'boolean') {
1432 if ($opts->{$p} eq '') {
1433 $opts->{$p} = 1;
1b71e564
WB
1434 } elsif (defined(my $bool = parse_boolean($opts->{$p}))) {
1435 $opts->{$p} = $bool;
e143e9d8
DM
1436 } else {
1437 raise("unable to parse boolean option\n", code => HTTP_BAD_REQUEST);
1438 }
23dc9401 1439 } elsif ($pd->{format}) {
8ba7c72b 1440
23dc9401 1441 if ($pd->{format} =~ m/-list/) {
8ba7c72b 1442 # allow --vmid 100 --vmid 101 and --vmid 100,101
23dc9401 1443 # allow --dow mon --dow fri and --dow mon,fri
43479146 1444 $opts->{$p} = join(",", @{$opts->{$p}}) if ref($opts->{$p}) eq 'ARRAY';
23dc9401 1445 } elsif ($pd->{format} =~ m/-alist/) {
8ba7c72b
DM
1446 # we encode array as \0 separated strings
1447 # Note: CGI.pm also use this encoding
1448 if (scalar(@{$opts->{$p}}) != 1) {
1449 $opts->{$p} = join("\0", @{$opts->{$p}});
1450 } else {
1451 # st that split_list knows it is \0 terminated
1452 my $v = $opts->{$p}->[0];
1453 $opts->{$p} = "$v\0";
1454 }
1455 }
e143e9d8
DM
1456 }
1457 }
1458 }
1459
0ce82909
DM
1460 foreach my $p (keys %$fixed_param) {
1461 $opts->{$p} = $fixed_param->{$p};
e143e9d8
DM
1462 }
1463
1464 return $opts;
1465}
1466
1467# A way to parse configuration data by giving a json schema
1468sub parse_config {
1469 my ($schema, $filename, $raw) = @_;
1470
1471 # do fast check (avoid validate_schema($schema))
1472 die "got strange schema" if !$schema->{type} ||
1473 !$schema->{properties} || $schema->{type} ne 'object';
1474
1475 my $cfg = {};
1476
3c4d612a 1477 while ($raw =~ /^\s*(.+?)\s*$/gm) {
e143e9d8 1478 my $line = $1;
e143e9d8 1479
3c4d612a
WB
1480 next if $line =~ /^#/;
1481
1482 if ($line =~ m/^(\S+?):\s*(.*)$/) {
e143e9d8
DM
1483 my $key = $1;
1484 my $value = $2;
1485 if ($schema->{properties}->{$key} &&
1486 $schema->{properties}->{$key}->{type} eq 'boolean') {
1487
1b71e564 1488 $value = parse_boolean($value) // $value;
e143e9d8
DM
1489 }
1490 $cfg->{$key} = $value;
1491 } else {
1492 warn "ignore config line: $line\n"
1493 }
1494 }
1495
1496 my $errors = {};
1497 check_prop($cfg, $schema, '', $errors);
1498
1499 foreach my $k (keys %$errors) {
1500 warn "parse error in '$filename' - '$k': $errors->{$k}\n";
1501 delete $cfg->{$k};
1502 }
1503
1504 return $cfg;
1505}
1506
1507# generate simple key/value file
1508sub dump_config {
1509 my ($schema, $filename, $cfg) = @_;
1510
1511 # do fast check (avoid validate_schema($schema))
1512 die "got strange schema" if !$schema->{type} ||
1513 !$schema->{properties} || $schema->{type} ne 'object';
1514
1515 validate($cfg, $schema, "validation error in '$filename'\n");
1516
1517 my $data = '';
1518
1519 foreach my $k (keys %$cfg) {
1520 $data .= "$k: $cfg->{$k}\n";
1521 }
1522
1523 return $data;
1524}
1525
bf27456b
DM
1526# helpers used to generate our manual pages
1527
1528my $find_schema_default_key = sub {
1529 my ($format) = @_;
1530
1531 my $default_key;
1532 my $keyAliasProps = {};
1533
1534 foreach my $key (keys %$format) {
1535 my $phash = $format->{$key};
1536 if ($phash->{default_key}) {
1537 die "multiple default keys in schema ($default_key, $key)\n"
1538 if defined($default_key);
1539 die "default key '$key' is an alias - this is not allowed\n"
1540 if defined($phash->{alias});
1541 die "default key '$key' with keyAlias attribute is not allowed\n"
1542 if $phash->{keyAlias};
bf27456b
DM
1543 $default_key = $key;
1544 }
1545 my $key_alias = $phash->{keyAlias};
c88c582d
DM
1546 die "found keyAlias without 'alias definition for '$key'\n"
1547 if $key_alias && !$phash->{alias};
1548
bf27456b
DM
1549 if ($phash->{alias} && $key_alias) {
1550 die "inconsistent keyAlias '$key_alias' definition"
1551 if defined($keyAliasProps->{$key_alias}) &&
1552 $keyAliasProps->{$key_alias} ne $phash->{alias};
1553 $keyAliasProps->{$key_alias} = $phash->{alias};
1554 }
1555 }
1556
1557 return wantarray ? ($default_key, $keyAliasProps) : $default_key;
1558};
1559
1560sub generate_typetext {
abc1afd8 1561 my ($format, $list_enums) = @_;
bf27456b 1562
d8c2b947 1563 my ($default_key, $keyAliasProps) = &$find_schema_default_key($format);
bf27456b
DM
1564
1565 my $res = '';
1566 my $add_sep = 0;
1567
1568 my $add_option_string = sub {
1569 my ($text, $optional) = @_;
1570
1571 if ($add_sep) {
1572 $text = ",$text";
1573 $res .= ' ';
1574 }
1575 $text = "[$text]" if $optional;
1576 $res .= $text;
1577 $add_sep = 1;
1578 };
1579
1580 my $format_key_value = sub {
1581 my ($key, $phash) = @_;
1582
1583 die "internal error" if defined($phash->{alias});
1584
1585 my $keytext = $key;
1586
1587 my $typetext = '';
1588
1589 if (my $desc = $phash->{format_description}) {
1590 $typetext .= "<$desc>";
1591 } elsif (my $text = $phash->{typetext}) {
1592 $typetext .= $text;
1593 } elsif (my $enum = $phash->{enum}) {
abc1afd8
DM
1594 if ($list_enums || (scalar(@$enum) <= 3)) {
1595 $typetext .= '<' . join('|', @$enum) . '>';
1596 } else {
1597 $typetext .= '<enum>';
1598 }
bf27456b
DM
1599 } elsif ($phash->{type} eq 'boolean') {
1600 $typetext .= '<1|0>';
1601 } elsif ($phash->{type} eq 'integer') {
1602 $typetext .= '<integer>';
1603 } elsif ($phash->{type} eq 'number') {
1604 $typetext .= '<number>';
1605 } else {
1606 die "internal error: neither format_description nor typetext found for option '$key'";
1607 }
1608
1609 if (defined($default_key) && ($default_key eq $key)) {
1610 &$add_option_string("[$keytext=]$typetext", $phash->{optional});
1611 } else {
1612 &$add_option_string("$keytext=$typetext", $phash->{optional});
1613 }
1614 };
1615
d8c2b947 1616 my $done = {};
bf27456b 1617
d8c2b947
DM
1618 my $cond_add_key = sub {
1619 my ($key) = @_;
1620
1621 return if $done->{$key}; # avoid duplicates
1622
1623 $done->{$key} = 1;
bf27456b
DM
1624
1625 my $phash = $format->{$key};
1626
d8c2b947
DM
1627 return if !$phash; # should not happen
1628
1629 return if $phash->{alias};
bf27456b
DM
1630
1631 &$format_key_value($key, $phash);
1632
d8c2b947
DM
1633 };
1634
1635 &$cond_add_key($default_key) if defined($default_key);
1636
1637 # add required keys first
1638 foreach my $key (sort keys %$format) {
1639 my $phash = $format->{$key};
1640 &$cond_add_key($key) if $phash && !$phash->{optional};
1641 }
1642
1643 # add the rest
1644 foreach my $key (sort keys %$format) {
1645 &$cond_add_key($key);
1646 }
1647
1648 foreach my $keyAlias (sort keys %$keyAliasProps) {
1649 &$add_option_string("<$keyAlias>=<$keyAliasProps->{$keyAlias }>", 1);
bf27456b
DM
1650 }
1651
1652 return $res;
1653}
1654
1655sub print_property_string {
1656 my ($data, $format, $skip, $path) = @_;
1657
1658 if (ref($format) ne 'HASH') {
1659 my $schema = get_format($format);
1660 die "not a valid format: $format\n" if !$schema;
1661 $format = $schema;
1662 }
1663
1664 my $errors = {};
1665 check_object($path, $format, $data, undef, $errors);
1666 if (scalar(%$errors)) {
1667 raise "format error", errors => $errors;
1668 }
1669
1670 my ($default_key, $keyAliasProps) = &$find_schema_default_key($format);
1671
1672 my $res = '';
1673 my $add_sep = 0;
1674
1675 my $add_option_string = sub {
1676 my ($text) = @_;
1677
1678 $res .= ',' if $add_sep;
1679 $res .= $text;
1680 $add_sep = 1;
1681 };
1682
1683 my $format_value = sub {
1684 my ($key, $value, $format) = @_;
1685
1686 if (defined($format) && ($format eq 'disk-size')) {
1687 return format_size($value);
1688 } else {
1689 die "illegal value with commas for $key\n" if $value =~ /,/;
1690 return $value;
1691 }
1692 };
1693
2289890b 1694 my $done = { map { $_ => 1 } @$skip };
bf27456b
DM
1695
1696 my $cond_add_key = sub {
971353e8 1697 my ($key, $isdefault) = @_;
bf27456b
DM
1698
1699 return if $done->{$key}; # avoid duplicates
1700
1701 $done->{$key} = 1;
1702
1703 my $value = $data->{$key};
1704
1705 return if !defined($value);
1706
1707 my $phash = $format->{$key};
1708
1709 # try to combine values if we have key aliases
1710 if (my $combine = $keyAliasProps->{$key}) {
1711 if (defined(my $combine_value = $data->{$combine})) {
1712 my $combine_format = $format->{$combine}->{format};
1713 my $value_str = &$format_value($key, $value, $phash->{format});
1714 my $combine_str = &$format_value($combine, $combine_value, $combine_format);
1715 &$add_option_string("${value_str}=${combine_str}");
1716 $done->{$combine} = 1;
1717 return;
1718 }
1719 }
1720
1721 if ($phash && $phash->{alias}) {
1722 $phash = $format->{$phash->{alias}};
1723 }
1724
1725 die "invalid key '$key'\n" if !$phash;
1726 die "internal error" if defined($phash->{alias});
1727
1728 my $value_str = &$format_value($key, $value, $phash->{format});
971353e8
WB
1729 if ($isdefault) {
1730 &$add_option_string($value_str);
1731 } else {
1732 &$add_option_string("$key=${value_str}");
1733 }
bf27456b
DM
1734 };
1735
1736 # add default key first
971353e8 1737 &$cond_add_key($default_key, 1) if defined($default_key);
bf27456b 1738
d8c2b947
DM
1739 # add required keys first
1740 foreach my $key (sort keys %$data) {
1741 my $phash = $format->{$key};
1742 &$cond_add_key($key) if $phash && !$phash->{optional};
1743 }
1744
1745 # add the rest
bf27456b
DM
1746 foreach my $key (sort keys %$data) {
1747 &$cond_add_key($key);
1748 }
1749
1750 return $res;
1751}
1752
1753sub schema_get_type_text {
abc1afd8 1754 my ($phash, $style) = @_;
bf27456b 1755
32f8e0c7
DM
1756 my $type = $phash->{type} || 'string';
1757
bf27456b
DM
1758 if ($phash->{typetext}) {
1759 return $phash->{typetext};
1760 } elsif ($phash->{format_description}) {
1761 return "<$phash->{format_description}>";
1762 } elsif ($phash->{enum}) {
25d9bda9 1763 return "<" . join(' | ', sort @{$phash->{enum}}) . ">";
bf27456b
DM
1764 } elsif ($phash->{pattern}) {
1765 return $phash->{pattern};
32f8e0c7 1766 } elsif ($type eq 'integer' || $type eq 'number') {
05185ea2 1767 # NOTE: always access values as number (avoid converion to string)
bf27456b 1768 if (defined($phash->{minimum}) && defined($phash->{maximum})) {
25d9bda9 1769 return "<$type> (" . ($phash->{minimum} + 0) . " - " .
05185ea2 1770 ($phash->{maximum} + 0) . ")";
bf27456b 1771 } elsif (defined($phash->{minimum})) {
25d9bda9 1772 return "<$type> (" . ($phash->{minimum} + 0) . " - N)";
bf27456b 1773 } elsif (defined($phash->{maximum})) {
25d9bda9 1774 return "<$type> (-N - " . ($phash->{maximum} + 0) . ")";
bf27456b 1775 }
32f8e0c7 1776 } elsif ($type eq 'string') {
bf27456b
DM
1777 if (my $format = $phash->{format}) {
1778 $format = get_format($format) if ref($format) ne 'HASH';
1779 if (ref($format) eq 'HASH') {
abc1afd8
DM
1780 my $list_enums = 0;
1781 $list_enums = 1 if $style && $style eq 'config-sub';
1782 return generate_typetext($format, $list_enums);
bf27456b
DM
1783 }
1784 }
1785 }
1786
25d9bda9 1787 return "<$type>";
bf27456b
DM
1788}
1789
e143e9d8 17901;