Function getSyncCommonProps

cli/internal/analytics/client.go:124–154

(invocationUUID uuid.UUID, event SyncStartedEvent, details *eventDetails)

}

func getSyncCommonProps(invocationUUID uuid.UUID, event SyncStartedEvent, details *eventDetails) rudderstack.Properties {
	destinationPaths := make([]string, len(event.Destinations))
	for i, d := range event.Destinations {
		destinationPaths[i] = d.Path
	}

	userID, userEmail := getUserIDEmail(details.user, details.currentTeam)

	props := rudderstack.NewProperties().
		// we are using the same invocation_uuid for sync_run_id
		// invocation_uuid to be consistent with the rest of the events
		// sync_run_id to match with cloud events
		Set("invocation_uuid", invocationUUID).
		Set("sync_run_id", invocationUUID).
		Set("team", details.currentTeam).
		Set("$groups", rudderstack.NewProperties().
			Set("team", details.currentTeam)).
		Set("environment", details.environment).
		Set("sync_name", event.Source.Name).
		Set("source_path", event.Source.Path).
		Set("destination_paths", destinationPaths).
		Set("user_id", userID).
		Set("user_email", userEmail)

	if event.ShardNum > 0 && event.ShardTotal > 0 {
		props = props.Set("shard_num", event.ShardNum).
			Set("shard_total", event.ShardTotal)
	}

	return props
}

func TrackSyncStarted(ctx context.Context, invocationUUID uuid.UUID, event SyncStartedEvent) {
	if client == nil {