1 files changed, 130 insertions, 0 deletions
diff --git a/cos/cosmgr/src/main/java/com/cablelabs/vcpe/cos/cosmgr/CoSService.java b/cos/cosmgr/src/main/java/com/cablelabs/vcpe/cos/cosmgr/CoSService.java
new file mode 100644
index 0000000..e9390fc
--- /dev/null
+++ b/cos/cosmgr/src/main/java/com/cablelabs/vcpe/cos/cosmgr/CoSService.java
@@ -0,0 +1,130 @@
+package com.cablelabs.vcpe.cos.cosmgr;
+
+import com.cablelabs.vcpe.common.Dbg;
+import com.cablelabs.vcpe.cos.cosbase.model.CoS;
+import com.cablelabs.vcpe.cos.cosbase.repository.CoSRespositoryInMem;
+
+import javax.ws.rs.*;
+import javax.ws.rs.core.GenericEntity;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
+import java.util.List;
+
+/**
+ * Root resource (exposed at "myresource" path)
+ */
+@Path("cos")
+public class CoSService
+{
+
+    @POST
+    @Consumes(MediaType.APPLICATION_JSON)
+    @Produces(MediaType.APPLICATION_JSON)
+  //--------------------------------------------------------
+    public Response create(CoS cos)
+  //--------------------------------------------------------
+    {
+        if ( cos == null) {
+            return Response.status(Response.Status.BAD_REQUEST).build();
+        }
+
+        Dbg.p("\nADDING [" + cos.getId() + "] to cos repo");
+        CoSRespositoryInMem.INSTANCE.add(cos);
+        CoSRespositoryInMem.INSTANCE.dump(0);
+        return Response.ok().entity(cos).build();
+    }
+
+    @PUT
+    @Path("{cosId}")
+    @Consumes(MediaType.APPLICATION_JSON)
+    @Produces(MediaType.APPLICATION_JSON)
+  //--------------------------------------------------------
+    public Response update(CoS cos)
+  //--------------------------------------------------------
+    {
+        Dbg.p("\nUPDATING [" + cos.getId()+"]");
+        CoSRespositoryInMem.INSTANCE.update(cos);
+        CoSRespositoryInMem.INSTANCE.dump(0);
+        return Response.ok().entity(cos).build();
+    }
+
+    @GET
+    @Produces(MediaType.APPLICATION_JSON)
+    @Path("{cosId}")
+  //--------------------------------------------------------
+    public Response get( @PathParam("cosId") String cosId )
+  //--------------------------------------------------------
+    {
+        if ( cosId == null) {
+            return Response.status(Response.Status.BAD_REQUEST).build();
+        }
+        Dbg.p("\nRETRIEVING ["+cosId+"]");
+        CoSRespositoryInMem.INSTANCE.dump(1);
+        CoS cos = CoSRespositoryInMem.INSTANCE.get(cosId);
+        if (cos == null) {
+            return Response.status(Response.Status.NOT_FOUND).build();
+        }
+        cos.dump(1);
+        return Response.ok().entity(cos).build();
+    }
+
+    @DELETE
+    @Path("{cosId}")
+    @Consumes(MediaType.APPLICATION_JSON)
+    @Produces(MediaType.APPLICATION_JSON)
+  //--------------------------------------------------------
+    public Response delete(@PathParam("cosId") String cosId)
+  //--------------------------------------------------------
+
+    {
+        if ( cosId == null) {
+            return Response.status(Response.Status.BAD_REQUEST).build();
+        }
+        Dbg.p("\nDELETE:" + cosId);
+        CoSRespositoryInMem.INSTANCE.delete(cosId);
+        CoSRespositoryInMem.INSTANCE.dump(0);
+        return Response.ok().build();
+    }
+
+
+    @GET
+    @Path("list")
+    @Produces(MediaType.APPLICATION_JSON)
+  //--------------------------------------------------------
+    public Response cosList()
+  //--------------------------------------------------------
+  // get a list of all CoS objects
+    {
+        Dbg.p("\nCOS GET ALL:");
+        List cosList = CoSRespositoryInMem.INSTANCE.getAll();
+        if (cosList == null  )
+        {
+            return Response.status(Response.Status.NOT_FOUND).build();
+        }
+        return Response.ok().entity(new GenericEntity<List<CoS>>(cosList) {}).build();
+    }
+
+    @GET
+    @Produces(MediaType.APPLICATION_JSON)
+  //--------------------------------------------------------
+    public CoS testGet()
+  //--------------------------------------------------------
+  // simple get to check out json format
+
+    {
+        CoS cos = new CoS();
+        cos.setAllProps("testGetCoS", 100, 0.99, 17.43, 2.43, 0.01);
+        return cos;
+    }
+
+    @GET
+    @Produces(MediaType.TEXT_PLAIN)
+  //--------------------------------------------------------
+    public String ping()
+  //--------------------------------------------------------
+  // simple ping to check connectivity
+    {
+        Dbg.p("In CoS Service simple get connection test server");
+        return "... pingCos reponse";
+    }
+}