create only one provider per cloud-type

capten/agent/internal/api/plugin_crossplane_provider_apis.go

@@ -22,6 +22,22 @@ func (a *Agent) AddCrossplanProvider(ctx context.Context, request *captenplugins
 		}, nil
 	}
 	a.log.Infof("Add Crossplane Provider %s with cloud provider %s request recieved", request.ProviderName, request.CloudProviderId)
+
+	project, err := a.as.GetCrossplanProviderByCloudType(request.CloudType)
+	if err != nil {
+		a.log.Infof("failed to get crossplane provider", err)
+		return &captenpluginspb.AddCrossplanProviderResponse{
+			Status:        captenpluginspb.StatusCode_INTERNAL_ERROR,
+			StatusMessage: "failed to get crossplane provider for " + request.CloudType,
+		}, nil
+	}
+	if project != nil {
+		return &captenpluginspb.AddCrossplanProviderResponse{
+			Status:        captenpluginspb.StatusCode_NOT_FOUND,
+			StatusMessage: "Crossplane provider is already available",
+		}, nil
+	}
+
 	id := uuid.New()
 	provider := model.CrossplaneProvider{
 		Id:              id.String(),
@@ -116,6 +132,21 @@ func (a *Agent) UpdateCrossplanProvider(ctx context.Context, request *captenplug
 
 	a.log.Infof("Update Crossplane Provider %s, %s request recieved", request.Id, request.ProviderName)
 
+	project, err := a.as.GetCrossplanProviderById(request.Id)
+	if err != nil {
+		a.log.Infof("failed to get crossplane provider for "+request.Id, err)
+		return &captenpluginspb.UpdateCrossplanProviderResponse{
+			Status:        captenpluginspb.StatusCode_INTERNAL_ERROR,
+			StatusMessage: "failed to get crossplane provider for " + request.Id,
+		}, nil
+	}
+	if project == nil {
+		return &captenpluginspb.UpdateCrossplanProviderResponse{
+			Status:        captenpluginspb.StatusCode_NOT_FOUND,
+			StatusMessage: "Crossplane provider is not available for" + request.Id,
+		}, nil
+	}
+
 	provider := model.CrossplaneProvider{
 		Id:              request.Id,
 		CloudType:       request.CloudType,

capten/agent/internal/capten-store/crossplane_store.go

@@ -10,10 +10,12 @@ import (
 )
 
 const (
-	getAllCrossplaneProvidersQuery    = "SELECT id, cloud_type, provider_name, cloud_provider_id, status FROM %s.CrossplaneProviders;"
-	insertCrossplaneProviderQuery     = "INSERT INTO %s.CrossplaneProviders(id, cloud_type, provider_name, cloud_provider_id, status) VALUES (?, ?, ?, ?, ?);"
-	deleteCrossplaneProviderByIDQuery = "DELETE FROM %s.CrossplaneProviders WHERE id=%s;"
-	updateCrossplaneProviderQuery     = "UPDATE %s.CrossplaneProviders SET cloud_type=?, provider_name=?, cloud_provider_id=?, status=? WHERE id=?;"
+	getAllCrossplaneProvidersQuery         = "SELECT id, cloud_type, provider_name, cloud_provider_id, status FROM %s.CrossplaneProviders;"
+	insertCrossplaneProviderQuery          = "INSERT INTO %s.CrossplaneProviders(id, cloud_type, provider_name, cloud_provider_id, status) VALUES (?, ?, ?, ?, ?);"
+	deleteCrossplaneProviderByIDQuery      = "DELETE FROM %s.CrossplaneProviders WHERE id=%s;"
+	updateCrossplaneProviderQuery          = "UPDATE %s.CrossplaneProviders SET cloud_type=?, provider_name=?, cloud_provider_id=?, status=? WHERE id=?;"
+	selectGetCrossplaneProviderByCloudType = "SELECT id, cloud_type, provider_name, cloud_provider_id, status FROM %s.CrossplaneProviders WHERE cloud_type='%s' ALLOW FILTERING;"
+	selectGetCrossplaneProviderById        = "SELECT id, cloud_type, provider_name, cloud_provider_id, status FROM %s.CrossplaneProviders  WHERE id='%s';"
 )
 
 func (a *Store) InsertCrossplaneProvider(provider *model.CrossplaneProvider) error {
@@ -81,3 +83,31 @@ func (a *Store) UpdateCrossplaneProvider(provider *model.CrossplaneProvider) err
 	err := a.client.Session().ExecuteBatch(batch)
 	return err
 }
+
+func (a *Store) GetCrossplanProviderByCloudType(cloudType string) (*captenpluginspb.CrossplaneProvider, error) {
+	query := fmt.Sprintf(selectGetCrossplaneProviderByCloudType, a.keyspace, cloudType)
+
+	providers, err := a.executeCrossplaneProvidersSelectQuery(query)
+	if err != nil {
+		return nil, err
+	}
+
+	if len(providers) <= 0 {
+		return nil, nil
+	}
+	return providers[0], nil
+}
+
+func (a *Store) GetCrossplanProviderById(id string) (*captenpluginspb.CrossplaneProvider, error) {
+	query := fmt.Sprintf(selectGetCrossplaneProviderById, a.keyspace, id)
+
+	providers, err := a.executeCrossplaneProvidersSelectQuery(query)
+	if err != nil {
+		return nil, err
+	}
+
+	if len(providers) <= 0 {
+		return nil, nil
+	}
+	return providers[0], nil
+}