fixes

Author: MarkDuckworth

packages/firestore/src/lite-api/pipeline.ts

@@ -18,7 +18,7 @@ import { DocumentKey } from '../model/document_key';
 import { ObjectValue } from '../model/object_value';
 import {
   ExecutePipelineRequest,
-  firestoreV1ApiClientInterfaces,
+  StructuredPipeline,
   Stage as ProtoStage
 } from '../protos/firestore_proto_api';
 import { invokeExecutePipeline } from '../remote/datastore';
@@ -63,8 +63,6 @@ import {
 } from './user_data_reader';
 import { AbstractUserDataWriter } from './user_data_writer';
 
-import StructuredPipeline = firestoreV1ApiClientInterfaces.StructuredPipeline;
-
 interface ReadableUserData {
   _readUserData(dataReader: UserDataReader): void;
 }

packages/firestore/src/protos/firestore_proto_api.ts

@@ -572,6 +572,8 @@ export declare type Stage = firestoreV1ApiClientInterfaces.Stage;
 export declare type Status = firestoreV1ApiClientInterfaces.Status;
 export declare type StructuredQuery =
   firestoreV1ApiClientInterfaces.StructuredQuery;
+export declare type StructuredPipeline =
+  firestoreV1ApiClientInterfaces.StructuredPipeline;
 export declare type Target = firestoreV1ApiClientInterfaces.Target;
 export declare type TargetChange = firestoreV1ApiClientInterfaces.TargetChange;
 export declare type TransactionOptions =

packages/firestore/src/remote/datastore.ts

@@ -252,7 +252,7 @@ export async function invokeExecutePipeline(
   >(
     'ExecutePipeline',
     datastoreImpl.serializer.databaseId,
-    toResourcePath(datastoreImpl.serializer.databaseId),
+    ResourcePath.emptyPath(),
     executePipelineRequest
   );
 

packages/firestore/test/integration/api/pipeline.test.ts

@@ -55,7 +55,7 @@ import { apiDescribe, withTestCollection } from '../util/helpers';
 
 use(chaiAsPromised);
 
-apiDescribe('Queries', persistence => {
+apiDescribe.only('Pipelines', persistence => {
   addEqualityMatcher();
   let firestore: Firestore;
   let randomCol: CollectionReference;