service generating a periodic data stream of encrypted messages where the number of encrypted strings can be anywhere between 49-499.
Each message contains an object with 3 keys: name, origin, destination and a secret_key which is a hash of these 3 fields. randomize the values for name, origin, destination from a constant list provided in data.json file

exmaple

originalMessage = {
  name: 'Jack Reacher',
  origin: 'Bengaluru',
  destination: 'Mumbai'
}

add a secret_key by creating a sha-256 hash of the above object

sumCheckMessage = {
  name: 'Jack Reacher',
  origin: 'Bengaluru',
  destination: 'Mumbai',
  secret_key: "sha-256 ash of originalMessage",
}

encrypt this payload using encryption algorithm `aes-256-ctr` with a pass key

encryptedMessage = "encrypted message string"

The Listener service allow an emitter to connect to it via sockets. On receipt of the encrypted message stream, the listener is decrypting this string and retrieve the data in the payload. Validating the objects using the secret_key to ensure data integrity. If the data integrity of any object is compromised then, it is discarding that operation and moving on to the next in the queue.

On successful object data integrity validation, adding a timestamp to that object and save it to a mongoDB collection modelled for saving time-series data where each document should be corresponding to the minute in which it is received. e.g. for data received for a person between 14:00 to 14:01 all records are added in a single document as a timeseries. Design the schema is such a manner to allow for optimal performance for aggregation timeseries queries.

All the valid data saved are displayed in a real-time manner on a small frontend app along with the success rate for data transmission and decoding

# git clone the repository
# run command: docker-compose up
# on second terminal go to public folder using command : cd .\encrypted-timeseries\public\
# on bash terminal run command : mongod
# after going to this directory run command: node .\emmiter.js
# for frontend app type : http://localhost:3000/ on browser and user will be able to see the data