require 'base64'

class JupytersController < ApplicationController
    include JupyterService
  
    before_action :shixun, only: [:open, :open1, :test, :save]


    def import_with_tpm
        shixun = Shixun.find_by(identifier: params[:identifier])

        upload_file = params["file"] || params["#{params[:file_param_name]}"] # 这里的file_param_name是为了方便其他插件名称
        uid_logger("#########################file_params####{params["#{params[:file]}"]}")
        raise "未上传文件" unless upload_file

        content = Base64.encode64(upload_file.tempfile.read)

        # upload to server
        shixun_tomcat = edu_setting('cloud_bridge')
        uri = "#{shixun_tomcat}/bridge/jupyter/update"
        tpiID = "tpm#{shixun.id}"
        params = {tpiID: tpiID, content: content}

        logger.info "test_juypter: uri->#{uri}, params->#{params}"
        res = uri_post uri, params
        if res && res['code'].to_i != 0
            raise("实训云平台繁忙（繁忙等级：100）")
        end

        render json: {status: 0}
    end

    def save_with_tpi
        myshixun = Myshixun.find_by(identifier: params[:identifier])
        jupyter_save_with_game(myshixun, params[:jupyter_port])
        render json: {status: 0}
    end

    def save_with_tpm
        shixun = Shixun.find_by(identifier: params[:identifier])
        jupyter_save_with_shixun(shixun, params[:jupyter_port])
        render json: {status: 0}
    end

    def get_info_with_tpi
        myshixun = Myshixun.find_by(identifier: params[:identifier])
        url = jupyter_url_with_game(myshixun)
        port = jupyter_port_with_game(myshixun)
        render json: {status: 0, url: url, port: port}
    end

    def get_info_with_tpm
        shixun = Shixun.find_by(identifier: params[:identifier])
        url = jupyter_url_with_shixun(shixun)
        port = jupyter_port_with_shixun(shixun)
        render json: {status: 0, url: url, port: port}
    end

    def reset_with_tpi
        myshixun = Myshixun.find_by(identifier: params[:identifier])
        info = jupyter_tpi_reset(myshixun)
        render json: {status: 0, url: info[:url], port: info[:port]}
    end

    def reset_with_tpm
        shixun = Shixun.find_by(identifier: params[:identifier])
        info = jupyter_tpm_reset(shixun)
        render json: {status: 0, url: info[:url], port: info[:port]}
    end

    def active_with_tpm
        shixun = Shixun.find_by(identifier: params[:identifier])
        jupyter_active_tpm(shixun)
        render json: {status: 0}
    end

    def active_with_tpi
        myshixun = Myshixun.find_by(identifier: params[:identifier])
        jupyter_active_tpi(myshixun)
        render json: {status: 0}
    end

    def timeinfo_with_tpm
        shixun = Shixun.find_by(identifier: params[:identifier])
        info = jupyter_timeinfo_tpm(shixun)
        render json: {status: 0}.merge(info)
    end

    def timeinfo_with_tpi
        myshixun = Myshixun.find_by(identifier: params[:identifier])
        info = jupyter_timeinfo_tpi(myshixun)
        render json: {status: 0}.merge(info)
    end
    

end