Wyrocznie

1pragma solidity ^0.6.7;
2
3import "@chainlink/contracts/src/v0.6/interfaces/AggregatorV3Interface.sol";
4
5contract PriceConsumerV3 {
6
7    AggregatorV3Interface internal priceFeed;
8
9    /**
10     * Sieć: Kovan
11     * Agregator: ETH/USD
12     * Adress: 0x9326BFA02ADD2366b30bacB125260Af641031331
13     */
14    constructor() public {
15        priceFeed = AggregatorV3Interface(0x9326BFA02ADD2366b30bacB125260Af641031331);
16    }
17
18    /**
19     * Zwraca ostatnią cenę
20     */
21    function getLatestPrice() public view returns (int) {
22        (
23            uint80 roundID,
24            int price,
25            uint startedAt,
26            uint timeStamp,
27            uint80 answeredInRound
28        ) = priceFeed.latestRoundData();
29        return price;
30    }
31}
32
Pokaż wszystko
 Kopiuj

1pragma solidity >=0.4.21 <0.6.0;
2
3contract Oracle {
4  Request[] requests; //lista żądań wprowadzonych do kontraktu
5  uint currentId = 0; //rosnący id żądania
6  uint minQuorum = 2; //minimalna liczba otrzymanych odpowiedzi przed zadeklarowaniem ostatecznego wyniku
7  uint totalOracleCount = 3; // liczba wyroczni osadzonych w kodzie źródłowym
8  // defines a general api request
9  struct Request {
10    uint id;                            // id żądania
11    string urlToQuery;                  //url API
12    string attributeToFetch;            //atrybut json (klucz) do pobrania w odpowiedzi
13    string agreedValue;                 //wartość z klucza
14    mapping(uint => string) anwers;     //odpowiedzi dostarczone przez wyrocznie
15    mapping(address => uint) quorum;    //wyrocznie, które będą odpytywać odpowiedź (1=wyrocznia nie głosowała, 2=wyrocznia głosowała)
16  }
17
18  //zdarzenie wyzwalające wyrocznię poza blockchainem
19  event NewRequest (
20    uint id,
21    string urlToQuery,
22    string attributeToFetch
23  );
24
25  //wyzwalane, jeśli jest konsensus co do końcowego wyniku
26  event UpdatedRequest (
27    uint id,
28    string urlToQuery,
29    string attributeToFetch,
30    string agreedValue
31  );
32
33  function createRequest (
34    string memory _urlToQuery,
35    string memory _attributeToFetch
36  )
37  public
38  {
39    uint lenght = requests.push(Request(currentId, _urlToQuery, _attributeToFetch, ""));
40    Request storage r = requests[lenght-1];
41
42    // osadzony adres wyroczni
43    r.quorum[address(0x6c2339b46F41a06f09CA0051ddAD54D1e582bA77)] = 1;
44    r.quorum[address(0xb5346CF224c02186606e5f89EACC21eC25398077)] = 1;
45    r.quorum[address(0xa2997F1CA363D11a0a35bB1Ac0Ff7849bc13e914)] = 1;
46
47    // uruchomienie zdarzenia do wykrycia poza blockchainem
48    emit NewRequest (
49      currentId,
50      _urlToQuery,
51      _attributeToFetch
52    );
53
54    // zwiększanie id żądania
55    currentId++;
56  }
57
58  //wywołane przez wyrocznię, aby zarejestrować jej odpowiedź
59  function updateRequest (
60    uint _id,
61    string memory _valueRetrieved
62  ) public {
63
64    Request storage currRequest = requests[_id];
65
66    //sprawdzenie, czy wyrocznia jest na liście zaufanych wyroczni
67    //i czy wyrocznia jeszcze nie głosowała
68    if(currRequest.quorum[address(msg.sender)] == 1){
69
70      //oznaczenie, że ten adres głosował
71      currRequest.quorum[msg.sender] = 2;
72
73      //iteracyjne przejście przez "tablicę" odpowiedzi do czasu uzyskania wolnej pozycji i zapisanie pobranej wartości
74      uint tmpI = 0;
75      bool found = false;
76      while(!found) {
77        //find first empty slot
78        if(bytes(currRequest.anwers[tmpI]).length == 0){
79          found = true;
80          currRequest.anwers[tmpI] = _valueRetrieved;
81        }
82        tmpI++;
83      }
84
85      uint currentQuorum = 0;
86
87      //iteracyjne przejście przez listę wyroczni i sprawdzenie, czy ich liczba jest wystarczająca(minimalne kworum)
88      //głosowały na tę samą odpowiedź jak bieżąca
89      for(uint i = 0; i < totalOracleCount; i++){
90        bytes memory a = bytes(currRequest.anwers[i]);
91        bytes memory b = bytes(_valueRetrieved);
92
93        if(keccak256(a) == keccak256(b)){
94          currentQuorum++;
95          if(currentQuorum >= minQuorum){
96            currRequest.agreedValue = _valueRetrieved;
97            emit UpdatedRequest (
98              currRequest.id,
99              currRequest.urlToQuery,
100              currRequest.attributeToFetch,
101              currRequest.agreedValue
102            );
103          }
104        }
105      }
106    }
107  }
108}
109
Pokaż wszystko
 Kopiuj