Merge pull request #3 from openebs/add-userid

feat(payload): add user_id to payload

client/client.go

@@ -29,6 +29,7 @@ func (c *MeasurementClient) Send(event *event.OpenebsEvent) error {
 	dataPayload, err := payload.NewPayload(
 		payload.WithClientId(client.clientId),
 		payload.WithOpenebsEvent(event),
+		payload.WithUserId(client.clientId),
 	)
 
 	if err != nil {

example/main.go

@@ -9,7 +9,7 @@ func main() {
 	client, err := gaClient.NewMeasurementClient(
 		gaClient.WithApiSecret("NguBiGh6QeOdeG3zJswggQ"),
 		gaClient.WithMeasurementId("G-TZGP46618W"),
-		gaClient.WithClientId("uniqueUserId-000000001"),
+		gaClient.WithClientId("uniqueClientId-000000001"),
 	)
 	if err != nil {
 		panic(err)

payload/build.go

@@ -11,6 +11,7 @@ type PayloadOption func(*Payload) error
 type Payload struct {
 	ClientId string     `json:"client_id"`
 	Events   []ApiEvent `json:"events"`
+	UserId   string     `json:"user_id"`
 }
 
 type ApiEvent struct {
@@ -43,6 +44,17 @@ func WithClientId(clientId string) PayloadOption {
 	}
 }
 
+func WithUserId(userId string) PayloadOption {
+	return func(p *Payload) error {
+		if len(userId) == 0 {
+			return errors.Errorf("failed to set Payload userId: id is an empty string")
+		}
+
+		p.UserId = userId
+		return nil
+	}
+}
+
 func WithOpenebsEvent(event *event.OpenebsEvent) PayloadOption {
 	return func(p *Payload) error {
 		p.Events = append(p.Events, ApiEvent{