Add support for database events in Doctl

commands/databases.go

@@ -155,6 +155,7 @@ For PostgreSQL and MySQL clusters, you can also provide a disk size in MiB to sc
 	cmd.AddCommand(databaseOptions())
 	cmd.AddCommand(databaseConfiguration())
 	cmd.AddCommand(databaseTopic())
+	cmd.AddCommand(databaseEvents())
 
 	return cmd
 }
@@ -2441,3 +2442,40 @@ func RunDatabaseConfigurationUpdate(c *CmdConfig) error {
 	}
 	return nil
 }
+
+func databaseEvents() *Command {
+	listDatabaseEvents := `
+
+You can get a list of database events by calling:
+
+	doctl databases events list <cluster-id>`
+	cmd := &Command{
+		Command: &cobra.Command{
+			Use:   "events",
+			Short: "Display commands for listing database cluster events",
+			Long:  `The subcommands under ` + "`" + `doctl databases events` + "`" + ` are for listing database cluster events.` + listDatabaseEvents,
+		},
+	}
+	cmdDatabaseEventsList := CmdBuilder(cmd, RunDatabaseEvents, "list <database-cluster-id>", "List your database cluster events", `Retrieves a list of database clusters events:`+listDatabaseEvents, Writer, aliasOpt("ls"), displayerType(&displayers.DatabaseEvents{}))
+
+	cmdDatabaseEventsList.Example = `The following example retrieves a list of databases events in a database cluster with the ID ` + "`" + `ca9f591d-f38h-5555-a0ef-1c02d1d1e35` + "`" + `: doctl databases events list ca9f591d-f38h-5555-a0ef-1c02d1d1e35`
+
+	return cmd
+}
+
+// RunDatabaseDBList retrieves a list of databases for specific database cluster
+func RunDatabaseEvents(c *CmdConfig) error {
+	if len(c.Args) == 0 {
+		return doctl.NewMissingArgsErr(c.NS)
+	}
+
+	id := c.Args[0]
+
+	dbEvents, err := c.Databases().ListDatabaseEvents(id)
+	if err != nil {
+		return err
+	}
+
+	item := &displayers.DatabaseEvents{DatabaseEvents: dbEvents}
+	return c.Display(item)
+}

commands/databases_test.go

@@ -249,6 +249,7 @@ func TestDatabasesCommand(t *testing.T) {
 		"connection",
 		"migrate",
 		"resize",
+		"events",
 		"firewalls",
 		"fork",
 		"backups",

commands/displayers/database.go

@@ -1647,3 +1647,47 @@ func (dc *RedisConfiguration) KV() []map[string]any {
 
 	return o
 }
+
+type DatabaseEvents struct {
+	DatabaseEvents do.DatabaseEvents
+}
+
+var _ Displayable = &DatabaseEvents{}
+
+func (dr *DatabaseEvents) JSON(out io.Writer) error {
+	return writeJSON(dr.DatabaseEvents, out)
+}
+
+func (dr *DatabaseEvents) Cols() []string {
+	return []string{
+		"ID",
+		"ServiceName",
+		"EventType",
+		"CreateTime",
+	}
+}
+
+func (dr *DatabaseEvents) ColMap() map[string]string {
+
+	return map[string]string{
+		"ID":          "ID",
+		"ServiceName": "Cluster Name",
+		"EventType":   "Type of Event",
+		"CreateTime":  "Create Time",
+	}
+}
+
+func (dr *DatabaseEvents) KV() []map[string]any {
+	out := make([]map[string]any, 0, len(dr.DatabaseEvents))
+
+	for _, r := range dr.DatabaseEvents {
+		o := map[string]any{
+			"ID":          r.ID,
+			"ServiceName": r.ServiceName,
+			"EventType":   r.EventType,
+			"CreateTime":  r.CreateTime,
+		}
+		out = append(out, o)
+	}
+	return out
+}

do/databases.go

@@ -125,6 +125,14 @@ type DatabaseTopicPartitions struct {
 	Partitions []*godo.TopicPartition
 }
 
+// DatabaseEvent is a wrapper for godo.DatabaseEvent
+type DatabaseEvent struct {
+	*godo.DatabaseEvent
+}
+
+// DatabaseEvents is a slice of DatabaseEvent
+type DatabaseEvents []DatabaseEvent
+
 // DatabasesService is an interface for interacting with DigitalOcean's Database API
 type DatabasesService interface {
 	List() (Databases, error)
@@ -183,6 +191,8 @@ type DatabasesService interface {
 	CreateTopic(string, *godo.DatabaseCreateTopicRequest) (*DatabaseTopic, error)
 	UpdateTopic(string, string, *godo.DatabaseUpdateTopicRequest) error
 	DeleteTopic(string, string) error
+
+	ListDatabaseEvents(string) (DatabaseEvents, error)
 }
 
 type databasesService struct {
@@ -745,3 +755,31 @@ func (ds *databasesService) DeleteTopic(databaseID, topicName string) error {
 
 	return err
 }
+
+func (ds *databasesService) ListDatabaseEvents(databaseID string) (DatabaseEvents, error) {
+	f := func(opt *godo.ListOptions) ([]any, *godo.Response, error) {
+		list, resp, err := ds.client.Databases.ListDatabaseEvents(context.TODO(), databaseID, opt)
+		if err != nil {
+			return nil, nil, err
+		}
+
+		si := make([]any, len(list))
+		for i := range list {
+			si[i] = list[i]
+		}
+
+		return si, resp, err
+	}
+
+	si, err := PaginateResp(f)
+	if err != nil {
+		return nil, err
+	}
+
+	list := make(DatabaseEvents, len(si))
+	for i := range si {
+		r := si[i].(godo.DatabaseEvent)
+		list[i] = DatabaseEvent{DatabaseEvent: &r}
+	}
+	return list, nil
+}