Added rionet

configs/development.yml

@@ -11,6 +11,10 @@ rpc:
     uri: https://rpc.tzkt.io/quebecnet
     timeout: 20
     requests_per_second: 20
+  rionet:
+    uri: https://rpc.tzkt.io/rionet
+    timeout: 20
+    requests_per_second: 20
 
 log_level: ${LOG_LEVEL:-info}
 
@@ -21,6 +25,8 @@ services:
     mempool: https://mempool.test.dipdup.net/v1/graphql
   quebecnet:
     mempool: https://mempool.test.dipdup.net/v1/graphql
+  rionet:
+    mempool: https://mempool.test.dipdup.net/v1/graphql
 
 storage:
   pg: 
@@ -58,10 +64,12 @@ api:
       mainnet: https://rpc.tzkt.io/mainnet
       ghostnet: https://rpc.tzkt.io/ghostnet
       quebecnet: https://rpc.tzkt.io/quebecnet
+      rionet: https://rpc.tzkt.io/rionet
   networks:
     - mainnet
     - ghostnet
     - quebecnet
+    - rionet
 
 indexer:
   project_name: indexer
@@ -73,9 +81,12 @@ indexer:
       receiver_threads: 5
     quebecnet:
       receiver_threads: 10
+    rionet:
+      receiver_threads: 10
 
 scripts:
   networks:
     - mainnet
     - ghostnet
     - quebecnet
+    - rionet

internal/bcd/protocols.go

@@ -47,6 +47,7 @@ var symLinks = map[string]string{
 	"PtParisBxoLz5gzMmn3d9WBQNoPSZakgnkMC2VNuQ3KXfUtUQeZ": SymLinkJakarta, // Paris B 2,
 	"PsParisCZo7KAh1Z1smVd9ZMZ1HHn5gkzbM94V3PLCpknFWhUAi": SymLinkJakarta, // Paris C
 	"PsQuebecnLByd3JwTiGadoG4nGWi3HYiLXUjkibeFV8dCFeVMUg": SymLinkJakarta, // Quebec
+	"PsRiotumaAMotcRoDWW1bysEhQy2n1M5fy8JgRp8jjRfHGmfeA7": SymLinkJakarta, // Rionet
 }
 
 // GetProtoSymLink -
@@ -86,4 +87,5 @@ var ChainID = map[string]string{
 	"NetXxWsskGahzQB": "oxfordnet",
 	"NetXR64bNAYkP4S": "parisnet",
 	"NetXuTeGinLEqxp": "quebecnet",
+	"NetXPdgaoabtBth": "rionet",
 }

internal/models/types/network.go

@@ -35,6 +35,7 @@ const (
 	Weeklynet
 	Parisnet
 	Quebecnet
+	Rionet
 )
 
 var networkNames = map[Network]string{
@@ -61,6 +62,7 @@ var networkNames = map[Network]string{
 	Oxfordnet:    "oxfordnet",
 	Parisnet:     "parisnet",
 	Quebecnet:    "quebecnet",
+	Rionet:       "rionet",
 }
 
 var namesToNetwork = map[string]Network{
@@ -87,6 +89,7 @@ var namesToNetwork = map[string]Network{
 	"weeklynet":    Weeklynet,
 	"parisnet":     Parisnet,
 	"quebecnet":    Quebecnet,
+	"rionet":       Rionet,
 }
 
 // String - convert enum to string for printing

internal/parsers/operations/migration.go

@@ -68,7 +68,8 @@ func (m Migration) Parse(ctx context.Context, data noderpc.Operation, operation
 		"PtParisBQscdCm6Cfow6ndeU6wKJyA3aV1j4D3gQBQMsTQyJCrz",
 		"PtParisBxoLz5gzMmn3d9WBQNoPSZakgnkMC2VNuQ3KXfUtUQeZ",
 		"PsParisCZo7KAh1Z1smVd9ZMZ1HHn5gkzbM94V3PLCpknFWhUAi",
-		"PsQuebecnLByd3JwTiGadoG4nGWi3HYiLXUjkibeFV8dCFeVMUg":
+		"PsQuebecnLByd3JwTiGadoG4nGWi3HYiLXUjkibeFV8dCFeVMUg",
+		"PsRiotumaAMotcRoDWW1bysEhQy2n1M5fy8JgRp8jjRfHGmfeA7":
 		return m.fromLazyStorageDiff(ctx, data, operation, store)
 	default:
 		return errors.Errorf("unknown protocol for migration parser: %s", protocol)

internal/parsers/protocols/protocol.go

@@ -87,7 +87,8 @@ func Get(ctx *config.Context, protocol string) (*Specific, error) {
 		"PtParisBQscdCm6Cfow6ndeU6wKJyA3aV1j4D3gQBQMsTQyJCrz",
 		"PtParisBxoLz5gzMmn3d9WBQNoPSZakgnkMC2VNuQ3KXfUtUQeZ",
 		"PsParisCZo7KAh1Z1smVd9ZMZ1HHn5gkzbM94V3PLCpknFWhUAi",
-		"PsQuebecnLByd3JwTiGadoG4nGWi3HYiLXUjkibeFV8dCFeVMUg":
+		"PsQuebecnLByd3JwTiGadoG4nGWi3HYiLXUjkibeFV8dCFeVMUg",
+		"PsRiotumaAMotcRoDWW1bysEhQy2n1M5fy8JgRp8jjRfHGmfeA7":
 		return &Specific{
 			StorageParser:         storage.NewLazyBabylon(ctx.BigMapDiffs, ctx.Operations, ctx.Accounts),
 			ContractParser:        contract.NewJakarta(ctx),
@@ -143,7 +144,8 @@ func NeedImplicitParsing(protocol string) bool {
 		"PtParisBQscdCm6Cfow6ndeU6wKJyA3aV1j4D3gQBQMsTQyJCrz",
 		"PtParisBxoLz5gzMmn3d9WBQNoPSZakgnkMC2VNuQ3KXfUtUQeZ",
 		"PsParisCZo7KAh1Z1smVd9ZMZ1HHn5gkzbM94V3PLCpknFWhUAi",
-		"PsQuebecnLByd3JwTiGadoG4nGWi3HYiLXUjkibeFV8dCFeVMUg":
+		"PsQuebecnLByd3JwTiGadoG4nGWi3HYiLXUjkibeFV8dCFeVMUg",
+		"PsRiotumaAMotcRoDWW1bysEhQy2n1M5fy8JgRp8jjRfHGmfeA7":
 		return true
 	}
 	return false