[WIP] Signal Scheme

daos/private/testdao37.json

@@ -0,0 +1,39 @@
+{
+  "name": "Hubristic Colorist",
+  "Avatar": "0x66301c44C22E0AEcd8ee8e6073A8300dC138A7af",
+  "DAOToken": "0xa6b58AE81c37b45BbeAC4C86866fA4b48e378139",
+  "Reputation": "0xB9e9DfAcb27f42357215aC3942810786C0cb75e2",
+  "Controller": "0xf577703d169b02e6807f80a4fCe029f7F91124CB",
+  "Schemes": [
+    {
+      "name": "GenericScheme",
+      "alias": "GenericSchemeAlias",
+      "address": "0xCE792fA3A9cd660fFD1be077CB1358A08Cf9106B",
+      "arcVersion": "0.0.1-rc.37"
+    },
+    {
+      "name": "ContributionRewardExt",
+      "alias": "ContributionRewardExt",
+      "address": "0xA10f1c26d7D4BCB1a93F84652177D2E2b320378B",
+      "arcVersion": "0.0.1-rc.36"
+    }
+  ],
+  "StandAloneContracts": [
+    {
+      "name": "Wallet",
+      "address": "0x0E1598278e34793C83A4B1989d410DD0D7652b92",
+      "arcVersion": "0.0.1-rc.37"
+    },
+    {
+      "name": "ContributionRewardExt",
+      "address": "0xA10f1c26d7D4BCB1a93F84652177D2E2b320378B",
+      "arcVersion": "0.0.1-rc.36"
+    },
+    {
+      "name": "Competition",
+      "address": "0xD65d9Cb0fC54c95Ed021D74cB5164b5B30bB4B86",
+      "arcVersion": "0.0.1-rc.36"
+    }
+  ],
+  "arcVersion": "0.0.1-rc.37"
+}

daos/rinkeby/devtest.json

@@ -0,0 +1,15 @@
+{
+    "name": "DevTest",
+    "Avatar": "0xBeB9C86C8D54e5C7cA2a7Dc67E50419FB98D9c05",
+    "DAOToken": "0x57bae8c98F913c10bBC23342596dE2E58E45466D",
+    "Reputation": "0x57bE0441440dFA2faE4Dd80Ec355Bc6db8257563",
+    "Controller": "0xB460481416B688b7E1c0D407f033567C687Fb607",
+    "Schemes": [
+      {
+        "name": "GenericScheme",
+        "alias": "GenericSchemeAlias",
+        "address": "0xad96d9685783bF29cB31eB038A44eC808aC17265"
+      }
+    ],
+    "arcVersion": "0.0.1-rc.31"
+  }

ops/mappings.json

@@ -8,6 +8,13 @@
         "mapping": "DAOToken",
         "arcVersion": "0.0.1-rc.16"
       },
+      {
+        "name": "NewSignalScheme",
+        "dao": "address",
+        "mapping": "SignalScheme",
+        "arcVersion": "0.0.1-rc.37",
+        "address": "0x383A20B3635a10a4da8f733E8eA256cBcAcB4D4E"
+      },
       {
         "name": "GenesisProtocol",
         "contractName": "GenesisProtocol",
@@ -737,6 +744,13 @@
         "mapping": "DAOToken",
         "arcVersion": "0.0.1-rc.19"
       },
