// ライブラリ読み込み
require './TwistOAuth/src/TwistOAuth.php';
require './TwistOAuth/src/TwistException.php';

class EroorLog{
	public function __construct($str){
		error_log(var_export($arr, true));
	}
}

class result{
    private $bool;
    private $str;
    private $key;
    public function __construct(bool $bool, string $str, string $key=null) {
        $this->bool=$bool;
        $this->str=$str;
        $this->key=$key;
    }
    
    public function result():Array{
        return [
            "flag"=>$this->bool,
            "result"=>($this->bool!=false)?$this->str:"",
            "key"=>$this->key
        ];
    }
}

class main{
    private $str;
    private $password;
    public function __construct(string $str, string $password) {
        $this->str=$str;
        $this->password=$password;
    }

    public function send(){
    //パスワードは正しい。
    try {
        // クレデンシャル生成
        $to = new TwistOAuth(CK, CS, USER_AT, USER_ASE);
        // ツイート
        $status = $to->post('direct_messages/new', [
                "text" => $this->str,
                "user_id"=> RINNA_USER_ID
        ]);
        $message_id=$status->id;
        
        $count=0;
        loop_point:
        
        time_nanosleep(0, 700000000);//0.7秒遅延する
        
        $response = $to->get('direct_messages', [
                "since_id" => $message_id
        ]);
        
        if(++$count<3 && empty($response)){
            goto loop_point;
        }
        
        if(empty($response)){
            //再取得してもりんなは応答していない
            return false;
        }
        
        $str="";
        
        foreach((array)$response as $r){
            if($r->sender->id!=RINNA_USER_ID){
                //りんなじゃないユーザーなので消えてもらう
                continue;
            }
            
            $str.=$r->text;//受け取ったテキストを追記
        }
        

        } catch (TwistException $e) {
            // エラーを表示
            echo "[{$e->getCode()}] {$e->getMessage()}";
			new EroorLog($e->getMessage());
            die();
        }
        
        return $str;
    }
    
    public function exe(){
        //パスワードチェック
        if($this->password!=PASSWORD){
			new EroorLog("パスワード相違");
			return false;
		}
        return $this->send();
    }
}

$inp = json_decode(file_get_contents('php://input')); //$input now contains the jsonobj

$result=(new main($inp->string,$inp->password))->exe();

//[bool メッセージ取得成功可否、具体的に受け取ったメッセージ]をjsonで送信
$json=json_encode((new result($result!=false, $result))->result());
ob_start();
var_dump($json);
$ob =ob_get_contents();
ob_end_clean();
 
$fp = fopen("./dump.txt", "w+" );
fputs($fp, $ob);
fclose( $fp );

echo $json;