FROM maven:3.6.2-jdk-11-slim as builder

WORKDIR /app

COPY pom.xml .

COPY src ./src

RUN mvn compile assembly:single

FROM adoptopenjdk/openjdk11:alpine

RUN apk --no-cache add graphviz ttf-ubuntu-font-family

COPY --from=builder /app/target/hello-broken-*dependencies.jar /hello-broken.jar

CMD ["java","-jar","/hello-broken.jar"]

This sample presents broken code in need of troubleshooting. An alternate

resource at `/improved` shows a more stable implementation with more informative

errors and default values.

Use it with the [Local Container Troubleshooting tutorial](http://cloud.google.com/run/docs/tutorials/local-troubleshooting).

For more details on how to work with this sample read the [Google Cloud Run Java Samples README](https://github.com/GoogleCloudPlatform/java-docs-samples/tree/master/run).

[![Run in Google Cloud][run_img]][run_link]

[run_img]: https://storage.googleapis.com/cloudrun/button.svg

[run_link]: https://deploy.cloud.run/?git_repo=https://github.com/GoogleCloudPlatform/java-docs-samples&dir=run/hello-broken

* **Spark**: Web server framework.

* **Junit**: [development] Test running framework.

<?xml version="1.0" encoding="UTF-8"?>

<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 https://maven.apache.org/xsd/maven-4.0.0.xsd">

<modelVersion>4.0.0</modelVersion>

<groupId>com.example.cloudrun</groupId>

<artifactId>hello-broken</artifactId>

<version>0.0.1-SNAPSHOT</version>

<!-- The parent pom defines common style checks and testing strategies for our samples. Removing or replacing it should not affect the execution of the samples in anyway. -->

<parent>

<groupId>com.google.cloud.samples</groupId>

<artifactId>shared-configuration</artifactId>

<version>1.0.11</version>

</parent>

<properties>

<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

<maven.compiler.source>11</maven.compiler.source>

<maven.compiler.target>11</maven.compiler.target>

</properties>

<dependencies>

<dependency>

<groupId>com.sparkjava</groupId>

<artifactId>spark-core</artifactId>

<version>2.8.0</version>

</dependency>

<dependency>

<groupId>ch.qos.logback</groupId>

<artifactId>logback-classic</artifactId>

<version>1.3.0-alpha4</version>

</dependency>

<dependency>

<groupId>org.slf4j</groupId>

<artifactId>slf4j-api</artifactId>

<version>1.7.5</version>

</dependency>

<dependency>

<groupId>org.slf4j</groupId>

<artifactId>slf4j-simple</artifactId>

<version>1.6.4</version>

</dependency>

<dependency>

<groupId>ch.qos.logback.contrib</groupId>

<artifactId>logback-json-classic</artifactId>

<version>0.1.5</version>

</dependency>

<dependency>

<groupId>junit</groupId>

<artifactId>junit</artifactId>

<version>4.11</version>

<scope>test</scope>

</dependency>

<dependency>

<groupId>com.github.stefanbirkner</groupId>

<artifactId>system-rules</artifactId>

<version>1.16.0</version>

<scope>test</scope>

</dependency>

</dependencies>

<build>

<plugins>

<plugin>

<artifactId>maven-compiler-plugin</artifactId>

<version>3.8.0</version>

</plugin>

<plugin>

<artifactId>maven-assembly-plugin</artifactId>

<configuration>

<archive>

<manifest>

<mainClass>com.example.cloudrun.App</mainClass>

</manifest>

</archive>

<descriptorRefs>

<descriptorRef>jar-with-dependencies</descriptorRef>

</descriptorRefs>

</configuration>

</plugin>

</plugins>

</build>

</project>

package com.example.cloudrun;

import static spark.Spark.get;

import static spark.Spark.port;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class App {

private static final Logger logger = LoggerFactory.getLogger(App.class);

public static void main(String[] args) {

int port = Integer.parseInt(System.getenv().getOrDefault("PORT", "8080"));

port(port);

get(

"/",

(req, res) -> {

logger.info("Hello: received request.");

// [START run_broken_service_problem]

String name = System.getenv("NAME");

if (name == null) {

// Standard error logs do not appear in Stackdriver Error Reporting.

System.err.println("Environment validation failed.");

String msg = "Missing required server parameter";

logger.error(msg, new Exception(msg));

res.status(500);

return "Internal Server Error";

}

// [END run_broken_service_problem]

res.status(200);

return String.format("Hello %s!", name);

});

get(

"/improved",

(req, res) -> {

logger.info("Hello: received request.");

// [START run_broken_service_upgrade]

String name = System.getenv().getOrDefault("NAME", "World");

if (System.getenv("NAME") == null) {

logger.warn(String.format("NAME not set, default to %s", name));

}

// [END run_broken_service_upgrade]

res.status(200);

return String.format("Hello %s!", name);

});

}

}

package com.example.cloudrun;

import static org.junit.Assert.assertEquals;

import static org.junit.Assert.assertTrue;

import static spark.Spark.awaitInitialization;

import static spark.Spark.stop;

import java.io.IOException;

import java.net.HttpURLConnection;

import java.net.URL;

import org.junit.AfterClass;

import org.junit.BeforeClass;

import org.junit.Rule;

import org.junit.Test;

import org.junit.contrib.java.lang.system.EnvironmentVariables;

import spark.utils.IOUtils;

public class AppTest {

private static final String brokenUrl = "/";

private static final String fixedUrl = "/improved";

@Rule public final EnvironmentVariables environmentVariables = new EnvironmentVariables();

@BeforeClass

public static void beforeClass() {

App app = new App();

app.main(new String[] {});

awaitInitialization();

}

@AfterClass

public static void afterClass() {

stop();

}

@Test

public void brokenShouldFailOnAnyRequest() {

try {

TestResponse response = executeRequest("GET", brokenUrl);

assertEquals(true, response);

} catch (IOException e) {

assertTrue(e.getMessage().startsWith("Server returned HTTP response code: 500"));

}

}

@Test

public void fixShouldSucceedWithDefault() throws IOException {

TestResponse response = executeRequest("GET", fixedUrl);

assertEquals(200, response.status);

assertEquals("Hello World!", response.body);

}

@Test

public void brokenShouldSucceedWithName() throws IOException {

environmentVariables.set("NAME", "test");

TestResponse response = executeRequest("GET", brokenUrl);

assertEquals(200, response.status);

assertEquals("Hello test!", response.body);

}

@Test

public void fixShouldSucceedWithName() throws IOException {

environmentVariables.set("NAME", "test");

TestResponse response = executeRequest("GET", fixedUrl);

assertEquals(200, response.status);

assertEquals("Hello test!", response.body);

}

private static TestResponse executeRequest(String method, String path) throws IOException {

URL url = new URL("http://localhost:8080" + path);

HttpURLConnection connection = (HttpURLConnection) url.openConnection();

connection.setRequestMethod(method);

connection.setDoOutput(true);

connection.connect();

String body = IOUtils.toString(connection.getInputStream());

return new TestResponse(connection.getResponseCode(), body);

}

public static class TestResponse {

public final String body;

public final int status;

public TestResponse(int status, String body) {

this.status = status;

this.body = body;

}

}

}