client/socket.go

@@ -1,21 +0,0 @@
-package client
-
-import (
-	"git.selly.red/Selly-Modules/natsio"
-	"git.selly.red/Selly-Modules/natsio/model"
-	"git.selly.red/Selly-Modules/natsio/subject"
-)
-
-// Socket ...
-type Socket struct{}
-
-// GetSocket ...
-func GetSocket() Socket {
-	return Socket{}
-}
-
-// EmitSocketEventDataReward ...
-func (s Socket) EmitSocketEventDataReward(p model.PayloadEmitSocketEvent) error {
-	_, err := natsio.GetServer().Request(subject.Socket.EmitEventReward, toBytes(p))
-	return err
-}

model/socket.go

@@ -1,9 +0,0 @@
-package model
-
-// PayloadEmitSocketEvent ...
-type PayloadEmitSocketEvent struct {
-	User        string `json:"user"`
-	Message     string `json:"message"`
-	Data        string `json:"data"`
-	IsNotRemove bool   `json:"isNotRemove"`
-}

subject/config.go

@@ -23,7 +23,6 @@ var prefixes = struct {
 	Affiliate          string
 	Product            string
 	Queue              string
-	Socket             string
 }{
 	Communication:      "communication",
 	Order:              "order",
@@ -47,5 +46,4 @@ var prefixes = struct {
 	Affiliate:          "affiliate",
 	Product:            "product",
 	Queue:              "queue",
-	Socket:             "socket",
 }

subject/socket.go

@@ -1,14 +0,0 @@
-package subject
-
-import "fmt"
-
-func getSocketValue(val string) string {
-	return fmt.Sprintf("%s.%s", prefixes.Socket, val)
-}
-
-// Socket ...
-var Socket = struct {
-	EmitEventReward string
-}{
-	EmitEventReward: getSocketValue("emit_event_reward"),
-}