Added feature-flags
This commit is contained in:
parent
a8b6989d27
commit
ac238b360a
@ -17,6 +17,14 @@
|
|||||||
"de"
|
"de"
|
||||||
]
|
]
|
||||||
},
|
},
|
||||||
|
"FeatureFlag": {
|
||||||
|
"AdminModule": true,
|
||||||
|
"BaseModule": true,
|
||||||
|
"BootLogModule": true,
|
||||||
|
"DatabaseModule": true,
|
||||||
|
"ModeratorModule": true,
|
||||||
|
"PermissionModule": true
|
||||||
|
},
|
||||||
"DiscordBot": {
|
"DiscordBot": {
|
||||||
"Token": "OTk4MTU5NjczODkzMDYwNzM4.GN3QyA.yvWO6L7Eu36gXQ7ARDs0Jg2J1VqIDnHLou5lT4",
|
"Token": "OTk4MTU5NjczODkzMDYwNzM4.GN3QyA.yvWO6L7Eu36gXQ7ARDs0Jg2J1VqIDnHLou5lT4",
|
||||||
"Prefix": "!kd "
|
"Prefix": "!kd "
|
||||||
|
@ -19,6 +19,14 @@
|
|||||||
"Token": "OTk4MTYwNDI3Njg5MTgxMjM3.GI7h67.BqD6Lu1Tz0MuG8iktYrcLnHi1pNozyMiWFGTKI",
|
"Token": "OTk4MTYwNDI3Njg5MTgxMjM3.GI7h67.BqD6Lu1Tz0MuG8iktYrcLnHi1pNozyMiWFGTKI",
|
||||||
"Prefix": "!ke "
|
"Prefix": "!ke "
|
||||||
},
|
},
|
||||||
|
"FeatureFlag": {
|
||||||
|
"AdminModule": true,
|
||||||
|
"BaseModule": true,
|
||||||
|
"BootLogModule": true,
|
||||||
|
"DatabaseModule": true,
|
||||||
|
"ModeratorModule": true,
|
||||||
|
"PermissionModule": true
|
||||||
|
},
|
||||||
"Bot": {
|
"Bot": {
|
||||||
"910199451145076828": {
|
"910199451145076828": {
|
||||||
"MessageDeleteTimer": 2
|
"MessageDeleteTimer": 2
|
||||||
|
@ -28,6 +28,14 @@
|
|||||||
"Buffered": "true",
|
"Buffered": "true",
|
||||||
"AuthPlugin": "mysql_native_password"
|
"AuthPlugin": "mysql_native_password"
|
||||||
},
|
},
|
||||||
|
"FeatureFlag": {
|
||||||
|
"AdminModule": true,
|
||||||
|
"BaseModule": true,
|
||||||
|
"BootLogModule": true,
|
||||||
|
"DatabaseModule": true,
|
||||||
|
"ModeratorModule": true,
|
||||||
|
"PermissionModule": true
|
||||||
|
},
|
||||||
"Bot": {
|
"Bot": {
|
||||||
"650366049023295514": {
|
"650366049023295514": {
|
||||||
"MessageDeleteTimer": 2
|
"MessageDeleteTimer": 2
|
||||||
|
@ -17,6 +17,14 @@
|
|||||||
"de"
|
"de"
|
||||||
]
|
]
|
||||||
},
|
},
|
||||||
|
"FeatureFlag": {
|
||||||
|
"AdminModule": true,
|
||||||
|
"BaseModule": true,
|
||||||
|
"BootLogModule": true,
|
||||||
|
"DatabaseModule": true,
|
||||||
|
"ModeratorModule": true,
|
||||||
|
"PermissionModule": true
|
||||||
|
},
|
||||||
"Bot": {
|
"Bot": {
|
||||||
"910199451145076828": {
|
"910199451145076828": {
|
||||||
"MessageDeleteTimer": 4
|
"MessageDeleteTimer": 4
|
||||||
|
@ -10,6 +10,7 @@ from cpl_core.environment import ApplicationEnvironment
|
|||||||
|
|
||||||
from bot_core.abc.client_utils_service_abc import ClientUtilsServiceABC
|
from bot_core.abc.client_utils_service_abc import ClientUtilsServiceABC
|
||||||
from bot_core.abc.message_service_abc import MessageServiceABC
|
from bot_core.abc.message_service_abc import MessageServiceABC
|
||||||
|
from bot_core.configuration.feature_flags_settings import FeatureFlagsSettings
|
||||||
from bot_core.pipes.date_time_offset_pipe import DateTimeOffsetPipe
|
from bot_core.pipes.date_time_offset_pipe import DateTimeOffsetPipe
|
||||||
from bot_core.service.client_utils_service import ClientUtilsService
|
from bot_core.service.client_utils_service import ClientUtilsService
|
||||||
from bot_core.service.message_service import MessageService
|
from bot_core.service.message_service import MessageService
|
||||||
@ -39,6 +40,7 @@ class Startup(StartupABC):
|
|||||||
self._start_time = datetime.now()
|
self._start_time = datetime.now()
|
||||||
|
|
||||||
self._config: Optional[ConfigurationABC] = None
|
self._config: Optional[ConfigurationABC] = None
|
||||||
|
self._feature_flags: Optional[FeatureFlagsSettings] = None
|
||||||
|
|
||||||
def configure_configuration(self, configuration: ConfigurationABC, environment: ApplicationEnvironment) -> ConfigurationABC:
|
def configure_configuration(self, configuration: ConfigurationABC, environment: ApplicationEnvironment) -> ConfigurationABC:
|
||||||
environment.set_working_directory(os.path.dirname(os.path.realpath(__file__)))
|
environment.set_working_directory(os.path.dirname(os.path.realpath(__file__)))
|
||||||
@ -52,6 +54,7 @@ class Startup(StartupABC):
|
|||||||
configuration.add_configuration('Startup_StartTime', str(self._start_time))
|
configuration.add_configuration('Startup_StartTime', str(self._start_time))
|
||||||
|
|
||||||
self._config = configuration
|
self._config = configuration
|
||||||
|
self._feature_flags = configuration.get_configuration(FeatureFlagsSettings)
|
||||||
return configuration
|
return configuration
|
||||||
|
|
||||||
def configure_services(self, services: ServiceCollectionABC, environment: ApplicationEnvironment) -> ServiceProviderABC:
|
def configure_services(self, services: ServiceCollectionABC, environment: ApplicationEnvironment) -> ServiceProviderABC:
|
||||||
@ -61,6 +64,7 @@ class Startup(StartupABC):
|
|||||||
services.add_db_context(DBContext, self._config.get_configuration(DatabaseSettings))
|
services.add_db_context(DBContext, self._config.get_configuration(DatabaseSettings))
|
||||||
|
|
||||||
# general services
|
# general services
|
||||||
|
if self._feature_flags.base_module:
|
||||||
services.add_transient(BaseHelperABC, BaseHelperService)
|
services.add_transient(BaseHelperABC, BaseHelperService)
|
||||||
services.add_transient(MessageServiceABC, MessageService)
|
services.add_transient(MessageServiceABC, MessageService)
|
||||||
services.add_transient(ClientUtilsServiceABC, ClientUtilsService)
|
services.add_transient(ClientUtilsServiceABC, ClientUtilsService)
|
||||||
@ -69,6 +73,7 @@ class Startup(StartupABC):
|
|||||||
services.add_transient(DateTimeOffsetPipe)
|
services.add_transient(DateTimeOffsetPipe)
|
||||||
|
|
||||||
# module services
|
# module services
|
||||||
|
if self._feature_flags.permission_module:
|
||||||
services.add_singleton(PermissionServiceABC, PermissionService)
|
services.add_singleton(PermissionServiceABC, PermissionService)
|
||||||
|
|
||||||
# data services
|
# data services
|
||||||
|
@ -1,3 +1,5 @@
|
|||||||
|
from typing import Optional
|
||||||
|
|
||||||
from cpl_core.application import StartupExtensionABC
|
from cpl_core.application import StartupExtensionABC
|
||||||
from cpl_core.configuration import ConfigurationABC
|
from cpl_core.configuration import ConfigurationABC
|
||||||
from cpl_core.dependency_injection import ServiceCollectionABC
|
from cpl_core.dependency_injection import ServiceCollectionABC
|
||||||
@ -5,6 +7,7 @@ from cpl_core.environment import ApplicationEnvironmentABC
|
|||||||
from cpl_discord import get_discord_collection
|
from cpl_discord import get_discord_collection
|
||||||
from cpl_discord.discord_event_types_enum import DiscordEventTypesEnum
|
from cpl_discord.discord_event_types_enum import DiscordEventTypesEnum
|
||||||
|
|
||||||
|
from bot_core.configuration.feature_flags_settings import FeatureFlagsSettings
|
||||||
from modules.admin.command.restart_command import RestartCommand
|
from modules.admin.command.restart_command import RestartCommand
|
||||||
from modules.admin.command.shutdown_command import ShutdownCommand
|
from modules.admin.command.shutdown_command import ShutdownCommand
|
||||||
from modules.base.command.afk_command import AFKCommand
|
from modules.base.command.afk_command import AFKCommand
|
||||||
@ -27,21 +30,24 @@ from modules.permission.events.permission_on_ready_event import PermissionOnRead
|
|||||||
class StartupDiscordExtension(StartupExtensionABC):
|
class StartupDiscordExtension(StartupExtensionABC):
|
||||||
|
|
||||||
def __init__(self):
|
def __init__(self):
|
||||||
pass
|
self._feature_flags: Optional[FeatureFlagsSettings] = None
|
||||||
|
|
||||||
def configure_configuration(self, config: ConfigurationABC, env: ApplicationEnvironmentABC):
|
def configure_configuration(self, config: ConfigurationABC, env: ApplicationEnvironmentABC):
|
||||||
pass
|
self._feature_flags = config.get_configuration(FeatureFlagsSettings)
|
||||||
|
|
||||||
def configure_services(self, services: ServiceCollectionABC, env: ApplicationEnvironmentABC):
|
def configure_services(self, services: ServiceCollectionABC, env: ApplicationEnvironmentABC):
|
||||||
services.add_discord()
|
services.add_discord()
|
||||||
dc = get_discord_collection(services)
|
dc = get_discord_collection(services)
|
||||||
""" commands """
|
""" commands """
|
||||||
# admin
|
# admin
|
||||||
|
if self._feature_flags.admin_module:
|
||||||
dc.add_command(RestartCommand)
|
dc.add_command(RestartCommand)
|
||||||
dc.add_command(ShutdownCommand)
|
dc.add_command(ShutdownCommand)
|
||||||
# moderator
|
# moderator
|
||||||
|
if self._feature_flags.moderator_module:
|
||||||
dc.add_command(PurgeCommand)
|
dc.add_command(PurgeCommand)
|
||||||
# simple
|
# simple
|
||||||
|
if self._feature_flags.base_module:
|
||||||
dc.add_command(AFKCommand)
|
dc.add_command(AFKCommand)
|
||||||
dc.add_command(HelpCommand)
|
dc.add_command(HelpCommand)
|
||||||
dc.add_command(InfoCommand)
|
dc.add_command(InfoCommand)
|
||||||
@ -49,18 +55,27 @@ class StartupDiscordExtension(StartupExtensionABC):
|
|||||||
dc.add_command(UserInfoCommand)
|
dc.add_command(UserInfoCommand)
|
||||||
""" events """
|
""" events """
|
||||||
# on_command_error
|
# on_command_error
|
||||||
|
if self._feature_flags.base_module:
|
||||||
dc.add_event(DiscordEventTypesEnum.on_command_error.value, BaseOnCommandErrorEvent)
|
dc.add_event(DiscordEventTypesEnum.on_command_error.value, BaseOnCommandErrorEvent)
|
||||||
# on_member_join
|
# on_member_join
|
||||||
|
if self._feature_flags.base_module:
|
||||||
dc.add_event(DiscordEventTypesEnum.on_member_join.value, BaseOnMemberJoinEvent)
|
dc.add_event(DiscordEventTypesEnum.on_member_join.value, BaseOnMemberJoinEvent)
|
||||||
# on_member_remove
|
# on_member_remove
|
||||||
|
if self._feature_flags.base_module:
|
||||||
dc.add_event(DiscordEventTypesEnum.on_member_join.value, BaseOnMemberRemoveEvent)
|
dc.add_event(DiscordEventTypesEnum.on_member_join.value, BaseOnMemberRemoveEvent)
|
||||||
# on_member_update
|
# on_member_update
|
||||||
|
if self._feature_flags.permission_module:
|
||||||
dc.add_event(DiscordEventTypesEnum.on_member_update.value, PermissionOnMemberUpdateEvent)
|
dc.add_event(DiscordEventTypesEnum.on_member_update.value, PermissionOnMemberUpdateEvent)
|
||||||
# on_message
|
# on_message
|
||||||
|
if self._feature_flags.base_module:
|
||||||
dc.add_event(DiscordEventTypesEnum.on_message.value, BaseOnMessageEvent)
|
dc.add_event(DiscordEventTypesEnum.on_message.value, BaseOnMessageEvent)
|
||||||
# on_voice_state_update
|
# on_voice_state_update
|
||||||
|
if self._feature_flags.base_module:
|
||||||
dc.add_event(DiscordEventTypesEnum.on_voice_state_update.value, BaseOnVoiceStateUpdateEvent)
|
dc.add_event(DiscordEventTypesEnum.on_voice_state_update.value, BaseOnVoiceStateUpdateEvent)
|
||||||
# on_ready
|
# on_ready
|
||||||
|
if self._feature_flags.database_module:
|
||||||
dc.add_event(DiscordEventTypesEnum.on_ready.value, DatabaseOnReadyEvent)
|
dc.add_event(DiscordEventTypesEnum.on_ready.value, DatabaseOnReadyEvent)
|
||||||
|
if self._feature_flags.permission_module:
|
||||||
dc.add_event(DiscordEventTypesEnum.on_ready.value, PermissionOnReadyEvent)
|
dc.add_event(DiscordEventTypesEnum.on_ready.value, PermissionOnReadyEvent)
|
||||||
|
if self._feature_flags.boot_log_module:
|
||||||
dc.add_event(DiscordEventTypesEnum.on_ready.value, BootLogOnReadyEvent) # has to be last
|
dc.add_event(DiscordEventTypesEnum.on_ready.value, BootLogOnReadyEvent) # has to be last
|
||||||
|
65
src/bot_core/configuration/feature_flags_settings.py
Normal file
65
src/bot_core/configuration/feature_flags_settings.py
Normal file
@ -0,0 +1,65 @@
|
|||||||
|
import traceback
|
||||||
|
from typing import Optional
|
||||||
|
|
||||||
|
from cpl_core.configuration.configuration_model_abc import ConfigurationModelABC
|
||||||
|
from cpl_core.console import Console
|
||||||
|
|
||||||
|
|
||||||
|
class FeatureFlagsSettings(ConfigurationModelABC):
|
||||||
|
|
||||||
|
def __init__(self):
|
||||||
|
ConfigurationModelABC.__init__(self)
|
||||||
|
|
||||||
|
self._admin_module = False # 02.10.2022 #48
|
||||||
|
self._base_module = True # 02.10.2022 #48
|
||||||
|
self._boot_log_module = True # 02.10.2022 #48
|
||||||
|
self._database_module = True # 02.10.2022 #48
|
||||||
|
self._moderator_module = False # 02.10.2022 #48
|
||||||
|
self._permission_module = True # 02.10.2022 #48
|
||||||
|
|
||||||
|
@property
|
||||||
|
def admin_module(self) -> bool:
|
||||||
|
return self._admin_module
|
||||||
|
|
||||||
|
@property
|
||||||
|
def base_module(self) -> bool:
|
||||||
|
return self._base_module
|
||||||
|
|
||||||
|
@property
|
||||||
|
def boot_log_module(self) -> bool:
|
||||||
|
return self._boot_log_module
|
||||||
|
|
||||||
|
@property
|
||||||
|
def database_module(self) -> bool:
|
||||||
|
return self._database_module
|
||||||
|
|
||||||
|
@property
|
||||||
|
def moderator_module(self) -> bool:
|
||||||
|
return self._moderator_module
|
||||||
|
|
||||||
|
@property
|
||||||
|
def permission_module(self) -> bool:
|
||||||
|
return self._permission_module
|
||||||
|
|
||||||
|
def from_dict(self, settings: dict):
|
||||||
|
try:
|
||||||
|
if 'AdminModule' in settings:
|
||||||
|
self._admin_module = settings['AdminModule']
|
||||||
|
|
||||||
|
if 'BaseModule' in settings:
|
||||||
|
self._base_module = settings['BaseModule']
|
||||||
|
|
||||||
|
if 'BootLogModule' in settings:
|
||||||
|
self._boot_log_module = settings['BootLogModule']
|
||||||
|
|
||||||
|
if 'DatabaseModule' in settings:
|
||||||
|
self._database_module = settings['DatabaseModule']
|
||||||
|
|
||||||
|
if 'ModeratorModule' in settings:
|
||||||
|
self._moderator_module = settings['ModeratorModule']
|
||||||
|
|
||||||
|
if 'PermissionModule' in settings:
|
||||||
|
self._permission_module = settings['PermissionModule']
|
||||||
|
except Exception as e:
|
||||||
|
Console.error(f'[ ERROR ] [ {__name__} ]: Reading error in {type(self).__name__} settings')
|
||||||
|
Console.error(f'[ EXCEPTION ] [ {__name__} ]: {e} -> {traceback.format_exc()}')
|
Loading…
Reference in New Issue
Block a user