1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
|
#!/usr/bin/python
# -*- coding: utf-8 -*-
# Copyright: (c) 2021, Ansible Project
# GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt)
# template: header.j2
# This module is autogenerated by vmware_rest_code_generator.
# See: https://github.com/ansible-collections/vmware_rest_code_generator
from __future__ import absolute_import, division, print_function
__metaclass__ = type
DOCUMENTATION = r"""
module: content_subscribedlibrary
short_description: Creates a new subscribed library
description: Creates a new subscribed library. <p> Once created, the subscribed library
will be empty. If the {@link LibraryModel#subscriptionInfo} property is set, the
Content Library Service will attempt to synchronize to the remote source. This
is an asynchronous operation so the content of the published library may not immediately
appear.
options:
client_token:
description:
- 'Unique token generated on the client for each creation request. The token
should be a universally unique identifier (UUID), for example: C(b8a2a2e3-2314-43cd-a871-6ede0f429751).
This token can be used to guarantee idempotent creation.'
type: str
creation_time:
description:
- The date and time when this library was created.
type: str
description:
description:
- A human-readable description for this library.
type: str
id:
description:
- An identifier which uniquely identifies this C(library_model).
type: str
last_modified_time:
description:
- The date and time when this library was last updated. This field is updated
automatically when the library properties are changed. This field is not
affected by adding, removing, or modifying a library item or its content
within the library. Tagging the library or syncing the subscribed library
does not alter this field.
type: str
last_sync_time:
description:
- The date and time when this library was last synchronized. This field applies
only to subscribed libraries. It is updated every time a synchronization
is triggered on the library. The value is not set for a local library.
type: str
library_id:
description:
- Identifier of the subscribed library whose content should be evicted. Required
with I(state=['absent', 'evict', 'present', 'sync'])
type: str
name:
description:
- The name of the library. A Library is identified by a human-readable name.
Library names cannot be undefined or an empty string. Names do not have
to be unique.
type: str
optimization_info:
description:
- Defines various optimizations and optimization parameters applied to this
library.
- 'Valid attributes are:'
- ' - C(optimize_remote_publishing) (bool): If set to C(True) then library
would be optimized for remote publishing. Turn it on if remote publishing
is dominant use case for this library. Remote publishing means here that
publisher and subscribers are not the part of the same C(vcenter) SSO
domain. Any optimizations could be done as result of turning on this optimization
during library creation. For example, library content could be stored
in different format but optimizations are not limited to just storage
format. Note, that value of this toggle could be set only during creation
of the library and you would need to migrate your library in case you
need to change this value (optimize the library for different use case).
([''present''])'
type: dict
publish_info:
description:
- Defines how this library is published so that it can be subscribed to by
a remote subscribed library. The C(publish_info) defines where and how
the metadata for this local library is accessible. A local library is
only published publically if C(publish_info.published) is C(True).
- 'Valid attributes are:'
- ' - C(authentication_method) (str): The C(authentication_method) indicates
how a subscribed library should authenticate to the published library
endpoint. ([''present''])'
- ' - Accepted values:'
- ' - BASIC'
- ' - NONE'
- ' - C(published) (bool): Whether the local library is published. ([''present''])'
- ' - C(publish_url) (str): The URL to which the library metadata is published
by the Content Library Service. This value can be used to set the C(subscription_info.subscriptionurl)
property when creating a subscribed library. ([''present''])'
- ' - C(user_name) (str): The username to require for authentication. ([''present''])'
- ' - C(password) (str): The new password to require for authentication. ([''present''])'
- ' - C(current_password) (str): The current password to verify. This field
is available starting in vSphere 6.7. ([''present''])'
- ' - C(persist_json_enabled) (bool): Whether library and library item metadata
are persisted in the storage backing as JSON files. This flag only applies
if the local library is published. Enabling JSON persistence allows you
to synchronize a subscribed library manually instead of over HTTP. You
copy the local library content and metadata to another storage backing
manually and then create a subscribed library referencing the location
of the library JSON file in the C(subscription_info.subscriptionurl).
When the subscribed library''s storage backing matches the subscription
URL, files do not need to be copied to the subscribed library. For a library
backed by a datastore, the library JSON file will be stored at the path
contentlib-{library_id}/lib.json on the datastore. For a library backed
by a remote file system, the library JSON file will be stored at {library_id}/lib.json
in the remote file system path. ([''present''])'
type: dict
server_guid:
description:
- The unique identifier of the vCenter server where the library exists.
type: str
session_timeout:
description:
- 'Timeout settings for client session. '
- 'The maximal number of seconds for the whole operation including connection
establishment, request sending and response. '
- The default value is 300s.
type: float
version_added: 2.1.0
state:
choices:
- absent
- evict
- present
- probe
- sync
default: present
description: []
type: str
storage_backings:
description:
- The list of default storage backings which are available for this library.
A storage backing defines a default storage location which can be used
to store files for library items in this library. Some library items,
for instance, virtual machine template items, support files that may be
distributed across various storage backings. One or more item files may
or may not be located on the default storage backing. Multiple default
storage locations are not currently supported but may become supported
in future releases.
- 'Valid attributes are:'
- ' - C(type) (str): The C(type) specifies the type of the storage backing.
([''present''])'
- ' - Accepted values:'
- ' - DATASTORE'
- ' - OTHER'
- ' - C(datastore_id) (str): Identifier of the datastore used to store the
content in the library. ([''present''])'
- ' - C(storage_uri) (str): URI identifying the location used to store the
content in the library. The following URI formats are supported: vSphere
6.5 <ul> <li>nfs://server/path?version=4 (for vCenter Server Appliance
only) - Specifies an NFS Version 4 server.</li> <li>nfs://server/path
(for vCenter Server Appliance only) - Specifies an NFS Version 3 server.
The nfs://server:/path format is also supported.</li> <li>smb://server/path
- Specifies an SMB server or Windows share.</li> </ul> vSphere 6.0 Update
1 <ul> <li>nfs://server:/path (for vCenter Server Appliance only)</li>
<li>file://unc-server/path (for vCenter Server for Windows only)</li>
<li>file:///mount/point (for vCenter Server Appliance only) - Local file
URIs are supported only when the path is a local mount point for an NFS
file system. Use of file URIs is strongly discouraged. Instead, use an
NFS URI to specify the remote file system.</li> </ul> vSphere 6.0 <ul>
<li>nfs://server:/path (for vCenter Server Appliance only)</li> <li>file://unc-server/path
(for vCenter Server for Windows only)</li> <li>file:///path - Local file
URIs are supported but strongly discouraged because it may interfere with
the performance of vCenter Server.</li> </ul> ([''present''])'
elements: dict
type: list
subscription_info:
description:
- Defines the subscription behavior for this Library. The C(subscription_info)
defines how this subscribed library synchronizes to a remote source. Setting
the value will determine the remote source to which the library synchronizes,
and how. Changing the subscription will result in synchronizing to a new
source. If the new source differs from the old one, the old library items
and data will be lost. Setting C(subscription_info.automaticSyncEnabled)
to false will halt subscription but will not remove existing cached data.
- 'Valid attributes are:'
- ' - C(authentication_method) (str): Indicate how the subscribed library
should authenticate with the published library endpoint. ([''present'',
''probe''])'
- ' - Accepted values:'
- ' - BASIC'
- ' - NONE'
- ' - C(automatic_sync_enabled) (bool): Whether the library should participate
in automatic library synchronization. In order for automatic synchronization
to happen, the global C(configuration_model.automatic_sync_enabled) option
must also be true. The subscription is still active even when automatic
synchronization is turned off, but synchronization is only activated with
an explicit call to M(vmware.vmware_rest.content_subscribedlibrary) with
C(state=sync) or M(vmware.vmware_rest.content_library_item) with C(state=sync).
In other words, manual synchronization is still available even when automatic
synchronization is disabled. ([''present'', ''probe''])'
- ' - C(on_demand) (bool): Indicates whether a library item''s content will
be synchronized only on demand. If this is set to C(True), then the library
item''s metadata will be synchronized but the item''s content (its files)
will not be synchronized. The Content Library Service will synchronize
the content upon request only. This can cause the first use of the content
to have a noticeable delay. Items without synchronized content can be
forcefully synchronized in advance using the M(vmware.vmware_rest.content_library_item)
with C(state=sync) call with C(force_sync_content) set to true. Once content
has been synchronized, the content can removed with the M(vmware.vmware_rest.content_library_item)
with C(state=sync) call. If this value is set to C(False), all content
will be synchronized in advance. ([''present'', ''probe''])'
- ' - C(password) (str): The password to use when authenticating. The password
must be set when using a password-based authentication method; empty strings
are not allowed. ([''present'', ''probe''])'
- ' - C(ssl_thumbprint) (str): An optional SHA-1 hash of the SSL certificate
for the remote endpoint. If this value is defined the SSL certificate
will be verified by comparing it to the SSL thumbprint. The SSL certificate
must verify against the thumbprint. When specified, the standard certificate
chain validation behavior is not used. The certificate chain is validated
normally if this value is not set. ([''present'', ''probe''])'
- ' - C(subscription_url) (str): The URL of the endpoint where the metadata
for the remotely published library is being served. This URL can be the
C(publish_info.publish_url) of the published library (for example, https://server/path/lib.json).
If the source content comes from a published library with C(publish_info.persist_json_enabled),
the subscription URL can be a URL pointing to the library JSON file on
a datastore or remote file system. The supported formats are: vSphere
6.5 <ul> <li>ds:///vmfs/volumes/{uuid}/mylibrary/lib.json (for datastore)</li>
<li>nfs://server/path/mylibrary/lib.json (for NFSv3 server on vCenter
Server Appliance)</li> <li>nfs://server/path/mylibrary/lib.json?version=4
(for NFSv4 server on vCenter Server Appliance) </li> <li>smb://server/path/mylibrary/lib.json
(for SMB server)</li> </ul> vSphere 6.0 <ul> <li>file://server/mylibrary/lib.json
(for UNC server on vCenter Server for Windows)</li> <li>file:///path/mylibrary/lib.json
(for local file system)</li> </ul> When you specify a DS subscription
URL, the datastore must be on the same vCenter Server as the subscribed
library. When you specify an NFS or SMB subscription URL, the C(storage_backings.storage_uri)
of the subscribed library must be on the same remote file server and should
share a common parent path with the subscription URL. ([''present'', ''probe''])'
- ' - C(user_name) (str): The username to use when authenticating. The username
must be set when using a password-based authentication method. Empty strings
are allowed for usernames. ([''present'', ''probe''])'
- ' - C(source_info) (dict): Information about the source published library.
This field will be set for a subscribed library which is associated with
a subscription of the published library. ([''present'', ''probe''])'
- ' - Accepted keys:'
- ' - source_library (string): Identifier of the published library.'
- ' - subscription (string): Identifier of the subscription associated
with the subscribed library.'
type: dict
type:
choices:
- LOCAL
- SUBSCRIBED
description:
- The C(library_type) defines the type of a Library. The type of a library
can be used to determine which additional services can be performed with
a library.
type: str
vcenter_hostname:
description:
- The hostname or IP address of the vSphere vCenter
- If the value is not specified in the task, the value of environment variable
C(VMWARE_HOST) will be used instead.
required: true
type: str
vcenter_password:
description:
- The vSphere vCenter password
- If the value is not specified in the task, the value of environment variable
C(VMWARE_PASSWORD) will be used instead.
required: true
type: str
vcenter_rest_log_file:
description:
- 'You can use this optional parameter to set the location of a log file. '
- 'This file will be used to record the HTTP REST interaction. '
- 'The file will be stored on the host that run the module. '
- 'If the value is not specified in the task, the value of '
- environment variable C(VMWARE_REST_LOG_FILE) will be used instead.
type: str
vcenter_username:
description:
- The vSphere vCenter username
- If the value is not specified in the task, the value of environment variable
C(VMWARE_USER) will be used instead.
required: true
type: str
vcenter_validate_certs:
default: true
description:
- Allows connection when SSL certificates are not valid. Set to C(false) when
certificates are not trusted.
- If the value is not specified in the task, the value of environment variable
C(VMWARE_VALIDATE_CERTS) will be used instead.
type: bool
version:
description:
- A version number which is updated on metadata changes. This value allows
clients to detect concurrent updates and prevent accidental clobbering
of data. This value represents a number which is incremented every time
library properties, such as name or description, are changed. It is not
incremented by changes to a library item within the library, including
adding or removing items. It is also not affected by tagging the library.
type: str
author:
- Ansible Cloud Team (@ansible-collections)
version_added: 2.0.0
requirements:
- vSphere 7.0.2 or greater
- python >= 3.6
- aiohttp
notes:
- Tested on vSphere 7.0.2
"""
EXAMPLES = r"""
- name: Create a content library pointing on a NFS share
vmware.vmware_rest.content_locallibrary:
name: my_library_on_nfs
description: automated
publish_info:
published: true
authentication_method: NONE
storage_backings:
- storage_uri: nfs://datastore.test/srv/share/content-library
type: OTHER
state: present
register: nfs_lib
- name: Create subscribed library
vmware.vmware_rest.content_subscribedlibrary:
name: sub_lib
subscription_info:
subscription_url: '{{ nfs_lib.value.publish_info.publish_url }}'
authentication_method: NONE
automatic_sync_enabled: false
on_demand: true
storage_backings:
- datastore_id: "{{ lookup('vmware.vmware_rest.datastore_moid', '/my_dc/datastore/rw_datastore') }}"
type: DATASTORE
register: sub_lib
- name: Create subscribed library (again)
vmware.vmware_rest.content_subscribedlibrary:
name: sub_lib
subscription_info:
subscription_url: '{{ nfs_lib.value.publish_info.publish_url }}'
authentication_method: NONE
automatic_sync_enabled: false
on_demand: true
storage_backings:
- datastore_id: "{{ lookup('vmware.vmware_rest.datastore_moid', '/my_dc/datastore/rw_datastore') }}"
type: DATASTORE
register: result
- name: Clean up the cache
vmware.vmware_rest.content_subscribedlibrary:
name: sub_lib
library_id: '{{ sub_lib.id }}'
state: evict
- name: Trigger a library sync
vmware.vmware_rest.content_subscribedlibrary:
name: sub_lib
library_id: '{{ sub_lib.id }}'
state: sync
"""
RETURN = r"""
# content generated by the update_return_section callback# task: Delete all the subscribed libraries
msg:
description: Delete all the subscribed libraries
returned: On success
sample: All items completed
type: str
results:
description: Delete all the subscribed libraries
returned: On success
sample:
- _ansible_item_label:
creation_time: '2022-11-23T20:06:05.189Z'
description: ''
id: 8b4e355e-a463-44f1-9b04-d0786a49cc7d
last_modified_time: '2022-11-23T20:06:05.189Z'
last_sync_time: '2022-11-23T20:06:07.717Z'
name: sub_lib
server_guid: 52fb0b5e-ffc3-465b-bf4f-e4e6d5423cf5
storage_backings:
- datastore_id: datastore-1065
type: DATASTORE
subscription_info:
authentication_method: NONE
automatic_sync_enabled: 0
on_demand: 1
subscription_url: https://vcenter.test:443/cls/vcsp/lib/a66d5c73-57f8-4a3a-9361-292a55f68516/lib.json
type: SUBSCRIBED
version: '4'
_ansible_no_log: null
ansible_loop_var: item
changed: 1
failed: 0
invocation:
module_args:
client_token: null
creation_time: null
description: null
id: null
last_modified_time: null
last_sync_time: null
library_id: 8b4e355e-a463-44f1-9b04-d0786a49cc7d
name: null
optimization_info: null
publish_info: null
server_guid: null
session_timeout: null
state: absent
storage_backings: null
subscription_info: null
type: null
vcenter_hostname: vcenter.test
vcenter_password: VALUE_SPECIFIED_IN_NO_LOG_PARAMETER
vcenter_rest_log_file: /tmp/vmware_rest.log
vcenter_username: administrator@vsphere.local
vcenter_validate_certs: 0
version: null
item:
creation_time: '2022-11-23T20:06:05.189Z'
description: ''
id: 8b4e355e-a463-44f1-9b04-d0786a49cc7d
last_modified_time: '2022-11-23T20:06:05.189Z'
last_sync_time: '2022-11-23T20:06:07.717Z'
name: sub_lib
server_guid: 52fb0b5e-ffc3-465b-bf4f-e4e6d5423cf5
storage_backings:
- datastore_id: datastore-1065
type: DATASTORE
subscription_info:
authentication_method: NONE
automatic_sync_enabled: 0
on_demand: 1
subscription_url: https://vcenter.test:443/cls/vcsp/lib/a66d5c73-57f8-4a3a-9361-292a55f68516/lib.json
type: SUBSCRIBED
version: '4'
value: {}
type: list
"""
# This structure describes the format of the data expected by the end-points
PAYLOAD_FORMAT = {
"sync": {"query": {}, "body": {}, "path": {"library_id": "library_id"}},
"update": {
"query": {},
"body": {
"creation_time": "creation_time",
"description": "description",
"id": "id",
"last_modified_time": "last_modified_time",
"last_sync_time": "last_sync_time",
"name": "name",
"optimization_info": "optimization_info",
"publish_info": "publish_info",
"server_guid": "server_guid",
"storage_backings": "storage_backings",
"subscription_info": "subscription_info",
"type": "type",
"version": "version",
},
"path": {"library_id": "library_id"},
},
"create": {
"query": {"client_token": "client_token"},
"body": {
"creation_time": "creation_time",
"description": "description",
"id": "id",
"last_modified_time": "last_modified_time",
"last_sync_time": "last_sync_time",
"name": "name",
"optimization_info": "optimization_info",
"publish_info": "publish_info",
"server_guid": "server_guid",
"storage_backings": "storage_backings",
"subscription_info": "subscription_info",
"type": "type",
"version": "version",
},
"path": {},
},
"delete": {"query": {}, "body": {}, "path": {"library_id": "library_id"}},
"probe": {
"query": {},
"body": {"subscription_info": "subscription_info"},
"path": {},
},
"evict": {"query": {}, "body": {}, "path": {"library_id": "library_id"}},
} # pylint: disable=line-too-long
import json
import socket
from ansible.module_utils.basic import env_fallback
try:
from ansible_collections.cloud.common.plugins.module_utils.turbo.exceptions import (
EmbeddedModuleFailure,
)
from ansible_collections.cloud.common.plugins.module_utils.turbo.module import (
AnsibleTurboModule as AnsibleModule,
)
AnsibleModule.collection_name = "vmware.vmware_rest"
except ImportError:
from ansible.module_utils.basic import AnsibleModule
from ansible_collections.vmware.vmware_rest.plugins.module_utils.vmware_rest import (
build_full_device_list,
exists,
gen_args,
get_device_info,
get_subdevice_type,
list_devices,
open_session,
prepare_payload,
update_changed_flag,
session_timeout,
)
def prepare_argument_spec():
argument_spec = {
"vcenter_hostname": dict(
type="str", required=True, fallback=(env_fallback, ["VMWARE_HOST"]),
),
"vcenter_username": dict(
type="str", required=True, fallback=(env_fallback, ["VMWARE_USER"]),
),
"vcenter_password": dict(
type="str",
required=True,
no_log=True,
fallback=(env_fallback, ["VMWARE_PASSWORD"]),
),
"vcenter_validate_certs": dict(
type="bool",
required=False,
default=True,
fallback=(env_fallback, ["VMWARE_VALIDATE_CERTS"]),
),
"vcenter_rest_log_file": dict(
type="str",
required=False,
fallback=(env_fallback, ["VMWARE_REST_LOG_FILE"]),
),
"session_timeout": dict(
type="float",
required=False,
fallback=(env_fallback, ["VMWARE_SESSION_TIMEOUT"]),
),
}
argument_spec["client_token"] = {"no_log": True, "type": "str"}
argument_spec["creation_time"] = {"type": "str"}
argument_spec["description"] = {"type": "str"}
argument_spec["id"] = {"type": "str"}
argument_spec["last_modified_time"] = {"type": "str"}
argument_spec["last_sync_time"] = {"type": "str"}
argument_spec["library_id"] = {"type": "str"}
argument_spec["name"] = {"type": "str"}
argument_spec["optimization_info"] = {"type": "dict"}
argument_spec["publish_info"] = {"type": "dict"}
argument_spec["server_guid"] = {"type": "str"}
argument_spec["state"] = {
"type": "str",
"choices": ["absent", "evict", "present", "probe", "sync"],
"default": "present",
}
argument_spec["storage_backings"] = {"type": "list", "elements": "dict"}
argument_spec["subscription_info"] = {"type": "dict"}
argument_spec["type"] = {"type": "str", "choices": ["LOCAL", "SUBSCRIBED"]}
argument_spec["version"] = {"type": "str"}
return argument_spec
async def main():
required_if = list([])
module_args = prepare_argument_spec()
module = AnsibleModule(
argument_spec=module_args, required_if=required_if, supports_check_mode=True
)
if not module.params["vcenter_hostname"]:
module.fail_json("vcenter_hostname cannot be empty")
if not module.params["vcenter_username"]:
module.fail_json("vcenter_username cannot be empty")
if not module.params["vcenter_password"]:
module.fail_json("vcenter_password cannot be empty")
try:
session = await open_session(
vcenter_hostname=module.params["vcenter_hostname"],
vcenter_username=module.params["vcenter_username"],
vcenter_password=module.params["vcenter_password"],
validate_certs=module.params["vcenter_validate_certs"],
log_file=module.params["vcenter_rest_log_file"],
)
except EmbeddedModuleFailure as err:
module.fail_json(err.get_message())
result = await entry_point(module, session)
module.exit_json(**result)
# template: default_module.j2
def build_url(params):
return ("https://{vcenter_hostname}" "/api/content/subscribed-library").format(
**params
)
async def entry_point(module, session):
if module.params["state"] == "present":
if "_create" in globals():
operation = "create"
else:
operation = "update"
elif module.params["state"] == "absent":
operation = "delete"
else:
operation = module.params["state"]
func = globals()["_" + operation]
return await func(module.params, session)
async def _create(params, session):
lookup_url = per_id_url = build_url(params)
uniquity_keys = ["name"]
comp_func = None
_json = None
if params["library_id"]:
_json = await get_device_info(session, build_url(params), params["library_id"])
if not _json and (uniquity_keys or comp_func):
_json = await exists(
params,
session,
url=lookup_url,
uniquity_keys=uniquity_keys,
per_id_url=per_id_url,
comp_func=comp_func,
)
if _json:
if "value" not in _json: # 7.0.2+
_json = {"value": _json}
if "_update" in globals():
params["library_id"] = _json["id"]
return await globals()["_update"](params, session)
return await update_changed_flag(_json, 200, "get")
payload = prepare_payload(params, PAYLOAD_FORMAT["create"])
_url = ("https://{vcenter_hostname}" "/api/content/subscribed-library").format(
**params
)
async with session.post(_url, json=payload, **session_timeout(params)) as resp:
if resp.status == 500:
text = await resp.text()
raise EmbeddedModuleFailure(
f"Request has failed: status={resp.status}, {text}"
)
try:
if resp.headers["Content-Type"] == "application/json":
_json = await resp.json()
except KeyError:
_json = {}
if (resp.status in [200, 201]) and "error" not in _json:
if isinstance(_json, str): # 7.0.2 and greater
_id = _json # TODO: fetch the object
elif isinstance(_json, dict) and "value" not in _json:
_id = list(_json["value"].values())[0]
elif isinstance(_json, dict) and "value" in _json:
_id = _json["value"]
_json_device_info = await get_device_info(session, _url, _id)
if _json_device_info:
_json = _json_device_info
return await update_changed_flag(_json, resp.status, "create")
async def _delete(params, session):
_in_query_parameters = PAYLOAD_FORMAT["delete"]["query"].keys()
payload = prepare_payload(params, PAYLOAD_FORMAT["delete"])
subdevice_type = get_subdevice_type("/api/content/subscribed-library/{library_id}")
if subdevice_type and not params[subdevice_type]:
_json = await exists(params, session, build_url(params))
if _json:
params[subdevice_type] = _json["id"]
_url = (
"https://{vcenter_hostname}" "/api/content/subscribed-library/{library_id}"
).format(**params) + gen_args(params, _in_query_parameters)
async with session.delete(_url, json=payload, **session_timeout(params)) as resp:
try:
if resp.headers["Content-Type"] == "application/json":
_json = await resp.json()
except KeyError:
_json = {}
return await update_changed_flag(_json, resp.status, "delete")
async def _evict(params, session):
_in_query_parameters = PAYLOAD_FORMAT["evict"]["query"].keys()
payload = prepare_payload(params, PAYLOAD_FORMAT["evict"])
subdevice_type = get_subdevice_type(
"/api/content/subscribed-library/{library_id}?action=evict"
)
if subdevice_type and not params[subdevice_type]:
_json = await exists(params, session, build_url(params))
if _json:
params[subdevice_type] = _json["id"]
_url = (
"https://{vcenter_hostname}"
# aa
"/api/content/subscribed-library/{library_id}?action=evict"
).format(**params) + gen_args(params, _in_query_parameters)
async with session.post(_url, json=payload, **session_timeout(params)) as resp:
try:
if resp.headers["Content-Type"] == "application/json":
_json = await resp.json()
except KeyError:
_json = {}
if "value" not in _json: # 7.0.2
_json = {"value": _json}
return await update_changed_flag(_json, resp.status, "evict")
async def _probe(params, session):
_in_query_parameters = PAYLOAD_FORMAT["probe"]["query"].keys()
payload = prepare_payload(params, PAYLOAD_FORMAT["probe"])
subdevice_type = get_subdevice_type("/api/content/subscribed-library?action=probe")
if subdevice_type and not params[subdevice_type]:
_json = await exists(params, session, build_url(params))
if _json:
params[subdevice_type] = _json["id"]
_url = (
"https://{vcenter_hostname}"
# aa
"/api/content/subscribed-library?action=probe"
).format(**params) + gen_args(params, _in_query_parameters)
async with session.post(_url, json=payload, **session_timeout(params)) as resp:
try:
if resp.headers["Content-Type"] == "application/json":
_json = await resp.json()
except KeyError:
_json = {}
if "value" not in _json: # 7.0.2
_json = {"value": _json}
return await update_changed_flag(_json, resp.status, "probe")
async def _sync(params, session):
_in_query_parameters = PAYLOAD_FORMAT["sync"]["query"].keys()
payload = prepare_payload(params, PAYLOAD_FORMAT["sync"])
subdevice_type = get_subdevice_type(
"/api/content/subscribed-library/{library_id}?action=sync"
)
if subdevice_type and not params[subdevice_type]:
_json = await exists(params, session, build_url(params))
if _json:
params[subdevice_type] = _json["id"]
_url = (
"https://{vcenter_hostname}"
# aa
"/api/content/subscribed-library/{library_id}?action=sync"
).format(**params) + gen_args(params, _in_query_parameters)
async with session.post(_url, json=payload, **session_timeout(params)) as resp:
try:
if resp.headers["Content-Type"] == "application/json":
_json = await resp.json()
except KeyError:
_json = {}
if "value" not in _json: # 7.0.2
_json = {"value": _json}
return await update_changed_flag(_json, resp.status, "sync")
async def _update(params, session):
payload = prepare_payload(params, PAYLOAD_FORMAT["update"])
_url = (
"https://{vcenter_hostname}" "/api/content/subscribed-library/{library_id}"
).format(**params)
async with session.get(_url, **session_timeout(params)) as resp:
_json = await resp.json()
if "value" in _json:
value = _json["value"]
else: # 7.0.2 and greater
value = _json
for k, v in value.items():
if k in payload:
if isinstance(payload[k], dict) and isinstance(v, dict):
to_delete = True
for _k in list(payload[k].keys()):
if payload[k][_k] != v.get(_k):
to_delete = False
if to_delete:
del payload[k]
elif payload[k] == v:
del payload[k]
elif payload[k] == {}:
del payload[k]
if payload == {} or payload == {"spec": {}}:
# Nothing has changed
if "value" not in _json: # 7.0.2
_json = {"value": _json}
_json["id"] = params.get("library_id")
return await update_changed_flag(_json, resp.status, "get")
async with session.patch(_url, json=payload, **session_timeout(params)) as resp:
try:
if resp.headers["Content-Type"] == "application/json":
_json = await resp.json()
except KeyError:
_json = {}
if "value" not in _json: # 7.0.2
_json = {"value": _json}
# e.g: content_configuration
if not _json and resp.status == 204:
async with session.get(_url, **session_timeout(params)) as resp_get:
_json_get = await resp_get.json()
if _json_get:
_json = _json_get
_json["id"] = params.get("library_id")
return await update_changed_flag(_json, resp.status, "update")
if __name__ == "__main__":
import asyncio
current_loop = asyncio.get_event_loop_policy().get_event_loop()
current_loop.run_until_complete(main())
|