feat(strm-1809): remove event_contract and schema commands (#127)

Use `data_contract` commands instead.

BREAKING CHANGE: event_contract and schema commands removed

pkg/bootstrap/bootstrap.go

@@ -16,7 +16,6 @@ import (
 	"strmprivacy/strm/pkg/entity/data_connector"
 	"strmprivacy/strm/pkg/entity/data_contract"
 	"strmprivacy/strm/pkg/entity/data_subject"
-	"strmprivacy/strm/pkg/entity/event_contract"
 	"strmprivacy/strm/pkg/entity/installation"
 	"strmprivacy/strm/pkg/entity/kafka_cluster"
 	"strmprivacy/strm/pkg/entity/kafka_exporter"
@@ -26,7 +25,6 @@ import (
 	"strmprivacy/strm/pkg/entity/member"
 	"strmprivacy/strm/pkg/entity/organization"
 	"strmprivacy/strm/pkg/entity/project"
-	"strmprivacy/strm/pkg/entity/schema"
 	"strmprivacy/strm/pkg/entity/schema_code"
 	"strmprivacy/strm/pkg/entity/stream"
 	"strmprivacy/strm/pkg/entity/usage"
@@ -68,9 +66,7 @@ func SetupServiceClients(accessToken *string) {
 	kafka_cluster.SetupClient(clientConnection, ctx)
 	kafka_user.SetupClient(clientConnection, ctx)
 	key_stream.SetupClient(clientConnection, ctx)
-	schema.SetupClient(clientConnection, ctx)
 	schema_code.SetupClient(clientConnection, ctx)
-	event_contract.SetupClient(clientConnection, ctx)
 	usage.SetupClient(clientConnection, ctx)
 	installation.SetupClient(clientConnection, ctx)
 	account.SetupClient(clientConnection, ctx)

pkg/cmd/activate.go

@@ -5,8 +5,6 @@ import (
 	"strmprivacy/strm/pkg/auth"
 	"strmprivacy/strm/pkg/common"
 	"strmprivacy/strm/pkg/entity/data_contract"
-	"strmprivacy/strm/pkg/entity/event_contract"
-	"strmprivacy/strm/pkg/entity/schema"
 )
 
 var ActivateCmd = &cobra.Command{
@@ -17,7 +15,5 @@ var ActivateCmd = &cobra.Command{
 }
 
 func init() {
-	ActivateCmd.AddCommand(event_contract.ActivateCmd())
-	ActivateCmd.AddCommand(schema.ActivateCmd())
 	ActivateCmd.AddCommand(data_contract.ActivateCmd())
 }

pkg/cmd/archive.go

@@ -5,8 +5,6 @@ import (
 	"strmprivacy/strm/pkg/auth"
 	"strmprivacy/strm/pkg/common"
 	"strmprivacy/strm/pkg/entity/data_contract"
-	"strmprivacy/strm/pkg/entity/event_contract"
-	"strmprivacy/strm/pkg/entity/schema"
 )
 
 var ArchiveCmd = &cobra.Command{
@@ -17,7 +15,5 @@ var ArchiveCmd = &cobra.Command{
 }
 
 func init() {
-	ArchiveCmd.AddCommand(event_contract.ArchiveCmd())
-	ArchiveCmd.AddCommand(schema.ArchiveCmd())
 	ArchiveCmd.AddCommand(data_contract.ArchiveCmd())
 }

pkg/cmd/create.go

@@ -8,11 +8,9 @@ import (
 	"strmprivacy/strm/pkg/entity/batch_job"
 	"strmprivacy/strm/pkg/entity/data_connector"
 	"strmprivacy/strm/pkg/entity/data_contract"
-	"strmprivacy/strm/pkg/entity/event_contract"
 	"strmprivacy/strm/pkg/entity/kafka_exporter"
 	"strmprivacy/strm/pkg/entity/kafka_user"
 	"strmprivacy/strm/pkg/entity/project"
-	"strmprivacy/strm/pkg/entity/schema"
 	"strmprivacy/strm/pkg/entity/stream"
 )
 
@@ -32,7 +30,5 @@ func init() {
 	CreateCmd.AddCommand(data_contract.CreateCmd())
 	CreateCmd.AddCommand(kafka_exporter.CreateCmd())
 	CreateCmd.AddCommand(kafka_user.CreateCmd())
-	CreateCmd.AddCommand(schema.CreateCmd())
-	CreateCmd.AddCommand(event_contract.CreateCmd())
 	CreateCmd.AddCommand(project.CreateCmd())
 }

pkg/cmd/delete.go

@@ -9,11 +9,9 @@ import (
 	"strmprivacy/strm/pkg/entity/data_connector"
 	"strmprivacy/strm/pkg/entity/data_contract"
 	"strmprivacy/strm/pkg/entity/data_subject"
-	"strmprivacy/strm/pkg/entity/event_contract"
 	"strmprivacy/strm/pkg/entity/kafka_exporter"
 	"strmprivacy/strm/pkg/entity/kafka_user"
 	"strmprivacy/strm/pkg/entity/project"
-	"strmprivacy/strm/pkg/entity/schema"
 	"strmprivacy/strm/pkg/entity/stream"
 )
 
@@ -32,8 +30,6 @@ func init() {
 	DeleteCmd.AddCommand(batch_job.DeleteCmd())
 	DeleteCmd.AddCommand(data_connector.DeleteCmd())
 	DeleteCmd.AddCommand(kafka_user.DeleteCmd())
-	DeleteCmd.AddCommand(event_contract.DeleteCmd())
-	DeleteCmd.AddCommand(schema.DeleteCmd())
 	DeleteCmd.AddCommand(data_subject.DeleteCmd())
 	DeleteCmd.AddCommand(data_contract.DeleteCmd())
 	DeleteCmd.AddCommand(project.DeleteCmd())

pkg/cmd/get.go

@@ -8,15 +8,13 @@ import (
 	"strmprivacy/strm/pkg/entity/batch_job"
 	"strmprivacy/strm/pkg/entity/data_connector"
 	"strmprivacy/strm/pkg/entity/data_contract"
-	"strmprivacy/strm/pkg/entity/event_contract"
 	"strmprivacy/strm/pkg/entity/installation"
 	"strmprivacy/strm/pkg/entity/kafka_cluster"
 	"strmprivacy/strm/pkg/entity/kafka_exporter"
 	"strmprivacy/strm/pkg/entity/kafka_user"
 	"strmprivacy/strm/pkg/entity/key_stream"
 	"strmprivacy/strm/pkg/entity/member"
 	"strmprivacy/strm/pkg/entity/project"
-	"strmprivacy/strm/pkg/entity/schema"
 	"strmprivacy/strm/pkg/entity/schema_code"
 	"strmprivacy/strm/pkg/entity/stream"
 	"strmprivacy/strm/pkg/entity/usage"
@@ -38,9 +36,7 @@ func init() {
 	GetCmd.AddCommand(kafka_cluster.GetCmd())
 	GetCmd.AddCommand(kafka_user.GetCmd())
 	GetCmd.AddCommand(key_stream.GetCmd())
-	GetCmd.AddCommand(schema.GetCmd())
 	GetCmd.AddCommand(schema_code.GetCmd())
-	GetCmd.AddCommand(event_contract.GetCmd())
 	GetCmd.AddCommand(usage.GetCmd())
 	GetCmd.AddCommand(installation.GetCmd())
 	GetCmd.AddCommand(member.GetCmd())

pkg/cmd/list.go

@@ -9,7 +9,6 @@ import (
 	"strmprivacy/strm/pkg/entity/data_connector"
 	"strmprivacy/strm/pkg/entity/data_contract"
 	"strmprivacy/strm/pkg/entity/data_subject"
-	"strmprivacy/strm/pkg/entity/event_contract"
 	"strmprivacy/strm/pkg/entity/installation"
 	"strmprivacy/strm/pkg/entity/kafka_cluster"
 	"strmprivacy/strm/pkg/entity/kafka_exporter"
@@ -18,7 +17,6 @@ import (
 	"strmprivacy/strm/pkg/entity/keylinks"
 	"strmprivacy/strm/pkg/entity/member"
 	"strmprivacy/strm/pkg/entity/project"
-	"strmprivacy/strm/pkg/entity/schema"
 	"strmprivacy/strm/pkg/entity/stream"
 )
 
@@ -38,8 +36,6 @@ func init() {
 	ListCmd.AddCommand(kafka_cluster.ListCmd())
 	ListCmd.AddCommand(kafka_user.ListCmd())
 	ListCmd.AddCommand(key_stream.ListCmd())
-	ListCmd.AddCommand(schema.ListCmd())
-	ListCmd.AddCommand(event_contract.ListCmd())
 	ListCmd.AddCommand(installation.ListCmd())
 	ListCmd.AddCommand(project.ListCmd())
 	ListCmd.AddCommand(member.ListCmd())