Done DTO classes

.gitignore

@@ -1,2 +1,3 @@
-C:\Users\DankessS\workspace\ClickMapActivity\.idea
+\ClickMapActivity\.idea
 /.idea/
+\ClickMapActivity-web\src\main\resources\js\bower_components

ClickMapActivity-cache/build.gradle

@@ -0,0 +1,18 @@
+group 'com.academy.engineer'
+version '1.0-SNAPSHOT'
+
+apply plugin: 'java'
+apply plugin: 'spring-boot'
+
+sourceCompatibility = 1.8
+targetCompatibility = 1.8
+
+repositories {
+    mavenCentral()
+}
+
+dependencies {
+    compile 'com.hazelcast:hazelcast:3.7.1'
+    compile ("org.springframework.boot:spring-boot-starter-data-jpa")
+    compile ("org.springframework.boot:spring-boot-starter-web")
+}

ClickMapActivity-cache/src/main/java/com/academy/cache/AbstractCacheSupplier.java

@@ -0,0 +1,24 @@
+package com.academy.cache;
+
+import com.hazelcast.core.HazelcastInstance;
+import com.hazelcast.core.IMap;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.util.concurrent.ConcurrentMap;
+
+/**
+ * Created by Daniel Palonek on 2016-09-17.
+ */
+public abstract class AbstractCacheSupplier {
+
+    @Autowired
+    private HazelcastInstance hazelcastInstance;
+
+    protected ConcurrentMap<String,Object> getUserContext() {
+        return hazelcastInstance.getUserContext();
+    }
+
+    protected IMap getMap(String mapName) {
+        return hazelcastInstance.getMap(mapName);
+    }
+}

ClickMapActivity-cache/src/main/java/com/academy/cache/CacheConstants.java

@@ -0,0 +1,15 @@
+package com.academy.cache;
+
+/**
+ * Created by Daniel Palonek on 2016-09-05.
+ */
+public class CacheConstants {
+
+    static final String LOGGED_USERNAME = "loggedUsername";
+    static final String USER_WEBSITES = "userWebsites";
+    static final String REQUESTED_WEBSITE = "requestedWebsite";
+    static final String WEBSITE_SUBPAGES = "websiteSubpages";
+    static final String ACTIVITIES = "activities";
+    static final String POINTS = "points";
+
+}

ClickMapActivity-cache/src/main/java/com/academy/cache/HazelcastConfiguration.java

@@ -0,0 +1,21 @@
+package com.academy.cache;
+
+import com.hazelcast.config.Config;
+import com.hazelcast.config.XmlConfigBuilder;
+import com.hazelcast.core.Hazelcast;
+import com.hazelcast.core.HazelcastInstance;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.io.FileNotFoundException;
+
+/**
+ * Created by Daniel Palonek on 2016-09-05.
+ */
+@Configuration
+public class HazelcastConfiguration {
+    @Bean
+    public HazelcastInstance config() {
+        return Hazelcast.newHazelcastInstance();
+    }
+}

ClickMapActivity-cache/src/main/java/com/academy/cache/UserCache.java

