epistemophiliac/fabric-samples
1
0
Fork 0
mirror of https://github.com/hyperledger/fabric-samples.git synced 2026-06-22 17:45:10 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Specify query handler strategy

Browse source 
Avoid load on a single peer by specifying the PREFER_MSPID_SCOPE_ROUND_ROBIN
strategy

Signed-off-by: James Taylor <jamest@uk.ibm.com>
This commit is contained in:
James Taylor 2021-07-02 12:24:13 +01:00
parent 9c98450946
commit 324f1c8683
2 changed files with 47 additions and 33 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

46
asset-transfer-basic/rest-api-typescript/src/fabric.ts Normal file
View file

@ -0,0 +1,46 @@
/*
* SPDX-License-Identifier: Apache-2.0
*/
import {
DefaultQueryHandlerStrategies,
Gateway,
GatewayOptions,
Contract,
Wallets,
} from 'fabric-network';
import * as config from './config';
export const getContract = async (): Promise<Contract> => {
const wallet = await Wallets.newInMemoryWallet();
const x509Identity = {
credentials: {
certificate: config.certificate,
privateKey: config.privateKey,
},
mspId: config.mspId,
type: 'X.509',
};
await wallet.put(config.identityName, x509Identity);
const gateway = new Gateway();
const connectOptions: GatewayOptions = {
wallet,
identity: config.identityName,
discovery: { enabled: true, asLocalhost: config.asLocalHost },
queryHandlerOptions: {
timeout: 3,
strategy: DefaultQueryHandlerStrategies.PREFER_MSPID_SCOPE_ROUND_ROBIN,
},
};
await gateway.connect(config.connectionProfile, connectOptions);
const network = await gateway.getNetwork(config.channelName);
const contract = network.getContract(config.chaincodeName);
return contract;
};

34
asset-transfer-basic/rest-api-typescript/src/server.ts
View file

@ -6,11 +6,10 @@ import helmet from 'helmet';
import { StatusCodes, getReasonPhrase } from 'http-status-codes'; import { StatusCodes, getReasonPhrase } from 'http-status-codes';
import express, { Application, NextFunction, Request, Response } from 'express'; import express, { Application, NextFunction, Request, Response } from 'express';
import pinoMiddleware from 'pino-http'; import pinoMiddleware from 'pino-http';
import { Gateway, GatewayOptions, Contract, Wallets } from 'fabric-network';
import * as config from './config';
import { logger } from './logger'; import { logger } from './logger';
import { assetsRouter } from './assets.router'; import { assetsRouter } from './assets.router';
import { getContract } from './fabric';
const { BAD_REQUEST, INTERNAL_SERVER_ERROR, NOT_FOUND, OK } = StatusCodes; const { BAD_REQUEST, INTERNAL_SERVER_ERROR, NOT_FOUND, OK } = StatusCodes;
@ -92,34 +91,3 @@ export const createServer = async (): Promise<Application> => {
return app; return app;
}; };
// TODO should this go in a fabric.ts file?
const getContract = async (): Promise<Contract> => {
const wallet = await Wallets.newInMemoryWallet();
const x509Identity = {
credentials: {
certificate: config.certificate,
privateKey: config.privateKey,
},
mspId: config.mspId,
type: 'X.509',
};
await wallet.put(config.identityName, x509Identity);
const gateway = new Gateway();
const gatewayOpts: GatewayOptions = {
wallet,
identity: config.identityName,
discovery: { enabled: true, asLocalhost: config.asLocalHost },
};
await gateway.connect(config.connectionProfile, gatewayOpts);
const network = await gateway.getNetwork(config.channelName);
const contract = network.getContract(config.chaincodeName);
return contract;
};