lab-100

.gitignore

@@ -1,3 +1,4 @@
 build/
 target/
 .metadata
+.wercker/

README.md

@@ -1,3 +1,10 @@
+About
+=====
+
+This repository contains the code for the Twitter feed microservice that you will use during the [Oracle Container Native Application Development workshop](http://oracle.github.io/learning-library/workshops/container-native-development).
+During the workshop you will Dockerize this Java microservice using Wercker, configure a CI/CD pipeline, and deploy the microservice to Oracle's managed Kubernetes service.
+
+
 Build
 =====
 
@@ -13,12 +20,4 @@ On successful build, you can run the app with `sh target/bin/start` which is a s
 Deploy
 ======
 
-Edit config.properties to set your target server, user id, password, and identity domain
-
-Deploy the application archive using `deploy.sh`.  This will create the service instance and deploy.  
-
-
-Redeploy
-========
-
-Once a service instance has been created, updated archives are deployed
+You will create Wercker pipelines to build, publish, and deploy this microservice during the workshop.

alpha-office-product-catalog.kubernetes.yml

@@ -0,0 +1,45 @@
+apiVersion: extensions/v1beta1
+kind: Deployment
+metadata:
+  name: product-catalog-app
+  labels:
+    commit: 4ca160fd05c003e5067fd6d9c8213656b24b962c
+spec:
+  replicas: 2
+  selector:
+    matchLabels:
+      app: product-catalog-app
+  template:
+    metadata:
+      labels:
+        app: product-catalog-app
+        commit: 4ca160fd05c003e5067fd6d9c8213656b24b962c
+    spec:
+      containers:
+      - name: product-catalog-app-container
+        image: derekoneil/alpha-office-product-catalog:master-4ca160fd05c003e5067fd6d9c8213656b24b962c
+        imagePullPolicy: Always
+        ports:
+        - name: pc-app-port
+          containerPort: 80
+          protocol: TCP
+      imagePullSecrets:
+        - name: wercker
+---
+apiVersion: v1
+kind: Service
+metadata:
+  name: product-catalog-service
+  labels:
+    app: product-catalog-app
+    commit: 4ca160fd05c003e5067fd6d9c8213656b24b962c
+spec:
+  ports:
+  - port: 30000
+    nodePort: 30000
+    targetPort: 80
+  selector:
+    app: product-catalog-app
+    commit: 4ca160fd05c003e5067fd6d9c8213656b24b962c
+  type: NodePort
+---

kubernetes.yml.template.final

@@ -0,0 +1,56 @@
+apiVersion: extensions/v1beta1
+kind: Deployment
+metadata:
+  name: twitter-feed-v2
+  labels:
+    commit: ${WERCKER_GIT_COMMIT}
+spec:
+  replicas: 2
+  selector:
+    matchLabels:
+      app: twitter-feed
+  template:
+    metadata:
+      labels:
+        app: twitter-feed
+        commit: ${WERCKER_GIT_COMMIT}
+        color: green
+    spec:
+      containers:
+      - name: twitter-feed
+        image: ${DOCKER_REPO}:${WERCKER_GIT_BRANCH}-${WERCKER_GIT_COMMIT}
+        imagePullPolicy: Always
+        ports:
+        - name: twitter-feed
+          containerPort: 8080
+          protocol: TCP
+        volumeMounts:
+          - name: podinfo
+            mountPath: /tmp
+            readOnly: false
+      volumes:
+        - name: podinfo
+          downwardAPI:
+            items:
+            - path: "labels"
+              fieldRef:
+                fieldPath: metadata.labels
+      imagePullSecrets:
+        - name: wercker
+---
+apiVersion: v1
+kind: Service
+metadata:
+  name: twitter-feed
+  labels:
+    app: twitter-feed
+    commit: ${WERCKER_GIT_COMMIT}
+spec:
+  ports:
+  - port: 30000
+    targetPort: 8080
+  selector:
+    app: twitter-feed
+    color: green
+  type: ClusterIP
+---

pom.xml

@@ -123,6 +123,13 @@
     					</execution>
     				</executions>
     			</plugin>
+		<plugin>
+            		<groupId>org.apache.maven.plugins</groupId>
+            		<artifactId>maven-surefire-plugin</artifactId>
+            		<configuration>
+                		<useSystemClassLoader>false</useSystemClassLoader>
+           	 	</configuration>
+        	</plugin>
         </plugins>
     </build>
 

src/main/java/com/example/Main.java

@@ -32,6 +32,7 @@ public class Main {
      */
     public static HttpServer startServer() throws UnknownHostException {
     	// Base URI the Grizzly HTTP server will listen on
+	System.out.println("Constructing URI: Hostname: " + System.getenv("HOSTNAME") + ", PORT: " + System.getenv("PORT"));
     	final Optional<String> port = Optional.ofNullable(System.getenv("PORT"));
     	final Optional<String> hostName = Optional.ofNullable(System.getenv("HOSTNAME"));
 		BASE_URI = "http://" + hostName.orElse("localhost") + ":" + port.orElse("8080") + "/";
@@ -50,32 +51,32 @@ public static HttpServer startServer() throws UnknownHostException {
      * @param args
      * @throws IOException
      */
-    public static void main(String[] args) throws IOException {
+    public static void main(String[] args) throws IOException, InterruptedException {
         final HttpServer server = startServer();
-        
+
         server.getServerConfiguration().addHttpHandler(new HttpHandler() {
 //            final SimpleDateFormat formatter = new SimpleDateFormat("HH:mm:ss");
-//            
+//
 //            @Override
 //            public void service(Request request, Response response) throws Exception {
 //                final Date now = new Date();
 //                final String formattedTime;
 //                synchronized (formatter) {
 //                    formattedTime = formatter.format(now);
 //                }
-//                        
+//
 //                response.setContentType("text/plain");
 //                response.getWriter().write("The time using the old Java Date object is: " + formattedTime);
 //            }
             @Override
             public void service(Request request, Response response) throws Exception {
                 response.setContentType("text/plain");
-                response.getWriter().write("The time using the new java.time API in Java 8 is: " + LocalTime.now().truncatedTo(ChronoUnit.SECONDS));
+                response.getWriter().write("The NEW time using the new java.time API in Java 8 is: " + LocalTime.now().truncatedTo(ChronoUnit.SECONDS));
             }
         }, "/time");
-        
-   
-        
+
+
+
      // Add the StaticHttpHandler to serve static resources from the static folder
 //        server.getServerConfiguration().addHttpHandler(
 //                new StaticHttpHandler("src/main/resources/static/"), "static/");
@@ -93,10 +94,17 @@ public void service(Request request, Response response) throws Exception {
         System.out.println(String.format("%sstatictweets</search> to see a set of stored static tweets", BASE_URI));
         System.out.println(String.format("%sjarstatic/index.html to see the jar static resource", BASE_URI));
         System.out.println();
-        System.out.println("Press enter to stop the server...");
-
-        System.in.read();
-        server.shutdown();
+        System.out.println("Press enter to NOT stop the server...");
+
+				try {
+					System.out.println("Joining current thread...");
+					Thread.currentThread().join();
+					System.out.println("Joined current thread.");
+				}
+				catch (Exception e) {
+					System.out.println("Caught Exception: " + e);
+				}
+        // System.in.read();
+        // server.shutdown();
     }
 }
-

src/main/java/com/example/StaticTweets.java

@@ -1,22 +1,25 @@
 package com.example;
 
-
 import java.io.IOException;
 import javax.ws.rs.GET;
 import javax.ws.rs.Path;
 import javax.ws.rs.PathParam;
 import javax.ws.rs.Produces;
 import javax.ws.rs.core.MediaType;
 import javax.ws.rs.core.Response;
-
+import java.nio.file.Files;
+import java.nio.file.Paths;
+import java.nio.charset.Charset;
+import java.util.regex.Pattern;
+import java.util.regex.Matcher;
 import org.glassfish.jersey.server.ChunkedOutput;
 
 /**
  * Root resource (exposed at "statictweets" path)
  */
 @Path("statictweets")
 public class StaticTweets {
-	
+
     private static SampleStreamExample example = new SampleStreamExample();
 
     /**
@@ -28,9 +31,9 @@ public class StaticTweets {
     @GET
     @Produces(MediaType.APPLICATION_JSON)
     public Response getIt() {
-    	
+
     	final ChunkedOutput<String> output = new ChunkedOutput<String>(String.class);
-    	
+
     	runTask(output,null);
     	return Response.ok()
     			.entity(output)
@@ -45,28 +48,55 @@ public Response getIt() {
      *
      * @return String that will be returned as an application/json response.
      */
-    /* --- Remove this comment to allow for Filtered Searching 
     @Path("{search}")
     @GET
     @Produces(MediaType.APPLICATION_JSON)
-    public Response getItWithCount(@PathParam("search") final String search) {
+    public Response getItWithCount(@PathParam("search") String search) {
+	    	System.out.println("Searching for tweets containing: " + search);
 	    	final ChunkedOutput<String> output = new ChunkedOutput<String>(String.class);
+	    	search = ""; //---Remove this line to enable searching
 	    	runTask(output, search);
 	    	return Response.ok()
 	    			.entity(output)
 	    			.header("Access-Control-Allow-Origin", "*")
 	    			.header("Access-Control-Allow-Methods", "GET, POST, DELETE, PUT")
 	    			.build();
 
-		
+
     }
-
-    --- Remove this comment to allow for Filtered Searching */
-
+
+
+	@Path("color")
+	@GET
+	@Produces(MediaType.APPLICATION_JSON)
+	public Response getColor() throws IOException {
+			System.out.println("Checking color");
+			String color = "yellow";
+			byte[] encoded = Files.readAllBytes(Paths.get("/tmp/labels"));
+		  color = new String(encoded, Charset.defaultCharset());
+			Pattern p = Pattern.compile("(?<=color=.)(\\w+)");
+			Matcher m = p.matcher(color);
+
+			if (m.find()) {
+			    color = m.group(1);
+			}
+
+			return Response.ok()
+					.entity(color)
+					.header("Access-Control-Allow-Origin", "*")
+					.header("Access-Control-Allow-Methods", "GET, POST, DELETE, PUT")
+					.build();
+
+
+	}
+
+
+
+
 	private void runTask(ChunkedOutput<String> output, String s) {
         new Thread(() -> {
             try {
-            	example.runStaticTwitterStream(output, s); 
+            	example.runStaticTwitterStream(output, s);
             } catch (IOException e) {
 				e.printStackTrace();
             } finally {
@@ -82,6 +112,6 @@ private void runTask(ChunkedOutput<String> output, String s) {
     	// the output will be probably returned even before
         // a first chunk is written by the new thread
 	}
-    
+
 
 }

twitter-feed.kubernetes.yml

@@ -0,0 +1,56 @@
+apiVersion: extensions/v1beta1
+kind: Deployment
+metadata:
+  name: twitter-feed-v2
+  labels:
+    commit: 9a8fa77277c4a8c3c96d96d4b804e83c26ac6cc0
+spec:
+  replicas: 2
+  selector:
+    matchLabels:
+      app: twitter-feed
+  template:
+    metadata:
+      labels:
+        app: twitter-feed
+        commit: 9a8fa77277c4a8c3c96d96d4b804e83c26ac6cc0
+        color: green
+    spec:
+      containers:
+      - name: twitter-feed
+        image: wcr.io/derekoneil/twitter-feed:master-9a8fa77277c4a8c3c96d96d4b804e83c26ac6cc0
+        imagePullPolicy: Always
+        ports:
+        - name: twitter-feed
+          containerPort: 8080
+          protocol: TCP
+        volumeMounts:
+          - name: podinfo
+            mountPath: /tmp
+            readOnly: false
+      volumes:
+        - name: podinfo
+          downwardAPI:
+            items:
+            - path: "labels"
+              fieldRef:
+                fieldPath: metadata.labels
+      imagePullSecrets:
+        - name: wercker
+---
+apiVersion: v1
+kind: Service
+metadata:
+  name: twitter-feed
+  labels:
+    app: twitter-feed
+    commit: 9a8fa77277c4a8c3c96d96d4b804e83c26ac6cc0
+spec:
+  ports:
+  - port: 30000
+    targetPort: 8080
+  selector:
+    app: twitter-feed
+    color: green
+  type: ClusterIP
+---