@@ -0,0 +1,107 @@
+package com.academy.cache;
+
+import org.springframework.stereotype.Component;
+
+import java.util.*;
+import java.util.stream.Collectors;
+import java.util.stream.StreamSupport;
+
+import static java.util.stream.StreamSupport.stream;
+
+/**
+ * Created by Daniel Palonek on 2016-09-16.
+ */
+@Component
+public class UserCache extends AbstractCacheSupplier {
+
+    public String getLoggedUsername() {
+         return (String)getUserContext().getOrDefault(CacheConstants.LOGGED_USERNAME,null);
+    }
+
+    public void setLoggedUsername(String username) {
+        getUserContext().put(CacheConstants.LOGGED_USERNAME,username);
+    }
+
+    public void removeLoggedUsername() {
+        getUserContext().remove(CacheConstants.LOGGED_USERNAME);
+    }
+
+    public void setUserWebsites(Iterable websites) {
+        getMap(CacheConstants.USER_WEBSITES).set(getLoggedUsername(),websites);
+    }
+
+    public Iterable getUserWebsites() {
+        return (Iterable)getMap(CacheConstants.USER_WEBSITES).get(getLoggedUsername());
+    }
+
+    public void removeUserWebsites() {
+        getMap(CacheConstants.USER_WEBSITES).remove(getLoggedUsername());
+    }
+
+    public void setRequestedWebsite(Object website) {
+        getUserContext().put(CacheConstants.REQUESTED_WEBSITE,website);
+    }
+
+    public Object getRequestedWebsite() {
+        return getUserContext().getOrDefault(CacheConstants.REQUESTED_WEBSITE,null);
+    }
+
+    public void setWebsiteSubpages(Long websiteId, Map<Long, Object> subpages) {
+        getMap(CacheConstants.WEBSITE_SUBPAGES).set(websiteId, subpages);
+    }
+
+    public void updateWebsiteSubpage(Long websiteId, Long subpageId, Object subpage) {
+        Map<Long, Object> subpages = (Map)getMap(CacheConstants.WEBSITE_SUBPAGES).get(websiteId);
+        if(subpages == null) {
+            subpages = new HashMap<>();
+        }
+        subpages.put(subpageId, subpage);
+        getMap(CacheConstants.WEBSITE_SUBPAGES).set(websiteId, subpages);
+    }
+
+    public Iterable getWebsiteSubpages(Long key) {
+        Map<Long, Object> subpages = (Map)getMap(CacheConstants.WEBSITE_SUBPAGES).get(key);
+        return subpages.entrySet().stream().map(Map.Entry::getValue).collect(Collectors.toList());
+    }
+
+    public void deleteWebsiteSubpages(Long websiteId) {
+        getMap(CacheConstants.WEBSITE_SUBPAGES).removeAsync(websiteId);
+    }
+
+    public void setSubpageActivities(Long subpageId, Iterable activities) {
+        getMap(CacheConstants.ACTIVITIES).set(subpageId,activities);
+    }
+
+    public synchronized void addSubpageActivity(Long subpageId, Object activity) {
+        Iterable values = (Iterable)getMap(CacheConstants.ACTIVITIES).get(subpageId);
+        if(values != null) {
+            List l = (List)StreamSupport.stream(values.spliterator(),false).collect(Collectors.toList());
+            l.add(activity);
+            getMap(CacheConstants.ACTIVITIES).set(subpageId, l);
+        } else {
+            List c = Arrays.asList(activity);
+            getMap(CacheConstants.ACTIVITIES).set(subpageId, c);
+        }
+    }
+
+    public Iterable getSubpageActivities(Long subpageId) {
+        return (Iterable)getMap(CacheConstants.ACTIVITIES).get(subpageId);
+    }
+
+    public void deleteSubpageActivities(Long subpageId) {
+        getMap(CacheConstants.ACTIVITIES).removeAsync(subpageId);
+    }
+
+    public void setActivityPoints(Long activityId, Iterable points) {
+        getMap(CacheConstants.POINTS).set(activityId, points);
+    }
+
+    public Iterable getActivityPoints(Long activityId) {
+        return (Iterable)getMap(CacheConstants.POINTS).get(activityId);
+    }
+
+    public void deleteActivityPoints(Long activityId) {
+        getMap(CacheConstants.POINTS).removeAsync(activityId);
+    }
+
+}

ClickMapActivity-cache/src/main/resources/hazelcast.xml

