fix(rpc): pass auth credentials into duplex streams

This commit is contained in:
Connor Peet 2017-10-21 09:52:57 -07:00
Родитель cd5f75796c
Коммит 834a3b50cc
2 изменённых файлов: 4 добавлений и 2 удалений

Просмотреть файл

@ -1,4 +1,6 @@
--<%= getCommentPrefixing(`rpc ${name}(`) %>
public <%= _.lowerFirst(name) %>(): Promise<IDuplexStream<<%= requestTsType %>, <%= responseTsType %>>> {
return this.client.getConnection('<%= service %>').then(cnx => (<any> cnx.client).<%= _.lowerFirst(name) %>());
return this.client
.getConnection('<%= service %>')
.then(({ client, metadata }) => (<any> client).<%= _.lowerFirst(name) %>(metadata));
}

Просмотреть файл

@ -5,7 +5,7 @@ import * as grpc from 'grpc';
export interface ICallable {
exec(service: keyof typeof Services, method: string, params: object): Promise<any>;
getConnection(service: keyof typeof Services): Promise<{ client: grpc.Client }>;
getConnection(service: keyof typeof Services): Promise<{ client: grpc.Client, metadata: grpc.Metadata }>;
}
export interface IResponseStream<T> {