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

se creo un service para crear recetas

Browse source
This commit is contained in:
lucas bonfil 2024-08-22 19:25:18 -03:00
parent a5e88af0a7
commit 1a302e2240
6 changed files with 286 additions and 66 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

129
asset-transfer-basic/maven-example/src/main/java/com/code/hyperledger/App.java
View file

@ -1,8 +1,7 @@
package com.code.hyperledger;
import com.code.hyperledger.coso.Asset;
import org.hyperledger.fabric.gateway.*;
import com.code.hyperledger.coso.Receta;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import com.google.gson.Gson;
@ -23,6 +22,7 @@ import org.hyperledger.fabric.client.identity.Identity;
import org.hyperledger.fabric.client.identity.Signer;
import org.hyperledger.fabric.client.identity.Signers;
import org.hyperledger.fabric.client.identity.X509Identity;
import org.springframework.context.annotation.Configuration;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
@ -36,9 +36,10 @@ import java.time.Instant;
import java.time.LocalDate;
import java.time.LocalDateTime;
@SpringBootApplication
public final class App {
private static final String MSP_ID = System.getenv().getOrDefault("MSP_ID", "Org1MSP");
public class App {
/*private static final String MSP_ID = System.getenv().getOrDefault("MSP_ID", "Org1MSP");
private static final String CHANNEL_NAME = System.getenv().getOrDefault("CHANNEL_NAME", "mychannel");
private static final String CHAINCODE_NAME = System.getenv().getOrDefault("CHAINCODE_NAME", "basic");
@ -57,10 +58,10 @@ public final class App {
private final Contract contract;
private final String assetId = "asset" + Instant.now().toEpochMilli();
private final Gson gson = new GsonBuilder().setPrettyPrinting().create();
private final Gson gson = new GsonBuilder().setPrettyPrinting().create();*/
public static void main(final String[] args) throws Exception {
System.out.println("\n--> ENTRANDO");
/*System.out.println("\n--> ENTRANDO");
// The gRPC client connection should be shared by all Gateway connections to
// this endpoint.
@ -78,10 +79,12 @@ public final class App {
new App(gateway).run();
} finally {
channel.shutdownNow().awaitTermination(5, TimeUnit.SECONDS);
}
}*/
SpringApplication.run(App.class, args);
}
private static ManagedChannel newGrpcConnection() throws IOException {
/*private static ManagedChannel newGrpcConnection() throws IOException {
var credentials = TlsChannelCredentials.newBuilder()
.trustManager(TLS_CERT_PATH.toFile())
.build();
@ -91,18 +94,18 @@ public final class App {
}
private static Identity newIdentity() throws IOException, CertificateException {
try (var certReader = Files.newBufferedReader(getFirstFilePath(CERT_DIR_PATH))) {
var certificate = Identities.readX509Certificate(certReader);
return new X509Identity(MSP_ID, certificate);
}
}
try (var certReader = Files.newBufferedReader(getFirstFilePath(CERT_DIR_PATH))) {
var certificate = Identities.readX509Certificate(certReader);
return new X509Identity(MSP_ID, certificate);
}
}
private static Signer newSigner() throws IOException, InvalidKeyException {
try (var keyReader = Files.newBufferedReader(getFirstFilePath(KEY_DIR_PATH))) {
var privateKey = Identities.readPrivateKey(keyReader);
return Signers.newPrivateKeySigner(privateKey);
}
}
private static Signer newSigner() throws IOException, InvalidKeyException {
try (var keyReader = Files.newBufferedReader(getFirstFilePath(KEY_DIR_PATH))) {
var privateKey = Identities.readPrivateKey(keyReader);
return Signers.newPrivateKeySigner(privateKey);
}
}
private static Path getFirstFilePath(Path dirPath) throws IOException {
try (var keyFiles = Files.list(dirPath)) {
@ -137,25 +140,25 @@ public final class App {
// Update an asset which does not exist.
updateNonExistentAsset();
}
}*/
/**
* This type of transaction would typically only be run once by an application
* the first time it was started after its initial deployment. A new version of
* the chaincode deployed later would likely not need to run an "init" function.
*/
private void initLedger() throws EndorseException, SubmitException, CommitStatusException, CommitException {
/*private void initLedger() throws EndorseException, SubmitException, CommitStatusException, CommitException {
System.out.println("\n--> Submit Transaction: InitLedger, function creates the initial set of assets on the ledger");
contract.submitTransaction("InitLedger");
System.out.println("*** Transaction committed successfully");
}
}*/
/**
* Evaluate a transaction to query ledger state.
*/
private void getAllAssets() throws GatewayException {
/*private void getAllAssets() throws GatewayException {
System.out.println("\n--> Evaluate Transaction: GetAllAssets, function returns all the current assets on the ledger");
var result = contract.evaluateTransaction("GetAllAssets");
@ -170,16 +173,16 @@ public final class App {
private String prettyJson(final String json) {
var parsedJson = JsonParser.parseString(json);
return gson.toJson(parsedJson);
}
}*/
/**
* Submit a transaction synchronously, blocking until it has been committed to
* the ledger.
*/
private void createAsset() throws EndorseException, SubmitException, CommitStatusException, CommitException {
/*private void createAsset() throws EndorseException, SubmitException, CommitStatusException, CommitException {
System.out.println("\n--> Submit Transaction: CreateAsset, creates new asset with all arguments");
Asset asset = new Asset(
Receta receta = new Receta(
assetId,
"Tom",
"presc456",
@ -200,33 +203,33 @@ public final class App {
contract.submitTransaction(
"CreateAsset",
asset.getId(),
asset.getOwner(),
asset.getPrescripcionAnteriorId(),
asset.getStatus(),
asset.getStatusChange().toString(),
asset.getPrioridad(),
asset.getMedicacion(),
asset.getRazon(),
asset.getNotas(),
asset.getPeriodoDeTratamiento(),
asset.getInstruccionesTratamiento(),
asset.getPeriodoDeValidez(),
asset.getDniPaciente(),
asset.getFechaDeAutorizacion().toString(),
Integer.toString(asset.getCantidad()),
asset.getExpectedSupplyDuration().toString()
receta.getId(),
receta.getOwner(),
receta.getPrescripcionAnteriorId(),
receta.getStatus(),
receta.getStatusChange().toString(),
receta.getPrioridad(),
receta.getMedicacion(),
receta.getRazon(),
receta.getNotas(),
receta.getPeriodoDeTratamiento(),
receta.getInstruccionesTratamiento(),
receta.getPeriodoDeValidez(),
receta.getDniPaciente(),
receta.getFechaDeAutorizacion().toString(),
Integer.toString(receta.getCantidad()),
receta.getExpectedSupplyDuration().toString()
);
System.out.println("*** Transaction committed successfully");
}
}*/
/**
* Submit transaction asynchronously, allowing the application to process the
* smart contract response (e.g. update a UI) while waiting for the commit
* notification.
*/
private void transferAssetAsync() throws EndorseException, SubmitException, CommitStatusException {
/*private void transferAssetAsync() throws EndorseException, SubmitException, CommitStatusException {
System.out.println("\n--> Async Submit Transaction: TransferAsset, updates existing asset owner");
var commit = contract.newProposal("TransferAsset")
@ -256,17 +259,17 @@ public final class App {
var evaluateResult = contract.evaluateTransaction("ReadAsset", assetId);
System.out.println("*** Result:" + prettyJson(evaluateResult));
}
}*/
/**
* submitTransaction() will throw an error containing details of any error
* responses from the smart contract.
*/
private void updateNonExistentAsset() {
/*private void updateNonExistentAsset() {
try {
System.out.println("\n--> Submit Transaction: UpdateAsset asset70, asset70 does not exist and should return an error");
Asset asset = new Asset(
Receta receta = new Receta(
"asset70", // Asset ID
"Tomoko", // Owner
"presc789", // Prescripcion Anterior Id
@ -288,21 +291,21 @@ public final class App {
contract.submitTransaction(
"UpdateAsset",
"asset70",
asset.getOwner(),
asset.getPrescripcionAnteriorId(),
asset.getStatus(),
asset.getStatusChange().toString(),
asset.getPrioridad(),
asset.getMedicacion(),
asset.getRazon(),
asset.getNotas(),
asset.getPeriodoDeTratamiento(),
asset.getInstruccionesTratamiento(),
asset.getPeriodoDeValidez(),
asset.getDniPaciente(),
asset.getFechaDeAutorizacion().toString(),
Integer.toString(asset.getCantidad()),
asset.getExpectedSupplyDuration().toString()
receta.getOwner(),
receta.getPrescripcionAnteriorId(),
receta.getStatus(),
receta.getStatusChange().toString(),
receta.getPrioridad(),
receta.getMedicacion(),
receta.getRazon(),
receta.getNotas(),
receta.getPeriodoDeTratamiento(),
receta.getInstruccionesTratamiento(),
receta.getPeriodoDeValidez(),
receta.getDniPaciente(),
receta.getFechaDeAutorizacion().toString(),
Integer.toString(receta.getCantidad()),
receta.getExpectedSupplyDuration().toString()
);
System.out.println("******** FAILED to return an error");
@ -325,5 +328,5 @@ public final class App {
System.out.println("Transaction ID: " + e.getTransactionId());
System.out.println("Status code: " + e.getCode());
}
}
}*/
}

4
asset-transfer-basic/maven-example/src/main/java/com/code/hyperledger/controllers/Example.java
View file

@ -1,6 +1,6 @@
package com.code.hyperledger.controllers;
import com.code.hyperledger.coso.Asset;
import com.code.hyperledger.coso.Receta;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@ -9,7 +9,7 @@ public class Example {
@GetMapping("/hello")
public String sayHello() {
Asset asset = new Asset();
Receta receta = new Receta();
return "Hello, World!";
}

39
asset-transfer-basic/maven-example/src/main/java/com/code/hyperledger/controllers/RecetaController.java Normal file
View file

@ -0,0 +1,39 @@
package com.code.hyperledger.controllers;
import com.code.hyperledger.coso.Receta;
import com.code.hyperledger.services.RecetaService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.time.LocalDate;
import java.time.LocalDateTime;
@RestController
@RequestMapping("/recetas")
public class RecetaController {
@Autowired
private RecetaService recetaService;
//usar este endpoint
@PostMapping("/crear")
public String crear() {
System.out.println("\n--> Submit Transaction: CreateAsset, creates new asset with all arguments");
recetaService.crearReceta();
return "Hello, World!";
}
@GetMapping("/obtener")
public String sayHello() {
com.code.hyperledger.coso.Receta receta = new com.code.hyperledger.coso.Receta();
return "Hello, World!";
}
}

2
asset-transfer-basic/maven-example/src/main/java/com/code/hyperledger/coso/Asset.java → asset-transfer-basic/maven-example/src/main/java/com/code/hyperledger/coso/Receta.java
View file

@ -10,7 +10,7 @@ import lombok.NoArgsConstructor;
@Data
@AllArgsConstructor
@NoArgsConstructor
public class Asset {
public class Receta {
private String id;
private String owner;
private String prescripcionAnteriorId;

177
asset-transfer-basic/maven-example/src/main/java/com/code/hyperledger/services/RecetaService.java Normal file
View file

@ -0,0 +1,177 @@
package com.code.hyperledger.services;
import com.code.hyperledger.App;
import com.code.hyperledger.coso.Receta;
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import io.grpc.Grpc;
import io.grpc.ManagedChannel;
import io.grpc.TlsChannelCredentials;
import lombok.SneakyThrows;
import org.hyperledger.fabric.client.*;
import org.hyperledger.fabric.client.identity.*;
import org.springframework.stereotype.Service;
import javax.annotation.PostConstruct;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.security.InvalidKeyException;
import java.security.cert.CertificateException;
import java.time.Instant;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.util.concurrent.TimeUnit;
@Service
public class RecetaService {
private static final String MSP_ID = System.getenv().getOrDefault("MSP_ID", "Org1MSP");
private static final String CHANNEL_NAME = System.getenv().getOrDefault("CHANNEL_NAME", "mychannel");
private static final String CHAINCODE_NAME = System.getenv().getOrDefault("CHAINCODE_NAME", "basic");
// Path to crypto materials.
private static final Path CRYPTO_PATH = Paths.get("../../test-network/organizations/peerOrganizations/org1.example.com");
// Path to user certificate.
private static final Path CERT_DIR_PATH = CRYPTO_PATH.resolve(Paths.get("users/User1@org1.example.com/msp/signcerts"));
// Path to user private key directory.
private static final Path KEY_DIR_PATH = CRYPTO_PATH.resolve(Paths.get("users/User1@org1.example.com/msp/keystore"));
// Path to peer tls certificate.
private static final Path TLS_CERT_PATH = CRYPTO_PATH.resolve(Paths.get("peers/peer0.org1.example.com/tls/ca.crt"));
// Gateway peer end point.
private static final String PEER_ENDPOINT = "localhost:7051";
private static final String OVERRIDE_AUTH = "peer0.org1.example.com";
private Contract contract;
private final String assetId = "asset" + Instant.now().toEpochMilli();
private final Gson gson = new GsonBuilder().setPrettyPrinting().create();
private static Path getFirstFilePath(Path dirPath) throws IOException {
try (var keyFiles = Files.list(dirPath)) {
return keyFiles.findFirst().orElseThrow();
}
}
@SneakyThrows
@PostConstruct
public void init() {
System.out.println("LLEGO ACA");
var channel = newGrpcConnection();
var builder = Gateway.newInstance().identity(newIdentity()).signer(newSigner()).connection(channel)
// Default timeouts for different gRPC calls
.evaluateOptions(options -> options.withDeadlineAfter(5, TimeUnit.SECONDS))
.endorseOptions(options -> options.withDeadlineAfter(15, TimeUnit.SECONDS))
.submitOptions(options -> options.withDeadlineAfter(5, TimeUnit.SECONDS))
.commitStatusOptions(options -> options.withDeadlineAfter(1, TimeUnit.MINUTES));
try (var gateway = builder.connect()) {
this.setContract(gateway);
} finally {
channel.shutdownNow().awaitTermination(5, TimeUnit.SECONDS);
}
}
private static ManagedChannel newGrpcConnection() throws IOException {
var credentials = TlsChannelCredentials.newBuilder()
.trustManager(TLS_CERT_PATH.toFile())
.build();
return Grpc.newChannelBuilder(PEER_ENDPOINT, credentials)
.overrideAuthority(OVERRIDE_AUTH)
.build();
}
private Identity newIdentity() throws IOException, CertificateException {
try (var certReader = Files.newBufferedReader(getFirstFilePath(CERT_DIR_PATH))) {
var certificate = Identities.readX509Certificate(certReader);
return new X509Identity(MSP_ID, certificate);
}
}
private Signer newSigner() throws IOException, InvalidKeyException {
try (var keyReader = Files.newBufferedReader(getFirstFilePath(KEY_DIR_PATH))) {
var privateKey = Identities.readPrivateKey(keyReader);
return Signers.newPrivateKeySigner(privateKey);
}
}
private void setContract(final Gateway gateway) {
// Get a network instance representing the channel where the smart contract is
// deployed.
var network = gateway.getNetwork(CHANNEL_NAME);
// Get the smart contract from the network.
contract = network.getContract(CHAINCODE_NAME);
}
private void initLedger() throws EndorseException, SubmitException, CommitStatusException, CommitException {
System.out.println("\n--> Submit Transaction: InitLedger, function creates the initial set of assets on the ledger");
contract.submitTransaction("InitLedger");
System.out.println("*** Transaction committed successfully");
}
public void crearReceta() {
System.out.println("\n--> Submit Transaction: CreateAsset, creates new asset with all arguments");
Receta receta = new Receta(
assetId,
"Tom",
"presc456",
"active",
LocalDateTime.now(),
"high",
"Medicine XYZ",
"Condition ABC",
"Take with food",
"30 days",
"1 pill per day",
"1 year",
"12345678",
LocalDate.now(),
30,
LocalDate.now()
);
try {
contract.submitTransaction(
"CreateAsset",
receta.getId(),
receta.getOwner(),
receta.getPrescripcionAnteriorId(),
receta.getStatus(),
receta.getStatusChange().toString(),
receta.getPrioridad(),
receta.getMedicacion(),
receta.getRazon(),
receta.getNotas(),
receta.getPeriodoDeTratamiento(),
receta.getInstruccionesTratamiento(),
receta.getPeriodoDeValidez(),
receta.getDniPaciente(),
receta.getFechaDeAutorizacion().toString(),
Integer.toString(receta.getCantidad()),
receta.getExpectedSupplyDuration().toString()
);
} catch (EndorseException e) {
e.printStackTrace();
} catch (SubmitException e) {
e.printStackTrace();
} catch (CommitStatusException e) {
e.printStackTrace();
} catch (CommitException e) {
e.printStackTrace();
}
System.out.println("*** Transaction committed successfully");
}
}

1
asset-transfer-basic/maven-example/src/test/java/com/code/main/MainApplicationTests.java
View file

@ -8,6 +8,7 @@ class MainApplicationTests {
@Test
void contextLoads() {
}
}