feat(dlp): added a sample for dlp inspect gcs send to scc (#3222)

* sync the branch

* sync the branch

* fixing the syncing issues

* reverting last unnecessary changes

* syncing with gcp main

* minor fix

* added a sample dlp_inspect_gcs_send_to_scc with test

* fix the ci failure

* updated the test with cleaning bucket

* updated the tests with TestMain()

* working on review change

* revert the last commit

* refactor the code

* update the create and cleanup function of bucket

* updateing the test case to avaoid failure in CI CD

* updated the test file

---------

Co-authored-by: Eric Schmidt <erschmid@google.com>

dlp/snippets/inspect/inspect_gcs_send_to_scc.go

@@ -0,0 +1,118 @@
+// Copyright 2023 Google LLC
+//
+// 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
+//
+//	https://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 inspect
+
+// [START dlp_inspect_gcs_send_to_scc]
+import (
+	"context"
+	"fmt"
+	"io"
+
+	dlp "cloud.google.com/go/dlp/apiv2"
+	"cloud.google.com/go/dlp/apiv2/dlppb"
+)
+
+// inspectGCSFileSendToScc inspects sensitive data in a Google Cloud Storage (GCS) file
+// and sends the inspection results to Google Cloud Security Command Center (SCC) for further analysis.
+func inspectGCSFileSendToScc(w io.Writer, projectID, gcsPath string) error {
+	// projectID := "my-project-id"
+	// gcsPath := "gs://" + "your-bucket-name" + "path/to/file.txt"
+
+	ctx := context.Background()
+
+	// Initialize a client once and reuse it to send multiple requests. Clients
+	// are safe to use across goroutines. When the client is no longer needed,
+	// call the Close method to cleanup its resources.
+	client, err := dlp.NewClient(ctx)
+	if err != nil {
+		return err
+	}
+
+	// Closing the client safely cleans up background resources.
+	defer client.Close()
+
+	// Specify the GCS file to be inspected.
+	cloudStorageOptions := &dlppb.CloudStorageOptions{
+		FileSet: &dlppb.CloudStorageOptions_FileSet{
+			Url: gcsPath,
+		},
+	}
+
+	// storageCfg represents the configuration for data inspection in various storage types.
+	storageConfig := &dlppb.StorageConfig{
+		Type: &dlppb.StorageConfig_CloudStorageOptions{
+			CloudStorageOptions: cloudStorageOptions,
+		},
+	}
+
+	// Specify the type of info the inspection will look for.
+	// See https://cloud.google.com/dlp/docs/infotypes-reference for complete list of info types
+	infoTypes := []*dlppb.InfoType{
+		{Name: "EMAIL_ADDRESS"},
+		{Name: "PERSON_NAME"},
+		{Name: "LOCATION"},
+		{Name: "PHONE_NUMBER"},
+	}
+
+	// The minimum likelihood required before returning a match.
+	minLikelihood := dlppb.Likelihood_UNLIKELY
+
+	// The maximum number of findings to report (0 = server maximum).
+	findingLimits := &dlppb.InspectConfig_FindingLimits{
+		MaxFindingsPerItem: 100,
+	}
+
+	inspectConfig := &dlppb.InspectConfig{
+		InfoTypes:     infoTypes,
+		MinLikelihood: minLikelihood,
+		Limits:        findingLimits,
+		IncludeQuote:  true,
+	}
+
+	// Specify the action that is triggered when the job completes.
+	action := &dlppb.Action{
+		Action: &dlppb.Action_PublishSummaryToCscc_{
+			PublishSummaryToCscc: &dlppb.Action_PublishSummaryToCscc{},
+		},
+	}
+
+	// Configure the inspection job we want the service to perform.
+	inspectJobConfig := &dlppb.InspectJobConfig{
+		StorageConfig: storageConfig,
+		InspectConfig: inspectConfig,
+		Actions: []*dlppb.Action{
+			action,
+		},
+	}
+
+	// Create the request for the job configured above.
+	req := &dlppb.CreateDlpJobRequest{
+		Parent: fmt.Sprintf("projects/%s/locations/global", projectID),
+		Job: &dlppb.CreateDlpJobRequest_InspectJob{
+			InspectJob: inspectJobConfig,
+		},
+	}
+
+	// Send the request.
+	resp, err := client.CreateDlpJob(ctx, req)
+	if err != nil {
+		return err
+	}
+
+	// Print the result.
+	fmt.Fprintf(w, "Job created successfully: %v", resp.Name)
+	return nil
+}
+
+// [END dlp_inspect_gcs_send_to_scc]