use async for WriteData

This commit is contained in:
Mikhail
2024-07-11 14:35:48 -04:00
parent ed40557e19
commit 988c71c5b2
121 changed files with 132 additions and 131 deletions

View File

@@ -59,7 +59,7 @@ namespace nksrv.LobbyServer
protected abstract Task HandleAsync(); protected abstract Task HandleAsync();
protected void WriteData<T>(T data) where T : IMessage, new() protected async Task WriteDataAsync<T>(T data) where T : IMessage, new()
{ {
if (ctx == null) if (ctx == null)
{ {
@@ -85,7 +85,7 @@ namespace nksrv.LobbyServer
{ {
ctx.Response.Headers.Set(System.Net.HttpRequestHeader.ContentEncoding, "gzip,enc"); ctx.Response.Headers.Set(System.Net.HttpRequestHeader.ContentEncoding, "gzip,enc");
var enc = PacketDecryption.EncryptData(((MemoryStream)responseBytes).ToArray(), UsedAuthToken); var enc = PacketDecryption.EncryptData(((MemoryStream)responseBytes).ToArray(), UsedAuthToken);
ctx.Response.OutputStream.Write(enc, 0, enc.Length); await ctx.Response.OutputStream.WriteAsync(enc, ctx.CancellationToken);
} }
} }
} }

View File

@@ -17,7 +17,7 @@ namespace nksrv.LobbyServer.Msgs.Antibot
// this is responsible for server side anticheat // this is responsible for server side anticheat
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -18,7 +18,7 @@ namespace nksrv.LobbyServer.Msgs.Antibot
var response = new ResAntibotRecvData(); var response = new ResAntibotRecvData();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -16,7 +16,7 @@ namespace nksrv.LobbyServer.Msgs.Archive
var response = new ResExistScenarioBookmark(); var response = new ResExistScenarioBookmark();
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -18,7 +18,7 @@ namespace nksrv.LobbyServer.Msgs.Archive
response.ArchiveRecordList.AddRange([100, 200, 300, 400, 500, 600, 700, 800, 900, 1000, 1100, 1200, 1300, 1400, 1500, 1600, 1700, 1800]); response.ArchiveRecordList.AddRange([100, 200, 300, 400, 500, 600, 700, 800, 900, 1000, 1100, 1200, 1300, 1400, 1500, 1600, 1700, 1800]);
response.UnlockedArchiveRecordList.AddRange([100, 200, 300, 400, 500, 600, 700, 800, 900, 1000, 1100, 1200, 1300, 1400, 1500, 1600, 1700, 1800]); response.UnlockedArchiveRecordList.AddRange([100, 200, 300, 400, 500, 600, 700, 800, 900, 1000, 1100, 1200, 1300, 1400, 1500, 1600, 1700, 1800]);
// TODO: allow unlocking // TODO: allow unlocking
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -16,7 +16,7 @@ namespace nksrv.LobbyServer.Msgs.Arena
var response = new ResGetArenaBanInfo(); var response = new ResGetArenaBanInfo();
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -17,7 +17,8 @@ namespace nksrv.LobbyServer.Msgs.Auth
var req = await ReadData<ReqLogout>(); var req = await ReadData<ReqLogout>();
JsonDb.Instance.GameClientTokens.Remove(UsedAuthToken); JsonDb.Instance.GameClientTokens.Remove(UsedAuthToken);
WriteData(new ResLogout());
await WriteDataAsync(new ResLogout());
} }
} }
} }

View File

