VhRmdZdZdZddlZ ddlZddlmZddlm Z ddl m Z ddl m Z dd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddlmZGddeZdZedk(reyy#e$rYkwxYw)a module: sns_topic short_description: Manages AWS SNS topics and subscriptions version_added: 1.0.0 description: - The M(community.aws.sns_topic) module allows you to create, delete, and manage subscriptions for AWS SNS topics. author: - "Joel Thompson (@joelthompson)" - "Fernando Jose Pando (@nand0p)" - "Will Thames (@willthames)" options: name: description: - The name or ARN of the SNS topic to manage. required: true type: str topic_type: description: - The type of topic that should be created. Either Standard for FIFO (first-in, first-out). - Some regions, including GovCloud regions do not support FIFO topics. Use a default value of 'standard' or omit the option if the region does not support FIFO topics. choices: ["standard", "fifo"] default: 'standard' type: str version_added: 2.0.0 state: description: - Whether to create or destroy an SNS topic. default: present choices: ["absent", "present"] type: str display_name: description: - Display name of the topic. type: str policy: description: - Policy to apply to the SNS topic. - Policy body can be YAML or JSON. - This is required for certain use cases for example with S3 bucket notifications. type: dict delivery_policy: description: - Delivery policy to apply to the SNS topic. type: dict suboptions: http: description: - Delivery policy for HTTP(S) messages. - See U(https://docs.aws.amazon.com/sns/latest/dg/sns-message-delivery-retries.html) for more information. type: dict required: false suboptions: disableSubscriptionOverrides: description: - Applies this policy to all subscriptions, even if they have their own policies. type: bool required: false defaultThrottlePolicy: description: - Throttle the rate of messages sent to subsriptions. type: dict suboptions: maxReceivesPerSecond: description: - The maximum number of deliveries per second per subscription. type: int required: true required: false defaultHealthyRetryPolicy: description: - Retry policy for HTTP(S) messages. type: dict required: true suboptions: minDelayTarget: description: - The minimum delay for a retry. type: int required: true maxDelayTarget: description: - The maximum delay for a retry. type: int required: true numRetries: description: - The total number of retries. type: int required: true numMaxDelayRetries: description: - The number of retries with the maximum delay between them. type: int required: true numMinDelayRetries: description: - The number of retries with just the minimum delay between them. type: int required: true numNoDelayRetries: description: - The number of retries to be performmed immediately. type: int required: true backoffFunction: description: - The function for backoff between retries. type: str required: true choices: ['arithmetic', 'exponential', 'geometric', 'linear'] subscriptions: description: - List of subscriptions to apply to the topic. Note that AWS requires subscriptions to be confirmed, so you will need to confirm any new subscriptions. suboptions: endpoint: description: Endpoint of subscription. required: true protocol: description: Protocol of subscription. required: true attributes: description: Attributes of subscription. Only supports RawMessageDelievery for SQS endpoints. default: {} version_added: "4.1.0" type: list elements: dict default: [] purge_subscriptions: description: - "Whether to purge any subscriptions not listed here. NOTE: AWS does not allow you to purge any PendingConfirmation subscriptions, so if any exist and would be purged, they are silently skipped. This means that somebody could come back later and confirm the subscription. Sorry. Blame Amazon." default: true type: bool content_based_deduplication: description: - Whether to enable content-based deduplication for this topic. - Ignored unless I(topic_type=fifo). - Defaults to C(disabled). choices: ["disabled", "enabled"] type: str version_added: 5.3.0 notes: - Support for I(tags) and I(purge_tags) was added in release 5.3.0. extends_documentation_fragment: - amazon.aws.common.modules - amazon.aws.region.modules - amazon.aws.tags.modules - amazon.aws.boto3 a8 - name: Create alarm SNS topic community.aws.sns_topic: name: "alarms" state: present display_name: "alarm SNS topic" delivery_policy: http: defaultHealthyRetryPolicy: minDelayTarget: 2 maxDelayTarget: 4 numRetries: 9 numMaxDelayRetries: 5 numMinDelayRetries: 2 numNoDelayRetries: 2 backoffFunction: "linear" disableSubscriptionOverrides: true defaultThrottlePolicy: maxReceivesPerSecond: 10 subscriptions: - endpoint: "my_email_address@example.com" protocol: "email" - endpoint: "my_mobile_number" protocol: "sms" - name: Create a topic permitting S3 bucket notifications community.aws.sns_topic: name: "S3Notifications" state: present display_name: "S3 notifications SNS topic" policy: Id: s3-topic-policy Version: 2012-10-17 Statement: - Sid: Statement-id Effect: Allow Resource: "arn:aws:sns:*:*:S3Notifications" Principal: Service: s3.amazonaws.com Action: sns:Publish Condition: ArnLike: aws:SourceArn: "arn:aws:s3:*:*:SomeBucket" - name: Example deleting a topic community.aws.sns_topic: name: "ExampleTopic" state: absent a sns_arn: description: The ARN of the topic you are modifying type: str returned: always sample: "arn:aws:sns:us-east-2:123456789012:my_topic_name" sns_topic: description: Dict of sns topic details type: complex returned: always contains: attributes_set: description: list of attributes set during this run returned: always type: list sample: [] check_mode: description: whether check mode was on returned: always type: bool sample: false content_based_deduplication: description: Whether or not content_based_deduplication was set returned: always type: str sample: disabled version_added: 5.3.0 delivery_policy: description: Delivery policy for the SNS topic returned: when topic is owned by this AWS account type: str sample: > {"http":{"defaultHealthyRetryPolicy":{"minDelayTarget":20,"maxDelayTarget":20,"numRetries":3,"numMaxDelayRetries":0, "numNoDelayRetries":0,"numMinDelayRetries":0,"backoffFunction":"linear"},"disableSubscriptionOverrides":false}} display_name: description: Display name for SNS topic returned: when topic is owned by this AWS account type: str sample: My topic name name: description: Topic name returned: always type: str sample: ansible-test-dummy-topic owner: description: AWS account that owns the topic returned: when topic is owned by this AWS account type: str sample: '123456789012' policy: description: Policy for the SNS topic returned: when topic is owned by this AWS account type: str sample: > {"Version":"2012-10-17","Id":"SomePolicyId","Statement":[{"Sid":"ANewSid","Effect":"Allow","Principal":{"AWS":"arn:aws:iam::123456789012:root"}, "Action":"sns:Subscribe","Resource":"arn:aws:sns:us-east-2:123456789012:ansible-test-dummy-topic","Condition":{"StringEquals":{"sns:Protocol":"email"}}}]} state: description: whether the topic is present or absent returned: always type: str sample: present subscriptions: description: List of subscribers to the topic in this AWS account returned: always type: list sample: [] subscriptions_added: description: List of subscribers added in this run returned: always type: list sample: [] subscriptions_confirmed: description: Count of confirmed subscriptions returned: when topic is owned by this AWS account type: str sample: '0' subscriptions_deleted: description: Count of deleted subscriptions returned: when topic is owned by this AWS account type: str sample: '0' subscriptions_existing: description: List of existing subscriptions returned: always type: list sample: [] subscriptions_new: description: List of new subscriptions returned: always type: list sample: [] subscriptions_pending: description: Count of pending subscriptions returned: when topic is owned by this AWS account type: str sample: '0' subscriptions_purge: description: Whether or not purge_subscriptions was set returned: always type: bool sample: true topic_arn: description: ARN of the SNS topic (equivalent to sns_arn) returned: when topic is owned by this AWS account type: str sample: arn:aws:sns:us-east-2:123456789012:ansible-test-dummy-topic topic_created: description: Whether the topic was created returned: always type: bool sample: false topic_deleted: description: Whether the topic was deleted returned: always type: bool sample: false N) parse_aws_arn)compare_policies)ansible_dict_to_boto3_tag_list)scrub_none_parameters)AnsibleCommunityAWSModule)canonicalize_endpoint)compare_delivery_policies)get_info)list_topic_subscriptions) list_topics)topic_arn_lookup) update_tagscXeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd Zy)SnsTopicManagerz*Handles SNS Topic creation and destructionc|jd|_||_||_||_||_||_||_|r t|nd|_ ||_ g|_ g|_ g|_ g|_t|_| |_| |_| |_d|_d|_d|_g|_| |_| |_y)NsnsF)client connectionmodulename topic_typestate display_namepolicyrdelivery_policy subscriptionssubscriptions_existingsubscriptions_deletedsubscriptions_addedsubscriptions_attributes_setdictdesired_subscription_attributespurge_subscriptionscontent_based_deduplication check_mode topic_created topic_deleted topic_arnattributes_settags purge_tags)selfrrrrrrrrr#r*r+r$r%s k/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/aws/plugins/modules/sns_topic.py__init__zSnsTopicManager.__init__gs !--.  $ ( IX4_E^b*&(#%'"#% ,.)/3v,#6 +F($""  $c.i}g}|jdk(r4d|d<|jjds|jdz|_|jrt |j}|j s3 |j j|j||}d|_y #tjjtjjf$r4}|jj|d|jYd}~qd}~wwxYw) Nfifotrue FifoTopic.fifo)Name AttributesTagszCouldn't create topic msgTopicArnT)rrendswithr*rr%r create_topicbotocore exceptions ClientError BotoCoreErrorr fail_json_awsr()r, attributesr*responsees r- _create_topiczSnsTopicManager._create_topics  ??f $&,J{ #99%%g. II/ 991$))r?r@rrArr)appendr%set_topic_attributesrrjsonloadsdumpsr$rr )r,changedtopic_attributesrDrLs r-_set_topic_attrsz SnsTopicManager._set_topic_attrss j#CCT^^C\]ij    !2!26F}6U!UG    & &~ 6??ROO88!%}]a]n]n9 ;;+DKKDTU]D^9_`G    & &x 0??ROO88!%xX\XbXbcgcncnXo9 + +0@0MQW0W.. $ @ @I MfSZG*+FGG##**+HIe<<%)^^C^ov=    $4 4()=)=tzzJZ[kJl?mnG    & &'8 9??[OO88!%&6'+zz$2F2F'G9wq##//1D1D1R1RS j KK % %a/WX\XfXfWg-h % i i j!++779L9L9Z9Z[RKK--a5P-QQR!++779L9L9Z9Z[RKK--a5P-QQR %//;;X=P=P=^=^_e 11!9c1dde !++779L9L9Z9Z[[KK--a5Y-ZZ[sy)J52K0 AM*(N48AP7K-8*K((K-07M'M  M7N1 N,,N147P+PP7Q5 Q00Q5c rd}t}|jDcgc]}|dt|d|df}}t|j|j |j D]}|d|df}|j||js+||vs0|ddvs8d}|jj||jrb |jj|d t|j%|D]Z\}}d}|j&j||f|jr2 |jj)|j || \|Scc}w#tjjtjj f$r(}|j j#|d Yd}~\d}~wwxYw#tjjtjj f$r5}|j j#|d |j  Yd}~-d}~wwxYw)NFprotocolendpointProtocolEndpointSubscriptionArnPendingConfirmationDeletedTr^Couldn't unsubscribe from topicr8)r:r\r]zCouldn't subscribe to topic )setrrr rrr(addr#rrQr% unsubscriber=r>r?r@rA differencer subscribe) r,rVsubscriptions_existing_listsubdesired_subscriptionssub_keyrDrZr[s r-_set_topic_subszSnsTopicManager._set_topic_subss&)e#bfbtbt! [^S_3C OS_U V! ! ,DOOT[[$..Y \C:J8G ' + +G 4((#88)*2TT**11':\33CHYDZ3[ \ #&&;"<"G"GHc"d f HhG  $ $ + +Xx,@ A??fOO--t~~PXck-l  f9! "%//;;X=P=P=^=^_\ 11!9Z1[[\!++779L9L9Z9Z[fKK--a7STXTbTbSc5d-eefs5E# E(7(G (7GGG 7H6*H11H6c|jD]`}|dt|d|df}|jdi}|jD]\}}t |||<||j |<by)NrZr[rB)rrgetitemsstrr")r,rjrltmp_dictkvs r-%_init_desired_subscription_attributesz5SnsTopicManager._init_desired_subscription_attributess%% EC:(=c*osS](_`Gww|R0H!( %1!!f  %=ED 0 0 9 Er/czd}t|j|j|jD]}|d|df}|d}|jj |s. |jj |d}|j|j d}|odvst|dj|jk7sd }|jr |jj|d| |S#tjjtjjf$r)}|jj|d|Yd}~d}~wwxYw#tjjtjjf$r'}|jj|d Yd}~d}~wwxYw) NFr\r]r^rbr6z6Couldn't get subscription attributes for subscription RawMessageDeliveryT)r^rIrJz6Couldn't set RawMessageDelivery subscription attribute)r rrr(r"roget_subscription_attributesr=r>r?r@rAlowerr%set_subscription_attributes)r,rVrjrlsub_arnsub_current_attributesrD raw_messages r-_set_topic_subs_attributesz*SnsTopicManager._set_topic_subs_attributess+DOOT[[$..Y sC:J8G+,G77;;GD q)-)T)Tel)T)m *& >>wGKKL`aK&+?CY+Y)*>?EEG;K\K\K^^"G??s OOGG07G[lwH) s4''33X5H5H5V5VW q ))!/efmen-opp q!) 3 3 ? ?ATATAbAbcs KK55a9qrrss0C9E97E0EE7F:F55F:ct|j|j|j}|sy|D]U}|ddvs |jj |d|j r6 |jj|dWy#tjjtjjf$r'}|jj|dYd}~d}~wwxYw)NFr^r_rbrcr8T) r rrr(rrQr%rfr=r>r?r@rA)r,rrjrDs r-_delete_subscriptionsz%SnsTopicManager._delete_subscriptions-s1$++t~~^   \C$%-OO**11#6G2HI\33CHYDZ3[  \%//;;X=P=P=^=^_\ 11!9Z1[[\s(B  7C(C##C(cVd|_|js( |jj|jyy#t j jt j jf$r4}|jj|d|jYd}~yd}~wwxYw)NTrGzCouldn't delete topic r8) r'r%r delete_topicr(r=r>r?r@rrA)r,rDs r- _delete_topiczSnsTopicManager._delete_topic=s! \,,dnn,E''33X5H5H5V5VW \ ))!3I$..IY1Z)[[ \s&=7B(4*B##B(c>tt|jS)N)boolrr)r,s r- _name_is_arnzSnsTopicManager._name_is_arnFsM$)),--r/cd}|j|js|j}|jt|j|j vr||j z}n@|js|js |jr|j jd||jz}|j|jt|j|j vr||jz}n?t|jj!r|j jd|t#|j|j |jz}|S)NFz[Cannot set display name, policy or delivery policy for SNS topics not owned by this accountr8zKCannot set subscription attributes for SNS topics not owned by this account)populate_topic_arnr(rEr rrrXrrr fail_jsonrmrur~anyr"valuesrr,rVs r- ensure_okzSnsTopicManager.ensure_okIs' !~~((*G >>[$++F F t,,. .G   $++1E1E KK ! !q "  4'')) 224 >>[$++F F t668 8G 55<<> ? KK ! !&s ! t;t T^^LLr/cd}|j|jrk|jt|j|jvr|jj d|j }||jz}|S)NFzOCannot use state=absent with third party ARN. Use subscribers=[] to unsubscriber8)rr(r rrrrrrs r- ensure_gonezSnsTopicManager.ensure_gone_sw ! >>~~[$++%NN %%i&002G t))+ +Gr/c|jr|j|_y|j}|jdk(r|j ds|dz }t |j |j||_y)Nr1r4)rrr(rr;r rr)r,rs r-rz"SnsTopicManager.populate_topic_arnks]    !YYDN yy ??f $T]]7-C GOD)$//4;;Mr/N)__name__ __module__ __qualname____doc__r.rErXrmrur~rrrrrrr/r-rrdsF4&%P,<|B E< ., Nr/rcBttddtddtddtddtddtddtddgd}ttdd| td d tdd ttdd   }ttdd | }ttdtddddgtdddgttdtd|tgddtd dtddgtd dtddg }t|d!}|jjd"}|jjd#}|jjd$}|jjd%}|jjd&} |jjd'} |jjd(} |jjd)} |jjd*} |j}|jjd+}|jjd,}t |||||| | | | ||| | }|dk(r|j }n|dk(r|j}t|jt|j||j-}|jd.i|y)/NintT)typerequiredrq) arithmetic exponential geometriclinear)rrchoices)minDelayTargetmaxDelayTarget numRetriesnumMaxDelayRetriesnumMinDelayRetriesnumNoDelayRetriesbackoffFunctionr!)rroptionsrF)maxReceivesPerSecond)defaultHealthyRetryPolicydisableSubscriptionOverridesdefaultThrottlePolicy)http)rstandardr1)rdefaultrpresentabsent)rr)r)rrlist)rrelements)rr resource_tags)raliasesrLdisabled)r) rrrrrrrr#r*r+r$) argument_specsupports_check_moderrrrrrrr#r$r*r+)rVsns_arn sns_topicr) r!AnsibleAWSModuleparamsror%rrrr(r r exit_json)http_retry_argshttp_delivery_args delivery_argsrrrrrrrrrr#r$r%r*r+rrV sns_factss r-mainrvs66UT2UT:UT:ED9%$@tuO"&FT?"[%)v%F"%)ut%D   v7I JM 4 UJV@TU9y(.CDV &-@2FVD fd; v'8 9VT2$()Z1H$I MMt TF ==  V $D""<0J MM  g &E==$$^4L ]]  x (Fmm''(9:OMM%%o6M --++,AB"(--"3"34Q"R""J ==  V $D""<0J   #I  %%' ( '')##9//9L9LMI F!y!r/__main__) DOCUMENTATIONEXAMPLESRETURNrSr= ImportError7ansible_collections.amazon.aws.plugins.module_utils.arnr:ansible_collections.amazon.aws.plugins.module_utils.policyr;ansible_collections.amazon.aws.plugins.module_utils.taggingrBansible_collections.amazon.aws.plugins.module_utils.transformationr>ansible_collections.community.aws.plugins.module_utils.modulesrr:ansible_collections.community.aws.plugins.module_utils.snsrr r r r r robjectrrrrr/r-rs\ |1 ft l  RWfdx\`O_RWRONfONdS"l zFu   sA44A<;A<