Add support for Sumo Logic

cmd/provider_cmd_sumologic.go

@@ -0,0 +1,47 @@
+// Copyright 2022 The Terraformer Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+package cmd
+
+import (
+ sumologic_terraforming "github.com/GoogleCloudPlatform/terraformer/providers/sumologic"
+ "github.com/GoogleCloudPlatform/terraformer/terraformutils"
+ "github.com/spf13/cobra"
+)
+
+func newCmdSumoLogicImporter(options ImportOptions) *cobra.Command {
+ var accessId, accessKey, environment string
+ cmd := &cobra.Command{
+ Use: "sumologic",
+ Short: "Import current state to Terraform configuration from Sumo Logic",
+ Long: "Import current state to Terraform configuration from Sumo Logic",
+ RunE: func(cmd *cobra.Command, args []string) error {
+ provider := newSumoLogicProvider()
+ err := Import(provider, options, []string{accessId, accessKey, environment})
+ if err != nil {
+ return err
+ }
+ return nil
+ },
+ }
+ cmd.AddCommand(listCmd(newSumoLogicProvider()))
+ baseProviderFlags(cmd.PersistentFlags(), &options, "users", "users=id1:id2:id4")
+ cmd.PersistentFlags().StringVarP(&accessId, "access-id", "", "", "Sumo Logic Access ID or env param SUMOLOGIC_ACCESS_ID")
+ cmd.PersistentFlags().StringVarP(&accessKey, "access-key", "", "", "Sumo Logic Access Key or env param SUMOLOGIC_ACCESS_KEY")
+ cmd.PersistentFlags().StringVarP(&environment, "environment", "", "", "Sumo Logic environment or env param SUMOLOGIC_ENVIRONMENT")
+ return cmd
+}
+
+func newSumoLogicProvider() terraformutils.ProviderGenerator {
+ return &sumologic_terraforming.SumoLogicProvider{}
+}

cmd/root.go

@@ -79,6 +79,7 @@ func providerImporterSubcommands() []func(options ImportOptions) *cobra.Command
  newCmdOpsgenieImporter,
  newCmdHoneycombioImporter,
  newCmdOpalImporter,
+ newCmdSumoLogicImporter,
  // Community
  newCmdKeycloakImporter,
  newCmdLogzioImporter,