@@ -36,8 +36,9 @@ namespace nksrv.LobbyServer.Msgs.Auth
response.FeatureDataInfo = new NetFeatureDataInfo() { UseFeatureData = true }; response.FeatureDataInfo = new NetFeatureDataInfo() { UseFeatureData = true };
response.Identifier = new NetLegacyUserIdentifier() { Server = 21769, Usn = (long)user.ID }; response.Identifier = new NetLegacyUserIdentifier() { Server = 21769, Usn = (long)user.ID };
response.ShouldRestartAfter = Duration.FromTimeSpan(TimeSpan.FromSeconds(86400)); response.ShouldRestartAfter = Duration.FromTimeSpan(TimeSpan.FromSeconds(86400));
response.EncryptionToken = ByteString.CopyFromUtf8(rsp.ClientAuthToken); response.EncryptionToken = ByteString.CopyFromUtf8(rsp.ClientAuthToken);
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -12,7 +12,8 @@ namespace nksrv.LobbyServer.Msgs.Auth
var response = new AuthIntlResponse(); var response = new AuthIntlResponse();
//response.BanInfo = new NetBanInfo() { BanId = 123, Description = "The server admin is sad today because the hinge on his HP laptop broke which happened to be an HP Elitebook 8470p, and the RAM controller exploded and then fixed itself, please contact him", StartAt = Timestamp.FromDateTime(DateTime.UtcNow), EndAt = Timestamp.FromDateTime(DateTime.UtcNow.AddDays(256)) }; //response.BanInfo = new NetBanInfo() { BanId = 123, Description = "The server admin is sad today because the hinge on his HP laptop broke which happened to be an HP Elitebook 8470p, and the RAM controller exploded and then fixed itself, please contact him", StartAt = Timestamp.FromDateTime(DateTime.UtcNow), EndAt = Timestamp.FromDateTime(DateTime.UtcNow.AddDays(256)) };
response.AuthSuccess = new NetAuthSuccess() { AuthToken = req.Token, CentauriZoneId = "84", FirstAuth = "", PurchaseRestriction = new NetUserPurchaseRestriction() { PurchaseRestriction = PurchaseRestriction.Unknown2, UpdatedAt = 638546758794611090 } }; response.AuthSuccess = new NetAuthSuccess() { AuthToken = req.Token, CentauriZoneId = "84", FirstAuth = "", PurchaseRestriction = new NetUserPurchaseRestriction() { PurchaseRestriction = PurchaseRestriction.Unknown2, UpdatedAt = 638546758794611090 } };
WriteData(response);
await WriteDataAsync(response);
} }
} }
} }

View File

@@ -16,7 +16,7 @@ namespace nksrv.LobbyServer.Msgs.Badge
var response = new ResDeleteBadge(); var response = new ResDeleteBadge();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -10,7 +10,7 @@ namespace nksrv.LobbyServer.Msgs.Badge
var req = await ReadData<ReqSyncBadge>(); var req = await ReadData<ReqSyncBadge>();
var response = new ResSyncBadge(); var response = new ResSyncBadge();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -16,7 +16,8 @@ namespace nksrv.LobbyServer.Msgs.Campaign
var response = new ResCampaignPackageGetAllShutdownFlags(); var response = new ResCampaignPackageGetAllShutdownFlags();
// TODO // TODO
WriteData(response);
await WriteDataAsync(response);
} }
} }
} }

View File

@@ -51,7 +51,7 @@ namespace nksrv.LobbyServer.Msgs.Campaign
response.Json = resultingJson; response.Json = resultingJson;
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -25,10 +25,10 @@ namespace nksrv.LobbyServer.Msgs.Campaign
// TODO // TODO
response.Reward = new(); response.Reward = new();
WriteData(response);
await WriteDataAsync(response);
} }
} }
} }

View File

@@ -10,8 +10,6 @@ namespace nksrv.LobbyServer.Msgs.Campaign
var req = await ReadData<ReqSaveCampaignField>(); var req = await ReadData<ReqSaveCampaignField>();
var user = GetUser(); var user = GetUser();
Console.WriteLine("Map ID: " + req.MapId);
var response = new ResGetFieldTalkList(); var response = new ResGetFieldTalkList();
Console.WriteLine($"save {req.MapId} with {req.Json}"); Console.WriteLine($"save {req.MapId} with {req.Json}");
@@ -25,9 +23,7 @@ namespace nksrv.LobbyServer.Msgs.Campaign
user.MapJson[req.MapId] = req.Json; user.MapJson[req.MapId] = req.Json;
} }
await WriteDataAsync(response);
WriteData(response);
} }
} }
} }

View File

@@ -30,8 +30,7 @@ namespace nksrv.LobbyServer.Msgs.Campaign
field.CompletedObjects.Add(new NetFieldObject() { PositionId = req.FieldObject.PositionID, Json = req.FieldObject.Json, Type = req.FieldObject.Type }); field.CompletedObjects.Add(new NetFieldObject() { PositionId = req.FieldObject.PositionID, Json = req.FieldObject.Json, Type = req.FieldObject.Type });
JsonDb.Save(); JsonDb.Save();
await WriteDataAsync(response);
WriteData(response);
} }
} }
} }

View File

