EventAPI v3

[AnatoleAM]

The next version of the Event API which is designed to work with the greater "v3" of the project.

Changes from v1

• Standard structures between both WebSocket and Server-Sent Event protocols
• Topics
• Mutable sessions

Checklist

• Universal "Connection" interface
• Event Subscriptions
• Transport: WebSocket
• Transport: Server-Sent Events
• Mutate sessions via REST (SSE)
• Add documentation

[TroyKomodo]

Almost, but will need to clean some stuff up more, such as moving towards common and also general tidying

[Nerixyz]

Realted to SevenTV/Common#21

WebSocket#Read handles the Unsubscribe command/op, but IsClientSentOp doesn't check for the OpcodeUnsubscribe (instead it checks for OpcodeSignal which has the same value):

EventAPI/src/app/client/websocket/websocket_read.go

Lines 46 to 50 in 150cc66

	// Verify the opcode
	if !client.IsClientSentOp(msg.Op) {
	w.Close(events.CloseCodeUnknownOperation)
	return
	}

EventAPI/src/app/client/websocket/websocket_read.go

Lines 59 to 64 in 150cc66

	// Handle command - UNSUBSCRIBE
	case events.OpcodeUnsubscribe:
	if err = handler.Unsubscribe(gctx, msg); err != nil {
	return
	}
	}

EventAPI/src/app/client/connection.go

Lines 40 to 51 in 150cc66

	func IsClientSentOp(op events.Opcode) bool {
	switch op {
	case events.OpcodeHeartbeat,
	events.OpcodeIdentify,
	events.OpcodeResume,
	events.OpcodeSubscribe,
	events.OpcodeSignal:
	return true
	default:
	return false
	}
	}