frankwang-lh / jmeter-hyperledger-plugin Goto Github PK

static String pathRoot = "YOUR FABRIC CONNECTION PROFILE & WALLET DIRECTORY PATH";
static String walletName = "WALLET_NAME";
static Path walletPath = Paths.get(pathRoot + walletName);
static Path networkConfigPath = Paths.get(pathRoot + "YOUR_NETWORK_CONFIG_FILE.json");

import java.util.concurrent.TimeoutException;

import org.hyperledger.fabric.gateway.ContractException;
import org.hyperledger.fabric.gateway.Network;

public interface SmartContract {
    // Name of smart contract - must match the name in your blockchain!
    String contractName = "contract_default";
    // Transaction method names - must match the name in your blockchain!
    String create = null;                     
    String check = null;
    String update = null;
    String delete = null;
    // Hyperledger Fabric gateway Network object
    Network network = null;
    // Default methods - init, invoke, read, update and delete
    // They may be left blank if such method does not exist in actual smart contract
    void initLedger() throws InterruptedException, TimeoutException, ContractException;
    Message invoke(String[] args) throws InterruptedException, TimeoutException, ContractException;
    Message read(String[] args) throws InterruptedException, TimeoutException, ContractException;
    Message update(String[] args) throws InterruptedException, TimeoutException, ContractException;
    Message delete(String[] args) throws InterruptedException, TimeoutException, ContractException;
}

    private int code;           // HTTP response code
    private String message;     // Response message
    private String data;        // Response data from transactions

import org.hyperledger.fabric.gateway.Contract;
import org.hyperledger.fabric.gateway.ContractException;
import org.hyperledger.fabric.gateway.Network;

import java.util.concurrent.TimeoutException;

public class CLASSNAME implements SmartContract {
    ...
    ...
    // Constructor
    public CLASSNAME(Network network, boolean init) {
        this.network = network;
        // Initialise the ledger
        if(init) {
            try {
                this.initLedger();
            } catch (Exception e) {
                System.out.println("Error: " + "Initialisation Failed");
            }
        }
    }
    
    @Override
    public void initLedger() throws InterruptedException, TimeoutException, ContractException {
        Contract contract = network.getContract(contractName);
        byte[] result_q1 = contract.createTransaction(WHATEVER_TRANSACTION).submit(SOME_ARGS);
        ...
    }
    
    @Override
    public Message invoke(String[] args) throws InterruptedException, TimeoutException, ContractException {
        Contract contract = network.getContract(contractName);
        if(args.length < 3) return new Message(400, "BAD REQUEST MISSING ARGUMENTS","");
        ... Handle Arguments
        ... Submit Requests
        byte[] result_q1 = contract.createTransaction(WHATEVER_TRANSACTION).submit(SOME_ARGS);
        ... Form return objects and throw exceptions if needed
        return new Message(200, RETURN_MESSAGE, TRANSACTION_RESULTS);
    }
    ...
    // If a default method does not exist, you may leave it blank or produce an error message. For Example:
    @Override
    public Message delete(String[] args) throws InterruptedException, TimeoutException, ContractException {
        return new Message(404, "NO DELETE ENDPOINT FOR THIS SMART CONTRACT." , null);
    }
    ...
    Add more custom methods / endpoints as required by your smart contracts
    ...
}

private Message testFabcar(Network network, String[] args, boolean init) throws InterruptedException, TimeoutException, ContractException {
        Fabcar fabcar = new Fabcar(network,init);
        switch(this.type){
            case "queryAll":
                return fabcar.queryAll(args);
            default:
                System.out.println("Response: Not a valid transaction option");
                return new Message(400, "Not a valid transaction option", null);
        }

}

private SmartContract generateSC(Network network, boolean init){
    switch(this.contract) {
        case "YOUR_CONTRACT":
            return new YOUR_SC(network,init);
        ......
    }
}

private Message defaultTest(String[] args, boolean init) {
    try {
        ...
        switch (this.type) {
            case "create":
                return sc.invoke(args);
            ...
            default:
                switch(this.contract) {
                    case "YOUR_CONTRACT":
                        return YOUR_TEST_METHOD(network,args,init);
                    default:
                        ...
                }
        }
        } catch (Exception e) {...}
    }  catch (Exception e2) {...}
}

private String getUrl(String root, String[] params){
    if(this.contract.equals("YOUR_CONTRACT")) {
        switch(this.type){
            case "create":
                return root+"create";
            case "update":
                return root+"transferTo";
            ...
            default:
                System.out.println("Response: Not a valid transaction option");
                return "Unknown operation";
        }
    } else {...}
}

private String[] defaultArgs(JavaSamplerContext context) {
    String[] args = new String[0];
    switch(this.contract) {
        case "YOUR_CONTRACT":
            String arg1 = getArg(context,"arg1") != null ? getArg(context,"arg1") : "aeg1_DEFAULT";
            ...
            args = new String[]{arg1,...};
            break;
        default:
            // DO NOTHING
    }
    return args;
}