Collapse _crud files into the main resource/datasource files

Author: mikejihbe

core_console_history_data_datasource.go

@@ -3,8 +3,11 @@
 package main
 
 import (
+	"time"
+
 	"github.com/hashicorp/terraform/helper/schema"
 
+	"github.com/MustWin/baremetal-sdk-go"
 	"github.com/oracle/terraform-provider-baremetal/client"
 	"github.com/oracle/terraform-provider-baremetal/crud"
 )
@@ -41,3 +44,25 @@ func readConsoleHistoryData(d *schema.ResourceData, m interface{}) (e error) {
 
 	return crud.ReadResource(reader)
 }
+
+type ConsoleHistoryDataDatasourceCrud struct {
+	crud.BaseCrud
+	ConsoleHistoryData *baremetal.ConsoleHistoryData
+}
+
+func (res *ConsoleHistoryDataDatasourceCrud) Get() (e error) {
+	id := res.D.Get("console_history_id").(string)
+
+	opts := &baremetal.ConsoleHistoryDataOptions{}
+	opts.Length = uint64(res.D.Get("length").(int))
+	opts.Offset = uint64(res.D.Get("offset").(int))
+
+	res.ConsoleHistoryData, e = res.Client.ShowConsoleHistoryData(id, opts)
+
+	return
+}
+
+func (res *ConsoleHistoryDataDatasourceCrud) SetData() {
+	res.D.SetId(time.Now().UTC().String())
+	res.D.Set("data", res.ConsoleHistoryData.Data)
+}

core_console_history_data_datasource_crud.go

@@ -7,6 +7,7 @@ import (
 
 	"github.com/hashicorp/terraform/helper/schema"
 
+	"github.com/MustWin/baremetal-sdk-go"
 	"github.com/oracle/terraform-provider-baremetal/client"
 	"github.com/oracle/terraform-provider-baremetal/crud"
 )
