Euler 0.1.1

Dockerfile

@@ -46,6 +46,8 @@ ENV GO_VERSION 1.11.2
 ENV GO_ARCH 'linux-amd64'
 ENV GO_BIN_SHA '1dfe664fa3d8ad714bbd15a36627992effd150ddabd7523931f077b3926d736d'
 
+ENV IPGET_VERSION 0.3.0
+ENV IPGET_ARCH 'linux-amd64'
 
 #  Install required dev tools to install go
 ###############################################################################
@@ -60,6 +62,19 @@ RUN url="https://golang.org/dl/go${GO_VERSION}.${GO_ARCH}.tar.gz" && \
 	tar -C /usr/local -xzf go.tgz &&\
 	rm go.tgz
 
+#  Download genesis file and links file from IPFS
+###############################################################################
+RUN url="https://dist.ipfs.io/ipget/v${IPGET_VERSION}/ipget_v${IPGET_VERSION}_${IPGET_ARCH}.tar.gz" && \
+    wget -O ipget.tgz "$url" && \
+    tar -xzf ipget.tgz && \
+    rm ipget.tgz
+
+WORKDIR /ipget
+RUN ./ipget QmSFTpNaXB3FhB4EWjsrUydupZXTL8Z44c2j18o5CGnN5h -o /genesis.json
+RUN ./ipget QmepwmLe7vQcK2W6WmvfEk46de3cJ4Jp6jXRXNhuR2AfJ9 -o /links
+RUN ./ipget QmdHeSsjkuThTe6VVDD4FUUfpQFH79R8tYrC2bgWwHC2bh -o /config.toml
+
+WORKDIR /
 
 #  Copy compiled kernel and binaries
 ###############################################################################
@@ -69,11 +84,8 @@ COPY --from=build_stage /sources/cyberdcli /usr/bin/cyberdcli
 COPY --from=build_stage /usr/lib/cbdrank.h /usr/lib/cbdrank.h
 COPY --from=build_stage /usr/lib/libcbdrank.so /usr/lib/libcbdrank.so
 
-
-#  Copy configs and startup scripts
+#  Copy startup scripts
 ###############################################################################
-COPY ./testnet/genesis.json /genesis.json
-COPY ./testnet/config.toml /config.toml
 
 COPY start_script.sh start_script.sh
 COPY entrypoint.sh /entrypoint.sh

README.md

@@ -2,7 +2,7 @@
 # cyberd. Knowledge consensus computer
 ![banner](logo.png)
 
-[![testnet](https://img.shields.io/badge/testnet-euler-green.svg?style=flat-square)](https://github.com/cybercongress/cyberd/blob/master/docs/run_validator.md)
+[![testnet](https://img.shields.io/badge/testnet-euler--1-green.svg?style=flat-square)](https://github.com/cybercongress/cyberd/blob/master/docs/run_validator.md)
 [![version](https://img.shields.io/github/release/cybercongress/cyberd.svg?style=flat-square)](https://github.com/cosmos/cosmos-sdk/releases/latest)
 [![CircleCI](https://img.shields.io/circleci/project/github/cybercongress/cyberd.svg?style=flat-square)](https://circleci.com/gh/cybercongress/cyberd/tree/master)
 [![license](https://img.shields.io/badge/License-Cyber-brightgreen.svg?style=flat-square)](https://github.com/cybercongress/cyberd/blob/master/LICENSE)

app/ante.go

@@ -0,0 +1,99 @@
+package app
+
+import (
+	"fmt"
+	sdk "github.com/cosmos/cosmos-sdk/types"
+	"github.com/cosmos/cosmos-sdk/x/auth"
+)
+
+// should be removed after cosmos refactor
+func NewAnteHandler(ak auth.AccountKeeper) sdk.AnteHandler {
+	return func(ctx sdk.Context, tx sdk.Tx, simulate bool) (newCtx sdk.Context, res sdk.Result, abort bool) {
+
+		//todo really need it?
+		newCtx = auth.SetGasMeter(true, ctx, 0)
+
+		// all transactions must be of type auth.StdTx
+		stdTx, ok := tx.(auth.StdTx)
+		if !ok {
+			return newCtx, sdk.ErrInternal("tx must be StdTx").Result(), true
+		}
+
+		params := ak.GetParams(ctx)
+		if err := tx.ValidateBasic(); err != nil {
+			return newCtx, err.Result(), true
+		}
+
+		if res := validateMemo(stdTx, params); !res.IsOK() {
+			return newCtx, res, true
+		}
+
+		// stdSigs contains the sequence number, account number, and signatures.
+		// When simulating, this would just be a 0-length slice.
+		signerAddrs := stdTx.GetSigners()
+		stdSigs := stdTx.GetSignatures()
+		isGenesis := ctx.BlockHeight() == 0
+		signerAccs := make([]auth.Account, len(signerAddrs))
+
+		for i := 0; i < len(stdSigs); i++ {
+
+			signerAccs[i], res = auth.GetSignerAcc(newCtx, ak, signerAddrs[i])
+			if !res.IsOK() {
+				return newCtx, res, true
+			}
+
+			// check signature, return account with incremented nonce
+			signBytes := auth.GetSignBytes(newCtx.ChainID(), stdTx, signerAccs[i], isGenesis)
+			signerAccs[i], res = processSig(signerAccs[i], stdSigs[i], signBytes, simulate)
+			if !res.IsOK() {
+				return newCtx, res, true
+			}
+
+			ak.SetAccount(newCtx, signerAccs[i])
+		}
+
+		return newCtx, sdk.Result{}, false // continue...
+	}
+}
+
+func validateMemo(stdTx auth.StdTx, params auth.Params) sdk.Result {
+	memoLength := len(stdTx.GetMemo())
+	if uint64(memoLength) > params.MaxMemoCharacters {
+		return sdk.ErrMemoTooLarge(
+			fmt.Sprintf(
+				"maximum number of characters is %d but received %d characters",
+				params.MaxMemoCharacters, memoLength,
+			),
+		).Result()
+	}
+
+	return sdk.Result{}
+}
+
+// verify the signature and increment the sequence. If the account doesn't have a pubkey, set it.
+func processSig(
+	acc auth.Account, sig auth.StdSignature, signBytes []byte, simulate bool,
+) (updatedAcc auth.Account, res sdk.Result) {
+
+	pubKey, res := auth.ProcessPubKey(acc, sig, simulate)
+	if !res.IsOK() {
+		return nil, res
+	}
+
+	err := acc.SetPubKey(pubKey)
+	if err != nil {
+		return nil, sdk.ErrInternal("setting PubKey on signer's account").Result()
+	}
+
+	if !simulate && !pubKey.VerifyBytes(signBytes, sig.Signature) {
+		return nil, sdk.ErrUnauthorized("signature verification failed").Result()
+	}
+
+	err = acc.SetSequence(acc.GetSequence() + 1)
+	if err != nil {
+		// Handle w/ #870
+		panic(err)
+	}
+
+	return acc, res
+}