#! /usr/bin/python3

# Import Built-Ins
import time
import random
import json
import requests
import threading
import traceback
from base64 import b64encode
from os import urandom
from threading import Thread
from functools import lru_cache
import socket
import shutil

# Import Third-Party
from abc import ABCMeta, abstractmethod
from skpy import Skype, SkypeNewMessageEvent, SkypeEventLoop, SkypeMsg

#python3 -m pip install -U discord.py
import discord
import asyncio


USERNAME = ""
PASSWORD = ""
#GROUP_URL = 'https://join.skype.com/icRoAW12SZfE'
GROUP_URL = "https://join.skype.com/T2FY7ggzID5k"

new_message = []
stick_channel = "relay_bot_test"

client = discord.Client()

@client.event
async def on_ready():
    print("Discord ok")
    #print(client.user.name)
    #print(client.user.id)
    print('------')

async def send_new_message(message):
    try:
        await client.send_message(stick_channel, message)
    except Exception as e:
        print(e)

@client.event
async def on_message(message):
    if not str(message.author) == "wojtekjBOT#2057":
        if message.content.startswith('!cat'):
            try:
                await client.send_file(message.channel,"cat.jpg", filename=None, content=None, tts=False)
                try:
                	url = 'http://thecatapi.com/api/images/get?type=jpg&size=med'
                	response = requests.get(url, stream=True)
                	with open('cat.jpg', 'wb') as out_file:
                		shutil.copyfileobj(response.raw, out_file)
                	del response
                except:
                	print("Error downloading cat")
            except Exception as e:
                print("Didnt found a cat: "+str(e))

        elif message.content.startswith('!stick'):
            global stick_channel
            stick_channel = message.channel
            print(message.channel)
            await client.send_message(message.channel, "I'm going to spam here!")
        else:
            print("Discord: "+str(message.content))
            push("skype", str(message.author), str(message.content))

def push(platform, user, message):
    try:
        if platform == "skype":
            print("Pushing to skype")
            global new_message
            new_message.append("["+user+"]: "+message)
            x.write_message()

        elif platform == "discord":
            print("Pushing to discord")
            text = "["+user+"]: "+message
            run_until_complete(send_new_message(text)) # BUG HEREEEEEEEE CANT CALL IT

    except Exception as e:
        print("Error in push: "+str(e))

class SkypeBot(SkypeEventLoop):
    def __init__(self):
        super(SkypeBot, self).__init__(USERNAME, PASSWORD)
        self.skype = Skype(USERNAME, PASSWORD)
        chat_group_id = self.chats.urlToIds(GROUP_URL).get('id')
        self.chat_group = self.chats.chat(chat_group_id)
        print("Skype ok")

    def write_message(self):
        global new_message
        message = new_message.pop(0)
        print("Sending skype: " +str(message))
        self.chat_group.sendMsg(message)

    def onEvent(self, event):
        if isinstance(event, SkypeNewMessageEvent):
            msg = {"username":event.msg.userId, "message_string":event.msg.content}
            if msg["username"] != self.userId:
                print("Skype:" +msg["message_string"])
                push("discord", str(msg["username"]), str(msg["message_string"]))

x = SkypeBot()

t = threading.Thread(target=x.loop)
t.start()


#CLIENT_ID = "344449945862144000
client.run('MzQ0NDQ5OTQ1ODYyMTQ0MDAw.DGts6w.GJryM1GoNIoCoCMk6eWvKpgUgGY')