refactor RiskId (#824)

contracts/examples/crop/CropProduct.sol

@@ -195,7 +195,6 @@ contract CropProduct is
         if (seasonEndAt < TimestampLib.current()) { revert ErrorInvalidSeasonEndAt(seasonEndAt); }
 
         // create risk, if new
-        bytes32 riskKey = keccak256(abi.encode(id));
         CropRisk memory cropRisk = CropRisk({
             seasonId: seasonId,
             locationId: locationId,
@@ -205,7 +204,7 @@ contract CropProduct is
             payoutDefined: false
         });
 
-        riskId = _createRisk(riskKey, abi.encode(cropRisk));
+        riskId = _createRisk(abi.encode(cropRisk));
         _riskId[id] = riskId;
     }
 

contracts/examples/fire/FireProduct.sol

@@ -248,7 +248,7 @@ contract FireProduct is
             return _riskMapping[cityName];
         }
         _cities.push(cityName);
-        risk = _createRisk(bytes32(abi.encodePacked(cityName)), "");
+        risk = _createRisk("");
         _riskMapping[cityName] = risk;
     }
 

contracts/examples/flight/FlightLib.sol

@@ -243,8 +243,6 @@ library FlightLib {
 
 
     function getFlightRisk(
-        InstanceReader reader,
-        NftId productNftId, 
         Str flightData,
         Timestamp departureTime, 
         string memory departureTimeLocal,
@@ -254,28 +252,20 @@ library FlightLib {
         public
         view
         returns (
-            RiskId riskId,
-            bool exists,
             FlightProduct.FlightRisk memory flightRisk
         )
     {
-        riskId = getRiskId(productNftId, flightData);
-        (exists, flightRisk) = getFlightRisk(reader, productNftId, riskId, false);
-
-        // create new risk if not existing
-        if (!exists) {
-            flightRisk = FlightProduct.FlightRisk({
-                flightData: flightData,
-                departureTime: departureTime,
-                departureTimeLocal: departureTimeLocal,
-                arrivalTime: arrivalTime,
-                arrivalTimeLocal: arrivalTimeLocal,
-                sumOfSumInsuredAmounts: AmountLib.toAmount(0),
-                status: bytes1(0),
-                delayMinutes: 0,
-                payoutOption: uint8(0),
-                statusUpdatedAt: TimestampLib.zero()});
-        }
+        flightRisk = FlightProduct.FlightRisk({
+            flightData: flightData,
+            departureTime: departureTime,
+            departureTimeLocal: departureTimeLocal,
+            arrivalTime: arrivalTime,
+            arrivalTimeLocal: arrivalTimeLocal,
+            sumOfSumInsuredAmounts: AmountLib.toAmount(0),
+            status: bytes1(0),
+            delayMinutes: 0,
+            payoutOption: uint8(0),
+            statusUpdatedAt: TimestampLib.zero()});
     }
 
 
@@ -306,20 +296,6 @@ library FlightLib {
         }
     }
 
-
-    function getRiskId(
-        NftId productNftId,
-        Str flightData
-    )
-        public
-        view 
-        returns (RiskId riskId)
-    {
-        bytes32 riskKey = getRiskKey(flightData);
-        riskId = getRiskId(productNftId, riskKey);
-    }
-
-
     function getRiskKey(
         Str flightData
     )
@@ -330,8 +306,4 @@ library FlightLib {
         return keccak256(abi.encode(flightData));
     }
 
-
-    function getRiskId(NftId productNftId, bytes32 riskKey) internal view returns (RiskId riskId) {
-        return RiskIdLib.toRiskId(productNftId, riskKey);
-    }
 }

contracts/examples/flight/FlightProduct.sol

@@ -67,6 +67,7 @@ contract FlightProduct is
     bool internal _testMode;
 
     mapping(RiskId riskId => RequestId requestId) internal _requests;
+    mapping(bytes32 encodedRisk => RiskId) internal _risks;
 
     // GIF V3 specifics
     NftId internal _defaultBundleNftId;
@@ -507,20 +508,22 @@ contract FlightProduct is
         returns (RiskId riskId)
     {
         bool exists;
-        FlightRisk memory flightRisk;
-        (riskId, exists, flightRisk) = FlightLib.getFlightRisk(
-            _getInstanceReader(), 
-            getNftId(), 
+        FlightRisk memory flightRisk = FlightLib.getFlightRisk(
             flightData, 
             departureTime, 
             departureTimeLocal,
             arrivalTime,
             arrivalTimeLocal);
 
+        bytes32 riskKey = FlightLib.getRiskKey(flightData);
+        exists = _risks[riskKey].gtz();
+
         // create risk, if new
         if (!exists) {
-            bytes32 riskKey = FlightLib.getRiskKey(flightData);
-            _createRisk(riskKey, abi.encode(flightRisk));
+            riskId = _createRisk(abi.encode(flightRisk));
+            _risks[riskKey] = riskId;
+        } else {
+            riskId = _risks[riskKey];
         }
 
         FlightLib.checkClusterRisk(

contracts/examples/unpermissioned/SimpleProduct.sol

@@ -81,13 +81,9 @@ contract SimpleProduct is
 
 
     function createRisk(
-        string memory id,
         bytes memory data
     ) public returns (RiskId) {
-        return _createRisk(
-            bytes32(abi.encodePacked(id)),
-            data
-        );
+        return _createRisk(data);
     }
 
     function updateRisk(

contracts/instance/ProductStore.sol

@@ -113,7 +113,8 @@ contract ProductStore is
     }
 
     //--- Risk --------------------------------------------------------------//
-    function createRisk(RiskId riskId, IRisk.RiskInfo memory info) external restricted() {
+    function createRisk(IRisk.RiskInfo memory info) external restricted() returns (RiskId riskId) {
+        riskId = _createNextRiskId();
         Key32 key = riskId.toKey32();
         _createMetadata(key);
         _risks[key] = info;

contracts/instance/base/ObjectCounter.sol

@@ -1,20 +1,22 @@
 // SPDX-License-Identifier: Apache-2.0
 pragma solidity ^0.8.20;
 
-import {Blocknumber, BlocknumberLib} from "../../type/Blocknumber.sol";
 import {NftId} from "../../type/NftId.sol";
-import {Amount} from "../../type/Amount.sol";
 import {RequestId, RequestIdLib} from "../../type/RequestId.sol";
+import {RiskId, RiskIdLib} from "../../type/RiskId.sol";
 
 contract ObjectCounter {
 
-    // TODO refactor risk id
-    // mapping(NftId productNftId => uint64 risks) private _riskCounter;
-
+    uint64 private _riskCounter = 0;
     uint256 private _requestCounter = 0;
 
     function _createNextRequestId() internal returns (RequestId requestId) {
         _requestCounter++;
         requestId = RequestIdLib.toRequestId(_requestCounter);
     }
+
+    function _createNextRiskId() internal returns (RiskId riskId) {
+        _riskCounter++;
+        riskId = RiskIdLib.toRiskId(_riskCounter);
+    }
 }

contracts/product/IRiskService.sol

@@ -23,7 +23,6 @@ interface IRiskService is IService {
     /// The key of the risk derived from the risk id in comination with the product NftId. 
     /// Risk data is stored in the instance store. 
     function createRisk(
-        bytes32 id,
         bytes memory data
     ) external returns (RiskId riskId);
 

contracts/product/Product.sol

@@ -181,17 +181,13 @@ abstract contract Product is
 
 
     function _createRisk(
-        bytes32 id,
         bytes memory data
     )
         internal
         virtual
         returns (RiskId riskId)
     {
-        return _getProductStorage()._riskService.createRisk(
-            id,
-            data
-        );
+        return _getProductStorage()._riskService.createRisk(data);
     }
 
     function _updateRisk(

contracts/product/RiskService.sol

@@ -40,7 +40,6 @@ contract RiskService is
 
     /// @inheritdoc IRiskService
     function createRisk(
-        bytes32 id,
         bytes memory data
     )
         external 
@@ -52,16 +51,12 @@ contract RiskService is
         (NftId productNftId, IInstance instance) = _getAndVerifyActiveComponent(PRODUCT());
 
         // effects
-        riskId = RiskIdLib.toRiskId(productNftId, id);
         IRisk.RiskInfo memory riskInfo = IRisk.RiskInfo({
             productNftId: productNftId, 
             createdAt: TimestampLib.current(),
             data: data});
 
-        instance.getProductStore().createRisk(
-            riskId,
-            riskInfo
-        );
+        riskId = instance.getProductStore().createRisk(riskInfo);
 
         // add risk to RiskSet
         RiskSet riskSet = instance.getRiskSet();

contracts/type/RiskId.sol

@@ -2,10 +2,9 @@
 pragma solidity ^0.8.20;
 
 import {Key32, KeyId, Key32Lib} from "./Key32.sol";
-import {NftId} from "./NftId.sol";
 import {RISK} from "./ObjectType.sol";
 
-type RiskId is bytes8;
+type RiskId is uint64;
 
 // type bindings
 using {
@@ -33,7 +32,7 @@ function neRiskId(RiskId a, RiskId b) pure returns (bool isDifferent) {
 
 library RiskIdLib {
     function zero() public pure returns (RiskId) {
-        return RiskId.wrap(bytes8(0));
+        return RiskId.wrap(uint64(0));
     }
 
     // @dev Converts a risk id into a uint256.
@@ -42,8 +41,8 @@ library RiskIdLib {
     }
 
     // @dev Converts a risk id string with a product NftId into a risk id.
-    function toRiskId(NftId productNftId, bytes32 risk) public pure returns (RiskId) {
-        return RiskId.wrap(bytes8(keccak256(abi.encode(productNftId, risk))));
+    function toRiskId(uint256 id) public pure returns (RiskId) {
+        return RiskId.wrap(uint64(id));
     }
 
     /// @dev Returns the key32 value for the specified risk id.
@@ -53,12 +52,13 @@ library RiskIdLib {
 
     /// @dev Returns the key id value for the specified nft id
     function toKeyId(RiskId id) public pure returns (KeyId keyId) {
-        return KeyId.wrap(bytes31(RiskId.unwrap(id)));
+        return KeyId.wrap(bytes31(uint248(RiskId.unwrap(id))));
     }
 
     function toRiskId(KeyId keyId) public pure returns (RiskId riskId) {
-        riskId = RiskId.wrap(bytes8(KeyId.unwrap(keyId)));
-        assert(toInt(riskId) < 2**64);
+        uint248 keyIdInt = uint248(bytes31(KeyId.unwrap(keyId)));
+        assert(keyIdInt < type(uint64).max);
+        return RiskId.wrap(uint64(keyIdInt));
     }
 
     function eq(RiskId a, RiskId b) public pure returns (bool isSame) {

scripts/deploy_flightdelay_components.ts

@@ -142,7 +142,6 @@ export async function deployFlightDelayComponentContracts(libraries: LibraryAddr
         {
             libraries: {
                 AmountLib: amountLibAddress,
-                RiskIdLib: riskIdLibAddress,
                 TimestampLib: timestampLibAddress,
             }
         });
@@ -188,6 +187,7 @@ export async function deployFlightDelayComponentContracts(libraries: LibraryAddr
                 ObjectTypeLib: objectTypeLibAddress,
                 ReferralLib: referralLibAddress,
                 RequestIdLib: requestIdLibAddress,
+                RiskIdLib: riskIdLibAddress,
                 SecondsLib: secondsLibAddress,
                 StrLib: strLibAddress,
                 TimestampLib: timestampLibAddress,

scripts/libs/services.ts

@@ -410,7 +410,6 @@ export async function deployAndRegisterServices(owner: Signer, registry: Registr
             ContractLib: libraries.contractLibAddress,
             BlocknumberLib: libraries.blockNumberLibAddress,
             NftIdLib: libraries.nftIdLibAddress,
-            RiskIdLib: libraries.riskIdLibAddress,
             RoleIdLib: libraries.roleIdLibAddress,
             TimestampLib: libraries.timestampLibAddress,
             VersionLib: libraries.versionLibAddress, 

test/TestBundle.t.sol

@@ -1098,7 +1098,7 @@ contract TestBundle is GifTest {
 
     function _createRisk(string memory riskIdStr) internal returns (RiskId riskId) {
         vm.startPrank(productOwner);
-        riskId = product.createRisk(riskIdStr, "");
+        riskId = product.createRisk("");
         vm.stopPrank();
     }
 

test/TestFees.t.sol

@@ -701,7 +701,7 @@ contract TestFees is GifTest {
             FeeLib.zero());
 
         bytes memory data = "bla di blubb";
-        RiskId riskId = product.createRisk("42x4711", data);
+        RiskId riskId = product.createRisk(data);
         vm.stopPrank();
 
         if (purchaseWithReferral) {

test/component/distribution/Referral.t.sol

@@ -89,7 +89,7 @@ contract ReferralTest is ReferralTestBase {
         // create risk
         vm.startPrank(productOwner);
         bytes memory data = "bla di blubb";
-        RiskId riskId = product.createRisk("42x4711", data);
+        RiskId riskId = product.createRisk(data);
         vm.stopPrank();
 
         vm.startPrank(customer);
@@ -187,7 +187,7 @@ contract ReferralTest is ReferralTestBase {
 
         vm.startPrank(productOwner);
         bytes memory data = "bla di blubb";
-        RiskId riskId = product.createRisk("42x4711", data);
+        RiskId riskId = product.createRisk(data);
         vm.stopPrank();
 
         vm.startPrank(customer);

test/component/product/PolicyServiceLib.t.sol

@@ -33,7 +33,7 @@ contract PolicyServiceLibTest is GifTest {
 
         // create test specific risk
         bytes memory data = "bla di blubb";
-        RiskId riskId = product.createRisk("42x4711", data);
+        RiskId riskId = product.createRisk(data);
 
         // crete application
         uint256 sumInsuredAmount = 1000;
@@ -97,7 +97,7 @@ contract PolicyServiceLibTest is GifTest {
 
         // create test specific risk
         bytes memory data = "bla di blubb";
-        RiskId riskId = product.createRisk("42x4711", data);
+        RiskId riskId = product.createRisk(data);
 
         // crete application
         uint256 sumInsuredAmount = 1000;
@@ -150,7 +150,7 @@ contract PolicyServiceLibTest is GifTest {
 
         // create test specific risk
         bytes memory data = "bla di blubb";
-        RiskId riskId = product.createRisk("42x4711", data);
+        RiskId riskId = product.createRisk(data);
 
         // crete application
         uint256 sumInsuredAmount = 1000;