ail-framework/bin/lib/ail_updates.py

#!/usr/bin/env python3
# -*-coding:UTF-8 -*

import datetime
import os
import sys

sys.path.append(os.environ['AIL_BIN'])
##################################
# Import Project packages
##################################
from lib.ConfigLoader import ConfigLoader

config_loader = ConfigLoader()
r_db = config_loader.get_db_conn("Kvrocks_DB")
config_loader = None

# # # # # # # #
#             #
#   UPDATE    #
#             #
# # # # # # # #

def get_ail_version():
    return r_db.get('ail:version')

def get_ail_float_version():
    version = get_ail_version()
    if version:
        version = float(version[1:])
    else:
        version = 0
    return version

# # # - - # # #

# # # # # # # # # # # #
#                     #
#  UPDATE BACKGROUND  #
#                     #
# # # # # # # # # # # #


BACKGROUND_UPDATES = {
    'v5.2': {
        'message': 'Compress HAR',
        'scripts': ['compress_har.py']
    },
}

class AILBackgroundUpdate:
    """
        AIL Background Update.
    """

    def __init__(self, version):
        self.version = version

    def _get_field(self, field):
        return r_db.hget('ail:update:background', field)

    def _set_field(self, field, value):
        r_db.hset('ail:update:background', field, value)

    def get_version(self):
        return self.version

    def get_message(self):
        return BACKGROUND_UPDATES.get(self.version, {}).get('message', '')

    def get_error(self):
        return self._get_field('error')

    def set_error(self, error):  # TODO ADD LOGS
        self._set_field('error', error)

    def get_nb_scripts(self):
        return int(len(BACKGROUND_UPDATES.get(self.version, {}).get('scripts', [''])))

    def get_scripts(self):
        return BACKGROUND_UPDATES.get(self.version, {}).get('scripts', [])

    def get_nb_scripts_done(self):
        done = self._get_field('done')
        try:
            done = int(done)
        except (TypeError, ValueError):
            done = 0
        return done

    def inc_nb_scripts_done(self):
        self._set_field('done', self.get_nb_scripts_done() + 1)

    def get_script(self):
        return self._get_field('script')

    def get_script_path(self):
        path = os.path.basename(self.get_script())
        if path:
            return os.path.join(os.environ['AIL_HOME'], 'update', self.version, path)

    def get_nb_to_update(self):  # TODO use cache ?????
        nb_to_update = self._get_field('nb_to_update')
        if not nb_to_update:
            nb_to_update = 1
        return int(nb_to_update)

    def set_nb_to_update(self, nb):
        self._set_field('nb_to_update', int(nb))

    def get_nb_updated(self):  # TODO use cache ?????
        nb_updated = self._get_field('nb_updated')
        if not nb_updated:
            nb_updated = 0
        return int(nb_updated)

    def inc_nb_updated(self):  # TODO use cache ?????
        r_db.hincrby('ail:update:background', 'nb_updated', 1)

    def get_progress(self):  # TODO use cache ?????
        return self._get_field('progress')

    def set_progress(self, progress):
        self._set_field('progress', progress)

    def update_progress(self):
        nb_updated = self.get_nb_updated()
        nb_to_update = self.get_nb_to_update()
        if nb_updated == nb_to_update:
            progress = 100
        elif nb_updated > nb_to_update:
            progress = 99
        else:
            progress = int((nb_updated * 100) / nb_to_update)
        self.set_progress(progress)
        print(f'{nb_updated}/{nb_to_update}    updated    {progress}%')
        return progress

    def is_running(self):
        return r_db.hget('ail:update:background', 'version') == self.version

    def get_meta(self, options=set()):
        meta = {'version': self.get_version(),
                'error': self.get_error(),
                'script': self.get_script(),
                'script_progress': self.get_progress(),
                'nb_update': self.get_nb_scripts(),
                'nb_completed': self.get_nb_scripts_done()}
        meta['progress'] = int(meta['nb_completed'] * 100 / meta['nb_update'])
        if 'message' in options:
            meta['message'] = self.get_message()
        return meta

    def start(self):
        self._set_field('version', self.version)
        r_db.hdel('ail:update:background', 'error')

    def start_script(self, script):
        self.clear()
        self._set_field('script', script)
        self.set_progress(0)

    def end_script(self):
        self.set_progress(100)
        self.inc_nb_scripts_done()

    def clear(self):
        r_db.hdel('ail:update:background', 'error')
        r_db.hdel('ail:update:background', 'progress')
        r_db.hdel('ail:update:background', 'nb_updated')
        r_db.hdel('ail:update:background', 'nb_to_update')

    def end(self):
        r_db.delete('ail:update:background')
        r_db.srem('ail:updates:background', self.version)


# To Add in update script
def add_background_update(version):
    r_db.sadd('ail:updates:background', version)

def is_update_background_running():
    return r_db.exists('ail:update:background')

def get_update_background_version():
    return r_db.hget('ail:update:background', 'version')

def get_update_background_meta(options=set()):
    version = get_update_background_version()
    if version:
        return AILBackgroundUpdate(version).get_meta(options=options)
    else:
        return {}

def get_update_background_to_launch():
    to_launch = []
    updates = r_db.smembers('ail:updates:background')
    for version in BACKGROUND_UPDATES:
        if version in updates:
            to_launch.append(version)
    return to_launch

# # # - - # # #

##########################################################################################
##########################################################################################
##########################################################################################

def get_ail_all_updates(date_separator='-'):
    dict_update = r_db.hgetall('ail:update_date')
    if date_separator:
        for version in dict_update:
            u_date = dict_update[version]
            dict_update[version] = f'{u_date[0:4]}{date_separator}{u_date[4:6]}{date_separator}{u_date[6:8]}'
    return dict_update


def add_ail_update(version):
    # Add new AIL version
    r_db.hset('ail:update_date', version, datetime.datetime.now().strftime("%Y%m%d"))
    # Set current ail version
    if float(version[1:]) > get_ail_float_version():
        r_db.set('ail:version', version)


def check_version(version):
    if version[0] != 'v':
        return False
    try:
        int(version[1])
        int(version[-1])
        int(version[1:].replace('.', ''))
    except:
        return False
    if '..' in version:
        return False
    return True


if __name__ == '__main__':
    res = check_version('v3.1..1')
    print(res)