src/dlt/gateway/chaincode/chaincode.go

+//  Copyright 2022-2024 ETSI OSG/SDG TeraFlowSDN (TFS) (https://tfs.etsi.org/)
+
+//  Licensed under the Apache License, Version 2.0 (the "License");
+//  you may not use this file except in compliance with the License.
+//  You may obtain a copy of the License at
+
+//       http://www.apache.org/licenses/LICENSE-2.0
+
+//  Unless required by applicable law or agreed to in writing, software
+//  distributed under the License is distributed on an "AS IS" BASIS,
+//  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//  See the License for the specific language governing permissions and
+//  limitations under the License.
+
+package main
+
+import (
+	"crypto/sha256"
+	"encoding/hex"
+	"encoding/json"
+	"fmt"
+	"log"
+
+	"github.com/hyperledger/fabric-contract-api-go/contractapi"
+)
+
+// Protobuf definitions
+type Uuid struct {
+	Uuid string `json:"uuid"`
+}
+
+type DltRecordId struct {
+	DomainUuid Uuid   `json:"domain_uuid"`
+	Type       string `json:"type"`
+	RecordUuid Uuid   `json:"record_uuid"`
+}
+
+type DltRecord struct {
+	RecordId DltRecordId `json:"record_id"`
+	DataJson string      `json:"data_json"`
+}
+
+type SmartContract struct {
+	contractapi.Contract
+}
+
+// InitLedger activates the chaincode
+func (s *SmartContract) InitLedger(ctx contractapi.TransactionContextInterface) error {
+	return nil
+}
+
+func (s *SmartContract) StoreRecord(ctx contractapi.TransactionContextInterface, recordId DltRecordId, dataJson string) error {
+
+	key, err := createHashKey(recordId)
+	if err != nil {
+		return fmt.Errorf("failed to create hash key: %v", err)
+	}
+
+	// Check if the same record does not exist before adding it to the ledger
+	exists, err := s.RecordExists(ctx, key)
+	if err == nil && exists != nil {
+		return fmt.Errorf("the record %s already exists", key)
+	}
+
+	// Trigger an event if the transaction is successful
+	storedRecord := DltRecord{
+		RecordId: recordId,
+		DataJson: dataJson,
+	}
+	eventJson, err := json.Marshal(storedRecord)
+	if err != nil {
+		return fmt.Errorf("failed to marshal stored record: %v", err)
+	}
+	ctx.GetStub().SetEvent("StoreRecord", eventJson)
+
+	// Store the record in the ledger
+	return ctx.GetStub().PutState(key, []byte(dataJson))
+}
+
+func (s *SmartContract) RetrieveRecord(ctx contractapi.TransactionContextInterface, recordId DltRecordId) (string, error) {
+	key, err := createHashKey(recordId)
+	if err != nil {
+		return "", fmt.Errorf("failed to create hash key: %v", err)
+	}
+
+	// Get the record from the ledger
+	dataBytes, err := ctx.GetStub().GetState(key)
+	if err != nil || dataBytes == nil {
+		return "", fmt.Errorf("data not found for key %s", key)
+	}
+	return string(dataBytes), nil
+}
+
+func (s *SmartContract) UpdateRecord(ctx contractapi.TransactionContextInterface, recordId DltRecordId, dataJson string) error {
+	key, err := createHashKey(recordId)
+	if err != nil {
+		return fmt.Errorf("failed to create hash key: %v", err)
+	}
+
+	// Check if the record exists before updating it
+	_, err = s.RecordExists(ctx, key)
+	if err != nil {
+		return err
+	}
+
+	// Trigger an event if the transaction is successful
+	eventData := DltRecord{RecordId: recordId, DataJson: dataJson}
+	eventJson, err := json.Marshal(eventData)
+	if err != nil {
+		return fmt.Errorf("failed to marshal event data: %v", err)
+	}
+	ctx.GetStub().SetEvent("UpdateRecord", eventJson)
+
+	// Update the record in the ledger
+	return ctx.GetStub().PutState(key, []byte(dataJson))
+}
+
+func (s *SmartContract) DeleteRecord(ctx contractapi.TransactionContextInterface, recordId DltRecordId) error {
+	key, err := createHashKey(recordId)
+	if err != nil {
+		return fmt.Errorf("failed to create hash key: %v", err)
+	}
+
+	// Check if the record exists before deleting it
+	exists, err := s.RecordExists(ctx, key)
+	if err != nil {
+		return err
+	}
+
+	// Trigger an event if the transaction is successful
+	eventData := DltRecord{RecordId: recordId, DataJson: string(exists)}
+	eventJson, err := json.Marshal(eventData)
+	if err != nil {
+		return fmt.Errorf("failed to marshal event data: %v", err)
+	}
+	ctx.GetStub().SetEvent("DeleteRecord", eventJson)
+
+	// Delete the record from the ledger
+	return ctx.GetStub().DelState(key)
+}
+
+func (s *SmartContract) RecordExists(ctx contractapi.TransactionContextInterface, key string) ([]byte, error) {
+	jsonData, err := ctx.GetStub().GetState(key)
+	if err != nil {
+		return nil, fmt.Errorf("failed to read from world state: %v", err)
+	}
+	if jsonData == nil {
+		return nil, fmt.Errorf("the record %s does not exist", key)
+	}
+	return jsonData, nil
+}
+
+func (s *SmartContract) GetAllRecords(ctx contractapi.TransactionContextInterface) ([]map[string]interface{}, error) {
+	// Range query with empty string for startKey and endKey does an
+	// open-ended query of all records in the chaincode namespace.
+	resultsIterator, err := ctx.GetStub().GetStateByRange("", "")
+	if err != nil {
+		return nil, err
+	}
+	defer resultsIterator.Close()
+
+	var records []map[string]interface{}
+	for resultsIterator.HasNext() {
+		queryResponse, err := resultsIterator.Next()
+		if err != nil {
+			return nil, err
+		}
+
+		var generic map[string]interface{}
+		if err := json.Unmarshal(queryResponse.Value, &generic); err != nil {
+			return nil, fmt.Errorf("invalid JSON data: %v", err)
+		}
+
+		records = append(records, generic)
+	}
+
+	return records, nil
+}
+
+func createHashKey(recordId DltRecordId) (string, error) {
+	recordIdJson, err := json.Marshal(recordId)
+	if err != nil {
+		return "", fmt.Errorf("failed to marshal record ID: %v", err)
+	}
+
+	hash := sha256.New()
+	hash.Write(recordIdJson)
+	return hex.EncodeToString(hash.Sum(nil)), nil
+}
+
+func main() {
+	recordChaincode, err := contractapi.NewChaincode(&SmartContract{})
+	if err != nil {
+		log.Panicf("Error creating chaincode: %v", err)
+	}
+
+	if err := recordChaincode.Start(); err != nil {
+		log.Panicf("Error starting chaincode: %v", err)
+	}
+}

