Improve logging

.github/workflows/attestor-ci.yml

@@ -0,0 +1,51 @@
+name: Attestor CI
+
+on:
+  push:
+    paths:
+      - 'services/attestor/**'
+      - '.github/workflows/attestor-ci.yml'
+  pull_request:
+    paths:
+      - 'services/attestor/**'
+      - '.github/workflows/attestor-ci.yml'
+
+permissions:
+  contents: read
+
+jobs:
+  attestor:
+    name: Lint / Vet / Test
+    runs-on: ubuntu-latest
+    defaults:
+      run:
+        shell: bash
+        working-directory: services/attestor
+    env:
+      GOFLAGS: -mod=readonly
+    steps:
+      - name: Check out repository
+        uses: actions/checkout@v4
+
+      - name: Set up Go
+        uses: actions/setup-go@v5
+        with:
+          go-version-file: services/attestor/go.mod
+          cache: true
+
+      - name: Download dependencies
+        run: go mod download
+
+      - name: Lint (gofmt)
+        run: |
+          fmt_out=$(gofmt -l .)
+          if [[ -n "$fmt_out" ]]; then
+            echo "The following files need gofmt:" && echo "$fmt_out"
+            exit 1
+          fi
+
+      - name: Vet
+        run: go vet ./...
+
+      - name: Test
+        run: go test ./...

.github/workflows/bridge-ci.yml

@@ -0,0 +1,51 @@
+name: Bridge CI
+
+on:
+  push:
+    paths:
+      - 'services/bridge/**'
+      - '.github/workflows/bridge-ci.yml'
+  pull_request:
+    paths:
+      - 'services/bridge/**'
+      - '.github/workflows/bridge-ci.yml'
+
+permissions:
+  contents: read
+
+jobs:
+  bridge:
+    name: Lint / Vet / Test
+    runs-on: ubuntu-latest
+    defaults:
+      run:
+        shell: bash
+        working-directory: services/bridge
+    env:
+      GOFLAGS: -mod=readonly
+    steps:
+      - name: Check out repository
+        uses: actions/checkout@v4
+
+      - name: Set up Go
+        uses: actions/setup-go@v5
+        with:
+          go-version-file: services/bridge/go.mod
+          cache: true
+
+      - name: Download dependencies
+        run: go mod download
+
+      - name: Lint (gofmt)
+        run: |
+          fmt_out=$(gofmt -l .)
+          if [[ -n "$fmt_out" ]]; then
+            echo "The following files need gofmt:" && echo "$fmt_out"
+            exit 1
+          fi
+
+      - name: Vet
+        run: go vet ./...
+
+      - name: Test
+        run: go test ./...

.gitmodules

@@ -1,3 +1,9 @@
 [submodule "contracts/lib/forge-std"]
 	path = contracts/lib/forge-std
 	url = https://github.com/foundry-rs/forge-std
+[submodule "contracts/lib/openzeppelin-contracts"]
+	path = contracts/lib/openzeppelin-contracts
+	url = https://github.com/OpenZeppelin/openzeppelin-contracts
+[submodule "contracts/tools/forge-wrapper/config-private"]
+	path = contracts/tools/forge-wrapper/config-private
+	url = git@github.com:diadata-org/spectra-deployment-configs.git

contracts/.solhint.json

@@ -1,7 +1,8 @@
 {
     "extends": "solhint:recommended",
     "rules": {
-      "no-global-import": "off"
+      "no-global-import": "off",
+      "func-visibility": ["error", {"ignoreConstructors": true}]
     }
   }
 

contracts/contracts/DIAOracleV2.sol

@@ -0,0 +1,87 @@
+// SPDX-License-Identifier: GPL-3.0
+pragma solidity 0.8.29;
+
+import {AccessControl} from "@openzeppelin/contracts/access/AccessControl.sol";
+
+interface IDIAOracleV2 {
+    function setValue(string memory key, uint128 value, uint128 timestamp) external;
+    function getValue(string memory key) external view returns (uint128, uint128);
+    function setMultipleValues(string[] memory keys, uint256[] memory compressedValues) external;
+}
+
+/**
+ * @title DIAOracleV2
+ * @dev A simple oracle contract that allows an authorized updater to set and retrieve price values with timestamps.
+ */
+contract DIAOracleV2 is IDIAOracleV2, AccessControl {
+    bytes32 public constant UPDATER_ROLE = keccak256("UPDATER_ROLE");
+
+    /// @notice Mapping to store compressed values of assets (price and timestamp).
+    /// @dev The stored value is a 256-bit integer where the upper 128 bits store the price and the lower 128 bits store the timestamp.
+    mapping (string => uint256) public values;
+
+    event OracleUpdate(string key, uint128 value, uint128 timestamp);
+    event UpdaterAddressChange(address newUpdater);
+
+    constructor()  {
+        _grantRole(DEFAULT_ADMIN_ROLE, msg.sender);
+        _grantRole(UPDATER_ROLE, msg.sender);
+    }
+
+    error MismatchedArrayLengths(uint256 keysLength, uint256 valuesLength);
+
+
+
+     /**
+     * @notice Updates the price and timestamp for a given asset key.
+     * @dev Only callable by the `oracleUpdater`.
+     * @param key The asset identifier (e.g., "BTC/USD").
+     * @param value The price value to set.
+     * @param timestamp The timestamp associated with the value.
+     */
+    function setValue(string memory key, uint128 value, uint128 timestamp) public onlyRole(UPDATER_ROLE) {
+         uint256 cValue = (((uint256)(value)) << 128) + timestamp;
+        values[key] = cValue;
+        emit OracleUpdate(key, value, timestamp);
+    }
+
+    /**
+     * @notice Updates multiple asset values in a single transaction.
+     * @dev Each entry in `compressedValues` should be a 256-bit integer where:
+     *      - The upper 128 bits represent the price value.
+     *      - The lower 128 bits represent the timestamp.
+     * @param keys The array of asset identifiers.
+     * @param compressedValues The array of compressed values (price and timestamp combined).
+     */
+
+    function setMultipleValues(string[] memory keys, uint256[] memory compressedValues) public  onlyRole(UPDATER_ROLE){
+ if (keys.length != compressedValues.length) {
+        revert MismatchedArrayLengths(keys.length, compressedValues.length);
+    }
+        for (uint128 i = 0; i < keys.length; i++) {
+            string memory currentKey = keys[i];
+            uint256 currentCvalue = compressedValues[i];
+            uint128 value = (uint128)(currentCvalue >> 128);
+            uint128 timestamp = (uint128)(currentCvalue % 2**128);
+
+            values[currentKey] = currentCvalue;
+            emit OracleUpdate(currentKey, value, timestamp);
+        }
+    }
+
+    /**
+     * @notice Retrieves the price and timestamp for a given asset key.
+     * @param key The asset identifier (e.g., "BTC/USD").
+     * @return value The stored price value.
+     * @return timestamp The stored timestamp.
+     */
+    function getValue(string memory key) external view returns (uint128, uint128) {
+        uint256 cValue = values[key];
+        uint128 timestamp = (uint128)(cValue % 2**128);
+        uint128 value = (uint128)(cValue >> 128);
+        return (value, timestamp);
+    }
+
+
+
+}