initial commit

Author: grutt

.gitignore

@@ -0,0 +1,17 @@
+# Python
+.venv
+*.pyc
+__pycache__/
+*.pyo
+*.pyd
+*.pyw
+*.pyz
+*.pywz
+*.ipynb_checkpoints/
+
+# TypeScript React
+node_modules/
+dist/
+build/
+
+.DS_Store

fast-api-react/fast-api-react/.gitignore

@@ -0,0 +1,4 @@
+__pycache__/
+.env
+certs/
+.venv

fast-api-react/fast-api-react/README.md

@@ -0,0 +1,39 @@
+# Hatchet FastAPI Example
+
+This is an example project demonstrating how to use Hatchet with FastAPI.
+
+## Prerequisites
+
+Before running this project, make sure you have the following:
+
+1. Python 3.7 or higher installed on your machine.
+2. Poetry package manager installed. You can install it by running `pip install poetry`.
+3. Clone this repository to your local machine.
+
+## Setup
+
+1. Create a `.env` file in the project root directory and set the required environment variables. Refer to the documentation for the specific environment variables needed for your application.
+
+2. Open a terminal and navigate to the project root directory.
+
+3. Run the following command to install the project dependencies:
+
+   ```shell
+   poetry install
+   ```
+
+## Running the API
+
+To start the FastAPI server, run the following command in the terminal:
+
+```shell
+poetry run api
+```
+
+## Running the Hatchet Worker
+
+To start the Hatchet worker, run the following command in the terminal:
+
+```shell
+poetry run hatchet
+```

fast-api-react/fast-api-react/backend/README.md

@@ -0,0 +1,26 @@
+[tool.poetry]
+name = "src"
+version = "0.0.0"
+description = "Easily run background tasks in FastAPI with Hatchet"
+authors = []
+readme = "README.md"
+
+[tool.poetry.scripts]
+api = "src.api.main:start"
+hatchet = "src.workflows.main:start"
+
+[tool.poetry.dependencies]
+python = "^3.8"
+python-dotenv = "^1.0.0"
+hatchet-sdk = "^0.9.4"
+uvicorn = {extras = ["standard"], version = "^0.27.0"}
+fastapi = "^0.109.0"
+openai = "^1.11.0"
+beautifulsoup4 = "^4.12.3"
+requests = "^2.31.0"
+urllib3 = "1.26.15"
+
+[build-system]
+requires = ["poetry-core"]
+build-backend = "poetry.core.masonry.api"
+

fast-api-react/fast-api-react/backend/__init__.py

@@ -0,0 +1,71 @@
+from fastapi import FastAPI
+from fastapi.middleware.cors import CORSMiddleware
+from fastapi.responses import StreamingResponse
+
+from .models import MessageRequest
+
+from hatchet_sdk import Hatchet
+import uvicorn
+from dotenv import load_dotenv
+import json
+
+load_dotenv()
+
+app = FastAPI()
+hatchet = Hatchet()
+
+
+origins = [
+    "http://localhost:3000",
+    "localhost:3000"
+]
+
+
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=origins,
+    allow_credentials=True,
+    allow_methods=["*"],
+    allow_headers=["*"]
+)
+
+
+def event_stream_generator(workflowRunId):
+    stream = hatchet.client.listener.stream(workflowRunId)
+
+    for event in stream:
+        data = json.dumps({
+            "type": event.type,
+            "payload": event.payload,
+            "workflowRunId": workflowRunId
+        })
+
+        #     stream.abort()
+        print(data)
+        yield "data: " + data + "\n\n"
+
+
+@app.get("/stream/{messageId}")
+async def stream(messageId: str):
+    # message id -> workflowRunId
+    workflowRunId = messageId
+    # stream = hatchet.stream(workflowRunId)
+    return StreamingResponse(event_stream_generator(workflowRunId), media_type='text/event-stream')
+
+
+@app.post("/message")
+def message(data: MessageRequest):
+    print(data.model_dump())
+
+    messageId = hatchet.client.admin.run_workflow("GenerateWorkflow", {
+        "request": data.model_dump()
+    })
+
+    # save step message id -> workflowRunId
+
+    return {"workflowRunId": messageId}
+
+
+def start():
+    """Launched with `poetry run start` at root level"""
+    uvicorn.run("src.api.main:app", host="0.0.0.0", port=8000, reload=True)