Initial commit.

mark.george / docker-demo

Browse code Initial commit. master
0 parent commit 51ddf4aded54abf198b408e0146d31161d4bf98e Mark George authored on 26 Feb 2018

Patch

Showing 7 changed files

Ignore Space Show notes View build.gradle 0 → 100644
apply plugin: 'java' def joobyVer = '1.3.0' sourceSets { main { java { srcDir 'src' } resources { srcDirs = ['conf', 'public'] } } } repositories { jcenter() } dependencies { // https://mvnrepository.com/artifact/org.jooby/jooby compile group: 'org.jooby', name: 'jooby-netty', version: joobyVer // https://mvnrepository.com/artifact/org.jooby/jooby-gson compile group: 'org.jooby', name: 'jooby-gson', version: joobyVer // https://mvnrepository.com/artifact/org.jooby/jooby-apitool compile group: 'org.jooby', name: 'jooby-apitool', version: joobyVer }

Ignore Space Show notes View

build.gradle 0 → 100644

Ignore Space Show notes View conf/logback.xml 0 → 100644
<!-- logback logging configuration --> <configuration debug="false"> <contextListener class="ch.qos.logback.classic.jul.LevelChangePropagator"/> <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender"> <encoder> <pattern>%d{HH:mm:ss} %-5level %logger - %msg%n %ex{full}</pattern> </encoder> <!-- send all except ERROR to stdout --> <filter class="ch.qos.logback.classic.filter.LevelFilter"> <level>ERROR</level> <onMatch>DENY</onMatch> <onMismatch>ACCEPT</onMismatch> </filter> <target>System.out</target> </appender> <appender name="STDERR" class="ch.qos.logback.core.ConsoleAppender"> <encoder> <pattern>%d{HH:mm:ss} %-5level %logger - %msg%n %ex{full}</pattern> </encoder> <!-- send only ERROR to stderr --> <filter class="ch.qos.logback.classic.filter.ThresholdFilter"> <level>ERROR</level> </filter> <target>System.err</target> </appender> <!-- set default logging level --> <root level="info"> <appender-ref ref="STDOUT" /> <appender-ref ref="STDERR" /> </root> </configuration>

Ignore Space Show notes View

conf/logback.xml 0 → 100644

<configuration debug="false">

<encoder>
			<pattern>%d{HH:mm:ss} %-5level %logger - %msg%n %ex{full}</pattern>
		</encoder>

<filter class="ch.qos.logback.classic.filter.LevelFilter">
			<level>ERROR</level>
			<onMatch>DENY</onMatch>
			<onMismatch>ACCEPT</onMismatch>
		</filter>

<target>System.out</target>
	</appender>

<encoder>
			<pattern>%d{HH:mm:ss} %-5level %logger - %msg%n %ex{full}</pattern>
		</encoder>

<filter class="ch.qos.logback.classic.filter.ThresholdFilter">
			<level>ERROR</level>
		</filter>

<target>System.err</target>

</appender>

<root level="info">
		<appender-ref ref="STDOUT" />
		<appender-ref ref="STDERR" />
	</root>

</configuration>

Ignore Space Show notes View src/dao/ShoppingDAO.java 0 → 100644
package dao; import domain.ShoppingItem; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; public class ShoppingDAO { private static final Map<String, ShoppingItem> items = new HashMap<>(); static { if(items.isEmpty()) { items.put("bread", new ShoppingItem("bread", "wholegrain bread")); items.put("beer", new ShoppingItem("beer", "something tasty")); } } public List<ShoppingItem> getList() { return new ArrayList(items.values()); } public void addItem(ShoppingItem item) { items.put(item.getName(), item); } public ShoppingItem getByName(String itemName) { return items.get(itemName); } public void delete(String name) { items.remove(name); } public void updateItem(String name, ShoppingItem updatedItem) { items.put(name, updatedItem); } public boolean exists(String itemName) { return items.containsKey(itemName); } }

Ignore Space Show notes View

src/dao/ShoppingDAO.java 0 → 100644

Ignore Space Show notes View src/domain/ShoppingItem.java 0 → 100644
package domain; import java.io.Serializable; /** * An item to be managed by the shopping list. / public class ShoppingItem implements Serializable { private String name; private String description; public ShoppingItem() { } public ShoppingItem(String name, String description) { this.name = name; this.description = description; } /* * @return The list item's description. / public String getDescription() { return description; } /* * @param description The list item's description. / public void setDescription(String description) { this.description = description; } /* * @return The list item's name. / public String getName() { return name; } /* * @param name The list item's name (must be unique). */ public void setName(String name) { this.name = name; } @Override public String toString() { return "ShoppingItem{" + "name=" + name + ", description=" + description + '}'; } }

Ignore Space Show notes View

src/domain/ShoppingItem.java 0 → 100644

