Initial commit for MoneyTransferAPI

Author: sonamko

.gitignore

@@ -0,0 +1,14 @@
+# ignore an entire directory
+/target/
+
+#ignore classpath
+.classpath
+
+#ignore IDE settings
+.idea/
+
+#ignore project files
+.project
+
+#ignore settings file
+.settings

pom.xml

@@ -0,0 +1,123 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+
+	<modelVersion>4.0.0</modelVersion>
+
+	<groupId>org.revolut</groupId>
+	<artifactId>moneytransfer</artifactId>
+	<packaging>jar</packaging>
+	<version>1.0</version>
+	<name>moneytransfer</name>
+
+	<properties>
+		<maven.compiler.source>1.8</maven.compiler.source>
+		<maven.compiler.target>1.8</maven.compiler.target>
+		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+	</properties>
+
+
+
+	<dependencies>
+		<dependency>
+			<groupId>org.glassfish.jersey.test-framework.providers</groupId>
+			<artifactId>jersey-test-framework-provider-grizzly2</artifactId>
+			<version>2.7</version>
+			<scope>test</scope>
+		</dependency>
+
+		<dependency>
+			<groupId>junit</groupId>
+			<artifactId>junit</artifactId>
+			<version>4.12</version>
+			<scope>test</scope>
+		</dependency>
+
+		<dependency>
+			<groupId>org.hamcrest</groupId>
+			<artifactId>hamcrest-all</artifactId>
+			<version>1.3</version>
+			<scope>test</scope>
+		</dependency>
+
+		<dependency>
+			<groupId>org.eclipse.jetty</groupId>
+			<artifactId>jetty-server</artifactId>
+			<version>9.2.3.v20140905</version>
+		</dependency>
+		<dependency>
+			<groupId>org.eclipse.jetty</groupId>
+			<artifactId>jetty-servlet</artifactId>
+			<version>9.2.3.v20140905</version>
+		</dependency>
+		<dependency>
+			<groupId>org.glassfish.jersey.core</groupId>
+			<artifactId>jersey-server</artifactId>
+			<version>2.7</version>
+		</dependency>
+		<dependency>
+			<groupId>org.glassfish.jersey.containers</groupId>
+			<artifactId>jersey-container-servlet-core</artifactId>
+			<version>2.7</version>
+		</dependency>
+		<dependency>
+			<groupId>org.glassfish.jersey.containers</groupId>
+			<artifactId>jersey-container-jetty-http</artifactId>
+			<version>2.7</version>
+		</dependency>
+		<dependency>
+			<groupId>org.glassfish.jersey.media</groupId>
+			<artifactId>jersey-media-moxy</artifactId>
+			<version>2.7</version>
+		</dependency>
+
+		<dependency>
+			<groupId>org.glassfish.jersey.ext</groupId>
+			<artifactId>jersey-bean-validation</artifactId>
+			<version>2.7</version>
+		</dependency>
+	</dependencies>
+
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-shade-plugin</artifactId>
+				<version>1.6</version>
+				<configuration>
+					<createDependencyReducedPom>true</createDependencyReducedPom>
+					<filters>
+						<filter>
+							<artifact>*:*</artifact>
+							<excludes>
+								<exclude>META-INF/*.SF</exclude>
+								<exclude>META-INF/*.DSA</exclude>
+								<exclude>META-INF/*.RSA</exclude>
+							</excludes>
+						</filter>
+					</filters>
+				</configuration>
+
+				<executions>
+					<execution>
+						<phase>package</phase>
+						<goals>
+							<goal>shade</goal>
+						</goals>
+						<configuration>
+							<transformers>
+								<transformer
+									implementation="org.apache.maven.plugins.shade.resource.ServicesResourceTransformer" />
+								<transformer
+									implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
+									<manifestEntries>
+										<Main-Class>org.revolut.moneytransfer.Main</Main-Class>
+									</manifestEntries>
+								</transformer>
+							</transformers>
+						</configuration>
+					</execution>
+				</executions>
+			</plugin>
+		</plugins>
+	</build>
+</project>

src/main/java/org/revolut/moneytransfer/Main.java

@@ -0,0 +1,34 @@
+package org.revolut.moneytransfer;
+
+import org.revolut.moneytransfer.exception.CustomExceptionMapper;
+import org.revolut.moneytransfer.resource.TransactionResource;
+import org.revolut.moneytransfer.resource.UserAccountResource;
+import org.eclipse.jetty.server.Server;
+import org.eclipse.jetty.servlet.ServletContextHandler;
+import org.eclipse.jetty.servlet.ServletHolder;
+
+public class Main {
+
+	public static void main(String[] args) throws Exception {
+		ServletContextHandler context = new ServletContextHandler(ServletContextHandler.SESSIONS);
+		context.setContextPath("/");
+
+		Server jettyServer = new Server(8080);
+		jettyServer.setHandler(context);
+
+		ServletHolder jerseyServlet = context.addServlet(org.glassfish.jersey.servlet.ServletContainer.class, "/*");
+		jerseyServlet.setInitOrder(0);
+
+		jerseyServlet.setInitParameter("jersey.config.server.provider.classnames",
+				UserAccountResource.class.getCanonicalName() + "," + CustomExceptionMapper.class.getCanonicalName()
+						+ "," + TransactionResource.class.getCanonicalName());
+
+		try {
+			jettyServer.start();
+			jettyServer.join();
+		} finally {
+			jettyServer.destroy();
+		}
+	}
+
+}

src/main/java/org/revolut/moneytransfer/constants/Constants.java

@@ -0,0 +1,13 @@
+package org.revolut.moneytransfer.constants;
+
+public class Constants {
+	public static final String USERS_DOES_NOT_EXISTS = "Users does not exists";
+	public static final String AMOUNT_TRANSFERED_SUCCESSFULLY = "Amount transfered successfully";
+	public static final String AMOUNT_WITHDRAWN_SUCCESSFULLY = "Amount withdrawn successfully";
+	public static final String USER_DOES_NOT_HAVE_SUFFICIENT_BALANCE = "User does not have sufficient balance";
+	public static final String AMOUNT_DEPOSITED_SUCCESSFULLY = "Amount deposited successfully";
+	public static final String USER_DOES_NOT_EXISTS = "User does not exists";
+	public static final String USER_ACCOUNT_DELETED_SUCCESSFULLY = "User Account deleted successfully";
+	public static final String USER_ACCOUNT_UPDATED_SUCCESSFULLY = "User Account updated successfully";
+	public static final String USER_CREATED_SUCCESFULLY = "User created succesfully";
+}

src/main/java/org/revolut/moneytransfer/dao/InMemoryDataStore.java

@@ -0,0 +1,27 @@
+package org.revolut.moneytransfer.dao;
+
+import java.util.concurrent.ConcurrentHashMap;
+
+import org.revolut.moneytransfer.model.UserAcount;
+
+
+public class InMemoryDataStore {
+	
+	public static ConcurrentHashMap<Long, UserAcount> map= new ConcurrentHashMap<>();
+	
+	static
+	{
+		map.put(1L, new UserAcount(1, "TEST1", "100"));
+		map.put(2L,new UserAcount(2, "TEST2", "100"));
+	}
+
+	public static ConcurrentHashMap<Long, UserAcount> getMap() {
+		return map;
+	}
+
+	public static void setMap(ConcurrentHashMap<Long, UserAcount> map) {
+		InMemoryDataStore.map = map;
+	}
+	
+	
+}

src/main/java/org/revolut/moneytransfer/exception/CustomExceptionMapper.java

@@ -0,0 +1,35 @@
+package org.revolut.moneytransfer.exception;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Set;
+
+import javax.validation.ConstraintViolation;
+import javax.validation.ConstraintViolationException;
+import javax.ws.rs.core.GenericEntity;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
+import javax.ws.rs.core.Response.Status;
+import javax.ws.rs.ext.ExceptionMapper;
+import javax.ws.rs.ext.Provider;
+
+import org.revolut.moneytransfer.model.ErrorEntity;
+
+@Provider
+public class CustomExceptionMapper implements ExceptionMapper<ConstraintViolationException> {
+
+	@Override
+	public Response toResponse(ConstraintViolationException e) {
+		Set<ConstraintViolation<?>> violations = e.getConstraintViolations();
+		List<ErrorEntity> errors = new ArrayList<>();
+		for (ConstraintViolation<?> violation : violations) {
+			ErrorEntity error = new ErrorEntity();
+			error.setErrorMsg(violation.getMessage());
+			errors.add(error);
+		}
+		GenericEntity<List<ErrorEntity>> messages = new GenericEntity<List<ErrorEntity>>(errors) {
+		};
+		return Response.status(Status.BAD_REQUEST).entity(messages).type(MediaType.APPLICATION_JSON).build();
+	}
+
+}

src/main/java/org/revolut/moneytransfer/model/CustomResponse.java

@@ -0,0 +1,31 @@
+package org.revolut.moneytransfer.model;
+
+import javax.ws.rs.core.Response.Status;
+
+public class CustomResponse {
+	private Object obj;
+	private Status responseCode;
+	
+	
+	public CustomResponse(Object obj, Status responseCode) {
+		this.obj = obj;
+		this.responseCode = responseCode;
+	}
+	
+	public Object getObject() {
+		return obj;
+	}
+	public void setObject(Object object) {
+		this.obj = object;
+	}
+	public Status getResponse() {
+		return responseCode;
+	}
+	public void setResponse(Status responseCode) {
+		this.responseCode = responseCode;
+	} 
+	
+	
+	
+
+}

src/main/java/org/revolut/moneytransfer/model/ErrorEntity.java

@@ -0,0 +1,20 @@
+package org.revolut.moneytransfer.model;
+
+import javax.xml.bind.annotation.XmlRootElement;
+
+@XmlRootElement
+public class ErrorEntity {
+	
+	private String errorMsg;
+
+	public String getErrorMsg() {
+		return errorMsg;
+	}
+
+	public void setErrorMsg(String errorMsg) {
+		this.errorMsg = errorMsg;
+	}
+	
+	
+
+}

src/main/java/org/revolut/moneytransfer/model/Transaction.java

@@ -0,0 +1,62 @@
+package org.revolut.moneytransfer.model;
+
+import javax.validation.constraints.Min;
+import javax.validation.constraints.Pattern;
+import javax.xml.bind.annotation.XmlAccessType;
+import javax.xml.bind.annotation.XmlAccessorType;
+import javax.xml.bind.annotation.XmlRootElement;
+
+import org.hibernate.validator.constraints.NotBlank;
+
+@XmlRootElement
+@XmlAccessorType(XmlAccessType.FIELD)
+public class Transaction {
+
+	private long fromUserId;
+	private long toUserId;
+	@Min(value = 1, message = "Amount should be greater than 0")
+	@NotBlank(message = "Amount should not be empty")
+	@Pattern(regexp = "[0-9]+", message = "Balance must be a valid number")
+	private String amount;
+
+	public Transaction() {
+
+	}
+
+	public Transaction(long fromUserId, long toUserId, String amount) {
+		super();
+		this.fromUserId = fromUserId;
+		this.toUserId = toUserId;
+		this.amount = amount;
+	}
+
+	public long getFromUserId() {
+		return fromUserId;
+	}
+
+	public void setFromUserId(long fromUserId) {
+		this.fromUserId = fromUserId;
+	}
+
+	public void setAmount(Long amount) {
+		this.amount = amount.toString();
+	}
+
+	public long getToUserId() {
+		return toUserId;
+	}
+
+	public void setToUserId(long toUserId) {
+		this.toUserId = toUserId;
+	}
+
+	public long getAmount() {
+		return Long.parseLong(amount);
+	}
+
+	@Override
+	public String toString() {
+		return "Transaction [fromUserId=" + fromUserId + ", toUserId=" + toUserId + ", amount=" + amount + "]";
+	}
+
+}