More flexible resource event parsing

Set received millis

Modified BillEntry so that resource events are grouped by service name (e.g. diskspace)

Add the versions key that pithos sends in details

Ensure java version and upgrade a couple of maven plugins

Squash a few message initialization bugs

Added Copyright notice and removed unused imports

Added support for parsing JSON the old way

Several fixes here and there => Removed all exceptions caused by Avro. Rolled back CachingPolicyStore load algorithm.

Fix some casting errors that had never appeared during compilation before. Ever

Initialize resource type map in new user state

Properly add userID in user agreement

Tmp check for the existense of user state

Initialize the proper var

Fix initialization of user agreement list

Fix initialization of userAgreementHistoryModel

Merge branch 'master' of https://code.grnet.gr/git/aquarium

Fixed selectorValue

Fix an NPE

Fix a bug with mongodb cursor

Update policy.json in test

Minor fix in BillTest

Merge branch 'master' of https://code.grnet.gr/git/aquarium

Conflicts:
src/main/scala/gr/grnet/aquarium/charging/ContinuousChargingBehavior.scala
src/main/scala/gr/grnet/aquarium/charging/bill/BillEntry.scala
src/test/scala/gr/grnet/aquarium/BillTest.scala

Now using schema-based messages

Fixed BillEntry: milliseconds are rounded off. BillTest can send ordered/out of order messages.

Finished scenarios and minor fixes.

Merge branch 'master' of https://code.grnet.gr/git/aquarium

Fixed RabbitMQProducer init delay. RabbitMQProducer is now a service.

Custom handling of diskspace details in virtual events. NOT GOOD.

Reverted chagned to BillEntry.

Merge branch 'master' of https://code.grnet.gr/git/aquarium

Minor fix in BillEntry (Virtual Resource event have no file path).

Now astakos also publishes resource events (for addcredits)

Fix json representation of numbers in the default policy

WIP integrating Avro-style policy messages

Change aliased to aliases in avro idl

Rename all messages

Rename conf to policy and make parentID optional (via null)

Added documentation to CronSpec and TimeslotComputations. Fixed a bug in ContinuousChargingBehavior. BillTest now sends more RC events to aquarium.

GenericPayloadHandler: one type less

Simplify the types of stored things

More Avro stuff

Move Avro generated classes to gen subpackage

Produce JSON policy configuration from Avro message

Add utility methods for message generation

Further additions to Avro messages

PolicyTest is failing.

Make unit name for addcredits uppercase

@inline a few trivial methods

Adjust the rest service to use the new json helpers

Add Avro-related helpers

Add some jackson-based json helpers

Jackson is pulled as a dependency from Avro and note that it is an old
version (< 2).

Added charging behavior for VMs and fixed BillEntry

One more test case with avro + json

Merge branch 'master' of https://code.grnet.gr/git/aquarium

Fixed RabbitMQProducer. Added BillTest.scala that simulates IM and RC events.

Add a test case for Avro-related message schema

Temporarily prefixing avro message names with _

Adding more Avro stuff

Enable deprecation warnings for javac

Remove simulation package

Aquarium is now configurable enough to not need a separate simulation
package.

Remove unused class

First-cut of Avro messages

Realtime calc for continuous charging behavior

Highly unoptimized and memory-unfriendly, proof of concept for the
moment.

Specific API for realtime calculations and first-cut implementation via virtual events

Fixed BillEntry

Remove unused code

Bill and BillEntry

Merge branch 'master' of https://code.grnet.gr/git/aquarium

Refactored BillEntry and relevant classes.

Implement Continuous behavior with the new scheme

Fix a bunch of related stuff in the process.

Another JSON-friendliness round

This time it could not deserialize due to some private field. Oh,
well...

Get rid of charging reason to make life easier with JSON

Unfortunately, the situation with JSON deserialization errors is getting
worse. I knew it, so I should have followed another path. Let me say it
once more:

Never, ever use string-based protocols/formats as your base.

Circa 2009: https://twitter.com/loverdos/status/5761681752

The bad news is that I do not have time to fix it in the next couple of
days due to a pending demo. Charging reason is not essential for the
demo, so I ditch it and put a reminder here so as to probably
reintroduce it in the future.

Add rabbitmq.imevents.credit property

Implement Once behavior with the new scheme. Refactor in the process

Fixed RabbitMQProducer. Now it is fully reliable.

Towards a perfect RabbitMQProducer -> actor not receiving msgs

Fixed ping.sh

added ping.sh

Change var to val

Adhere to existing naming conventions

NOTE: Test integration with the receiving system (Astakos).

WIP charging behavior

Minor fixes in UserActor, BillEntry and RabbitMQProducer

Merge branch 'master' of https://code.grnet.gr/git/aquarium

Finished Bill implementation. Added bill.sh to automatically send events and print the resulting bill

Merge selectors into master

NOTE: master was in DNC state (Does Not Compile).

Hook selectors into the price computation path

Use full type hints for json

Enable incremental compilation

Upgrade scala-maven-plugin

RabbitMQProducer handles Nacks. UserActor accepts user balance additions from Astakos. Timeslot.align has been fixed. Details Pings have been implemented.

Reliable message passing for RabbitMQProducer

Added REST functionality for the Bill. RabbitMQProducer was refined. UserActor sends message only when state changes

Selector simplifications

Merge branch 'master' into merged_master_selectors

minor fix in JSON message (UserActor-->Astakos , user balance)

RabbitMQ producer sends user balance >= 0 to astakos

First cut of selectors.

Pandora's box. Too simple. Too flexible.

Added RabbitMQProducer.scala. The code has been tests and works. "rabbitmq.imevents.credit=astakos:astakos-events-credit" must be added in aquarium.properties

Fix bad handling of IMEvent from the UserActor.

Upon arrival of the first IMEvent and after some ResourceEvents had
already arrived at the UserActor, we got an exception due to user
agreements beeing empty (being empty is reasonable, since there were no
IMEvent previously).

The correct behavior is to check for this case and then run
initializeStateOfIMEvents().

Removed timeslot computations print statements