summaryrefslogtreecommitdiff
path: root/sandpit/test_parse_message.go
diff options
context:
space:
mode:
authorKatolaZ <katolaz@freaknet.org>2017-07-15 01:26:39 +0100
committerKatolaZ <katolaz@freaknet.org>2017-07-15 01:26:39 +0100
commit726b399e4747032a3d052339cd62c57ae5b6767c (patch)
treeaac8350e83bb13e9628dd287ca3aae97ecafcb32 /sandpit/test_parse_message.go
parented637037b75cb5dfe1b49e776956fa6ab3632b68 (diff)
pipeline from spool to worker is done -- added examples
Diffstat (limited to 'sandpit/test_parse_message.go')
-rw-r--r--sandpit/test_parse_message.go44
1 files changed, 44 insertions, 0 deletions
diff --git a/sandpit/test_parse_message.go b/sandpit/test_parse_message.go
new file mode 100644
index 0000000..f60f03c
--- /dev/null
+++ b/sandpit/test_parse_message.go
@@ -0,0 +1,44 @@
+package main
+
+import(
+ "fmt"
+ "github.com/go-yaml/yaml"
+ "io/ioutil"
+ "log"
+ "os"
+)
+
+
+var orig_msg= `
+---
+m_id: 123456
+m_repo: master
+m_branch: test_branch
+m_oldrev: a1b2c3d4e5f6
+m_newrev: 9a8b7c6d5e4f
+...
+
+`
+
+
+func main(){
+
+ var msg *SCORSHmsg
+ msg = new(SCORSHmsg)
+
+
+ fname := "spool/test_2"
+
+ data, err := ioutil.ReadFile(fname)
+ if err != nil {
+ log.Printf("Unable to open file: %s\n", fname)
+ os.Exit(1)
+ }
+ err = yaml.Unmarshal([]byte(data), msg)
+ if err != nil{
+ log.Printf("Error parsing message: %s", err)
+ }
+
+ fmt.Printf("%s\n", msg)
+
+}