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

PDCs to be tested in OSC-Test Network

Browse source
This commit is contained in:
Fernando Garzon 2023-02-24 10:33:08 -08:00
parent 4aa12017bf
commit dc1deb4bc9
1 changed files with 36 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

38
asset-transfer-private-data/chaincode-go/chaincode/asset_transfer.go
View file

@ -883,7 +883,6 @@ func (s *SmartContract) WriteSchemaToPDC(ctx contractapi.TransactionContextInter
return fmt.Errorf("CreateSchema cannot be performed: Error %v", err) return fmt.Errorf("CreateSchema cannot be performed: Error %v", err)
} }
// Make submitting client the owner
Schema := PrivateSchemaContent{ Schema := PrivateSchemaContent{
JsonSchemaContent: jsonFileContent, JsonSchemaContent: jsonFileContent,
SchemaId: assetInput.SchemaId, SchemaId: assetInput.SchemaId,
@ -1003,10 +1002,43 @@ func (s *SmartContract) writeProjectToPDC(ctx contractapi.TransactionContextInte
if err != nil { if err != nil {
return fmt.Errorf("failed to get Project: %v", err) return fmt.Errorf("failed to get Project: %v", err)
} else if assetAsBytes != nil { } else if assetAsBytes != nil {
fmt.Println("Project already exists: " + assetInput.SchemaId) fmt.Println("Project already exists: " + assetInput.ProjectID)
return fmt.Errorf("this Project already exists: " + assetInput.SchemaId) return fmt.Errorf("this Project already exists: " + assetInput.ProjectID)
} }
// Get ID of submitting client identity
clientID, err := submittingClientIdentity(ctx)
if err != nil {
return err
}
// Verify that the client is submitting request to peer in their organization
// This is to ensure that a client from another org doesn't attempt to read or
// write private data from this peer.
err = verifyClientOrgMatchesPeerOrg(ctx)
if err != nil {
return fmt.Errorf("CreateSchema cannot be performed: Error %v", err)
}
Project := PrivateProjectsContent{
OrgName: assetInput.OrgName,
ProjectName: assetInput.ProjectName,
//AdminGroup: ,
//UsersGroup: ,
ProjectID: assetInput.ProjectID,
}
assetJSONasBytes, err := json.Marshal(Project)
if err != nil {
return fmt.Errorf("failed to marshal Schema into JSON: %v", err)
}
log.Printf("WriteProjectToPDC Put: collection %v, ID %v, owner %v", PDC2, assetInput.ProjectID, clientID)
err = ctx.GetStub().PutPrivateData(PDC2, assetInput.ProjectID, assetJSONasBytes)
if err != nil {
return fmt.Errorf("failed to put asset into private data collection: %v", err)
}
return nil
} }