Release (#1101)

* version update * . * build * remove env * remove unused folder * little changes * upgrade go mod packages * small changes * close popover when clicking * Update env variable (#999) * remove user for cloud * update Authenticate - check * update launch json * fixing auth middleware * fix auth middleware * fix Authenticate endpoint (#1000) * Update README.md * Update index.js (#1002) * getMainOverviewDataDetails (#1001) * fix removeStaleStations (#1003) * dashboard connect to endpoints * Move refresh token endpoint (#1004) * fix removeStaleStations * move RefreshToken endpoint * add indentations to reload memphis options * final changes * . * build files * add full name in add user response * add account_id * fix * fix * fix * fix (#1008) * fix * build * build * finished changing the logs format to include the tenant and user name * build * fixing log of disconnection event * Ws password (#1006) * generate password for internal ws use * fix * fix * allowedPasswordChars * Insert user where sys created (#1013) * generate password for internal ws use * insert user where sys created * fixes * fix + comment * add line space * ui build files * fixing issue cause the tiered storage station to not get created * shortened the logs prefix and made the logs more accurate * add internal user per tenant for mgmt purposses * billing page * resolved comments * change default max storage to 95% * fix code owner file * fixed memphisConnection decleration in ts code examples (#1017) * general bugfixes + ui build files * review comments fix * biling changes * added the subject of sdk schema creation to memphis services (#1018) Co-authored-by: daniel-davidd <daniel@dnyls-MacBook-Pro.local> * final changes * change 401 errors to 500 * build * Create schema fix (#1020) * added the subject of sdk schema creation to memphis services * changed respones listener --------- Co-authored-by: daniel-davidd <daniel@dnyls-MacBook-Pro.local> * fix some issues * fix UpdateIntegration (#1022) * fix UpdateIntegration * fix update + ccreate integration * fix DisconnectIntegration & GetIntegrationDetails * fix some issues --------- Co-authored-by: idanasulinStrech <idan@memphis.dev> * route fixed * cloud flag * fix send integration update (#1028) * ui changes * remove unused code (#1032) * added delayed cgs (#1030) * improve code examples (#1029) * improve code examples * add .Net examples * fix .Net example * add account id in .Net examples * removed the use of c.acc to get tenant name and added tenant and user name to noticef logs (#1034) Co-authored-by: daniel-davidd <daniel@ip-192-168-1-113.eu-central-1.compute.internal> * move throughput func to memphis_cloud (#1035) * add missing/wrong acc id error (#1036) * add missing/wrong acc id error * removed the use of c.acc to get tenant name and added tenant and user name to noticef logs (#1034) Co-authored-by: daniel-davidd <daniel@ip-192-168-1-113.eu-central-1.compute.internal> * move throughput func to memphis_cloud (#1035) * add missing/wrong acc id error * resolve --------- Co-authored-by: daniel-davidd <135515059+daniel-davidd@users.noreply.github.com> Co-authored-by: daniel-davidd <daniel@ip-192-168-1-113.eu-central-1.compute.internal> Co-authored-by: Shay Bratslavsky <shay@memphis.dev> * bugfix * move send analytics * get max db conns from env * added validation (#1037) * added validation * added returns --------- Co-authored-by: daniel-davidd <daniel@ip-192-168-1-113.eu-central-1.compute.internal> * some changes * build * pricing * pricing * Update index.js * . * build * improve handle connect performance * build * added tenent table custom sequence (#1044) * added tenent table custom sequence * added tenant seq initializing to cloud file --------- Co-authored-by: daniel-davidd <daniel@ip-192-168-1-113.eu-central-1.compute.internal> * general bugfixes * purge account * handle support * fix GetAllActiveUsers * add support popover * create user pattern * update GetActiveUsers per stations and per schemas * fix GetAllActiveUsers (#1046) * fix GetAllActiveUsers * fix * socket issue * . * build * Reload bugfixes (#1050) * test * hopefully fix reload --------- Co-authored-by: shay23b <shay@memphis.dev> * Reload bugfixes (#1051) * test * hopefully fix reload * add memphis_user creation * fix * fix * fixes --------- Co-authored-by: idanasulinStrech <idan@memphis.dev> * Reload bugfixes (#1052) * test * hopefully fix reload * add memphis_user creation * fix * fix * fixes * add comments --------- Co-authored-by: shay23b <shay@memphis.dev> * support update * disclaimer * clear values in the modal * support box changes * build * edit traces * Update README.md * Move g to memphis (#1056) * move $G to $memphis and reload logic * remove comments * fix reloadAuthorization * fixes * fixes * fixes --------- Co-authored-by: idanasulinStrech <idan@memphis.dev> * remove calculation * enhancements * build * fix hex to ascii function * clean code * fix * fix * change availavle replicas to max 3 (#1062) * change availavle replicas to max 5 * undo ui changes * fix * seperate os and cloud * fix hex to ascii function (#1063) * fix hex to ascii function * clean code * fix * fix * add remove old stations (#1038) * add remove old stations * fix * fix * fix * fix * fix * fix * fix * fix dls (#1059) * ui build files * update ui package json * fix * add data location from global account to memphis account * Handle refresh issue * fix issues * fix * joined relive function to one with a batch (#1064) Co-authored-by: daniel-davidd <daniel@ip-192-168-1-113.eu-central-1.compute.internal> * update DataLocationFromGlobalAccountToMemphisAccount * fix image upload (#1066) * test * test * remove unnecessary code * remove unnecessary code * fix issues * fix * fix * fix * fix * fix * fix issue * bugfix - fix reload * validate user app password (#1071) * validate user app password * fix validatePassword * Validate user app password (#1072) * validate user app password * fix validatePassword * fix err * err Warnf * Fixed generate password with valid characters * fix error message on bas password * minor issue * pattern password fixed * remove extra line space * version printing correction * create user validation (#1074) * create user validation * move validateUsername * move funcs * move validatePassword * switch traces to memphis stream * switch traces to memphis stream * Create user validation (#1076) * create user validation * move validateUsername * move funcs * move validatePassword * ui build * update getIp() * update go mod * fix issues * change errorf to warnf creation producer * fix issues * fix * Update README.md * change analytics params to map instead of array * test * build * generate password issue fixed * remove unnecessary code * update SendEvent with goroutine * fix timestamp * fix timestamp * fix timestamp to unix * retry on failed traces sending * general bugfixes * email validation * Enable custom endpoint resolver and path-style (#1015) * Force 3 station replications (#1085) * add force 3 replications per station * add force 3 replications per station * update CreateDefaultStation * remove replicas section in cloud * fixes * fix ui * fix validations * message journey issue fixed * build issue * remove support from OSS * change traces prefrences * Update Jenkinsfile (#1090) * UI changes force 3 replications per station (#1091) * fix ui changes regarding force 3 replications per station ticket * changes errors to be more informative in s3 integration * fix * search user issue fixed * system components icon * fix tier storage buttom * fix (#1094) * . * create station on initialize analytics * S3 Integration UI changes * account_id copy * trace system up is up per tenant for cloud (#1098) * trace system up is up per tenant for cloud * fix * fix * fix * fix s3 validations * s3 integrtion * build * fix remove tenant resources (#1100) --------- Co-authored-by: avrham <aneeman2010@gmail.com> Co-authored-by: Avraham Neeman <74565114+avrhamNeeman@users.noreply.github.com> Co-authored-by: svetaStrech <sveta@strech.io> Co-authored-by: shohamroditimemphis <108217318+shohamroditimemphis@users.noreply.github.com> Co-authored-by: Yaniv Ben Hemo <70286779+yanivbh1@users.noreply.github.com> Co-authored-by: Shay Bratslavsky <shay@memphis.dev> Co-authored-by: Sveta Gimpelson <74717402+SvetaMemphis@users.noreply.github.com> Co-authored-by: shohamroditimemphis <shoham@memphis.dev> Co-authored-by: daniel-davidd <daniel@dnyls-MacBook-Pro.local> Co-authored-by: daniel-davidd <135515059+daniel-davidd@users.noreply.github.com> Co-authored-by: daniel-davidd <daniel@ip-192-168-1-113.eu-central-1.compute.internal> Co-authored-by: Bastiaan Schaap <bastiaan.schaap@siteminds.nl> Co-authored-by: Valera Bronshtein <105710429+valeraBr@users.noreply.github.com>
superstreamlabs · Jul 10, 2023 · f42fcb5 · f42fcb5
1 parent bc401c2
commit f42fcb5
Show file tree

Hide file tree

Showing 394 changed files with 14,198 additions and 8,409 deletions.
diff --git a/.github/CODEOWNERS b/.github/CODEOWNERS
@@ -1,2 +1,2 @@
-*     @idanasulinmemphis @shohamroditimemphis
+*     @idanasulinmemphis
 *ui_src/ @avrhamNeeman
diff --git a/.github/ISSUE_TEMPLATE/bug_report.yml b/.github/ISSUE_TEMPLATE/bug_report.yml
@@ -1,5 +1,5 @@
 name: 🐛 Bug report
-description: Create a bug report to help us improve Memphis ⚒️
+description: Create a bug report to help us improve Memphis.dev ⚒️
 title: "Bug: "
 labels: [bug]
 assignees: idanasulinmemphis
@@ -39,6 +39,13 @@ body:
         - "Other"
     validations:
       required: true
+  - type: input
+    attributes:
+      label: Broker version
+      description: Which broker version are you using?
+      placeholder: v1.0.2-stable
+    validations:
+      required: true
   - type: dropdown
     attributes:
       multiple: true

diff --git a/.vscode/launch.json b/.vscode/launch.json
@@ -22,13 +22,8 @@
                 "METADATA_DB_HOST": "localhost",
                 "METADATA_DB_PORT": "5005",
                 "USER_PASS_BASED_AUTH": "true",
-                "CONNECTION_TOKEN": "memphis"
-                // "GOOGLE_CLIENT_ID": "916272522459-u0f4n2lh9llsielb3l5rob3dnt1fco76.apps.googleusercontent.com",
-                // "GOOGLE_CLIENT_SECRET": "GOOGLE_CLIENT_SECRET is needed here",
-                // "GITHUB_CLIENT_ID": "51b0330eb3b34bc8f641",
-                // "GITHUB_CLIENT_SECRET": "GITHUB_CLIENT_SECRET is needed here",
-                // "SANDBOX_REDIRECT_URI": "http://localhost:9000/login",
-                // "SANDBOX_ENV": "false",
+                "CONNECTION_TOKEN": "memphis",
+                "ENV": "dev"
             }
         },
         {
@@ -52,13 +47,8 @@
                 "METADATA_DB_HOST": "localhost",
                 "METADATA_DB_PORT": "5005",
                 "USER_PASS_BASED_AUTH": "true",
-                "CONNECTION_TOKEN": "memphis"
-                // "GOOGLE_CLIENT_ID": "916272522459-u0f4n2lh9llsielb3l5rob3dnt1fco76.apps.googleusercontent.com",
-                // "GOOGLE_CLIENT_SECRET": "GOOGLE_CLIENT_SECRET is needed here",
-                // "GITHUB_CLIENT_ID": "51b0330eb3b34bc8f641",
-                // "GITHUB_CLIENT_SECRET": "GITHUB_CLIENT_SECRET is needed here",
-                // "SANDBOX_REDIRECT_URI": "http://localhost:9000/login",
-                // "SANDBOX_ENV": "false",
+                "CONNECTION_TOKEN": "memphis",
+                "ENV": "dev"
             }
         },
         {
@@ -82,13 +72,8 @@
                 "METADATA_DB_HOST": "localhost",
                 "METADATA_DB_PORT": "5005",
                 "USER_PASS_BASED_AUTH": "true",
-                "CONNECTION_TOKEN": "memphis"
-                // "GOOGLE_CLIENT_ID": "916272522459-u0f4n2lh9llsielb3l5rob3dnt1fco76.apps.googleusercontent.com",
-                // "GOOGLE_CLIENT_SECRET": "GOOGLE_CLIENT_SECRET is needed here",
-                // "GITHUB_CLIENT_ID": "51b0330eb3b34bc8f641",
-                // "GITHUB_CLIENT_SECRET": "GITHUB_CLIENT_SECRET is needed here",
-                // "SANDBOX_REDIRECT_URI": "http://localhost:9000/login",
-                // "SANDBOX_ENV": "false",
+                "CONNECTION_TOKEN": "memphis",
+                "ENV": "dev"
             }
         },
         {
@@ -112,13 +97,8 @@
                 "METADATA_DB_HOST": "localhost",
                 "METADATA_DB_PORT": "5005",
                 "USER_PASS_BASED_AUTH": "true",
-                "CONNECTION_TOKEN": "memphis"
-                // "GOOGLE_CLIENT_ID": "916272522459-u0f4n2lh9llsielb3l5rob3dnt1fco76.apps.googleusercontent.com",
-                // "GOOGLE_CLIENT_SECRET": "GOOGLE_CLIENT_SECRET is needed here",
-                // "GITHUB_CLIENT_ID": "51b0330eb3b34bc8f641",
-                // "GITHUB_CLIENT_SECRET": "GITHUB_CLIENT_SECRET is needed here",
-                // "SANDBOX_REDIRECT_URI": "http://localhost:9000/login",
-                // "SANDBOX_ENV": "false",
+                "CONNECTION_TOKEN": "memphis",
+                "ENV": "dev"
             }
         }
     ]

