catdevman / awsume-go Goto Github PK

		}
		argsplugin := raw.(shared.ArgumentsService)
		args, err := argsplugin.Get()
		// TODO: handle err from rpc call
		// TODO: handle if plugins have the same flag
		for _, a := range args.Arguments {
			switch a.Type {
			case "string":
				rootCmd.PersistentFlags().String(a.Name, a.Value, a.Flag)
			case "int", "int32", "int64":
				// TODO: handle err when converting string to int
				v, _ := strconv.Atoi(a.Value)
				rootCmd.PersistentFlags().Int(a.Name, v, a.Flag)
			case "bool":
				// TODO: handle error when converting string to bool
				v, _ := strconv.ParseBool(a.Value)
				rootCmd.PersistentFlags().Bool(a.Name, v, a.Flag)
			}
		}
	}
}

func handlePostArgs(plugs []*plugin.Client) {

		}
		argsplugin := raw.(shared.ArgumentsService)
		args, err := argsplugin.Get()
		// TODO: handle err from rpc call
		// TODO: handle if plugins have the same flag
		for _, a := range args.Arguments {
			switch a.Type {
			case "string":
				rootCmd.PersistentFlags().String(a.Name, a.Value, a.Flag)
			case "int", "int32", "int64":
				// TODO: handle err when converting string to int
				v, _ := strconv.Atoi(a.Value)
				rootCmd.PersistentFlags().Int(a.Name, v, a.Flag)
			case "bool":
				// TODO: handle error when converting string to bool
				v, _ := strconv.ParseBool(a.Value)
				rootCmd.PersistentFlags().Bool(a.Name, v, a.Flag)
			}
		}
	}
}

func handlePostArgs(plugs []*plugin.Client) {

		}
		argsplugin := raw.(shared.ArgumentsService)
		args, err := argsplugin.Get()
		// TODO: handle err from rpc call
		// TODO: handle if plugins have the same flag
		for _, a := range args.Arguments {
			switch a.Type {
			case "string":
				rootCmd.PersistentFlags().String(a.Name, a.Value, a.Flag)
			case "int", "int32", "int64":
				// TODO: handle err when converting string to int
				v, _ := strconv.Atoi(a.Value)
				rootCmd.PersistentFlags().Int(a.Name, v, a.Flag)
			case "bool":
				// TODO: handle error when converting string to bool
				v, _ := strconv.ParseBool(a.Value)
				rootCmd.PersistentFlags().Bool(a.Name, v, a.Flag)
			}
		}
	}
}

func handlePostArgs(plugs []*plugin.Client) {

		client := plugin.NewClient(&plugin.ClientConfig{
			HandshakeConfig:  shared.Handshake,
			Plugins:          shared.PluginMap,
			Cmd:              exec.Command("sh", "-c", filename), // TODO: This seems heavy handed can we load these paths from the conf file
			AllowedProtocols: []plugin.Protocol{plugin.ProtocolGRPC},
			Logger:           logger,
		})

		}
		argsplugin := raw.(shared.ArgumentsService)
		args, err := argsplugin.Get()
		// TODO: handle err from rpc call
		// TODO: handle if plugins have the same flag
		for _, a := range args.Arguments {
			switch a.Type {
			case "string":
				rootCmd.PersistentFlags().String(a.Name, a.Value, a.Flag)
			case "int", "int32", "int64":
				// TODO: handle err when converting string to int
				v, _ := strconv.Atoi(a.Value)
				rootCmd.PersistentFlags().Int(a.Name, v, a.Flag)
			case "bool":
				// TODO: handle error when converting string to bool
				v, _ := strconv.ParseBool(a.Value)
				rootCmd.PersistentFlags().Bool(a.Name, v, a.Flag)
			}
		}
	}
}

func handlePostArgs(plugs []*plugin.Client) {

func (m *ArgumentsServer) Post(ctx context.Context, req *proto.ArgumentsMsg) (*proto.ArgumentsMsg, error) {
	argsMsg, err := m.Impl.Post(req)
	// TODO: Turn shared Arguments into proto ArgumentsMsg
	return argsMsg, err
}