Function main

pkg/redis/codec/main.go:40–95

()

}

func main() {
	typ := flag.String("type", "", "Proto type to be used")
	encode := flag.Bool("encode", false, "Whether encoding should be performed (default: false)")

	flag.Parse()

	var pb proto.Message
	switch *typ {
	case "":
		log.Print("Type cannot be empty")
		flag.Usage()
		os.Exit(1)

	case "ttnpb.EndDevice":
		pb = &ttnpb.EndDevice{}
	case "ttnpb.GatewayConnectionStats":
		pb = &ttnpb.GatewayConnectionStats{}
	case "ttnpb.ApplicationActivationSettings":
		pb = &ttnpb.ApplicationActivationSettings{}
	case "ttnpb.UplinkToken":
		pb = &ttnpb.UplinkToken{}
	default:
		log.Printf("Unknown type: `%s`", *typ)
		flag.Usage()
		os.Exit(1)
	}
	if *encode {
		if err := json.NewDecoder(os.Stdin).Decode(pb); err != nil {
			log.Fatalf("Failed to read proto as JSON from stdin: %v", err)
		}
		s, err := redis.MarshalProto(pb)
		if err != nil {
			log.Fatalf("Failed to marshal proto: %v", err)
		}
		if _, err := os.Stdout.Write([]byte(s)); err != nil {
			log.Fatalf("Failed to write to stdout: %v", err)
		}
		return
	}
	rd := bufio.NewReader(os.Stdin)
	for {
		b, err := rd.ReadString('\n')
		if err != nil {
			if errors.Is(err, io.EOF) {
				break
			}
			log.Fatalf("Failed to read from stdin: %v", err)
		}
		if err := redis.UnmarshalProto(b, pb); err != nil {
			log.Fatalf("Failed to unmarshal proto: %v", err)
		}
		if err := json.NewEncoder(os.Stdout).Encode(pb); err != nil {
			log.Fatalf("Failed to write proto as JSON to stdout: %v", err)
		}
	}
}