Compare commits

..

No commits in common. "24e3f9f2fd77525fffd12634a89ab77363fd9e25" and "f9edbf1bc0bc105461f03cfd3104d9ec0d49de7f" have entirely different histories.

9 changed files with 64 additions and 93 deletions

View file

@ -13,17 +13,14 @@ jobs:
- name: Set up Python
uses: actions/setup-python@v2
with:
python-version: 3.10
python-version: 3.x
- name: Install dependencies
run: |
python -m pip install --upgrade pip
pip install -r requirements.txt
- name: Start API server
env:
MONGO_URI: ${{ secrets.MONGO_URI }}
TEST_NOVA_KEY: ${{ secrets.NOVA_KEY }}
run: |
python run

View file

@ -1,59 +0,0 @@
max-credits: 100001
max-credits-owner: 694201337
start-credits: 1000
costs:
other: 10
chat-models:
gpt-3: 10
gpt-4: 30
gpt-4-32k: 100
## Roles Explanation
# Bonuses: They are a multiplier for costs
# They work like: final_cost = cost * bonus
# Rate limits: Limit the requests of the user
# The rate limit is by how many seconds until a new request can be done.
## TODO: Setup proper rate limit settings for each role
## Current settings are:
## **NOT MEANT FOR PRODUCTION. DO NOT USE WITH THESE SETTINGS.**
roles:
owner:
bonus: 0.1
rate_limit:
other: 60
gpt-3: 60
gpt-4: 35
gpt-4-32k: 5
admin:
bonus: 0.3
rate_limit:
other: 60
gpt-3: 60
gpt-4: 30
gpt-4-32k: 4
helper:
bonus: 0.4
rate_limit:
other: 60
gpt-3: 60
gpt-4: 25
gpt-4-32k: 3
booster:
bonus: 0.5
rate_limit:
other: 60
gpt-3: 60
gpt-4: 20
gpt-4-32k: 2
default:
bonus: 0
rate_limit:
other: 60
gpt-3: 60
gpt-4: 15
gpt-4-32k: 1

19
api/config/credits.yml Normal file
View file

@ -0,0 +1,19 @@
max-credits: 100001
max-credits-owner: 694201337
start-credits: 1000
costs:
other: 10
chat-models:
gpt-3: 10
gpt-4: 30
gpt-4-32k: 100
# bonuses are multiplier for costs:
# final_cost = cost * bonus
bonuses:
owner: 0.1
admin: 0.3
helper: 0.4
booster: 0.5

View file

@ -62,6 +62,5 @@ class StatsManager:
return await db.find_one({obj_filter})
if __name__ == '__main__':
stats = StatsManager()
asyncio.run(stats.add_date())
asyncio.run(stats.add_path('/__demo/test'))
asyncio.run(Stats.add_date())
asyncio.run(Stats.add_path('/__demo/test'))

View file

@ -9,7 +9,7 @@ from motor.motor_asyncio import AsyncIOMotorClient
load_dotenv()
with open('config/config.yml', encoding='utf8') as f:
with open('config/credits.yml', encoding='utf8') as f:
credits_config = yaml.safe_load(f)
## MONGODB Setup

View file

@ -26,12 +26,12 @@ import yaml
load_dotenv()
## Loads config which contains rate limits
with open('config/config.yml', encoding='utf8') as f:
with open('config/credits.yml', encoding='utf8') as f:
config = yaml.safe_load(f)
## Where all rate limit requested data will be stored.
# Rate limit data is **not persistent** (It will be deleted on server stop/restart).
user_last_request_time = {}
# user_last_request_time = {}
DEMO_PAYLOAD = {
'model': 'gpt-3.5-turbo',
@ -93,18 +93,18 @@ async def stream(
## Rate limits user.
# If rate limit is exceeded, error code 429. Otherwise, lets the user pass but notes down
# last request time for future requests.
if user:
role = user.get('role', 'default')
rate_limit = config['roles'].get(role, 1)['rate_limit'].get(payload['model'], 1)
# if user:
# role = user.get('role', 'default')
# rate_limit = config['roles'][role]['rate_limit'].get(payload['model'], 10)
last_request_time = user_last_request_time.get(user['api_key'])
time_since_last_request = datetime.now() - last_request_time
# last_request_time = user_last_request_time.get(user['api_key'])
# time_since_last_request = datetime.datetime.now() - last_request_time
if time_since_last_request < datetime.timedelta(seconds=rate_limit):
yield await errors.yield_error(429, "Rate limit exceeded', 'You are making requests too quickly. Please wait and try again later. Ask a administrator if you think this shouldn't happen. ")
return
else:
user_last_request_time[user['_id']] = datetime.now()
# if time_since_last_request < datetime.timedelta(seconds=rate_limit):
# yield await errors.yield_error(429, 'Rate limit exceeded', "You are making requests too quickly. Please wait and try again later. Ask a administrator if you think this shouldn't happen.")
# return
# else:
# user_last_request_time[user['_id']] = datetime.datetime.now()
## Setup managers
db = UserManager()

View file

@ -16,8 +16,8 @@ load_dotenv()
models_list = json.load(open('models.json'))
with open('config/config.yml', encoding='utf8') as f:
config = yaml.safe_load(f)
with open('config/credits.yml', encoding='utf8') as f:
credits_config = yaml.safe_load(f)
async def handle(incoming_request):
"""
@ -62,7 +62,7 @@ async def handle(incoming_request):
if path_contains_models:
return fastapi.responses.JSONResponse(content=models_list)
costs = config['costs']
costs = credits_config['costs']
cost = costs['other']
if 'chat/completions' in path:
@ -77,8 +77,7 @@ async def handle(incoming_request):
if policy_violation:
return await errors.error(400, f'The request contains content which violates this model\'s policies for "{policy_violation}".', 'We currently don\'t support any NSFW models.')
role = user.get('role', 'default')
role_cost_multiplier = config['roles'].get(role, 1)['bonus']
role_cost_multiplier = credits_config['bonuses'].get(user['role'], 1)
cost = round(cost * role_cost_multiplier)
if user['credits'] < cost:

View file

@ -1,12 +1,15 @@
import sys
# Weird hack because PYTHON IS GOOD LANGUAGE :))))
sys.path.append('../')
from api.db.users import UserManager
import os
from dotenv import load_dotenv
load_dotenv()
async def get_all_users(client):
users = client[os.getenv('MONGO_NAME', 'nova-test')]['users']
return users
async def update_credits(pymongo_client, settings=None):
manager = UserManager()
users = await manager.get_all_users(pymongo_client)
users = await get_all_users(pymongo_client)
if not settings:
users.update_many({}, {'$inc': {'credits': 2500}})
@ -14,4 +17,8 @@ async def update_credits(pymongo_client, settings=None):
else:
for key, value in settings.items():
users.update_many(
{'level': key}, {'$inc': {'credits': int(value)}})
{'level': key},
{'$inc':
{'credits': int(value)}
}
)

View file

@ -10,7 +10,16 @@ from dotenv import load_dotenv
load_dotenv()
MODEL = 'gpt-3.5-turbo'
# MESSAGES = [
# {
# 'role': 'system',
# 'content': 'Always answer with "3", no matter what the user asks for. No exceptions. Just answer with the number "3". Nothing else. Just "3". No punctuation.'
# },
# {
# 'role': 'user',
# 'content': '1+1=',
# },
# ]
MESSAGES = [
{
'role': 'user',