Ignore Space Show notes View src/resources/ShoppingItemResource.java 0 → 100644
package resources; import dao.ShoppingDAO; import domain.ShoppingItem; import org.jooby.Err; import org.jooby.Jooby; import org.jooby.MediaType; import org.jooby.Status; public class ShoppingItemResource extends Jooby { public ShoppingItemResource(ShoppingDAO dao) { path("/api/items/item", () -> { /** * Get an item. * * @param name The item's name. * @return The item matching the given name. / get("/:name", (req) -> { String name = req.param("name").value(); if (dao.exists(name)) { return dao.getByName(name); } else { throw new Err(Status.NOT_FOUND, "No item matches that name"); } }); /* * Delete an item from the list. * * @param name The name of the item to delete. / delete("/:name", (req, rsp) -> { String name = req.param("name").value(); if (dao.exists(name)) { dao.delete(name); rsp.status(Status.NO_CONTENT); } else { rsp.status(Status.NOT_FOUND); } }); /* * Update an existing item. * * @param name The name of the item to update. * @param body The new details for the item. */ put("/:name", (req, rsp) -> { String name = req.param("name").value(); ShoppingItem item = req.body().to(ShoppingItem.class); // make sure the names match an existing item or there is a conflict that will likely cause data corruption in the database (PKs should always be immutable) if (name.equals(item.getName()) && dao.exists(name)) { dao.updateItem(name, item); rsp.status(Status.ACCEPTED); } else { rsp.status(Status.CONFLICT); } }); }).produces(MediaType.json).consumes(MediaType.json); } }

Ignore Space Show notes View

src/resources/ShoppingItemResource.java 0 → 100644

package resources;

import dao.ShoppingDAO;
import domain.ShoppingItem;
import org.jooby.Err;
import org.jooby.Jooby;
import org.jooby.MediaType;
import org.jooby.Status;

public class ShoppingItemResource extends Jooby {

public ShoppingItemResource(ShoppingDAO dao) {

path("/api/items/item", () -> {

/**
			 * Get an item.
			 *
			 * @param name The item's name.
			 * @return The item matching the given name.
			 */
			get("/:name", (req) -> {
				String name = req.param("name").value();

if (dao.exists(name)) {
					return dao.getByName(name);
				} else {
					throw new Err(Status.NOT_FOUND, "No item matches that name");
				}

});

/**
			 * Delete an item from the list.
			 *
			 * @param name The name of the item to delete.
			 */
			delete("/:name", (req, rsp) -> {
				String name = req.param("name").value();

if (dao.exists(name)) {
					dao.delete(name);
					rsp.status(Status.NO_CONTENT);
				} else {
					rsp.status(Status.NOT_FOUND);
				}
			});

/**
			 * Update an existing item.
			 *
			 * @param name The name of the item to update.
			 * @param body The new details for the item.
			 */
			put("/:name", (req, rsp) -> {
				String name = req.param("name").value();
				ShoppingItem item = req.body().to(ShoppingItem.class);

// make sure the names match an existing item or there is a conflict that will likely cause data corruption in the database (PKs should always be immutable)
				if (name.equals(item.getName()) && dao.exists(name)) {
					dao.updateItem(name, item);
					rsp.status(Status.ACCEPTED);
				} else {
					rsp.status(Status.CONFLICT);
				}
			});

}).produces(MediaType.json).consumes(MediaType.json);

}

Ignore Space Show notes View src/resources/ShoppingListResource.java 0 → 100644
package resources; import dao.ShoppingDAO; import domain.ShoppingItem; import org.jooby.Jooby; import org.jooby.MediaType; import org.jooby.Status; public class ShoppingListResource extends Jooby { public ShoppingListResource(ShoppingDAO dao) { /** * A shopping list management service. / path("/api/items", () -> { /* * Lists the items in the shopping list. * * @return Items in the list. / get(() -> { return dao.getList(); }); /* * Add an item to the shopping list. * * @param body The item to add to the list. * @return 201 response if successful. */ post((req, rsp) -> { ShoppingItem item = req.body(ShoppingItem.class); dao.addItem(item); rsp.status(Status.CREATED); }); }).produces(MediaType.json).consumes(MediaType.json); } }

Ignore Space Show notes View

src/resources/ShoppingListResource.java 0 → 100644

Ignore Space Show notes View src/service/Server.java 0 → 100644
/* / package service; import dao.ShoppingDAO; import domain.ShoppingItem; import java.util.ArrayList; import org.jooby.Jooby; import org.jooby.apitool.ApiTool; import org.jooby.json.Gzon; import resources.ShoppingItemResource; import resources.ShoppingListResource; /* * Shopping List Service. */ public class Server extends Jooby { public Server() { super("Server"); ShoppingDAO dao = new ShoppingDAO(); // add support for JSON use(new Gzon()); use(new ShoppingListResource(dao)); use(new ShoppingItemResource(dao)); // add Swagger documentation use(new ApiTool().modify(r -> r.pattern().equals("/api/items"), route -> { // Fix response type since Swagger couldn't guess route.response().type(new ShoppingItem[0].getClass()); }).swagger()); } public static void main(String[] args) { new Server().start(); } }

Ignore Space Show notes View

src/service/Server.java 0 → 100644

Show line notes below