80 lines
2.1 KiB
JavaScript
80 lines
2.1 KiB
JavaScript
const Parse = require('parse/node').Parse;
|
|
const PostgresStorageAdapter = require('../lib/Adapters/Storage/Postgres/PostgresStorageAdapter')
|
|
.default;
|
|
const postgresURI =
|
|
process.env.PARSE_SERVER_TEST_DATABASE_URI ||
|
|
'postgres://localhost:5432/parse_server_postgres_adapter_test_database';
|
|
|
|
//public schema
|
|
const databaseOptions1 = {
|
|
initOptions: {
|
|
schema: 'public',
|
|
},
|
|
};
|
|
|
|
//not exists schema
|
|
const databaseOptions2 = {
|
|
initOptions: {
|
|
schema: 'not_exists_schema',
|
|
},
|
|
};
|
|
|
|
const GameScore = Parse.Object.extend({
|
|
className: 'GameScore',
|
|
});
|
|
|
|
describe_only_db('postgres')('Postgres database init options', () => {
|
|
|
|
it('should create server with public schema databaseOptions', async () => {
|
|
const adapter = new PostgresStorageAdapter({
|
|
uri: postgresURI,
|
|
collectionPrefix: 'test_',
|
|
databaseOptions: databaseOptions1,
|
|
});
|
|
await reconfigureServer({
|
|
databaseAdapter: adapter,
|
|
});
|
|
const score = new GameScore({
|
|
score: 1337,
|
|
playerName: 'Sean Plott',
|
|
cheatMode: false,
|
|
});
|
|
await score.save();
|
|
});
|
|
|
|
it('should create server using postgresql uri with public schema databaseOptions', async () => {
|
|
const postgresURI2 = new URL(postgresURI);
|
|
postgresURI2.protocol = 'postgresql:';
|
|
const adapter = new PostgresStorageAdapter({
|
|
uri: postgresURI2.toString(),
|
|
collectionPrefix: 'test_',
|
|
databaseOptions: databaseOptions1,
|
|
});
|
|
await reconfigureServer({
|
|
databaseAdapter: adapter,
|
|
});
|
|
const score = new GameScore({
|
|
score: 1337,
|
|
playerName: 'Sean Plott',
|
|
cheatMode: false,
|
|
});
|
|
await score.save();
|
|
});
|
|
|
|
it('should fail to create server if schema databaseOptions does not exist', async () => {
|
|
const adapter = new PostgresStorageAdapter({
|
|
uri: postgresURI,
|
|
collectionPrefix: 'test_',
|
|
databaseOptions: databaseOptions2,
|
|
});
|
|
try {
|
|
await reconfigureServer({
|
|
databaseAdapter: adapter,
|
|
});
|
|
fail("Should have thrown error");
|
|
} catch(error) {
|
|
expect(error).toBeDefined();
|
|
}
|
|
});
|
|
});
|