confluence.py

# coding=utf-8
import io
import json
import logging
import os
import re
import time
from typing import cast

import requests
from bs4 import BeautifulSoup
from deprecated import deprecated
from requests import HTTPError

from atlassian import utils

from .errors import (
    ApiConflictError,
    ApiError,
    ApiNotAcceptable,
    ApiNotFoundError,
    ApiPermissionError,
    ApiValueError,
)
from .rest_client import AtlassianRestAPI

log = logging.getLogger(__name__)


class Confluence(AtlassianRestAPI):
    content_types = {
        ".gif": "image/gif",
        ".png": "image/png",
        ".jpg": "image/jpeg",
        ".jpeg": "image/jpeg",
        ".pdf": "application/pdf",
        ".doc": "application/msword",
        ".xls": "application/vnd.ms-excel",
        ".svg": "image/svg+xml",
    }

    def __init__(self, url, *args, **kwargs):
        if ("atlassian.net" in url or "jira.com" in url) and ("/wiki" not in url):
            url = AtlassianRestAPI.url_joiner(url, "/wiki")
            if "cloud" not in kwargs:
                kwargs["cloud"] = True
        super(Confluence, self).__init__(url, *args, **kwargs)

    @staticmethod
    def _create_body(body, representation):
        if representation not in [
            "atlas_doc_format",
            "editor",
            "export_view",
            "view",
            "storage",
            "wiki",
        ]:
            raise ValueError("Wrong value for representation, it should be either wiki or storage")

        return {representation: {"value": body, "representation": representation}}

    def _get_paged(
        self,
        url,
        params=None,
        data=None,
        flags=None,
        trailing=None,
        absolute=False,
    ):
        """
        Used to get the paged data

        :param url: string:                        The url to retrieve
        :param params: dict (default is None):     The parameter's
        :param data: dict (default is None):       The data
        :param flags: string[] (default is None):  The flags
        :param trailing: bool (default is None):   If True, a trailing slash is added to the url
        :param absolute: bool (default is False):  If True, the url is used absolute and not relative to the root

        :return: A generator object for the data elements
        """

        if params is None:
            params = {}

        while True:
            response = self.get(
                url,
                trailing=trailing,
                params=params,
                data=data,
                flags=flags,
                absolute=absolute,
            )
            if "results" not in response:
                return

            for value in response.get("results", []):
                yield value

            # According to Cloud and Server documentation the links are returned the same way:
            # https://developer.atlassian.com/cloud/confluence/rest/api-group-content/#api-wiki-rest-api-content-get
            # https://developer.atlassian.com/server/confluence/pagination-in-the-rest-api/
            url = response.get("_links", {}).get("next")
            if url is None:
                break
            # From now on we have relative URLs with parameters
            absolute = False
            # Params are now provided by the url
            params = {}
            # Trailing should not be added as it is already part of the url
            trailing = False

        return

    def page_exists(self, space, title, type=None):
        """
        Check if title exists as page.
        :param space: Space key
        :param title: Title of the page
        :param type: type of the page, 'page' or 'blogpost'. Defaults to 'page'
        :return:
        """
        url = "rest/api/content"
        params = {}
        if space is not None:
            params["spaceKey"] = str(space)
        if title is not None:
            params["title"] = str(title)
        if type is not None:
            params["type"] = str(type)

        try:
            response = self.get(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 404:
                raise ApiPermissionError(
                    "The calling user does not have permission to view the content",
                    reason=e,
                )

            raise

        if response.get("results"):
            return True
        else:
            return False

    def share_with_others(self, page_id, group, message):
        """
        Notify members (currently only groups implemented) about something on that page
        """
        url = "rest/share-page/latest/share"
        params = {
            "contextualPageId": page_id,
            # "emails": [],
            "entityId": page_id,
            "entityType": "page",
            "groups": group,
            "note": message,
            # "users":[]
        }
        r = self.post(url, json=params, headers={"contentType": "application/json; charset=utf-8"}, advanced_mode=True)
        if r.status_code != 200:
            raise Exception(f"failed sharing content {r.status_code}: {r.text}")

    def get_page_child_by_type(self, page_id, type="page", start=None, limit=None, expand=None):
        """
        Provide content by type (page, blog, comment)
        :param page_id: A string containing the id of the type content container.
        :param type:
        :param start: OPTIONAL: The start point of the collection to return. Default: None (0).
        :param limit: OPTIONAL: how many items should be returned after the start index. Default: Site limit 200.
        :param expand: OPTIONAL: expand e.g. history
        :return:
        """
        params = {}
        if start is not None:
            params["start"] = int(start)
        if limit is not None:
            params["limit"] = int(limit)
        if expand is not None:
            params["expand"] = expand

        url = f"rest/api/content/{page_id}/child/{type}"
        log.info(url)

        try:
            if not self.advanced_mode and start is None and limit is None:
                return self._get_paged(url, params=params)
            else:
                response = self.get(url, params=params)
                if self.advanced_mode:
                    return response
                return response.get("results")
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no content with the given id, "
                    "or the calling user does not have permission to view the content",
                    reason=e,
                )

            raise

    def get_child_title_list(self, page_id, type="page", start=None, limit=None):
        """
        Find a list of Child title
        :param page_id: A string containing the id of the type content container.
        :param type:
        :param start: OPTIONAL: The start point of the collection to return. Default: None (0).
        :param limit: OPTIONAL: how many items should be returned after the start index. Default: Site limit 200.
        :return:
        """
        child_page = self.get_page_child_by_type(page_id, type, start, limit)
        child_title_list = [child["title"] for child in child_page]
        return child_title_list

    def get_child_id_list(self, page_id, type="page", start=None, limit=None):
        """
        Find a list of Child id
        :param page_id: A string containing the id of the type content container.
        :param type:
        :param start: OPTIONAL: The start point of the collection to return. Default: None (0).
        :param limit: OPTIONAL: how many items should be returned after the start index. Default: Site limit 200.
        :return:
        """
        child_page = self.get_page_child_by_type(page_id, type, start, limit)
        child_id_list = [child["id"] for child in child_page]
        return child_id_list

    def get_child_pages(self, page_id):
        """
        Get child pages for the provided page_id
        :param page_id:
        :return:
        """
        return self.get_page_child_by_type(page_id=page_id, type="page")

    def get_page_id(self, space, title, type="page"):
        """
        Provide content id from search result by title and space.
        :param space: SPACE key
        :param title: title
        :param type: type of content: Page or Blogpost. Defaults to page
        :return:
        """
        return (self.get_page_by_title(space, title, type=type) or {}).get("id")

    def get_parent_content_id(self, page_id):
        """
        Provide parent content id from page id
        :type page_id: str
        :return:
        """
        parent_content_id = None
        try:
            parent_content_id = (self.get_page_by_id(page_id=page_id, expand="ancestors").get("ancestors") or {})[
                -1
            ].get("id") or None
        except Exception as e:
            log.error(e)
        return parent_content_id

    def get_parent_content_title(self, page_id):
        """
        Provide parent content title from page id
        :type page_id: str
        :return:
        """
        parent_content_title = None
        try:
            parent_content_title = (self.get_page_by_id(page_id=page_id, expand="ancestors").get("ancestors") or {})[
                -1
            ].get("title") or None
        except Exception as e:
            log.error(e)
        return parent_content_title

    def get_page_space(self, page_id):
        """
        Provide space key from content id.
        :param page_id: content ID
        :return:
        """
        return ((self.get_page_by_id(page_id, expand="space") or {}).get("space") or {}).get("key") or None

    def get_pages_by_title(self, space, title, start=0, limit=200, expand=None):
        """
        Provide pages by title search
        :param space: Space key
        :param title: Title of the page
        :param start: OPTIONAL: The start point of the collection to return. Default: None (0).
        :param limit: OPTIONAL: The limit of the number of labels to return, this may be restricted by
                            fixed system limits. Default: 200.
        :param expand: OPTIONAL: expand e.g. history
        :return: The JSON data returned from searched results the content endpoint, or the results of the
                 callback. Will raise requests.HTTPError on bad input, potentially.
                 If it has IndexError then return the None.
        """
        return self.get_page_by_title(space, title, start, limit, expand)

    def get_page_by_title(self, space, title, start=0, limit=1, expand=None, type="page"):
        """
        Returns the first page  on a piece of Content.
        :param space: Space key
        :param title: Title of the page
        :param start: OPTIONAL: The start point of the collection to return. Default: None (0).
        :param limit: OPTIONAL: The limit of the number of labels to return, this may be restricted by
                            fixed system limits. Default: 1.
        :param expand: OPTIONAL: expand e.g. history
        :param type: OPTIONAL: Type of content: Page or Blogpost. Defaults to page
        :return: The JSON data returned from searched results the content endpoint, or the results of the
                 callback. Will raise requests.HTTPError on bad input, potentially.
                 If it has IndexError then return the None.
        """
        url = "rest/api/content"
        params = {"type": type}
        if start is not None:
            params["start"] = int(start)
        if limit is not None:
            params["limit"] = int(limit)
        if expand is not None:
            params["expand"] = expand
        if space is not None:
            params["spaceKey"] = str(space)
        if title is not None:
            params["title"] = str(title)

        if self.advanced_mode:
            return self.get(url, params=params)
        try:
            response = self.get(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 404:
                raise ApiPermissionError(
                    "The calling user does not have permission to view the content",
                    reason=e,
                )

            raise
        try:
            return response.get("results")[0]
        except (IndexError, TypeError) as e:
            log.error(f"Can't find '{title}' page on {self.url}")
            log.debug(e)
            return None

    def get_page_by_id(self, page_id, expand=None, status=None, version=None):
        """
        Returns a piece of Content.
        Example request URI(s):
        http://example.com/confluence/rest/api/content/1234?expand=space,body.view,version,container
        http://example.com/confluence/rest/api/content/1234?status=any
        :param page_id: Content ID
        :param status: (str) list of Content statuses to filter results on. Default value: [current]
        :param version: (int)
        :param expand: OPTIONAL: Default value: history,space,version
                       We can also specify some extensions such as extensions.inlineProperties
                       (for getting inline comment-specific properties) or extensions. Resolution
                       for the resolution status of each comment in the results
        :return:
        """
        params = {}
        if expand:
            params["expand"] = expand
        if status:
            params["status"] = status
        if version:
            params["version"] = version
        url = f"rest/api/content/{page_id}"

        try:
            response = self.get(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no content with the given id, "
                    "or the calling user does not have permission to view the content",
                    reason=e,
                )

            raise

        return response

    def get_tables_from_page(self, page_id):
        """
        Fetches html  tables added to  confluence page
        :param page_id: integer confluence page_id
        :return: json object with page_id, number_of_tables_in_page
                 and list of list tables_content representing scraped tables
        """
        try:
            page_content = self.get_page_by_id(page_id, expand="body.storage")["body"]["storage"]["value"]

            if page_content:
                tables_raw = [
                    [[cell.text for cell in row("th") + row("td")] for row in table("tr")]
                    for table in BeautifulSoup(page_content, features="lxml")("table")
                ]
                if len(tables_raw) > 0:
                    return json.dumps(
                        {
                            "page_id": page_id,
                            "number_of_tables_in_page": len(tables_raw),
                            "tables_content": tables_raw,
                        }
                    )
                else:
                    return {
                        "No tables found for page: ": page_id,
                    }
            else:
                return {"Page content is empty"}
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                log.error("Couldn't retrieve tables  from page", page_id)
                raise ApiError(
                    "There is no content with the given pageid, pageid params is not an integer "
                    "or the calling user does not have permission to view the page",
                    reason=e,
                )
        except Exception as e:
            log.error("Error occured", e)

    def scrap_regex_from_page(self, page_id, regex):
        """
        Method scraps regex patterns from a Confluence page_id.

        :param page_id: The ID of the Confluence page.
        :param regex: The regex pattern to scrape.
        :return: A list of regex matches.
        """
        regex_output = []
        page_output = self.get_page_by_id(page_id, expand="body.storage")["body"]["storage"]["value"]
        try:
            if page_output is not None:
                description_matches = [x.group(0) for x in re.finditer(regex, page_output)]
                if description_matches:
                    regex_output.extend(description_matches)
            return regex_output
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                log.error("couldn't find page_id : ", page_id)
                raise ApiNotFoundError(
                    "There is no content with the given page id,"
                    "or the calling user does not have permission to view the page",
                    reason=e,
                )

    def get_page_labels(self, page_id, prefix=None, start=None, limit=None):
        """
        Returns the list of labels on a piece of Content.
        :param page_id: A string containing the id of the labels content container.
        :param prefix: OPTIONAL: The prefixes to filter the labels with {@see Label.Prefix}.
                                Default: None.
        :param start: OPTIONAL: The start point of the collection to return. Default: None (0).
        :param limit: OPTIONAL: The limit of the number of labels to return, this may be restricted by
                            fixed system limits. Default: 200.
        :return: The JSON data returned from the content/{id}/label endpoint, or the results of the
                 callback. Will raise requests.HTTPError on bad input, potentially.
        """
        url = f"rest/api/content/{page_id}/label"
        params = {}
        if prefix:
            params["prefix"] = prefix
        if start is not None:
            params["start"] = int(start)
        if limit is not None:
            params["limit"] = int(limit)

        try:
            response = self.get(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no content with the given id, "
                    "or the calling user does not have permission to view the content",
                    reason=e,
                )

            raise

        return response

    def get_page_comments(
        self,
        content_id,
        expand=None,
        parent_version=None,
        start=0,
        limit=25,
        location=None,
        depth=None,
    ):
        """

        :param content_id:
        :param expand: extensions.inlineProperties,extensions.resolution
        :param parent_version:
        :param start:
        :param limit:
        :param location: inline or not
        :param depth:
        :return:
        """
        params = {"id": content_id, "start": start, "limit": limit}
        if expand:
            params["expand"] = expand
        if parent_version:
            params["parentVersion"] = parent_version
        if location:
            params["location"] = location
        if depth:
            params["depth"] = depth
        url = f"rest/api/content/{content_id}/child/comment"

        try:
            response = self.get(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no content with the given id, "
                    "or the calling user does not have permission to view the content",
                    reason=e,
                )

            raise

        return response

    def get_draft_page_by_id(self, page_id, status="draft", expand=None):
        """
        Gets content by id with status = draft
        :param page_id: Content ID
        :param status: (str) list of content statuses to filter results on. Default value: [draft]
        :param expand: OPTIONAL: Default value: history,space,version
                       We can also specify some extensions such as extensions.inlineProperties
                       (for getting inline comment-specific properties) or extensions. Resolution
                       for the resolution status of each comment in the results
        :return:
        """
        # Version not passed since draft versions don't match the page and
        # operate differently between different collaborative modes
        return self.get_page_by_id(page_id=page_id, expand=expand, status=status)

    def get_all_pages_by_label(self, label, start=0, limit=50, expand=None):
        """
        Get all page by label
        :param label:
        :param start: OPTIONAL: The start point of the collection to return. Default: None (0).
        :param limit: OPTIONAL: The limit of the number of pages to return, this may be restricted by
                      fixed system limits. Default: 50
        :param expand: OPTIONAL: a comma separated list of properties to expand on the content
        :return:
        """
        url = "rest/api/content/search"
        params = {}
        if label:
            params["cql"] = f'type={"page"} AND label="{label}"'
        if start:
            params["start"] = start
        if limit:
            params["limit"] = limit
        if expand:
            params["expand"] = expand

        try:
            response = self.get(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 400:
                raise ApiValueError("The CQL is invalid or missing", reason=e)

            raise

        return response.get("results")

    def get_all_pages_from_space_raw(
        self,
        space,
        start=0,
        limit=50,
        status=None,
        expand=None,
        content_type="page",
    ):
        """
        Get all pages from space

        :param space:
        :param start: OPTIONAL: The start point of the collection to return. Default: None (0).
        :param limit: OPTIONAL: The limit of the number of pages to return, this may be restricted by
                            fixed system limits. Default: 50
        :param status: OPTIONAL: list of statuses the content to be found is in.
                                 Defaults to current is not specified.
                                 If set to 'any', content in 'current' and 'trashed' status will be fetched.
                                 Does not support 'historical' status for now.
        :param expand: OPTIONAL: a comma separated list of properties to expand on the content.
                                 Default value: history,space,version.
        :param content_type: the content type to return. Default value: page. Valid values: page, blogpost.
        :return:
        """
        url = "rest/api/content"
        params = {}
        if space:
            params["spaceKey"] = space
        if start:
            params["start"] = start
        if limit:
            params["limit"] = limit
        if status:
            params["status"] = status
        if expand:
            params["expand"] = expand
        if content_type:
            params["type"] = content_type

        try:
            response = self.get(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 404:
                raise ApiPermissionError(
                    "The calling user does not have permission to view the content",
                    reason=e,
                )

            raise

        return response

    def get_all_pages_from_space(
        self,
        space,
        start=0,
        limit=50,
        status=None,
        expand=None,
        content_type="page",
    ):
        """
         Retrieve all pages from a Confluence space.

        :param space: The space key to fetch pages from.
        :param start: OPTIONAL: The starting point of the collection. Default: 0.
        :param limit: OPTIONAL: The maximum number of pages per request. Default: 50.
        :param status: OPTIONAL: Filter pages by status ('current', 'trashed', 'any'). Default: None.
        :param expand: OPTIONAL: Comma-separated list of properties to expand. Default: history,space,version.
        :param content_type: OPTIONAL: The content type to return ('page', 'blogpost'). Default: page.
        :return: List containing all pages from the specified space.
        """
        all_pages = []  # Initialize an empty list to store all pages
        while True:
            # Fetch a single batch of pages
            response = self.get_all_pages_from_space_raw(
                space=space,
                start=start,
                limit=limit,
                status=status,
                expand=expand,
                content_type=content_type,
            )

            # Extract results from the response
            results = response.get("results", [])
            all_pages.extend(results)  # Add the current batch of pages to the list

            # Break the loop if no more pages are available
            if len(results) < limit:
                break

            # Increment the start index for the next batch
            start += limit
        return all_pages

    def get_all_pages_from_space_as_generator(
        self,
        space,
        start=0,
        limit=50,
        status=None,
        expand="history,space,version",
        content_type="page",
    ):
        """
        Retrieve all pages from a Confluence space using pagination.

        :param space: The space key to fetch pages from.
        :param start: OPTIONAL: The starting point of the collection. Default: 0.
        :param limit: OPTIONAL: The maximum number of pages per request. Default: 50.
        :param status: OPTIONAL: Filter pages by status ('current', 'trashed', 'any'). Default: None.
        :param expand: OPTIONAL: Comma-separated list of properties to expand. Default: history,space,version.
        :param content_type: OPTIONAL: The content type to return ('page', 'blogpost'). Default: page.
        :return: Generator yielding pages one by one.
        """
        while True:
            # Fetch a single batch of pages
            response = self.get_all_pages_from_space_raw(
                space=space,
                start=start,
                limit=limit,
                status=status,
                expand=expand,
                content_type=content_type,
            )

            # Extract results from the response
            results = response.get("results", [])
            yield from results  # Yield each page individually

            # Break the loop if no more pages are available
            if len(results) < limit:
                break
            start += limit
        pass

    def get_all_pages_from_space_trash(self, space, start=0, limit=500, status="trashed", content_type="page"):
        """
        Get list of pages from trash
        :param space:
        :param start: OPTIONAL: The start point of the collection to return. Default: None (0).
        :param limit: OPTIONAL: The limit of the number of pages to return, this may be restricted by
                            fixed system limits. Default: 500
        :param status:
        :param content_type: the content type to return. Default value: page. Valid values: page, blogpost.
        :return:
        """
        return self.get_all_pages_from_space(space, start, limit, status, content_type=content_type)

    def get_all_draft_pages_from_space(self, space, start=0, limit=500, status="draft"):
        """
        Get list of draft pages from space
        Use case is cleanup old drafts from Confluence
        :param space:
        :param start: OPTIONAL: The start point of the collection to return. Default: None (0).
        :param limit: OPTIONAL: The limit of the number of pages to return, this may be restricted by
                            fixed system limits. Default: 500
        :param status:
        :return:
        """
        return self.get_all_pages_from_space(space, start, limit, status)

    def get_all_draft_pages_from_space_through_cql(self, space, start=0, limit=500, status="draft"):
        """
        Search list of draft pages by space key
        Use case is cleanup old drafts from Confluence
        :param space: Space Key
        :param status: Can be changed
        :param start: OPTIONAL: The start point of the collection to return. Default: None (0).
        :param limit: OPTIONAL: The limit of the number of pages to return, this may be restricted by
                            fixed system limits. Default: 500
        :return:
        """
        url = f"rest/api/content?cql=space=spaceKey={space} and status={status}"
        params = {}
        if limit:
            params["limit"] = limit
        if start:
            params["start"] = start

        try:
            response = self.get(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 404:
                raise ApiPermissionError(
                    "The calling user does not have permission to view the content",
                    reason=e,
                )

            raise

        return response.get("results")

    def get_all_pages_by_space_ids_confluence_cloud(
        self,
        space_ids,
        batch_size=250,
        sort=None,
        status=None,
        title=None,
        body_format=None,
    ):
        """
        Get all pages from a set of space ids:
        https://developer.atlassian.com/cloud/confluence/rest/v2/api-group-page/#api-pages-get
        :param space_ids: A Set of space IDs passed as a filter to Confluence
        :param batch_size: OPTIONAL: The batch size of pages to retrieve from confluence per request MAX is 250.
                                     Default: 250
        :param sort: OPTIONAL: The order the pages are retrieved in.
                               Valid values:
                                    id, -id, created-date, -created-date, modified-date, -modified-date, title, -title
        :param status: OPTIONAL: Filter pages based on their status.
                                 Valid values: current, archived, deleted, trashed
                                 Default: current,archived
        :param title: OPTIONAL: Filter pages based on their title.
        :param body_format: OPTIONAL: The format of the body in the response. Valid values: storage, atlas_doc_format
        :return:
        """
        path = "/api/v2/pages"
        params = {}
        if space_ids:
            params["space-id"] = ",".join(space_ids)
        if batch_size:
            params["limit"] = batch_size
        if sort:
            params["sort"] = sort
        if status:
            params["status"] = status
        if title:
            params["title"] = title
        if body_format:
            params["body-format"] = body_format

        _all_pages = []
        try:
            while True:
                response = self.get(path, params=params)

                pages = response.get("results")
                _all_pages = _all_pages + pages

                links = response.get("_links")
                if links is not None and "next" in links:
                    path = response["_links"]["next"].removeprefix("/wiki/")
                    params = {}
                else:
                    break
        except HTTPError as e:
            if e.response.status_code == 400:
                raise ApiValueError(
                    "The configured params cannot be interpreted by Confluence"
                    "Check the api documentation for valid values for status, expand, and sort params",
                    reason=e,
                )
            if e.response.status_code == 401:
                raise HTTPError("Unauthorized (401)", response=response)
            raise

        return _all_pages

    @deprecated(version="2.4.2", reason="Use get_all_restrictions_for_content()")
    def get_all_restictions_for_content(self, content_id):
        """Let's use the get_all_restrictions_for_content()"""
        return self.get_all_restrictions_for_content(content_id=content_id)

    def get_all_restrictions_for_content(self, content_id):
        """
        Returns info about all restrictions by operation.
        :param content_id:
        :return: Return the raw json response
        """
        url = f"rest/api/content/{content_id}/restriction/byOperation"
        return self.get(url)

    def remove_page_from_trash(self, page_id):
        """
        This method removes a page from trash
        :param page_id:
        :return:
        """
        return self.remove_page(page_id=page_id, status="trashed")

    def remove_page_as_draft(self, page_id):
        """
        This method removes a page from trash if it is a draft
        :param page_id:
        :return:
        """
        return self.remove_page(page_id=page_id, status="draft")

    def remove_content(self, content_id):
        """
        Remove any content
        :param content_id:
        :return:
        """
        try:
            response = self.delete(f"rest/api/content/{content_id}")
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no content with the given id, or the calling "
                    "user does not have permission to trash or purge the content",
                    reason=e,
                )
            if e.response.status_code == 409:
                raise ApiConflictError(
                    "There is a stale data object conflict when trying to delete a draft",
                    reason=e,
                )

            raise

        return response

    def remove_page(self, page_id, status=None, recursive=False):
        """
        This method removes a page, if it has recursive flag, method removes including child pages
        :param page_id:
        :param status: OPTIONAL: type of page
        :param recursive: OPTIONAL: if True - will recursively delete all children pages too
        :return:
        """
        url = f"rest/api/content/{page_id}"
        if recursive:
            children_pages = self.get_page_child_by_type(page_id)
            for children_page in children_pages:
                self.remove_page(children_page.get("id"), status, recursive)
        params = {}
        if status:
            params["status"] = status

        try:
            response = self.delete(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no content with the given id, or the calling "
                    "user does not have permission to trash or purge the content",
                    reason=e,
                )
            if e.response.status_code == 409:
                raise ApiConflictError(
                    "There is a stale data object conflict when trying to delete a draft",
                    reason=e,
                )

            raise

        return response

    def create_page(
        self,
        space,
        title,
        body,
        parent_id=None,
        type="page",
        representation="storage",
        editor=None,
        full_width=False,
        status="current",
    ):
        """
        Create page from scratch
        :param space:
        :param title:
        :param body:
        :param parent_id:
        :param type:
        :param representation: OPTIONAL: either Confluence 'storage' or 'wiki' markup format
        :param editor: OPTIONAL: v2 to be created in the new editor
        :param full_width: DEFAULT: False
        :param status: either 'current' or 'draft'
        :return:
        """
        log.info('Creating %s "%s" -> "%s"', type, space, title)
        url = "rest/api/content/"
        data = {
            "type": type,
            "title": title,
            "status": status,
            "space": {"key": space},
            "body": self._create_body(body, representation),
            "metadata": {"properties": {}},
        }
        if parent_id:
            data["ancestors"] = [{"type": type, "id": parent_id}]
        if editor is not None and editor in ["v1", "v2"]:
            data["metadata"]["properties"]["editor"] = {"value": editor}
        if full_width is True:
            data["metadata"]["properties"]["content-appearance-draft"] = {"value": "full-width"}
            data["metadata"]["properties"]["content-appearance-published"] = {"value": "full-width"}
        else:
            data["metadata"]["properties"]["content-appearance-draft"] = {"value": "fixed-width"}
            data["metadata"]["properties"]["content-appearance-published"] = {"value": "fixed-width"}

        try:
            response = self.post(url, data=data)
        except HTTPError as e:
            if e.response.status_code == 404:
                raise ApiPermissionError(
                    "The calling user does not have permission to view the content",
                    reason=e,
                )

            raise

        return response

    def move_page(
        self,
        space_key,
        page_id,
        target_id=None,
        target_title=None,
        position="append",
    ):
        """
        Move page method
        :param space_key:
        :param page_id:
        :param target_title:
        :param target_id:
        :param position: topLevel or append , above, below
        :return:
        """
        url = "/pages/movepage.action"
        params = {"spaceKey": space_key, "pageId": page_id}
        if target_title:
            params["targetTitle"] = target_title
        if target_id:
            params["targetId"] = target_id
        if position:
            params["position"] = position
        return self.post(url, params=params, headers=self.no_check_headers)

    def create_or_update_template(
        self,
        name,
        body,
        template_type="page",
        template_id=None,
        description=None,
        labels=None,
        space=None,
    ):
        """
        Creates a new or updates an existing content template.

        Note, blueprint templates cannot be created or updated via the REST API.

        If you provide a ``template_id`` then this method will update the template with the provided settings.
        If no ``template_id`` is provided, then this method assumes you are creating a new template.

        :param str name: If creating, the name of the new template. If updating, the name to change
            the template name to. Set to the current name if this field is not being updated.
        :param dict body: This object is used when creating or updating content.
            {
                "storage": {
                    "value": "<string>",
                    "representation": "view"
                }
            }
        :param str template_type: OPTIONAL: The type of the new template. Default: "page".
        :param str template_id: OPTIONAL: The ID of the template being updated. REQUIRED if updating a template.
        :param str description: OPTIONAL: A description of the new template. Max length 255.
        :param list labels: OPTIONAL: Labels for the new template. An array like:
            [
                {
                    "prefix": "<string>",
                    "name": "<string>",
                    "id": "<string>",
                    "label": "<string>",
                }
            ]
        :param dict space: OPTIONAL: The key for the space of the new template. Only applies to space templates.
            If not specified, the template will be created as a global template.
        :return:
        """
        data = {"name": name, "templateType": template_type, "body": body}

        if description:
            data["description"] = description

        if labels:
            data["labels"] = labels

        if space:
            data["space"] = {"key": space}

        if template_id:
            data["templateId"] = template_id
            return self.put("rest/api/template", data=json.dumps(data))

        return self.post("rest/api/template", json=data)

    @deprecated(version="3.7.0", reason="Use get_content_template()")
    def get_template_by_id(self, template_id):
        """
        Get user template by id. Experimental API
        Use case is get template body and create page from that
        """
        url = f"rest/experimental/template/{template_id}"

        try:
            response = self.get(url)
        except HTTPError as e:
            if e.response.status_code == 403:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no content with the given id, "
                    "or the calling user does not have permission to view the content",
                    reason=e,
                )

            raise
        return response

    def get_content_template(self, template_id):
        """
        Get a content template.

        This includes information about the template, like the name, the space or blueprint
            that the template is in, the body of the template, and more.
        :param str template_id: The ID of the content template to be returned
        :return:
        """
        url = f"rest/api/template/{template_id}"

        try:
            response = self.get(url)
        except HTTPError as e:
            if e.response.status_code == 403:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no content with the given id, "
                    "or the calling user does not have permission to view the content",
                    reason=e,
                )

            raise

        return response

    @deprecated(version="3.7.0", reason="Use get_blueprint_templates()")
    def get_all_blueprints_from_space(self, space, start=0, limit=None, expand=None):
        """
        Get all users blueprints from space. Experimental API
        :param space: Space Key
        :param start: OPTIONAL: The start point of the collection to return. Default: None (0).
        :param limit: OPTIONAL: The limit of the number of pages to return, this may be restricted by
                            fixed system limits. Default: 20
        :param expand: OPTIONAL: expand e.g. body
        """
        url = "rest/experimental/template/blueprint"
        params = {}
        if space:
            params["spaceKey"] = space
        if start:
            params["start"] = start
        if limit:
            params["limit"] = limit
        if expand:
            params["expand"] = expand

        try:
            response = self.get(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 403:
                raise ApiPermissionError(
                    "The calling user does not have permission to view the content",
                    reason=e,
                )

            raise

        return response.get("results") or []

    def get_blueprint_templates(self, space=None, start=0, limit=None, expand=None):
        """
        Gets all templates provided by blueprints.

        Use this method to retrieve all global blueprint templates or all blueprint templates in a space.
        :param space: OPTIONAL: The key of the space to be queried for templates. If ``space`` is not
            specified, global blueprint templates will be returned.
        :param start: OPTIONAL: The starting index of the returned templates. Default: None (0).
        :param limit: OPTIONAL: The limit of the number of pages to return, this may be restricted by
                            fixed system limits. Default: 25
        :param expand: OPTIONAL: A multi-value parameter indicating which properties of the template to expand.
        """
        url = "rest/api/template/blueprint"
        params = {}
        if space:
            params["spaceKey"] = space
        if start:
            params["start"] = start
        if limit:
            params["limit"] = limit
        if expand:
            params["expand"] = expand

        try:
            response = self.get(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 403:
                raise ApiPermissionError(
                    "The calling user does not have permission to view the content",
                    reason=e,
                )

            raise

        return response.get("results") or []

    @deprecated(version="3.7.0", reason="Use get_content_templates()")
    def get_all_templates_from_space(self, space, start=0, limit=None, expand=None):
        """
        Get all users templates from space. Experimental API
        ref: https://docs.atlassian.com/atlassian-confluence/1000.73.0/com/atlassian/confluence/plugins/restapi\
    /resources/TemplateResource.html
        :param space: Space Key
        :param start: OPTIONAL: The start point of the collection to return. Default: None (0).
        :param limit: OPTIONAL: The limit of the number of pages to return, this may be restricted by
                                fixed system limits. Default: 20
        :param expand: OPTIONAL: expand e.g. body
        """
        url = "rest/experimental/template/page"
        params = {}
        if space:
            params["spaceKey"] = space
        if start:
            params["start"] = start
        if limit:
            params["limit"] = limit
        if expand:
            params["expand"] = expand

        try:
            response = self.get(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 403:
                raise ApiPermissionError(
                    "The calling user does not have permission to view the content",
                    reason=e,
                )
            raise

        return response.get("results") or []

    def get_content_templates(self, space=None, start=0, limit=None, expand=None):
        """
        Get all content templates.
        Use this method to retrieve all global content templates or all content templates in a space.
        :param space: OPTIONAL: The key of the space to be queried for templates. If ``space`` is not
            specified, global templates will be returned.
        :param start: OPTIONAL: The start point of the collection to return. Default: None (0).
        :param limit: OPTIONAL: The limit of the number of pages to return, this may be restricted by
                            fixed system limits. Default: 25
        :param expand: OPTIONAL: A multi-value parameter indicating which properties of the template to expand.
            e.g. ``body``
        """
        url = "rest/api/template/page"
        params = {}
        if space:
            params["spaceKey"] = space
        if start:
            params["start"] = start
        if limit:
            params["limit"] = limit
        if expand:
            params["expand"] = expand

        try:
            response = self.get(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 403:
                raise ApiPermissionError(
                    "The calling user does not have permission to view the content",
                    reason=e,
                )

            raise

        return response.get("results") or []

    def remove_template(self, template_id):
        """
        Deletes a template.

        This results in different actions depending on the type of template:
            * If the template is a content template, it is deleted.
            * If the template is a modified space-level blueprint template, it reverts to the template
                inherited from the global-level blueprint template.
            * If the template is a modified global-level blueprint template, it reverts to the default
                global-level blueprint template.
        Note: Unmodified blueprint templates cannot be deleted.

        :param str template_id: The ID of the template to be deleted.
        :return:
        """
        return self.delete(f"rest/api/template/{template_id}")

    def get_all_spaces(
        self,
        start=0,
        limit=50,
        expand=None,
        space_type=None,
        space_status=None,
    ):
        """
        Get all spaces with provided limit
        :param start: OPTIONAL: The start point of the collection to return. Default: None (0).
        :param limit: OPTIONAL: The limit of the number of pages to return, this may be restricted by
                            fixed system limits. Default: 500
        :param space_type: OPTIONAL: Filter the list of spaces returned by type (global, personal)
        :param space_status: OPTIONAL: Filter the list of spaces returned by status (current, archived)
        :param expand: OPTIONAL: additional info, e.g. metadata, icon, description, homepage
        """
        url = "rest/api/space"
        params = {}
        if start:
            params["start"] = start
        if limit:
            params["limit"] = limit
        if expand:
            params["expand"] = expand
        if space_type:
            params["type"] = space_type
        if space_status:
            params["status"] = space_status
        return self.get(url, params=params)

    def archive_space(self, space_key):
        """
        Archive space
        :param space_key:
        :return:
        """
        url = f"rest/api/space/{space_key}/archive"
        return self.put(url)

    def get_trashed_contents_by_space(self, space_key, cursor=None, expand=None, limit=100):
        """
        Get trashed contents by space
        :param space_key:
        :param cursor:
        :param expand:
        :param limit:
        :return:
        """
        url = f"rest/api/space/{space_key}/content/trash"
        params = {"limit": limit}
        if cursor:
            params["cursor"] = cursor
        if expand:
            params["expand"] = expand
        return self.get(url, params=params)

    def remove_trashed_contents_by_space(self, space_key):
        """
        Remove all content from the trash in the given space,
        deleting them permanently.Example request URI:
        :param space_key:
        :return:
        """
        url = f"rest/api/space/{space_key}/content/trash"
        return self.delete(url)

    def add_comment(self, page_id, text):
        """
        Add comment into page
        :param page_id
        :param text
        """
        data = {
            "type": "comment",
            "container": {"id": page_id, "type": "page", "status": "current"},
            "body": self._create_body(text, "storage"),
        }

        try:
            response = self.post("rest/api/content/", data=data)
        except HTTPError as e:
            if e.response.status_code == 404:
                raise ApiPermissionError(
                    "The calling user does not have permission to view the content",
                    reason=e,
                )

            raise

        return response

    def attach_content(
        self,
        content,
        name,
        content_type="application/binary",
        page_id=None,
        title=None,
        space=None,
        comment=None,
    ):
        """
        Attach (upload) a file to a page, if it exists it will update automatically the
        version the new file and keep the old one.
        :param title: The page name
        :type  title: ``str``
        :param space: The space name
        :type  space: ``str``
        :param page_id: The page id to which we would like to upload the file
        :type  page_id: ``str``
        :param name: The name of the attachment
        :type  name: ``str``
        :param content: Contains the content which should be uploaded
        :type  content: ``binary``
        :param content_type: Specify the HTTP content type.
                The default is "application/binary"
        :type  content_type: ``str``
        :param comment: A comment describing this upload/file
        :type  comment: ``str``
        """
        page_id = self.get_page_id(space=space, title=title) if page_id is None else page_id
        type = "attachment"
        if page_id is not None:
            comment = comment if comment else f"Uploaded {name}."
            data = {
                "type": type,
                "fileName": name,
                "contentType": content_type,
                "comment": comment,
                "minorEdit": "true",
            }
            headers = {
                "X-Atlassian-Token": "no-check",
                "Accept": "application/json",
            }
            path = f"rest/api/content/{page_id}/child/attachment"
            # Check if there is already a file with the same name
            attachments = self.get(path=path, headers=headers, params={"filename": name})
            if attachments.get("size"):
                path = path + "/" + attachments["results"][0]["id"] + "/data"

            try:
                response = self.post(
                    path=path,
                    data=data,
                    headers=headers,
                    files={"file": (name, content, content_type)},
                )
            except HTTPError as e:
                if e.response.status_code == 403:
                    # Raise ApiError as the documented reason is ambiguous
                    raise ApiError(
                        "Attachments are disabled or the calling user does "
                        "not have permission to add attachments to this content",
                        reason=e,
                    )
                if e.response.status_code == 404:
                    # Raise ApiError as the documented reason is ambiguous
                    raise ApiError(
                        "The requested content is not found, the user does not have "
                        "permission to view it, or the attachments exceeds the maximum "
                        "configured attachment size",
                        reason=e,
                    )

                raise

            return response
        else:
            log.warning("No 'page_id' found, not uploading attachments")
            return None

    def attach_file(
        self,
        filename,
        name=None,
        content_type=None,
        page_id=None,
        title=None,
        space=None,
        comment=None,
    ):
        """
        Attach (upload) a file to a page, if it exists it will update automatically the
        version the new file and keep the old one.
        :param title: The page name
        :type  title: ``str``
        :param space: The space name
        :type  space: ``str``
        :param page_id: The page id to which we would like to upload the file
        :type  page_id: ``str``
        :param filename: The file to upload (Specifies the content)
        :type  filename: ``str``
        :param name: Specifies name of the attachment. This parameter is optional.
                     Is no name give the file name is used as name
        :type  name: ``str``
        :param content_type: Specify the HTTP content type. The default is
                            The default is "application/binary"
        :type  content_type: ``str``
        :param comment: A comment describing this upload/file
        :type  comment: ``str``
        """
        # get base name of the file to get the attachment from confluence.
        if name is None:
            name = os.path.basename(filename)
        if content_type is None:
            extension = os.path.splitext(filename)[-1]
            content_type = self.content_types.get(extension, "application/binary")

        with open(filename, "rb") as infile:
            content = infile.read()
        return self.attach_content(
            content,
            name,
            content_type,
            page_id=page_id,
            title=title,
            space=space,
            comment=comment,
        )

    def download_attachments_from_page(self, page_id, path=None, start=0, limit=50, filename=None, to_memory=False):
        """
        Downloads attachments from a Confluence page. Supports downloading all files or a specific file.
        Files can either be saved to disk or returned as BytesIO objects for in-memory handling.

        :param page_id: str
            The ID of the Confluence page to fetch attachments from.
        :param path: str, optional
            Directory where attachments will be saved. If None, defaults to the current working directory.
            Ignored if `to_memory` is True.
        :param start: int, optional
            The start point for paginated attachment fetching. Default is 0. Ignored if `filename` is specified.
        :param limit: int, optional
            The maximum number of attachments to fetch per request. Default is 50. Ignored if `filename` is specified.
        :param filename: str, optional
            The name of a specific file to download. If provided, only this file will be fetched.
        :param to_memory: bool, optional
            If True, attachments are returned as a dictionary of {filename: BytesIO object}.
            If False, files are written to the specified directory on disk.
        :return:
            - If `to_memory` is True, returns a dictionary {filename: BytesIO object}.
            - If `to_memory` is False, returns a summary dict: {"attachments_downloaded": int, "path": str}.
        :raises:
            - FileNotFoundError: If the specified path does not exist.
            - PermissionError: If there are permission issues with the specified path.
            - requests.HTTPError: If the HTTP request to fetch an attachment fails.
            - Exception: For any unexpected errors.
        """
        # Default path to current working directory if not provided
        if not to_memory and path is None:
            path = os.getcwd()

        try:
            # Fetch attachments based on the specified parameters
            if filename:
                # Fetch specific file by filename
                attachments = self.get_attachments_from_content(page_id=page_id, filename=filename)["results"]
                if not attachments:
                    return f"No attachment with filename '{filename}' found on the page."
            else:
                # Fetch all attachments with pagination
                attachments = self.get_attachments_from_content(page_id=page_id, start=start, limit=limit)["results"]
                if not attachments:
                    return "No attachments found on the page."

            # Prepare to handle downloads
            downloaded_files = {}
            for attachment in attachments:
                file_name = attachment["title"] or attachment["id"]  # Use attachment ID if title is unavailable
                download_link = attachment["_links"]["download"]
                # Fetch the file content
                response = self.get(str(download_link), not_json_response=True)

                if to_memory:
                    # Store in BytesIO object
                    file_obj = io.BytesIO(response)
                    downloaded_files[file_name] = file_obj
                else:
                    # Save file to disk
                    file_path = os.path.join(path, file_name)
                    with open(file_path, "wb") as file:
                        file.write(response)

            # Return results based on storage mode
            if to_memory:
                return downloaded_files
            else:
                return {"attachments_downloaded": len(attachments), "path": path}
        except NotADirectoryError:
            raise FileNotFoundError(f"The directory '{path}' does not exist.")
        except PermissionError:
            raise PermissionError(f"Permission denied when trying to save files to '{path}'.")
        except requests.HTTPError as http_err:
            raise requests.HTTPError(
                f"HTTP error occurred while downloading attachments: {http_err}",
                response=http_err.response,
                request=http_err.request,
            )
        except Exception as err:
            raise Exception(f"An unexpected error occurred: {err}")

    def delete_attachment(self, page_id, filename, version=None):
        """
        Remove completely a file if version is None or delete version
        :param version:
        :param page_id: file version
        :param filename:
        :return:
        """
        params = {"pageId": page_id, "fileName": filename}
        if version:
            params["version"] = version
        return self.post(
            "json/removeattachment.action",
            params=params,
            headers=self.form_token_headers,
        )

    def delete_attachment_by_id(self, attachment_id, version):
        """
        Remove completely a file if version is None or delete version
        :param attachment_id:
        :param version: file version
        :return:
        """
        if self.cloud:
            url = f"rest/api/content/{attachment_id}/version/{version}"
        else:
            url = f"rest/experimental/content/{attachment_id}/version/{version}"
        return self.delete(url)

    def remove_page_attachment_keep_version(self, page_id, filename, keep_last_versions):
        """
        Keep last versions
        :param filename:
        :param page_id:
        :param keep_last_versions:
        :return:
        """
        attachment = self.get_attachments_from_content(page_id=page_id, expand="version", filename=filename).get(
            "results"
        )[0]
        attachment_versions = self.get_attachment_history(attachment.get("id"))
        while len(attachment_versions) > keep_last_versions:
            remove_version_attachment_number = attachment_versions[keep_last_versions].get("number")
            self.delete_attachment_by_id(
                attachment_id=attachment.get("id"),
                version=remove_version_attachment_number,
            )
            log.info(
                "Removed oldest version for %s, now versions equal more than %s",
                attachment.get("title"),
                len(attachment_versions),
            )
            attachment_versions = self.get_attachment_history(attachment.get("id"))
        log.info("Kept versions %s for %s", keep_last_versions, attachment.get("title"))

    def get_attachment_history(self, attachment_id, limit=200, start=0):
        """
        Get attachment history
        :param attachment_id
        :param limit
        :param start
        :return
        """
        params = {"limit": limit, "start": start}
        if self.cloud:
            url = f"rest/api/content/{attachment_id}/version"
        else:
            url = f"rest/experimental/content/{attachment_id}/version"
        return (self.get(url, params=params) or {}).get("results")

    # @todo prepare more attachments info
    def get_attachments_from_content(
        self,
        page_id,
        start=0,
        limit=50,
        expand=None,
        filename=None,
        media_type=None,
    ):
        """
        Get attachments for page
        :param page_id:
        :param start:
        :param limit:
        :param expand:
        :param filename:
        :param media_type:
        :return:
        """
        params = {}
        if start:
            params["start"] = start
        if limit:
            params["limit"] = limit
        if expand:
            params["expand"] = expand
        if filename:
            params["filename"] = filename
        if media_type:
            params["mediaType"] = media_type
        url = f"rest/api/content/{page_id}/child/attachment"

        try:
            response = self.get(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no content with the given id, "
                    "or the calling user does not have permission to view the content",
                    reason=e,
                )

            raise

        return response

    def set_page_label(self, page_id, label):
        """
        Set a label on the page
        :param page_id: content_id format
        :param label: label to add
        :return:
        """
        url = f"rest/api/content/{page_id}/label"
        data = {"prefix": "global", "name": label}

        try:
            response = self.post(path=url, data=data)
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no content with the given id, "
                    "or the calling user does not have permission to view the content",
                    reason=e,
                )

            raise

        return response

    def remove_page_label(self, page_id: str, label: str):
        """
        Delete Confluence page label
        :param page_id: content_id format
        :param label: label name
        :return:
        """
        url = f"rest/api/content/{page_id}/label"
        params = {"id": page_id, "name": label}

        try:
            response = self.delete(path=url, params=params)
        except HTTPError as e:
            if e.response.status_code == 403:
                raise ApiPermissionError(
                    "The user has view permission, " "but no edit permission to the content",
                    reason=e,
                )
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "The content or label doesn't exist, "
                    "or the calling user doesn't have view permission to the content",
                    reason=e,
                )

            raise

        return response

    def history(self, page_id):
        url = f"rest/api/content/{page_id}/history"
        try:
            response = self.get(url)
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no content with the given id, "
                    "or the calling user does not have permission to view the content",
                    reason=e,
                )

            raise

        return response

    def get_content_history(self, content_id):
        return self.history(content_id)

    def get_content_history_by_version_number(self, content_id, version_number):
        """
        Get content history by version number
        :param content_id:
        :param version_number:
        :return:
        """
        if self.cloud:
            url = f"rest/api/content/{content_id}/version/{version_number}"
        else:
            url = f"rest/experimental/content/{content_id}/version/{version_number}"
        return self.get(url)

    def remove_content_history(self, page_id, version_number):
        """
        Remove content history. It works as experimental method
        :param page_id:
        :param version_number: version number
        :return:
        """
        if self.cloud:
            url = f"rest/api/content/{page_id}/version/{version_number}"
        else:
            url = f"rest/experimental/content/{page_id}/version/{version_number}"
        self.delete(url)

    def remove_page_history(self, page_id, version_number):
        """
        Remove content history. It works as experimental method
        :param page_id:
        :param version_number: version number
        :return:
        """
        self.remove_content_history(page_id, version_number)

    def remove_content_history_in_cloud(self, page_id, version_id):
        """
        Remove content history. It works in CLOUD
        :param page_id:
        :param version_id:
        :return:
        """
        url = f"rest/api/content/{page_id}/version/{version_id}"
        self.delete(url)

    def remove_page_history_keep_version(self, page_id, keep_last_versions):
        """
        Keep last versions
        :param page_id:
        :param keep_last_versions:
        :return:
        """
        page = self.get_page_by_id(page_id=page_id, expand="version")
        page_number = page.get("version").get("number")
        while page_number > keep_last_versions:
            self.remove_page_history(page_id=page_id, version_number=1)
            page = self.get_page_by_id(page_id=page_id, expand="version")
            page_number = page.get("version").get("number")
            log.info("Removed oldest version for %s, now it's %s", page.get("title"), page_number)
        log.info("Kept versions %s for %s", keep_last_versions, page.get("title"))

    def has_unknown_attachment_error(self, page_id):
        """
        Check has unknown attachment error on page
        :param page_id:
        :return:
        """
        unknown_attachment_identifier = "plugins/servlet/confluence/placeholder/unknown-attachment"
        result = self.get_page_by_id(page_id, expand="body.view")
        if len(result) == 0:
            return ""
        body = ((result.get("body") or {}).get("view") or {}).get("value") or {}
        if unknown_attachment_identifier in body:
            return result.get("_links").get("base") + result.get("_links").get("tinyui")
        return ""

    def is_page_content_is_already_updated(self, page_id, body, title=None):
        """
        Compare content and check is already updated or not
        :param page_id: Content ID for retrieve storage value
        :param body: Body for compare it
        :param title: Title to compare
        :return: True if the same
        """
        confluence_content = self.get_page_by_id(page_id)
        if title:
            current_title = confluence_content.get("title", None)
            if title != current_title:
                log.info("Title of %s is different", page_id)
                return False

        if self.advanced_mode:
            confluence_content = (
                (self.get_page_by_id(page_id, expand="body.storage").json() or {}).get("body") or {}
            ).get("storage") or {}
        else:
            confluence_content = ((self.get_page_by_id(page_id, expand="body.storage") or {}).get("body") or {}).get(
                "storage"
            ) or {}

        confluence_body_content = confluence_content.get("value")

        if confluence_body_content:
            # @todo move into utils
            confluence_body_content = utils.symbol_normalizer(confluence_body_content)

        log.debug('Old Content: """%s"""', confluence_body_content)
        log.debug('New Content: """%s"""', body)

        if confluence_body_content.strip().lower() == body.strip().lower():
            log.info("Content of %s is exactly the same", page_id)
            return True
        else:
            log.info("Content of %s differs", page_id)
            return False

    def update_existing_page(
        self,
        page_id,
        title,
        body,
        type="page",
        representation="storage",
        minor_edit=False,
        version_comment=None,
        full_width=False,
    ):
        """Duplicate update_page. Left for the people who used it before. Use update_page instead"""
        return self.update_page(
            page_id=page_id,
            title=title,
            body=body,
            type=type,
            representation=representation,
            minor_edit=minor_edit,
            version_comment=version_comment,
            full_width=full_width,
        )

    def update_page(
        self,
        page_id,
        title,
        body=None,
        parent_id=None,
        type="page",
        representation="storage",
        minor_edit=False,
        version_comment=None,
        always_update=False,
        full_width=False,
    ):
        """
        Update page if already exist
        :param page_id:
        :param title:
        :param body:
        :param parent_id:
        :param type:
        :param representation: OPTIONAL: either Confluence 'storage' or 'wiki' markup format
        :param minor_edit: Indicates whether to notify watchers about changes.
            If False then notifications will be sent.
        :param version_comment: Version comment
        :param always_update: Whether always to update (suppress content check)
        :param full_width: OPTIONAL: Default False
        :return:
        """
        # update current page
        params = {"status": "current"}
        log.info('Updating %s "%s" with %s', type, title, parent_id)

        if not always_update and body is not None and self.is_page_content_is_already_updated(page_id, body, title):
            return self.get_page_by_id(page_id)

        try:
            if self.advanced_mode:
                version = self.history(page_id).json()["lastUpdated"]["number"] + 1
            else:
                version = self.history(page_id)["lastUpdated"]["number"] + 1
        except (IndexError, TypeError) as e:
            log.error("Can't find '%s' %s!", title, type)
            log.debug(e)
            return None

        data = {
            "id": page_id,
            "type": type,
            "title": title,
            "version": {"number": version, "minorEdit": minor_edit},
            "metadata": {"properties": {}},
        }
        if body is not None:
            data["body"] = self._create_body(body, representation)

        if parent_id:
            data["ancestors"] = [{"type": "page", "id": parent_id}]
        if version_comment:
            data["version"]["message"] = version_comment

        if full_width is True:
            data["metadata"]["properties"]["content-appearance-draft"] = {"value": "full-width"}
            data["metadata"]["properties"]["content-appearance-published"] = {"value": "full-width"}
        else:
            data["metadata"]["properties"]["content-appearance-draft"] = {"value": "fixed-width"}
            data["metadata"]["properties"]["content-appearance-published"] = {"value": "fixed-width"}
        try:
            response = self.put(
                f"rest/api/content/{page_id}",
                data=data,
                params=params,
            )
        except HTTPError as e:
            if e.response.status_code == 400:
                raise ApiValueError(
                    "No space or no content type, or setup a wrong version "
                    "type set to content, or status param is not draft and "
                    "status content is current",
                    reason=e,
                )
            if e.response.status_code == 404:
                raise ApiNotFoundError("Can not find draft with current content", reason=e)

            raise

        return response

    def _insert_to_existing_page(
        self,
        page_id,
        title,
        insert_body,
        parent_id=None,
        type="page",
        representation="storage",
        minor_edit=False,
        version_comment=None,
        top_of_page=False,
    ):
        """
        Insert body to a page if already exist
        :param parent_id:
        :param page_id:
        :param title:
        :param insert_body:
        :param type:
        :param representation: OPTIONAL: either Confluence 'storage' or 'wiki' markup format
        :param minor_edit: Indicates whether to notify watchers about changes.
            If False then notifications will be sent.
        :param top_of_page: Option to add the content to the end of page body
        :return:
        """
        log.info('Updating %s "%s"', type, title)
        # update current page
        params = {"status": "current"}

        if self.is_page_content_is_already_updated(page_id, insert_body, title):
            return self.get_page_by_id(page_id)
        else:
            version = self.history(page_id)["lastUpdated"]["number"] + 1
            previous_body = (
                (self.get_page_by_id(page_id, expand="body.storage").get("body") or {}).get("storage").get("value")
            )
            previous_body = previous_body.replace("&oacute;", "ó")
            body = insert_body + previous_body if top_of_page else previous_body + insert_body
            data = {
                "id": page_id,
                "type": type,
                "title": title,
                "body": self._create_body(body, representation),
                "version": {"number": version, "minorEdit": minor_edit},
            }

            if parent_id:
                data["ancestors"] = [{"type": "page", "id": parent_id}]
            if version_comment:
                data["version"]["message"] = version_comment

            try:
                response = self.put(
                    f"rest/api/content/{page_id}",
                    data=data,
                    params=params,
                )
            except HTTPError as e:
                if e.response.status_code == 400:
                    raise ApiValueError(
                        "No space or no content type, or setup a wrong version "
                        "type set to content, or status param is not draft and "
                        "status content is current",
                        reason=e,
                    )
                if e.response.status_code == 404:
                    raise ApiNotFoundError("Can not find draft with current content", reason=e)

                raise

            return response

    def append_page(
        self,
        page_id,
        title,
        append_body,
        parent_id=None,
        type="page",
        representation="storage",
        minor_edit=False,
    ):
        """
        Append body to page if already exist
        :param parent_id:
        :param page_id:
        :param title:
        :param append_body:
        :param type:
        :param representation: OPTIONAL: either Confluence 'storage' or 'wiki' markup format
        :param minor_edit: Indicates whether to notify watchers about changes.
            If False then notifications will be sent.
        :return:
        """
        log.info('Updating %s "%s"', type, title)

        return self._insert_to_existing_page(
            page_id,
            title,
            append_body,
            parent_id=parent_id,
            type=type,
            representation=representation,
            minor_edit=minor_edit,
            top_of_page=False,
        )

    def prepend_page(
        self,
        page_id,
        title,
        prepend_body,
        parent_id=None,
        type="page",
        representation="storage",
        minor_edit=False,
    ):
        """
        Append body to page if already exist
        :param parent_id:
        :param page_id:
        :param title:
        :param prepend_body:
        :param type:
        :param representation: OPTIONAL: either Confluence 'storage' or 'wiki' markup format
        :param minor_edit: Indicates whether to notify watchers about changes.
            If False then notifications will be sent.
        :return:
        """
        log.info('Updating %s "%s"', type, title)

        return self._insert_to_existing_page(
            page_id,
            title,
            prepend_body,
            parent_id=parent_id,
            type=type,
            representation=representation,
            minor_edit=minor_edit,
            top_of_page=True,
        )

    def update_or_create(
        self,
        parent_id,
        title,
        body,
        representation="storage",
        minor_edit=False,
        version_comment=None,
        editor=None,
        full_width=False,
    ):
        """
        Update page or create a page if it is not exists
        :param parent_id:
        :param title:
        :param body:
        :param representation: OPTIONAL: either Confluence 'storage' or 'wiki' markup format
        :param minor_edit: Update page without notification
        :param version_comment: Version comment
        :param editor: OPTIONAL: v2 to be created in the new editor
        :param full_width: OPTIONAL: Default is False
        :return:
        """
        space = self.get_page_space(parent_id)

        if self.page_exists(space, title):
            page_id = self.get_page_id(space, title)
            parent_id = parent_id if parent_id is not None else self.get_parent_content_id(page_id)
            result = self.update_page(
                parent_id=parent_id,
                page_id=page_id,
                title=title,
                body=body,
                representation=representation,
                minor_edit=minor_edit,
                version_comment=version_comment,
                full_width=full_width,
            )
        else:
            result = self.create_page(
                space=space,
                parent_id=parent_id,
                title=title,
                body=body,
                representation=representation,
                editor=editor,
                full_width=full_width,
            )

        log.info(
            "You may access your page at: %s%s",
            self.url,
            ((result or {}).get("_links") or {}).get("tinyui"),
        )
        return result

    def convert_wiki_to_storage(self, wiki):
        """
        Convert to Confluence XHTML format from wiki style
        :param wiki:
        :return:
        """
        data = {"value": wiki, "representation": "wiki"}
        return self.post("rest/api/contentbody/convert/storage", data=data)

    def convert_storage_to_view(self, storage):
        """
        Convert from Confluence XHTML format to view format
        :param storage:
        :return:
        """
        data = {"value": storage, "representation": "storage"}
        return self.post("rest/api/contentbody/convert/view", data=data)

    def set_page_property(self, page_id, data):
        """
        Set the page (content) property e.g. add hash parameters
        :param page_id: content_id format
        :param data: data should be as json data
        :return:
        """
        url = f"rest/api/content/{page_id}/property"
        json_data = data

        try:
            response = self.post(path=url, data=json_data)
        except HTTPError as e:
            if e.response.status_code == 400:
                raise ApiValueError(
                    "The given property has a different content id to the one in the "
                    "path, or the content already has a value with the given key, or "
                    "the value is missing, or the value is too long",
                    reason=e,
                )
            if e.response.status_code == 403:
                raise ApiPermissionError(
                    "The user does not have permission to " "edit the content with the given id",
                    reason=e,
                )
            if e.response.status_code == 413:
                raise ApiValueError("The value is too long", reason=e)

            raise

        return response

    def update_page_property(self, page_id, data):
        """
        Update the page (content) property.
        Use json data or independent keys
        :param data:
        :param page_id: content_id format
        :data: property data in json format
        :return:
        """
        url = f"rest/api/content/{page_id}/property/{data.get('key')}"
        try:
            response = self.put(path=url, data=data)
        except HTTPError as e:
            if e.response.status_code == 400:
                raise ApiValueError(
                    "The given property has a different content id to the one in the "
                    "path, or the content already has a value with the given key, or "
                    "the value is missing, or the value is too long",
                    reason=e,
                )
            if e.response.status_code == 403:
                raise ApiPermissionError(
                    "The user does not have permission to " "edit the content with the given id",
                    reason=e,
                )
            if e.response.status_code == 404:
                raise ApiNotFoundError(
                    "There is no content with the given id, or no property with the given key, "
                    "or if the calling user does not have permission to view the content.",
                    reason=e,
                )
            if e.response.status_code == 409:
                raise ApiConflictError(
                    "The given version is does not match the expected " "target version of the updated property",
                    reason=e,
                )
            if e.response.status_code == 413:
                raise ApiValueError("The value is too long", reason=e)
            raise
        return response

    def delete_page_property(self, page_id, page_property):
        """
        Delete the page (content) property e.g. delete key of hash
        :param page_id: content_id format
        :param page_property: key of property
        :return:
        """
        url = f"rest/api/content/{page_id}/property/{str(page_property)}"
        try:
            response = self.delete(path=url)
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no content with the given id, "
                    "or the calling user does not have permission to view the content",
                    reason=e,
                )

            raise

        return response

    def get_page_property(self, page_id, page_property_key):
        """
        Get the page (content) property e.g. get key of hash
        :param page_id: content_id format
        :param page_property_key: key of property
        :return:
        """
        url = f"rest/api/content/{page_id}/property/{str(page_property_key)}"
        try:
            response = self.get(path=url)
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no content with the given id, or no property with the "
                    "given key, or the calling user does not have permission to view "
                    "the content",
                    reason=e,
                )

            raise

        return response

    def get_page_properties(self, page_id):
        """
        Get the page (content) properties
        :param page_id: content_id format
        :return: get properties
        """
        url = f"rest/api/content/{page_id}/property"

        try:
            response = self.get(path=url)
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no content with the given id, "
                    "or the calling user does not have permission to view the content",
                    reason=e,
                )

            raise

        return response

    def get_page_ancestors(self, page_id):
        """
        Provide the ancestors from the page (content) id
        :param page_id: content_id format
        :return: get properties
        """
        url = f"rest/api/content/{page_id}?expand=ancestors"

        try:
            response = self.get(path=url)
        except HTTPError as e:
            if e.response.status_code == 404:
                raise ApiPermissionError(
                    "The calling user does not have permission to view the content",
                    reason=e,
                )

            raise

        return response.get("ancestors")

    def clean_all_caches(self):
        """Clean all caches from cache management"""
        headers = self.form_token_headers
        return self.delete("rest/cacheManagement/1.0/cacheEntries", headers=headers)

    def clean_package_cache(self, cache_name="com.gliffy.cache.gon"):
        """Clean caches from cache management
        e.g.
        com.gliffy.cache.gon
        org.hibernate.cache.internal.StandardQueryCache_v5
        """
        headers = self.form_token_headers
        data = {"cacheName": cache_name}
        return self.delete("rest/cacheManagement/1.0/cacheEntries", data=data, headers=headers)

    def get_all_groups(self, start=0, limit=1000):
        """
        Get all groups from Confluence User management
        :param start: OPTIONAL: The start point of the collection to return. Default: None (0).
        :param limit: OPTIONAL: The limit of the number of groups to return, this may be restricted by
                                fixed system limits. Default: 1000
        :return:
        """
        url = f"rest/api/group?limit={limit}&start={start}"

        try:
            response = self.get(url)
        except HTTPError as e:
            if e.response.status_code == 403:
                raise ApiPermissionError(
                    "The calling user does not have permission to view groups",
                    reason=e,
                )

            raise

        return response.get("results")

    def create_group(self, name):
        """
        Create a group by given group parameter

        :param name: str
        :return: New group params
        """
        url = "rest/api/admin/group"
        data = {"name": name, "type": "group"}
        return self.post(url, data=data)

    def remove_group(self, name):
        """
        Delete a group by given group parameter
        If you delete a group and content is restricted to that group, the content will be hidden from all users

        :param name: str
        :return:
        """
        log.info("Removing group:  %s  during Confluence remove_group method execution", name)
        url = f"rest/api/admin/group/{name}"

        try:
            response = self.delete(url)
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no group with the given name, "
                    "or the calling user does not have permission to delete it",
                    reason=e,
                )
            raise

        return response

    def get_group_members(self, group_name="confluence-users", start=0, limit=1000, expand=None):
        """
        Get a paginated collection of users in the given group
        :param group_name
        :param start: OPTIONAL: The start point of the collection to return. Default: None (0).
        :param limit: OPTIONAL: The limit of the number of users to return, this may be restricted by
                            fixed system limits. Default: 1000
        :param expand: OPTIONAL: A comma separated list of properties to expand on the content. status
        :return:
        """
        url = f"rest/api/group/{group_name}/member?limit={limit}&start={start}&expand={expand}"

        try:
            response = self.get(url)
        except HTTPError as e:
            if e.response.status_code == 403:
                raise ApiPermissionError(
                    "The calling user does not have permission to view users",
                    reason=e,
                )

            raise

        return response.get("results")

    def get_all_members(self, group_name="confluence-users", expand=None):
        """
        Get  collection of all users in the given group
        :param group_name
        :param expand: OPTIONAL: A comma separated list of properties to expand on the content. status
        :return:
        """
        limit = 50
        flag = True
        step = 0
        members = []
        while flag:
            values = self.get_group_members(
                group_name=group_name,
                start=len(members),
                limit=limit,
                expand=expand,
            )
            step += 1
            if len(values) == 0:
                flag = False
            else:
                members.extend(values)
        if not members:
            print(f"Did not get members from {group_name} group, please check permissions or connectivity")
        return members

    def get_space(self, space_key, expand="description.plain,homepage", params=None):
        """
        Get information about a space through space key
        :param space_key: The unique space key name
        :param expand: OPTIONAL: additional info from description, homepage
        :param params: OPTIONAL: dictionary of additional URL parameters
        :return: Returns the space along with its ID
        """
        url = f"rest/api/space/{space_key}"
        params = params or {}
        if expand:
            params["expand"] = expand
        try:
            response = self.get(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no space with the given key, "
                    "or the calling user does not have permission to view the space",
                    reason=e,
                )
            raise
        return response

    def get_space_content(
        self,
        space_key,
        depth="all",
        start=0,
        limit=500,
        content_type=None,
        expand="body.storage",
    ):
        """
        Get space content.
        You can specify which type of content want to receive, or get all content types.
        Use expand to get specific content properties or page
        :param content_type:
        :param space_key: The unique space key name
        :param depth: OPTIONAL: all|root
                                Gets all space pages or only root pages
        :param start: OPTIONAL: The start point of the collection to return. Default: 0.
        :param limit: OPTIONAL: The limit of the number of pages to return, this may be restricted by
                                fixed system limits. Default: 500
        :param expand: OPTIONAL: by default expands page body in confluence storage format.
                                 See atlassian documentation for more information.
        :return: Returns the space along with its ID
        """

        content_type = f"{'/' + content_type if content_type else ''}"
        url = f"rest/api/space/{space_key}/content{content_type}"
        params = {
            "depth": depth,
            "start": start,
            "limit": limit,
        }
        if expand:
            params["expand"] = expand
        try:
            response = self.get(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no space with the given key, "
                    "or the calling user does not have permission to view the space",
                    reason=e,
                )
            raise
        return response

    def get_home_page_of_space(self, space_key):
        """
        Get information about a space through space key
        :param space_key: The unique space key name
        :return: Returns homepage
        """
        return self.get_space(space_key, expand="homepage").get("homepage")

    def create_space(self, space_key, space_name):
        """
        Create space
        :param space_key:
        :param space_name:
        :return:
        """
        data = {"key": space_key, "name": space_name}
        self.post("rest/api/space", data=data)

    def delete_space(self, space_key):
        """
        Delete space
        :param space_key:
        :return:
        """
        url = f"rest/api/space/{space_key}"

        try:
            response = self.delete(url)
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no space with the given key, "
                    "or the calling user does not have permission to delete it",
                    reason=e,
                )

            raise

        return response

    def get_space_property(self, space_key, expand=None):
        url = f"rest/api/space/{space_key}/property"
        params = {}
        if expand:
            params["expand"] = expand

        try:
            response = self.get(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no space with the given key, "
                    "or the calling user does not have permission to view the space",
                    reason=e,
                )

            raise

        return response

    def get_user_details_by_username(self, username, expand=None):
        """
        Get information about a user through username
        :param username: The username
        :param expand: OPTIONAL expand for get status of user.
                Possible param is "status". Results are "Active, Deactivated"
        :return: Returns the user details
        """
        url = "rest/api/user"
        params = {"username": username}
        if expand:
            params["expand"] = expand

        try:
            response = self.get(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 403:
                raise ApiPermissionError(
                    "The calling user does not have permission to view users",
                    reason=e,
                )
            if e.response.status_code == 404:
                raise ApiNotFoundError(
                    "The user with the given username or userkey does not exist",
                    reason=e,
                )

            raise

        return response

    def get_user_details_by_accountid(self, accountid, expand=None):
        """
        Get information about a user through accountid
        :param accountid: The account id
        :param expand: OPTIONAL expand for get status of user.
                Possible param is "status". Results are "Active, Deactivated"
        :return: Returns the user details
        """
        url = "rest/api/user"
        params = {"accountId": accountid}
        if expand:
            params["expand"] = expand

        try:
            response = self.get(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 403:
                raise ApiPermissionError(
                    "The calling user does not have permission to view users",
                    reason=e,
                )
            if e.response.status_code == 404:
                raise ApiNotFoundError(
                    "The user with the given account does not exist",
                    reason=e,
                )

            raise

        return response

    def get_user_details_by_userkey(self, userkey, expand=None):
        """
        Get information about a user through user key
        :param userkey: The user key
        :param expand: OPTIONAL expand for get status of user.
                Possible param is "status". Results are "Active, Deactivated"
        :return: Returns the user details
        """
        url = "rest/api/user"
        params = {"key": userkey}
        if expand:
            params["expand"] = expand

        try:
            response = self.get(url, params=params)
        except HTTPError as e:
            if e.response.status_code == 403:
                raise ApiPermissionError(
                    "The calling user does not have permission to view users",
                    reason=e,
                )
            if e.response.status_code == 404:
                raise ApiNotFoundError(
                    "The user with the given username or userkey does not exist",
                    reason=e,
                )

            raise

        return response

    def cql(
        self,
        cql,
        start=0,
        limit=None,
        expand=None,
        include_archived_spaces=None,
        excerpt=None,
    ):
        """
        Get results from cql search result with all related fields
        Search for entities in Confluence using the Confluence Query Language (CQL)
        :param cql:
        :param start: OPTIONAL: The start point of the collection to return. Default: 0.
        :param limit: OPTIONAL: The limit of the number of issues to return, this may be restricted by
                        fixed system limits. Default by built-in method: 25
        :param excerpt: the excerpt strategy to apply to the result, one of : indexed, highlight, none.
                        This defaults to highlight
        :param expand: OPTIONAL: the properties to expand on the search result,
                        this may cause database requests for some properties
        :param include_archived_spaces: OPTIONAL: whether to include content in archived spaces in the result,
                                    this defaults to false
        :return:
        """
        params = {}
        if start is not None:
            params["start"] = int(start)
        if limit is not None:
            params["limit"] = int(limit)
        if cql is not None:
            params["cql"] = cql
        if expand is not None:
            params["expand"] = expand
        if include_archived_spaces is not None:
            params["includeArchivedSpaces"] = include_archived_spaces
        if excerpt is not None:
            params["excerpt"] = excerpt

        try:
            response = self.get("rest/api/search", params=params)
        except HTTPError as e:
            if e.response.status_code == 400:
                raise ApiValueError("The query cannot be parsed", reason=e)

            raise

        return response

    def get_page_as_pdf(self, page_id):
        """
        Export page as standard pdf exporter
        :param page_id: Page ID
        :return: PDF File
        """
        headers = self.form_token_headers
        url = f"spaces/flyingpdf/pdfpageexport.action?pageId={page_id}"
        if self.api_version == "cloud" or self.cloud:
            url = self.get_pdf_download_url_for_confluence_cloud(url)
            if not url:
                log.error("Failed to get download PDF url.")
                raise ApiNotFoundError("Failed to export page as PDF", reason="Failed to get download PDF url.")
            # To download the PDF file, the request should be with no headers of authentications.
            return requests.get(url, timeout=75).content
        return self.get(url, headers=headers, not_json_response=True)

    def get_page_as_word(self, page_id):
        """
        Export page as standard word exporter.
        :param page_id: Page ID
        :return: Word File
        """
        headers = self.form_token_headers
        url = f"exportword?pageId={page_id}"
        return self.get(url, headers=headers, not_json_response=True)

    def get_space_export(self, space_key: str, export_type: str) -> str:
        """
        Export a Confluence space to a file of the specified type.
        (!) This method was developed for Confluence Cloud and may not work with Confluence on-prem.
        (!) This is an experimental method that does not trigger an officially supported REST endpoint.
        It may break if Atlassian changes the space export front-end logic.

        :param space_key: The key of the space to export.
        :param export_type: The type of export to perform. Valid values are: 'html', 'csv', 'xml', 'pdf'.
        :return: The URL to download the exported file.
        """

        def get_atl_request(link: str):
            # Nested function  used to get atl_token used for XSRF protection.
            # This is only applicable to html/csv/xml space exports
            try:
                response = self.get(link, advanced_mode=True)
                parsed_html = BeautifulSoup(response.text, "html.parser")
                atl_token = parsed_html.find("input", {"name": "atl_token"}).get("value")  # type: ignore[union-attr]
                return atl_token
            except Exception as e:
                raise ApiError("Problems with getting the atl_token for get_space_export method :", reason=e)

        # Checks if space_ke parameter is valid and if api_token has relevant permissions to space
        self.get_space(space_key=space_key, expand="permissions")

        try:
            log.info(
                "Initiated experimental get_space_export method for export type: "
                + export_type
                + " from Confluence space: "
                + space_key
            )
            if export_type == "csv":
                form_data = dict(
                    atl_token=get_atl_request(f"spaces/exportspacecsv.action?key={space_key}"),
                    exportType="TYPE_CSV",
                    contentOption="all",
                    includeComments="true",
                    confirm="Export",
                )
            elif export_type == "html":
                form_data = {
                    "atl_token": get_atl_request(f"spaces/exportspacehtml.action?key={space_key}"),
                    "exportType": "TYPE_HTML",
                    "contentOption": "visibleOnly",
                    "includeComments": "true",
                    "confirm": "Export",
                }
            elif export_type == "xml":
                form_data = {
                    "atl_token": get_atl_request(f"spaces/exportspacexml.action?key={space_key}"),
                    "exportType": "TYPE_XML",
                    "contentOption": "all",
                    "includeComments": "true",
                    "confirm": "Export",
                }
            elif export_type == "pdf":
                url = "spaces/flyingpdf/doflyingpdf.action?key=" + space_key
                log.info("Initiated PDF  space export")
                return self.get_pdf_download_url_for_confluence_cloud(url)
            else:
                raise ValueError("Invalid export_type parameter value. Valid values are: 'html/csv/xml/pdf'")
            url = self.url_joiner(url=self.url, path=f"spaces/doexportspace.action?key={space_key}")

            # Sending a POST request that triggers the space export.
            response = self.session.post(url, headers=self.form_token_headers, data=form_data)
            parsed_html = BeautifulSoup(response.text, "html.parser")
            # Getting the poll URL to get the export progress status
            try:
                poll_url = cast("str", parsed_html.find("meta", {"name": "ajs-pollURI"}).get("content"))  # type: ignore[union-attr]
            except Exception as e:
                raise ApiError("Problems with getting the poll_url for get_space_export method :", reason=e)
            running_task = True
            while running_task:
                try:
                    progress_response = self.get(poll_url) or {}
                    log.info(f"Space {space_key} export status: {progress_response.get('message', 'None')}")
                    if progress_response is not {} and progress_response.get("complete"):
                        parsed_html = BeautifulSoup(progress_response.get("message"), "html.parser")
                        download_url = cast("str", parsed_html.find("a", {"class": "space-export-download-path"}).get("href"))  # type: ignore
                        if self.url in download_url:
                            return download_url
                        else:
                            combined_url = self.url + download_url
                            # Ensure only one /wiki is included in the path
                            if combined_url.count("/wiki") > 1:
                                combined_url = combined_url.replace("/wiki/wiki", "/wiki")
                            return combined_url
                    time.sleep(30)
                except Exception as e:
                    raise ApiError(
                        "Encountered error during space export status check from space " + space_key, reason=e
                    )

            return "None"  # Return None if the while loop does not return a value
        except Exception as e:
            raise ApiError("Encountered error during space export from space " + space_key, reason=e)

    def export_page(self, page_id):
        """
        Alias method for export page as pdf
        :param page_id: Page ID
        :return: PDF File
        """
        return self.get_page_as_pdf(page_id)

    def get_descendant_page_id(self, space, parent_id, title):
        """
        Provide  space, parent_id and title of the descendant page, it will return the descendant page_id
        :param space: str
        :param parent_id: int
        :param title: str
        :return: page_id of the page whose title is passed in argument
        """
        page_id = ""

        url = f'rest/api/content/search?cql=parent={parent_id}%20AND%20space="{space}"'

        try:
            response = self.get(url, {})
        except HTTPError as e:
            if e.response.status_code == 400:
                raise ApiValueError("The CQL is invalid or missing", reason=e)

            raise

        for each_page in response.get("results", []):
            if each_page.get("title") == title:
                page_id = each_page.get("id")
                break
        return page_id

    def reindex(self):
        """
        It is not public method for reindex Confluence
        :return:
        """
        url = "rest/prototype/1/index/reindex"
        return self.post(url)

    def reindex_get_status(self):
        """
        Get reindex status of Confluence
        :return:
        """
        url = "rest/prototype/1/index/reindex"
        return self.get(url)

    def health_check(self):
        """
        Get health status
        https://confluence.atlassian.com/jirakb/how-to-retrieve-health-check-results-using-rest-api-867195158.html
        :return:
        """
        # check as Troubleshooting & Support Tools Plugin
        response = self.get("rest/troubleshooting/1.0/check/")
        if not response:
            # check as support tools
            response = self.get("rest/supportHealthCheck/1.0/check/")
        return response

    def synchrony_enable(self):
        """
        Enable Synchrony
        :return:
        """
        headers = {"X-Atlassian-Token": "no-check"}
        url = "rest/synchrony-interop/enable"
        return self.post(url, headers=headers)

    def synchrony_disable(self):
        """
        Disable Synchrony
        :return:
        """
        headers = {"X-Atlassian-Token": "no-check"}
        url = "rest/synchrony-interop/disable"
        return self.post(url, headers=headers)

    def check_access_mode(self):
        return self.get("rest/api/accessmode")

    def anonymous(self):
        """
        Get information about how anonymous is represented in confluence
        :return:
        """
        try:
            response = self.get("rest/api/user/anonymous")
        except HTTPError as e:
            if e.response.status_code == 403:
                raise ApiPermissionError(
                    "The calling user does not have permission to use Confluence",
                    reason=e,
                )

            raise

        return response

    def get_plugins_info(self):
        """
        Provide plugins info
        :return a json of installed plugins
        """
        url = "rest/plugins/1.0/"
        return self.get(url, headers=self.no_check_headers, trailing=True)

    def get_plugin_info(self, plugin_key):
        """
        Provide plugin info
        :return a json of installed plugins
        """
        url = f"rest/plugins/1.0/{plugin_key}-key"
        return self.get(url, headers=self.no_check_headers, trailing=True)

    def get_plugin_license_info(self, plugin_key):
        """
        Provide plugin license info
        :return a json specific License query
        """
        url = f"rest/plugins/1.0/{plugin_key}-key/license"
        return self.get(url, headers=self.no_check_headers, trailing=True)

    def upload_plugin(self, plugin_path):
        """
        Provide plugin path for upload into Jira e.g. useful for auto deploy
        :param plugin_path:
        :return:
        """
        files = {"plugin": open(plugin_path, "rb")}
        upm_token = self.request(
            method="GET",
            path="rest/plugins/1.0/",
            headers=self.no_check_headers,
            trailing=True,
        ).headers["upm-token"]
        url = f"rest/plugins/1.0/?token={upm_token}"
        return self.post(url, files=files, headers=self.no_check_headers)

    def disable_plugin(self, plugin_key):
        """
        Disable a plugin
        :param plugin_key:
        :return:
        """
        app_headers = {
            "X-Atlassian-Token": "no-check",
            "Content-Type": "application/vnd.atl.plugins+json",
        }
        url = f"rest/plugins/1.0/{plugin_key}-key"
        data = {"status": "disabled"}
        return self.put(url, data=data, headers=app_headers)

    def enable_plugin(self, plugin_key):
        """
        Enable a plugin
        :param plugin_key:
        :return:
        """
        app_headers = {
            "X-Atlassian-Token": "no-check",
            "Content-Type": "application/vnd.atl.plugins+json",
        }
        url = f"rest/plugins/1.0/{plugin_key}-key"
        data = {"status": "enabled"}
        return self.put(url, data=data, headers=app_headers)

    def delete_plugin(self, plugin_key):
        """
        Delete plugin
        :param plugin_key:
        :return:
        """
        url = f"rest/plugins/1.0/{plugin_key}-key"
        return self.delete(url)

    def check_plugin_manager_status(self):
        url = "rest/plugins/latest/safe-mode"
        return self.request(method="GET", path=url, headers=self.safe_mode_headers)

    def update_plugin_license(self, plugin_key, raw_license):
        """
        Update license for plugin
        :param plugin_key:
        :param raw_license:
        :return:
        """
        app_headers = {
            "X-Atlassian-Token": "no-check",
            "Content-Type": "application/vnd.atl.plugins+json",
        }
        url = f"/plugins/1.0/{plugin_key}/license"
        data = {"rawLicense": raw_license}
        return self.put(url, data=data, headers=app_headers)

    def check_long_tasks_result(self, start=None, limit=None, expand=None):
        """
        Get result of long tasks
        :param start: OPTIONAL: The start point of the collection to return. Default: None (0).
        :param limit: OPTIONAL: The limit of the number of pages to return, this may be restricted by
                            fixed system limits. Default: 50
        :param expand:
        :return:
        """
        params = {}
        if expand:
            params["expand"] = expand
        if start:
            params["start"] = start
        if limit:
            params["limit"] = limit
        return self.get("rest/api/longtask", params=params)

    def check_long_task_result(self, task_id, expand=None):
        """
        Get result of long tasks
        :param task_id: task id
        :param expand:
        :return:
        """
        params = None
        if expand:
            params = {"expand": expand}

        try:
            response = self.get(f"rest/api/longtask/{task_id}", params=params)
        except HTTPError as e:
            if e.response.status_code == 404:
                # Raise ApiError as the documented reason is ambiguous
                raise ApiError(
                    "There is no task with the given key, " "or the calling user does not have permission to view it",
                    reason=e,
                )

            raise

        return response

    def get_pdf_download_url_for_confluence_cloud(self, url):
        """
        Confluence cloud does not return the PDF document when the PDF
        export is initiated. Instead, it starts a process in the background
        and provides a link to download the PDF once the process completes.
        This functions polls the long-running task page and returns the
        download url of the PDF.
        This method is used in get_space_export() method for space-> PDF export.
        :param url: URL to initiate PDF export
        :return: Download url for PDF file
        """
        try:
            running_task = True
            headers = self.form_token_headers
            log.info("Initiate PDF export from Confluence Cloud")
            response = self.get(url, headers=headers, not_json_response=True)
            response_string = response.decode(encoding="utf-8", errors="ignore")
            task_id = response_string.split('name="ajs-taskId" content="')[1].split('">')[0]
            poll_url = f"/services/api/v1/task/{task_id}/progress"
            while running_task:
                log.info("Check if export task has completed.")
                progress_response = self.get(poll_url)
                percentage_complete = int(progress_response.get("progress", 0))
                task_state = progress_response.get("state")
                if task_state == "FAILED":
                    log.error("PDF conversion not successful.")
                    return None
                elif percentage_complete == 100:
                    running_task = False
                    log.info(f"Task completed - {task_state}")
                    log.debug("Extract task results to download PDF.")
                    task_result_url = progress_response.get("result")
                else:
                    log.info(f"{percentage_complete}% - {task_state}")
                    time.sleep(3)
            log.debug("Task successfully done, querying the task result for the download url")
            # task result url starts with /wiki, remove it.
            task_content = self.get(task_result_url[5:], not_json_response=True)
            download_url = task_content.decode(encoding="utf-8", errors="strict")
            log.debug("Successfully got the download url")
            return download_url
        except IndexError as e:
            log.error(e)
            return None

    def audit(
        self,
        start_date=None,
        end_date=None,
        start=None,
        limit=None,
        search_string=None,
    ):
        """
        Fetch a paginated list of AuditRecord instances dating back to a certain time
        :param start_date:
        :param end_date:
        :param start:
        :param limit:
        :param search_string:
        :return:
        """
        url = "rest/api/audit"
        params = {}
        if start_date:
            params["startDate"] = start_date
        if end_date:
            params["endDate"] = end_date
        if start:
            params["start"] = start
        if limit:
            params["limit"] = limit
        if search_string:
            params["searchString"] = search_string
        return self.get(url, params=params)

    """
    ##############################################################################################
    #   Confluence whiteboards (cloud only!)  #
    ##############################################################################################
    """

    def create_whiteboard(self, spaceId, title=None, parentId=None):
        url = "/api/v2/whiteboards"
        data = {"spaceId": spaceId}
        if title is not None:
            data["title"] = title
        if parentId is not None:
            data["parentId"] = parentId
        return self.post(url, data=data)

    def get_whiteboard(self, whiteboard_id):
        try:
            url = "/api/v2/whiteboards/%s" % (whiteboard_id)
            return self.get(url)
        except HTTPError as e:
            # Default 404 error handling is ambiguous
            if e.response.status_code == 404:
                raise ApiValueError(
                    "Whiteboard not found. Check confluence instance url and/or if whiteboard id exists", reason=e
                )

            raise

    def delete_whiteboard(self, whiteboard_id):
        try:
            url = "/api/v2/whiteboards/%s" % (whiteboard_id)
            return self.delete(url)
        except HTTPError as e:
            # # Default 404 error handling is ambiguous
            if e.response.status_code == 404:
                raise ApiValueError(
                    "Whiteboard not found. Check confluence instance url and/or if whiteboard id exists", reason=e
                )

            raise

    """
    ##############################################################################################
    #   Team Calendars REST API implements  (https://jira.atlassian.com/browse/CONFSERVER-51003) #
    ##############################################################################################
    """

    def team_calendars_get_sub_calendars(self, include=None, viewing_space_key=None, calendar_context=None):
        """
        Get subscribed calendars
        :param include:
        :param viewing_space_key:
        :param calendar_context:
        :return:
        """
        url = "rest/calendar-services/1.0/calendar/subcalendars"
        params = {}
        if include:
            params["include"] = include
        if viewing_space_key:
            params["viewingSpaceKey"] = viewing_space_key
        if calendar_context:
            params["calendarContext"] = calendar_context
        return self.get(url, params=params)

    def team_calendars_get_sub_calendars_watching_status(self, include=None):
        url = "rest/calendar-services/1.0/calendar/subcalendars/watching/status"
        params = {}
        if include:
            params["include"] = include
        return self.get(url, params=params)

    def team_calendar_events(self, sub_calendar_id, start, end, user_time_zone_id=None):
        """
        Get calendar event status
        :param sub_calendar_id:
        :param start:
        :param end:
        :param user_time_zone_id:
        :return:
        """
        url = "rest/calendar-services/1.0/calendar/events"
        params = {}
        if sub_calendar_id:
            params["subCalendarId"] = sub_calendar_id
        if user_time_zone_id:
            params["userTimeZoneId"] = user_time_zone_id
        if start:
            params["start"] = start
        if end:
            params["end"] = end
        return self.get(url, params=params)

    def get_mobile_parameters(self, username):
        """
        Get mobile paramaters
        :param username:
        :return:
        """
        url = f"rest/mobile/1.0/profile/{username}"
        return self.get(url)

    def avatar_upload_for_user(self, user_key, data):
        """

        :param user_key:
        :param data: json like {"avatarDataURI":"image in base64"}
        :return:
        """
        url = f"rest/user-profile/1.0/{user_key}/avatar/upload"
        return self.post(url, data=data)

    def avatar_set_default_for_user(self, user_key):
        """
        :param user_key:
        :return:
        """
        url = f"rest/user-profile/1.0/{user_key}/avatar/default"
        return self.get(url)

    def add_user(self, email, fullname, username, password):
        """
        That method related to creating user via json rpc for Confluence Server
        """
        params = {"email": email, "fullname": fullname, "name": username}
        url = "rpc/json-rpc/confluenceservice-v2"
        data = {
            "jsonrpc": "2.0",
            "method": "addUser",
            "params": [params, password],
        }
        self.post(url, data=data)

    def change_user_password(self, username, password):
        """
        That method related to changing user password via json rpc for Confluence Server
        """
        params = {"name": username}
        url = "rpc/json-rpc/confluenceservice-v2"
        data = {
            "jsonrpc": "2.0",
            "method": "changeUserPassword",
            "params": [params, password],
        }
        self.post(url, data=data)

    def change_my_password(self, oldpass, newpass):
        """
        That method related to changing calling user's own password via json rpc for Confluence Server
        """
        url = "rpc/json-rpc/confluenceservice-v2"
        data = {
            "jsonrpc": "2.0",
            "method": "changeMyPassword",
            "params": [oldpass, newpass],
        }
        self.post(url, data=data)

    def add_user_to_group(self, username, group_name):
        """
        Add given user to a group

        :param username: str - username of user to add to group
        :param group_name: str - name of group to add user to
        :return: Current state of the group
        """
        url = f"rest/api/user/{username}/group/{group_name}"
        return self.put(url)

    def remove_user_from_group(self, username, group_name):
        """
        Remove the given {@link User} identified by username from the given {@link Group} identified by groupName.
        This method is idempotent i.e. if the membership is not present then no action will be taken.

        :param username: str - username of user to add to group
        :param group_name: str - name of group to add user to
        :return: Current state of the group
        """
        url = f"rest/api/user/{username}/group/{group_name}"
        return self.delete(url)

    # Space Permissions
    def get_all_space_permissions(self, space_key):
        """
        Returns list of permissions granted to users and groups in the particular space.
        :param space_key:
        :return:
        """
        url = f"rest/api/space/{space_key}/permissions"
        return self.get(url)

    def set_permissions_to_multiple_items_for_space(self, space_key, user_key=None, group_name=None, operations=None):
        """
        Sets permissions to multiple users/groups in the given space.
        Request should contain all permissions that user/group/anonymous user will have in a given space.
        If permission is absent in the request, but was granted before, it will be revoked.
        If empty list of permissions passed to user/group/anonymous user,
        then all their existing permissions will be revoked.
        If user/group/anonymous user not mentioned in the request, their permissions will not be revoked.

        Maximum 40 different users/groups/anonymous user could be passed in the request.
        :param space_key:
        :param user_key:
        :param group_name:
        :param operations:
        :return:
        """
        url = f"rest/api/space/{space_key}/permissions"
        params = []

        if user_key:
            params.append({"userKey": user_key, "operations": operations or []})

        if group_name:
            params.append({"groupName": group_name, "operations": operations or []})

        if not user_key and not group_name:
            params.append({"operations": operations or []})
        payload_json = json.dumps(params)
        return self.post(url, data=payload_json)

    def get_permissions_granted_to_anonymous_for_space(self, space_key):
        """
        Get permissions granted to anonymous user for the given space
        :param space_key:
        :return:
        """
        url = f"rest/api/space/{space_key}/permissions/anonymous"
        return self.get(url)

    def set_permissions_to_anonymous_for_space(self, space_key, operations=None):
        """
        Grant permissions to anonymous user in the given space. Operation doesn't override existing permissions,
        will only add those one that weren't granted before. Multiple permissions could be passed in one request.
        Supported targetType and operationKey pairs:

        space read
        space administer
        space export
        space restrict
        space delete_own
        space delete_mail
        page create
        page delete
        blogpost create
        blogpost delete
        comment create
        comment delete
        attachment create
        attachment delete
        :param space_key:
        :param operations:
        :return:
        """
        url = f"rest/api/space/{space_key}/permissions/anonymous"
        data = {"operations": operations or []}
        return self.put(url, data=data)

    def remove_permissions_from_anonymous_for_space(self, space_key, operations=None):
        """
        Revoke permissions from anonymous user in the given space.
        If anonymous user doesn't have permissions that we are trying to revoke,
        those permissions will be silently skipped. Multiple permissions could be passed in one request.
        Supported targetType and operationKey pairs:

        space read
        space administer
        space export
        space restrict
        space delete_own
        space delete_mail
        page create
        page delete
        blogpost create
        blogpost delete
        comment create
        comment delete
        attachment create
        attachment delete
        :param space_key:
        :param operations:
        :return:
        """
        url = f"rest/api/space/{space_key}/permissions/anonymous/revoke"
        data = {"operations": operations or []}
        return self.put(url, data=data)

    def get_permissions_granted_to_group_for_space(self, space_key, group_name):
        """
        Get permissions granted to group for the given space
        :param space_key:
        :param group_name:
        :return:
        """
        url = f"rest/api/space/{space_key}/permissions/group/{group_name}"
        return self.get(url)

    def set_permissions_to_group_for_space(self, space_key, group_name, operations=None):
        """
        Grant permissions to group in the given space.
        Operation doesn't override existing permissions, will only add those one that weren't granted before.
        Multiple permissions could be passed in one request. Supported targetType and operationKey pairs:

        space read
        space administer
        space export
        space restrict
        space delete_own
        space delete_mail
        page create
        page delete
        blogpost create
        blogpost delete
        comment create
        comment delete
        attachment create
        attachment delete
        :param space_key:
        :param group_name:
        :param operations:
        :return:
        """
        url = f"rest/api/space/{space_key}/permissions/group/{group_name}"
        data = {"operations": operations or []}
        return self.put(url, data=data)

    def remove_permissions_from_group_for_space(self, space_key, group_name, operations=None):
        """
        Revoke permissions from a group in the given space.
        If group doesn't have permissions that we are trying to revoke,
        those permissions will be silently skipped. Multiple permissions could be passed in one request.
        Supported targetType and operationKey pairs:

        space read
        space administer
        space export
        space restrict
        space delete_own
        space delete_mail
        page create
        page delete
        blogpost create
        blogpost delete
        comment create
        comment delete
        attachment create
        attachment delete
        :param space_key:
        :param group_name:
        :param operations:
        :return:
        """
        url = f"rest/api/space/{space_key}/permissions/group/{group_name}/revoke"
        data = {"operations": operations or []}
        return self.put(url, data=data)

    def get_permissions_granted_to_user_for_space(self, space_key, user_key):
        """
        Get permissions granted to user for the given space
        :param space_key:
        :param user_key:
        :return:
        """
        url = f"rest/api/space/{space_key}/permissions/user/{user_key}"
        return self.get(url)

    def set_permissions_to_user_for_space(self, space_key, user_key, operations=None):
        """
        Grant permissions to user in the given space.
        Operation doesn't override existing permissions, will only add those one that weren't granted before.
        Multiple permissions could be passed in one request. Supported targetType and operationKey pairs:

        space read
        space administer
        space export
        space restrict
        space delete_own
        space delete_mail
        page create
        page delete
        blogpost create
        blogpost delete
        comment create
        comment delete
        attachment create
        attachment delete
        :param space_key:
        :param user_key:
        :param operations:
        :return:
        """
        url = f"rest/api/space/{space_key}/permissions/user/{user_key}"
        data = {"operations": operations or []}
        return self.put(url, data=data)

    def remove_permissions_from_user_for_space(self, space_key, user_key, operations=None):
        """
        Revoke permissions from a user in the given space.
        If user doesn't have permissions that we are trying to revoke,
        those permissions will be silently skipped. Multiple permissions could be passed in one request.
        Supported targetType and operationKey pairs:

        space read
        space administer
        space export
        space restrict
        space delete_own
        space delete_mail
        page create
        page delete
        blogpost create
        blogpost delete
        comment create
        comment delete
        attachment create
        attachment delete
        :param space_key:
        :param user_key:
        :param operations:
        :return:
        """
        url = f"rest/api/space/{space_key}/permissions/user/{user_key}/revoke"
        data = {"operations": operations or []}
        return self.put(url, params=data)

    def add_space_permissions(
        self,
        space_key,
        subject_type,
        subject_id,
        operation_key,
        operation_target,
    ):
        """
        Add permissions to a space

        :param space_key: str - key of space to add permissions to
        :param subject_type: str - type of subject to add permissions for
        :param subject_id: str - id of subject to add permissions for
        :param operation_key: str - key of operation to add permissions for
        :param operation_target: str - target of operation to add permissions for
        :return: Current permissions of space
        """
        url = f"rest/api/space/{space_key}/permission"
        data = {
            "subject": {"type": subject_type, "identifier": subject_id},
            "operation": {"key": operation_key, "target": operation_target},
            "_links": {},
        }

        return self.post(url, data=data, headers=self.experimental_headers)

    def remove_space_permission(self, space_key, user, permission):
        """
        The JSON-RPC APIs for Confluence are provided here to help you browse and discover APIs you have access to.
        JSON-RPC APIs operate differently than REST APIs.
        To learn more about how to use these APIs,
        please refer to the Confluence JSON-RPC documentation on Atlassian Developers.
        """
        if self.api_version == "cloud" or self.cloud:
            return {}
        url = "rpc/json-rpc/confluenceservice-v2"
        data = {
            "jsonrpc": "2.0",
            "method": "removePermissionFromSpace",
            "id": 9,
            "params": [permission, user, space_key],
        }
        return self.post(url, data=data).get("result") or {}

    def get_space_permissions(self, space_key):
        """
        The JSON-RPC APIs for Confluence are provided here to help you browse and discover APIs you have access to.
        JSON-RPC APIs operate differently than REST APIs.
        To learn more about how to use these APIs,
        please refer to the Confluence JSON-RPC documentation on Atlassian Developers.
        """
        if self.api_version == "cloud" or self.cloud:
            return self.get_space(space_key=space_key, expand="permissions")
        url = "rpc/json-rpc/confluenceservice-v2"
        data = {
            "jsonrpc": "2.0",
            "method": "getSpacePermissionSets",
            "id": 7,
            "params": [space_key],
        }
        return self.post(url, data=data).get("result") or {}

    def get_subtree_of_content_ids(self, page_id):
        """
        Get subtree of page ids
        :param page_id:
        :return: Set of page ID
        """
        output = list()
        output.append(page_id)
        children_pages = self.get_page_child_by_type(page_id)
        for page in children_pages:
            child_subtree = self.get_subtree_of_content_ids(page.get("id"))
            if child_subtree:
                output.extend([p for p in child_subtree])
        return set(output)

    def set_inline_tasks_checkbox(self, page_id, task_id, status):
        """
        Set inline task element value
        status is CHECKED or UNCHECKED
        :return:
        """
        url = f"rest/inlinetasks/1/task/{page_id}/{task_id}/"
        data = {"status": status, "trigger": "VIEW_PAGE"}
        return self.post(url, json=data)

    def get_jira_metadata(self, page_id):
        """
        Get linked Jira ticket metadata
        PRIVATE method
        :param page_id: Page Id
        :return:
        """
        url = "rest/jira-metadata/1.0/metadata"
        params = {"pageId": page_id}
        return self.get(url, params=params)

    def get_jira_metadata_aggregated(self, page_id):
        """
        Get linked Jira ticket aggregated metadata
        PRIVATE method
        :param page_id: Page Id
        :return:
        """
        url = "rest/jira-metadata/1.0/metadata/aggregate"
        params = {"pageId": page_id}
        return self.get(url, params=params)

    def clean_jira_metadata_cache(self, global_id):
        """
        Clean cache for linked Jira app link
        PRIVATE method
        :param global_id: ID of Jira app link
        :return:
        """
        url = "rest/jira-metadata/1.0/metadata/cache"
        params = {"globalId": global_id}
        return self.delete(url, params=params)

    # Collaborative editing
    def collaborative_editing_get_configuration(self):
        """
        Get collaborative editing configuration
        Related to the on-prem setup Confluence Data Center
        :return:
        """
        if self.cloud:
            return ApiNotAcceptable
        url = "rest/synchrony-interop/configuration"
        return self.get(url, headers=self.no_check_headers)

    def collaborative_editing_disable(self):
        """
        Disable collaborative editing
        Related to the on-prem setup Confluence Data Center
        :return:
        """
        if self.cloud:
            return ApiNotAcceptable
        url = "rest/synchrony-interop/disable"
        return self.post(url, headers=self.no_check_headers)

    def collaborative_editing_enable(self):
        """
        Disable collaborative editing
        Related to the on-prem setup Confluence Data Center
        :return:
        """
        if self.cloud:
            return ApiNotAcceptable
        url = "rest/synchrony-interop/enable"
        return self.post(url, headers=self.no_check_headers)

    def collaborative_editing_restart(self):
        """
        Disable collaborative editing
        Related to the on-prem setup Confluence Data Center
        :return:
        """
        if self.cloud:
            return ApiNotAcceptable
        url = "rest/synchrony-interop/restart"
        return self.post(url, headers=self.no_check_headers)

    def collaborative_editing_shared_draft_status(self):
        """
        Status of collaborative editing
        Related to the on-prem setup Confluence Data Center
        :return: false or true parameter in json
                {
                     "sharedDraftsEnabled": false
                }
        """
        if self.cloud:
            return ApiNotAcceptable
        url = "rest/synchrony-interop/status"
        return self.get(url, headers=self.no_check_headers)

    def collaborative_editing_synchrony_status(self):
        """
        Status of collaborative editing
        Related to the on-prem setup Confluence Data Center
        :return: stopped or running parameter in json
            {
                "status": "stopped"
            }
        """
        if self.cloud:
            return ApiNotAcceptable
        url = "rest/synchrony-interop/synchrony-status"
        return self.get(url, headers=self.no_check_headers)

    def synchrony_get_configuration(self):
        """
        Status of collaborative editing
        Related to the on-prem setup Confluence Data Center
        :return:
        """
        if self.cloud:
            return ApiNotAcceptable
        url = "rest/synchrony/1.0/config/status"
        return self.get(url, headers=self.no_check_headers)

    def synchrony_remove_draft(self, page_id):
        """
        Status of collaborative editing
        Related to the on-prem setup Confluence Data Center
        :return:
        """
        if self.cloud:
            return ApiNotAcceptable
        url = f"rest/synchrony/1.0/content/{page_id}/changes/unpublished"
        return self.delete(url)

    def get_license_details(self):
        """
        Returns the license detailed information
        """
        url = "rest/license/1.0/license/details"
        return self.get(url)

    def get_license_user_count(self):
        """
        Returns the total used seats in the license
        """
        url = "rest/license/1.0/license/userCount"
        return self.get(url)

    def get_license_remaining(self):
        """
        Returns the available license seats remaining
        """
        url = "rest/license/1.0/license/remainingSeats"
        return self.get(url)

    def get_license_max_users(self):
        """
        Returns the license max users
        """
        url = "rest/license/1.0/license/maxUsers"
        return self.get(url)

    def raise_for_status(self, response):
        """
        Checks the response for an error status and raises an exception with the error message provided by the server
        :param response:
        :return:
        """
        if response.status_code == 401 and response.headers.get("Content-Type") != "application/json;charset=UTF-8":
            raise HTTPError("Unauthorized (401)", response=response)

        if 400 <= response.status_code < 600:
            try:
                j = response.json()
                error_msg = j["message"]
            except Exception as e:
                log.error(e)
                response.raise_for_status()
            else:
                raise HTTPError(error_msg, response=response)