@@ -16,9 +16,9 @@ namespace nksrv.LobbyServer.Msgs.Character
var response = new ResGetAttractiveList(); var response = new ResGetAttractiveList();
response.CounselAvailableCount = 3; // TODO response.CounselAvailableCount = 3; // TODO
// TODO: Validate response from real server and pull info from user info // TODO: Validate response from real server and pull info from user info
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -20,7 +20,7 @@ namespace nksrv.LobbyServer.Msgs.Character
// return all // return all
response.CostumeIds.AddRange(StaticDataParser.Instance.GetAllCostumes()); response.CostumeIds.AddRange(StaticDataParser.Instance.GetAllCostumes());
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -16,7 +16,7 @@ namespace nksrv.LobbyServer.Msgs.Character
response.Character.Add(new NetUserCharacterData() { Default = new() { Csn = item.Csn, Skill1Lv = item.Skill1Lvl, Skill2Lv = item.Skill2Lvl, CostumeId = item.CostumeId, Lv = item.Level, Grade = item.Grade, Tid = item.Tid, UltiSkillLv = item.UltimateLevel } }); response.Character.Add(new NetUserCharacterData() { Default = new() { Csn = item.Csn, Skill1Lv = item.Skill1Lvl, Skill2Lv = item.Skill2Lvl, CostumeId = item.CostumeId, Lv = item.Level, Grade = item.Grade, Tid = item.Tid, UltiSkillLv = item.UltimateLevel } });
} }
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -35,7 +35,7 @@ namespace nksrv.LobbyServer.Msgs.Character
response.Synchro.SynchroLv = highestLevelCharacters.Last().Level; response.Synchro.SynchroLv = highestLevelCharacters.Last().Level;
// TODO: Validate response from real server and pull info from user info // TODO: Validate response from real server and pull info from user info
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -50,7 +50,7 @@ namespace nksrv.LobbyServer.Msgs.Character
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -27,7 +27,7 @@ namespace nksrv.LobbyServer.Msgs.Character
var response = new ResSetCharacterCostume(); var response = new ResSetCharacterCostume();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -31,7 +31,7 @@ namespace nksrv.LobbyServer.Msgs.Event
// TODO reward // TODO reward
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -18,7 +18,7 @@ namespace nksrv.LobbyServer.Msgs.Event
// TOOD // TOOD
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -16,7 +16,7 @@ namespace nksrv.LobbyServer.Msgs.Event
var response = new ResGetEventMissionClear(); var response = new ResGetEventMissionClear();
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -26,7 +26,7 @@ namespace nksrv.LobbyServer.Msgs.Event
user.EventInfo.Add(req.EventID, new EventData()); user.EventInfo.Add(req.EventID, new EventData());
} }
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -69,7 +69,7 @@ namespace nksrv.LobbyServer.Msgs.Event
JoinAt = 0 JoinAt = 0
}); });
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -102,7 +102,7 @@ namespace nksrv.LobbyServer.Msgs.Event
EventEndDate = DateTime.Now.AddDays(20).Ticks, EventEndDate = DateTime.Now.AddDays(20).Ticks,
EventDisableDate = DateTime.Now.AddDays(20).Ticks, EventDisableDate = DateTime.Now.AddDays(20).Ticks,
}); });
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -16,7 +16,7 @@ namespace nksrv.LobbyServer.Msgs.Friend
var response = new ResGetFriendData(); var response = new ResGetFriendData();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -20,7 +20,7 @@ namespace nksrv.LobbyServer.Msgs.Gacha
response.FreeCount = 0; response.FreeCount = 0;
response.EventData = new NetEventData() { Id = 1 }; response.EventData = new NetEventData() { Id = 1 };
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -40,7 +40,7 @@ namespace nksrv.LobbyServer.Msgs.Gacha
JsonDb.Save(); JsonDb.Save();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -16,7 +16,7 @@ namespace nksrv.LobbyServer.Msgs
response.CheatShiftDuration = Duration.FromTimeSpan(TimeSpan.FromSeconds(0)); response.CheatShiftDuration = Duration.FromTimeSpan(TimeSpan.FromSeconds(0));
// todo: validate response with actual server // todo: validate response with actual server
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -19,7 +19,7 @@ namespace nksrv.LobbyServer.Msgs
var response = new ResGetGachaData(); var response = new ResGetGachaData();
if (user.GachaTutorialPlayCount > 0) if (user.GachaTutorialPlayCount > 0)
response.Gacha.Add(new NetUserGachaData() { GachaType = 3, PlayCount = 1 }); response.Gacha.Add(new NetUserGachaData() { GachaType = 3, PlayCount = 1 });
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -30,7 +30,7 @@ namespace nksrv.LobbyServer.Msgs.Inventory
} }
JsonDb.Save(); JsonDb.Save();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -31,7 +31,7 @@ namespace nksrv.LobbyServer.Msgs.Inventory
JsonDb.Save(); JsonDb.Save();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -23,7 +23,7 @@ namespace nksrv.LobbyServer.Msgs.Inventory
// TODO implement // TODO implement
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -35,7 +35,7 @@ namespace nksrv.LobbyServer.Msgs.Inventory
} }
} }
JsonDb.Save(); JsonDb.Save();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -32,7 +32,7 @@ namespace nksrv.LobbyServer.Msgs.Inventory
JsonDb.Save(); JsonDb.Save();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -17,7 +17,7 @@ namespace nksrv.LobbyServer.Msgs.Messenger
// TODO: save these things // TODO: save these things
var response = new ResPickTodayDailyMessage(); var response = new ResPickTodayDailyMessage();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -17,7 +17,7 @@ namespace nksrv.LobbyServer.Msgs.Messenger
// TODO: save these things // TODO: save these things
var response = new ResGetMessages(); var response = new ResGetMessages();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -17,7 +17,7 @@ namespace nksrv.LobbyServer.Msgs.Messenger
// TODO: get proper response // TODO: get proper response
var response = new ResGetPickedMessageList(); var response = new ResGetPickedMessageList();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -17,7 +17,7 @@ namespace nksrv.LobbyServer.Msgs.Messenger
// TODO: get proper response // TODO: get proper response
var response = new ResForcePickTodayRandomMessage(); var response = new ResForcePickTodayRandomMessage();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -12,7 +12,7 @@ namespace nksrv.LobbyServer.Msgs.Messenger
// TODO: save these things // TODO: save these things
var response = new ResProceedMessage(); var response = new ResProceedMessage();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -16,7 +16,7 @@ namespace nksrv.LobbyServer.Msgs.Minigame.Dave
var response = new ResGetAllMiniGameDaveTriggers(); var response = new ResGetAllMiniGameDaveTriggers();
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -16,7 +16,7 @@ namespace nksrv.LobbyServer.Msgs.Minigame
var response = new ResGetMiniGameNKSV2Data(); var response = new ResGetMiniGameNKSV2Data();
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -16,7 +16,7 @@ namespace nksrv.LobbyServer.Msgs.Minigame.IslandAdventure
var response = new ResGetIslandAdventureFishingStepUpRewardStatus(); var response = new ResGetIslandAdventureFishingStepUpRewardStatus();
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -16,7 +16,7 @@ namespace nksrv.LobbyServer.Msgs.Minigame.IslandAdventure
var response = new ResGetIslandAdventurePhotoStepUpRewardStatus(); var response = new ResGetIslandAdventurePhotoStepUpRewardStatus();
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -16,7 +16,7 @@ namespace nksrv.LobbyServer.Msgs.Minigame.IslandAdventure
var response = new ResGetIslandAdventureMissionProgress(); var response = new ResGetIslandAdventureMissionProgress();
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -16,7 +16,7 @@ namespace nksrv.LobbyServer.Msgs.Minigame.PlaySoda
var response = new ResGetPlaySodaChallengeModeInfo(); var response = new ResGetPlaySodaChallengeModeInfo();
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -11,7 +11,7 @@ namespace nksrv.LobbyServer.Msgs.Misc
var response = new ResEnterLobbyPing(); var response = new ResEnterLobbyPing();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -15,7 +15,7 @@ namespace nksrv.LobbyServer.Msgs.Misc
response.Unavailables.Add(3); response.Unavailables.Add(3);
// TODO: Validate response from real server and pull info from user info // TODO: Validate response from real server and pull info from user info
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -19,7 +19,7 @@ namespace nksrv.LobbyServer.Msgs.Misc
var r = new ResGetFeatureFlag(); var r = new ResGetFeatureFlag();
r.IsOpen = true; r.IsOpen = true;
WriteData(r); await WriteDataAsync(r);
} }
} }
} }

