fetcher = ProxyFetcher(loop=loop)

.vscode/settings.json

@@ -0,0 +1,6 @@
+{
+    "[python]": {
+        "editor.defaultFormatter": "ms-python.black-formatter"
+    },
+    "python.formatting.provider": "none"
+}

App/Chat/PoeChatrouter.py

@@ -31,10 +31,10 @@ async def fetch_predictions(data):
     else:
         # If an event loop is already running, use the current one
         loop = asyncio.get_event_loop()
-    fetcher = ProxyFetcher(loop=loop)
+
     if not proxy_set:
         try:
-
+            fetcher = ProxyFetcher(loop=loop)
             proxies = fetcher.get(
                 limit=10,
                 protocols=[Protocols.HTTP],

App/Chat/utils/PoeBot.py

@@ -8,7 +8,7 @@ pattern = r"\!\[.*?\]\((.*?)\)"
 
 client = PoeApi("sXvCnfYy8CHnXNTRlxhmVg==")
 CHAT_CODE = ""
-print(client.get_chat_history()["data"])
+# print(client.get_chat_history()["data"])
 GEN_CODE = ""
 
 
@@ -63,4 +63,5 @@ async def GenerateImage(req: BotRequest):
             client = PoeApi("sXvCnfYy8CHnXNTRlxhmVg==")
             GEN_CODE = ""
             counter += 1
-            print(client.get_chat_history()["data"])
+            client.get_chat_history()
+            # print(client.get_chat_history()["data"])

App/TTS/text.py

@@ -0,0 +1,17 @@
+
+x={
+      "name": "execute_sql",
+      "description": "Executes the sql query, the schema of the table is CREATE TABLE fund_data (id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY, scheme_id BIGINT UNSIGNED DEFAULT 0, net_asset_value DECIMAL(20, 4), outstanding_number_of_units DECIMAL(20, 4), nav_per_unit DECIMAL(20, 4), sale_price_per_unit DECIMAL(20, 4), repurchase_price_per_unit DECIMAL(20, 4), date_valued DATE, scheme_name VARCHAR(255)); all calculations should end in the current date and nothing more, for the lastest price of any fund use the last recorded price, using  sale_price_per_unit create a sql query to pass to the execute_sql. There is Liquid Fund, Umoja Fund, Bond Fund, Jikimu Fund Wekeza Maisha Fund and Watoto Fund. Make sure that the  syntax is valid!",
+      "parameters": {
+        "type": "object",
+        "properties": {
+          "query": {
+            "type": "string",
+            "description": "SQL query passed to the "
+          }
+        },
+        "required": ["query"]
+      }
+    }
+
+#sql query to 

App/TTS/text2sql.py

@@ -0,0 +1,277 @@
+import csv
+
+queries = [
+    {
+        "description": "Get all records from fund_data",
+        "query": "SELECT * FROM fund_data;",
+    },
+    {
+        "description": "Get all records from fund_data",
+        "query": "SELECT * FROM fund_data;",
+    },
+    {
+        "description": "Get all unique fund names",
+        "query": "SELECT DISTINCT scheme_name FROM fund_data;",
+    },
+    {
+        "description": "Get the latest price for each fund",
+        "query": """
+            SELECT scheme_name, sale_price_per_unit
+            FROM fund_data
+            WHERE (scheme_name, date_valued) IN (
+                SELECT scheme_name, MAX(date_valued)
+                FROM fund_data
+                GROUP BY scheme_name
+            );
+        """,
+    },
+    {
+        "description": "Get the total sale_price_per_unit for each fund",
+        "query": "SELECT scheme_name, SUM(sale_price_per_unit) FROM fund_data GROUP BY scheme_name;",
+    },
+    {
+        "description": "Get the number of records for each fund",
+        "query": "SELECT scheme_name, COUNT(*) FROM fund_data GROUP BY scheme_name;",
+    },
+    {
+        "description": "Get the earliest and latest date_valued for each fund",
+        "query": "SELECT scheme_name, MIN(date_valued), MAX(date_valued) FROM fund_data GROUP BY scheme_name;",
+    },
+    {
+        "description": "Get the sale_price_per_unit for the latest date_valued for each fund",
+        "query": """
+        SELECT scheme_name, sale_price_per_unit
+        FROM fund_data
+        WHERE date_valued = (
+            SELECT MAX(date_valued)
+            FROM fund_data AS fd
+            WHERE fd.scheme_name = fund_data.scheme_name
+        );
+    """,
+    },
+    {
+        "description": "Get the fund with the highest average sale_price_per_unit for each year",
+        "query": """
+        SELECT YEAR(date_valued) AS year, scheme_name, AVG(sale_price_per_unit) AS avg_price
+        FROM fund_data
+        GROUP BY year, scheme_name
+        ORDER BY avg_price DESC;
+    """,
+    },
+    {
+        "description": "Get the fund with the highest total sale_price_per_unit for each month in 2020",
+        "query": """
+        SELECT MONTH(date_valued) AS month, scheme_name, SUM(sale_price_per_unit) AS total_price
+        FROM fund_data
+        WHERE YEAR(date_valued) = 2020
+        GROUP BY month, scheme_name
+        ORDER BY total_price DESC;
+    """,
+    },
+    {
+        "description": "Get the top 3 funds with the highest average sale_price_per_unit for each quarter in 2020",
+        "query": """
+        SELECT QUARTER(date_valued) AS quarter, scheme_name, AVG(sale_price_per_unit) AS avg_price
+        FROM fund_data
+        WHERE YEAR(date_valued) = 2020
+        GROUP BY quarter, scheme_name
+        ORDER BY avg_price DESC
+        LIMIT 3;
+    """,
+    },
+    {
+        "description": "Get the fund with the highest sale_price_per_unit for the last date_valued of each month in 2020",
+        "query": """
+        SELECT scheme_name, sale_price_per_unit
+        FROM fund_data
+        WHERE date_valued IN (
+            SELECT MAX(date_valued)
+            FROM fund_data
+            WHERE YEAR(date_valued) = 2020
+            GROUP BY MONTH(date_valued)
+        )
+        ORDER BY sale_price_per_unit DESC;
+    """,
+    },
+    {
+        "description": "Get the fund with the lowest average sale_price_per_unit",
+        "query": """
+        SELECT scheme_name, AVG(sale_price_per_unit) AS avg_price
+        FROM fund_data
+        GROUP BY scheme_name
+        ORDER BY avg_price ASC
+        LIMIT 1;
+    """,
+    },
+    {
+        "description": "Get the date with the highest total sale_price_per_unit for all funds",
+        "query": """
+        SELECT date_valued, SUM(sale_price_per_unit) AS total_price
+        FROM fund_data
+        GROUP BY date_valued
+        ORDER BY total_price DESC
+        LIMIT 1;
+    """,
+    },
+    {
+        "description": "Get the fund with the most records in the database",
+        "query": """
+        SELECT scheme_name, COUNT(*) AS count
+        FROM fund_data
+        GROUP BY scheme_name
+        ORDER BY count DESC
+        LIMIT 1;
+    """,
+    },
+    {
+        "description": "Get the date with the most records in the database",
+        "query": """
+        SELECT date_valued, COUNT(*) AS count
+        FROM fund_data
+        GROUP BY date_valued
+        ORDER BY count DESC
+        LIMIT 1;
+    """,
+    },
+    {
+        "description": "Get the fund with the highest sale_price_per_unit on the latest date_valued",
+        "query": """
+        SELECT scheme_name, sale_price_per_unit
+        FROM fund_data
+        WHERE date_valued = (
+            SELECT MAX(date_valued)
+            FROM fund_data
+        )
+        ORDER BY sale_price_per_unit DESC
+        LIMIT 1;
+    """,
+    },
+    {
+        "description": "Get the percentage change in average sale_price_per_unit from the previous month for each fund in 2020",
+        "query": """
+        SELECT scheme_name, MONTH(date_valued) AS month, 
+        ((AVG(sale_price_per_unit) - LAG(AVG(sale_price_per_unit)) OVER (PARTITION BY scheme_name ORDER BY month)) / LAG(AVG(sale_price_per_unit)) OVER (PARTITION BY scheme_name ORDER BY month)) * 100 AS pct_change
+        FROM fund_data
+        WHERE YEAR(date_valued) = 2020
+        GROUP BY scheme_name, month;
+    """,
+    },
+    {
+        "description": "Get the top 5 funds with the highest average sale_price_per_unit",
+        "query": """
+        SELECT scheme_name, AVG(sale_price_per_unit) AS avg_price
+        FROM fund_data
+        GROUP BY scheme_name
+        ORDER BY avg_price DESC
+        LIMIT 5;
+    """,
+    },
+    {
+        "description": "Calculate percentage return of funds in 2020",
+        "query": """
+            SELECT 
+                start_price.scheme_name, 
+                ((end_price.sale_price_per_unit - start_price.sale_price_per_unit) / start_price.sale_price_per_unit) * 100 AS percentage_return
+            FROM 
+                (SELECT scheme_name, sale_price_per_unit
+                FROM fund_data
+                WHERE scheme_name IN ('Liquid Fund', 'Bond Fund') AND date_valued = (SELECT MIN(date_valued) FROM fund_data WHERE scheme_name = fund_data.scheme_name)
+                GROUP BY scheme_name) AS start_price,
+                (SELECT scheme_name, sale_price_per_unit
+                FROM fund_data
+                WHERE scheme_name IN ('Liquid Fund', 'Bond Fund') AND date_valued = (SELECT MAX(date_valued) FROM fund_data WHERE scheme_name = fund_data.scheme_name)
+                GROUP BY scheme_name) AS end_price
+            WHERE start_price.scheme_name = end_price.scheme_name;
+        """,
+    },
+    {
+        "description": "Calculate Sharpe Ratio of Liquid Fund in 2020",
+        "query": """
+            SELECT 
+                scheme_name,
+                AVG(daily_return) AS avg_return,
+                STDDEV_POP(daily_return) AS std_dev,
+                (AVG(daily_return) - 12) / STDDEV_POP(daily_return) AS sharpe_ratio
+            FROM 
+                (SELECT 
+                    scheme_name,
+                    ((sale_price_per_unit - LAG(sale_price_per_unit) OVER (PARTITION BY scheme_name ORDER BY date_valued)) / LAG(sale_price_per_unit) OVER (PARTITION BY scheme_name ORDER BY date_valued)) * 100 AS daily_return
+                FROM 
+                    fund_data
+                WHERE 
+                    scheme_name = 'Liquid Fund' AND YEAR(date_valued) = 2020) AS daily_returns
+            GROUP BY 
+                scheme_name;
+        """,
+    },
+    {
+        "description": "Get the total number of records in fund_data",
+        "query": "SELECT COUNT(*) FROM fund_data;",
+    },
+    {
+        "description": "Get the average sale_price_per_unit for each fund",
+        "query": "SELECT scheme_name, AVG(sale_price_per_unit) FROM fund_data GROUP BY scheme_name;",
+    },
+    {
+        "description": "Get all unique fund names",
+        "query": "SELECT DISTINCT scheme_name FROM fund_data;",
+    },
+    {
+        "description": "Get the latest price for each fund",
+        "query": """
+            SELECT scheme_name, sale_price_per_unit
+            FROM fund_data
+            WHERE (scheme_name, date_valued) IN (
+                SELECT scheme_name, MAX(date_valued)
+                FROM fund_data
+                GROUP BY scheme_name
+            );
+        """,
+    },
+    {
+        "description": "Calculate percentage return of funds in 2020",
+        "query": """
+            SELECT 
+                start_price.scheme_name, 
+                ((end_price.sale_price_per_unit - start_price.sale_price_per_unit) / start_price.sale_price_per_unit) * 100 AS percentage_return
+            FROM 
+                (SELECT scheme_name, sale_price_per_unit
+                FROM fund_data
+                WHERE scheme_name IN ('Liquid Fund', 'Bond Fund') AND date_valued = (SELECT MIN(date_valued) FROM fund_data WHERE scheme_name = fund_data.scheme_name)
+                GROUP BY scheme_name) AS start_price,
+                (SELECT scheme_name, sale_price_per_unit
+                FROM fund_data
+                WHERE scheme_name IN ('Liquid Fund', 'Bond Fund') AND date_valued = (SELECT MAX(date_valued) FROM fund_data WHERE scheme_name = fund_data.scheme_name)
+                GROUP BY scheme_name) AS end_price
+            WHERE start_price.scheme_name = end_price.scheme_name;
+        """,
+    },
+    {
+        "description": "Calculate Sharpe Ratio of Liquid Fund in 2020",
+        "query": """
+            SELECT 
+                scheme_name,
+                AVG(daily_return) AS avg_return,
+                STDDEV_POP(daily_return) AS std_dev,
+                (AVG(daily_return) - 12) / STDDEV_POP(daily_return) AS sharpe_ratio
+            FROM 
+                (SELECT 
+                    scheme_name,
+                    ((sale_price_per_unit - LAG(sale_price_per_unit) OVER (PARTITION BY scheme_name ORDER BY date_valued)) / LAG(sale_price_per_unit) OVER (PARTITION BY scheme_name ORDER BY date_valued)) * 100 AS daily_return
+                FROM 
+                    fund_data
+                WHERE 
+                    scheme_name = 'Liquid Fund' AND YEAR(date_valued) = 2020) AS daily_returns
+            GROUP BY 
+                scheme_name;
+        """,
+    },
+]
+
+with open("queries.csv", "w", newline="") as csvfile:
+    fieldnames = ["description", "query"]
+    writer = csv.DictWriter(csvfile, fieldnames=fieldnames)
+
+    writer.writeheader()
+    for query in queries:
+        writer.writerow(query)

App/TTS/utils/HeyGen.py

@@ -1,5 +1,22 @@
 import aiohttp
-from App.TTS.Schemas import HeyGenTTSRequest
+
+
+
+from pydantic import BaseModel, Field, validator
+from typing import List, Optional
+import uuid
+class HeyGenTTSRequest(BaseModel):
+    voice_id: str = Field(default="d7bbcdd6964c47bdaae26decade4a933")
+    rate: str = Field(default="1")
+    pitch: str = Field(default="-3%")
+    text: str = "Sample"
+
+    @validator("text")
+    def validate_age(cls, value, values):
+        if not "speak" in value:
+            return f'<speak> <voice name="{values.get("voice_id")}"><prosody rate="{values.get("rate")}" pitch="{values.get("pitch")}">{value}</prosody></voice></speak>'
+        else:
+            return value
 
 
 class HeygenAPI:
@@ -82,3 +99,23 @@ class HeygenAPI:
 
     async def __aexit__(self, exc_type, exc_value, traceback):
         await self.close_session()
+
+
+async def main():
+    data = {
+        "account": "mebaxo5916@tospage.com",
+        "password": "HBBHN4RPs_rA$%R",
+        "token":'+DTX2g=='
+    }
+    async with HeygenAPI(**data) as heygen:
+        req = HeyGenTTSRequest(
+            text="Hello, this is a test",
+            # voice_id="1",
+        )
+        response = await heygen.tts_request(req)
+        print(response)
+
+if __name__ == "__main__":
+    import asyncio
+
+    asyncio.run(main())

App/TTS/utils/Initialize.py

@@ -0,0 +1 @@
+

App/app.py

@@ -3,8 +3,8 @@ from fastapi import FastAPI
 from fastapi.middleware.gzip import GZipMiddleware
 
 from .TTS.TTSRoutes import tts_router
-from .Embedding.EmbeddingRoutes import embeddigs_router
-from .Chat.PoeChatrouter import chat_router
+# from .Embedding.EmbeddingRoutes import embeddigs_router
+# from .Chat.PoeChatrouter import chat_router
 
 from fastapi.middleware.cors import CORSMiddleware
 
@@ -45,6 +45,6 @@ async def landing_page():
     return {"code": 200, "message": "we are back!"}
 
 
-app.include_router(embeddigs_router)
+# app.include_router(embeddigs_router)
 app.include_router(tts_router)
-app.include_router(chat_router)
+# app.include_router(chat_router)

App/voices.json

@@ -0,0 +1,299 @@
+[
+    {
+        "voiceId": "5436957b7d364ce79bc8d37e",
+        "name": "Lucy",
+        "color": "#266DD3",
+        "displayName": "Kylie",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/Lucy.wav",
+        "upgradePlan": null,
+        "myVoice": null
+    },
+    {
+        "voiceId": "2ade011b9fa4443c9af3acd5",
+        "name": "Emma",
+        "color": "#9B4AB8",
+        "displayName": "Emma",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/2ade011b9fa4443c9af3acd5.wav",
+        "upgradePlan": "FREE",
+        "myVoice": null
+    },
+    {
+        "voiceId": "ece80d8188fa4778ab549fd0",
+        "name": "Jennifer",
+        "color": "#FAB400",
+        "displayName": "Jennifer",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/ece80d8188fa4778ab549fd0.wav",
+        "upgradePlan": "FREE",
+        "myVoice": null
+    },
+    {
+        "voiceId": "826cbf58fb1245369a1f5d9b",
+        "name": "Anthony",
+        "color": "#403DBF",
+        "displayName": "Anthony",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/826cbf58fb1245369a1f5d9b.wav",
+        "upgradePlan": "FREE",
+        "myVoice": null
+    },
+    {
+        "voiceId": "9ea55391f75a48edb13e5630",
+        "name": "Sophia",
+        "color": "#FE810E",
+        "displayName": "Sophia",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/9ea55391f75a48edb13e5630.wav",
+        "upgradePlan": "FREE",
+        "myVoice": null
+    },
+    {
+        "voiceId": "5f9b7eb2d2794cb1b85ec8da",
+        "name": "Samantha",
+        "color": "#FAB400",
+        "displayName": "Samantha",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/5f9b7eb2d2794cb1b85ec8da.wav",
+        "upgradePlan": "FREE",
+        "myVoice": null
+    },
+    {
+        "voiceId": "c60166365edf46589657770d",
+        "name": "Ben",
+        "color": "#31A93D",
+        "displayName": "Ben",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/c60166365edf46589657770d.wav",
+        "upgradePlan": "FREE",
+        "myVoice": null
+    },
+    {
+        "voiceId": "d323529cbc79441abc65c0af",
+        "name": "Charlotte",
+        "color": "#358E64",
+        "displayName": "Charlotte",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/d323529cbc79441abc65c0af.wav",
+        "upgradePlan": "FREE",
+        "myVoice": null
+    },
+    {
+        "voiceId": "0ecfaf9c48a24b1da871f20a",
+        "name": "Frank",
+        "color": "#5DB1EE",
+        "displayName": "Frank",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/0ecfaf9c48a24b1da871f20a.wav",
+        "upgradePlan": "FREE",
+        "myVoice": null
+    },
+    {
+        "voiceId": "359adc49dbaa4de0b4a19c49",
+        "name": "Logan",
+        "color": "#BA324F",
+        "displayName": "Logan",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/359adc49dbaa4de0b4a19c49.wav",
+        "upgradePlan": "FREE",
+        "myVoice": null
+    },
+    {
+        "voiceId": "2e7c549a1fcf4efba133f73e",
+        "name": "Matthew",
+        "color": "#18BCB2",
+        "displayName": "Matthew",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/2e7c549a1fcf4efba133f73e.wav",
+        "upgradePlan": "FREE",
+        "myVoice": null
+    },
+    {
+        "voiceId": "6a1b284fdf8f43658e0d962c",
+        "name": "Michael",
+        "color": "#FF5B5B",
+        "displayName": "Michael",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/6a1b284fdf8f43658e0d962c.wav",
+        "upgradePlan": "FREE",
+        "myVoice": null
+    },
+    {
+        "voiceId": "d4d49ad195fd4877a9b40b2d",
+        "name": "Robert",
+        "color": "#A8C012",
+        "displayName": "Robert",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/d4d49ad195fd4877a9b40b2d.wav",
+        "upgradePlan": "FREE",
+        "myVoice": null
+    },
+    {
+        "voiceId": "2a55f0fcdca345cda94c262a",
+        "name": "Victoria",
+        "color": "#653BBE",
+        "displayName": "Victoria",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/2a55f0fcdca345cda94c262a.wav",
+        "upgradePlan": "FREE",
+        "myVoice": null
+    },
+    {
+        "voiceId": "44580aaacdc64fa6a0e3c3fe",
+        "name": "Lucas",
+        "color": "#CD42B7",
+        "displayName": "Lucas",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/44580aaacdc64fa6a0e3c3fe.wav",
+        "upgradePlan": "FREE",
+        "myVoice": null
+    },
+    {
+        "voiceId": "9785244c974b4c70a259ef93",
+        "name": "John",
+        "color": "#5DB1EE",
+        "displayName": "John",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/9785244c974b4c70a259ef93.wav",
+        "upgradePlan": "FREE",
+        "myVoice": null
+    },
+    {
+        "voiceId": "2b14a70f78c248e28200d7a6",
+        "name": "Olivia",
+        "color": "#2596BE",
+        "displayName": "Olivia",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/2b14a70f78c248e28200d7a6.WAV",
+        "upgradePlan": "FREE",
+        "myVoice": null
+    },
+    {
+        "voiceId": "38de550f4c9b46ea816579d9",
+        "name": "William",
+        "color": "#D62839",
+        "displayName": "Daniel",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/William.wav",
+        "upgradePlan": null,
+        "myVoice": null
+    },
+    {
+        "voiceId": "f96e2bf4fea54decaf7d1ab1",
+        "name": "Nadia",
+        "color": "#E16036",
+        "displayName": "Maria",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/Nadia.wav",
+        "upgradePlan": null,
+        "myVoice": null
+    },
+    {
+        "voiceId": "348743483218608",
+        "name": "en-US-Wavenet-G",
+        "color": "#008080",
+        "displayName": "Sunshine",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/Sunshine.wav",
+        "upgradePlan": null,
+        "myVoice": null
+    },
+    {
+        "voiceId": "348743483218605",
+        "name": "en-US-Wavenet-D",
+        "color": "#FF5722",
+        "displayName": "Kenny",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/Kenny.wav",
+        "upgradePlan": null,
+        "myVoice": null
+    },
+    {
+        "voiceId": "348743483218600",
+        "name": "en-US-Standard-D",
+        "color": "#673AB7",
+        "displayName": "Andrew",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/Andrew.wav",
+        "upgradePlan": null,
+        "myVoice": null
+    },
+    {
+        "voiceId": "348743483218601",
+        "name": "en-US-Standard-H",
+        "color": "#3F51B5",
+        "displayName": "Melissa",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/Melissa.wav",
+        "upgradePlan": null,
+        "myVoice": null
+    },
+    {
+        "voiceId": "348743483218602",
+        "name": "en-US-Wavenet-A",
+        "color": "#AB47BC",
+        "displayName": "Martin",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/Martin.wav",
+        "upgradePlan": null,
+        "myVoice": null
+    },
+    {
+        "voiceId": "348743483218603",
+        "name": "en-US-Wavenet-B",
+        "color": "#A167A5",
+        "displayName": "James",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/James.wav",
+        "upgradePlan": null,
+        "myVoice": null
+    },
+    {
+        "voiceId": "348743483218604",
+        "name": "en-US-Wavenet-C",
+        "color": "#E91E63",
+        "displayName": "Caitlyn",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/Caitlyn.wav",
+        "upgradePlan": null,
+        "myVoice": null
+    },
+    {
+        "voiceId": "348743483218612",
+        "name": "en-AU-Wavenet-B",
+        "color": "#867AE9",
+        "displayName": "Russel",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/Russel.wav",
+        "upgradePlan": null,
+        "myVoice": null
+    },
+    {
+        "voiceId": "348743483218606",
+        "name": "en-US-Wavenet-E",
+        "color": "#F08700",
+        "displayName": "Arianna",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/Arianna.wav",
+        "upgradePlan": null,
+        "myVoice": null
+    },
+    {
+        "voiceId": "348743483218607",
+        "name": "en-US-Wavenet-F",
+        "color": "#FFC107",
+        "displayName": "Sisilia",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/Sisilia.wav",
+        "upgradePlan": null,
+        "myVoice": null
+    },
+    {
+        "voiceId": "348743483218613",
+        "name": "en-GB-Wavenet-F",
+        "color": "#C449C2",
+        "displayName": "Diana",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/Diana.wav",
+        "upgradePlan": null,
+        "myVoice": null
+    },
+    {
+        "voiceId": "348743483218609",
+        "name": "en-US-Wavenet-H",
+        "color": "#53BB8D",
+        "displayName": "Mia",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/Mia.wav",
+        "upgradePlan": null,
+        "myVoice": null
+    },
+    {
+        "voiceId": "348743483218610",
+        "name": "en-US-Wavenet-I",
+        "color": "#1092F9",
+        "displayName": "Fred",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/Fred.wav",
+        "upgradePlan": null,
+        "myVoice": null
+    },
+    {
+        "voiceId": "348743483218611",
+        "name": "en-US-Wavenet-J",
+        "color": "#00BCD4",
+        "displayName": "Vincent",
+        "fileUrl": "https://storage.googleapis.com/podcastle-prod-public/Voices%20preview/Vincent.wav",
+        "upgradePlan": null,
+        "myVoice": null
+    }
+]

gradio-app.py

@@ -0,0 +1,96 @@
+import gradio as gr
+import asyncio
+import copy
+import json
+import base64
+from io import BytesIO
+import IPython.display as ipd
+from watchgod import awatch
+from Complete import (
+    Speak,
+    Transcriber,
+    MovieDescriptionProcessor,
+)  # Replace 'your_script' with your actual module name
+
+tts_client = Speak()
+movie_processor = MovieDescriptionProcessor()
+
+
+# Gradio app function
+def gradio_app(movie_name, year, media_type, original_language, go_button):
+    if go_button:
+        print("here")
+        # Construct the message for movie description
+        message = movie_processor.prompt_fetcher()
+        message = message.format(
+            media_type=media_type,
+            movie_name=movie_name,
+            original_language=original_language,
+            movie_year=year,
+        )
+
+        # Process movie description
+        script = asyncio.run(movie_processor.process_movie_description(message))
+
+        # Generate image descriptions
+        message, result = movie_processor.prompt_fetcher("images").split("{format}")
+        message = message.format(script=script) + result
+        images_descriptions = asyncio.run(
+            movie_processor.process_movie_description(message, "Assistant")
+        )
+        image_json = movie_processor.extract_json_from_markdown(images_descriptions)
+
+        # Generate audio file
+        audio_file_path = asyncio.run(tts_client.say(script))
+
+        # Create an instance of the Transcriber class
+        transcriber = Transcriber(audio_file_path)
+
+        # Perform the transcription task
+        asyncio.run(transcriber.transcribe())
+
+        # Download the JSON transcription to a file
+        output_json_path = "./output.json"  # Replace with the desired output path
+        asyncio.run(transcriber.download_transcription(output_json_path))
+
+        # Return the outputs
+        return {
+            "image_json": image_json,
+            "audio_file": {"name": "audio_file.wav", "file_path": audio_file_path},
+            "tts_json": {"name": "tts_output.json", "file_path": output_json_path},
+        }
+    return None
+
+
+# Define Gradio inputs
+inputs = [
+    gr.Textbox(placeholder="Avatar", label="Movie Name"),
+    gr.Textbox(placeholder="2023", label="Year"),
+    gr.Radio(choices=["movie", "tv series"], label="Media Type"),
+    gr.Dropdown(choices=["English", "Spanish"], label="Original Language"),
+    gr.Button("go_button"),
+]
+
+
+# Define Gradio outputs
+outputs = [
+    gr.Textbox("image_json", label="Image JSON"),
+    # gr.File("audio_file", label="Audio File"),
+    # gr.File("tts_json", label="TTS JSON")
+]
+
+# Create the Gradio interface
+iface = gr.Interface(fn=gradio_app, inputs=inputs, outputs=outputs, live=True)
+
+
+# Launch the Gradio app
+async def restart_gradio():
+    async for changes in awatch(".", watcher_cls=watchgod.DefaultDirWatcher):
+        await iface.close()
+        iface.launch()
+
+
+# Run Gradio interface and hot-reloading
+loop = asyncio.get_event_loop()
+loop.create_task(restart_gradio())
+iface.launch()

litellm_uuid.txt

@@ -0,0 +1 @@
+8eb83e0c-0450-4a95-95cb-2c9544c27526

queries.csv

@@ -0,0 +1,185 @@
+description,query
+Get all records from fund_data,SELECT * FROM fund_data;
+Get all records from fund_data,SELECT * FROM fund_data;
+Get all unique fund names,SELECT DISTINCT scheme_name FROM fund_data;
+Get the latest price for each fund,"
+            SELECT scheme_name, sale_price_per_unit
+            FROM fund_data
+            WHERE (scheme_name, date_valued) IN (
+                SELECT scheme_name, MAX(date_valued)
+                FROM fund_data
+                GROUP BY scheme_name
+            );
+        "
+Get the total sale_price_per_unit for each fund,"SELECT scheme_name, SUM(sale_price_per_unit) FROM fund_data GROUP BY scheme_name;"
+Get the number of records for each fund,"SELECT scheme_name, COUNT(*) FROM fund_data GROUP BY scheme_name;"
+Get the earliest and latest date_valued for each fund,"SELECT scheme_name, MIN(date_valued), MAX(date_valued) FROM fund_data GROUP BY scheme_name;"
+Get the sale_price_per_unit for the latest date_valued for each fund,"
+        SELECT scheme_name, sale_price_per_unit
+        FROM fund_data
+        WHERE date_valued = (
+            SELECT MAX(date_valued)
+            FROM fund_data AS fd
+            WHERE fd.scheme_name = fund_data.scheme_name
+        );
+    "
+Get the fund with the highest average sale_price_per_unit for each year,"
+        SELECT YEAR(date_valued) AS year, scheme_name, AVG(sale_price_per_unit) AS avg_price
+        FROM fund_data
+        GROUP BY year, scheme_name
+        ORDER BY avg_price DESC;
+    "
+Get the fund with the highest total sale_price_per_unit for each month in 2020,"
+        SELECT MONTH(date_valued) AS month, scheme_name, SUM(sale_price_per_unit) AS total_price
+        FROM fund_data
+        WHERE YEAR(date_valued) = 2020
+        GROUP BY month, scheme_name
+        ORDER BY total_price DESC;
+    "
+Get the top 3 funds with the highest average sale_price_per_unit for each quarter in 2020,"
+        SELECT QUARTER(date_valued) AS quarter, scheme_name, AVG(sale_price_per_unit) AS avg_price
+        FROM fund_data
+        WHERE YEAR(date_valued) = 2020
+        GROUP BY quarter, scheme_name
+        ORDER BY avg_price DESC
+        LIMIT 3;
+    "
+Get the fund with the highest sale_price_per_unit for the last date_valued of each month in 2020,"
+        SELECT scheme_name, sale_price_per_unit
+        FROM fund_data
+        WHERE date_valued IN (
+            SELECT MAX(date_valued)
+            FROM fund_data
+            WHERE YEAR(date_valued) = 2020
+            GROUP BY MONTH(date_valued)
+        )
+        ORDER BY sale_price_per_unit DESC;
+    "
+Get the fund with the lowest average sale_price_per_unit,"
+        SELECT scheme_name, AVG(sale_price_per_unit) AS avg_price
+        FROM fund_data
+        GROUP BY scheme_name
+        ORDER BY avg_price ASC
+        LIMIT 1;
+    "
+Get the date with the highest total sale_price_per_unit for all funds,"
+        SELECT date_valued, SUM(sale_price_per_unit) AS total_price
+        FROM fund_data
+        GROUP BY date_valued
+        ORDER BY total_price DESC
+        LIMIT 1;
+    "
+Get the fund with the most records in the database,"
+        SELECT scheme_name, COUNT(*) AS count
+        FROM fund_data
+        GROUP BY scheme_name
+        ORDER BY count DESC
+        LIMIT 1;
+    "
+Get the date with the most records in the database,"
+        SELECT date_valued, COUNT(*) AS count
+        FROM fund_data
+        GROUP BY date_valued
+        ORDER BY count DESC
+        LIMIT 1;
+    "
+Get the fund with the highest sale_price_per_unit on the latest date_valued,"
+        SELECT scheme_name, sale_price_per_unit
+        FROM fund_data
+        WHERE date_valued = (
+            SELECT MAX(date_valued)
+            FROM fund_data
+        )
+        ORDER BY sale_price_per_unit DESC
+        LIMIT 1;
+    "
+Get the percentage change in average sale_price_per_unit from the previous month for each fund in 2020,"
+        SELECT scheme_name, MONTH(date_valued) AS month, 
+        ((AVG(sale_price_per_unit) - LAG(AVG(sale_price_per_unit)) OVER (PARTITION BY scheme_name ORDER BY month)) / LAG(AVG(sale_price_per_unit)) OVER (PARTITION BY scheme_name ORDER BY month)) * 100 AS pct_change
+        FROM fund_data
+        WHERE YEAR(date_valued) = 2020
+        GROUP BY scheme_name, month;
+    "
+Get the top 5 funds with the highest average sale_price_per_unit,"
+        SELECT scheme_name, AVG(sale_price_per_unit) AS avg_price
+        FROM fund_data
+        GROUP BY scheme_name
+        ORDER BY avg_price DESC
+        LIMIT 5;
+    "
+Calculate percentage return of funds in 2020,"
+            SELECT 
+                start_price.scheme_name, 
+                ((end_price.sale_price_per_unit - start_price.sale_price_per_unit) / start_price.sale_price_per_unit) * 100 AS percentage_return
+            FROM 
+                (SELECT scheme_name, sale_price_per_unit
+                FROM fund_data
+                WHERE scheme_name IN ('Liquid Fund', 'Bond Fund') AND date_valued = (SELECT MIN(date_valued) FROM fund_data WHERE scheme_name = fund_data.scheme_name)
+                GROUP BY scheme_name) AS start_price,
+                (SELECT scheme_name, sale_price_per_unit
+                FROM fund_data
+                WHERE scheme_name IN ('Liquid Fund', 'Bond Fund') AND date_valued = (SELECT MAX(date_valued) FROM fund_data WHERE scheme_name = fund_data.scheme_name)
+                GROUP BY scheme_name) AS end_price
+            WHERE start_price.scheme_name = end_price.scheme_name;
+        "
+Calculate Sharpe Ratio of Liquid Fund in 2020,"
+            SELECT 
+                scheme_name,
+                AVG(daily_return) AS avg_return,
+                STDDEV_POP(daily_return) AS std_dev,
+                (AVG(daily_return) - 12) / STDDEV_POP(daily_return) AS sharpe_ratio
+            FROM 
+                (SELECT 
+                    scheme_name,
+                    ((sale_price_per_unit - LAG(sale_price_per_unit) OVER (PARTITION BY scheme_name ORDER BY date_valued)) / LAG(sale_price_per_unit) OVER (PARTITION BY scheme_name ORDER BY date_valued)) * 100 AS daily_return
+                FROM 
+                    fund_data
+                WHERE 
+                    scheme_name = 'Liquid Fund' AND YEAR(date_valued) = 2020) AS daily_returns
+            GROUP BY 
+                scheme_name;
+        "
+Get the total number of records in fund_data,SELECT COUNT(*) FROM fund_data;
+Get the average sale_price_per_unit for each fund,"SELECT scheme_name, AVG(sale_price_per_unit) FROM fund_data GROUP BY scheme_name;"
+Get all unique fund names,SELECT DISTINCT scheme_name FROM fund_data;
+Get the latest price for each fund,"
+            SELECT scheme_name, sale_price_per_unit
+            FROM fund_data
+            WHERE (scheme_name, date_valued) IN (
+                SELECT scheme_name, MAX(date_valued)
+                FROM fund_data
+                GROUP BY scheme_name
+            );
+        "
+Calculate percentage return of funds in 2020,"
+            SELECT 
+                start_price.scheme_name, 
+                ((end_price.sale_price_per_unit - start_price.sale_price_per_unit) / start_price.sale_price_per_unit) * 100 AS percentage_return
+            FROM 
+                (SELECT scheme_name, sale_price_per_unit
+                FROM fund_data
+                WHERE scheme_name IN ('Liquid Fund', 'Bond Fund') AND date_valued = (SELECT MIN(date_valued) FROM fund_data WHERE scheme_name = fund_data.scheme_name)
+                GROUP BY scheme_name) AS start_price,
+                (SELECT scheme_name, sale_price_per_unit
+                FROM fund_data
+                WHERE scheme_name IN ('Liquid Fund', 'Bond Fund') AND date_valued = (SELECT MAX(date_valued) FROM fund_data WHERE scheme_name = fund_data.scheme_name)
+                GROUP BY scheme_name) AS end_price
+            WHERE start_price.scheme_name = end_price.scheme_name;
+        "
+Calculate Sharpe Ratio of Liquid Fund in 2020,"
+            SELECT 
+                scheme_name,
+                AVG(daily_return) AS avg_return,
+                STDDEV_POP(daily_return) AS std_dev,
+                (AVG(daily_return) - 12) / STDDEV_POP(daily_return) AS sharpe_ratio
+            FROM 
+                (SELECT 
+                    scheme_name,
+                    ((sale_price_per_unit - LAG(sale_price_per_unit) OVER (PARTITION BY scheme_name ORDER BY date_valued)) / LAG(sale_price_per_unit) OVER (PARTITION BY scheme_name ORDER BY date_valued)) * 100 AS daily_return
+                FROM 
+                    fund_data
+                WHERE 
+                    scheme_name = 'Liquid Fund' AND YEAR(date_valued) = 2020) AS daily_returns
+            GROUP BY 
+                scheme_name;
+        "

sample.py

@@ -0,0 +1,77 @@
+# ---
+# lambda-test: false
+# ---
+# # Stable Diffusion (A1111)
+#
+# This example runs the popular [AUTOMATIC1111/stable-diffusion-webui](https://github.com/AUTOMATIC1111/stable-diffusion-webui)
+# project on Modal, without modification. We start a Modal container with an A10G GPU, run the server as a
+# subprocess, and forward the port using a [tunnel](/docs/guide/tunnels).
+
+import socket
+import subprocess
+import time
+import webbrowser
+
+from modal import Image, Queue, Stub, forward
+
+stub = Stub("fooocus")
+stub.urls = Queue.new()  # TODO: FunctionCall.get() doesn't support generators.
+
+
+def wait_for_port(port: int):
+    while True:
+        try:
+            with socket.create_connection(("127.0.0.1", port), timeout=5.0):
+                break
+        except OSError:
+            time.sleep(0.1)
+
+
+# The following function starts the web UI container. Notice that it requires a few steps to
+# install dependencies, since `stable-diffusion-webui` doesn't come with a prepackaged script
+# to do this. (It usually installs dependencies on first launch.)
+#
+# After defining the custom container image, we start the server with `accelerate launch`. This
+# function is also where you would configure hardware resources, CPU/memory, and timeouts.
+#
+# If you want to run it with an A100 GPU, just change `gpu="a10g"` to `gpu="a100"`.
+
+
+@stub.function(
+    image=Image.debian_slim()
+    .apt_install("wget", "git")
+    .run_commands(
+        "pip install pygit2==1.12.2",
+        "git clone https://github.com/lllyasviel/Fooocus.git",
+        "pip install -r /Fooocus/requirements_versions.txt",
+        gpu="a10g",
+    ),
+    gpu="a10g",
+    cpu=2,
+    memory=1024,
+    timeout=3600,
+)
+def start_web_ui():
+    START_COMMAND = r"""
+        python /Fooocus/entry_with_update.py --share
+"""
+    with forward(7860) as tunnel:
+        p = subprocess.Popen(START_COMMAND, shell=True)
+        wait_for_port(7860)
+        print("[MODAL] ==> Accepting connections at", tunnel.url)
+        stub.urls.put(tunnel.url)
+        p.wait(3600)
+
+
+# The first run may take a few minutes to build the image. When the container starts, it will open
+# the page in your browser.
+
+
+@stub.local_entrypoint()
+def main(no_browser: bool = False):
+    start_web_ui.spawn()
+    url = stub.urls.get()
+    if not no_browser:
+        webbrowser.open(url)
+    while True:  # TODO: FunctionCall.get() doesn't support generators.
+        time.sleep(1)