require 'spec_helper'
require 'models/runtime/event'
require 'repositories/service_event_repository'
require 'cloud_controller/security_context'

module VCAP::Services::ServiceBrokers
  RSpec.describe ServiceManager do
    let(:broker) { VCAP::CloudController::ServiceBroker.make }

    let(:service_id) { Sham.guid }
    let(:service_name) { Sham.name }
    let(:service_description) { Sham.description }
    let(:service_event_repository) do
      VCAP::CloudController::Repositories::ServiceEventRepository.new(
        VCAP::CloudController::UserAuditInfo.from_context(VCAP::CloudController::SecurityContext)
      )
    end

    let(:plan_id) { Sham.guid }
    let(:plan_name) { Sham.name }
    let(:plan_description) { Sham.description }
    let(:plan_maintenance_info) do
      { 'version' => '2.0' }
    end
    let(:service_metadata_hash) do
      { 'metadata' => { 'foo' => 'bar' } }
    end
    let(:plan_metadata_hash) do
      { 'metadata' => { 'cost' => '0.0' } }
    end
    let(:dashboard_client_attrs) do
      {
        'id' => 'abcde123',
        'secret' => 'sekret',
        'redirect_uri' => 'http://example.com'
      }
    end
    let(:plan_schemas_hash) do
      {
          'schemas' => {
              'service_instance' => {
                  'create' => {
                      'parameters' => {
                          '$schema' => 'http://json-schema.org/draft-04/schema', 'type' => 'object'
                      }
                  },
                  'update' => {
                      'parameters' => {
                        '$schema' => 'http://json-schema.org/draft-04/schema', 'type' => 'object'
                      }
                  }
              },
              'service_binding' => {
                'create' => {
                  'parameters' => {
                    '$schema' => 'http://json-schema.org/draft-04/schema', 'type' => 'object'
                  }
                }
              }
          }
      }
    end
    let(:catalog_hash) do
      {
        'services' => [
          {
            'id'          => service_id,
            'name'        => service_name,
            'description' => service_description,
            'bindable'    => true,
            'dashboard_client' => dashboard_client_attrs,
            'tags'        => ['mysql', 'relational'],
            'requires'    => ['ultimate', 'power'],
            'plan_updateable' => true,
            'bindings_retrievable' => true,
            'instances_retrievable' => true,
            'allow_context_updates' => true,
            'plans' => [
              {
                'id'          => plan_id,
                'name'        => plan_name,
                'description' => plan_description,
                'plan_updateable' => true,
                'free'        => false,
                'bindable'    => true,
                'maximum_polling_duration' => 3600,
                'maintenance_info' => plan_maintenance_info,
              }.merge(plan_metadata_hash).merge(plan_schemas_hash)
            ]
          }.merge(service_metadata_hash)
        ]
      }
    end
    let(:catalog) { V2::Catalog.new(broker, catalog_hash) }
    let(:service_manager) { ServiceManager.new(service_event_repository) }

    let(:user_email) { 'user@example.com' }
    let(:token) do
      {
        'scope' => ['cloud_controller.read', 'cloud_controller.write'],
        'email' => user_email,
      }
    end
    let(:user) { VCAP::CloudController::User.make }

    before do
      VCAP::CloudController::SecurityContext.set(user, token)
    end
    after do
      VCAP::CloudController::SecurityContext.clear
    end

    describe 'initializing' do
      subject { ServiceManager.new(service_event_repository) }

      its(:has_warnings?) { should eq false }
      its(:warnings) { should eq [] }
    end

    describe '#sync_services_and_plans' do
      it 'creates services from the catalog' do
        expect {
          service_manager.sync_services_and_plans(catalog)
        }.to change(VCAP::CloudController::Service, :count).by(1)

        service = VCAP::CloudController::Service.last
        expect(service.service_broker).to eq(broker)
        expect(service.label).to eq(service_name)
        expect(service.description).to eq(service_description)
        expect(service.bindable).to be true
        expect(service.tags).to match_array(['mysql', 'relational'])
        expect(JSON.parse(service.extra)).to eq({ 'foo' => 'bar' })
        expect(service.requires).to eq(['ultimate', 'power'])
        expect(service.plan_updateable).to eq true
        expect(service.bindings_retrievable).to eq true
        expect(service.instances_retrievable).to eq true
        expect(service.allow_context_updates).to eq true
      end

      it 'records an audit event for each service and plan' do
        service_manager.sync_services_and_plans(catalog)

        event = VCAP::CloudController::Event.first(type: 'audit.service.create')
        service = VCAP::CloudController::Service.last
        expect(event.type).to eq('audit.service.create')
        expect(event.actor_type).to eq('service_broker')
        expect(event.actor).to eq(broker.guid)
        expect(event.actor_name).to eq(broker.name)
        expect(event.timestamp).to be
        expect(event.actee).to eq(service.guid)
        expect(event.actee_type).to eq('service')
        expect(event.actee_name).to eq(service_name)
        expect(event.space_guid).to eq('')
        expect(event.organization_guid).to eq('')
        expect(event.metadata).to eq({
          'service_broker_guid' => service.service_broker.guid,
          'unique_id' => service_id,
          'provider' => service.provider,
          'url' => service.url,
          'version' => service.version,
          'info_url' => service.info_url,
          'bindable' => service.bindable,
          'long_description' => service.long_description,
          'documentation_url' => service.documentation_url,
          'label' => service_name,
          'description' => service.description,
          'tags' => service.tags,
          'extra' => service.extra,
          'active' => service.active,
          'requires' => service.requires,
          'plan_updateable' => service.plan_updateable,
          'bindings_retrievable' => service.bindings_retrievable,
          'instances_retrievable' => service.instances_retrievable,
          'allow_context_updates' => service.allow_context_updates,
        })

        event = VCAP::CloudController::Event.first(type: 'audit.service_plan.create')
        service_plan = VCAP::CloudController::ServicePlan.last
        expect(event.type).to eq('audit.service_plan.create')
        expect(event.actor_type).to eq('service_broker')
        expect(event.actor).to eq(broker.guid)
        expect(event.actor_name).to eq(broker.name)
        expect(event.timestamp).to be
        expect(event.actee).to eq(service_plan.guid)
        expect(event.actee_type).to eq('service_plan')
        expect(event.actee_name).to eq(plan_name)
        expect(event.space_guid).to eq('')
        expect(event.organization_guid).to eq('')
        expect(event.metadata).to eq({
          'name' => service_plan.name,
          'free' => service_plan.free,
          'description' => service_plan.description,
          'plan_updateable' => service_plan.plan_updateable,
          'maximum_polling_duration' => service_plan.maximum_polling_duration,
          'maintenance_info' => service_plan.maintenance_info,
          'service_guid' => service_plan.service.guid,
          'extra' => '{"cost":"0.0"}',
          'unique_id' => service_plan.unique_id,
          'public' => service_plan.public,
          'bindable' => true,
          'active' => service_plan.active,
          'create_instance_schema' => '{"$schema":"http://json-schema.org/draft-04/schema","type":"object"}',
          'update_instance_schema' => '{"$schema":"http://json-schema.org/draft-04/schema","type":"object"}',
          'create_binding_schema' => '{"$schema":"http://json-schema.org/draft-04/schema","type":"object"}'
        })
      end

      context 'when catalog service metadata is nil' do
        let(:service_metadata_hash) { { 'metadata' => nil } }

        it 'leaves the extra field as nil' do
          service_manager.sync_services_and_plans(catalog)
          service = VCAP::CloudController::Service.last
          expect(service.extra).to be_nil
        end
      end

      context 'when the catalog service has no metadata key' do
        let(:service_metadata_hash) { {} }

        it 'leaves the extra field as nil' do
          service_manager.sync_services_and_plans(catalog)
          service = VCAP::CloudController::Service.last
          expect(service.extra).to be_nil
        end
      end

      context 'when the plan does not exist in the database' do
        it 'creates plans from the catalog' do
          expect {
            service_manager.sync_services_and_plans(catalog)
          }.to change(VCAP::CloudController::ServicePlan, :count).by(1)

          plan = VCAP::CloudController::ServicePlan.last
          expect(plan.service).to eq(VCAP::CloudController::Service.last)
          expect(plan.name).to eq(plan_name)
          expect(plan.description).to eq(plan_description)
          expect(plan.plan_updateable).to eq(true)
          expect(plan.maximum_polling_duration).to eq(3600)
          expect(plan.parsed_maintenance_info).to eq(plan_maintenance_info)
          expect(JSON.parse(plan.extra)).to eq({ 'cost' => '0.0' })
          expect(plan.create_instance_schema).to eq('{"$schema":"http://json-schema.org/draft-04/schema","type":"object"}')
          expect(plan.update_instance_schema).to eq('{"$schema":"http://json-schema.org/draft-04/schema","type":"object"}')
          expect(plan.create_binding_schema).to eq('{"$schema":"http://json-schema.org/draft-04/schema","type":"object"}')

          expect(plan.free).to be false
        end

        it 'marks the plan as private' do
          service_manager.sync_services_and_plans(catalog)
          plan = VCAP::CloudController::ServicePlan.last
          expect(plan.public).to be false
        end
      end

      context 'when the catalog service plan metadata is empty' do
        let(:plan_metadata_hash) { { 'metadata' => nil } }

        it 'leaves the plan extra field as nil' do
          service_manager.sync_services_and_plans(catalog)
          plan = VCAP::CloudController::ServicePlan.last
          expect(plan.extra).to be_nil
        end
      end

      context 'when the catalog service plan has no metadata key' do
        let(:plan_metadata_hash) { {} }

        it 'leaves the plan extra field as nil' do
          service_manager.sync_services_and_plans(catalog)
          plan = VCAP::CloudController::ServicePlan.last
          expect(plan.extra).to be_nil
        end
      end

      describe 'schemas' do
        context 'when the catalog service plan has schemas' do
          let(:plan_schemas_hash) do
            {
              'schemas' => {
                'service_instance' => {
                  'create' => {
                    'parameters' => {
                      '$schema' => 'http://json-schema.org/draft-04/schema', 'type' => 'object', 'anything_youd_like' => 'woohooo'
                    }
                  },
                  'update' => {
                    'parameters' => {
                      '$schema' => 'http://json-schema.org/draft-04/schema', 'type' => 'object', 'crazy_stuff' => 'yay'
                    }
                  }
                },
                'service_binding' => {
                  'create' => {
                    'parameters' => {
                      '$schema' => 'http://json-schema.org/draft-04/schema', 'type' => 'object', 'title' => 'also titles'
                    }
                  }
                }
              }
            }
          end

          it 'persists the schemas in the catalog' do
            service_manager.sync_services_and_plans(catalog)
            plan = VCAP::CloudController::ServicePlan.last
            expect(plan.create_instance_schema).to eq(
              '{"$schema":"http://json-schema.org/draft-04/schema","type":"object","anything_youd_like":"woohooo"}'
            )
            expect(plan.update_instance_schema).to eq(
              '{"$schema":"http://json-schema.org/draft-04/schema","type":"object","crazy_stuff":"yay"}'
            )
            expect(plan.create_binding_schema).to eq(
              '{"$schema":"http://json-schema.org/draft-04/schema","type":"object","title":"also titles"}'
            )
          end
        end

        context 'when the catalog service plan schemas is empty' do
          let(:plan_schemas_hash) { { 'schemas' => nil } }

          it 'leaves the plan schemas field as nil' do
            service_manager.sync_services_and_plans(catalog)
            plan = VCAP::CloudController::ServicePlan.last
            expect(plan.create_instance_schema).to be_nil
            expect(plan.update_instance_schema).to be_nil
            expect(plan.create_binding_schema).to be_nil
          end
        end

        context 'when the catalog service plan schema has no service instance' do
          let(:plan_schemas_hash) do
            {
              'schemas' => {
                'service_binding' => {
                  'create' => {
                    'parameters' => {
                      '$schema' => 'http://json-schema.org/draft-04/schema', 'type' => 'object', 'title' => 'also titles'
                    }
                  }
                }
              }
            }
          end

          it 'persists everything else' do
            service_manager.sync_services_and_plans(catalog)
            plan = VCAP::CloudController::ServicePlan.last
            expect(plan.create_instance_schema).to be_nil
            expect(plan.update_instance_schema).to be_nil
            expect(plan.create_binding_schema).to eq(
              '{"$schema":"http://json-schema.org/draft-04/schema","type":"object","title":"also titles"}'
            )
          end
        end

        context 'when the catalog service plan service instance create schema has an incomplete structure' do
          let(:plan_schemas_hash) do
            {
              'schemas' => {
                'service_instance' => {
                  'create' => {
                  }
                }
              }
            }
          end

          it 'sets all schemas to nil' do
            service_manager.sync_services_and_plans(catalog)
            plan = VCAP::CloudController::ServicePlan.last
            expect(plan.create_instance_schema).to be_nil
          end
        end

        context 'when the catalog service plan service instance update schema has an incomplete structure' do
          let(:plan_schemas_hash) do
            {
              'schemas' => {
                'service_instance' => {
                  'update' => {
                  }
                }
              }
            }
          end

          it 'sets all schemas to nil' do
            service_manager.sync_services_and_plans(catalog)
            plan = VCAP::CloudController::ServicePlan.last
            expect(plan.update_instance_schema).to be_nil
          end
        end

        context 'when the catalog service plan service binding create schema has an incomplete structure' do
          let(:plan_schemas_hash) do
            {
              'schemas' => {
                'service_binding' => {
                  'create' => {
                  }
                }
              }
            }
          end

          it 'sets all schemas to nil' do
            service_manager.sync_services_and_plans(catalog)
            plan = VCAP::CloudController::ServicePlan.last
            expect(plan.create_binding_schema).to be_nil
          end
        end

        context 'when the catalog service plan has no schemas key' do
          let(:plan_schemas_hash) { {} }

          it 'leaves the plan schemas field as nil' do
            service_manager.sync_services_and_plans(catalog)
            plan = VCAP::CloudController::ServicePlan.last
            expect(plan.create_instance_schema).to be_nil
            expect(plan.update_instance_schema).to be_nil
            expect(plan.create_binding_schema).to be_nil
          end
        end

        context 'when the catalog service plan has a nil service instance schema' do
          let(:plan_schemas_hash) { { 'schemas' => { 'service_instance' => nil } } }

          it 'leaves the plan schemas field as nil' do
            service_manager.sync_services_and_plans(catalog)
            plan = VCAP::CloudController::ServicePlan.last
            expect(plan.create_instance_schema).to be_nil
            expect(plan.update_instance_schema).to be_nil
          end
        end

        context 'when the catalog service plan has a nil service binding schema' do
          let(:plan_schemas_hash) { { 'schemas' => { 'service_binding' => nil } } }

          it 'leaves the plan schemas field as nil' do
            service_manager.sync_services_and_plans(catalog)
            plan = VCAP::CloudController::ServicePlan.last
            expect(plan.create_binding_schema).to be_nil
          end
        end
      end

      context 'when a service already exists' do
        let!(:service) do
          VCAP::CloudController::Service.make(
            service_broker: broker,
            unique_id: service_id
          )
        end

        it 'updates the existing service' do
          expect(service.label).to_not eq(service_name)
          expect(service.description).to_not eq(service_description)

          expect {
            service_manager.sync_services_and_plans(catalog)
          }.to_not change(VCAP::CloudController::Service, :count)

          service.reload
          expect(service.label).to eq(service_name)
          expect(service.description).to eq(service_description)
        end

        context 'when the broker is different' do
          let(:different_broker) { VCAP::CloudController::ServiceBroker.make }

          context 'and when there is a single service exposed from a different broker' do
            let!(:service) do
              VCAP::CloudController::Service.make(
                service_broker: different_broker,
                unique_id: service_id
              )
            end

            it 'creates the new plan' do
              expect {
                service_manager.sync_services_and_plans(catalog)
              }.to change(VCAP::CloudController::ServicePlan, :count).by(1)

              plan = VCAP::CloudController::ServicePlan.last
              expect(plan.service).to eq(VCAP::CloudController::Service.last)
              expect(plan.name).to eq(plan_name)
              expect(plan.description).to eq(plan_description)

              expect(plan.free).to be false
              expect(plan.bindable).to be true
            end
          end

          context 'and when there are two service with identical ids exposed from different brokers' do
            let!(:service_2) do
              VCAP::CloudController::Service.make(
                service_broker: different_broker,
                unique_id: service_id
              )
            end

            it 'updates the service for the correct broker' do
              expect {
                service_manager.sync_services_and_plans(catalog)
              }.to_not change(VCAP::CloudController::Service, :count)

              [service, service_2].map(&:reload)

              expect(service.label).to eq(service_name)
              expect(service.description).to eq(service_description)
              expect(service_2.label).not_to eq(service_name)
              expect(service_2.description).not_to eq(service_name)
            end
          end
        end

        it 'creates the new plan' do
          expect {
            service_manager.sync_services_and_plans(catalog)
          }.to change(VCAP::CloudController::ServicePlan, :count).by(1)

          plan = VCAP::CloudController::ServicePlan.last
          expect(plan.service).to eq(VCAP::CloudController::Service.last)
          expect(plan.name).to eq(plan_name)
          expect(plan.description).to eq(plan_description)

          expect(plan.free).to be false
          expect(plan.bindable).to be true
        end

        context 'when a service is renamed and a new service is added with the old name' do
          let!(:service) do
            VCAP::CloudController::Service.make(
              label: service_name,
              service_broker: broker,
              unique_id: service_id
            )
          end

          let(:catalog_hash) do
            {
              'services' => [
                {
                  'id'          => 'new-service-id',
                  'name'        => service_name,
                  'description' => service_description,
                  'bindable'    => true,
                  'plans' => [
                    {
                      'id'          => 'new-plan-id-1',
                      'name'        => plan_name,
                      'description' => plan_description,
                      'free'        => false,
                      'bindable'    => true,
                    },
                  ]
                },
                {
                  'id'          => service_id,
                  'name'        => 'new-name',
                  'description' => service_description,
                  'bindable'    => true,
                  'plans' => [
                    {
                      'id'          => 'new-plan-id-2',
                      'name'        => plan_name,
                      'description' => plan_description,
                      'free'        => false,
                      'bindable'    => true,
                    },
                  ]
                },
              ]
            }
          end

          it 'renames the service and creates the new service with the old name' do
            service_manager.sync_services_and_plans(catalog)

            service.reload
            expect(service.label).to eq 'new-name'

            new_service = VCAP::CloudController::Service.find(unique_id: 'new-service-id')
            expect(new_service.label).to eq service_name
          end
        end

        context 'and a plan already exists' do
          let!(:plan) do
            VCAP::CloudController::ServicePlan.make(
              service: service,
              unique_id: plan_id,
              free: true,
              bindable: false,
              maximum_polling_duration: 0,
              maintenance_info: nil,
              create_instance_schema: nil,
              update_instance_schema: nil
            )
          end

          it 'updates the existing plan' do
            expect(plan.name).to_not eq(plan_name)
            expect(plan.description).to_not eq(plan_description)
            expect(plan.free).to be true
            expect(plan.bindable).to be false
            expect(plan.plan_updateable).to be_nil
            expect(plan.maximum_polling_duration).to be_zero
            expect(plan.maintenance_info).to be_nil
            expect(plan.create_instance_schema).to be_nil
            expect(plan.update_instance_schema).to be_nil
            expect(plan.create_binding_schema).to be_nil

            expect {
              service_manager.sync_services_and_plans(catalog)
            }.to_not change(VCAP::CloudController::ServicePlan, :count)

            plan.reload
            expect(plan.name).to eq(plan_name)
            expect(plan.description).to eq(plan_description)
            expect(plan.free).to be false
            expect(plan.bindable).to be true
            expect(plan.plan_updateable).to be true
            expect(plan.maximum_polling_duration).to eq(3600)
            expect(plan.parsed_maintenance_info).to eq(plan_maintenance_info)
            expect(plan.create_instance_schema).to eq('{"$schema":"http://json-schema.org/draft-04/schema","type":"object"}')
            expect(plan.update_instance_schema).to eq('{"$schema":"http://json-schema.org/draft-04/schema","type":"object"}')
            expect(plan.create_binding_schema).to eq('{"$schema":"http://json-schema.org/draft-04/schema","type":"object"}')
          end

          it 'creates service audit events for each service plan updated' do
            service_manager.sync_services_and_plans(catalog)

            service_plan = VCAP::CloudController::ServicePlan.last

            event = VCAP::CloudController::Event.first(type: 'audit.service_plan.update')
            expect(event.type).to eq('audit.service_plan.update')
            expect(event.actor_type).to eq('service_broker')
            expect(event.actor).to eq(broker.guid)
            expect(event.actor_name).to eq(broker.name)
            expect(event.timestamp).to be
            expect(event.actee).to eq(service_plan.guid)
            expect(event.actee_type).to eq('service_plan')
            expect(event.actee_name).to eq(plan_name)
            expect(event.space_guid).to eq('')
            expect(event.organization_guid).to eq('')
            expect(event.metadata).to include({
              'name' => service_plan.name,
              'description' => service_plan.description,
              'extra' => '{"cost":"0.0"}',
              'bindable' => true,
              'free' => false,
              'create_instance_schema' => '{"$schema":"http://json-schema.org/draft-04/schema","type":"object"}',
              'update_instance_schema' => '{"$schema":"http://json-schema.org/draft-04/schema","type":"object"}',
              'create_binding_schema' => '{"$schema":"http://json-schema.org/draft-04/schema","type":"object"}'
            })
          end

          context 'when the plan belongs to a different service' do
            let(:different_service) { VCAP::CloudController::Service.make }

            context 'and when there is only one plan exposed from that service' do
              let!(:plan) do
                VCAP::CloudController::ServicePlan.make(
                  service: different_service,
                  unique_id: plan_id
                )
              end

              it 'creates a new plan associated with the service and keeps the old unchanged ' do
                expect {
                  service_manager.sync_services_and_plans(catalog)
                }.to change(VCAP::CloudController::ServicePlan, :count).by(1)

                new_plan = VCAP::CloudController::ServicePlan.last
                service.reload
                expect(new_plan.service).to eq(service)
                expect(new_plan.name).to eq(plan_name)
                expect(new_plan.description).to eq(plan_description)

                expect(new_plan.free).to be false
                expect(new_plan.bindable).to be true

                expect(plan.service).to eq(different_service)
                expect(plan.name).not_to eq(new_plan)
              end
            end

            context 'when there are two plans with the same id that belong to different services' do
              let!(:plan_2) do
                VCAP::CloudController::ServicePlan.make(
                  service: different_service,
                  unique_id: plan_id
                )
              end

              it 'updates the plan that belongs to the corresponding service and keeps the other unchanged' do
                expect {
                  service_manager.sync_services_and_plans(catalog)
                }.not_to change(VCAP::CloudController::ServicePlan, :count)

                [plan, plan_2].map(&:reload)
                expect(plan.name).to eq(plan_name)
                expect(plan.description).to eq(plan_description)

                expect(plan_2.name).not_to eq(plan_name)
                expect(plan_2.description).not_to eq(plan_description)
              end
            end
          end

          context 'when a plan is renamed and a new plan is added with the old name' do
            let!(:plan) do
              VCAP::CloudController::ServicePlan.make(
                name: plan_name,
                service: service,
                unique_id: plan_id,
                free: true,
                bindable: false,
                create_instance_schema: nil,
                update_instance_schema: nil
              )
            end

            let(:catalog_hash) do
              {
                'services' => [
                  {
                    'id'          => service_id,
                    'name'        => service_name,
                    'description' => service_description,
                    'bindable'    => true,
                    'dashboard_client' => dashboard_client_attrs,
                    'tags'        => ['mysql', 'relational'],
                    'requires'    => ['ultimate', 'power'],
                    'plan_updateable' => true,
                    'bindings_retrievable' => true,
                    'instances_retrievable' => true,
                    'allow_context_updates' => true,
                    'plans' => [
                      {
                        'id'          => 'new-plan-id',
                        'name'        => plan_name,
                        'description' => plan_description,
                        'free'        => false,
                        'bindable'    => true,
                      }.merge(plan_metadata_hash).merge(plan_schemas_hash),
                      {
                        'id'          => plan_id,
                        'name'        => plan_name + '-legacy',
                        'description' => plan_description,
                        'free'        => false,
                        'bindable'    => true,
                      }.merge(plan_metadata_hash).merge(plan_schemas_hash)
                    ]
                  }.merge(service_metadata_hash)
                ]
              }
            end

            it 'renames the plan and creates the new plan with the old name' do
              service_manager.sync_services_and_plans(catalog)

              plan.reload
              expect(plan.name).to eq plan_name + '-legacy'

              new_plan = VCAP::CloudController::ServicePlan.find(unique_id: 'new-plan-id')
              expect(new_plan.name).to eq plan_name
            end
          end

          context 'when the plan is public' do
            before do
              plan.update(public: true)
            end

            it 'does not make it public' do
              service_manager.sync_services_and_plans(catalog)
              plan.reload
              expect(plan.public).to be true
            end
          end
        end

        context 'and a plan exists that has been removed from the broker catalog' do
          let(:missing_plan_name) { '111' }
          let!(:missing_plan) do
            VCAP::CloudController::ServicePlan.make(
              service: service,
              unique_id: 'nolongerexists',
              name: missing_plan_name,
            )
          end

          it 'deletes the plan from the db' do
            service_manager.sync_services_and_plans(catalog)
            expect(VCAP::CloudController::ServicePlan.find(id: missing_plan.id)).to be_nil
          end

          it 'creates service audit events for each service plan deleted' do
            service_manager.sync_services_and_plans(catalog)

            event = VCAP::CloudController::Event.first(type: 'audit.service_plan.delete')
            expect(event.type).to eq('audit.service_plan.delete')
            expect(event.actor_type).to eq('service_broker')
            expect(event.actor).to eq(broker.guid)
            expect(event.actor_name).to eq(broker.name)
            expect(event.timestamp).to be
            expect(event.actee).to eq(missing_plan.guid)
            expect(event.actee_type).to eq('service_plan')
            expect(event.actee_name).to eq(missing_plan.name)
            expect(event.space_guid).to eq('')
            expect(event.organization_guid).to eq('')
            expect(event.metadata).to be_empty
          end

          context 'when an instance for the plan exists' do
            let(:service_name) { 'AAA' }
            let(:missing_plan2_name) { '222' }
            let(:missing_service2_name) { 'BBB' }
            let(:missing_service2_plan_name) { '111-B' }

            before do
              VCAP::CloudController::ManagedServiceInstance.make(service_plan: missing_plan)

              missing_plan2 = VCAP::CloudController::ServicePlan.make(service: service, unique_id: 'plan2_nolongerexists', name: missing_plan2_name)
              VCAP::CloudController::ManagedServiceInstance.make(service_plan: missing_plan2)
            end

            it 'marks the existing plan as inactive' do
              expect(missing_plan).to be_active

              service_manager.sync_services_and_plans(catalog)
              missing_plan.reload

              expect(missing_plan).not_to be_active
            end

            context 'when there are existing service instances' do
              before do
                missing_service2 = VCAP::CloudController::Service.make(service_broker: broker, label: missing_service2_name)
                missing_service2_plan = VCAP::CloudController::ServicePlan.make(service: missing_service2, unique_id: 'i_be_gone', name: missing_service2_plan_name)
                VCAP::CloudController::ManagedServiceInstance.make(service_plan: missing_service2_plan)
              end

              it 'adds a formatted warning' do
                service_manager.sync_services_and_plans(catalog)
                expect(service_manager.warnings).to include(<<~HEREDOC)
                  Warning: Service plans are missing from the broker's catalog (#{broker.broker_url}/v2/catalog) but can not be removed from Cloud Foundry while instances exist. The plans have been deactivated to prevent users from attempting to provision new instances of these plans. The broker should continue to support bind, unbind, and delete for existing instances; if these operations fail contact your broker provider.
                  #{service_name}
                    #{missing_plan_name}
                    #{missing_plan2_name}
                  #{missing_service2_name}
                    #{missing_service2_plan_name}
                HEREDOC
              end
            end

            context 'when there are no existing service instances' do
              it 'does not add a formatted warning' do
                service_manager.sync_services_and_plans(catalog)
                expect(service_manager.warnings).to_not include(<<~HEREDOC)
                  Warning: Service plans are missing from the broker's catalog (#{broker.broker_url}/v2/catalog) but can not be removed from Cloud Foundry while instances exist. The plans have been deactivated to prevent users from attempting to provision new instances of these plans. The broker should continue to support bind, unbind, and delete for existing instances; if these operations fail contact your broker provider.
                  #{service_name}
                    #{missing_plan_name}
                    #{missing_plan2_name}
                  #{missing_service2_name}
                    #{missing_service2_plan_name}
                HEREDOC
              end
            end
          end
        end
      end

      context 'when a service no longer exists' do
        let!(:service) do
          VCAP::CloudController::Service.make(
            service_broker: broker,
            unique_id: 'nolongerexists',
            label: 'was-an-awesome-service',
          )
        end

        let!(:service_owned_by_other_broker) do
          other_service_broker = VCAP::CloudController::ServiceBroker.make

          VCAP::CloudController::Service.make(
            service_broker: other_service_broker,
            unique_id: 'other-service-id'
          )
        end

        it 'should delete the service' do
          service_manager.sync_services_and_plans(catalog)
          expect(VCAP::CloudController::Service.find(id: service.id)).to be_nil
        end

        it 'creates service audit events for each service deleted' do
          service_manager.sync_services_and_plans(catalog)

          event = VCAP::CloudController::Event.first(type: 'audit.service.delete')
          expect(event.type).to eq('audit.service.delete')
          expect(event.actor_type).to eq('service_broker')
          expect(event.actor).to eq(broker.guid)
          expect(event.actor_name).to eq(broker.name)
          expect(event.timestamp).to be
          expect(event.actee).to eq(service.guid)
          expect(event.actee_type).to eq('service')
          expect(event.actee_name).to eq('was-an-awesome-service')
          expect(event.space_guid).to eq('')
          expect(event.organization_guid).to eq('')
          expect(event.metadata).to be_empty
        end

        it 'should not delete services owned by other brokers' do
          service_manager.sync_services_and_plans(catalog)
          expect(VCAP::CloudController::Service.find(id: service_owned_by_other_broker.id)).not_to be_nil
        end

        context 'but it has an active plan' do
          before do
            plan = VCAP::CloudController::ServicePlan.make(
              service: service,
              unique_id: 'also_no_longer_in_catalog'
            )
            VCAP::CloudController::ManagedServiceInstance.make(service_plan: plan)

            other_broker_plan = VCAP::CloudController::ServicePlan.make(
              service: service_owned_by_other_broker,
              unique_id: 'in-another-brokers-catalog'
            )
            VCAP::CloudController::ManagedServiceInstance.make(service_plan: other_broker_plan)
          end

          it 'marks the existing service as inactive' do
            expect(service).to be_active

            service_manager.sync_services_and_plans(catalog)
            service.reload

            expect(service).not_to be_active
          end

          it 'does not mark a service belonging to another broker as inactive' do
            expect(service_owned_by_other_broker).to be_active

            service_manager.sync_services_and_plans(catalog)
            service_owned_by_other_broker.reload

            expect(service_owned_by_other_broker).to be_active
          end
        end
      end
    end

    describe '#has_warnings?' do
      context 'when there are no warnings' do
        before do
          allow(service_manager).to receive(:warnings).and_return([])
        end

        it 'returns false' do
          expect(service_manager.has_warnings?).to be false
        end
      end

      context 'when there are warnings' do
        before do
          allow(service_manager).to receive(:warnings).and_return(['a warning'])
        end

        it 'returns true' do
          expect(service_manager.has_warnings?).to be true
        end
      end
    end
  end
end