View File

@@ -15,7 +15,7 @@ namespace nksrv.LobbyServer.Msgs.Misc
{ {
var r = new MaintenanceNoticeResponse(); var r = new MaintenanceNoticeResponse();
WriteData(r); await WriteDataAsync(r);
} }
} }
} }

View File

@@ -17,7 +17,7 @@ namespace nksrv.LobbyServer.Msgs.Misc
var r = new ResourceHostResponse(); var r = new ResourceHostResponse();
r.BaseUrl = "https://cloud.nikke-kr.com/prdenv/122-b0255105e0/{Platform}"; r.BaseUrl = "https://cloud.nikke-kr.com/prdenv/122-b0255105e0/{Platform}";
WriteData(r); await WriteDataAsync(r);
} }
} }
} }

View File

@@ -14,7 +14,7 @@ namespace nksrv.LobbyServer.Msgs.Misc
{ {
var r = new SentryDataResponse(); var r = new SentryDataResponse();
// TODO check proper response from real server // TODO check proper response from real server
WriteData(r); await WriteDataAsync(r);
} }
} }
} }

View File

@@ -19,7 +19,7 @@ namespace nksrv.LobbyServer.Msgs.Misc
r.MatchUrl = "https://global-match.nikke-kr.com"; r.MatchUrl = "https://global-match.nikke-kr.com";
r.WorldId = 84; r.WorldId = 84;
WriteData(r); await WriteDataAsync(r);
} }
} }
} }

