clear_cache.py

# Import API Service
# Copyright (C) 2020-2021 Memobase Project
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU Affero General Public License for more details.
#
# You should have received a copy of the GNU Affero General Public License
# along with this program.  If not, see <https://www.gnu.org/licenses/>.
from flask_restful import Resource, current_app
import requests
import traceback

from requests.auth import HTTPBasicAuth


class ClearCache(Resource):

    def __init__(self):
        self.logger = current_app.logger
        self.headers = {
            'X-API-Key': current_app.config['drupal-api-key']
        }
        user = current_app.config['drupal-user']
        password = current_app.config['drupal-password']
        self.auth = HTTPBasicAuth(user, password)
        self.url = current_app.config['drupal-api-url'] + current_app.config['clear-cache-url']

    def get(self):
        """
        Tell drupal to clear the import-process-cache
        ---
        tags:
          - clear drupal cache
        responses:
          200:
            description: Success, the call to drupal could be executed
          500:
            description: Failure tha call to drupal could neo be executed
        """

        try:
            response = requests.get(self.url, headers=self.headers, auth=self.auth)
        except Exception as ex:
            msg = 'Exception while calling ' + self.url + ': ' + str(ex) + '\n' + \
                  traceback.format_exc()
            self.logger.error(msg)
            return {
                       'response': msg,
                   }, 500
        if response.ok:
            self.logger.debug('successfully called ' + self.url)
            return {
                       'content': response.content.decode("utf-8"),
                   }, response.status_code
        else:
            self.logger.error('Clearing Cache Failed')
            self.logger.error('statuscode: ' + str(response.status_code) + ' content: ' +
                              response.content.decode('utf-8'))
            return {
                       'content': response.content.decode("utf-8"),
                   }, response.status_code