gmaslowski / distractor Goto Github PK

View Code? Open in Web Editor NEW

6.0 6.0 2.0 2.19 MB

Scala 93.63% Shell 0.14% HTML 1.77% JavaScript 4.46%

integration-framework integrations reactor scala

distractor's People

Contributors

Stargazers

Watchers

Forkers

gitter-badger pawmot

distractor's Issues

Introduce typed ReactorResponse

OneLineResponse
MultilineResponse

Use Akka's microkernel for starting the application.

Introduce online issue trackeer

Spike on splitting reactors and transports to multiple JVMs

InfoReactor should output more information.

/info - information about distractor + version + registered reactors

Introduce online continuous integration

Configure test coverage service

Allow to invoke InfoReactor with "/info"

Currently the regex which validates request messages is not able to match against "/info".

Add docker support.

Add possibility to start distractor with docker.

ReactorTransportMixer should have a diiferent name.

Currently the name doesn't qiute fit to what it is intented for. It has to react to requests from transports and route messages to reactors. Pick a new name. Remember to update the lackonick documentation.

ggf

Add http view of distractor status.

Make SystemReactor return a value to TelnetTransport when invoked

Fix current develop build.

Make it only running. The current code is corrupted.

[error] /home/greg/dev/projects/private/distractor/src/main/scala/com/fp/distractor/core/transport/TransportRegistry.scala:5: value Message is not a member of object com.fp.distractor.core.transport.api.TransportApi
[error] import com.fp.distractor.core.transport.api.TransportApi.{Message, Say}
[error]        ^
[error] /home/greg/dev/projects/private/distractor/src/main/scala/com/fp/distractor/core/reactor/info/SystemReactor.scala:5: value Message is not a member of object com.fp.distractor.core.transport.api.TransportApi
[error] import com.fp.distractor.core.transport.api.TransportApi.{Message, Say}
[error]        ^
[error] /home/greg/dev/projects/private/distractor/src/main/scala/com/fp/distractor/core/reactor/info/SystemReactor.scala:20: not found: type Message
[error]       mixer forward new Say(new Message(shellCommandResponse))
[error]                                 ^
[error] /home/greg/dev/projects/private/distractor/src/main/scala/com/fp/distractor/core/transport/TransportRegistry.scala:11: not found: type Message
[error]   case class SendBroadcast(broadcast: Message)
[error]                                       ^
[error] four errors found
[error] (compile:compileIncremental) Compilation failed
[error] Total time: 6 s, completed 2015-09-04 18:47:33

Introduce activator wrapper/launcher instead of sbt.

Spike on creating reactor-api and transport-api.

To make distractor easier to extend, one idea was to work on a spike which gives API to easily create transports and reactors.

Bump akka to newest version: 2.3.13

Add CodeCoverage tool and make some decent test code coverage

Draw architecture overview

Switch packages

Switch from com.fp package into com.gmaslowski package

Add jenkins integration

listing jobs
listing specified job status
broadcasting build updates to all transports

Investigate why TelnetReactor cannot be restarted so easily. Introduce a retry restart for TelnetTransport.

akka.actor.ActorInitializationException: exception during creation
    at akka.actor.ActorInitializationException$.apply(Actor.scala:166)
    at akka.actor.ActorCell.create(ActorCell.scala:596)
    at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456)
    at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478)
    at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:263)
    at akka.dispatch.Mailbox.run(Mailbox.scala:219)
    at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397)
    at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
    at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.io.IOException: Error while binding on 0.0.0.0/0.0.0.0:8111