feature: initial grpc setup

Author: mostafa6765

.gitignore

@@ -0,0 +1,88 @@
+# Python
+__pycache__/
+*.py[cod]
+*$py.class
+*.so
+.Python
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+MANIFEST
+
+# Virtual Environments
+venv/
+env/
+ENV/
+.env
+.venv
+env.bak/
+venv.bak/
+
+# gRPC generated files
+*_pb2.py
+*_pb2_grpc.py
+
+# IDE specific files
+.idea/
+.vscode/
+*.swp
+*.swo
+.DS_Store
+.project
+.pydevproject
+.settings/
+
+# Logs
+*.log
+logs/
+
+# Local configuration
+*.local.py
+*.local.yaml
+*.local.yml
+*.local.json
+
+# Database
+*.sqlite3
+*.db
+
+# Test cache
+.pytest_cache/
+.coverage
+htmlcov/
+.tox/
+nosetests.xml
+coverage.xml
+*.cover
+
+# Documentation
+docs/_build/
+docs/site/
+
+# Environment variables
+.env
+.env.local
+
+# Jupyter Notebook
+.ipynb_checkpoints
+
+# mypy
+.mypy_cache/
+.dmypy.json
+dmypy.json
+
+# Docker
+.dockerignore
+docker-compose.override.yml

Pipfile

@@ -0,0 +1,16 @@
+[[source]]
+url = "https://pypi.org/simple"
+verify_ssl = true
+name = "pypi"
+
+[packages]
+grpcio = "*"
+grpcio-tools = "*"
+protobuf = "*"
+watchdog = "*"
+
+[dev-packages]
+
+[requires]
+python_version = "3.12"
+python_full_version = "3.12.3"

Pipfile.lock

@@ -0,0 +1 @@
+* https://github.com/AliBigdeli/FastApi-GRPC-Todo-Microservice-App/tree/main

__docs/readme.md

@@ -0,0 +1,2 @@
+python -m grpc_tools.protoc -I=protobuf/ --python_out=src/proto --grpc_python_out=src/proto protobuf/*.proto
+	cd src/proto && sed -i '' 's/^\(import.*pb2\)/from . \1/g' *.py

generate.sh

@@ -0,0 +1,19 @@
+syntax = "proto3";
+
+package hello;
+
+// Define the greeting service
+service Greeter {
+  // Define a simple RPC method
+  rpc SayHello (HelloRequest) returns (HelloResponse) {}
+}
+
+// Request message
+message HelloRequest {
+  string name = 1;
+}
+
+// Response message
+message HelloResponse {
+  string message = 1;
+} 

protobuf/hello.proto

@@ -0,0 +1 @@
+python3 ./src/hot_reload.py ./src/main.py

run_project.sh

@@ -0,0 +1,53 @@
+import os
+import sys
+import time
+import subprocess
+from watchdog.observers import Observer
+from watchdog.events import FileSystemEventHandler
+
+class ServerRestartHandler(FileSystemEventHandler):
+    def __init__(self, server_file):
+        self.server_file = server_file
+        self.process = None
+        self.start_server()
+    
+    def start_server(self):
+        # Kill previous process if it exists
+        if self.process:
+            print("Stopping gRPC server...")
+            self.process.terminate()
+            self.process.wait()
+
+        
+        # Start new server process
+        print("Starting gRPC server...")
+        self.process = subprocess.Popen([sys.executable, self.server_file])
+    
+    def on_modified(self, event):
+        # Check if it's a Python file
+        if event.src_path.endswith('.py'):
+            print(f"Detected change in {event.src_path}")
+            self.start_server()
+
+if __name__ == "__main__":
+    if len(sys.argv) < 2:
+        print("Usage: python hot_reload.py <server_file.py>")
+        sys.exit(1)
+    
+    server_file = sys.argv[1]
+    path = os.path.dirname(os.path.abspath(server_file)) or '.'
+    
+    event_handler = ServerRestartHandler(server_file)
+    observer = Observer()
+    observer.schedule(event_handler, path, recursive=True)
+    observer.start()
+    
+    try:
+        while True:
+            time.sleep(1)
+    except KeyboardInterrupt:
+        observer.stop()
+        if event_handler.process:
+            event_handler.process.terminate()
+    
+    observer.join()