blob: bd8c97793976965e3dcc5f702700bbfeaa18b869 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
|
using System;
using Fleck;
using Dalamud.Game.Command;
using Dalamud.IoC;
using Dalamud.Plugin;
using Dalamud.Plugin.Services;
using System.Collections.Generic;
using System.Threading;
using System.Text.Json;
using System.Text.Json.Serialization;
using Dalamud.Interface.Windowing;
using DiscordToXIV.Windows;
namespace DiscordToXIV;
public class Message
{
[JsonPropertyName("author")]
public string Author { get; set; }
[JsonPropertyName("author_name")]
public string AuthorName { get; set; }
[JsonPropertyName("nickname")]
public string Nickname { get; set; }
[JsonPropertyName("content")]
public string Content { get; set; }
[JsonPropertyName("time")]
public string Time { get; set; }
[JsonPropertyName("channel")]
public string Channel { get; set; }
}
public sealed class Plugin : IDalamudPlugin
{
[PluginService] internal static IDalamudPluginInterface PluginInterface { get; private set; } = null!;
[PluginService] internal static ICommandManager CommandManager { get; private set; } = null!;
[PluginService] internal static IChatGui ChatGui { get; private set; } = null!;
[PluginService] internal static IPluginLog PluginLog { get; private set; } = null!;
private const string CommandName = "/pdiscordtoxiv";
private const int DefaultPort = 8765;
private WebSocketServer _webSocketServer;
private CancellationTokenSource _cancellationTokenSource;
private List<IWebSocketConnection> _connectedClients;
public Configuration Configuration { get; init; }
private ConfigWindow ConfigWindow { get; init; }
public readonly WindowSystem WindowSystem = new("SamplePlugin");
public Plugin()
{
Configuration = PluginInterface.GetPluginConfig() as Configuration ?? new Configuration();
ConfigWindow = new ConfigWindow(this);
WindowSystem.AddWindow(ConfigWindow);
_cancellationTokenSource = new CancellationTokenSource();
_connectedClients = new List<IWebSocketConnection>();
CommandManager.AddHandler(CommandName, new CommandInfo(OnCommand)
{
HelpMessage = "Start WebSocket server. Usage: /pdiscordtoxiv [port]"
});
PluginInterface.UiBuilder.OpenConfigUi += ToggleConfigUI;
ChatGui.Print("Plugin starting...");
}
public void Dispose()
{
StopWebSocketServer();
CommandManager.RemoveHandler(CommandName);
}
private void OnCommand(string command, string args)
{
var port = DefaultPort;
if (!string.IsNullOrEmpty(args))
{
if(args == "stop")
{
StopWebSocketServer();
ChatGui.Print("WebSocket server stop requested");
return;
}
if (!int.TryParse(args, out port) || port <= 0 || port > 65535)
{
ChatGui.PrintError($"Invalid port number: {args}. Using default port {DefaultPort}.");
port = DefaultPort;
}
}
StartWebSocketServer(port);
ChatGui.Print($"WebSocket server started on port {port}");
}
private void StartWebSocketServer(int port)
{
StopWebSocketServer();
_webSocketServer = new WebSocketServer($"ws://0.0.0.0:{port}");
_webSocketServer.Start(socket =>
{
socket.OnOpen = () =>
{
PluginLog.Information("WebSocket connection opened.");
_connectedClients.Add(socket);
};
socket.OnClose = () =>
{
PluginLog.Information("WebSocket connection closed.");
_connectedClients.Remove(socket);
};
socket.OnMessage = message =>
{
try
{
Message receivedMessage = JsonSerializer.Deserialize<Message>(message);
//PluginLog.Information($"Message from {receivedMessage.Nickname}: {receivedMessage.Content}");
ChatGui.Print($"[{receivedMessage.AuthorName}] {receivedMessage.Nickname}: {receivedMessage.Content}");
}
catch (Exception ex)
{
PluginLog.Error($"Failed to deserialize message: {ex.Message}");
}
};
});
}
private void StopWebSocketServer()
{
if (_webSocketServer != null)
{
PluginLog.Information("Stopping WebSocket server...");
foreach (var socket in _connectedClients)
{
if (socket.IsAvailable)
{
socket.Close();
}
}
_webSocketServer.Dispose();
_cancellationTokenSource.Cancel();
PluginLog.Information("WebSocket server stopped.");
}
}
public void ToggleConfigUI() => ConfigWindow.Toggle();
}
|
