wozwize commited on
Commit
163d201
·
1 Parent(s): f98b162

updating to AsyncClient

Browse files
Files changed (4) hide show
  1. Dockerfile +1 -1
  2. app/main.py +2 -2
  3. app/routers/analyze.py +2 -2
  4. tests/test_supabase.py +2 -2
Dockerfile CHANGED
@@ -16,7 +16,7 @@ RUN pip install git+https://github.com/supabase/supabase-py.git
16
 
17
  # Copy dependencies
18
  COPY requirements.txt .
19
- RUN pip install --no-cache-dir -r requirements.txt
20
 
21
  # Copy all files
22
  COPY . .
 
16
 
17
  # Copy dependencies
18
  COPY requirements.txt .
19
+ RUN pip install -r requirements.txt
20
 
21
  # Copy all files
22
  COPY . .
app/main.py CHANGED
@@ -1,7 +1,7 @@
1
  import os
2
  from fastapi import FastAPI
3
  from fastapi.middleware.cors import CORSMiddleware
4
- from supabase import create_client
5
  from app.routers import analyze, health
6
 
7
  # FastAPI app setup
@@ -21,7 +21,7 @@ SUPABASE_URL = os.getenv("SUPABASE_URL")
21
  SUPABASE_KEY = os.getenv("SUPABASE_KEY")
22
 
23
  if SUPABASE_URL and SUPABASE_KEY:
24
- supabase = create_client(SUPABASE_URL, SUPABASE_KEY)
25
  print("Connected to Supabase successfully!")
26
  else:
27
  print("Supabase connection failed. Please check your secrets.")
 
1
  import os
2
  from fastapi import FastAPI
3
  from fastapi.middleware.cors import CORSMiddleware
4
+ from supabase import create_client, AsyncClient
5
  from app.routers import analyze, health
6
 
7
  # FastAPI app setup
 
21
  SUPABASE_KEY = os.getenv("SUPABASE_KEY")
22
 
23
  if SUPABASE_URL and SUPABASE_KEY:
24
+ supabase = AsyncClient(SUPABASE_URL, SUPABASE_KEY)
25
  print("Connected to Supabase successfully!")
26
  else:
27
  print("Supabase connection failed. Please check your secrets.")
app/routers/analyze.py CHANGED
@@ -3,7 +3,7 @@ from pydantic import BaseModel, HttpUrl
3
  from typing import Dict, Any, List
4
  import logging
5
  import os
6
- from supabase import create_client
7
 
8
  from mediaunmasked.scrapers.article_scraper import ArticleScraper
9
  from mediaunmasked.analyzers.scoring import MediaScorer
@@ -21,7 +21,7 @@ scorer = MediaScorer()
21
  # Initialize Supabase connection (works for async environments)
22
  SUPABASE_URL = os.getenv("SUPABASE_URL")
23
  SUPABASE_KEY = os.getenv("SUPABASE_KEY")
24
- supabase = create_client(SUPABASE_URL, SUPABASE_KEY) # This works for async
25
 
26
  class ArticleRequest(BaseModel):
27
  url: HttpUrl
 
3
  from typing import Dict, Any, List
4
  import logging
5
  import os
6
+ from supabase import create_client, AsyncClient
7
 
8
  from mediaunmasked.scrapers.article_scraper import ArticleScraper
9
  from mediaunmasked.analyzers.scoring import MediaScorer
 
21
  # Initialize Supabase connection (works for async environments)
22
  SUPABASE_URL = os.getenv("SUPABASE_URL")
23
  SUPABASE_KEY = os.getenv("SUPABASE_KEY")
24
+ supabase = AsyncClient(SUPABASE_URL, SUPABASE_KEY) # This works for async
25
 
26
  class ArticleRequest(BaseModel):
27
  url: HttpUrl
tests/test_supabase.py CHANGED
@@ -1,5 +1,5 @@
1
  import configparser
2
- from supabase import create_client
3
 
4
  # Read the properties file
5
  config = configparser.ConfigParser()
@@ -10,7 +10,7 @@ SUPABASE_URL = config.get('DEFAULT', 'SUPABASE_URL')
10
  SUPABASE_KEY = config.get('DEFAULT', 'SUPABASE_KEY')
11
 
12
  # Initialize Supabase client
13
- supabase = create_client(SUPABASE_URL, SUPABASE_KEY)
14
 
15
  # Test data to insert and update
16
  test_url = "https://www.straitstimes.com/world/united-states/us-senate-confirms-trump-loyalist-kash-patel-to-head-fbi"
 
1
  import configparser
2
+ from supabase import create_client, AsyncClient
3
 
4
  # Read the properties file
5
  config = configparser.ConfigParser()
 
10
  SUPABASE_KEY = config.get('DEFAULT', 'SUPABASE_KEY')
11
 
12
  # Initialize Supabase client
13
+ supabase = AsyncClient(SUPABASE_URL, SUPABASE_KEY)
14
 
15
  # Test data to insert and update
16
  test_url = "https://www.straitstimes.com/world/united-states/us-senate-confirms-trump-loyalist-kash-patel-to-head-fbi"