OddSockets Unity SDK

using UnityEngine;
using OddSockets.Unity;

public class ChatManager : MonoBehaviour
{
    private OddSocketsClient client;
    private OddSocketsChannel chatChannel;

    async void Start()
    {
        // OddSocketsClient is a MonoBehaviour: add it as a component, then initialize.
        client = gameObject.AddComponent();
        client.Initialize(new OddSocketsUnityConfig
        {
            ApiKey = "ak_live_1234567890abcdef",
            UserId = "player123"
        });

        // Set up event handlers
        client.OnConnected += OnConnected;
        client.OnError += OnError;

        // Connect. A realtime worker is auto-provisioned for your account -
        // there is no server URL to configure.
        await client.ConnectAsync();
    }

    private async void OnConnected()
    {
        Debug.Log("Connected to OddSockets!");

        // Get a channel and subscribe
        chatChannel = client.Channel("game-chat");
        await chatChannel.SubscribeAsync(OnMessage);

        // Publish a message
        await chatChannel.PublishAsync(new { text = "gg wp", player = "Player1" });
    }

    private void OnMessage(ChannelMessageData message)
    {
        Debug.Log($"Received: {message.Data}");
    }

    private void OnError(System.Exception error)
    {
        Debug.LogError($"OddSockets error: {error.Message}");
    }

    void OnDestroy()
    {
        client?.Disconnect();
    }
}

// All enhanced features are accessed through client.Enhanced
var enhanced = client.Enhanced;

// Reactions
enhanced.OnReactionAdded += data => Debug.Log($"Reaction: {data}");
await enhanced.AddReactionAsync(messageId, "game-chat", "\uD83D\uDD25", "player123");

// Typing indicator
enhanced.OnUserTyping += data => Debug.Log($"typing: {data}");
await enhanced.StartTypingAsync("player123", "game-chat");

// Direct messages (whispers)
enhanced.OnDmReceived += data => Debug.Log($"DM: {data}");
await enhanced.SendDmAsync(conversationId, "gg wp", "player123");

// Custom game events (raw escape hatch on the client itself)
client.On("objective_captured", payload => Debug.Log($"captured: {payload}"));
await client.EmitAsync("objective_captured", new { team = "red", point = "B" });