Method createTestPostgreSQLDatabase

backend/tests/action_test.go:615–654

createTestPostgreSQLDatabase creates a test PostgreSQL database instance and database

(ctx context.Context, t *testing.T)

// createTestPostgreSQLDatabase creates a test PostgreSQL database instance and database
func (ctl *controller) createTestPostgreSQLDatabase(ctx context.Context, t *testing.T) (*v1pb.Database, *Container) {
	a := require.New(t)

	// Get PostgreSQL container
	pgContainer, err := getPgContainer(ctx)
	a.NoError(err)

	// Create PostgreSQL instance
	instanceResp, err := ctl.instanceServiceClient.CreateInstance(ctx, connect.NewRequest(&v1pb.CreateInstanceRequest{
		InstanceId: generateRandomString("inst")[:8],
		Instance: &v1pb.Instance{
			Title:       "Test PostgreSQL Instance",
			Engine:      v1pb.Engine_POSTGRES,
			Environment: new("environments/prod"),
			Activation:  true,
			DataSources: []*v1pb.DataSource{{
				Type:     v1pb.DataSourceType_ADMIN,
				Host:     pgContainer.host,
				Port:     pgContainer.port,
				Username: "postgres",
				Password: "root-password",
				Id:       "admin",
			}},
		},
	}))
	a.NoError(err)

	// Create database
	dbName := generateRandomString("db")[:8]
	err = ctl.createDatabase(ctx, ctl.project, instanceResp.Msg, nil, dbName, "postgres")
	a.NoError(err)

	// Get database
	databaseResp, err := ctl.databaseServiceClient.GetDatabase(ctx, connect.NewRequest(&v1pb.GetDatabaseRequest{
		Name: fmt.Sprintf("%s/databases/%s", instanceResp.Msg.Name, dbName),
	}))
	a.NoError(err)

	return databaseResp.Msg, pgContainer
}

func TestActionRolloutCommand(t *testing.T) {
	t.Parallel()