SIP: Queue

[kingflurkel]

Insert a transaction in a queue. Script is continuously iterating over the items in the queue, checking the status of the transaction. Fires events on status update.

[bkawk]

Block Tasks

Triggered on creation of a new block

• Get Balance

  name: get_balance
  last_run: 0234023402340
  next_run: 349583405830
  interval: Block
  function: _getBalance
  error: _errorBalance
  publicKey: 0x03k5j3lk4j53l4j5345345435

Recurring Tasks

For Everyone

• Get FX Rates When the node starts up this is entered into the queue

  name: get_fx
  last_run: 0234023402340
  next_run: 349583405830
  interval: 5min
  function: _getFx
  error: _errorFx
  publicKey: 0

• Get Hashtags

  name: get_hashtags
  last_run: 0234023402340
  next_run: 349583405830
  interval: 5min
  function: _getHashtags
  error: _errorHashtags
  publicKey: 0

• Get Gas Price

  name: get_fx
  last_run: 0234023402340
  next_run: 349583405830
  interval: 5min
  function: _getGasPrice
  error: _getGasPrice
  publicKey: 0

Health Check

• Check if API container replies
• Check if Chain container replies
• Check if Proxy container replies
• Create a new monitoring job on NS1

One time tasks

One time tasks are not added to the queue but are processed on request.

Specific User

• Get Requests for selected hashtag
• Broadcast transaction
• Save Avatar to IPFS
• Save Front End Error
• Get nonce

---

A Task

• A single unit of work that is completed by a single function
• Once a job is completed the result is is emitted or broadcast

The Queue

• list of Jobs to be completed

Queue Manager

• every 3 seconds check the queue for jobs that have a next run time less than the current time
• pass an array of jobs to the job sheduler

Task Sheduler

• Inserts jobs into the job schedular array as they arrive
• The scheduled jobs are processed as fast as possible, one after another
• Once a job has been completed its removed from the queue or rescheduled

Event Log

• A log of all completed jobs
• Log the time each event took to complete

Error Log

• A log of all errors

---

Events

On Startup

• Tasks for everyone is added to the queue
• Add server IP address to NS1

On Connect

When a user connects we add the Repeating tasks for a specific user to the queue

socketId: 8d79fg7d9f8g7
publicKey: 0x00d8fg0d9f8g0dfg90df8g09d8fgcckk
connectedTime: 23234234234

On Disconnect

When a user disconnects we remove the Repeating tasks for a specific user to the queue

socketId: 8d79fg7d9f8g7
publicKey: 0x00d8fg0d9f8g0dfg90df8g09d8fgcckk
connectedTime: 23234234234

On Block

When a block occours

• Get Balance

[ghost]

If the balance of all connected users is checked for every block, the majority will result in "no change". If the node is a full node, it could provide all Transfer logs, and the API service could calculate all balances of all addresses. Then the balance for any address would be known and up to date just by listening to the Transfer log filter.