@@ -74,3 +75,46 @@ func readConsoleHistory(d *schema.ResourceData, m interface{}) (e error) {
 func deleteConsoleHistory(d *schema.ResourceData, m interface{}) (e error) {
 	return fmt.Errorf("console history resource: console history %v cannot be deleted", d.Id())
 }
+
+type ConsoleHistoryResourceCrud struct {
+	crud.BaseCrud
+	Res *baremetal.ConsoleHistoryMetadata
+}
+
+func (s *ConsoleHistoryResourceCrud) ID() string {
+	return s.Res.ID
+}
+
+func (s *ConsoleHistoryResourceCrud) CreatedPending() []string {
+	return []string{baremetal.ResourceRequested}
+}
+
+func (s *ConsoleHistoryResourceCrud) CreatedTarget() []string {
+	return []string{baremetal.ResourceSucceeded}
+}
+
+func (s *ConsoleHistoryResourceCrud) State() string {
+	return s.Res.State
+}
+
+func (s *ConsoleHistoryResourceCrud) Create() (e error) {
+	instanceID := s.D.Get("instance_id").(string)
+
+	s.Res, e = s.Client.CaptureConsoleHistory(instanceID, nil)
+
+	return
+}
+
+func (s *ConsoleHistoryResourceCrud) Get() (e error) {
+	s.Res, e = s.Client.GetConsoleHistory(s.D.Id())
+	return
+}
+
+func (s *ConsoleHistoryResourceCrud) SetData() {
+	s.D.Set("availability_domain", s.Res.AvailabilityDomain)
+	s.D.Set("compartment_id", s.Res.CompartmentID)
+	s.D.Set("display_name", s.Res.DisplayName)
+	s.D.Set("instance_id", s.Res.InstanceID)
+	s.D.Set("state", s.Res.State)
+	s.D.Set("time_created", s.Res.TimeCreated.String())
+}

core_console_history_resource.go

@@ -3,10 +3,14 @@
 package main
 
 import (
+	"time"
+
 	"github.com/hashicorp/terraform/helper/schema"
 
+	"github.com/MustWin/baremetal-sdk-go"
 	"github.com/oracle/terraform-provider-baremetal/client"
 	"github.com/oracle/terraform-provider-baremetal/crud"
+	"github.com/oracle/terraform-provider-baremetal/options"
 )
 
 func CpeDatasource() *schema.Resource {
@@ -41,3 +45,55 @@ func readCpeList(d *schema.ResourceData, m interface{}) (e error) {
 	return crud.ReadResource(reader)
 
 }
+
+type CPEDatasourceCrud struct {
+	crud.BaseCrud
+	Resource *baremetal.ListCpes
+}
+
+func (s *CPEDatasourceCrud) Get() (e error) {
+	compartmentID := s.D.Get("compartment_id").(string)
+
+	opts := &baremetal.ListOptions{}
+	options.SetListOptions(s.D, opts)
+
+	s.Resource = &baremetal.ListCpes{Cpes: []baremetal.Cpe{}}
+
+	for {
+		var list *baremetal.ListCpes
+		if list, e = s.Client.ListCpes(compartmentID, opts); e != nil {
+			break
+		}
+
+		s.Resource.Cpes = append(s.Resource.Cpes, list.Cpes...)
+
+		if hasNextPage := options.SetNextPageOption(list.NextPage, &opts.PageListOptions); !hasNextPage {
+			break
+		}
+	}
+
+	return
+}
+
+func (s *CPEDatasourceCrud) SetData() {
+	if s.Resource != nil {
+		s.D.SetId(time.Now().UTC().String())
+
+		cpes := []map[string]interface{}{}
+
+		for _, v := range s.Resource.Cpes {
+			cpe := map[string]interface{}{
+				"id":             v.ID,
+				"compartment_id": v.CompartmentID,
+				"display_name":   v.DisplayName,
+				"ip_address":     v.IPAddress,
+				"time_created":   v.TimeCreated.String(),
+			}
+
+			cpes = append(cpes, cpe)
+		}
+
+		s.D.Set("cpes", cpes)
+
+	}
+}

core_console_history_resource_crud.go

@@ -5,6 +5,7 @@ package main
 import (
 	"github.com/hashicorp/terraform/helper/schema"
 
+	"github.com/MustWin/baremetal-sdk-go"
 	"github.com/oracle/terraform-provider-baremetal/client"
 	"github.com/oracle/terraform-provider-baremetal/crud"
 )
@@ -79,3 +80,54 @@ func deleteCpe(d *schema.ResourceData, m interface{}) (e error) {
 	sync.Client = client
 	return sync.Delete()
 }
+
+type CpeResourceCrud struct {
+	crud.BaseCrud
+	Resource *baremetal.Cpe
+}
+
+func (s *CpeResourceCrud) ID() string {
+	return s.Resource.ID
+}
+
+func (s *CpeResourceCrud) Create() (e error) {
+	compartmentID := s.D.Get("compartment_id").(string)
+	ipAddress := s.D.Get("ip_address").(string)
+
+	opts := &baremetal.CreateOptions{}
+	displayName, ok := s.D.GetOk("display_name")
+	if ok {
+		opts.DisplayName = displayName.(string)
+	}
+
+	s.Resource, e = s.Client.CreateCpe(compartmentID, ipAddress, opts)
+	return
+}
+
+func (s *CpeResourceCrud) Get() (e error) {
+	s.Resource, e = s.Client.GetCpe(s.D.Id())
+	return
+}
+
+func (s *CpeResourceCrud) Update() (e error) {
+	opts := &baremetal.IfMatchDisplayNameOptions{}
+	compartmentID := s.D.Get("compartment_id").(string)
+	displayName, ok := s.D.GetOk("display_name")
+	if ok {
+		opts.DisplayName = displayName.(string)
+	}
+
+	s.Resource, e = s.Client.UpdateCpe(compartmentID, opts)
+	return
+}
+
+func (s *CpeResourceCrud) SetData() {
+	s.D.Set("compartment_id", s.Resource.CompartmentID)
+	s.D.Set("display_name", s.Resource.DisplayName)
+	s.D.Set("ip_address", s.Resource.IPAddress)
+	s.D.Set("time_created", s.Resource.TimeCreated.String())
+}
+
+func (s *CpeResourceCrud) Delete() (e error) {
+	return s.Client.DeleteCpe(s.D.Id(), nil)
+}