Fix minor issues in message marshalling and config files

conf.broker.yaml.template

@@ -16,7 +16,7 @@ rpc:
 plugins:
   uniswap:
     schedule:
-      ethereum: 5000
+      ethereum: 5s
 
     tokens:
       - name: ethereum

conf.remote.yaml.template

@@ -16,7 +16,7 @@ rpc:
 plugins:
   uniswap:
     schedule:
-      ethereum: 5000
+      ethereum: 5s
 
     tokens:
       - name: ethereum

conf.standalone.yaml.template

@@ -23,8 +23,8 @@ rpc:
 plugins:
   logs:
     schedule:
-      arbitrum: 100
-      ethereum: 5000
+      arbitrum: 100ms
+      ethereum: 5s
 
     events:
       - name: DAI
@@ -39,8 +39,8 @@ plugins:
 
   uniswap:
     schedule:
-      arbitrum: 100
-      ethereum: 5000
+      arbitrum: 100ms
+      ethereum: 5s
 
     tokens:
       - name: ethereum

conf.worker.yaml.template

@@ -17,7 +17,7 @@ rpc:
 plugins:
   uniswap:
     schedule:
-      ethereum: 5000
+      ethereum: 5s
 
     tokens:
       - name: ethereum

quickstart.md

@@ -215,7 +215,7 @@ rpc:
 plugins:
   uniswap:
     schedule:
-      ethereum: 5000
+      ethereum: 5s
 
     tokens:
       - name: ethereum

src/net/server.go

@@ -334,34 +334,25 @@ func rootHandler(w http.ResponseWriter, r *http.Request) {
 
 			SendMessage(conn, messageType, opcodes.Feedback, "conf.ok")
 			Send(conn, messageType, opcodes.KoskChallenge, result)
-		case opcodes.PriceReport:
-			// TODO: Maybe this is unnecessary
-			if payload[1] != 0 {
-				SendError(conn, messageType, opcodes.Feedback, constants.ErrNotSupportedDataset)
-				continue
-			}
 
-			result, err := processPriceReport(conn, payload[2:])
+		case opcodes.PriceReport:
+			result, err := processPriceReport(conn, payload[1:])
 			if err != nil {
 				SendError(conn, messageType, opcodes.Error, err)
 			}
 
 			BroadcastPayload(opcodes.PriceReportBroadcast, result)
 			SendMessage(conn, messageType, opcodes.Feedback, "signature.accepted")
-		case opcodes.EventLog:
-			// TODO: Maybe this is unnecessary
-			if payload[1] != 0 {
-				SendError(conn, messageType, opcodes.Feedback, constants.ErrNotSupportedDataset)
-				continue
-			}
 
-			result, err := processEventLog(conn, payload[2:])
+		case opcodes.EventLog:
+			result, err := processEventLog(conn, payload[1:])
 			if err != nil {
 				SendError(conn, messageType, opcodes.Error, err)
 			}
 
 			BroadcastPayload(opcodes.EventLogBroadcast, result)
 			SendMessage(conn, messageType, opcodes.Feedback, "signature.accepted")
+
 		case opcodes.CorrectnessReport:
 			result, err := processCorrectnessRecord(conn, payload[1:])
 			if err != nil {
@@ -370,16 +361,19 @@ func rootHandler(w http.ResponseWriter, r *http.Request) {
 
 			BroadcastPayload(opcodes.CorrectnessReportBroadcast, result)
 			SendMessage(conn, messageType, opcodes.Feedback, "signature.accepted")
+
 		case opcodes.KoskResult:
 			err := processKosk(conn, payload[1:])
 			if err != nil {
 				SendError(conn, messageType, opcodes.Error, err)
 			}
 			SendMessage(conn, messageType, opcodes.Feedback, "kosk.ok")
+
 		case opcodes.RegisterConsumer:
 			// TODO: Consumers must specify what they're subscribing to
 			repository.Consumers.Store(conn, true)
 			repository.BroadcastMutex.Store(conn, new(sync.Mutex))
+
 		default:
 			SendError(conn, messageType, opcodes.Error, constants.ErrNotSupportedInstruction)
 		}

src/net/shared/shared.go

@@ -23,7 +23,7 @@ func SendRaw(data []byte) error {
 
 func Send(opCode opcodes.OpCode, payload []byte) {
 	err := SendRaw(
-		append([]byte{byte(opCode), 0}, payload...),
+		append([]byte{byte(opCode)}, payload...),
 	)
 	if err != nil {
 		log.Logger.Error("Can't send packet: %v", err)

src/plugins/uniswap/uniswap.go

@@ -214,9 +214,6 @@ func RecordSignature(
 			return true
 		})
 
-		reportLog.
-			With("Majority", fmt.Sprintf("%x", hash.Bytes())[:8]).
-			Debug("Values")
 		reportLog.
 			With("Majority", fmt.Sprintf("%x", hash.Bytes())[:8]).
 			Debug("Values")
@@ -225,6 +222,7 @@ func RecordSignature(
 			info.Asset,
 			SaveSignatureArgs{Hash: hash, Info: info},
 		)
+
 		if debounce {
 			DebouncedSaveSignatures(
 				info.Asset,