Compare commits

...

4 Commits

Author SHA1 Message Date
980da5a085 remove ducjdb extension from postgres 2025-02-18 18:39:50 +03:00
3bcec2abff updated account info gathering 2025-02-13 16:41:15 +03:00
533fe1f84e RedisValidation updated 2025-02-12 15:59:38 +03:00
24eb6519f2 RedisValidation updated 2025-02-12 15:59:36 +03:00
22 changed files with 563 additions and 238 deletions

View File

@@ -83,18 +83,14 @@ class RedisCategoryPageInfoKeysAction:
page_index: str = (
f"{RedisCategoryPageInfoKeys.PAGE_MENU_INDEX}:{RedisCategoryPageInfoKeys.PAGE_URL}"
)
page_mapper_key: str = (
f"{RedisCategoryPageInfoKeys.PAGE_MENU_INDEX}:{RedisCategoryPageInfoKeys.PAGE_URL}"
)
page_mapper_key: str = (
f"{page_mapper_key}:{RedisCategoryPageInfoKeys.PAGE_LANGUAGE}"
page_mapper_key_language: str = (
f"{RedisCategoryPageInfoKeys.PAGE_MENU_INDEX}:{RedisCategoryPageInfoKeys.PAGE_LANGUAGE}"
)
menu_mapper_key: str = (
f"{RedisCategoryPageInfoKeys.PAGE_URL}:{RedisCategoryPageInfoKeys.PAGE_MENU_INDEX}"
)
menu_mapper_key: str = (
f"{menu_mapper_key}:{RedisCategoryPageInfoKeys.PAGE_MENU_COMPONENT}"
menu_mapper_key_component: str = (
f"{RedisCategoryPageInfoKeys.PAGE_URL}:{RedisCategoryPageInfoKeys.PAGE_MENU_COMPONENT}"
)

View File

View File

@@ -0,0 +1,36 @@
class AccountLanguageModels:
account_language_update_models = {
"en": {
"page": "Update Account Records",
},
"tr": {
"page": "Hesap Kayıdı Güncelle",
},
}
account_language_created_models = {
"en": {
"page": "Create Account Records",
},
"tr": {
"page": "Hesap Kayıdı Oluştur",
},
}
account_language_list_models = {
"en": {
"page": "List Account Records",
},
"tr": {
"page": "Hesap Kaytlarını Listele",
},
}
account_language_create_form_models = {
"en": {"page": "Create Account Records", "button": "Create"},
"tr": {"page": "Hesap Kayıdı Oluştur", "button": "Oluştur"},
},
account_language_update_form_models = {
"en": {"page": "Update Account Records", "button:": "Update"},
"tr": {"page": "Hesap Kayıdı Güncelle", "button:": "Güncelle"},
},

View File

@@ -32,7 +32,7 @@ def setup_cors_middleware(app: FastAPI) -> None:
"""
app.add_middleware(
CORSMiddleware,
allow_origins=["*"],
allow_origins=["http://localhost:3000","*"],
allow_credentials=True,
allow_methods=["*"],
allow_headers=["*"],

View File

@@ -48,7 +48,7 @@ class ApiConfig(DefaultApiConfig):
# Server Configuration
app = "app:app"
host = "0.0.0.0"
port = 41575
port = 8888
log_level = "info"
reload = True

View File

@@ -27,7 +27,7 @@ def setup_cors_middleware(app: FastAPI) -> None:
"""
app.add_middleware(
CORSMiddleware,
allow_origins=["*"],
allow_origins=["http://localhost:3000","*"],
allow_credentials=True,
allow_methods=["*"],
allow_headers=["*"],

View File

@@ -43,7 +43,7 @@ class ApiConfig(DefaultApiConfig):
# Uvicorn server configuration
app = "app:app"
host = "0.0.0.0"
port = 41576
port = 8888
log_level = "info"
reload = True

View File

@@ -27,7 +27,7 @@ def setup_cors_middleware(app: FastAPI) -> None:
"""
app.add_middleware(
CORSMiddleware,
allow_origins=["*"],
allow_origins=["http://localhost:3000","*"],
allow_credentials=True,
allow_methods=["*"],
allow_headers=["*"],

View File

@@ -42,7 +42,7 @@ class ApiConfig(DefaultApiConfig):
# App configuration
app = "app:app"
host = "0.0.0.0"
port = 41577
port = 8888
log_level = "info"
reload = True

View File

@@ -4,8 +4,10 @@ from Events.Engine.abstract_class import PageInfo
authentication_page_info = PageInfo(
name="Authentication",
url="",
language_models={},
endpoints={},
icon="Authentication",
language_models=None,
endpoints=None,
info=None,
instructions=None,
sub_components=[],
)

View File

@@ -1,3 +1,4 @@
from typing import Any, Dict, Optional
from Events.Engine.abstract_class import DefaultClusterName
@@ -5,6 +6,17 @@ cluster_name = "AccountCluster"
prefix = "/accounts"
icon = "Building"
# Icons
class Icons:
PENCIL = "Pencil"
PLUS = "Plus"
TABLE = "Table"
# Components
class Components:
TABLE = "Table"
FORM = "Form"
LINK = "Link"
# Keys for the cluster
class KeyValidations:
@@ -12,10 +24,41 @@ class KeyValidations:
data = "data"
validation = "validations"
# Keys for Validation TYPES
class KeyTypeValidations:
HEADERS = "HEADERS"
DATA = "DATA"
MODIFY = "MODIFY"
VALIDATION = "VALIDATION"
BOTH = "BOTH"
# Types of keys
class KeyTypes:
REQUEST = "REQUEST"
RESPONSE = "RESPONSE"
BOTH = "BOTH"
# Key URLS for the cluster
class KeyURLs:
validations = "/validations/validations"
# "data": {"event_code": f"{KeyBases.list_key}", "asked_field": KeyValidations.headers, "type": KeyTypes.RESPONSE},
class ValidationRequest:
def __init__(self, event_code: str, asked_field: str, type_: Optional[str] = "REQUEST"):
self.event_code = event_code
self.asked_field = asked_field
self.type = type_
def dump(self) -> Dict[str, Any]:
return {
"event_code": self.event_code,
"asked_field": self.asked_field,
"type": self.type,
}
# Keys for the cluster
class KeyBases:
create_key = f"{prefix}/create"

View File

@@ -21,6 +21,7 @@ AccountCluster = CategoryCluster(
},
mapping=page_2_keys,
include_in_schema=True,
template_ui="LCU",
sub_category=[],
is_client=True,
)

View File

@@ -1,27 +1,96 @@
from Events.Engine.abstract_class import PageInfo
from .bases import KeyValidations, cluster_name, KeyBases, PageBases, icon, KeyURLs
from Events.base_request_model import AUTH_URL_EXTENSION, EVENTS_URL_EXTENSION, VALID_URL_EXTENSION
from .account_records import (
AccountRecordsUpdateEventMethods,
AccountRecordsCreateEventMethods,
AccountRecordsListEventMethods,
)
from .bases import Components, KeyTypeValidations, KeyTypes, ValidationRequest, icon, cluster_name
from .bases import KeyValidations, KeyBases, PageBases, KeyURLs
from .lang_models import (
account_language_create_models_as_dict,
account_language_model_as_dict,
account_language_list_models_as_dict,
account_language_created_models_as_dict,
account_language_create_form_models_as_dict,
account_language_update_form_models_as_dict,
account_language_create_link_models_as_dict,
account_language_update_link_models_as_dict,
)
RedisValidation = dict(
NAME="AccountCluster",
PREFIX="/accounts",
URL="/dashboard?site=AccountCluster",
ICON="Building",
INFO={
"en": {
"page": "Account Records for reaching user all types account information",
},
"tr": {
"page": "Kullanıcı tüm hesap bilgilerine ulaşmak için Hesap Kayıtları",
},
},
SUB_COMPONENTS={
"/accounts/create": {
"SITE_URL": "/events/create?site=AccountCluster",
"COMPONENT": "Link",
"PREFIX_URL": "/accounts/create",
"INFO": {
"en": {
"page": "Create Account Records",
"actions": "Actions",
"table": "Table",
},
"tr": {
"page": "Hesap Kayıdı Oluştur",
"actions": "Aksiyonlar",
"table": "Tablo",
},
},
"INSTRUCTIONS": None,
},
"/accounts/list": {
"SITE_URL": "/events/dashboard?site=AccountCluster",
"COMPONENT": "Table",
"PREFIX_URL": "/accounts/list",
"INFO": {
"en": { "page": "List Account Records" },
"tr": { "page": "Hesap Kayıtlarını Listele" },
},
"INSTRUCTIONS": {
"headers": {
"store": True,
"url": "/validations/header",
"data": {
"event_code": "/accounts/list",
"asked_field": "headers",
},
},
"data": {
"store": True,
"url": "/accounts/list",
"data": {
"page": 1,
"limit": 1,
"order_by": "uu_id",
"order_type": "desc",
"query": None,
},
},
},
},
},
)
class ClustersPageInfo:
# Cluster Page Infos that are available for the client
dashboard_page_info = PageInfo(
DASHBOARD = PageInfo(
name=f"{cluster_name}",
url=PageBases.DASHBOARD,
icon=icon,
page_info={
template_ui="LCU",
info={
"en": {
"page": "Account Records for reaching user all types account information",
},
@@ -29,53 +98,60 @@ class ClustersPageInfo:
"page": "Kullanıcı tüm hesap bilgilerine ulaşmak için Hesap Kayıtları",
},
},
instructions={
sub_components={
str(KeyBases.create_key): {
"SITE_URL": PageBases.CREATE,
"COMPONENT": Components.LINK,
"PREFIX_URL": KeyBases.create_key,
"ENDPOINTS": AccountRecordsCreateEventMethods.retrieve_all_event_keys(),
"LANGUAGE_MODELS": account_language_create_link_models_as_dict,
"INSTRUCTIONS": {},
},
str(KeyBases.update_key): {
"SITE_URL": PageBases.UPDATE,
"COMPONENT": Components.LINK,
"PREFIX_URL": KeyBases.update_key,
"ENDPOINTS": AccountRecordsUpdateEventMethods.retrieve_all_event_keys(),
"LANGUAGE_MODELS": account_language_update_link_models_as_dict,
"INSTRUCTIONS": {},
},
str(KeyBases.list_key): {
"headers": {
"store": True,
"url": KeyURLs.validations,
"data": {"event_code": f"{KeyBases.list_key}", "asked_field": KeyValidations.headers},
"SITE_URL": PageBases.DASHBOARD,
"COMPONENT": Components.TABLE,
"PREFIX_URL": KeyBases.list_key,
"INFO": {
"en": {"page": "List Account Records"},
"tr": {"page": "Hesap Kayıtlarını Listele"},
},
"data": {
"store": True,
"url": f"{KeyBases.list_key}",
"data": dict(page=1, limit=1),
"ENDPOINTS": AccountRecordsListEventMethods.retrieve_all_event_keys(),
"LANGUAGE_MODELS": account_language_list_models_as_dict,
"INSTRUCTIONS": {
KeyTypeValidations.HEADERS: {
"store": True,
"url": f"{VALID_URL_EXTENSION}{KeyURLs.validations}",
"data": ValidationRequest(
event_code=f"{KeyBases.list_key}",
asked_field=KeyValidations.headers,
type_=KeyTypes.RESPONSE
).dump(),
},
KeyTypeValidations.DATA: {
"store": True,
"url": f"{EVENTS_URL_EXTENSION}{KeyBases.list_key}",
"params": None,
"data": dict(page=1, limit=1, order_by="uu_id", order_type="desc", query=None),
},
},
},
},
endpoints={
str(KeyBases.update_key): AccountRecordsUpdateEventMethods.retrieve_all_event_keys(),
str(KeyBases.create_key): AccountRecordsCreateEventMethods.retrieve_all_event_keys(),
str(KeyBases.list_key): AccountRecordsListEventMethods.retrieve_all_event_keys(),
},
language_models={
str(KeyBases.list_key): {
str(KeyBases.update_key): account_language_model_as_dict,
str(KeyBases.create_key): account_language_created_models_as_dict,
str(KeyBases.list_key): account_language_list_models_as_dict,
}
},
)
create_page_info = PageInfo(
CREATE = PageInfo(
name=f"{cluster_name}",
url=PageBases.CREATE,
icon=icon,
instructions={
str(KeyBases.create_key): {
"validation": {
"store": True,
"url": KeyURLs.validations,
"data": {"event_code": f"{KeyBases.create_key}", "asked_field": KeyValidations.validation },
},
"headers": {
"store": True,
"url": KeyURLs.validations,
"data": {"event_code": f"{KeyBases.create_key}", "asked_field": KeyValidations.headers},
},
},
},
page_info={
template_ui="LCU",
info={
"en": {
"page": "Create Account Records for reaching user all types account information",
},
@@ -83,33 +159,53 @@ class ClustersPageInfo:
"page": "Kullanıcı tüm hesap bilgilerine ulaşmak için Hesap Kayıt Oluştur",
},
},
endpoints={
str(KeyBases.create_key): AccountRecordsCreateEventMethods.retrieve_all_event_keys(),
},
language_models={
str(KeyBases.create_key): account_language_create_models_as_dict,
},
)
update_page_info = PageInfo(
name=f"{cluster_name}",
url=PageBases.UPDATE,
icon=icon,
instructions={
str(KeyBases.update_key): {
"validation": {
"store": True,
"url": KeyURLs.validations,
"data": {"event_code": f"{KeyBases.update_key}", "asked_field": KeyValidations.validation},
sub_components={
str(KeyBases.create_key): {
"SITE_URL": PageBases.CREATE,
"COMPONENT": Components.FORM,
"PREFIX_URL": KeyBases.create_key,
"INFO": {
"en": {"page": "Create Account Records", "button": "Create"},
"tr": {"page": "Hesap Kayıtlarını Oluştur", "button": "Oluştur"},
},
"headers": {
"store": True,
"url": KeyURLs.validations,
"data": {"event_code": f"{KeyBases.update_key}", "asked_field": KeyValidations.headers},
"ENDPOINTS": AccountRecordsCreateEventMethods.retrieve_all_event_keys(),
"LANGUAGE_MODELS": account_language_create_form_models_as_dict,
"INSTRUCTIONS": {
KeyTypeValidations.VALIDATION: {
"store": True,
"url": f"{VALID_URL_EXTENSION}{KeyURLs.validations}",
"data": ValidationRequest(
event_code=f"{KeyBases.create_key}",
asked_field=KeyValidations.validation,
type_=KeyTypes.REQUEST
).dump(),
},
KeyTypeValidations.HEADERS: {
"store": True,
"url": f"{VALID_URL_EXTENSION}{KeyURLs.validations}",
"data": ValidationRequest(
event_code=f"{KeyBases.create_key}",
asked_field=KeyValidations.headers,
type_=KeyTypes.REQUEST
).dump(),
},
KeyTypeValidations.MODIFY: {
"store": False,
"url": f"{EVENTS_URL_EXTENSION}{KeyBases.create_key}",
"params": None,
"data": None,
},
},
},
},
page_info={
)
UPDATE = PageInfo(
name=f"{cluster_name}",
url=PageBases.UPDATE,
icon=icon,
template_ui="LCU",
info={
"en": {
"page": "Update Account Records via all types account information",
},
@@ -117,20 +213,52 @@ class ClustersPageInfo:
"page": "Tüm hesap bilgileri aracılığıyla Hesap Kayıtlarını Güncelle",
},
},
endpoints={
str(KeyBases.update_key): AccountRecordsUpdateEventMethods.retrieve_all_event_keys(),
},
language_models={
str(KeyBases.update_key): account_language_update_form_models_as_dict,
sub_components={
str(KeyBases.update_key): {
"SITE_URL": PageBases.UPDATE,
"COMPONENT": Components.FORM,
"PREFIX_URL": KeyBases.update_key,
"INFO": {
"en": {"page": "Update Account Records", "button": "Update"},
"tr": {"page": "Hesap Kayıtlarını Güncelle", "button": "Güncelle"},
},
"ENDPOINTS": AccountRecordsUpdateEventMethods.retrieve_all_event_keys(),
"LANGUAGE_MODELS": account_language_update_form_models_as_dict,
"INSTRUCTIONS": {
KeyTypeValidations.VALIDATION: {
"store": True,
"url": f"{VALID_URL_EXTENSION}{KeyURLs.validations}",
"data": ValidationRequest(
event_code=f"{KeyBases.update_key}",
asked_field=KeyValidations.validation,
type_=KeyTypes.REQUEST
).dump(),
},
KeyTypeValidations.HEADERS: {
"store": True,
"url": f"{VALID_URL_EXTENSION}{KeyURLs.validations}",
"data": ValidationRequest(
event_code=f"{KeyBases.update_key}",
asked_field=KeyValidations.headers,
type_=KeyTypes.REQUEST
).dump(),
},
KeyTypeValidations.MODIFY: {
"store": False,
"url": f"{EVENTS_URL_EXTENSION}{KeyBases.update_key}",
"params": None,
"data": None,
},
},
},
},
)
# Page Variations of the cluster
page_infos = {
ClustersPageInfo.dashboard_page_info.URL: ClustersPageInfo.dashboard_page_info,
ClustersPageInfo.create_page_info.URL: ClustersPageInfo.create_page_info,
ClustersPageInfo.update_page_info.URL: ClustersPageInfo.update_page_info,
ClustersPageInfo.DASHBOARD.URL: ClustersPageInfo.DASHBOARD,
ClustersPageInfo.CREATE.URL: ClustersPageInfo.CREATE,
ClustersPageInfo.UPDATE.URL: ClustersPageInfo.UPDATE,
}

View File

@@ -1,78 +1,44 @@
from Events.Engine.abstract_class import DefaultClusterName, LanguageModels
from .bases import KeyBases, cluster_name
from ApiLayers.LanguageModels.PageInfos.accounts.account import AccountLanguageModels
from Events.Engine.abstract_class import LanguageModels
from .bases import Components, Icons, KeyBases, PageBases
account_language_update_models = LanguageModels()
account_language_update_models.COMPONENT = "Link"
account_language_update_models.SITE_URL = f"/update?{DefaultClusterName}={cluster_name}"
account_language_update_models.PREFIX_URL = (
KeyBases.update_key
)
account_language_update_models.PAGE_INFO = {
"en": {
"page": "Update Account Records",
},
"tr": {
"page": "Hesap Kayıdı Güncelle",
},
}
account_language_model_as_dict = account_language_update_models.as_dict()
account_language_update_models.COMPONENT = Components.LINK
account_language_update_models.SITE_URL = PageBases.UPDATE
account_language_update_models.ICON = Icons.PENCIL
account_language_update_models.PREFIX_URL = KeyBases.update_key
account_language_update_models.PAGE_INFO = AccountLanguageModels.account_language_update_models
account_language_update_link_models_as_dict = account_language_update_models.as_dict()
account_language_created_models = LanguageModels()
account_language_created_models.COMPONENT = "Link"
account_language_created_models.SITE_URL = f"/create?{DefaultClusterName}={cluster_name}"
account_language_created_models.PREFIX_URL = (
KeyBases.create_key
)
account_language_created_models.PAGE_INFO = {
"en": {
"page": "Create Account Records",
},
"tr": {"page": "Hesap Kayıdı Oluştur"},
}
account_language_created_models_as_dict = account_language_created_models.as_dict()
account_language_created_models.COMPONENT = Components.LINK
account_language_created_models.ICON = Icons.PLUS
account_language_created_models.SITE_URL = PageBases.CREATE
account_language_created_models.PREFIX_URL = KeyBases.create_key
account_language_created_models.PAGE_INFO = AccountLanguageModels.account_language_created_models
account_language_create_link_models_as_dict = account_language_created_models.as_dict()
account_language_list_models = LanguageModels()
account_language_list_models.COMPONENT = "Table"
account_language_list_models.SITE_URL = f"/dashboard?{DefaultClusterName}={cluster_name}"
account_language_list_models.PREFIX_URL = (
KeyBases.list_key
)
account_language_list_models.PAGE_INFO = {
"en": {
"page": "List Account Records",
},
"tr": {
"page": "Hesap Kayıtlarını Listele",
},
}
account_language_list_models.COMPONENT = Components.TABLE
account_language_list_models.ICON = Icons.TABLE
account_language_list_models.SITE_URL = PageBases.DASHBOARD
account_language_list_models.PREFIX_URL = KeyBases.list_key
account_language_list_models.PAGE_INFO = AccountLanguageModels.account_language_list_models
account_language_list_models_as_dict = account_language_list_models.as_dict()
account_language_create_form_models = LanguageModels()
account_language_create_form_models.COMPONENT = "Form"
account_language_create_form_models.SITE_URL = f"/create?{DefaultClusterName}={cluster_name}"
account_language_create_form_models.PREFIX_URL = (
KeyBases.create_key
)
account_language_create_form_models.PAGE_INFO = {
"en": {"page": "List Account Records", "button:": "Create"},
"tr": {"page": "Hesap Kayıtlarını Listele", "button:": "Oluştur"},
}
account_language_create_models_as_dict = account_language_create_form_models.as_dict()
account_language_create_form_models.COMPONENT = Components.FORM
account_language_create_form_models.ICON = Icons.PLUS
account_language_create_form_models.SITE_URL = PageBases.CREATE
account_language_create_form_models.PREFIX_URL = KeyBases.create_key
account_language_create_form_models.PAGE_INFO = AccountLanguageModels.account_language_create_form_models
account_language_create_form_models_as_dict = account_language_create_form_models.as_dict()
account_language_update_form_models = LanguageModels()
account_language_update_form_models.COMPONENT = "Form"
account_language_update_form_models.SITE_URL = f"/update?{DefaultClusterName}={cluster_name}"
account_language_update_form_models.PREFIX_URL = (
KeyBases.update_key
)
account_language_update_form_models.PAGE_INFO = {
"en": {"page": "Update Account Records", "button:": "Update"},
"tr": {"page": "Hesap Kayıdı Güncelle", "button:": "Güncelle"},
}
account_language_update_form_models_as_dict = (
account_language_update_form_models.as_dict()
)
account_language_update_form_models.COMPONENT = Components.FORM
account_language_update_form_models.ICON = Icons.PENCIL
account_language_update_form_models.SITE_URL = PageBases.UPDATE
account_language_update_form_models.PREFIX_URL = KeyBases.update_key
account_language_update_form_models.PAGE_INFO = AccountLanguageModels.account_language_update_form_models
account_language_update_form_models_as_dict = account_language_update_form_models.as_dict()

View File

@@ -63,7 +63,7 @@ cluster_event.endpoint_callable = get_cluster_by_event_function_code
# Page Event
page_event = Event(
name="page_event",
key="",
key="2a43bff2-3720-4427-b226-9b2f6ef00b57",
request_validator=PagePydantic,
language_models=[],
statics=None,

View File

@@ -2,13 +2,16 @@
Validation function handlers
"""
from typing import Dict, Any
from typing import Dict, Any, Optional
from fastapi import Request
from ApiLayers.AllConfigs.Redis.configs import (
RedisValidationKeysAction,
RedisCategoryKeys,
RedisValidationKeysAction,
RedisCategoryPageInfoKeysAction,
)
from ApiLayers.ApiLibrary.common.line_number import get_line_number_for_error
from ApiLayers.ErrorHandlers.Exceptions.api_exc import HTTPExceptionApi
from Services.Redis.Actions.actions import RedisActions
from Events.base_request_model import BaseRouteModel
@@ -75,7 +78,7 @@ class RedisValidationRetrieve(ValidateBase):
)
if redis_validation.status:
return redis_validation.first
raise ValueError("Header not found")
raise ValueError("Validation not found")
class ValidationsBoth(RedisHeaderRetrieve, RedisValidationRetrieve):
@@ -155,14 +158,32 @@ class RetrievePage(BaseRouteModel):
raise NotImplementedError("Cluster not found")
@classmethod
def retrieve_page(cls, data: Any):
def retrieve_page(cls, data: Any) -> Optional[Dict[str, Any]]:
"""
Retrieve page by event function code
Check reachable codes for user to render which page and components on Frontend
Uses:
Context Token Retriever to get user information from ACCESS_TOKEN
CategoryCluster Retrieve Cluster Retrieve cluster by name
Check available instructions of page and info user with it
Args:
request: FastAPI request object
data.page: Request body containing login credentials
{
"page": "/dashboard?site=AccountCluster"
}
Returns:
NAME=cluster_name.name,
PREFIX=cluster_name.PREFIX,
URL=dict(page_info).get("URL", None),
ICON=dict(page_info).get("ICON", None),
INFO=dict(page_info).get("INFO", None),
SUB_COMPONENTS=sub_components,
"""
from Events.Engine import CategoryCluster
from Events.JustEvents.events_file import retrieve_cluster_by_name
reachable_codes = []
reachable_codes, page_name = [], getattr(data, "page", None)
if cls.context_retriever.token.is_employee:
reachable_codes = (
cls.context_retriever.token.selected_company.reachable_event_codes
@@ -171,46 +192,61 @@ class RetrievePage(BaseRouteModel):
reachable_codes = (
cls.context_retriever.token.selected_occupant.reachable_event_codes
)
cluster_from_all_events = cls.get_site_cluster(page_name=data.page)
if not cluster_from_all_events:
raise ValueError(f"Cluster not found : {data.page}")
cluster_name: CategoryCluster = retrieve_cluster_by_name(cluster_from_all_events)
if not cluster_name:
raise ValueError("Cluster not found")
page_info = cluster_name.retrieve_page_info().get(data.page, None)
if not page_info:
raise ValueError("Page not found")
endpoints: dict = dict(page_info).get("endpoints", {})
if not endpoints:
raise ValueError("Endpoints not found")
new_page_info_dict = dict(
name=cluster_name.name,
prefix=cluster_name.PREFIX,
url=dict(page_info).get("url", None),
icon=dict(page_info).get("icon", None),
mapping=cluster_name.MAPPING,
page_info=dict(page_info).get("page_info", None),
endpoints={},
language_models={},
instructions={},
cluster_name = str(page_name).split("?")[1].split("=")[1]
print("page_name", f"{RedisCategoryPageInfoKeysAction.page_index}:{page_name}")
page_info_from_redis = RedisActions.get_json(
list_keys=[
RedisCategoryPageInfoKeysAction.page_index,
cluster_name,
]
)
for key, event_codes in dict(endpoints).items():
# Meaning client can reach this endpoint [] & [] intersection
if set(event_codes) & set(reachable_codes):
language_models = dict(page_info).get("language_models", {})
instructions = dict(page_info).get("instructions", {})
new_page_info_dict["endpoints"][key] = True
if language_models.get(key, None):
if key in language_models[key].keys(): # key has sub key blocks inside lang model
for key_model, val_model in dict(language_models[key]).items():
if key_model in new_page_info_dict["endpoints"].keys():
new_page_info_dict["language_models"][key_model] = language_models[key][key_model]
else:
new_page_info_dict["language_models"][key] = language_models[key]
if instructions.get(key, None):
new_page_info_dict["instructions"][key] = instructions.get(key, None)
return new_page_info_dict
page_info_all = page_info_from_redis.first
if not page_info_all:
return dict(
NAME=f"{cluster_name}",
PREFIX=f"NOT IMPLEMENTED",
URL=f"{page_name}",
MESSAGE="Cluster not found"
)
page_info = page_info_all.get(page_name, {})
sub_components = dict(page_info).get("SUB_COMPONENTS", {})
print("PAGE INFO : ", dict(
page_name=page_name,
page_info=page_info,
sub_components=sub_components,
NAME=cluster_name,
PREFIX=page_info_all.get("prefix", ""),
TEMPLATE_UI=dict(page_info).get("TEMPLATE_UI", ""),
URL=dict(page_info).get("URL", None),
ICON=dict(page_info).get("ICON", None),
INFO=dict(page_info).get("INFO", None),
SUB_COMPONENTS=sub_components,
# MAPPING=cluster_name.MAPPING,
))
new_page_info = dict(
NAME=cluster_name,
PREFIX=page_info_all.get("prefix", ""),
TEMPLATE_UI=dict(page_info).get("TEMPLATE_UI", ""),
URL=dict(page_info).get("URL", None),
ICON=dict(page_info).get("ICON", None),
INFO=dict(page_info).get("INFO", None),
SUB_COMPONENTS=sub_components,
# MAPPING=cluster_name.MAPPING,
)
for key, events in dict(sub_components).items():
# Meaning client can reach this endpoint [] & [] intersection in reachable_codes
endpoint_event_codes = dict(events).get("ENDPOINTS", [])
if not len(list(set(endpoint_event_codes) & set(reachable_codes))) == 1:
print(f"{endpoint_event_codes} :||: Endpoint is not available for the current user")
new_page_info["SUB_COMPONENTS"].pop(key, None)
for key in new_page_info["SUB_COMPONENTS"].keys():
new_page_info["SUB_COMPONENTS"][key].pop("ENDPOINTS", None)
if len(new_page_info["SUB_COMPONENTS"]) == 0:
return dict(
NAME=cluster_name,
PREFIX=page_info_all.get("prefix", ""),
MESSAGE="This cluster is not registered or not accessible for the current user"
)
return new_page_info

View File

@@ -1,13 +1,13 @@
"""
Validation records request and response models.
"""
from typing import Optional
from pydantic import BaseModel
class ValidationsPydantic(BaseModel):
event_code: str
type: Optional[str] = "REQUEST"
asked_field: Optional[str] = "all"

View File

@@ -53,27 +53,94 @@ class PageInfo:
"/update?site=AccountCluster": ["/accounts/update"],
"/create?site=AccountCluster": ["/accounts/create"],
},
RedisValidation = dict(
NAME="AccountCluster",
PREFIX="/accounts",
URL="/dashboard?site=AccountCluster",
ICON="Building",
INFO={
"en": {
"page": "Account Records for reaching user all types account information",
},
"tr": {
"page": "Kullanıcı tüm hesap bilgilerine ulaşmak için Hesap Kayıtları",
},
},
SUB_COMPONENTS={
"/accounts/create": {
"SITE_URL": "/events/create?site=AccountCluster",
"COMPONENT": "Link",
"PREFIX_URL": "/accounts/create",
"INFO": {
"en": {
"page": "Create Account Records",
"actions": "Actions",
"table": "Table",
},
"tr": {
"page": "Hesap Kayıdı Oluştur",
"actions": "Aksiyonlar",
"table": "Tablo",
},
},
"INSTRUCTIONS": None,
},
"/accounts/list": {
"SITE_URL": "/events/dashboard?site=AccountCluster",
"COMPONENT": "Table",
"PREFIX_URL": "/accounts/list",
"INFO": {
"en": { "page": "List Account Records" },
"tr": { "page": "Hesap Kayıtlarını Listele" },
},
"INSTRUCTIONS": {
"headers": {
"store": True,
"url": "/validations/header",
"data": {
"event_code": "/accounts/list",
"asked_field": "headers",
},
},
"data": {
"store": True,
"url": "/accounts/list",
"data": {
"page": 1,
"limit": 1,
"order_by": "uu_id",
"order_type": "desc",
"query": None,
},
},
},
},
},
)
"""
NAME: str
PAGE_URL: str
PAGEINFO: Dict[str, Any]
INFO: Dict[str, Any]
URL: str = ""
ENDPOINTS: Dict[str, Any]
LANGUAGE_MODELS: Dict[str, Any]
SUB_COMPONENTS: Optional[list["PageComponent"]] = None
INSTRUCTIONS: Optional[Dict[str, Any]] = None
TEMPLATE_UI: Optional[str] = "LCU"
def __init__(
self,
name: str,
icon: str,
url: str,
endpoints: Dict[str, Any],
language_models: Dict[str, Any],
page_info: Optional[Dict[str, Any]] = None,
sub_components: Optional[list["PageComponent"]] = None,
info: Optional[Dict[str, Any]] = None,
endpoints: Optional[Dict[str, Any]] = None,
language_models: Optional[Dict[str, Any]] = None,
sub_components: Optional[list[Dict[str, Any]]] = None,
instructions: Optional[Dict[str, Any]] = None,
template_ui: Optional[str] = "LCU",
):
self.NAME = name
self.LANGUAGE_MODELS = language_models
@@ -81,8 +148,9 @@ class PageInfo:
self.URL = url
self.SUB_COMPONENTS = sub_components
self.ENDPOINTS = endpoints
self.PAGEINFO = page_info
self.INFO = info
self.INSTRUCTIONS = instructions
self.TEMPLATE_UI = template_ui
@property
def endpoints(self):
@@ -95,17 +163,14 @@ class PageInfo:
@property
def as_dict(self):
as_dict = {
"name": self.NAME,
"icon": self.ICON,
"url": self.URL,
"endpoints": self.ENDPOINTS,
"language_models": self.LANGUAGE_MODELS,
"page_info": self.PAGEINFO,
"NAME": self.NAME,
"ICON": self.ICON,
"URL": self.URL,
"TEMPLATE_UI": self.TEMPLATE_UI,
"LANGUAGE_MODELS": self.LANGUAGE_MODELS,
"INFO": self.INFO,
"SUB_COMPONENTS": self.SUB_COMPONENTS,
}
if self.INSTRUCTIONS:
as_dict["instructions"] = self.INSTRUCTIONS
if self.SUB_COMPONENTS:
as_dict["sub_components"] = [i.as_dict() for i in self.SUB_COMPONENTS]
return as_dict
@@ -268,6 +333,7 @@ class CategoryCluster:
DESCRIPTION: str
ENDPOINTS: dict[str, MethodToEvent] # {"MethodToEvent": MethodToEvent, ...}
SUBCATEGORY: Optional[List["CategoryCluster"]] # [CategoryCluster, ...]
TEMPLATE_UI: Optional[str] = "LCU" # LCU as List/Create/Update
MAPPING: Optional[List[Dict[str, Any]]] # [{"key": "value"}, ...]
INCLUDE_IN_SCHEMA: Optional[bool] = True
IS_CLIENT: Optional[bool] = False
@@ -282,6 +348,7 @@ class CategoryCluster:
sub_category: list,
mapping: Optional[List[Dict[str, Any]]] = None,
pageinfo: Optional[Dict["str", PageInfo]] = None,
template_ui: Optional[str] = "LCU",
include_in_schema: Optional[bool] = True,
is_client: Optional[bool] = False,
):
@@ -294,6 +361,7 @@ class CategoryCluster:
self.SUBCATEGORY = sub_category or []
self.INCLUDE_IN_SCHEMA = include_in_schema
self.MAPPING = mapping
self.TEMPLATE_UI = template_ui
self.IS_CLIENT = is_client
@property
@@ -347,6 +415,7 @@ class CategoryCluster:
return {"prefix": self.PREFIX, "mapping": self.MAPPING, **page_infos}
"""
page_infos = {}
print('def retrieve_page_info self.PAGEINFO',self.PAGEINFO)
if isinstance(self.PAGEINFO, dict):
for page_key, page_info in dict(self.PAGEINFO).items():
if page_info_dict := getattr(page_info, "as_dict", None):
@@ -354,7 +423,7 @@ class CategoryCluster:
return {"prefix": self.PREFIX, "mapping": self.MAPPING, **page_infos}
if hasattr(self.PAGEINFO, "as_dict"):
return {"prefix": self.PREFIX, "mapping": self.MAPPING, **self.PAGEINFO.as_dict}
return
return {"prefix": self.PREFIX, "mapping": self.MAPPING}
class LanguageModels:
@@ -363,6 +432,7 @@ class LanguageModels:
PREFIX_URL: str = ""
PAGE_INFO: dict
STATIC_PATH: str = STATIC_PATH
ICON: str = ""
def as_dict(self):
return {
@@ -370,6 +440,7 @@ class LanguageModels:
"COMPONENT": self.COMPONENT,
"PREFIX_URL": self.PREFIX_URL,
"PAGE_INFO": self.PAGE_INFO,
"ICON": self.ICON,
}

View File

@@ -24,6 +24,10 @@ from Services.PostgresDb.Models.pagination import (
TokenDictType = Union[EmployeeTokenObject, OccupantTokenObject]
STATIC_PATH = "events"
AUTH_URL_EXTENSION = "http://auth-service:8888"
EVENTS_URL_EXTENSION = "http://events-service:8888"
VALID_URL_EXTENSION = "http://validation-service:8888"
class EndpointBaseRequestModel(BaseModel):

View File

@@ -168,4 +168,4 @@ The AI will automatically:
- Update existing notes when relevant
- Track development progress
For detailed documentation about specific components, refer to the corresponding files in the `/docs/` directory.
For detailed documentation about specific components, refer to the corresponding files in the `/docs/` directory.

View File

@@ -1,32 +1,48 @@
services:
init-service:
initservice:
container_name: initservice
build:
context: .
dockerfile: DockerApiServices/InitServiceApi/Dockerfile
auth-service:
authservice:
container_name: authservice
build:
context: .
dockerfile: DockerApiServices/AuthServiceApi/Dockerfile
ports:
- "8081:41575"
- "8081:8888"
depends_on:
- init-service
- initservice
networks:
- wag-network
validation-service:
validationservice:
container_name: validationservice
build:
context: .
dockerfile: DockerApiServices/ValidationServiceApi/Dockerfile
context: .
dockerfile: DockerApiServices/ValidationServiceApi/Dockerfile
ports:
- "8082:41577"
- "8082:8888"
depends_on:
- init-service
- initservice
networks:
- wag-network
event-service:
eventservice:
container_name: eventservice
build:
context: .
dockerfile: DockerApiServices/EventServiceApi/Dockerfile
context: .
dockerfile: DockerApiServices/EventServiceApi/Dockerfile
ports:
- "8083:41576"
- "8083:8888"
depends_on:
- init-service
- initservice
networks:
- wag-network
networks:
wag-network:
name: wag-network
external: true

26
run.sh Executable file
View File

@@ -0,0 +1,26 @@
#!/bin/bash
# Check if wag-network exists
if ! docker network ls | grep -q "wag-network"; then
echo "Creating wag-network..."
docker network create wag-network
else
echo "wag-network already exists"
fi
# Bring down existing containers
echo "Stopping and removing existing containers..."
docker compose down --remove-orphans
# Build and start containers
echo "Building and starting containers..."
docker compose -f docker-compose-services.yml up --build -d
# Add container to wag-network
echo "Adding container to wag-network..."
docker container inspect authservice > /dev/null && docker network connect wag-network authservice
docker container inspect eventservice > /dev/null && docker network connect wag-network eventservice
docker container inspect validationservice > /dev/null && docker network connect wag-network validationservice
# Run migrations
echo "Setup complete! Backend Services Auth | Event | Validation are running..."