View File

@@ -21,7 +21,7 @@ namespace nksrv.LobbyServer.Msgs.Misc
r.Salt1 = ByteString.CopyFrom(StaticDataParser.Salt1); r.Salt1 = ByteString.CopyFrom(StaticDataParser.Salt1);
r.Salt2 = ByteString.CopyFrom(StaticDataParser.Salt2); r.Salt2 = ByteString.CopyFrom(StaticDataParser.Salt2);
WriteData(r); await WriteDataAsync(r);
} }
} }
} }

View File

@@ -16,7 +16,7 @@ namespace nksrv.LobbyServer.Msgs.Misc
var response = new ResUserOnlineStateLog(); var response = new ResUserOnlineStateLog();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -17,7 +17,7 @@ namespace nksrv.LobbyServer.Msgs.Mission
var response = new ResGetAchievementRewardedData(); var response = new ResGetAchievementRewardedData();
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -17,7 +17,7 @@ namespace nksrv.LobbyServer.Msgs.Mission.Rewards
// TODO: implement // TODO: implement
var response = new ResGetDailyRewardedData(); var response = new ResGetDailyRewardedData();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -12,7 +12,7 @@ namespace nksrv.LobbyServer.Msgs.Outpost
// TODO: save these things // TODO: save these things
var response = new ResGetJukeboxRewardedData(); var response = new ResGetJukeboxRewardedData();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -17,7 +17,7 @@ namespace nksrv.LobbyServer.Msgs.Mission.Rewards
// TODO: implement // TODO: implement
var response = new ResGetWeeklyRewardedData(); var response = new ResGetWeeklyRewardedData();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -17,7 +17,7 @@ namespace nksrv.LobbyServer.Msgs.Outpost
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -16,7 +16,7 @@ namespace nksrv.LobbyServer.Msgs.Outpost
var response = new ResGetDispatchList(); var response = new ResGetDispatchList();
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -41,7 +41,7 @@ namespace nksrv.LobbyServer.Msgs.Outpost
response.Data.Add(new NetUserOutpostData() { SlotId = 38, BuildingId = 33601, IsDone = true, StartAt = 638549982076760660, CompleteAt = 638549982076760660 }); response.Data.Add(new NetUserOutpostData() { SlotId = 38, BuildingId = 33601, IsDone = true, StartAt = 638549982076760660, CompleteAt = 638549982076760660 });
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -12,7 +12,7 @@ namespace nksrv.LobbyServer.Msgs.Outpost
// TODO: save these things // TODO: save these things
var response = new ResGetRecycleRoomData(); var response = new ResGetRecycleRoomData();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -11,7 +11,7 @@ namespace nksrv.LobbyServer.Msgs.Outpost
var response = new ResGetMemoryList(); var response = new ResGetMemoryList();
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -21,7 +21,7 @@ namespace nksrv.LobbyServer.Msgs.Outpost
var response = new ResShowOutpostBattleReward(); var response = new ResShowOutpostBattleReward();
response.OutpostBattleLevel = user.OutpostBattleLevel; response.OutpostBattleLevel = user.OutpostBattleLevel;
response.OutpostBattleTime = new NetOutpostBattleTime() { MaxBattleTime = 864000000000, MaxOverBattleTime = 12096000000000, BattleTime = battleTimeMs }; response.OutpostBattleTime = new NetOutpostBattleTime() { MaxBattleTime = 864000000000, MaxOverBattleTime = 12096000000000, BattleTime = battleTimeMs };
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -12,7 +12,7 @@ namespace nksrv.LobbyServer.Msgs.PartyMatch
var response = new ResListInvitation(); var response = new ResListInvitation();
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -18,7 +18,7 @@ namespace nksrv.LobbyServer.Msgs.Pass
// TODO: Support events // TODO: Support events
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -18,7 +18,7 @@ namespace nksrv.LobbyServer.Msgs.Pass
// TODO: Support events // TODO: Support events
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -16,7 +16,7 @@ namespace nksrv.LobbyServer.Msgs.Ranking
var response = new ResUpdateRankingServerReward(); var response = new ResUpdateRankingServerReward();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -22,7 +22,7 @@ namespace nksrv.LobbyServer.Msgs.Shop
{ {
response.ProductInfoList.Add(new NetJupiterProductInfo() { CurrencyCode = "US", CurrencySymbol = "$", MicroPrice = 0, Price = "1", ProductId = item }); response.ProductInfoList.Add(new NetJupiterProductInfo() { CurrencyCode = "US", CurrencySymbol = "$", MicroPrice = 0, Price = "1", ProductId = item });
} }
WriteData(response); await WriteDataAsync(response);
} }
catch(Exception ex) catch(Exception ex)
{ {

View File

@@ -15,7 +15,7 @@ namespace nksrv.LobbyServer.Msgs.Shop
var req = await ReadData<ReqShopProductList>(); var req = await ReadData<ReqShopProductList>();
var response = new ResShopProductList(); var response = new ResShopProductList();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -17,7 +17,7 @@ namespace nksrv.LobbyServer.Msgs.Shop.InApp
var response = new ResGetSubscription(); var response = new ResGetSubscription();
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -16,7 +16,7 @@ namespace nksrv.LobbyServer.Msgs.Shop.InApp
var response = new ResGetJupiterMarketingDetail(); var response = new ResGetJupiterMarketingDetail();
response.MarketingDetail = "{}"; response.MarketingDetail = "{}";
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -17,7 +17,7 @@ namespace nksrv.LobbyServer.Msgs.Shop.InApp
var response = new ResGetMonthlySubscriptionReward(); var response = new ResGetMonthlySubscriptionReward();
// TODO: Validate response from real server // TODO: Validate response from real server
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -18,7 +18,7 @@ namespace nksrv.LobbyServer.Msgs.Shop.InApp
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -17,7 +17,7 @@ namespace nksrv.LobbyServer.Msgs.Shop.InApp
var response = new ResGetInAppShopReceivableProductList(); var response = new ResGetInAppShopReceivableProductList();
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -17,7 +17,7 @@ namespace nksrv.LobbyServer.Msgs.Shop.InApp
var response = new ResGetCustomPackageSetupData(); var response = new ResGetCustomPackageSetupData();
// TODO: Validate response from real server and pull info from user info // TODO: Validate response from real server and pull info from user info
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -10,7 +10,7 @@ namespace nksrv.LobbyServer.Msgs.Shop.PackageShop
var req = await ReadData<ReqGetPopupPackageState>(); var req = await ReadData<ReqGetPopupPackageState>();
var response = new ResGetPopupPackageState(); var response = new ResGetPopupPackageState();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -17,7 +17,7 @@ namespace nksrv.LobbyServer.Msgs.Shop.PackageShop
var response = new ResGetCampaignPackage(); var response = new ResGetCampaignPackage();
// TODO: Validate response from real server and pull info from user info // TODO: Validate response from real server and pull info from user info
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -27,7 +27,7 @@ namespace nksrv.LobbyServer.Msgs.Simroom
}, },
NextLegacyBuffResetDate = Timestamp.FromDateTimeOffset(DateTime.UtcNow.AddDays(7)) }; NextLegacyBuffResetDate = Timestamp.FromDateTimeOffset(DateTime.UtcNow.AddDays(7)) };
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -20,7 +20,7 @@ namespace nksrv.LobbyServer.Msgs.Soloraid
}; };
// TODO // TODO
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -28,7 +28,7 @@ namespace nksrv.LobbyServer.Msgs.Stage
WriteData(response); await WriteDataAsync(response);
} }
} }

