559 lines
15 KiB
Lua
559 lines
15 KiB
Lua
local WS=WS
|
|
local PLAYERS=PLAYERS
|
|
|
|
local NET={
|
|
allow_online=false,
|
|
accessToken=false,
|
|
cloudData={},
|
|
|
|
roomState={--A copy of room structure on server
|
|
roomInfo={
|
|
name=false,
|
|
type=false,
|
|
version=false,
|
|
},
|
|
roomData={},
|
|
count=false,
|
|
capacity=false,
|
|
private=false,
|
|
start=false,
|
|
},
|
|
spectate=false,--If player is spectating
|
|
specSRID=false,--Cached SRID when enter playing room, for connect WS after scene swapped
|
|
seed=false,
|
|
|
|
roomReadyState=false,
|
|
|
|
onlineCount="_",
|
|
}
|
|
|
|
|
|
|
|
--------------------------<NEW HTTP API>
|
|
local function getMsg(request,timeout)
|
|
HTTP(request)
|
|
local totalTime=0
|
|
while true do
|
|
local mes=HTTP.pollMsg(request.pool)
|
|
if mes then
|
|
if type(mes.body)=='string' and #mes.body>0 then
|
|
return JSON.decode(mes.body)
|
|
else
|
|
MES.new('info',text.serverDown)
|
|
return
|
|
end
|
|
else
|
|
totalTime=totalTime+coroutine.yield()
|
|
if totalTime>timeout then
|
|
return
|
|
end
|
|
end
|
|
end
|
|
end
|
|
function NET.getCode(email)
|
|
if not TASK.lock('getCode') then return end
|
|
TASK.new(function()
|
|
local res=getMsg({
|
|
pool='getCode',
|
|
path='/techmino/api/v1/auth/verify/email',
|
|
body={email=email},
|
|
},12.6)
|
|
|
|
if res then
|
|
if res.code==200 then
|
|
USER.email=email
|
|
SCN.fileDropped(2)
|
|
MES.new('info',text.checkEmail,5)
|
|
else
|
|
MES.new('error',res.message,5)
|
|
end
|
|
else
|
|
MES.new('warn',text.requestFailed,5)
|
|
end
|
|
|
|
WAIT.interrupt()
|
|
end)
|
|
WAIT{
|
|
quit=function()
|
|
TASK.unlock('getCode')
|
|
HTTP.deletePool('getCode')
|
|
end,
|
|
timeout=12.6,
|
|
}
|
|
end
|
|
function NET.codeLogin(code)
|
|
if not TASK.lock('codeLogin') then return end
|
|
TASK.new(function()
|
|
local res=getMsg({
|
|
pool='codeLogin',
|
|
path='/techmino/api/v1/auth/login/email',
|
|
body={
|
|
email=USER.email,
|
|
code=code,
|
|
},
|
|
},6.26)
|
|
|
|
if res then
|
|
if res.code==200 then
|
|
USER.rToken=res.data.refreshToken
|
|
USER.aToken=res.data.accessToken
|
|
NET.connectWS()
|
|
SCN.pop()SCN.go('net_menu')
|
|
elseif res.code==201 then
|
|
USER.rToken=res.data.refreshToken
|
|
USER.aToken=res.data.accessToken
|
|
SCN.pop()SCN.push('net_menu')
|
|
SCN.fileDropped(3)
|
|
else
|
|
MES.new('error',res.message,5)
|
|
end
|
|
else
|
|
MES.new('warn',text.requestFailed,5)
|
|
end
|
|
|
|
WAIT.interrupt()
|
|
end)
|
|
WAIT{
|
|
quit=function()
|
|
TASK.unlock('codeLogin')
|
|
HTTP.deletePool('codeLogin')
|
|
end,
|
|
timeout=6.26,
|
|
}
|
|
end
|
|
function NET.setPW(code,pw)
|
|
if not TASK.lock('setPW') then return end
|
|
TASK.new(function()
|
|
pw=HASH.pbkdf2(HASH.sha3_256,pw,"salt",26000)
|
|
|
|
local res=getMsg({
|
|
pool='setPW',
|
|
method='PUT',
|
|
path='/techmino/api/v1/auth/reset/email',
|
|
body={
|
|
email=USER.email,
|
|
code=code,
|
|
newPassword=pw,
|
|
},
|
|
},6.26)
|
|
|
|
if res then
|
|
if res.code==200 then
|
|
USER.password=pw
|
|
SCN.back()
|
|
else
|
|
MES.new('error',res.message,5)
|
|
end
|
|
else
|
|
MES.new('warn',text.requestFailed,5)
|
|
end
|
|
|
|
WAIT.interrupt()
|
|
end)
|
|
WAIT{
|
|
quit=function()
|
|
TASK.unlock('setPW')
|
|
HTTP.deletePool('setPW')
|
|
end,
|
|
timeout=6.26,
|
|
}
|
|
end
|
|
function NET.autoLogin()
|
|
if not USER.password then
|
|
SCN.go('login')
|
|
return
|
|
end
|
|
if not TASK.lock('autoLogin') then return end
|
|
TASK.new(function()
|
|
if USER.aToken then
|
|
local res=getMsg({
|
|
pool='autoLogin',
|
|
path='/techmino/api/v1/auth/check',
|
|
headers={["x-access-token"]=USER.aToken},
|
|
},6.26)
|
|
|
|
if res then
|
|
if res.code==200 then
|
|
NET.connectWS()
|
|
SCN.go('net_menu')
|
|
WAIT.interrupt()
|
|
return
|
|
else
|
|
LOG("Access token expired")
|
|
end
|
|
else
|
|
WAIT.interrupt()
|
|
return
|
|
end
|
|
end
|
|
if USER.rToken then
|
|
local res=getMsg({
|
|
pool='autoLogin',
|
|
path='/techmino/api/v1/auth/refresh',
|
|
headers={["x-refresh-token"]=USER.rToken},
|
|
},6.26)
|
|
|
|
if res then
|
|
if res.code==200 then
|
|
USER.rToken=res.data.refreshToken
|
|
USER.aToken=res.data.accessToken
|
|
NET.connectWS()
|
|
SCN.go('net_menu')
|
|
WAIT.interrupt()
|
|
return
|
|
else
|
|
LOG("Refresh token expired")
|
|
end
|
|
else
|
|
WAIT.interrupt()
|
|
return
|
|
end
|
|
end
|
|
if USER.password then
|
|
local res=getMsg({
|
|
pool='pwLogin',
|
|
path='/techmino/api/v1/auth/login/email',
|
|
body={
|
|
email=USER.email,
|
|
password=USER.password,
|
|
},
|
|
},6.26)
|
|
if res then
|
|
if res.code==200 then
|
|
USER.rToken=res.data.refreshToken
|
|
USER.aToken=res.data.accessToken
|
|
NET.connectWS()
|
|
SCN.go('net_menu')
|
|
WAIT.interrupt()
|
|
return
|
|
else
|
|
MES.new('warn',text.requestFailed)
|
|
end
|
|
else
|
|
WAIT.interrupt()
|
|
end
|
|
end
|
|
|
|
SCN.go('login')
|
|
WAIT.interrupt()
|
|
end)
|
|
WAIT{
|
|
quit=function()
|
|
TASK.unlock('autoLogin')
|
|
HTTP.deletePool('autoLogin')
|
|
end,
|
|
timeout=12.6,
|
|
}
|
|
end
|
|
function NET.pwLogin(email,pw)
|
|
if not TASK.lock('pwLogin') then return end
|
|
TASK.new(function()
|
|
pw=HASH.pbkdf2(HASH.sha3_256,pw,"salt",26000)
|
|
|
|
local res=getMsg({
|
|
pool='pwLogin',
|
|
path='/techmino/api/v1/auth/login/email',
|
|
body={
|
|
email=email,
|
|
password=pw,
|
|
},
|
|
},6.26)
|
|
|
|
if res then
|
|
if res.code==200 then
|
|
USER.email=email
|
|
USER.password=pw
|
|
USER.rToken=res.data.refreshToken
|
|
USER.aToken=res.data.accessToken
|
|
NET.connectWS()
|
|
SCN.go('net_menu')
|
|
else
|
|
MES.new('error',res.message,5)
|
|
end
|
|
else
|
|
MES.new('warn',text.requestFailed,5)
|
|
end
|
|
|
|
WAIT.interrupt()
|
|
end)
|
|
WAIT{
|
|
quit=function()
|
|
TASK.unlock('pwLogin')
|
|
HTTP.deletePool('pwLogin')
|
|
end,
|
|
timeout=12.6,
|
|
}
|
|
end
|
|
|
|
--------------------------<NEW WS API>
|
|
local function wsSend(act,data)
|
|
-- print("SEND ACT: "..act)
|
|
WS.send('game',JSON.encode{
|
|
action=act,
|
|
data=data,
|
|
})
|
|
end
|
|
|
|
--Room
|
|
NET.room={}
|
|
function NET.room.chat(mes,rid)
|
|
wsSend(1300,{
|
|
message=mes,
|
|
roomId=rid,--Admin
|
|
})
|
|
end
|
|
function NET.room.create(roomName,description,capacity,roomType,roomData,password)
|
|
if TASK.lock('enterRoom',2)then
|
|
NET.roomState.private=not not password
|
|
NET.roomState.capacity=capacity
|
|
wsSend(1301,{
|
|
capacity=capacity,
|
|
info={
|
|
name=roomName,
|
|
type=roomType,
|
|
version=VERSION.room,
|
|
description=description,
|
|
},
|
|
data=roomData,
|
|
|
|
password=password,
|
|
})
|
|
end
|
|
end
|
|
function NET.room.getData(rid)
|
|
wsSend(1302,{
|
|
roomId=rid,--Admin
|
|
})
|
|
end
|
|
function NET.room.setData(data,rid)
|
|
wsSend(1303,{
|
|
data=data,
|
|
roomId=rid,--Admin
|
|
})
|
|
end
|
|
function NET.room.getInfo(rid)
|
|
wsSend(1304,{
|
|
roomId=rid,--Admin
|
|
})
|
|
end
|
|
function NET.room.setInfo(info,rid)
|
|
wsSend(1305,{
|
|
info=info,
|
|
roomId=rid,--Admin
|
|
})
|
|
end
|
|
function NET.room.enter(rid,password)
|
|
if TASK.lock('enterRoom',6)then
|
|
SFX.play('reach',.6)
|
|
wsSend(1306,{
|
|
data={
|
|
rid=rid,
|
|
password=password,
|
|
}
|
|
})
|
|
end
|
|
end
|
|
function NET.room.kick(pid,rid)
|
|
wsSend(1307,{
|
|
playerId=pid,--Host
|
|
roomId=rid,--Admin
|
|
})
|
|
end
|
|
function NET.room.leave()
|
|
wsSend(1308)
|
|
end
|
|
function NET.room.fetch()
|
|
if TASK.lock('fetchRoom',3)then
|
|
wsSend(1309,{
|
|
data={
|
|
pageIndex=0,
|
|
pageSize=26,
|
|
}
|
|
})
|
|
end
|
|
end
|
|
function NET.room.setPW(pw,rid)
|
|
if TASK.lock('fetchRoom',3)then
|
|
wsSend(1310,{
|
|
data={
|
|
password=pw,
|
|
roomId=rid,--Admin
|
|
}
|
|
})
|
|
end
|
|
end
|
|
function NET.room.remove(rid)
|
|
wsSend(1311,{
|
|
roomId=rid--Admin
|
|
})
|
|
end
|
|
|
|
--Player
|
|
NET.player={}
|
|
function NET.player.updateConf()
|
|
wsSend(1200,dumpBasicConfig())
|
|
end
|
|
function NET.player.finish(mes)--what mes?
|
|
wsSend(1201,mes)
|
|
end
|
|
function NET.player.joinGroup(gid)
|
|
wsSend(1202,gid)
|
|
end
|
|
function NET.player.setReady(bool)
|
|
wsSend(1203,bool)
|
|
end
|
|
function NET.player.setHost(pid)
|
|
wsSend(1204,{
|
|
playerId=pid,
|
|
role='Admin',
|
|
})
|
|
end
|
|
function NET.player.setState(state)-- what state?
|
|
wsSend(1205,state)
|
|
end
|
|
function NET.player.stream(stream)
|
|
wsSend(1206,stream)
|
|
end
|
|
function NET.player.setPlaying(playing)
|
|
wsSend(1207,playing and 'Gamer' or 'Spectator')
|
|
end
|
|
|
|
--WS
|
|
function NET.connectWS()
|
|
if WS.status('game')=='dead'then
|
|
WS.connect('game','',{['x-access-token']=USER.aToken},6)
|
|
TASK.new(NET.updateWS)
|
|
end
|
|
end
|
|
function NET.closeWS()
|
|
WS.close('game')
|
|
end
|
|
function NET.updateWS()
|
|
while WS.status('game')~='dead'do
|
|
coroutine.yield()
|
|
local message,op=WS.read('game')
|
|
if message then
|
|
if op=='ping'then
|
|
elseif op=='pong'then
|
|
elseif op=='close'then
|
|
local res=JSON.decode(message)
|
|
MES.new('info',("$1 $2"):repD(text.wsClose,res and res.message or message))
|
|
if res and res.message then LOG(res.message) end
|
|
TEST.yieldUntilNextScene()
|
|
while SCN.stack[#SCN.stack-1]~='main' do SCN.pop() end
|
|
SCN.back()
|
|
return
|
|
else
|
|
local res=JSON.decode(message)
|
|
if res then
|
|
-- print(("RECV ACT: $1 ($2)"):repD(res.action,res.type))
|
|
if res.type=='Failed' then
|
|
MES.new('warn',text.requestFailed..": "..(res.reason or "/"))
|
|
elseif res.action==1100 then-- TODO
|
|
elseif res.action==1101 then-- TODO
|
|
elseif res.action==1102 then-- TODO
|
|
elseif res.action==1201 then-- TODO
|
|
elseif res.action==1202 then-- TODO
|
|
elseif res.action==1203 then-- TODO
|
|
elseif res.action==1204 then-- TODO
|
|
elseif res.action==1205 then-- TODO
|
|
elseif res.action==1206 then-- TODO
|
|
elseif res.action==1207 then-- TODO
|
|
elseif res.action==1301 then-- TODO
|
|
elseif res.action==1302 then-- TODO
|
|
elseif res.action==1303 then-- TODO
|
|
elseif res.action==1304 then-- TODO
|
|
elseif res.action==1305 then-- TODO
|
|
elseif res.action==1306 then-- TODO
|
|
elseif res.action==1307 then-- TODO
|
|
elseif res.action==1308 then-- TODO
|
|
elseif res.action==1309 then-- TODO
|
|
elseif res.action==1310 then-- TODO
|
|
elseif res.action==1311 then-- TODO
|
|
end
|
|
else
|
|
WS.alert('user')
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
--------------------------<OLD ONLINE API>
|
|
--Account & User
|
|
function NET.getUserInfo(uid)
|
|
wsSend({
|
|
data={
|
|
uid=uid,
|
|
hash=USERS.getHash(uid),
|
|
},
|
|
})
|
|
end
|
|
|
|
--Save
|
|
function NET.uploadSave()
|
|
if TASK.lock('uploadSave',8)then
|
|
wsSend({data={sections={
|
|
{section=1,data=STRING.packTable(STAT)},
|
|
{section=2,data=STRING.packTable(RANKS)},
|
|
{section=3,data=STRING.packTable(SETTING)},
|
|
{section=4,data=STRING.packTable(KEY_MAP)},
|
|
{section=5,data=STRING.packTable(VK_ORG)},
|
|
{section=6,data=STRING.packTable(loadFile('conf/vkSave1','-canSkip')or{})},
|
|
{section=7,data=STRING.packTable(loadFile('conf/vkSave2','-canSkip')or{})},
|
|
}}})
|
|
MES.new('info',"Uploading")
|
|
end
|
|
end
|
|
function NET.downloadSave()
|
|
if TASK.lock('downloadSave',8)then
|
|
wsSend({data={sections={1,2,3,4,5,6,7}}})
|
|
MES.new('info',"Downloading")
|
|
end
|
|
end
|
|
function NET.loadSavedData(sections)
|
|
for _,sec in next,sections do
|
|
if sec.section==1 then
|
|
NET.cloudData.STAT=STRING.unpackTable(sec.data)
|
|
elseif sec.section==2 then
|
|
NET.cloudData.RANKS=STRING.unpackTable(sec.data)
|
|
elseif sec.section==3 then
|
|
NET.cloudData.SETTING=STRING.unpackTable(sec.data)
|
|
elseif sec.section==4 then
|
|
NET.cloudData.keyMap=STRING.unpackTable(sec.data)
|
|
elseif sec.section==5 then
|
|
NET.cloudData.VK_org=STRING.unpackTable(sec.data)
|
|
elseif sec.section==6 then
|
|
NET.cloudData.vkSave1=STRING.unpackTable(sec.data)
|
|
elseif sec.section==7 then
|
|
NET.cloudData.vkSave2=STRING.unpackTable(sec.data)
|
|
end
|
|
end
|
|
local success=true
|
|
TABLE.cover(NET.cloudData.STAT,STAT)
|
|
success=success and saveStats()
|
|
|
|
TABLE.cover(NET.cloudData.RANKS,RANKS)
|
|
success=success and saveProgress()
|
|
|
|
TABLE.cover(NET.cloudData.SETTING,SETTING)
|
|
success=success and saveSettings()
|
|
applySettings()
|
|
|
|
TABLE.cover(NET.cloudData.keyMap,KEY_MAP)
|
|
success=success and saveFile(KEY_MAP,'conf/key')
|
|
|
|
TABLE.cover(NET.cloudData.VK_org,VK_ORG)
|
|
success=success and saveFile(VK_ORG,'conf/virtualkey')
|
|
|
|
if #NET.cloudData.vkSave1[1]then success=success and saveFile(NET.cloudData.vkSave1,'conf/vkSave1')end
|
|
if #NET.cloudData.vkSave2[1]then success=success and saveFile(NET.cloudData.vkSave2,'conf/vkSave2')end
|
|
if success then
|
|
MES.new('check',text.saveDone)
|
|
else
|
|
MES.new('warn',text.dataCorrupted)
|
|
end
|
|
end
|
|
|
|
return NET
|