kirankbs / mqtt-simulator Goto Github PK

At present, User has to send all the Task details to update which may be not efficient in terms of Bandwidth, computation and latency.
To avoid this user just sends interested fields to update with primary identifier. API get's the task and update only requested fields.
If task is not available then user gets proper feedback

Acceptance Criteria

• Code is formatted using scala format

** Techincal Details**
Plugin

Sub Tasks

• Use the Sbt plugin
• Create .scalafmt.conf file
• Apply it to code

Database: https://scala-slick.org/doc/3.1.0/database.html#database-thread-pool

Test diff time zone scenarios, send with, without zones

When NoContent, NoResource etc

Reproduce
Run command ./sbt run locally and send kill signal.

Observed Behaviour
Exception:

Exception in thread "sbt-bg-threads-1" java.util.concurrent.RejectedExecutionException
	at java.base/java.util.concurrent.ForkJoinPool.externalPush(ForkJoinPool.java:1880)
	at java.base/java.util.concurrent.ForkJoinPool.externalSubmit(ForkJoinPool.java:1921)
	at java.base/java.util.concurrent.ForkJoinPool.execute(ForkJoinPool.java:2453)
	at scala.concurrent.impl.ExecutionContextImpl.execute(ExecutionContextImpl.scala:24)
	at sbt.internal.BackgroundThreadPool$BackgroundRunnable.$anonfun$cleanup$1(DefaultBackgroundJobService.scala:390)
	at sbt.internal.BackgroundThreadPool$BackgroundRunnable.$anonfun$cleanup$1$adapted(DefaultBackgroundJobService.scala:389)
	at scala.collection.immutable.List.foreach(List.scala:392)
	at sbt.internal.BackgroundThreadPool$BackgroundRunnable.cleanup(DefaultBackgroundJobService.scala:389)
	at sbt.internal.BackgroundThreadPool$BackgroundRunnable.run(DefaultBackgroundJobService.scala:359)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:834)

Expected Behaviour
Service just shutdown without exception

Technical Details
https://doc.akka.io/docs/akka-http/current/server-side/graceful-termination.html

Create basic http stubbed routes to check Akka Http and Scalatest integration for endpoints

Acceptance Criteria

• POST a simulation
• GET a simulation
• GET all simulations
• PATCH a simulation
• Delete a simulation

Initial logic is implemented with an in-memory list. Replace it with Postgres database to persist simulation definitions.

Acceptance Criteria

• GET simulation
• GET simulation by id
• Update simulation definition
• Delete the simulation definition.

• Message
• EndAt: If no value then ignore it
• CreateAt: Ignore
• UpdateAt: Ignroe

Add OpenApi specification for simulation definition endpoints.

Acceptance Criteria

• Specification is added

Technical Details

• OpenAPI spec

Sub Tasks

• POST simulation definition
• GET all simulation definitions
• GET single simulation definition
• PATCH single simulation definition
• DELETE single simulation definition

Sbt task to generate docker image.

Acceptance Criteria

• Docker image is generated

Sub Task

• Add docker publish local support

As a user, i should be able to manage simulation life cycle. Once i create simulation with required definition, simulation has to start. The status of the simulation is queried by API to view.

Acceptance Criteria

• Simulation definition is stored
• Simulation definition is retrieved

Technical Details

• Postgres is the storage
• Slick: Functional Relational Mapping
• FlyWay Migration

Sub Tasks

• Setup FlyWay
• Create initial evolution script
• Create relational mapping for simulation definition
• Update APIs to use DB rather than in memory implementation

When NoContent, NoResource etc

ErrorResponse:

• Error Code
• Error Message
• ???

Write tests for Akka Http routes

Acceptance Criteria

• Tests are added for routes

Technical Details

• Scalatest
• Akka Http test kit
• Mocito Scala: Idiomatic Syntax

Sub Tasks

• POST simulation definition
• GET all simultion definitions
• GET single simulation definition
• PATCH single simulation definition
• DELETE single simulation definition

More resource usage
check performance
check benchmarking