Function hintSelectMessage

cli/cmd/sync_v3.go:740–811

(destinationSpecs []specs.Destination, statsPerTable *utils.ConcurrentMap[string, SyncRunTableProgressValue], sourceTables map[string]bool)

}

func hintSelectMessage(destinationSpecs []specs.Destination, statsPerTable *utils.ConcurrentMap[string, SyncRunTableProgressValue], sourceTables map[string]bool) {
	val, _ := config.GetValue("first_sync_completed")
	firstSyncCompleted, _ := strconv.ParseBool(val)
	if firstSyncCompleted {
		return
	}

	if auth.NewTokenClient().GetTokenType() != auth.BearerToken {
		return
	}

	ensureDependencies := func(tableQuery tableQueries) bool {
		for _, dependency := range tableQuery.Dependencies {
			_, ok := sourceTables[dependency]
			if !ok {
				return false
			}
		}
		return true
	}

	destPaths := lo.SliceToMap(destinationSpecs, func(spec specs.Destination) (string, specs.Destination) {
		return spec.Path, spec
	})

	for _, tablePair := range tablesQueries {
		tables := lo.Keys(tablePair)
		if len(tables) == 0 {
			continue
		}
		tableName := tables[0]
		rows, ok := statsPerTable.Get(tableName)
		if !ok || rows.Rows == 0 {
			continue
		}

		tableQuery := tablePair[tableName]

		if !ensureDependencies(tableQuery) {
			continue
		}

		for _, destinationQuery := range tableQuery.Destinations {
			destinationPaths := lo.Keys(destinationQuery)
			if len(destinationPaths) == 0 {
				continue
			}
			destinationPath := destinationPaths[0]
			destSpec, ok := destPaths[destinationPath]
			if !ok {
				continue
			}

			fmt.Println()
			fmt.Println("🎉 Success!")
			fmt.Println()
			fmt.Println(tableQuery.Description)
			fmt.Println()