# distutils: language=c++
# distutils: extra_compile_args = ["-O3"]
# cython: language_level=3, boundscheck=False, wraparound=False
# cython: cdivision=True

import requests
from bs4 import BeautifulSoup
import os

############################################################################

cpdef scrape():

url='URL here'

page=requests.get(url)

if page.status_code==200:
        print('http request successful')

page.encoding=page.apparent_encoding #Requestで日本語を扱えるようにする．

soup=BeautifulSoup(page.text,'lxml') #html構文解析

today_table=soup.find(id='forecast-point-1h-today') #tableのweather取得 
weather=today_table.find('tr',class_='weather')

data=weather.find_all('p') #dataに今日のデータ格納

# forecasts={"ko":None,"yowa":None,"ame":None,"tuyo":None,"gou":None}
forecasts={}
check=[0,0,0,0,0]
for i in range(len(data)):
        if check[0]==0 and data[i].contents[0]=="小雨":
                forecasts["ko"]=i+1
                check[0]=1
        elif check[1]==0 and data[i].contents[0]=="弱雨":
                forecasts["yowa"]=i+1
                check[1]=1
        elif check[2]==0 and data[i].contents[0]=="雨":
                forecasts["ame"]=i+1
                check[2]=1
        elif check[3]==0 and data[i].contents[0]=="強雨":
                forecasts["tuyo"]=i+1
                check[3]=1
        elif check[4]==0 and data[i].contents[0]=="豪雨":
                forecasts["gou"]=i+1
                check[4]=1


if check[0]==0:
        forecasts["ko"]=None
        check[0]=1
if check[1]==0:
        forecasts["yowa"]=None
        check[1]=1
if check[2]==0:
        forecasts["ame"]=None
        check[2]=1
if check[3]==0:
        forecasts["tuyo"]=None
        check[3]=1
if check[4]==0:
        forecasts["gou"]=None
        check[4]=1

return forecasts
    
    

    
import socket
import gc
import time
from datetime import datetime
################# 音声ファイル作成 #######################
import os
from gtts import gTTS

def make_audio(text):
    japanese=text
    tts = gTTS(japanese, lang='ja')
    tts.save("readaloud.mp3")
    print("making audio finish")

#########################################################
# Scraping cython使ってますがあまり早くなってません．
#########################################################
import scraping 

def make_text():
    result=scraping.scrape()
    print("scraping finish")

    text_time=[]
    text_umb=None

    if (result['yowa']!=None or result['ame']!=None or result['tuyo']!=None or result['gou']!=None):
        text_umb="今日は傘を持っていきましょう．"
    elif result['ko']!=None and (result['yowa']==None and result['ame']==None and result['tuyo']==None and result['gou']==None):
        text_umb="今日は折り畳み傘を持っていきましょう．"
    elif not any(result):
        text_umb="今日は傘を持って行かなくて大丈夫です．"

    keys=list(result.keys())

    now_hour=int(datetime.now().hour)
    for key in keys:
        if result[key]!=None:
            #現在以降の天気を反映させる
            if key=='ko':
                if  result['ko']>=now_hour:
                    time=str(result['ko'])+"時から小雨．"
            elif key=='yowa':
                if  result['yowa']>=now_hour:                
                    time=str(result['yowa'])+"時から弱雨．"
            elif key=='ame':
                if  result['ame']>=now_hour:
                    time=str(result['ame'])+"時から雨．"
            elif key=='tuyo':
                if  result['tuyo']>=now_hour:
                    time=str(result['tuyo'])+"時から強い雨．"
            elif key=='gou':
                if  result['gou']>=now_hour:
                    time=str(result['gou'])+"時から豪雨．"

            text_time.append(time)
    
    if text_umb==None:
        text_full=("今日は傘を持っていく必要はありません．")
    else:
        text_full=text_umb+''.join(text_time)+"です．"
    print("text making finish")
    return text_full


