run.py

from fastapi import FastAPI, HTTPException
from fastapi.responses import JSONResponse
from filmpertutti import filmpertutti
from streamingcommunity import streaming_community
from tantifilm import tantifilm
from lordchannel import lordchannel
from streamingwatch import streamingwatch
import json
import config
import logging
from okru import okru_get_url
from animeworld import animeworld
from dictionaries import okru,STREAM
import httpx
# Configure logging
FILMPERTUTTI = config.FILMPERTUTTI
STREAMINGCOMMUNITY = config.STREAMINGCOMMUNITY
MYSTERIUS = config.MYSTERIUS
TUTTIFILM = config.TUTTIFILM
TF_DOMAIN = config.TF_DOMAIN
LORDCHANNEL = config.LORDCHANNEL
STREAMINGWATCH= config.STREAMINGWATCH
ANIMEWORLD = config.ANIMEWORLD
HOST = config.HOST
PORT = int(config.PORT)
HF = config.HF
if HF == "1":
    HF = "🤗️"
    #Cool code to set the hugging face if the service is hosted there.
else:
    HF = ""
if MYSTERIUS == "1":
    from cool import cool

app = FastAPI()
MANIFEST = {
    "id": "org.stremio.mammamia",
    "version": "1.0.5",
    "catalogs": [
        {"type": "tv", "id": "tv_channels", "name": "TV Channels"}
    ],
    "resources": ["stream", "catalog","meta"],
    "types": ["movie", "series", "tv"],
    "name": "Mamma Mia",
    "description": "Addon providing HTTPS Streams for Italian Movies,Series and Live TV! Note that you need to have Kitsu Addon installed in order to watch Anime",
    "logo": "https://creazilla-store.fra1.digitaloceanspaces.com/emojis/49647/pizza-emoji-clipart-md.png"
}



def respond_with(data):
    resp = JSONResponse(data)
    resp.headers['Access-Control-Allow-Origin'] = '*'
    resp.headers['Access-Control-Allow-Headers'] = '*'
    print(data)
    return resp

@app.get('/manifest.json')
def addon_manifest():
    return respond_with(MANIFEST)

@app.get('/')
def root():
    return "Hello, this is a Stremio Addon providing HTTPS Stream for Italian Movies/Series, to install it add /manifest.json to the url and then add it into the Stremio search bar"

@app.get('/catalog/{type}/{id}.json')
def addon_catalog(type, id):
    if type != "tv":
        raise HTTPException(status_code=404)

    catalogs = {"metas": []}
    for channel in STREAM["channels"]:
        catalogs["metas"].append({
            "id": channel["id"],
            "type": "tv",
            "name": channel["title"],
            "poster": channel["poster"],  # Add poster URL if available
            "description": f"Watch {channel['title']}"
        })
    return respond_with(catalogs)
    
@app.get('/meta/tv/{id}.json')
def addon_meta(id: str):
    # Find the channel by ID
    channel = next((ch for ch in STREAM['channels'] if ch['id'] == id), None)
    
    if not channel:
        raise HTTPException(status_code=404, detail="Channel not found")
    
    meta = {
        'meta': {
            'id': channel['id'],
            'type': 'tv',
            'name': channel['name'],
            'poster': channel['poster'],
            'posterShape': 'landscape',
            'description': channel['title'],
            # Additional fields can be added here
            'background': channel['poster'],  # Example of using the same poster as background
            'logo': channel['poster'],  # Example of using the same poster as logo
            'url': channel['url'],  # Using the stream URL as a website link
        }
    }
    return respond_with(meta)


@app.get('/stream/{type}/{id}.json')
async def addon_stream(type, id):
    if type not in MANIFEST['types']:
        raise HTTPException(status_code=404)
    streams = {'streams': []}
    async with httpx.AsyncClient() as client:
        if type == "tv":
            for channel in STREAM["channels"]:
                if channel["id"] == id:
                    streams['streams'].append({
                        'title': channel['name'],
                        'url': channel['url']
                        })
                    if id in okru:
                        channel_url = await okru_get_url(id,client)
                        streams['streams'].append({
                            'title': channel['name'] + "OKRU",
                            'url': channel_url
                        })
            if not streams['streams']:
                raise HTTPException(status_code=404)
            return respond_with(streams)
        else:
            logging.debug(f"Handling movie or series: {id}")
            if "kitsu" in id:
                if ANIMEWORLD == "1":
                    animeworld_urls = await animeworld(id,client)
                    print(animeworld_urls)
                    if animeworld_urls:
                        i = 0
                        for url in animeworld_urls:
                            if url:
                                if i == 0:
                                    title = "Original"
                                elif i == 1:
                                     title = "Italian"
                                streams['streams'].append({'title': f'{HF}Animeworld {title}', 'url': url})
                                i+=1
            else:
                if MYSTERIUS == "1":
                    results = await cool(id,client)
                    if results:
                        for resolution, link in results.items():
                            streams['streams'].append({'title': f'{HF}Mysterious {resolution}', 'url': link})
                if STREAMINGCOMMUNITY == "1":
                    url_streaming_community,url_720_streaming_community,quality_sc = await streaming_community(id,client)
                    if url_streaming_community is not None:
                        if quality_sc == "1080":
                            streams['streams'].append({'title': f'{HF}StreamingCommunity 1080p Max', 'url': url_streaming_community})
                            streams['streams'].append({'title': f'{HF}StreamingCommunity 720p Max', 'url': url_720_streaming_community})
                        else:
                            streams['streams'].append({'title': f'{HF}StreamingCommunity 720p Max', 'url': url_streaming_community})
                if LORDCHANNEL == "1":
                    url_lordchannel,quality_lordchannel = await lordchannel(id,client)
                    if quality_lordchannel == "FULL HD" and url_lordchannel !=  None:
                        streams['streams'].append({'title': f'{HF}LordChannel 1080p', 'url': url_lordchannel})
                    elif url_lordchannel !=  None:
                        streams['streams'].append({'title': f'{HF}LordChannel 720p', 'url': url_lordchannel})            
                if FILMPERTUTTI == "1":
                    url_filmpertutti = await filmpertutti(id,client)
                    if url_filmpertutti is not None:
                        streams['streams'].append({'title': 'Filmpertutti', 'url': url_filmpertutti})
                if TUTTIFILM == "1":
                    url_tuttifilm = await tantifilm(id,client)
                    if url_tuttifilm:
                        if not isinstance(url_tuttifilm, str):
                            for title, url in url_tuttifilm.items():    
                                streams['streams'].append({'title': f'{HF}Tantifilm {title}', 'url': url,  'behaviorHints': {'proxyHeaders': {"request": {"Referer": "https://d000d.com/"}}, 'notWebReady': True}})
                if STREAMINGWATCH == "1":
                    url_streamingwatch = await streamingwatch(id,client)
                    if url_streamingwatch:
                        streams['streams'].append({'title': f'{HF}StreamingWatch 720p', 'url': url_streamingwatch})
        if not streams['streams']:
            raise HTTPException(status_code=404)

    return respond_with(streams)


if __name__ == '__main__':
    import uvicorn
    uvicorn.run("run:app", host=HOST, port=PORT, log_level="info")