import logging
import re

from streamlink.plugin import Plugin, pluginmatcher
from streamlink.plugin.api import validate
from streamlink.stream.hls import HLSStream
from streamlink.utils.parse import parse_qsd
from streamlink.utils.url import update_scheme

log = logging.getLogger(__name__)


@pluginmatcher(re.compile(
    r"https?://(?:www\.)?earthcam\.com/"
))
class EarthCam(Plugin):
    _re_json_base = re.compile(r"""var\s+json_base\s*=\s*(?P<json>{.*?});""", re.DOTALL)

    def _get_streams(self):
        data = self.session.http.get(self.url, schema=validate.Schema(
            validate.transform(self._re_json_base.search),
            validate.any(None, validate.all(
                validate.get("json"),
                validate.parse_json(),
                {"cam": {
                    validate.text: {
                        "live_type": validate.text,
                        "html5_streamingdomain": validate.text,
                        "html5_streampath": validate.text,
                        "group": validate.text,
                        "location": validate.text,
                        "title": validate.text,
                        "liveon": validate.text,
                        "defaulttab": validate.text,
                    }
                }},
                validate.get("cam")
            ))
        ))
        if not data:
            return

        cam_name = parse_qsd(self.url).get("cam") or next(iter(data.keys()), None)
        cam_data = data.get(cam_name)
        if not cam_data:
            return

        # exclude everything other than live video streams
        if cam_data["live_type"] != "flashvideo" or cam_data["liveon"] != "true" or cam_data["defaulttab"] != "live":
            return

        log.debug("Found cam {0}".format(cam_name))
        hls_domain = cam_data["html5_streamingdomain"]
        hls_playpath = cam_data["html5_streampath"]

        self.author = cam_data["group"]
        self.category = cam_data["location"]
        self.title = cam_data["title"]

        if hls_playpath:
            hls_url = update_scheme("https://", self.url, "{0}{1}".format(hls_domain, hls_playpath))
            for s in HLSStream.parse_variant_playlist(self.session, hls_url).items():
                yield s


__plugin__ = EarthCam