fix: bucket config

Author: SMillerDev

influxdb/buckets.sls

@@ -19,24 +19,27 @@ influxdb_bucket_{{ config['name'] }}:
       - pkg: jq
 {%- set bucket = salt['cmd.shell']("influx bucket list --json | jq -r '.[] | select(.name == \"" + config['name'] + "\").id'") %}
 {% else %}
+{%- set orgID = salt['cmd.shell']("curl -s -f -H'Authorization: Token {{ influxdb['user']['admin']['token'] }}' https://{{ influxdb['remote']['host'] }}/api/v2/orgs | jq -r '.[0].id'") %}
+
 get_bucket_{{ config['name'] }}:
   http.query:
     - name: 'https://{{ influxdb['remote']['host'] }}/api/v2/buckets/{{ config['name'] }}'
+    - port: 8086
     - status: 200
     - method: GET
     - header_dict:
         Authorization: Token {{ influxdb['user']['admin']['token'] }}
 
 {%- set bucket_data = {
-  name: config['name'],
-  description: config['description'] | default('A bucket for ' + config['name']),
-  orgID: config['orgID'],
-  retentionRules: [],
-  rp: config['retention_policy']
+  'name':           config['name'],
+  'description':    config['description'] | default('A bucket for ' + config['name']),
+  'orgID':          orgID,
+  'rp':             config['retention_policy'] | default('0'),
 } %}
 create_bucket_{{ config['name'] }}:
   http.query:
     - name: 'https://{{ influxdb['remote']['host'] }}/api/v2/buckets'
+    - port: 8086
     - status: 200
     - method: POST
     - data: '{{ bucket_data | tojson }}'

influxdb/users.sls

@@ -21,6 +21,7 @@ influxdb_user_{{ loop.index0 }}:
 get_user_{{ loop.index0 }}:
   http.query:
     - name: 'https://{{ influxdb['remote']['host'] }}/api/v2/users/{{ name }}'
+    - port: 8086
     - status: 200
     - method: GET
     - header_dict:
@@ -29,6 +30,7 @@ get_user_{{ loop.index0 }}:
 create_user_{{ loop.index0 }}:
   http.query:
     - name: 'https://{{ influxdb['remote']['host'] }}/api/v2/users'
+    - port: 8086
     - status: 200
     - method: POST
     - data: '{"name": "{{ name }}"}'
@@ -41,6 +43,7 @@ create_user_{{ loop.index0 }}:
 set_password_{{ loop.index0 }}:
   http.query:
     - name: 'https://{{ influxdb['remote']['host'] }}/api/v2/users{{ name }}/password'
+    - port: 8086
     - status: 200
     - method: POST
     - data: '{"password": "{{ config["password"] }}"}'