View File

@@ -70,7 +70,7 @@ namespace nksrv.LobbyServer.Msgs.Stage
JsonDb.Save(); JsonDb.Save();
} }
WriteData(response); await WriteDataAsync(response);
} }
private NetRewardData RegisterRewardsForUser(Utils.User user, RewardTableRecord rewardData) private NetRewardData RegisterRewardsForUser(Utils.User user, RewardTableRecord rewardData)

View File

@@ -16,7 +16,7 @@ namespace nksrv.LobbyServer.Msgs.Stage
var response = new ResEnterStage(); var response = new ResEnterStage();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -26,7 +26,7 @@ namespace nksrv.LobbyServer.Msgs.Stage
response.SquadData = ""; response.SquadData = "";
WriteData(response); await WriteDataAsync(response);
} }
public static NetFieldObjectData CreateFieldInfo(Utils.User user, int chapter, string mod) public static NetFieldObjectData CreateFieldInfo(Utils.User user, int chapter, string mod)

View File

@@ -13,7 +13,7 @@ namespace nksrv.LobbyServer.Msgs.Subquest
// TOOD // TOOD
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -11,7 +11,7 @@ namespace nksrv.LobbyServer.Msgs.System
var response = new CheckVersionResponse(); var response = new CheckVersionResponse();
response.Availability = 0; // None = 0, Available = 1, Mandatory = 2 response.Availability = 0; // None = 0, Available = 1, Mandatory = 2
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -27,7 +27,7 @@ namespace nksrv.LobbyServer.Msgs.Team
} }
} }
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -19,7 +19,7 @@ namespace nksrv.LobbyServer.Msgs.Team
{ {
Console.WriteLine("support character used: " + item); Console.WriteLine("support character used: " + item);
} }
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -34,7 +34,7 @@ namespace nksrv.LobbyServer.Msgs.Team
} }
JsonDb.Save(); JsonDb.Save();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -36,7 +36,7 @@ namespace nksrv.LobbyServer.Msgs.Tower
response.Data.Add(t3); response.Data.Add(t3);
response.Data.Add(t4); response.Data.Add(t4);
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -23,7 +23,7 @@ namespace nksrv.LobbyServer.Msgs.Trigger
JsonDb.Save(); JsonDb.Save();
var response = new ResFinMainQuest(); var response = new ResFinMainQuest();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -16,7 +16,7 @@ namespace nksrv.LobbyServer.Msgs.Trigger
response.MainQuestList.Add(new NetMainQuestData() { IsReceived = item.Value, Tid = item.Key }); response.MainQuestList.Add(new NetMainQuestData() { IsReceived = item.Value, Tid = item.Key });
} }
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -10,7 +10,7 @@ namespace nksrv.LobbyServer.Msgs.Trigger
var req = ReadData<ReqSyncTrigger>(); var req = ReadData<ReqSyncTrigger>();
var response = new ResSyncTrigger(); var response = new ResSyncTrigger();
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -85,7 +85,7 @@ namespace nksrv.LobbyServer.Msgs.User
response.LastClearedNormalMainStageId = user.LastNormalStageCleared; response.LastClearedNormalMainStageId = user.LastNormalStageCleared;
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -51,7 +51,7 @@ namespace nksrv.LobbyServer.Msgs.User
new NetFeatureFlag() { FeatureKind = NetFeatureKind.Ce002MiniGame, IsOpen = true }, new NetFeatureFlag() { FeatureKind = NetFeatureKind.Ce002MiniGame, IsOpen = true },
new NetFeatureFlag() { FeatureKind = NetFeatureKind.SoloRaid, IsOpen = true }, new NetFeatureFlag() { FeatureKind = NetFeatureKind.SoloRaid, IsOpen = true },
]); ]);
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

View File

@@ -27,7 +27,7 @@ namespace nksrv.LobbyServer.Msgs.User
// todo tutorial playcount of gacha // todo tutorial playcount of gacha
response.TutorialGachaPlayCount = user.GachaTutorialPlayCount; response.TutorialGachaPlayCount = user.GachaTutorialPlayCount;
WriteData(response); await WriteDataAsync(response);
} }
} }
} }

Some files were not shown because too many files have changed in this diff Show More