importwin.ui;/*DSG{{*/varwinform = win.form(text="斗鱼简易播放器";right=935;bottom=607)

winform.add(

btnFullScreen={cls="button";text="全屏";left=488;top=560;right=584;bottom=592;db=1;dl=1;z=4};

btnView={cls="button";text="查看";left=360;top=560;right=456;bottom=592;db=1;dl=1;z=2};

custom={cls="custom";text="custom";left=16;top=16;right=921;bottom=525;ah=1;aw=1;z=5};

edRoomId={cls="edit";text="https://www.douyu.com/71771";left=120;top=560;right=344;bottom=593;db=1;dl=1;edge=1;multiline=1;z=1};

static={cls="static";text="直播间地址";left=24;top=568;right=104;bottom=592;db=1;dl=1;transparent=1;z=3};

static2={cls="static";text="音量";left=680;top=576;right=720;bottom=594;db=1;dl=1;transparent=1;z=7};

trackbar={cls="trackbar";left=720;top=560;right=904;bottom=590;db=1;dl=1;max=100;min=0;z=6}

)/*}}*/importmpvPlayer;importhpsocket.tcpPullClient;importthread.commandvarmpv = mpvPlayer(winform.custom);vartcpPullClient = hpsocket.tcpPullClient()varthCmd = thread.command()

thCmd.onChat =function(nick, txt){

mpv.setOption("osd-msg1", nick ++"："++ txt );

}varmpvOption = {

["osd-font-size"] = 35;// 字体大小["osd-spacing"] = 2;// 字体间距["osd-align-x"] ="center";// 显示位置["osd-align-y"] ="bottom";

["osd-back-color"] ="#171111";// 背景颜色}for(k,vinmpvOption){

mpv.setOption(k,v)

}varsendData =function(s){vardata = {

int len;

struct msg = {

int len;

wordtype= 689;

byte cryptedField;

byte reservedField;

byte body[] = s;

byte e;

}

}

data.len = raw.sizeof(data.msg)

data.msg.len = data.len

tcpPullClient.send( data,raw.sizeof(data ))

}varloginreq =function(roomId){

sendData("type@=loginreq/roomid@="++ roomId ++"/")

}varjoingroup =function(roomId){

sendData("type@=joingroup/rid@="++ roomId ++"/gid@=-9999/")

}varkeepLive =function(){

sendData("type@=mrkl/")

}vargetFlvUrl =function(link){importcrypt;importweb.json;importinet.http;if!#linkreturnnull,"请填写房间号";

link = string.match( link,"(.+?)$")if!linkreturnnull,"房间号填写有误";varhttp = inet.http()// 获取直播房间详情varhtml = http.get("http://open.douyucdn.cn/api/RoomApi/room/"++ link )if!htmlreturnnull,"网络连接有误";varr = web.json.parse( html )if( r.error !== 0 )returnnull,"数据解析有误，网站可能已更新";varroomId = r.data.room_idvarroomInfo = {

name = r.data.owner_name;

roomName = r.data.room_name;

roomId = roomId

}if( r.data.room_status ==="2"){returnnull,"没有开播";

}varkey ="zNzMV1y4EMxOHS6I5WKm"vart =tonumber(time())varbasicUrl ="http://capi.douyucdn.cn/api/v1/"varpath ="room/"++ roomId ++"?aid=wp&cdn=ws&client_sys=wp&time="++ tvarurl = basicUrl ++ path ++"&auth="++ crypt.md5( path ++ key,false)

html = http.get( url )if( !html ){returnnull,"网络连接有误";

}varr = web.json.parse(html)if( r.error === 0 ){returnr.data.rtmp_url ++"/"++ r.data.rtmp_live, roomInfo;

}returnnull,"数据解析有误，网站可能已更新";

}vartmId;varview =function(link){varurl , roomInfo = win.invoke( getFlvUrl, link )if!urlreturnnull, roomInfo;

tcpPullClient.stop()if( !tcpPullClient.start("openbarrage.douyutv.com",8601,false) )returnnull,"连接斗鱼弹幕服务器失败";

loginreq( roomInfo.roomId)

joingroup(roomInfo.roomId)if( tmId ){

winform.killtimer(tmId)

}

tmId = winform.addtimer(

15000,function(hwnd,msg,id,tick){

keepLive()

}

)

winform.text = roomInfo.name ++"："++ roomInfo.roomName

mpv.command("loadfile", url)returntrue;

}

tcpPullClient.onPullReceive =function(hpTcpPullClient,connId,length){importthread.commandwhile(varmin, remain = 9, length;

;

remain >= min

) {

remain -= 4;varbuf = {INT len};if0 !== hpTcpPullClient.peek( buf, 4 )return;varlen = buf.len;ifremain < lenreturn;

remain -= len;varbufLen = 4+len

buf = raw.buffer( bufLen )if0 !== hpTcpPullClient.fetch( buf, bufLen )return;vars = raw.tostring(buf)if( string.match( s,`type@=(.+?)/`) =="chatmsg"){varnickname = string.match( s,`nn@=(.+?)/`)vartxt = string.match( s,`txt@=(.+?)/`)if( nickname ? txt ){

thread.command.post("onChat", nickname , txt )

}

}

}

}

winform.btnView.oncommand =function(id,event){owner.disabled =truevarlink = winform.edRoomId.textvarurl, err  = view(link)if( !url ){

winform.msgboxErr(err)

}owner.disabled =false}

winform.trackbar.pos = 70

mpv.setVolume(winform.trackbar.pos)

winform.trackbar.oncommand =function(id,event,pos){if( event == 0x8/*_TB_ENDTRACK*/){

mpv.setVolume(winform.trackbar.pos)

}elseif( event = 0x5/*_TB_THUMBTRACK*/){

mpv.setVolume(pos)

}

}

winform.btnFullScreen.oncommand =function(id,event){

winform.custom.fullscreen(true)

}importwin.ui.accelerator

win.ui.accelerator({

{ vkey =0x1B/*_VK_ESC*/;oncommand =function(id,event) winform.custom.fullscreen(false) }

{ vkey =0x7A/*_VK_F11*/; oncommand =function(id,event) winform.custom.fullscreen() }

},winform);

winform.show()

win.loopMessage();