Method RedisFlush

tools/mage/dev.go:139–173

RedisFlush deletes all keys from redis except specific task queues.

()

// RedisFlush deletes all keys from redis except specific task queues.
func (Dev) RedisFlush() error {
	if mg.Verbose() {
		fmt.Println("Deleting keys from redis (preserving task queues)")
	}

	keys, err := sh.Output("docker", dockerComposeFlags("exec", "-T", "redis", "redis-cli", "keys", "ttn:v3:*")...)
	if err != nil {
		return err
	}

	ks := strings.Split(keys, "\n")
	if len(ks) == 0 {
		return nil
	}

	// Delete all keys except preserved ones
	baseArgs := []string{"exec", "-T", "redis", "redis-cli", "del"}
	keysToDelete := make([]string, 0, len(ks))

	for _, k := range ks {
		if k != "ttn:v3:ns:tasks:downlink:ready" &&
			k != "ttn:v3:ns:tasks:downlink:input" &&
			k != "ttn:v3:ns:application-uplinks:uplinks" {
			keysToDelete = append(keysToDelete, k)
		}
	}
	// No keys to delete
	if len(keysToDelete) == len(baseArgs) {
		return nil
	}

	flags := dockerComposeFlags(append(baseArgs, keysToDelete...)...)
	_, err = sh.Exec(nil, nil, os.Stderr, "docker", flags...)
	return err
}

// DBStart starts the databases of the development environment.
func (Dev) DBStart() error {