def task1():#audioの作成まで行う．
        text_full=make_text()
        make_audio(text_full)
        gc.collect()#ガベージコレクションの強制実行
    
    

    
#!/usr/bin/env python3

import socket
import gc
import os

import logging

# ログ設定
# logging.basicConfig(
#     filename='/home/kayu/Desktop/weather/main.log',  # ログを記録するファイル名
#     level=logging.INFO,  # 記録するログのレベル（DEBUG, INFO, WARNING, ERROR, CRITICAL）
#     format='%(asctime)s - %(levelname)s - %(message)s',  # ログメッセージのフォーマット
# )

# logging.info("this is run by bash")
#########################################################
# TCP connection
#########################################################

def pico_connect():
    HOST = 'IP adress here'  # Raspberry PiのIPアドレス
    PORT = port num here           # クライアントと同じポート番号

    # ソケットの設定
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    sock.bind((HOST, PORT))
    # try:
    #     sock.bind((HOST, PORT))
    # except Exception as e:
        # logging.info(f"Error binding socket: {e}")
    sock.listen(1)

    # logging.info("waitng for aconnection")
    print('Waiting for a connection...')



    # 接続の確立
    conn, addr = sock.accept()
    print(f'Connected by {addr}')
    # logging.info(f'Connected by {addr}')
    sock.close()



#########################################################
# Reading aloud cythonで読み上げは遅い
#########################################################

################# Japanese ###################
def read_aloud():
    # logging.info("trying to read aloud")
    os.system("/usr/bin/mplayer -speed 1.1 -af scaletempo /home/kayu/Desktop/weather/audio/readaloud.mp3")
    # logging.info("read aloud end")
# ################# English ###################
# english='Japan\'s Health Ministry updated its Q&A page. You can find answers to such questions as how you can avoid catching/spreading the virus, what is the "cough etiquette". '
# tts = gTTS(english, lang='en')
# tts.save("./audio/english.mp3")
# os.system("mplayer ./audio/english.mp3")


#################################
# 実行
#################################
import schedule
import time
from datetime import datetime




def task2():#接続を待って読み上げまで
    pico_connect()
    # logging.info("connect successful")
    read_aloud()
    gc.collect()#ガベージコレクションの強制実行



while True:
    # logging.info("task2 start")
    task2()
    # logging.info("task2 end\n")
    # if datetime.now().hour==3:
    #     break#毎朝3時でmain.py終了
        

gc.collect()#ガベージコレクションの強制実行  
    
    
    

        
    
import time
import network
import machine 
import utime
import socket

HOST='ラズパイip adress'
PORT=port num


# タクトスイッチ(入力)の設定
sw= machine.Pin(19, machine.Pin.IN, machine.Pin.PULL_UP)


led= machine.Pin('LED', machine.Pin.OUT)


led.on()#電源がついたことを知らせる．
time.sleep(1)
led.off()


ssid='wi-fi ssid'
password='wi-fi password'

wlan = network.WLAN(network.STA_IF)
wlan.active(True)
wlan.connect(ssid, password)

max_wait = 10
while max_wait > 0:
    if wlan.status() < 0 or wlan.status() >= 3:
        break
    max_wait -= 1
    print('waiting for connection...')
    time.sleep(1)
    
if wlan.status() != 3:
    raise RuntimeError('network connection failed')
else:
    print('WIFI connected')
    status = wlan.ifconfig()
    print('ip = ' + status[0])


#ユニキャスト
def com_send():
    while True: 
        led.off()
        sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

        sock.connect((HOST, PORT))

        while True:
            if sw.value() == 0:
                led.on()
                print("sending message")   
                message="Read aloud"    
                # メッセージ送信
                sock.send(message.encode('utf-8'))
                print("sending message successful")
                time.sleep(1)
                break
            else:
                print("waiting for pushing button")
                time.sleep(0.2)

        # 通信の終了
        sock.close()
        time.sleep(15)#ラズパイ側が次のソケット開くのを待つ
        led.off()


if __name__ == "__main__":
    com_send()