-
Notifications
You must be signed in to change notification settings - Fork 9
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #29 from Wooza/share-via-chat
Share data via chat
- Loading branch information
Showing
6 changed files
with
182 additions
and
9 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,117 @@ | ||
| using ProtoBuf; | ||
| using System; | ||
| using System.IO.Compression; | ||
| using System.IO; | ||
| using Vintagestory.API.Client; | ||
| using Vintagestory.API.Common; | ||
| using ProspectorInfo.Map; | ||
| using System.Linq; | ||
| using System.Text; | ||
|
|
||
| namespace ProspectorInfo.Utils | ||
| { | ||
| internal class ChatDataSharing | ||
| { | ||
| private static readonly string CHAT_PREFIX = "ProspectingData;"; | ||
|
|
||
| private readonly ICoreClientAPI api; | ||
| private readonly ProspectorOverlayLayer prospectorOverlayLayer; | ||
| private readonly ModConfig modConfig; | ||
| public ChatDataSharing(ICoreClientAPI api, ProspectorOverlayLayer prospectorOverlayLayer, ModConfig modConfig) | ||
| { | ||
| this.api = api; | ||
| this.prospectorOverlayLayer = prospectorOverlayLayer; | ||
| this.modConfig = modConfig; | ||
| api.Event.ChatMessage += OnChatMessage; | ||
| } | ||
|
|
||
| private void OnChatMessage(int groupId, string message, EnumChatType chattype, string data) { | ||
| if (chattype != EnumChatType.OthersMessage) | ||
| return; | ||
|
|
||
| int startIdx = message.IndexOf(CHAT_PREFIX); | ||
| if (startIdx == -1) | ||
| return; | ||
|
|
||
| if (!modConfig.AcceptChatSharing) | ||
| { | ||
| api.ShowChatMessage("Someone shared prospecting data in chat but you currently don't accept data from the chat.<br/>" + | ||
| "Use '.pi acceptchatsharing true' to accept prospecting data in the future."); | ||
| return; | ||
| } | ||
|
|
||
| var result = DeserializeFromBase64<ProspectorMessages>(message.Substring(startIdx + CHAT_PREFIX.Length)); | ||
| if (result != null) | ||
| prospectorOverlayLayer.AddOrUpdateProspectingData(result.Values.ToArray()); | ||
| } | ||
|
|
||
| public void ShareData(ProspectorMessages messages) | ||
| { | ||
| string data = SerializeToBase64<ProspectorMessages>(messages); | ||
| if (data == null) | ||
| return; | ||
|
|
||
| // Add some whitespace before sending, to avoid lag spikes when rendering the chat message. | ||
| // The base64 deserializer ignores whitespace. | ||
| api.SendChatMessage(CHAT_PREFIX + AddWhitespace(data, 64)); | ||
| } | ||
|
|
||
| private string SerializeToBase64<T>(T data) { | ||
| try | ||
| { | ||
| using (var resultStream = new MemoryStream()) | ||
| { | ||
| using (var compressionStream = new DeflateStream(resultStream, CompressionLevel.Optimal)) | ||
| { | ||
| Serializer.Serialize(compressionStream, data); | ||
| } | ||
| byte[] result = resultStream.ToArray(); | ||
| return Convert.ToBase64String(result); | ||
| } | ||
| } | ||
| catch (Exception ex) | ||
| { | ||
| api.Logger.Error("Failed to serialize prospecting data", ex); | ||
| return null; | ||
| } | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Little hackery to avoid lag spikes when rendering a single long string without whitespace. | ||
| /// </summary> | ||
| private static string AddWhitespace(string input, int interval) | ||
| { | ||
| StringBuilder stringBuilder = new StringBuilder(); | ||
| int currentPosition = 0; | ||
| while (currentPosition + interval < input.Length) | ||
| { | ||
| stringBuilder.Append(input.Substring(currentPosition, interval)).Append(" "); | ||
| currentPosition += interval; | ||
| } | ||
| if (currentPosition < input.Length) | ||
| { | ||
| stringBuilder.Append(input.Substring(currentPosition)); | ||
| } | ||
| return stringBuilder.ToString(); | ||
| } | ||
|
|
||
| private T DeserializeFromBase64<T>(string message) where T : class | ||
| { | ||
| try | ||
| { | ||
| using (var resultStream = new MemoryStream(Convert.FromBase64String(message))) | ||
| { | ||
| using (var decompressionStream = new DeflateStream(resultStream, CompressionMode.Decompress)) | ||
| { | ||
| return Serializer.Deserialize<T>(decompressionStream); | ||
| } | ||
| } | ||
| } | ||
| catch (Exception ex) | ||
| { | ||
| api.Logger.Error("Failed to deserialize shared prospecting data from chat", ex); | ||
| return null; | ||
| } | ||
| } | ||
| } | ||
| } |