mirror of
https://github.com/status-im/github-oracle.git
synced 2026-08-27 09:51:10 +00:00
RegisterEth integration
This commit is contained in:
Ricardo Guilherme Schmidt
@@ -0,0 +1,214 @@
|
||||
//Author: Ricardo Guilherme Schmidt <3esmit@gmail.com>
|
||||
pragma solidity ^0.4.11;
|
||||
|
||||
import "lib/oraclize/oraclizeAPI_0.4.sol";
|
||||
import "lib/ethereans/management/Owned.sol";
|
||||
|
||||
contract GitHubRegisterEth is Owned, usingOraclize{
|
||||
string private credentials = "";
|
||||
string [] metadata = new string[](0);
|
||||
mapping (bytes32 => UserClaim) userClaim; //temporary db for oraclize user register queries
|
||||
mapping (bytes32 => uint256) indexes;
|
||||
mapping (uint256 => User) users;
|
||||
|
||||
event RegisterUpdated(string name);
|
||||
event newMetaTag(uint size, string tag);
|
||||
|
||||
//stores temporary data for oraclize user register request
|
||||
struct UserClaim {
|
||||
address sender;
|
||||
string githubid;
|
||||
}
|
||||
|
||||
struct User {
|
||||
address addr;
|
||||
string login;
|
||||
mapping (bytes4 => string) meta;
|
||||
}
|
||||
|
||||
function GitHubRegisterEth(){
|
||||
oraclize_setProof(proofType_TLSNotary | proofStorage_IPFS);
|
||||
}
|
||||
|
||||
function register(string _github_user, string _gistid) payable {
|
||||
bytes32 ocid = oraclize_query("nested", _getQuery(_github_user, _gistid));
|
||||
userClaim[ocid] = UserClaim({sender: msg.sender, githubid: _github_user});
|
||||
}
|
||||
|
||||
function getAddr(uint256 _id) public constant returns(address addr) {
|
||||
return users[_id].addr;
|
||||
}
|
||||
|
||||
function getMeta(uint256 _id, string key) public constant returns(string data){
|
||||
return users[_id].meta[bytes4(sha3(key))];
|
||||
}
|
||||
|
||||
function getName(address _addr) public constant returns(string name){
|
||||
return users[indexes[sha3(_addr)]].login;
|
||||
}
|
||||
|
||||
function getMeta(address _addr, string key) public constant returns(string data){
|
||||
return users[indexes[sha3(_addr)]].meta[bytes4(sha3(key))];
|
||||
}
|
||||
|
||||
function getAddr(string _name) public constant returns(address addr) {
|
||||
return users[indexes[sha3(_name)]].addr;
|
||||
}
|
||||
|
||||
function getMeta(string _name, string key) public constant returns(string data){
|
||||
return users[indexes[sha3(_name)]].meta[bytes4(sha3(key))];
|
||||
}
|
||||
|
||||
event OracleEvent(bytes32 myid, string result, bytes proof);
|
||||
|
||||
//oraclize response callback
|
||||
function __callback(bytes32 myid, string result, bytes proof) {
|
||||
OracleEvent(myid,result,proof);
|
||||
if (msg.sender != oraclize.cbAddress()){
|
||||
throw;
|
||||
}else {
|
||||
_register(myid, result);
|
||||
}
|
||||
}
|
||||
|
||||
function _register(bytes32 myid, string result) internal {
|
||||
bytes memory v = bytes(result);
|
||||
uint8 pos = 0;
|
||||
address addrLoaded;
|
||||
string memory login;
|
||||
uint256 userId;
|
||||
(addrLoaded,pos) = getNextAddr(v,pos);
|
||||
(login,pos) = getNextString(v,pos);
|
||||
(userId,pos) = getNextUInt(v,pos);
|
||||
if(userClaim[myid].sender == addrLoaded && sha3(userClaim[myid].githubid) == sha3(login)){
|
||||
RegisterUpdated(login);
|
||||
if(users[userId].addr != 0x0){
|
||||
delete indexes[sha3(users[userId].login)];
|
||||
delete indexes[sha3(users[userId].addr)];
|
||||
}
|
||||
indexes[sha3(addrLoaded)] = userId;
|
||||
indexes[sha3(login)] = userId;
|
||||
users[userId].addr = addrLoaded;
|
||||
users[userId].login = login;
|
||||
for (uint i = 0; i < metadata.length; i++){
|
||||
(users[userId].meta[bytes4(sha3(metadata[i]))],pos) = getNextString(v,pos);
|
||||
}
|
||||
}
|
||||
delete userClaim[myid]; //should always be deleted
|
||||
}
|
||||
|
||||
//owner management
|
||||
function setAPICredentials(string _client_id, string _client_secret) only_owner {
|
||||
credentials = concat(concat(concat("?client_id=",_client_id),"&client_secret="),_client_secret);
|
||||
}
|
||||
|
||||
function clearAPICredentials() only_owner {
|
||||
credentials = "";
|
||||
}
|
||||
|
||||
function addMetaTag(string tag) only_owner{
|
||||
metadata.length++;
|
||||
metadata[metadata.length-1] = tag;
|
||||
newMetaTag(metadata.length-1,tag);
|
||||
}
|
||||
|
||||
function resetMetaTags() only_owner{
|
||||
metadata.length = 0;
|
||||
}
|
||||
|
||||
//internal helper functions
|
||||
function _getQuery(string _github_user, string _gistid) internal constant returns (string){
|
||||
string memory a = concat(concat(concat("[identity] ${[URL] https://gist.githubusercontent.com/", _github_user),"/"),_gistid);
|
||||
a = concat(concat(concat(a, "/raw/}, ${[URL] json(https://api.github.com/gists/"),_gistid),credentials);
|
||||
a = concat(a, ").owner.[login,id]}");
|
||||
if(metadata.length > 0){
|
||||
a = concat(concat(concat(a, ", ${[URL] json(https://api.github.com/users/"),_github_user),credentials);
|
||||
a = concat(a, ").[");
|
||||
uint ml = metadata.length;
|
||||
for (uint i = 0; i < ml; i++){
|
||||
a = concat(a, metadata[i]);
|
||||
if (i < ml-1) a = concat(a, ",");
|
||||
}
|
||||
a = concat(a, "]}");
|
||||
}
|
||||
|
||||
return a;
|
||||
}
|
||||
|
||||
function concat(string _a, string _b) internal constant returns (string) {
|
||||
bytes memory _ba = bytes(_a);
|
||||
bytes memory _bb = bytes(_b);
|
||||
uint _balength = _ba.length;
|
||||
uint _bblength = _bb.length;
|
||||
string memory ab = new string(_balength + _bblength);
|
||||
bytes memory bab = bytes(ab);
|
||||
uint k = 0;
|
||||
for (uint i = 0; i < _balength; i++) bab[k++] = _ba[i];
|
||||
for (i = 0; i < _bblength; i++) bab[k++] = _bb[i];
|
||||
return string(bab);
|
||||
}
|
||||
|
||||
function getNextString(bytes _str, uint8 _pos) internal constant returns (string,uint8) {
|
||||
uint8 start = 0;
|
||||
uint8 end = 0;
|
||||
uint strl =_str.length;
|
||||
for (;strl > _pos; _pos++) {
|
||||
if (_str[_pos] == '"'){ //Found quotation mark
|
||||
if(_str[_pos-1] != '\\'){ //is not escaped
|
||||
end = start == 0 ? 0: _pos;
|
||||
start = start == 0 ? (_pos+1) : start;
|
||||
if(end > 0) break;
|
||||
}
|
||||
}
|
||||
}
|
||||
bytes memory str = new bytes(end-start);
|
||||
for(_pos=0; _pos<str.length; _pos++){
|
||||
str[_pos] = _str[start+_pos];
|
||||
}
|
||||
for(_pos=end+1; _pos<_str.length; _pos++) if (_str[_pos] == ','){ _pos++; break; } //end
|
||||
|
||||
return (string(str),_pos);
|
||||
}
|
||||
|
||||
function getNextUInt(bytes _str, uint8 _pos) internal constant returns (uint,uint8) {
|
||||
uint val = 0;
|
||||
uint strl =_str.length;
|
||||
for (; strl > _pos; _pos++) {
|
||||
byte bp = _str[_pos];
|
||||
if (bp == ','){ //Find ends
|
||||
_pos++; break;
|
||||
}else if ((bp >= 48)&&(bp <= 57)){ //only ASCII numbers
|
||||
val *= 10;
|
||||
val += uint(bp) - 48;
|
||||
}
|
||||
}
|
||||
return (val,_pos);
|
||||
}
|
||||
|
||||
function getNextAddr(bytes _str, uint8 _pos) internal constant returns (address, uint8){
|
||||
uint160 iaddr = 0;
|
||||
uint strl =_str.length;
|
||||
for(;strl > _pos; _pos++){
|
||||
byte bp = _str[_pos];
|
||||
if (bp == '0'){
|
||||
if (_str[_pos+1] == 'x'){
|
||||
for (_pos=_pos+2; _pos<2+2*20; _pos+=2){
|
||||
iaddr *= 256;
|
||||
iaddr += (uint160(hexVal(uint160(_str[_pos])))*16+uint160(hexVal(uint160(_str[_pos+1]))));
|
||||
}
|
||||
_pos++;
|
||||
break;
|
||||
}
|
||||
}else if (bp == ','){
|
||||
_pos++;
|
||||
break;
|
||||
}
|
||||
}
|
||||
return (address(iaddr),_pos);
|
||||
}
|
||||
|
||||
function hexVal(uint val) internal constant returns (uint){
|
||||
return val - (val < 58 ? 48 : (val < 97 ? 55 : 87));
|
||||
}
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user