jestream

jestream/config.go

@@ -1,8 +0,0 @@
-package jestream
-
-// StreamConfig ...
-var StreamConfig = struct {
-	Notification string
-}{
-	Notification: "Service_Notification",
-}

jestream/notification.go

@@ -1,8 +0,0 @@
-package jestream
-
-// SubjectNotification ...
-var SubjectNotification = struct {
-	PushNotifications string
-}{
-	PushNotifications: "selly.pull.notification.push_notifications",
-}

js/model/selly.go

@@ -1,10 +1,10 @@
-package model
+package jsmodel
 
-// PayloadPushNotification ...
-type PayloadPushNotification struct {
+// PushNotification ...
+type PushNotification struct {
 	User        string `json:"user"`
 	Type        string `json:"type"`
-	TargetId    string `json:"targetId"`
+	TargetID    string `json:"targetId"`
 	IsFromAdmin bool   `json:"isFromAdmin"`
 	Category    string `json:"category"`
 	Options     struct {

js/subject/config.go

@@ -0,0 +1,10 @@
+package jssubject
+
+var root = "js"
+
+// prefixes ...
+var prefixes = struct {
+	Selly string
+}{
+	Selly: "selly",
+}

js/subject/selly.go

@@ -0,0 +1,19 @@
+package jssubject
+
+import (
+	"fmt"
+)
+
+// getSellyValue ...
+func getSellyValue(val string) string {
+	return fmt.Sprintf("%s.%s.%s", root, prefixes.Selly, val)
+}
+
+// Selly ...
+var Selly = struct {
+	Stream           string
+	PushNotification string
+}{
+	Stream:           prefixes.Selly,
+	PushNotification: getSellyValue("push_notifications"),
+}