@@ -0,0 +1,192 @@
+<hazelcast xsi:schemaLocation="http://www.hazelcast.com/schema/config hazelcast-config-3.7.xsd"
+           xmlns="http://www.hazelcast.com/schema/config"
+           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
+    <group>
+        <name>dev</name>
+        <password>dev-pass</password>
+    </group>
+    <management-center enabled="false">http://localhost:8080/mancenter</management-center>
+    <network>
+        <port auto-increment="true" port-count="100">5701</port>
+        <outbound-ports>
+            <!--
+            Allowed port range when connecting to other nodes.
+            0 or * means use system provided port.
+            -->
+            <ports>0</ports>
+        </outbound-ports>
+        <join>
+            <multicast enabled="true">
+                <multicast-group>224.2.2.3</multicast-group>
+                <multicast-port>54327</multicast-port>
+            </multicast>
+            <tcp-ip enabled="false">
+                <interface>127.0.0.1</interface>
+                <member-list>
+                    <member>127.0.0.1</member>
+                </member-list>
+            </tcp-ip>
+            <aws enabled="false">
+                <access-key>my-access-key</access-key>
+                <secret-key>my-secret-key</secret-key>
+                <!--optional, default is us-east-1 -->
+                <region>us-west-1</region>
+                <!--optional, default is ec2.amazonaws.com. If set, region shouldn't be set as it will override this property -->
+                <host-header>ec2.amazonaws.com</host-header>
+                <!-- optional, only instances belonging to this group will be discovered, default will try all running instances -->
+                <security-group-name>hazelcast-sg</security-group-name>
+                <tag-key>type</tag-key>
+                <tag-value>hz-nodes</tag-value>
+            </aws>
+            <discovery-strategies>
+            </discovery-strategies>
+        </join>
+        <interfaces enabled="false">
+            <interface>10.10.1.*</interface>
+        </interfaces>
+        <ssl enabled="false"/>
+        <socket-interceptor enabled="false"/>
+        <symmetric-encryption enabled="false">
+            <!--
+               encryption algorithm such as
+               DES/ECB/PKCS5Padding,
+               PBEWithMD5AndDES,
+               AES/CBC/PKCS5Padding,
+               Blowfish,
+               DESede
+            -->
+            <algorithm>PBEWithMD5AndDES</algorithm>
+            <!-- salt value to use when generating the secret key -->
+            <salt>thesalt</salt>
+            <!-- pass phrase to use when generating the secret key -->
+            <password>thepass</password>
+            <!-- iteration count to use when generating the secret key -->
+            <iteration-count>19</iteration-count>
+        </symmetric-encryption>
+    </network>
+    <partition-group enabled="false"/>
+    <executor-service name="default">
+        <pool-size>16</pool-size>
+        <!--Queue capacity. 0 means Integer.MAX_VALUE.-->
+        <queue-capacity>0</queue-capacity>
+    </executor-service>
+    <queue name="default">
+        <!--
+            Maximum size of the queue. When a JVM's local queue size reaches the maximum,
+            all put/offer operations will get blocked until the queue size
+            of the JVM goes down below the maximum.
+            Any integer between 0 and Integer.MAX_VALUE. 0 means
+            Integer.MAX_VALUE. Default is 0.
+        -->
+        <max-size>0</max-size>
+        <!--
+            Number of backups. If 1 is set as the backup-count for example,
+            then all entries of the map will be copied to another JVM for
+            fail-safety. 0 means no backup.
+        -->
+        <backup-count>1</backup-count>
+
+        <!--
+            Number of async backups. 0 means no backup.
+        -->
+        <async-backup-count>0</async-backup-count>
+
+        <empty-queue-ttl>-1</empty-queue-ttl>
+    </queue>
+    <map name="userWebsites">
+        <in-memory-format>BINARY</in-memory-format>
+        <backup-count>1</backup-count>
+        <async-backup-count>0</async-backup-count>
+        <time-to-live-seconds>24000</time-to-live-seconds>
+        <max-idle-seconds>24000</max-idle-seconds>
+        <eviction-policy>LRU</eviction-policy>
+        <max-size policy="PER_NODE">0</max-size>
+        <merge-policy>com.hazelcast.map.merge.PutIfAbsentMapMergePolicy</merge-policy>
+        <cache-deserialized-values>INDEX-ONLY</cache-deserialized-values>
+    </map>
+    <map name="websiteSubpages">
+        <in-memory-format>BINARY</in-memory-format>
+        <backup-count>1</backup-count>
+        <async-backup-count>0</async-backup-count>
+        <time-to-live-seconds>24000</time-to-live-seconds>
+        <max-idle-seconds>24000</max-idle-seconds>
+        <eviction-policy>LRU</eviction-policy>
+        <max-size policy="PER_NODE">0</max-size>
+        <merge-policy>com.hazelcast.map.merge.PutIfAbsentMapMergePolicy</merge-policy>
+        <cache-deserialized-values>INDEX-ONLY</cache-deserialized-values>
+    </map>
+    <map name="activities">
+        <in-memory-format>BINARY</in-memory-format>
+        <backup-count>1</backup-count>
+        <async-backup-count>0</async-backup-count>
+        <time-to-live-seconds>24000</time-to-live-seconds>
+        <max-idle-seconds>24000</max-idle-seconds>
+        <eviction-policy>LRU</eviction-policy>
+        <max-size policy="PER_NODE">0</max-size>
+        <merge-policy>com.hazelcast.map.merge.PutIfAbsentMapMergePolicy</merge-policy>
+        <cache-deserialized-values>INDEX-ONLY</cache-deserialized-values>
+    </map>
+    <map name="points">
+        <in-memory-format>BINARY</in-memory-format>
+        <backup-count>1</backup-count>
+        <async-backup-count>0</async-backup-count>
+        <time-to-live-seconds>24000</time-to-live-seconds>
+        <max-idle-seconds>24000</max-idle-seconds>
+        <eviction-policy>LRU</eviction-policy>
+        <max-size policy="PER_NODE">0</max-size>
+        <merge-policy>com.hazelcast.map.merge.PutIfAbsentMapMergePolicy</merge-policy>
+        <cache-deserialized-values>INDEX-ONLY</cache-deserialized-values>
+    </map>
+
+    <multimap name="default">
+        <backup-count>1</backup-count>
+        <value-collection-type>SET</value-collection-type>
+    </multimap>
+
+    <list name="default">
+        <backup-count>1</backup-count>
+    </list>
+
+    <set name="default">
+        <backup-count>1</backup-count>
+    </set>
+
+    <jobtracker name="default">
+        <max-thread-size>0</max-thread-size>
+        <!-- Queue size 0 means number of partitions * 2 -->
+        <queue-size>0</queue-size>
+        <retry-count>0</retry-count>
+        <chunk-size>1000</chunk-size>
+        <communicate-stats>true</communicate-stats>
+        <topology-changed-strategy>CANCEL_RUNNING_OPERATION</topology-changed-strategy>
+    </jobtracker>
+
+    <semaphore name="default">
+        <initial-permits>0</initial-permits>
+        <backup-count>1</backup-count>
+        <async-backup-count>0</async-backup-count>
+    </semaphore>
+
+    <reliable-topic name="default">
+        <read-batch-size>10</read-batch-size>
+        <topic-overload-policy>BLOCK</topic-overload-policy>
+        <statistics-enabled>true</statistics-enabled>
+    </reliable-topic>
+
+    <ringbuffer name="default">
+        <capacity>10000</capacity>
+        <backup-count>1</backup-count>
+        <async-backup-count>0</async-backup-count>
+        <time-to-live-seconds>30</time-to-live-seconds>
+        <in-memory-format>BINARY</in-memory-format>
+    </ringbuffer>
+
+    <serialization>
+        <portable-version>0</portable-version>
+    </serialization>
+
+    <services enable-defaults="true"/>
+
+    <lite-member enabled="false"/>
+
+</hazelcast>