Remove mongo implementations and fix test

Author: drew-gross

spec/ParseAPI.spec.js

@@ -13,7 +13,7 @@ var TestUtils = require('../src/index').TestUtils;
 const requiredUserFields = { fields: Object.assign({}, defaultColumns._Default, defaultColumns._User) };
 
 describe('miscellaneous', function() {
-  fit('create a GameScore object', function(done) {
+  it('create a GameScore object', function(done) {
     var obj = new Parse.Object('GameScore');
     obj.set('score', 1337);
     obj.save().then(function(obj) {
@@ -121,10 +121,7 @@ describe('miscellaneous', function() {
       fail('one of the users should not have been created');
       done();
     })
-    .catch(error => {
-      fail('index build failed')
-      done();
-    });
+    .catch(done);
   });
 
   it('ensure that if people already have duplicate users, they can still sign up new users', done => {

src/Adapters/Storage/Postgres/PostgresStorageAdapter.js

@@ -30,20 +30,11 @@ export class PostgresStorageAdapter {
   };
 
   classExists(name) {
-    console.log('classExists(name) {')
-    return this.connect().then(() => {
-      return this.database.listCollections({ name: this._collectionPrefix + name }).toArray();
-    }).then(collections => {
-      return collections.length > 0;
-    });
+    return Promise.reject('Not implented yet.')
   }
 
   setClassLevelPermissions(className, CLPs) {
-    console.log('setClassLevelPermissions(className, CLPs) {')
-    return this._schemaCollection()
-    .then(schemaCollection => schemaCollection.updateSchema(className, {
-      $set: { _metadata: { class_permissions: CLPs } }
-    }));
+    return Promise.reject('Not implented yet.')
   }
 
   createClass(className, schema) {
@@ -78,19 +69,7 @@ export class PostgresStorageAdapter {
   // Drops a collection. Resolves with true if it was a Parse Schema (eg. _User, Custom, etc.)
   // and resolves with false if it wasn't (eg. a join table). Rejects if deletion was impossible.
   deleteClass(className) {
-    console.log('deleteClass(className) {')
-    return this._adaptiveCollection(className)
-    .then(collection => collection.drop())
-    .catch(error => {
-      // 'ns not found' means collection was already gone. Ignore deletion attempt.
-      if (error.message == 'ns not found') {
-        return;
-      }
-      throw error;
-    })
-    // We've dropped the collection, now remove the _SCHEMA document
-    .then(() => this._schemaCollection())
-    .then(schemaCollection => schemaCollection.findAndDeleteSchema(className))
+    return Promise.reject('Not implented yet.')
   }
 
   // Delete all data known to this adatper. Used for testing.
@@ -130,28 +109,7 @@ export class PostgresStorageAdapter {
 
   // Returns a Promise.
   deleteFields(className, schema, fieldNames) {
-    console.log('deleteFields(className, schema, fieldNames) {')
-    const mongoFormatNames = fieldNames.map(fieldName => {
-      if (schema.fields[fieldName].type === 'Pointer') {
-        return `_p_${fieldName}`
-      } else {
-        return fieldName;
-      }
-    });
-    const collectionUpdate = { '$unset' : {} };
-    mongoFormatNames.forEach(name => {
-      collectionUpdate['$unset'][name] = null;
-    });
-
-    const schemaUpdate = { '$unset' : {} };
-    fieldNames.forEach(name => {
-      schemaUpdate['$unset'][name] = null;
-    });
-
-    return this._adaptiveCollection(className)
-    .then(collection => collection.updateMany({}, collectionUpdate))
-    .then(() => this._schemaCollection())
-    .then(schemaCollection => schemaCollection.updateSchema(className, schemaUpdate));
+    return Promise.reject('Not implented yet.')
   }
 
   // Return a promise for all schemas known to this adapter, in Parse format. In case the
@@ -187,47 +145,22 @@ export class PostgresStorageAdapter {
   // If no objects match, reject with OBJECT_NOT_FOUND. If objects are found and deleted, resolve with undefined.
   // If there is some other error, reject with INTERNAL_SERVER_ERROR.
   deleteObjectsByQuery(className, schema, query) {
-    console.log('deleteObjectsByQuery(className, schema, query) {')
-    return this._adaptiveCollection(className)
-    .then(collection => {
-      let mongoWhere = transformWhere(className, query, schema);
-      return collection.deleteMany(mongoWhere)
-    })
-    .then(({ result }) => {
-      if (result.n === 0) {
-        throw new Parse.Error(Parse.Error.OBJECT_NOT_FOUND, 'Object not found.');
-      }
-      return Promise.resolve();
-    }, error => {
-      throw new Parse.Error(Parse.Error.INTERNAL_SERVER_ERROR, 'Database adapter error');
-    });
+    return Promise.reject('Not implented yet.')
   }
 
   // Apply the update to all objects that match the given Parse Query.
   updateObjectsByQuery(className, schema, query, update) {
-    console.log('updateObjectsByQuery(className, schema, query, update) {')
-    const mongoUpdate = transformUpdate(className, update, schema);
-    const mongoWhere = transformWhere(className, query, schema);
-    return this._adaptiveCollection(className)
-    .then(collection => collection.updateMany(mongoWhere, mongoUpdate));
+    return Promise.reject('Not implented yet.')
   }
 
   // Hopefully we can get rid of this in favor of updateObjectsByQuery.
   findOneAndUpdate(className, schema, query, update) {
-    console.log('findOneAndUpdate(className, schema, query, update) {')
-    const mongoUpdate = transformUpdate(className, update, schema);
-    const mongoWhere = transformWhere(className, query, schema);
-    return this._adaptiveCollection(className)
-    .then(collection => collection.findOneAndUpdate(mongoWhere, mongoUpdate));
+    return Promise.reject('Not implented yet.')
   }
 
   // Hopefully we can get rid of this. It's only used for config and hooks.
   upsertOneObject(className, schema, query, update) {
-    console.log('upsertOneObject(className, schema, query, update) {')
-    const mongoUpdate = transformUpdate(className, update, schema);
-    const mongoWhere = transformWhere(className, query, schema);
-    return this._adaptiveCollection(className)
-    .then(collection => collection.upsertOne(mongoWhere, mongoUpdate));
+    return Promise.reject('Not implented yet.')
   }
 
   // Executes a find. Accepts: className, query in Parse format, and { skip, limit, sort }.
@@ -241,29 +174,12 @@ export class PostgresStorageAdapter {
   // Way of determining if a field is nullable. Undefined doesn't count against uniqueness,
   // which is why we use sparse indexes.
   ensureUniqueness(className, schema, fieldNames) {
-    console.log('ensureUniqueness(className, schema, fieldNames) {')
-    return Promise.resolve();
-    let indexCreationRequest = {};
-    let mongoFieldNames = fieldNames.map(fieldName => transformKey(className, fieldName, schema));
-    mongoFieldNames.forEach(fieldName => {
-      indexCreationRequest[fieldName] = 1;
-    });
-    return this._adaptiveCollection(className)
-    .then(collection => collection._ensureSparseUniqueIndexInBackground(indexCreationRequest))
-    .catch(error => {
-      if (error.code === 11000) {
-        throw new Parse.Error(Parse.Error.DUPLICATE_VALUE, 'Tried to ensure field uniqueness for a class that already has duplicates.');
-      } else {
-        throw error;
-      }
-    });
+    return Promise.resolve('ensureUniqueness not implented yet.')
   }
 
   // Executs a count.
   count(className, schema, query) {
-    console.log('count(className, schema, query) {')
-    return this._adaptiveCollection(className)
-    .then(collection => collection.count(transformWhere(className, query, schema)));
+    return Promise.reject('Not implented yet.')
   }
 }