@@ -1309,0 +1311,4 @@
+        items:
+            type: object
+            required:
+                - token

@@ -1309,0 +1318,4 @@
+                    type: string
+                    enum: ['all']
+                    description: |
+                        Database name (required to be 'all').

@@ -1309,0 +1330,4 @@
+                    type: string
+                    description: |
+                        The InfluxDB executable to use. Defaults to `influx`.
+                token:

@@ -1309,0 +1344,4 @@
+                    type: string
+                    description: |
+                        InfluxDB hostname/IP to connect to. 
+                        Defaults to 127.0.0.1.

@@ -1309,0 +1360,4 @@
+                    type: string
+                    description: |
+                        The name of the organization. 
+                        If provided, do not use organization_id.

@@ -1309,0 +1361,4 @@
+                    description: |
+                        The name of the organization. 
+                        If provided, do not use organization_id.
+                bucket_name:

@@ -1309,0 +1370,4 @@
+                    type: string
+                    description: |
+                        The ID of the bucket to backup. 
+                        If provided, do not use bucket_name.

@@ -1309,0 +1396,4 @@
+                    type: boolean
+                    description: |
+                        Enable debug logging for HTTP requests.
+                full:

@@ -0,0 +37,4 @@
+    dry_run,
+):
+    '''
+    Dump the given InfluxDB databases to a named pipe. The databases are supplied as a sequence of

@@ -0,0 +43,4 @@
+    log prefix in any log entries).
+
+    Return a sequence of subprocess.Popen instances for the dump processes ready to spew to a named
+    pipe. But if this is a dry run, then don't actually dump anything and return an empty sequence.

@@ -0,0 +51,4 @@
+
+    logger.info(f'Dumping InfluxDB databases{dry_run_label}')
+
+    processes = []

@@ -0,0 +71,4 @@
+
+        logger.debug(
+            f'Command: {command}',
+        )

@@ -0,0 +74,4 @@
+        )
+
+        dump.create_parent_directory_for_dump(dump_filename)
+        execute_command(command, shell=True)  # noqa: S604

@@ -0,0 +89,4 @@
+
+def build_dump_command(database, dump_filename):
+    '''
+    Return the backup command.

@@ -0,0 +98,4 @@
+        # Add protocol prefix based on tls setting
+        protocol = 'https://' if database.get('tls', True) else 'http://'
+        # Format as protocol://hostname:port
+        host = f'{protocol}{host}:{port}'

@@ -0,0 +111,4 @@
+        + ('backup',)
+        + (('--skip-verify',) if skip_verify else ())
+        + (('--http-debug',) if http_debug else ())
+        + (('--host', shlex.quote(str(host))) if host else ())

@@ -0,0 +162,4 @@
+    databases, config, borgmatic_runtime_directory, name=None
+):  # pragma: no cover
+    '''
+    Given a sequence of configurations dicts, a configuration dict, a prefix to log with, the

@@ -0,0 +175,4 @@
+        ),
+        dump.make_data_source_dump_filename(
+            make_dump_path(borgmatic_source_directory), name, hostname='*'
+        ),

@@ -0,0 +191,4 @@
+    '''
+    Restore a database from the given extract stream. The database is supplied as a data source
+    configuration dict, but the given hook configuration is ignored. The given configuration dict is
+    used to construct the destination path, and the given log prefix is used for any log entries. If

@@ -0,0 +193,4 @@
+    configuration dict, but the given hook configuration is ignored. The given configuration dict is
+    used to construct the destination path, and the given log prefix is used for any log entries. If
+    this is a dry run, then don't actually restore anything. Trigger the given active extract
+    process (an instance of subprocess.Popen) to produce output to consume.

@@ -0,0 +219,4 @@
+    # if the restore paths don't exist in the archive.
+    execute_command_with_processes(
+        restore_command,
+        [extract_process] if extract_process else [],

@@ -0,0 +237,4 @@
+        # Add protocol prefix based on tls setting
+        protocol = 'https://' if database.get('tls', True) else 'http://'
+        # Format as protocol://hostname:port
+        host = f'{protocol}{host}:{port}'

@@ -0,0 +252,4 @@
+    http_debug = database.get('http_debug')
+    full = database.get('full_replace')
+    influx_command = tuple(
+        shlex.quote(part) for part in shlex.split(database.get('influx_command') or 'influx')

@@ -105,0 +109,4 @@
+      port: 8087
+      tls: true
+      skip_verify: true
+      tojen: mysecrettoken

@@ -0,0 +4,4 @@
+
+
+def test_make_dump_path_creates_correct_path():
+    assert module.make_dump_path('/tmp') == '/tmp/influxdb_databases'

@@ -0,0 +8,4 @@
+
+
+def test_get_default_port_returns_correct_port():
+    assert module.get_default_port(None, None) == 8086

@@ -0,0 +13,4 @@
+
+def test_use_streaming_always_returns_false():
+    assert not module.use_streaming(databases=[], config={})
+    assert not module.use_streaming(databases=[{'name': 'bucket1'}], config={})

@@ -0,0 +46,4 @@
+        '--bucket',
+        'TestBucket',
+        '/tmp/dumpfile',
+    )

@@ -0,0 +74,4 @@
+    )
+
+
+def test_build_dump_command_with_http_disabled():

@@ -0,0 +236,4 @@
+        '--token',
+        'testtoken',
+        '/tmp/dumpfile',
+    )

@@ -0,0 +276,4 @@
+            'mytoken',
+            '--org-id',
+            'org123',
+        ),

@@ -0,0 +289,4 @@
+        dry_run=False,
+    )
+
+    assert len(processes) == 0  # No subprocess.Popen instances are returned.

@@ -0,0 +309,4 @@
+        dry_run=True,
+    )
+
+    assert len(processes) == 0

@@ -0,0 +327,4 @@
+        'port': '8086',  # Changed to string to avoid TypeError
+        'password': 'mytoken',
+    }
+    extract_process = flexmock(stdout=flexmock())

@@ -0,0 +340,4 @@
+    )
+
+    flexmock(module).should_receive('execute_command_with_processes').with_args(
+        ('influx', 'restore', '--host', 'https://localhost:8086', '--token', 'mytoken'),

@@ -0,0 +724,4 @@
+        '--token',
+        'mytoken',
+        '/tmp/dumpfile',
+    )

@@ -0,0 +737,4 @@
+        config={},
+        borgmatic_runtime_directory='/tmp',
+        dry_run=False,
+    )