Spaces:
Running
Running
File size: 5,027 Bytes
4319b2e |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 |
import io
import requests
import os
import re
import uuid
from PIL import Image, ImageEnhance
from fastapi import APIRouter, Depends
from fastapi.responses import StreamingResponse
from fastapi import UploadFile
from fastapi import *
from fastapi.responses import *
from fastapi.responses import JSONResponse
from fastapi import HTTPException
from dotenv import load_dotenv
from pydantic import BaseModel
from pymongo import MongoClient
from models import *
from RyuzakiLib import AsyicXSearcher
from main import validate_api_key
load_dotenv()
TOOLS_NEW_URL = os.environ["TOOLS_NEW_URL"]
router = APIRouter()
class XnxxSearch(BaseModel):
q: str
class XnxxLinks(BaseModel):
url: str
async def tools_search(
name=None,
parameter=None,
ai_model=None,
upload_check=False
):
if upload_check:
TOOLS_API_URL = f"{TOOLS_NEW_URL}/{ai_model}/{parameter}"
else:
TOOLS_API_URL = f"{TOOLS_NEW_URL}/tools/{name}?{parameter}"
return TOOLS_API_URL
async def toanime(input):
url = await tools_search(
ai_model="ai",
parameter="toanime",
upload_check=True
)
try:
image = Image.open(input)
buffer = io.BytesIO()
image.save(buffer, format='JPEG')
buffer.seek(0)
files = {
'image': ('toanime.jpg', buffer, 'image/jpeg')
}
response = requests.post(
url,
files=files,
headers={
'accept': 'application/json'
}
)
if response.status_code == 200:
data = response.json()
res = {
"image_data": data['result'],
"image_size": data['size']
}
return res
else:
return 'Identifikasi Gagal'
except Exception:
return 'Identifikasi Gagal'
@router.post("/akeno/toanime", response_model=SuccessResponse, responses={422: {"model": SuccessResponse}})
async def toanime(
file: UploadFile = File(...),
api_key: None = Depends(validate_api_key)
):
with open(file_path, "wb") as f:
f.write(await file.read())
try:
response = await toanime(file_path)
url_image = response["image_data"]
return SuccessResponse(
status="True",
randydev={"url": url_image}
)
except:
return SuccessResponse(
status="False",
randydev={"error": "Error fucking"}
)
@router.post("/akeno/xnxxsearch", response_model=SuccessResponse, responses={422: {"model": SuccessResponse}})
async def xnxx_search(
payload: XnxxSearch,
api_key: None = Depends(validate_api_key)
):
url = await tools_search(name="xnxxsearch", parameter=f"q={payload.query}")
try:
response = await AsyicXSearcher.search(url, re_json=True)
result = response["result"]
return SuccessResponse(
status="True",
randydev={"results": result}
)
except:
return SuccessResponse(
status="False",
randydev={"error": "Error fucking"}
)
@router.post("/akeno/xnxx-dl", response_model=SuccessResponse, responses={422: {"model": SuccessResponse}})
async def xnxx_download(
payload: XnxxLinks,
api_key: None = Depends(validate_api_key)
):
url = await tools_search(name="xnxxdl", parameter=f"url={payload.link}")
try:
response = await AsyicXSearcher.search(url, re_json=True)
result = response["result"]
return SuccessResponse(
status="True",
randydev={"results": result}
)
except:
return SuccessResponse(
status="False",
randydev={"error": "Error fucking"}
)
@router.post("/akeno/xnxx-videodl", response_model=SuccessResponse, responses={422: {"model": SuccessResponse}})
async def xnxx_videodl(
payload: XnxxLinks,
api_key: None = Depends(validate_api_key)
):
url = await tools_search(name="xvideosdl", parameter=f"url={payload.link}")
try:
response = await AsyicXSearcher.search(url, re_json=True)
result = response["result"]
return SuccessResponse(
status="True",
randydev={"results": result}
)
except:
return SuccessResponse(
status="False",
randydev={"error": "Error fucking"}
)
@router.post("/akeno/instagramdl", response_model=SuccessResponse, responses={422: {"model": SuccessResponse}})
async def instagramdl(
payload: XnxxLinks,
api_key: None = Depends(validate_api_key)
):
url = await tools_search(name="instagramdl", parameter=f"url={payload.link}")
try:
response = await AsyicXSearcher.search(url, re_json=True)
result = response["result"]
return SuccessResponse(
status="True",
randydev={"results": result}
)
except:
return SuccessResponse(
status="False",
randydev={"error": "Error fucking"}
)
|