#12 Support for userLogon and userSession UserActivity.

src/main/resources/db/manual/create_users-mysql.sql

@@ -1,6 +1,6 @@
 #Normal User
 CREATE USER 'vr'@'localhost' IDENTIFIED BY 'vr1234';
-GRANT DELETE,INSERT,SELECT,UPDATE ON ValueReporter.* TO 'vr'@'localhost';
+GRANT CREATE,DELETE,INSERT,SELECT,UPDATE ON ValueReporter.* TO 'vr'@'localhost';
 
 #Admin
 CREATE USER 'vrAdmin'@'localhost' IDENTIFIED BY 'vrAdmin1234';

src/main/resources/db/migration/mysql/V2__Create_UserActivityTables.sql

@@ -0,0 +1,15 @@
+use ValueReporter;
+CREATE TABLE IF NOT EXISTS userLogon (
+  id bigint auto_increment primary key,
+  starttime TIMESTAMP  NOT NULL,
+  userid varchar(255)  NOT NULL
+);
+
+CREATE TABLE IF NOT EXISTS userSession (
+  id bigint auto_increment primary key,
+  starttime TIMESTAMP  NOT NULL,
+  userid varchar(255)  NOT NULL,
+  usersessionfunction varchar(255),
+  applicationtokenid varchar(255)  NOT NULL,
+  applicationid varchar(255)  NOT NULL
+);

src/test/java/org/valuereporter/activity/ObservedActivitiesIntegrationTest.java

@@ -14,15 +14,15 @@ public static void main(String[] args) throws InterruptedException {
         String reporterPort = "4901";
         String prefix = "test";
         int cacheSize = 1;
-        int forwardInterval = 1000;
+        int forwardInterval = 10;
         new Thread(new ObservedActivityDistributer(reporterHost, reporterPort, prefix, cacheSize, forwardInterval)).start();
 
 
         String userid = "TODO";
         do {
             org.valuereporter.agent.activity.ObservedActivity observedActivity = new UserLogonObservedActivity(userid);
             MonitorReporter.reportActivity(observedActivity);
-            Thread.sleep(10000);
+            Thread.sleep(100);
         } while (true);
     }
 }