src/dlt/gateway/chaincode/go.mod

+<!--   Copyright 2022-2024 ETSI OSG/SDG TeraFlowSDN (TFS) (https://tfs.etsi.org/)
+
+  Licensed under the Apache License, Version 2.0 (the "License");
+  you may not use this file except in compliance with the License.
+  You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+  Unless required by applicable law or agreed to in writing, software
+  distributed under the License is distributed on an "AS IS" BASIS,
+  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  See the License for the specific language governing permissions and
+  limitations under the License. -->
+
+module chaincode
+
+go 1.17
+
+require github.com/hyperledger/fabric-contract-api-go v1.2.1
+
+require (
+	github.com/go-openapi/jsonpointer v0.19.5 // indirect
+	github.com/go-openapi/jsonreference v0.20.0 // indirect
+	github.com/go-openapi/spec v0.20.8 // indirect
+	github.com/go-openapi/swag v0.21.1 // indirect
+	github.com/gobuffalo/envy v1.10.1 // indirect
+	github.com/gobuffalo/packd v1.0.1 // indirect
+	github.com/gobuffalo/packr v1.30.1 // indirect
+	github.com/golang/protobuf v1.5.2 // indirect
+	github.com/hyperledger/fabric-chaincode-go v0.0.0-20230228194215-b84622ba6a7a // indirect
+	github.com/hyperledger/fabric-protos-go v0.3.0 // indirect
+	github.com/joho/godotenv v1.4.0 // indirect
+	github.com/josharian/intern v1.0.0 // indirect
+	github.com/mailru/easyjson v0.7.7 // indirect
+	github.com/rogpeppe/go-internal v1.8.1 // indirect
+	github.com/xeipuuv/gojsonpointer v0.0.0-20190905194746-02993c407bfb // indirect
+	github.com/xeipuuv/gojsonreference v0.0.0-20180127040603-bd5ef7bd5415 // indirect
+	github.com/xeipuuv/gojsonschema v1.2.0 // indirect
+	golang.org/x/net v0.7.0 // indirect
+	golang.org/x/sys v0.5.0 // indirect
+	golang.org/x/text v0.7.0 // indirect
+	google.golang.org/genproto v0.0.0-20230110181048-76db0878b65f // indirect
+	google.golang.org/grpc v1.53.0 // indirect
+	google.golang.org/protobuf v1.28.1 // indirect
+	gopkg.in/yaml.v2 v2.4.0 // indirect
+)