Kotta commited on
Commit ·
4e54695
1
Parent(s): 1015a8a
feature(#9): updated request body type with confs.
Browse files
Brain/src/common/assembler.py
CHANGED
|
@@ -67,5 +67,5 @@ class Assembler:
|
|
| 67 |
|
| 68 |
"""mapping basic req"""
|
| 69 |
|
| 70 |
-
def to_req_model(self, basic_req: BasicReq) -> ReqModel:
|
| 71 |
return ReqModel(basic_req.to_json())
|
|
|
|
| 67 |
|
| 68 |
"""mapping basic req"""
|
| 69 |
|
| 70 |
+
def to_req_model(self, basic_req: BasicReq.Confs) -> ReqModel:
|
| 71 |
return ReqModel(basic_req.to_json())
|
Brain/src/firebase/firebase.py
CHANGED
|
@@ -42,7 +42,7 @@ def get_firebase_admin_name(uuid: str = ""):
|
|
| 42 |
def firebase_admin_with_setting(data: BasicReq):
|
| 43 |
# firebase admin init
|
| 44 |
assembler = Assembler()
|
| 45 |
-
setting = assembler.to_req_model(data)
|
| 46 |
try:
|
| 47 |
firebase_app = initialize_app(setting)
|
| 48 |
except Exception as ex:
|
|
|
|
| 42 |
def firebase_admin_with_setting(data: BasicReq):
|
| 43 |
# firebase admin init
|
| 44 |
assembler = Assembler()
|
| 45 |
+
setting = assembler.to_req_model(data.confs)
|
| 46 |
try:
|
| 47 |
firebase_app = initialize_app(setting)
|
| 48 |
except Exception as ex:
|
Brain/src/model/requests/request_model.py
CHANGED
|
@@ -67,27 +67,30 @@ def get_client_info(request: Request):
|
|
| 67 |
|
| 68 |
|
| 69 |
class BasicReq(BaseModel):
|
| 70 |
-
class
|
| 71 |
-
|
| 72 |
-
|
| 73 |
-
|
| 74 |
-
|
| 75 |
-
|
| 76 |
-
|
| 77 |
-
|
| 78 |
-
|
| 79 |
-
|
| 80 |
-
|
| 81 |
-
|
| 82 |
-
|
| 83 |
-
|
| 84 |
-
|
| 85 |
-
|
| 86 |
-
|
| 87 |
-
|
| 88 |
-
|
| 89 |
-
|
| 90 |
-
|
|
|
|
|
|
|
|
|
|
| 91 |
|
| 92 |
|
| 93 |
"""endpoint: /sendNotification"""
|
|
|
|
| 67 |
|
| 68 |
|
| 69 |
class BasicReq(BaseModel):
|
| 70 |
+
class Confs(BaseModel):
|
| 71 |
+
class Settings(BaseModel):
|
| 72 |
+
temperature: float = 0.6
|
| 73 |
+
|
| 74 |
+
openai_key: str
|
| 75 |
+
pinecone_key: str
|
| 76 |
+
pinecone_env: str
|
| 77 |
+
firebase_key: str
|
| 78 |
+
token: str = ""
|
| 79 |
+
uuid: str = ""
|
| 80 |
+
settings: Settings
|
| 81 |
+
|
| 82 |
+
def to_json(self):
|
| 83 |
+
return {
|
| 84 |
+
"openai_key": self.openai_key,
|
| 85 |
+
"pinecone_key": self.pinecone_key,
|
| 86 |
+
"pinecone_env": self.pinecone_env,
|
| 87 |
+
"firebase_key": self.firebase_key,
|
| 88 |
+
"settings": {"temperature": self.settings.temperature},
|
| 89 |
+
"token": self.token,
|
| 90 |
+
"uuid": self.uuid,
|
| 91 |
+
}
|
| 92 |
+
|
| 93 |
+
confs: Confs
|
| 94 |
|
| 95 |
|
| 96 |
"""endpoint: /sendNotification"""
|
Brain/src/router/api.py
CHANGED
|
@@ -71,14 +71,16 @@ def construct_blueprint_api() -> APIRouter:
|
|
| 71 |
|
| 72 |
# parsing params
|
| 73 |
query = data.message
|
| 74 |
-
token =
|
| 75 |
-
uuid =
|
| 76 |
# check browser endpoint
|
| 77 |
if client_info.is_browser():
|
| 78 |
query = f"{query} in a web browser"
|
| 79 |
|
| 80 |
result = getCompletion(
|
| 81 |
-
query=query,
|
|
|
|
|
|
|
| 82 |
)
|
| 83 |
|
| 84 |
# check contact querying
|
|
@@ -126,10 +128,10 @@ def construct_blueprint_api() -> APIRouter:
|
|
| 126 |
cloud_message = CloudMessage(firebase_app=firebase_app)
|
| 127 |
|
| 128 |
image_model = ImageModel()
|
| 129 |
-
token =
|
| 130 |
|
| 131 |
image_model.image_name = data.image_name
|
| 132 |
-
image_model.uuid =
|
| 133 |
image_model.status = data.status
|
| 134 |
|
| 135 |
image_model.image_text = getTextFromImage(
|
|
@@ -170,8 +172,8 @@ def construct_blueprint_api() -> APIRouter:
|
|
| 170 |
# parsing params
|
| 171 |
image_name = data.image_name
|
| 172 |
message = data.message
|
| 173 |
-
token =
|
| 174 |
-
uuid =
|
| 175 |
|
| 176 |
image_content = getTextFromImage(filename=image_name, firebase_app=firebase_app)
|
| 177 |
# check message type
|
|
@@ -222,8 +224,8 @@ def construct_blueprint_api() -> APIRouter:
|
|
| 222 |
# cloud message
|
| 223 |
cloud_message = CloudMessage(firebase_app=firebase_app)
|
| 224 |
feedback_service = FeedbackService(firebase_app=firebase_app)
|
| 225 |
-
token =
|
| 226 |
-
uuid =
|
| 227 |
|
| 228 |
# parsing feedback payload
|
| 229 |
prompt = BasicModel(
|
|
@@ -303,8 +305,8 @@ def construct_blueprint_api() -> APIRouter:
|
|
| 303 |
# cloud message
|
| 304 |
cloud_message = CloudMessage(firebase_app=firebase_app)
|
| 305 |
try:
|
| 306 |
-
token =
|
| 307 |
-
uuid =
|
| 308 |
histories = assembler.to_array_message_model(data.history) # json array
|
| 309 |
user_input = data.user_input
|
| 310 |
"""init chat service with model"""
|
|
@@ -352,8 +354,8 @@ def construct_blueprint_api() -> APIRouter:
|
|
| 352 |
except BrainException as ex:
|
| 353 |
return assembler.to_response(ex.code, ex.message, "")
|
| 354 |
try:
|
| 355 |
-
token =
|
| 356 |
-
uuid =
|
| 357 |
|
| 358 |
# parsing feedback payload
|
| 359 |
sms_model = assembler.to_sms_model(data.data)
|
|
@@ -390,8 +392,8 @@ def construct_blueprint_api() -> APIRouter:
|
|
| 390 |
except BrainException as ex:
|
| 391 |
return assembler.to_response(ex.code, ex.message, "")
|
| 392 |
try:
|
| 393 |
-
token =
|
| 394 |
-
uuid =
|
| 395 |
|
| 396 |
# parsing contacts
|
| 397 |
contacts = []
|
|
@@ -424,8 +426,8 @@ def construct_blueprint_api() -> APIRouter:
|
|
| 424 |
except BrainException as ex:
|
| 425 |
return assembler.to_response(ex.code, ex.message, "")
|
| 426 |
try:
|
| 427 |
-
token =
|
| 428 |
-
uuid =
|
| 429 |
|
| 430 |
# parsing contacts
|
| 431 |
# train contact
|
|
|
|
| 71 |
|
| 72 |
# parsing params
|
| 73 |
query = data.message
|
| 74 |
+
token = setting.token
|
| 75 |
+
uuid = setting.uuid
|
| 76 |
# check browser endpoint
|
| 77 |
if client_info.is_browser():
|
| 78 |
query = f"{query} in a web browser"
|
| 79 |
|
| 80 |
result = getCompletion(
|
| 81 |
+
query=query,
|
| 82 |
+
setting=setting,
|
| 83 |
+
firebase_app=firebase_app,
|
| 84 |
)
|
| 85 |
|
| 86 |
# check contact querying
|
|
|
|
| 128 |
cloud_message = CloudMessage(firebase_app=firebase_app)
|
| 129 |
|
| 130 |
image_model = ImageModel()
|
| 131 |
+
token = setting.token
|
| 132 |
|
| 133 |
image_model.image_name = data.image_name
|
| 134 |
+
image_model.uuid = setting.uuid
|
| 135 |
image_model.status = data.status
|
| 136 |
|
| 137 |
image_model.image_text = getTextFromImage(
|
|
|
|
| 172 |
# parsing params
|
| 173 |
image_name = data.image_name
|
| 174 |
message = data.message
|
| 175 |
+
token = setting.token
|
| 176 |
+
uuid = setting.uuid
|
| 177 |
|
| 178 |
image_content = getTextFromImage(filename=image_name, firebase_app=firebase_app)
|
| 179 |
# check message type
|
|
|
|
| 224 |
# cloud message
|
| 225 |
cloud_message = CloudMessage(firebase_app=firebase_app)
|
| 226 |
feedback_service = FeedbackService(firebase_app=firebase_app)
|
| 227 |
+
token = setting.token
|
| 228 |
+
uuid = setting.uuid
|
| 229 |
|
| 230 |
# parsing feedback payload
|
| 231 |
prompt = BasicModel(
|
|
|
|
| 305 |
# cloud message
|
| 306 |
cloud_message = CloudMessage(firebase_app=firebase_app)
|
| 307 |
try:
|
| 308 |
+
token = setting.token
|
| 309 |
+
uuid = setting.uuid
|
| 310 |
histories = assembler.to_array_message_model(data.history) # json array
|
| 311 |
user_input = data.user_input
|
| 312 |
"""init chat service with model"""
|
|
|
|
| 354 |
except BrainException as ex:
|
| 355 |
return assembler.to_response(ex.code, ex.message, "")
|
| 356 |
try:
|
| 357 |
+
token = setting.token
|
| 358 |
+
uuid = setting.uuid
|
| 359 |
|
| 360 |
# parsing feedback payload
|
| 361 |
sms_model = assembler.to_sms_model(data.data)
|
|
|
|
| 392 |
except BrainException as ex:
|
| 393 |
return assembler.to_response(ex.code, ex.message, "")
|
| 394 |
try:
|
| 395 |
+
token = setting.token
|
| 396 |
+
uuid = setting.uuid
|
| 397 |
|
| 398 |
# parsing contacts
|
| 399 |
contacts = []
|
|
|
|
| 426 |
except BrainException as ex:
|
| 427 |
return assembler.to_response(ex.code, ex.message, "")
|
| 428 |
try:
|
| 429 |
+
token = setting.token
|
| 430 |
+
uuid = setting.uuid
|
| 431 |
|
| 432 |
# parsing contacts
|
| 433 |
# train contact
|
Brain/src/router/browser_router.py
CHANGED
|
@@ -38,8 +38,8 @@ def construct_blueprint_browser_api() -> APIRouter:
|
|
| 38 |
|
| 39 |
item_link = ""
|
| 40 |
try:
|
| 41 |
-
token =
|
| 42 |
-
uuid =
|
| 43 |
|
| 44 |
# parsing contacts
|
| 45 |
# train contact
|
|
|
|
| 38 |
|
| 39 |
item_link = ""
|
| 40 |
try:
|
| 41 |
+
token = setting.token
|
| 42 |
+
uuid = setting.uuid
|
| 43 |
|
| 44 |
# parsing contacts
|
| 45 |
# train contact
|