events

var CancelCmd = &cobra.Command{
	Use:     "cancel [[flags]]",
	Aliases: []string{"canc", "abort", "remove", "purge"},
	Short:   "Cance Event from Event Bus",
	Args:    cobra.ExactArgs(0),
	RunE: func(cmd *cobra.Command, args []string) error {
		ctx, client := MakeEventsServiceClientOrFail()

		req := &pb.CancelRequest{}

		t, err := cmd.Flags().GetString("type")
		if err != nil {
			return err
		} else {
			req.Type = t
		}

		uuid, err := cmd.Flags().GetString("uuid")
		if err != nil {
			return err
		} else {
			req.Uuid = uuid
		}

		id, err := cmd.Flags().GetString("id")
		if err != nil {
			return err
		} else {
			req.Id = id
		}

		if _, err := client.Cancel(ctx, req); err != nil {
			return err
		}

		fmt.Println("Successfully removed event from the event bus.")

		return nil
	},
}

var ListCmd = &cobra.Command{
	Use:     "list [[flags]]",
	Aliases: []string{"ls", "list"},
	Short:   "List Events",
	Args:    cobra.ExactArgs(0),
	RunE: func(cmd *cobra.Command, args []string) error {
		ctx, client := MakeEventsServiceClientOrFail()

		req := &pb.ConsumeRequest{}

		t, err := cmd.Flags().GetString("type")
		if err != nil {
			return err
		} else {
			req.Type = t
		}

		uuid, err := cmd.Flags().GetString("uuid")
		if err != nil {
			return err
		} else {
			req.Uuid = uuid
		}

		events, err := client.List(ctx, req)
		if err != nil {
			return err
		}

		for _, event := range events.Events {
			fmt.Printf("%v\n", event)
		}

		return nil
	},
}

var PubCmd = &cobra.Command{
	Use:     "pub [template] [[flags]]",
	Aliases: []string{"publish", "send"},
	Short:   "Publishes Event",
	Args:    cobra.ExactArgs(1),
	RunE: func(cmd *cobra.Command, args []string) error {
		ctx, client := MakeEventsServiceClientOrFail()

		var format string
		{
			pathSlice := strings.Split(args[0], ".")
			format = pathSlice[len(pathSlice)-1]
		}

		template, err := os.ReadFile(args[0])
		if err != nil {
			fmt.Println("Error reading template file")
			return err
		}

		switch format {
		case "json":
		case "yml", "yaml":
			template, err = yaml.YAMLToJSON(template)
			if err != nil {
				return err
			}
		default:
			return errors.New("Unsupported template format " + format)
		}

		event := &pb.Event{}
		err = json.Unmarshal(template, &event)
		if err != nil {
			return err
		}

		t, err := cmd.Flags().GetString("type")
		if err != nil {
			return err
		} else {
			event.Type = t
		}

		uuid, err := cmd.Flags().GetString("uuid")
		if err != nil {
			return err
		} else {
			event.Uuid = uuid
		}

		response, err := client.Publish(ctx, event)
		if err != nil {
			return err
		}

		ok, err := tools.PrintJsonDataQ(cmd, response)
		if err != nil {
			return err
		}
		if !ok {
			fmt.Println("Successfully sent event")
		}

		return nil
	},
}

var SubCmd = &cobra.Command{
	Use:     "sub [[flags]]",
	Aliases: []string{"subscribe", "consume"},
	Short:   "Consume Events",
	Args:    cobra.ExactArgs(0),
	RunE: func(cmd *cobra.Command, args []string) error {
		ctx, client := MakeEventsServiceClientOrFail()

		req := &pb.ConsumeRequest{}

		t, err := cmd.Flags().GetString("type")
		if err != nil {
			return err
		} else {
			req.Type = t
		}

		uuid, err := cmd.Flags().GetString("uuid")
		if err != nil {
			return err
		} else {
			req.Uuid = uuid
		}

		stream, err := client.Consume(ctx, req)
		if err != nil {
			return err
		}

		for {
			msg, err := stream.Recv()
			if err != nil {
				return err
			}

			ok, err := tools.PrintJsonDataQ(cmd, msg)
			if err != nil {
				return err
			}
			if !ok {
				fmt.Println(msg)
			}
		}
	},
}