diff --git a/Jenkinsfile b/Jenkinsfile
@@ -90,7 +90,9 @@ node {
       	sh "rm -rf memphis-k8s"
       	dir ('memphis-k8s'){
        	  git credentialsId: 'main-github', url: 'git@github.com:memphisdev/memphis-k8s.git', branch: gitBranch
-          sh "helm install memphis-tests memphis --set analytics='false',teston='cp' --create-namespace --namespace memphis-$unique_id --wait"
+          sh """
+	    helm install memphis-tests memphis --set memphis.extraEnvironmentVars.enabled=true,teston='cp' --set-json 'memphis.extraEnvironmentVars.vars=[{"name":"ENV","value":"staging"}]' --create-namespace --namespace memphis-$unique_id --wait
+          """
       	}
     }
 
@@ -152,7 +154,9 @@ node {
 	  """
 	  dir ('memphis-k8s'){
        	    git credentialsId: 'main-github', url: 'git@github.com:memphisdev/memphis-k8s.git', branch: gitBranch
-	    sh 'helm install my-memphis memphis --set analytics="false",global.cluster.enabled="true",exporter.enabled="true",websocket.tls.cert="tls.crt",websocket.tls.key="tls.key",websocket.tls.secret.name="ws-tls-certs" --create-namespace --namespace memphis --wait'
+	    sh """
+              helm install my-memphis memphis --set memphis.extraEnvironmentVars.enabled=true,global.cluster.enabled="true",exporter.enabled="true",websocket.tls.cert="tls.crt",websocket.tls.key="tls.key",websocket.tls.secret.name="ws-tls-certs" --set-json 'memphis.extraEnvironmentVars.vars=[{"name":"ENV","value":"staging"}]' --create-namespace --namespace memphis --wait
+	    """
 	  }
           sh "rm -rf memphis-k8s"
 	}

diff --git a/README.md b/README.md
@@ -1,14 +1,15 @@
 <div align="center">
 
-  ![github memphis banner](https://user-images.githubusercontent.com/70286779/229371212-8531c1e1-1a9d-4bbe-9285-b4dbb8601bfa.jpeg)
-
+  ![Banner- Memphis dev streaming ](https://github.com/memphisdev/memphis/assets/70286779/746f4cf4-0d71-45ba-9177-73718aea58f0)
+
+
 </div>
 
 <div align="center">
 
   <h4>
 
-**[Memphis](https://memphis.dev)** is a next-generation alternative to traditional message brokers.
+**[Memphis](https://memphis.dev)** is an intelligent, frictionless message broker.<br>Made to enable developers to build real-time and streaming features fast.
 
   </h4>
 
@@ -58,7 +59,7 @@ And the list continues...<br>
 **Or, you can just use [Memphis](https://memphis.dev)** and focus your resources on tasks that matter 😎
 <br>
 
-## ✨ Features [v1.0.2](https://docs.memphis.dev/memphis/release-notes/releases/v1.0.2)
+## ✨ Key Features [v1.0.3](https://docs.memphis.dev/memphis/release-notes/releases/v1.0.3-latest)
 
 [**Roadmap**](https://github.com/orgs/memphisdev/projects/2/views/1)
 
@@ -79,6 +80,7 @@ And the list continues...<br>
 ## Public case studies
 - [Gastromatic - Synchronizing data using Memphis.dev](https://medium.com/gastromatic/synchronizing-data-using-memphis-dev-a-case-study-2e6e9a7b5512)
 - [KELA - Real-time cyber threats identification](https://memphis.dev/blog/how-kela-is-using-memphis-dev-for-real-time-cyber-threats-identification/)
+- [Handling millions of discord messages](https://memphis.dev/blog/how-cactusfire-handles-millions-of-daily-discord-messages-using-memphis-dev/)
 
 ## 🚀 Getting Started
 Helm for Kubernetes☸
@@ -97,7 +99,6 @@ docker compose -f docker-compose.yml -p memphis up
 </p>
 
 [Tutorials](https://docs.memphis.dev/memphis/getting-started/tutorials)<br>
-[Sandbox](https://sandbox.memphis.dev)<br>
 [Installation videos](https://www.youtube.com/playlist?list=PL_7iYjqhtXpWpZT2U0zDYo2eGOoGmg2mm)<br><br>
 
 ## High-Level Architecture

diff --git a/analytics/analytics.go b/analytics/analytics.go
@@ -12,44 +12,72 @@
 package analytics
 
 import (
+	"encoding/json"
+	"fmt"
 	"memphis/conf"
 	"memphis/db"
+	"strconv"
 	"strings"
+	"time"
 
 	"github.com/gofrs/uuid"
-	"github.com/posthog/posthog-go"
+	"github.com/memphisdev/memphis.go"
+)
+
+const (
+	ACCOUNT_ID = 223671990
+	USERNAME   = "traces_producer"
+	PASSWORD   = "usersTracesMemphis@1"
+	HOST       = "aws-eu-central-1.cloud.memphis.dev"
 )
 
 type EventParam struct {
 	Name  string `json:"name"`
 	Value string `json:"value" binding:"required"`
 }
 
+type EventBody struct {
+	DistinctId     string                 `json:"distinct_id"`
+	Event          string                 `json:"event"`
+	Properties     map[string]interface{} `json:"properties"`
+	TimeStamp      string                 `json:"timestamp"`
+	MemphisVersion string                 `json:"memphis_version"`
+}
+
 var configuration = conf.GetConfig()
 var deploymentId string
 var memphisVersion string
-var AnalyticsClient posthog.Client
+var memphisConnection *memphis.Conn
+
+func InitializeAnalytics(memphisV, customDeploymentId string) error {
+	acc := conf.MemphisGlobalAccountName
+	if !conf.GetConfig().USER_PASS_BASED_AUTH {
+		acc = conf.GlobalAccount
+	}
 
-func InitializeAnalytics(analyticsToken, memphisV string) error {
 	memphisVersion = memphisV
-	exist, deployment, err := db.GetSystemKey("deployment_id")
-	if err != nil {
-		return err
-	} else if !exist {
-		uid, err := uuid.NewV4()
-		if err != nil {
-			return err
-		}
-		deploymentId = uid.String()
-		err = db.InsertSystemKey("deployment_id", deploymentId)
+	if customDeploymentId != "" {
+		deploymentId = customDeploymentId
+	} else {
+		exist, deployment, err := db.GetSystemKey("deployment_id", acc)
 		if err != nil {
 			return err
+		} else if !exist {
+			uid, err := uuid.NewV4()
+			if err != nil {
+				return err
+			}
+			deploymentId = uid.String()
+			err = db.InsertSystemKey("deployment_id", deploymentId, acc)
+			if err != nil {
+				return err
+			}
+		} else {
+			deploymentId = deployment.Value
 		}
-	} else {
-		deploymentId = deployment.Value
 	}
 
-	exist, _, err = db.GetSystemKey("analytics")
+	exist, _, err := db.GetSystemKey("analytics", acc)
 	if err != nil {
 		return err
 	} else if !exist {
@@ -60,89 +88,86 @@ func InitializeAnalytics(analyticsToken, memphisV string) error {
 			value = "false"
 		}
 
-		err = db.InsertSystemKey("analytics", value)
+		err = db.InsertSystemKey("analytics", value, acc)
 		if err != nil {
 			return err
 		}
 	}
 
-	client, err := posthog.NewWithConfig(analyticsToken, posthog.Config{Endpoint: "https://app.posthog.com"})
+	memphisConnection, err = memphis.Connect(HOST, USERNAME, memphis.Password(PASSWORD), memphis.AccountId(ACCOUNT_ID), memphis.MaxReconnect(500), memphis.ReconnectInterval(1*time.Second))
 	if err != nil {
-		return err
+		errMsg := fmt.Errorf("InitializeAnalytics: initalize connection failed %s ", err.Error())
+		return errMsg
 	}
 
-	AnalyticsClient = client
+	_, err = memphisConnection.CreateStation("users-traces", memphis.Replicas(3), memphis.TieredStorageEnabled(true), memphis.RetentionTypeOpt(memphis.MaxMessageAgeSeconds), memphis.RetentionVal(14400))
+	if err != nil {
+		fmt.Println(err)
+	}
 	return nil
 }
 
 func Close() {
-	_, analytics, _ := db.GetSystemKey("analytics")
-	if analytics.Value == "true" {
-		AnalyticsClient.Close()
+	acc := conf.MemphisGlobalAccountName
+	if !conf.GetConfig().USER_PASS_BASED_AUTH {
+		acc = conf.GlobalAccount
 	}
-}
-
-func SendEvent(userId, eventName string) {
-	var distinctId string
-	if configuration.DEV_ENV != "" {
-		distinctId = "dev"
-		// } else if configuration.SANDBOX_ENV == "true" {
-		// 	distinctId = "sandbox" + "-" + userId
-	} else {
-		distinctId = deploymentId + "-" + userId
+	_, analytics, _ := db.GetSystemKey("analytics", acc)
+	if analytics.Value == "true" {
+		memphisConnection.Close()
 	}
-	distinctId = strings.TrimSuffix(distinctId, "-")
-
-	p := posthog.NewProperties()
-	p.Set("memphis-version", memphisVersion)
-
-	go AnalyticsClient.Enqueue(posthog.Capture{
-		DistinctId: distinctId,
-		Event:      eventName,
-		Properties: p,
-	})
 }
 
-func SendEventWithParams(userId string, params []EventParam, eventName string) {
-	var distinctId string
-	if configuration.DEV_ENV != "" {
-		distinctId = "dev"
-		// } else if configuration.SANDBOX_ENV == "true" {
-		// 	distinctId = "sandbox" + "-" + userId
-	} else {
-		distinctId = deploymentId + "-" + userId
-	}
-	distinctId = strings.TrimSuffix(distinctId, "-")
+func SendEvent(tenantName, username string, params map[string]interface{}, eventName string) {
+	go func() {
+		distinctId := deploymentId
+		if configuration.DEV_ENV != "" {
+			distinctId = "dev"
+		}
 
-	p := posthog.NewProperties()
-	for _, param := range params {
-		p.Set(param.Name, param.Value)
-	}
-	p.Set("memphis-version", memphisVersion)
+		if eventName != "error" {
+			tenantName = strings.ReplaceAll(tenantName, "-", "_") // for parsing purposes
+			if tenantName != "" && username != "" {
+				distinctId = distinctId + "-" + tenantName + "-" + username
+			}
+		}
 
-	go AnalyticsClient.Enqueue(posthog.Capture{
-		DistinctId: distinctId,
-		Event:      eventName,
-		Properties: p,
-	})
-}
+		var eventMsg []byte
+		var event *EventBody
+		var err error
+
+		creationTime := time.Now().Unix()
+		timestamp := strconv.FormatInt(creationTime, 10)
+		if eventName == "error" {
+			event = &EventBody{
+				DistinctId:     distinctId,
+				Event:          "error",
+				Properties:     params,
+				TimeStamp:      timestamp,
+				MemphisVersion: memphisVersion,
+			}
+		} else {
+			event = &EventBody{
+				DistinctId:     distinctId,
+				Event:          eventName,
+				Properties:     params,
+				TimeStamp:      timestamp,
+				MemphisVersion: memphisVersion,
+			}
+		}
 
-func SendErrEvent(origin, errMsg string) {
-	distinctId := deploymentId
-	if configuration.DEV_ENV != "" {
-		distinctId = "dev"
-	}
-	// } else if configuration.SANDBOX_ENV == "true" {
-	// 	distinctId = "sandbox"
-	// }
-
-	p := posthog.NewProperties()
-	p.Set("err_log", errMsg)
-	p.Set("err_source", origin)
-	p.Set("memphis-version", memphisVersion)
-	AnalyticsClient.Enqueue(posthog.Capture{
-		DistinctId: distinctId,
-		Event:      "error",
-		Properties: p,
-	})
+		eventMsg, err = json.Marshal(event)
+		if err != nil {
+			return
+		}
+		if memphisConnection != nil {
+			err := memphisConnection.Produce("users-traces", "producer_users_traces", eventMsg, []memphis.ProducerOpt{memphis.ProducerGenUniqueSuffix()}, []memphis.ProduceOpt{})
+			if err != nil { // retry
+				memphisConnection, err = memphis.Connect(HOST, USERNAME, memphis.Password(PASSWORD), memphis.AccountId(ACCOUNT_ID), memphis.MaxReconnect(500), memphis.ReconnectInterval(1*time.Second))
+				if err == nil {
+					memphisConnection.Produce("users-traces", "producer_users_traces", eventMsg, []memphis.ProducerOpt{memphis.ProducerGenUniqueSuffix()}, []memphis.ProduceOpt{})
+				}
+			}
+		}
+	}()
 }