import logging
import os
from io import BytesIO

import requests
from PIL import Image
from smart_open import open

TEST_PHOTO = "https://upload.wikimedia.org/wikipedia/commons/thumb/5/5b/Jervis_Bay_nuclear_plant_site.JPG/650px-Jervis_Bay_nuclear_plant_site.JPG"


S3_EXPORT_DEFAULT_BUCKET = "s3://photos.opennem.org.au/"


UPLOAD_ARGS = {
    "ContentType": "image/jpeg",
}


logging.basicConfig(level=logging.INFO)

logger = logging.getLogger(__name__)
logger.setLevel(logging.INFO)

from opennem.db import SessionLocal
from opennem.db.models.opennem import Photo


def write_photo_to_s3(file_path: str, data):
    s3_save_path = os.path.join(S3_EXPORT_DEFAULT_BUCKET, file_path)
    write_count = 0

    with open(
        s3_save_path,
        "wb",
        transport_params=dict(multipart_upload_kwargs=UPLOAD_ARGS),
    ) as fh:
        write_count = fh.write(data)

    logger.info("Wrote {} to {}".format(len(data), s3_save_path))

    return write_count


def photos_process():
    session = SessionLocal()

    photos = session.query(Photo).filter(Photo.processed == False).all()

    # for photo in photos:
    #     r = write_photo_to_s3()


def img_to_buffer(img):
    buf = BytesIO()

    if img.mode in ("RGBA", "P"):
        img = img.convert("RGB")

    img.save(buf, format="JPEG")

    return buf.getbuffer()


def store_photo(photo_url: str):
    img = Image.open(requests.get(photo_url, stream=True).raw)

    save_bugger = BytesIO()
    img.save(save_bugger, format="JPEG")

    write_photo_to_s3("test.jpeg", data=save_bugger.getbuffer())


if __name__ == "__main__":
    photos_process()

import logging
import os
from io import BytesIO

import requests
from PIL import Image
from smart_open import open

TEST_PHOTO = "https://upload.wikimedia.org/wikipedia/commons/thumb/5/5b/Jervis_Bay_nuclear_plant_site.JPG/650px-Jervis_Bay_nuclear_plant_site.JPG"


S3_EXPORT_DEFAULT_BUCKET = "s3://photos.opennem.org.au/"


UPLOAD_ARGS = {
    "ContentType": "image/jpeg",
}


logging.basicConfig(level=logging.INFO)

logger = logging.getLogger(__name__)
logger.setLevel(logging.INFO)

from opennem.db import SessionLocal
from opennem.db.models.opennem import Photo


def write_photo_to_s3(file_path: str, data):
    s3_save_path = os.path.join(S3_EXPORT_DEFAULT_BUCKET, file_path)
    write_count = 0

    with open(
        s3_save_path,
        "wb",
        transport_params=dict(multipart_upload_kwargs=UPLOAD_ARGS),
    ) as fh:
        write_count = fh.write(data)

    logger.info("Wrote {} to {}".format(len(data), s3_save_path))

    return write_count


def photos_process():
    session = SessionLocal()

    photos = session.query(Photo).filter(Photo.processed == False).all()

    # for photo in photos:
    #     r = write_photo_to_s3()


def img_to_buffer(img):
    buf = BytesIO()

    if img.mode in ("RGBA", "P"):
        img = img.convert("RGB")

    img.save(buf, format="JPEG")

    return buf.getbuffer()


def store_photo(photo_url: str):
    img = Image.open(requests.get(photo_url, stream=True).raw)

    save_bugger = BytesIO()
    img.save(save_bugger, format="JPEG")

    write_photo_to_s3("test.jpeg", data=save_bugger.getbuffer())


if __name__ == "__main__":
    photos_process()

# for photo in photos: #     r = write_photo_to_s3()