intial build : more work to do

.idea/.gitignore

+# Default ignored files
+/shelf/
+/workspace.xml

.idea/inspectionProfiles/Project_Default.xml

+<component name="InspectionProjectProfileManager">
+  <profile version="1.0">
+    <option name="myName" value="Project Default" />
+    <inspection_tool class="PyPep8NamingInspection" enabled="true" level="WEAK WARNING" enabled_by_default="true">
+      <option name="ignoredErrors">
+        <list>
+          <option value="N802" />
+          <option value="N806" />
+        </list>
+      </option>
+    </inspection_tool>
+  </profile>
+</component>
\ No newline at end of file

.idea/inspectionProfiles/profiles_settings.xml

+<component name="InspectionProjectProfileManager">
+  <settings>
+    <option name="USE_PROJECT_PROFILE" value="false" />
+    <version value="1.0" />
+  </settings>
+</component>
\ No newline at end of file

.idea/misc.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectRootManager" version="2" project-jdk-name="Python 3.11 (python_redis)" project-jdk-type="Python SDK" />
+</project>
\ No newline at end of file

.idea/modules.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/.idea/python_redis.iml" filepath="$PROJECT_DIR$/.idea/python_redis.iml" />
+    </modules>
+  </component>
+</project>
\ No newline at end of file

.idea/python_redis.iml

+<?xml version="1.0" encoding="UTF-8"?>
+<module type="PYTHON_MODULE" version="4">
+  <component name="NewModuleRootManager">
+    <content url="file://$MODULE_DIR$">
+      <excludeFolder url="file://$MODULE_DIR$/venv" />
+    </content>
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>
\ No newline at end of file

.idea/vcs.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="VcsDirectoryMappings">
+    <mapping directory="$PROJECT_DIR$" vcs="Git" />
+  </component>
+</project>
\ No newline at end of file

main.py

+import uvicorn
+
+uvicorn.run("scripts.core.services.app:app")

scripts/config/mqtt_connection.py

+MQTT_HOST = '192.168.0.220'
+MQTT_PORT = 1883
+
+TOPIC = 'doctor/#'

scripts/config/redis_connection.py

+import redis
+
+REDIS_PORT = 6379
+REDIS_HOST = '127.0.0.1'
+r = redis.Redis(host=REDIS_HOST, port=REDIS_PORT)

scripts/core/handlers/check_patient_visited.py

+from scripts.config.redis_connection import r
+
+
+def check_patient_id(patient_id):
+    try:
+        # Check if the patient has visited before
+        all_patient_id = r.keys()
+        if r.exists(patient_id):
+            doctor_topic = r.get(patient_id)
+            print("patient id already presnt in redis databse")
+
+        else:
+            # If the patient is new, assign a doctor using round-robin
+            print("done succesfull")
+    except Exception as e:
+        print("Exception occurred due to \"", e, "\"")
+

scripts/core/handlers/create_new_patient_data.py

+import json
+from scripts.core.handlers.store_patient_details_in_redis import insert_data_redis
+
+
+def insert_new_data():
+    patient_name = input("enter patient name")
+    patient_id = int(input("enter patient id"))
+    patient_description = input("enter patient description")
+    patiend_age = int(input("enter patient age"))
+
+    data_to_be_sent = {
+        "patient_description": patient_description,
+        "patient_name": patient_name,
+
+        "age ": patiend_age,
+
+    }
+
+    print(" data that will be published to broker is :\n\n", "patiend id :\n", patient_id, "\npatient description \n\n",
+          json.dumps(data_to_be_sent))
+
+    insert_data_redis(patient_id, json.dumps(data_to_be_sent))

scripts/core/handlers/store_patient_details_in_redis.py

+from scripts.config.redis_connection import r
+from scripts.core.handlers.check_patient_visited import check_patient_id
+
+def insert_data_redis(patient_id,x):
+    r.set(patient_id,x)
+
+    check_patient_id(patient_id)
+
+
+
+
+
+
+
+

scripts/core/services/app.py

+from fastapi import FastAPI
+
+from scripts.core.handlers.create_new_patient_data import insert_new_data
+
+app = FastAPI()
+
+
+@app.get("/")
+def index():
+    return {"message :", " FAST API IS CONNECTED"}
+
+
+insert_new_data()
+
+