diff --git a/src/CRUD/CRUD.go b/src/CRUD/CRUD.go
new file mode 100644
index 0000000..6d728a1
--- /dev/null
+++ b/src/CRUD/CRUD.go
@@ -0,0 +1,145 @@
+package main
+
+import (
+	"bytes"
+	"flag"
+	"fmt"
+	"io"
+	"io/ioutil"
+	"net/http"
+	"os"
+	"github.com/Comcast/webpa-common/wrp"
+)
+
+const (
+	AuthHeaderName				= "Authorization"
+	TypeHeaderName              = "X-Xmidt-Message-Type"
+	ContentHeaderName           = "X-Xmidt-Content-Type"
+	TransIdHeaderName           = "X-Xmidt-Transaction-Uuid"
+	SourceHeaderName            = "X-Xmidt-Source"
+	DestHeaderName 				= "X-Webpa-Device-Name"
+	PathURL 					= "https://api.xmidt.comcast.net/api/v2/device"
+)
+
+
+var auth string
+
+func makeRequest(requestType, messageType, source, transId, dest, contentType, payload string, client *http.Client) {
+
+	
+	headers := make(map[string]string)
+	
+	headers[AuthHeaderName] = auth
+	var req *http.Request
+	var err error
+
+	if "POST" == requestType {
+		headers[TypeHeaderName]= messageType
+		headers[ContentHeaderName]= contentType
+		headers[TransIdHeaderName]= transId
+		headers[SourceHeaderName]= source
+		headers[DestHeaderName]= dest
+		
+		req, err = http.NewRequest(requestType, PathURL, bytes.NewBufferString(payload))
+	}
+	
+
+	if err != nil {
+		fmt.Printf("Request %s failed: %s, %v\n", requestType, PathURL, err)
+	}
+
+	for k, v := range headers {
+		req.Header.Set(k, v)
+	}
+	
+	resp, err := client.Do(req)
+	
+	if err != nil {
+		fmt.Printf("Failed to obtain request: %v\n", err)
+	} else {
+
+		if 200 != resp.StatusCode {
+			fmt.Printf("Failed. resp.StatusCode %v \n", resp.StatusCode)
+		} else if 200 == resp.StatusCode {
+			/*Decode Msgpack response to JSON format*/
+			target := wrp.AllFormats()
+			decoder := wrp.NewDecoder(resp.Body, target[0])
+			var buffer bytes.Buffer
+			encoder := wrp.NewEncoder(&buffer, target[1])
+
+			if message, err := wrp.TranscodeMessage(encoder, decoder); err != nil {
+				fmt.Println("Error while converting:", target[0], "to", target[1], err)
+			} else {
+				//Headers
+				fmt.Println("Content-Type :", resp.Header.Get("Content-Type"))
+				fmt.Println("Status :", resp.Header.Get("X-Xmidt-Status"))
+				fmt.Println("Build :", resp.Header.Get("X-Scytale-Build"))
+				fmt.Println("Flavor :", resp.Header.Get("X-Scytale-Flavor"))
+				fmt.Println("Region :", resp.Header.Get("X-Scytale-Region"))
+				fmt.Println("Server :", resp.Header.Get("X-Scytale-Server"))
+				//Metadata
+				fmt.Println("Fw-name :", message.Metadata["fw-name"])
+				//WRP fields
+				fmt.Println("TransactionKey :", message.TransactionKey())
+				fmt.Println("source :", message.Source)
+				fmt.Println("Destination :", message.Destination)
+				fmt.Println("MessageType :", message.Type)
+				fmt.Println("payload :", string(message.Payload))
+			}
+
+		} else {
+			fmt.Println("Request failed with status ", resp.StatusCode)
+		}
+		io.Copy(ioutil.Discard, resp.Body)
+		resp.Body.Close()
+	}
+}
+
+func main() {
+	if "" == os.Getenv("WEBPA_SAT") {
+		fmt.Printf("Environment variable WEBPA_SAT must be set a valid SAT token.")
+		return
+	}
+
+	auth = "Bearer " + os.Getenv("WEBPA_SAT")
+
+	var maxConnReuse uint
+	var requestType, messageType, source, dest, contentType, transId, payload string
+
+	flag.StringVar(&messageType, "messageType", "", "type of the request to send")
+	flag.StringVar(&payload, "payload", "", "the payload to send to apply")
+	flag.StringVar(&source, "source", "", "source value for CRUD operations")
+	flag.StringVar(&dest, "dest", "", "CRUD dest value to apply")
+	flag.StringVar(&transId, "transId", "", "transId for CRUD operations")
+	flag.StringVar(&contentType, "contentType", "", "contentType for CRUD operations")
+	flag.UintVar(&maxConnReuse, "max-reuse", 100, "the maximum number of connection re-use attempts -- (advanced)")
+
+	flag.Parse()
+
+	if "" == messageType{
+		fmt.Printf("Please provide messageType option\n")
+		return
+	} else if "" != messageType {
+		requestType = "POST"
+		if "Create" == messageType || "Update" == messageType {
+			if "" == payload {
+				fmt.Printf("Please provide payload option\n")
+				return
+			}
+		}
+		
+		if "" == source || "" == dest || "" == transId || "" == contentType {
+			fmt.Printf("Please provide the required arguments: source, dest, transId, contentType\n")
+			return
+		}
+	}
+
+	client := &http.Client{
+		Transport: &http.Transport{
+			MaxIdleConnsPerHost: int(maxConnReuse),
+		},
+	}
+
+	makeRequest(requestType, messageType, source, transId, dest, contentType, payload, client)
+
+}
diff --git a/src/CRUD/README.md b/src/CRUD/README.md
new file mode 100644
index 0000000..6c42be5
--- /dev/null
+++ b/src/CRUD/README.md
@@ -0,0 +1,42 @@
+## CRUD
+Utility to perform parodus CRUD operations for a particular device mac.
+
+To build with just go:
+```
+export GOPATH=`pwd`
+cd src
+glide install
+cd CRUD
+go build
+
+```
+
+## Authentication
+export WEBPA_SAT=<SAT_Token>
+
+### Example :
+
+### Create
+```
+./CRUD -messageType=5 -source="tag-update" -dest="mac:14cfe21421xx/parodus/tag/test1" -transId="bd4ad2d1-5c9c-486f-8e25-52c242b38" -contentType="application/json" -payload='{ "expires" : 12345}'
+```
+
+### Retrieve
+```
+./CRUD -messageType=6 -source="tag-update" -dest="mac:14cfe21421xx/parodus/tag/test1" -transId="bd4ad2d1-5c9c-486f-8e25-52c242b38" -contentType="application/json"
+
+```
+
+
+### Update
+```
+./CRUD -messageType=7 -source="tag-update" -dest="mac:14cfe21421xx/parodus/tag/test1" -transId="bd4ad2d1-5c9c-486f-8e25-52c242b38" -contentType="application/json" -payload='{ "expires" : 12345}'
+
+```
+
+### Delete
+```
+./CRUD -messageType=8 -source="tag-update" -dest="mac:14cfe21421xx/parodus/tag/test1" -transId="bd4ad2d1-5c9c-486f-8e25-52c242b38" -contentType="application/json"
+
+```
+
diff --git a/src/glide.yaml b/src/glide.yaml
new file mode 100644
index 0000000..4e7325c
--- /dev/null
+++ b/src/glide.yaml
@@ -0,0 +1,5 @@
+package: .
+import:
+- package: github.com/Comcast/webpa-common
+  version: c936e1b4ec39c3bb796d28aa11a1bd97dac4e05d
+