+      {
+        "name": "NewSignalScheme",
+        "dao": "address",
+        "mapping": "SignalScheme",
+        "arcVersion": "0.0.1-rc.37",
+        "address": "0xE06d896da40B73Cb02650220E480e20F38e7bE18"
+      },
       {
         "name": "Reputation",
         "contractName": "Reputation",

src/domain/index.ts

@@ -1,4 +1,4 @@
-import { Address, BigDecimal, BigInt, Bytes, Entity, store, Value} from '@graphprotocol/graph-ts';
+import { Address, BigDecimal, BigInt, Bytes, Entity, store, Value } from '@graphprotocol/graph-ts';
 import { setContractsInfo, setTemplatesInfo } from '../contractsInfo';
 import { Transfer } from '../types/DAOToken/DAOToken';
 import {
@@ -36,22 +36,23 @@ import {
 import {
   daoBountyRedemption,
   insertGPRewards,
-  insertGPRewardsToHelper ,
-  reputationRedemption ,
+  insertGPRewardsToHelper,
+  reputationRedemption,
   tokenRedemption,
 } from './reward';
+import { writeSignal } from './signal';
 import { insertStake } from './stake';
 import { getToken, insertToken, updateTokenTotalSupply } from './token';
 import { insertVote } from './vote';
 
-function isProposalValid(proposalId: string ): boolean {
+function isProposalValid(proposalId: string): boolean {
   let p = Proposal.load(proposalId);
-  return  ((p != null) && (equalsBytes(p.paramsHash, new Bytes(32)) == false));
+  return ((p != null) && (equalsBytes(p.paramsHash, new Bytes(32)) == false));
 }
 
 function handleGPProposalPrivate(proposalId: string): void {
-   let gpProposal = GenesisProtocolProposal.load(proposalId);
-   if (gpProposal != null) {
+  let gpProposal = GenesisProtocolProposal.load(proposalId);
+  if (gpProposal != null) {
     updateGPProposal(
       gpProposal.address as Address,
       gpProposal.proposalId,
@@ -66,7 +67,7 @@ function handleGPProposalPrivate(proposalId: string): void {
       3, // Queued
       gpProposal.address as Address,
     );
-   }
+  }
 }
 
 export function handleNewContributionProposal(
@@ -92,26 +93,26 @@ export function handleNewContributionProposal(
 }
 
 export function handleNewSchemeRegisterProposal(
-   proposalId: string,
-   timestamp: BigInt,
-   avatar: Bytes,
-   votingMachine: Bytes,
-   descriptionHash: string,
-   schemeAddress: Address,
- ): void {
-    if (!daoModule.exists(avatar as Address)) {
-      return;
-    }
-    updateSRProposal(
-      proposalId,
-      timestamp,
-      avatar as Address,
-      votingMachine as Address,
-      descriptionHash,
-      schemeAddress,
-    );
-    handleGPProposalPrivate(proposalId);
- }
+  proposalId: string,
+  timestamp: BigInt,
+  avatar: Bytes,
+  votingMachine: Bytes,
+  descriptionHash: string,
+  schemeAddress: Address,
+): void {
+  if (!daoModule.exists(avatar as Address)) {
+    return;
+  }
+  updateSRProposal(
+    proposalId,
+    timestamp,
+    avatar as Address,
+    votingMachine as Address,
+    descriptionHash,
+    schemeAddress,
+  );
+  handleGPProposalPrivate(proposalId);
+}
 
 export function handleNewCallProposal(
   avatar: Address,
@@ -138,12 +139,12 @@ export function handleStake(event: Stake): void {
   if (equalsBytes(proposal.paramsHash, new Bytes(32))) {
     return;
   }
-  if (event.params._vote.toI32() ==  1) {
+  if (event.params._vote.toI32() == 1) {
     proposal.stakesFor = proposal.stakesFor.plus(event.params._amount);
   } else {
     proposal.stakesAgainst = proposal.stakesAgainst.plus(event.params._amount);
   }
-  proposal.confidence =  (new BigDecimal(proposal.stakesFor)) / (new BigDecimal(proposal.stakesAgainst));
+  proposal.confidence = (new BigDecimal(proposal.stakesFor)) / (new BigDecimal(proposal.stakesAgainst));
   saveProposal(proposal);
   insertStake(
     eventId(event),
@@ -192,24 +193,20 @@ export function handleVoteProposal(event: VoteProposal): void {
 
 export function confidenceLevelUpdate(proposalId: Bytes, confidenceThreshold: BigInt): void {
   if (isProposalValid(proposalId.toHex())) {
-      updateProposalconfidence(proposalId, confidenceThreshold);
+    updateProposalconfidence(proposalId, confidenceThreshold);
   }
 }
 
-export function handleRegisterScheme(avatar: Address,
-                                     nativeTokenAddress: Address,
-                                     nativeReputationAddress: Address,
-                                     scheme: Address ,
-                                     paramsHash: Bytes,
-                                     timestamp: BigInt): void {
+export function handleRegisterScheme(avatar: Address, nativeTokenAddress: Address, nativeReputationAddress: Address,
+                                     scheme: Address, paramsHash: Bytes, timestamp: BigInt): void {
   // Detect the first register scheme event which indicates a new DAO
   let isFirstRegister = store.get(
     'FirstRegisterSchemeFlag',
     avatar.toHex(),
   );
   if (isFirstRegister == null) {
     setContractsInfo();
-    let dao = daoModule.insertNewDAO(avatar, nativeTokenAddress , nativeReputationAddress);
+    let dao = daoModule.insertNewDAO(avatar, nativeTokenAddress, nativeReputationAddress);
     insertToken(hexToAddress(dao.nativeToken), avatar.toHex());
     insertReputation(
       hexToAddress(dao.nativeReputation),
@@ -265,20 +262,20 @@ export function handleNativeTokenTransfer(event: Transfer): void {
 }
 
 export function handleExecuteProposal(event: ExecuteProposal): void {
-   if (isProposalValid(event.params._proposalId.toHex())) {
-       updateProposalExecution(event.params._proposalId, event.params._totalReputation, event.block.timestamp);
-    }
+  if (isProposalValid(event.params._proposalId.toHex())) {
+    updateProposalExecution(event.params._proposalId, event.params._totalReputation, event.block.timestamp);
+  }
 }
 
 export function handleStateChange(event: StateChange): void {
   if (isProposalValid(event.params._proposalId.toHex())) {
-      updateProposalState(event.params._proposalId, event.params._proposalState, event.address);
-      if ((event.params._proposalState == 1) ||
-          (event.params._proposalState == 2)) {
-          insertGPRewards(event.params._proposalId, event.block.timestamp, event.address, event.params._proposalState);
-      }
+    updateProposalState(event.params._proposalId, event.params._proposalState, event.address);
+    if ((event.params._proposalState == 1) ||
+      (event.params._proposalState == 2)) {
+      insertGPRewards(event.params._proposalId, event.block.timestamp, event.address, event.params._proposalState);
+    }
 
-      addProposalStateChangeEvent(event.params._proposalId, event.transaction.from, event.block.timestamp);
+    addProposalStateChangeEvent(event.params._proposalId, event.transaction.from, event.block.timestamp);
   }
 }
 
@@ -288,20 +285,20 @@ export function handleExecutionStateChange(event: GPExecuteProposal): void {
   }
 }
 
-export function handleGPRedemption(proposalId: Bytes, beneficiary: Address , timestamp: BigInt , type: string): void {
-   if (isProposalValid(proposalId.toHex())) {
-       if (type == 'token') {
-           tokenRedemption(proposalId, beneficiary, timestamp);
-       } else if (type == 'reputation') {
-           reputationRedemption(proposalId, beneficiary, timestamp);
-       } else {
-           daoBountyRedemption(proposalId, beneficiary, timestamp);
-       }
+export function handleGPRedemption(proposalId: Bytes, beneficiary: Address, timestamp: BigInt, type: string): void {
+  if (isProposalValid(proposalId.toHex())) {
+    if (type == 'token') {
+      tokenRedemption(proposalId, beneficiary, timestamp);
+    } else if (type == 'reputation') {
+      reputationRedemption(proposalId, beneficiary, timestamp);
+    } else {
+      daoBountyRedemption(proposalId, beneficiary, timestamp);
     }
+  }
 }
 
 export function daoRegister(dao: Address, tag: string): void {
-   daoModule.register(dao, tag);
+  daoModule.register(dao, tag);
 }
 
 export function addDaoMember(reputationHolder: ReputationHolder): void {
@@ -321,10 +318,14 @@ export function addDaoMember(reputationHolder: ReputationHolder): void {
 }
 
 export function removeDaoMember(reputationHolder: ReputationHolder): void {
-   let dao = getReputation(reputationHolder.contract.toHex()).dao;
-   if (dao == null) {
-     // reputation that's not attached to a DAO
-     return;
-   }
-   daoModule.decreaseDAOmembersCount(dao);
+  let dao = getReputation(reputationHolder.contract.toHex()).dao;
+  if (dao == null) {
+    // reputation that's not attached to a DAO
+    return;
+  }
+  daoModule.decreaseDAOmembersCount(dao);
+}
+
+export function addSignal(signalId: string, proposalId: string): void {
+  writeSignal(signalId, proposalId);
 }

src/domain/schema.graphql

@@ -211,3 +211,8 @@ type Event @entity {
 	dao: DAO
 	timestamp: BigInt!
 }
+
+type Signal @entity{
+	id: ID!
+	data: String
+}