From 8465830c1d3403d7db003ad9409f93000f3a8afa Mon Sep 17 00:00:00 2001
From: Patrick Marques <pmarques@users.noreply.github.com>
Date: Sun, 7 Jan 2018 03:21:57 +0000
Subject: [PATCH] Add new module digital_ocean_floating_ip_facts (#26372)

---
 .../digital_ocean_floating_ip_facts.py        | 138 ++++++++++++++++++
 1 file changed, 138 insertions(+)
 create mode 100644 lib/ansible/modules/cloud/digital_ocean/digital_ocean_floating_ip_facts.py

diff --git a/lib/ansible/modules/cloud/digital_ocean/digital_ocean_floating_ip_facts.py b/lib/ansible/modules/cloud/digital_ocean/digital_ocean_floating_ip_facts.py
new file mode 100644
index 0000000000..e2a23afba5
--- /dev/null
+++ b/lib/ansible/modules/cloud/digital_ocean/digital_ocean_floating_ip_facts.py
@@ -0,0 +1,138 @@
+#!/usr/bin/python
+# -*- coding: utf-8 -*-
+
+# Copyright: Ansible Project
+# GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt)
+
+from __future__ import absolute_import, division, print_function
+__metaclass__ = type
+
+
+ANSIBLE_METADATA = {'status': ['preview'],
+                    'supported_by': 'community',
+                    'metadata_version': '1.1'}
+
+DOCUMENTATION = '''
+---
+module: digital_ocean_floating_ip_facts
+short_description: DigitalOcean Floating IPs facts
+description:
+     - Fetch DigitalOcean Floating IPs facts.
+version_added: "2.5"
+author: "Patrick Marques (@pmarques)"
+options:
+  oauth_token:
+    description:
+     - DigitalOcean OAuth token.
+    required: true
+  timeout:
+    description:
+    - The timeout in seconds used for polling DigitalOcean's API.
+    default: 30
+
+notes:
+  - Version 2 of DigitalOcean API is used.
+requirements:
+  - "python >= 2.6"
+'''
+
+
+EXAMPLES = '''
+- name: "Gather facts about all Floating IPs"
+  digital_ocean_floating_ip_facts:
+  register: result
+
+- name: "List of current floating ips"
+  debug: var=result.floating_ips
+'''
+
+
+RETURN = '''
+# Digital Ocean API info https://developers.digitalocean.com/documentation/v2/#floating-ips
+floating_ips:
+    description: a DigitalOcean Floating IP resource
+    returned: success and no resource constraint
+    type: list
+    sample: [
+      {
+        "ip": "45.55.96.47",
+        "droplet": null,
+        "region": {
+          "name": "New York 3",
+          "slug": "nyc3",
+          "sizes": [
+            "512mb",
+            "1gb",
+            "2gb",
+            "4gb",
+            "8gb",
+            "16gb",
+            "32gb",
+            "48gb",
+            "64gb"
+          ],
+          "features": [
+            "private_networking",
+            "backups",
+            "ipv6",
+            "metadata"
+          ],
+          "available": true
+        },
+        "locked": false
+      }
+    ]
+'''
+
+import json
+import os
+
+from ansible.module_utils.basic import env_fallback
+from ansible.module_utils.basic import AnsibleModule
+from ansible.module_utils.digital_ocean import DigitalOceanHelper
+
+
+def core(module):
+    rest = DigitalOceanHelper(module)
+
+    page = 1
+    has_next = True
+    floating_ips = []
+    while has_next or 200 != status_code:
+        response = rest.get("floating_ips?page={0}&per_page=20".format(page))
+        status_code = response.status_code
+        # stop if any error during pagination
+        if 200 != status_code:
+            break
+        page = page + 1
+        floating_ips.extend(response.json["floating_ips"])
+        has_next = "pages" in response.json["links"] and "next" in response.json["links"]["pages"]
+
+    if status_code == 200:
+        module.exit_json(changed=False, floating_ips=floating_ips)
+    else:
+        module.fail_json(msg="Error fecthing facts [{0}: {1}]".format(
+            status_code, response.json["message"]))
+
+
+def main():
+    module = AnsibleModule(
+        argument_spec=dict(
+            oauth_token=dict(
+                no_log=True,
+                # Support environment variable for DigitalOcean OAuth Token
+                fallback=(env_fallback, ['DO_API_TOKEN', 'DO_API_KEY', 'DO_OAUTH_TOKEN']),
+                required=True,
+            ),
+            validate_certs=dict(type='bool', default=True),
+            timeout=dict(type='int', default=30),
+        ),
+    )
+
+    try:
+        core(module)
+    except Exception as e:
+        module.fail_json(msg=str(e))
+
+if __name__ == '__main__':
+    main()