Revert "Add support for create/update/delete event types for database functions. (#57)" (#64)

This reverts commit 3533644.

Author: laurenzlong

spec/providers/database.spec.ts

@@ -62,86 +62,24 @@ describe('DatabaseBuilder', () => {
         resource: 'projects/_/instances/subdomains/refs/users',
       } as any);
     });
-  });
-
-  describe('#onCreate()', () => {
-    it('should return "ref.create" as the event type', () => {
-      let eventType = database.ref('foo').onCreate(() => null).__trigger.eventTrigger.eventType;
-      expect(eventType).to.eq('providers/google.firebase.database/eventTypes/ref.create');
-    });
-
-    it('should construct a proper resource path', () => {
-      let resource = database.ref('foo').onCreate(() => null).__trigger.eventTrigger.resource;
-      expect(resource).to.eq('projects/_/instances/subdomain/refs/foo');
-    });
 
-    it('should return a handler that emits events with a proper DeltaSnapshot', () => {
-      let handler = database.ref('/users/{id}').onCreate(event => {
-        expect(event.data.val()).to.deep.equal({ foo: 'bar' });
+    it('should interpolate params until the server does it', () => {
+      let handler = database.ref('/users/{id}').onWrite(event => {
+        expect(event.resource).to.equal('projects/_/instances/subdomain/refs/users/aUserId');
       });
 
       return handler({
         data: {
           data: null,
-          delta: { foo: 'bar' },
+          delta: 'hello',
         },
-        resource: 'projects/_/instances/subdomains/refs/users',
-      } as any);
-    });
-  });
-
-  describe('#onUpdate()', () => {
-    it('should return "ref.update" as the event type', () => {
-      let eventType = database.ref('foo').onUpdate(() => null).__trigger.eventTrigger.eventType;
-      expect(eventType).to.eq('providers/google.firebase.database/eventTypes/ref.update');
-    });
-
-    it('should construct a proper resource path', () => {
-      let resource = database.ref('foo').onUpdate(() => null).__trigger.eventTrigger.resource;
-      expect(resource).to.eq('projects/_/instances/subdomain/refs/foo');
-    });
-
-    it('should return a handler that emits events with a proper DeltaSnapshot', () => {
-      let handler = database.ref('/users/{id}').onUpdate(event => {
-        expect(event.data.val()).to.deep.equal({ foo: 'bar' });
-      });
-
-      return handler({
-        data: {
-          data: null,
-          delta: { foo: 'bar' },
+        resource: 'projects/_/instances/subdomain/refs/users/{id}',
+        params: {
+          id: 'aUserId',
         },
-        resource: 'projects/_/instances/subdomains/refs/users',
-      } as any);
-    });
-  });
-
-  describe('#onDelete()', () => {
-    it('should return "ref.delete" as the event type', () => {
-      let eventType = database.ref('foo').onDelete(() => null).__trigger.eventTrigger.eventType;
-      expect(eventType).to.eq('providers/google.firebase.database/eventTypes/ref.delete');
-    });
-
-    it('should construct a proper resource path', () => {
-      let resource = database.ref('foo').onDelete(() => null).__trigger.eventTrigger.resource;
-      expect(resource).to.eq('projects/_/instances/subdomain/refs/foo');
-    });
-
-    it('should return a handler that emits events with a proper DeltaSnapshot', () => {
-      let handler = database.ref('/users/{id}').onDelete(event => {
-        expect(event.data.val()).to.deep.equal({ foo: 'bar' });
       });
-
-      return handler({
-        data: {
-          data: null,
-          delta: { foo: 'bar' },
-        },
-        resource: 'projects/_/instances/subdomains/refs/users',
-      } as any);
     });
   });
-
 });
 
 describe('DeltaSnapshot', () => {

src/providers/database.ts

@@ -79,28 +79,6 @@ export class RefBuilder {
 
   /** Respond to any write that affects a ref. */
   onWrite(handler: (event: Event<DeltaSnapshot>) => PromiseLike<any> | any): CloudFunction<DeltaSnapshot> {
-    return this.onOperation(handler, 'ref.write');
-  }
-
-  /** Respond to new data on a ref. */
-  onCreate(handler: (event: Event<DeltaSnapshot>) => PromiseLike<any> | any): CloudFunction<DeltaSnapshot> {
-    return this.onOperation(handler, 'ref.create');
-  }
-
-  /** Respond to update on a ref. */
-  onUpdate(handler: (event: Event<DeltaSnapshot>) => PromiseLike<any> | any): CloudFunction<DeltaSnapshot> {
-    return this.onOperation(handler, 'ref.update');
-  }
-
-  /** Respond to all data being deleted from a ref. */
-  onDelete(handler: (event: Event<DeltaSnapshot>) => PromiseLike<any> | any): CloudFunction<DeltaSnapshot> {
-    return this.onOperation(handler, 'ref.delete');
-  }
-
-  private onOperation(
-    handler: (event: Event<DeltaSnapshot>) => PromiseLike<any> | any,
-    eventType: string): CloudFunction<DeltaSnapshot> {
-
     const dataConstructor = (raw: Event<any>) => {
       if (raw.data instanceof DeltaSnapshot) {
         return raw.data;
@@ -115,10 +93,16 @@ export class RefBuilder {
     };
     return makeCloudFunction({
       provider, handler,
-      eventType: eventType,
+      eventType: 'ref.write',
       resource: this.resource,
       dataConstructor,
-      before: (event) => this.apps.retain(event),
+      before: (event) => {
+        // BUG(36000428) Remove when no longer necessary
+        _.forEach(event.params, (val, key) => {
+          event.resource = _.replace(event.resource, `{${key}}`, val);
+        });
+        this.apps.retain(event);
+      },
       after: (event) => this.apps.release(event),
     });
   }