Function runCreate

example/auditlogstream/main.go:104–142

(args []string)

}

func runCreate(args []string) {
	fs, enterprise := newFlagSet("create")
	container := fs.String("container", "", "Azure Blob Storage container name (required).")
	sasURL := fs.String("sas-url", "", "Plain-text Azure SAS URL to encrypt and submit (required).")
	enabled := fs.Bool("enabled", true, "Whether the stream should be enabled immediately.")

	ctx, client, ent := parseAndInit(fs, enterprise, args)
	requireFlag("container", *container)
	requireFlag("sas-url", *sasURL)

	streamKey, _, err := client.Enterprise.GetAuditLogStreamKey(ctx, ent)
	if err != nil {
		log.Fatalf("Error fetching audit log stream key: %v", err)
	}
	fmt.Printf("Retrieved stream key ID: %v\n", streamKey.KeyID)

	encryptedSASURL, err := encryptSecret(streamKey.Key, *sasURL)
	if err != nil {
		log.Fatalf("Error encrypting SAS URL: %v", err)
	}
	fmt.Println("SAS URL encrypted successfully.")

	config := github.NewAzureBlobStreamConfig(*enabled, &github.AzureBlobConfig{
		KeyID:           streamKey.KeyID,
		Container:       *container,
		EncryptedSASURL: encryptedSASURL,
	})

	stream, _, err := client.Enterprise.CreateAuditLogStream(ctx, ent, *config)
	if err != nil {
		log.Fatalf("Error creating audit log stream: %v", err)
	}

	fmt.Println("Successfully created audit log stream:")
	fmt.Printf("  ID:         %v\n", stream.ID)
	fmt.Printf("  Type:       %v\n", stream.StreamType)
	fmt.Printf("  Enabled:    %v\n", stream.Enabled)
	fmt.Printf("  Created at: %v\n", stream.CreatedAt)
}

func runDelete(args []string) {
	fs, enterprise := newFlagSet("delete")