Added storage service, add save via feign.

Author: alex-muliarevych

config/rating-service.properties

@@ -17,5 +17,6 @@
 		<module>rating-service</module>
 		<module>hackster-service</module>
 		<module>realtor-service</module>
+		<module>storage-service</module>>
 	</modules>
 </project>

pom.xml

@@ -45,6 +45,21 @@
 			<artifactId>lombok</artifactId>
 			<version>1.16.12</version>
 		</dependency>
+		<dependency>
+			<groupId>io.github.openfeign</groupId>
+			<artifactId>feign-okhttp</artifactId>
+			<version>9.3.1</version>
+		</dependency>
+		<dependency>
+			<groupId>io.github.openfeign</groupId>
+			<artifactId>feign-gson</artifactId>
+			<version>9.3.1</version>
+		</dependency>
+		<dependency>
+			<groupId>io.github.openfeign</groupId>
+			<artifactId>feign-slf4j</artifactId>
+			<version>9.3.1</version>
+		</dependency>
 	</dependencies>
 
 	<dependencyManagement>

realtor-service/pom.xml

@@ -17,4 +17,6 @@ public class ApartmentRecord {
   private String phone;
   @NonNull
   private String realtorName;
+  @NonNull
+  private String mail;
 }

realtor-service/src/main/java/com/lohika/jclub/ApartmentRecord.java

@@ -0,0 +1,14 @@
+package com.lohika.jclub;
+
+import feign.Headers;
+import feign.RequestLine;
+
+/**
+ * Created by omuliarevych on 6/8/17.
+ */
+public interface ApartmentRecordClient {
+
+    @RequestLine("POST /apartmentRecords")
+    @Headers("Content-Type: application/json")
+    void storeApartment(ApartmentRecord apartmentRecord);
+}

realtor-service/src/main/java/com/lohika/jclub/ApartmentRecordClient.java

@@ -21,6 +21,9 @@ public class RealtorController {
     @Autowired
     private RestTemplate restTemplate;
 
+    @Autowired
+    private RealtorService realtorService;
+
     @PostMapping("/apartments")
     public void addApartment(@RequestBody ApartmentRecord apartmentRecord) {
         ResponseEntity<Boolean> isHackster =
@@ -29,6 +32,15 @@ public void addApartment(@RequestBody ApartmentRecord apartmentRecord) {
         log.info("Is hackster " + isHackster);
     }
 
+    @PostMapping("/storeApartments")
+    public void storeApartment(@RequestBody ApartmentRecord apartmentRecord) {
+        realtorService.storeApartment(apartmentRecord);
+        /*ApartmentRecordClient apartmentRecordClient = Feign.builder().encoder(new JacksonEncoder())
+                .decoder(new JacksonDecoder()).target(ApartmentRecordClient.class, "http://storage-service");
+        apartmentRecordClient.storeApartment(apartmentRecord);*/
+        log.info("Stored");
+    }
+
     @RequestMapping("/service-instances/{applicationName}")
     public List<ServiceInstance> serviceInstancesByApplicationName(@PathVariable String applicationName) {
         return this.discoveryClient.getInstances(applicationName);

realtor-service/src/main/java/com/lohika/jclub/RealtorController.java

@@ -4,9 +4,13 @@
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
 import org.springframework.cloud.client.loadbalancer.LoadBalanced;
+import org.springframework.cloud.netflix.feign.EnableFeignClients;
+import org.springframework.cloud.netflix.feign.FeignClient;
 import org.springframework.context.annotation.Bean;
+import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.client.RestTemplate;
 
+@EnableFeignClients
 @EnableDiscoveryClient
 @SpringBootApplication
 public class RealtorServiceApplication {
@@ -21,3 +25,9 @@ public RestTemplate restTemplate() {
 		return new RestTemplate();
 	}
 }
+
+@FeignClient("storage-service")
+interface RealtorService {
+	@PostMapping("/apartmentRecords")
+	void storeApartment(ApartmentRecord apartmentRecord);
+}

realtor-service/src/main/java/com/lohika/jclub/RealtorServiceApplication.java

@@ -0,0 +1,25 @@
+package com.lohika.jclub;
+
+import lombok.*;
+
+import javax.persistence.Entity;
+import javax.persistence.Id;
+
+@NoArgsConstructor
+@AllArgsConstructor
+@Data
+@Entity
+public class ApartmentRecord {
+  @NonNull
+  private String location;
+  @NonNull
+  private double price;
+  @NonNull
+  private double sqft;
+  @NonNull
+  private String phone;
+  @NonNull
+  private String realtorName;
+  @Id
+  private String mail;
+}

storage-service/src/main/java/com/lohika/jclub/ApartmentRecord.java

@@ -0,0 +1,11 @@
+package com.lohika.jclub;
+
+import org.springframework.data.repository.CrudRepository;
+import org.springframework.data.rest.core.annotation.RepositoryRestResource;
+
+/**
+ * Created by omuliarevych on 6/8/17.
+ */
+@RepositoryRestResource
+public interface ApartmentRepository extends CrudRepository<ApartmentRecord, String> {
+}