RED-201: Network Generated Transactions

src/index.ts

@@ -21,6 +21,7 @@ import * as shardFunctionTypes_ from './state-manager/shardFunctionTypes'
 import * as StateManagerTypes_ from './state-manager/StateManagerTypes'
 import * as StateMetaDataTypes_ from './state-manager/StateMetaDataTypes'
 import * as ModesTypes_ from './p2p/ModesTypes'
+import * as ServiceQueueTypes_ from './p2p/ServiceQueueTypes'
 import * as Utils_ from './utils/functions/stringify'
 
 export type hexstring = string
@@ -51,6 +52,7 @@ export namespace P2P {
   export import SyncTypes = SyncTypes_
   export import TemplateTypes = TemplateTypes_
   export import ModesTypes = ModesTypes_
+  export import ServiceQueueTypes = ServiceQueueTypes_
 }
 
 export namespace StateManager {

src/p2p/CycleCreatorTypes.ts

@@ -12,6 +12,7 @@ import * as SafetyMode from './SafetyModeTypes'
 import * as Snapshot from './SnapshotTypes'
 import * as Modes from './ModesTypes'
 import * as LostArchivers from './LostArchiverTypes'
+import * as ServiceQueue from './ServiceQueueTypes'
 
 /** TYPES */
 
@@ -42,7 +43,8 @@ export type CycleTxs =
   Lost.Txs &
   Rotation.Txs &
   CycleAutoScale.Txs &
-  LostArchivers.Txs
+  LostArchivers.Txs &
+  ServiceQueue.Txs
 // don't forget to add new modules here
 
 export type CycleRecord = BaseRecord &
@@ -68,7 +70,8 @@ export type CycleRecord = BaseRecord &
     standbyNodeListHash: hexstring
   } &
   LostArchivers.Record &
-  { random: number }
+  { random: number } &
+  ServiceQueue.Record
 
 export type CycleData = CycleRecord & {
   marker: CycleMarker

src/p2p/P2PTypes.ts

@@ -26,6 +26,7 @@ export interface P2PNode {
   address: string
   joinRequestTimestamp: number
   activeTimestamp: number
+  activeCycle: number
   syncingTimestamp: number
   readyTimestamp: number
   refreshedCounter?: number

src/p2p/ServiceQueueTypes.ts

@@ -0,0 +1,33 @@
+import { SignedObject } from "./P2PTypes"
+
+export interface Txs {
+  txadd: AddNetworkTx[]
+  txremove: RemoveNetworkTx[]
+}
+
+export interface AddNetworkTx<T = any> {
+  hash: string
+  type: string
+  txData: T
+  cycle: number // cycle the tx was added
+  subQueueKey?: string
+}
+
+export interface RemoveNetworkTx {
+  txHash: string
+  cycle: number // cycle the tx was added
+}
+
+export type SignedAddNetworkTx = AddNetworkTx & SignedObject;
+export type SignedRemoveNetworkTx = RemoveNetworkTx & SignedObject;
+
+export interface NetworkTxEntry {
+  hash: string
+  tx: AddNetworkTx
+}
+
+export interface Record {
+  txadd: AddNetworkTx[]
+  txremove: RemoveNetworkTx[]
+  txlisthash: string
+}