Skip to content

Commit f3eb753

Browse files
committed
refactor typecasting
1 parent 1749aa9 commit f3eb753

File tree

2 files changed

+10
-19
lines changed

2 files changed

+10
-19
lines changed

src/batch-transaction.ts

Lines changed: 5 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -148,23 +148,16 @@ class BatchTransaction extends Snapshot {
148148
query: string | ExecuteSqlRequest,
149149
cb?: CreateQueryPartitionsCallback,
150150
): void | Promise<CreateQueryPartitionsResponse> {
151-
if (is.string(query)) {
152-
query = {
153-
sql: query as string,
154-
};
155-
}
151+
const request: ExecuteSqlRequest =
152+
typeof query === 'string' ? {sql: query} : query;
156153

157-
const reqOpts = Object.assign(
158-
{},
159-
query,
160-
Snapshot.encodeParams(query as ExecuteSqlRequest),
161-
);
154+
const reqOpts = Object.assign({}, query, Snapshot.encodeParams(request));
162155

163156
delete (reqOpts as any).gaxOptions;
164157
delete (reqOpts as any).types;
165158

166159
const traceConfig: traceConfig = {
167-
sql: (query as ExecuteSqlRequest).sql,
160+
sql: request.sql,
168161
opts: this._observabilityOptions,
169162
dbName: this.getDBName(),
170163
};
@@ -182,7 +175,7 @@ class BatchTransaction extends Snapshot {
182175
client: 'SpannerClient',
183176
method: 'partitionQuery',
184177
reqOpts,
185-
gaxOpts: (query as ExecuteSqlRequest).gaxOptions,
178+
gaxOpts: request.gaxOptions,
186179
headers: injectRequestIDIntoHeaders(headers, this.session),
187180
},
188181
(err, partitions, resp) => {

test/batch-transaction.ts

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@ import {
3333
LEADER_AWARE_ROUTING_HEADER,
3434
} from '../src/common';
3535
import {ExecuteSqlRequest} from '../src/transaction';
36+
import {CallOptions} from 'google-gax';
3637

3738
let promisified = false;
3839
const fakePfy = extend({}, pfy, {
@@ -160,9 +161,9 @@ describe('BatchTransaction', () => {
160161
},
161162
};
162163

163-
const QUERY = {
164+
const QUERY: ExecuteSqlRequest = {
164165
sql: 'SELECT * FROM Singers',
165-
gaxOptions: GAX_OPTS,
166+
gaxOptions: GAX_OPTS as CallOptions,
166167
params: {},
167168
types: {},
168169
dataBoostEnabled: true,
@@ -184,10 +185,7 @@ describe('BatchTransaction', () => {
184185
.withArgs(QUERY)
185186
.returns(fakeParams);
186187

187-
batchTransaction.createQueryPartitions(
188-
QUERY as ExecuteSqlRequest,
189-
assert.ifError,
190-
);
188+
batchTransaction.createQueryPartitions(QUERY, assert.ifError);
191189

192190
const {client, method, reqOpts, gaxOpts, headers} = stub.lastCall.args[0];
193191
assert.strictEqual(client, 'SpannerClient');
@@ -234,7 +232,7 @@ describe('BatchTransaction', () => {
234232
.withArgs(QUERY)
235233
.returns(fakeParams);
236234

237-
await batchTransaction.createQueryPartitions(QUERY as ExecuteSqlRequest);
235+
await batchTransaction.createQueryPartitions(QUERY);
238236

239237
const {client, method, reqOpts, gaxOpts, headers} = stub.lastCall.args[0];
240238
assert.strictEqual(client, 'SpannerClient');

0 commit comments

Comments
 (0)