get reflex web to source its files from reflex

Author: adhami3310

docs/__init__.py

@@ -0,0 +1 @@
+"""Reflex documentation."""

docs/getting_started/__init__.py

@@ -0,0 +1 @@
+"""Getting started docs."""

docs/getting_started/chat_tutorial_style.py

@@ -0,0 +1,28 @@
+"""Common styles for questions and answers."""
+
+import reflex as rx
+
+shadow = "rgba(0, 0, 0, 0.15) 0px 2px 8px"
+chat_margin = "20%"
+message_style = {
+    "padding": "1em",
+    "border_radius": "5px",
+    "margin_y": "0.5em",
+    "box_shadow": shadow,
+    "max_width": "30em",
+    "display": "inline-block",
+}
+
+# Set specific styles for questions and answers.
+question_style = message_style | {
+    "background_color": rx.color("gray", 4),
+    "margin_left": chat_margin,
+}
+answer_style = message_style | {
+    "background_color": rx.color("accent", 8),
+    "margin_right": chat_margin,
+}
+
+# Styles for the action bar.
+input_style = {"border_width": "1px", "box_shadow": shadow, "width": "350px"}
+button_style = {"background_color": rx.color("accent", 10), "box_shadow": shadow}

docs/getting_started/chat_tutorial_utils.py

@@ -0,0 +1,99 @@
+"""Utility classes for the chat app tutorial."""
+
+from __future__ import annotations
+
+import os
+
+import openai  # pyright: ignore[reportMissingImports]
+
+import reflex as rx
+
+OPENAI_API_KEY = os.environ.get("OPENAI_API_KEY")
+
+
+class ChatappState(rx.State):
+    """State for the chat app tutorial."""
+
+    # The current question being asked.
+    question: str
+
+    # Keep track of the chat history as a list of (question, answer) tuples.
+    chat_history: list[tuple[str, str]]
+
+    def set_question(self, q: str):
+        """Set the current question."""
+        self.question = q
+
+    def set_question1(self, q: str):
+        """Set the current question (variant 1)."""
+        self.question = q
+
+    def set_question2(self, q: str):
+        """Set the current question (variant 2)."""
+        self.question = q
+
+    def set_question3(self, q: str):
+        """Set the current question (variant 3)."""
+        self.question = q
+
+    def answer(self) -> None:
+        """Answer the question with a static response."""
+        # Our chatbot is not very smart right now...
+        answer = "I don't know!"
+        self.chat_history.append((self.question, answer))
+
+    def answer2(self) -> None:
+        """Answer the question and clear the input."""
+        # Our chatbot is not very smart right now...
+        answer = "I don't know!"
+        self.chat_history.append((self.question, answer))
+        # Clear the question input.
+        self.question = ""
+
+    async def answer3(self):
+        """Answer with a streaming static response."""
+        import asyncio
+
+        # Our chatbot is not very smart right now...
+        answer = "I don't know!"
+        self.chat_history.append((self.question, ""))
+
+        # Clear the question input.
+        self.question = ""
+        # Yield here to clear the frontend input before continuing.
+        yield
+
+        for i in range(len(answer)):
+            await asyncio.sleep(0.1)
+            self.chat_history[-1] = (self.chat_history[-1][0], answer[: i + 1])
+            yield
+
+    async def answer4(self):
+        """Answer using the OpenAI API with streaming."""
+        # Our chatbot has some brains now!
+        client = openai.AsyncOpenAI(api_key=OPENAI_API_KEY)
+        session = await client.chat.completions.create(
+            model="gpt-4o-mini",
+            messages=[{"role": "user", "content": self.question}],
+            stop=None,
+            temperature=0.7,
+            stream=True,
+        )
+
+        # Add to the answer as the chatbot responds.
+        answer = ""
+        self.chat_history.append((self.question, answer))
+
+        # Clear the question input.
+        self.question = ""
+        # Yield here to clear the frontend input before continuing.
+        yield
+
+        async for item in session:
+            if hasattr(item.choices[0].delta, "content"):
+                if item.choices[0].delta.content is None:
+                    # presence of 'None' indicates the end of the response
+                    break
+                answer += item.choices[0].delta.content
+                self.chat_history[-1] = (self.chat_history[-1][0], answer)
+                yield