@@ -130,6 +131,7 @@ func providerGenerators() map[string]func() terraformutils.ProviderGenerator {
  newPagerDutyProvider,
  newHoneycombioProvider,
  newOpalProvider,
+ newSumoLogicProvider,
  // Community
  newKeycloakProvider,
  newLogzioProvider,

docs/sumologic.md

@@ -0,0 +1,43 @@
+## Use with Sumologic
+
+Example:
+
+```
+./terraformer import sumologic --resources=user --access-id=SUMOLOGIC_ACCESS_ID --access-key=SUMOLOGIC_ACCESS_KEY --environment=SUMOLOGIC_ENVIRONMENT
+```
+
+You can also export env vars instead of providing them via args.
+```
+export SUMOLOGIC_ENVIRONMENT="us2"
+export SUMOLOGIC_ACCESS_ID="US2_ACCESS_ID"
+export SUMOLOGIC_ACCESS_KEY="US2_ACCESS_KEY"
+
+./terraformer import sumologic --resources=user
+```
+
+List of supported Sumologic services:
+
+* `connection`
+ * `sumologic_connection`
+* `dashboard`
+ * `sumologic_dashboard`
+* `field_extraction_rule`
+ * `sumologic_field_extraction_rule`
+* `monitor`
+ * `sumologic_monitor`
+* `partition`
+ * `sumologic_partition`
+* `role`
+ * `sumologic_role`
+
+ _Roles can be imported by name, which can be passed via `--filter` option._
+ ```
+ terraformer import sumologic --resources=role --filter 'Name=name;Value=App Admin'
+ ```
+* `user`
+ * `sumologic_user`
+
+ _Users can be imported by email, which can be passed via `--filter` option._
+ ```
+ terraformer import sumologic --resources=user --filter 'Name=email;[email protected]'
+ ```

go.mod

@@ -360,6 +360,8 @@ require (
  github.com/manicminer/hamilton v0.44.0
  github.com/opalsecurity/opal-go v1.0.19
  gopkg.in/ns1/ns1-go.v2 v2.6.5
+ github.com/sumovishal/sumologic-go-sdk v0.0.0-20220807145511-cf1ced70723b
+ github.com/sumovishal/sumologic-go-sdk v0.0.0-20230810134622-c151e5f7d9f6
 )
 
 require (

go.sum

@@ -1416,6 +1416,12 @@ github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o
 github.com/stretchr/testify v1.8.2 h1:+h33VjcLVPDHtOdpUCuF+7gSuG3yGIftsP1YvFihtJ8=
 github.com/stretchr/testify v1.8.2/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
 github.com/subosito/gotenv v1.2.0/go.mod h1:N0PQaV/YGNqwC0u51sEeR/aUtSLEXKX9iv69rRypqCw=
+github.com/sumovishal/sumologic-go-sdk v0.0.0-20220806134908-7d671aa8dc0f h1:AQkmKYt+ffgcsd/n1GfJ4DWq1AtYXh5KNC8OGhV7iWI=
+github.com/sumovishal/sumologic-go-sdk v0.0.0-20220806134908-7d671aa8dc0f/go.mod h1:DG0EwAJA796aYF/O79yUQ5rlp5loiPU1Sf/TRXOpCmM=
+github.com/sumovishal/sumologic-go-sdk v0.0.0-20220807145511-cf1ced70723b h1:+msQGas9ER8bzezyR+hLAhdKgMURIsVd9lLs30A+cI8=
+github.com/sumovishal/sumologic-go-sdk v0.0.0-20220807145511-cf1ced70723b/go.mod h1:yqBp0ZPIjBtPjYPuxg/84peHkSFfRwEYqhZu27+xmxc=
+github.com/sumovishal/sumologic-go-sdk v0.0.0-20230810134622-c151e5f7d9f6 h1:JRqRDIVZRWiSPen/5SghdPOedtplPdBjoKMJ5xtnoKg=
+github.com/sumovishal/sumologic-go-sdk v0.0.0-20230810134622-c151e5f7d9f6/go.mod h1:DG0EwAJA796aYF/O79yUQ5rlp5loiPU1Sf/TRXOpCmM=
 github.com/svanharmelen/jsonapi v0.0.0-20180618144545-0c0828c3f16d/go.mod h1:BSTlc8jOjh0niykqEGVXOLXdi9o0r0kR8tCYiMvjFgw=
 github.com/tencentcloud/tencentcloud-sdk-go v1.0.392/go.mod h1:l8PU0g9KTDkwn6R4F9WbXXSUwRgKs6k7rj52H4uAcM0=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/aa v1.0.392/go.mod h1:DTrc+dJQjeL+2b7KEkfW1RiZqssiHxIMjRWhnt6PmU4=

providers/sumologic/connection.go

@@ -0,0 +1,68 @@
+// Copyright 2021 The Terraformer Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package sumologic
+
+import (
+ "fmt"
+
+ "github.com/GoogleCloudPlatform/terraformer/terraformutils"
+ "github.com/iancoleman/strcase"
+ sumologic "github.com/sumovishal/sumologic-go-sdk/api"
+)
+
+type ConnectionGenerator struct {
+ SumoLogicService
+}
+
+func (g *ConnectionGenerator) createResources(connections []sumologic.Connection) []terraformutils.Resource {
+ resources := make([]terraformutils.Resource, len(connections))
+
+ for i, connection := range connections {
+ name := strcase.ToSnake(replaceSpaceAndDash(connection.Name))
+ resource := terraformutils.NewSimpleResource(
+ connection.Id,
+ fmt.Sprintf("%s-%s", name, connection.Id),
+ "sumologic_connection",
+ g.ProviderName,
+ []string{})
+ resources[i] = resource
+ }
+
+ return resources
+}
+
+func (g *ConnectionGenerator) InitResources() error {
+ client := g.Client()
+ req := client.ConnectionManagementApi.ListConnections(g.AuthCtx())
+ req = req.Limit(100)
+
+ respBody, _, err := client.ConnectionManagementApi.ListConnectionsExecute(req)
+ if err != nil {
+ return err
+ }
+ connections := respBody.Data
+ for respBody.Next != nil {
+ req = req.Token(respBody.GetNext())
+ respBody, _, err = client.ConnectionManagementApi.ListConnectionsExecute(req)
+ if err != nil {
+ return err
+ }
+ connections = append(connections, respBody.Data...)
+ }
+
+ resources := g.createResources(connections)
+ g.Resources = resources
+ return nil
+}

providers/sumologic/dashboard.go

@@ -0,0 +1,73 @@
+// Copyright 2022 The Terraformer Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package sumologic
+
+import (
+ "fmt"
+
+ "github.com/GoogleCloudPlatform/terraformer/terraformutils"
+ "github.com/iancoleman/strcase"
+ sumologic "github.com/sumovishal/sumologic-go-sdk/api"
+)
+
+type DashboardGenerator struct {
+ SumoLogicService
+}
+
+func (g *DashboardGenerator) createResources(dashboards []sumologic.Dashboard) []terraformutils.Resource {
+ resources := make([]terraformutils.Resource, len(dashboards))
+
+ for i, dashboard := range dashboards {
+ title := strcase.ToSnake(replaceSpaceAndDash(dashboard.Title))
+
+ resource := terraformutils.NewSimpleResource(
+ *dashboard.Id,
+ fmt.Sprintf("%s-%s", title, *dashboard.Id),
+ "sumologic_dashboard",
+ g.ProviderName,
+ []string{})
+ resources[i] = resource
+ }
+
+ return resources
+}
+
+func (g *DashboardGenerator) InitResources() error {
+ client := g.Client()
+
+ var resources []terraformutils.Resource
+ var dashboards []sumologic.Dashboard
+
+ req := client.DashboardManagementApi.ListDashboards(g.AuthCtx())
+ req = req.Limit(100)
+
+ respBody, _, err := client.DashboardManagementApi.ListDashboardsExecute(req)
+ if err != nil {
+ return err
+ }
+ dashboards = respBody.Dashboards
+ for respBody.Next != nil {
+ req = req.Token(respBody.GetNext())
+ respBody, _, err = client.DashboardManagementApi.ListDashboardsExecute(req)
+ if err != nil {
+ return err
+ }
+ dashboards = append(dashboards, respBody.Dashboards...)
+ }
+
+ resources = g.createResources(dashboards)
+ g.Resources = resources
+ return nil
+}

providers/sumologic/field_extraction_rule.go

@@ -0,0 +1,68 @@
+// Copyright 2021 The Terraformer Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package sumologic
+
+import (
+ "fmt"
+
+ "github.com/GoogleCloudPlatform/terraformer/terraformutils"
+ "github.com/iancoleman/strcase"
+ sumologic "github.com/sumovishal/sumologic-go-sdk/api"
+)
+
+type FieldExtractionRuleGenerator struct {
+ SumoLogicService
+}
+
+func (g *FieldExtractionRuleGenerator) createResources(rules []sumologic.ExtractionRule) []terraformutils.Resource {
+ resources := make([]terraformutils.Resource, len(rules))
+
+ for i, rule := range rules {
+ name := strcase.ToSnake(replaceSpaceAndDash(rule.Name))
+ resource := terraformutils.NewSimpleResource(
+ rule.Id,
+ fmt.Sprintf("%s-%s", name, rule.Id),
+ "sumologic_field_extraction_rule",
+ g.ProviderName,
+ []string{})
+ resources[i] = resource
+ }
+
+ return resources
+}
+
+func (g *FieldExtractionRuleGenerator) InitResources() error {
+ client := g.Client()
+ req := client.ExtractionRuleManagementApi.ListExtractionRules(g.AuthCtx())
+ req = req.Limit(100)
+
+ respBody, _, err := client.ExtractionRuleManagementApi.ListExtractionRulesExecute(req)
+ if err != nil {
+ return err
+ }
+ rules := respBody.Data
+ for respBody.Next != nil {
+ req = req.Token(respBody.GetNext())
+ respBody, _, err = client.ExtractionRuleManagementApi.ListExtractionRulesExecute(req)
+ if err != nil {
+ return err
+ }
+ rules = append(rules, respBody.Data...)
+ }
+
+ resources := g.createResources(rules)
+ g.Resources = resources
+ return nil
+}