X-Git-Url: https://code.grnet.gr/git/ganeti-local/blobdiff_plain/262f3e6c550a81dcb576c8bb85236731002bcfe0..5ef78537289a5247a8c89318445189867f8cf11e:/Ganeti/HTools/Rapi.hs

diff --git a/Ganeti/HTools/Rapi.hs b/Ganeti/HTools/Rapi.hs
index ddd047d..84332f6 100644
--- a/Ganeti/HTools/Rapi.hs
+++ b/Ganeti/HTools/Rapi.hs
@@ -26,14 +26,14 @@ Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
 module Ganeti.HTools.Rapi
     (
       loadData
+    , parseData
     ) where
 
 import Network.Curl
 import Network.Curl.Types ()
-import Network.Curl.Code
-import Data.List
 import Control.Monad
-import Text.JSON (JSObject, JSValue, fromJSObject)
+import Text.JSON (JSObject, JSValue, fromJSObject, decodeStrict)
+import Text.JSON.Types (JSValue(..))
 import Text.Printf (printf)
 
 import Ganeti.HTools.Utils
@@ -58,7 +58,7 @@ getUrl url = do
 -- | Append the default port if not passed in.
 formatHost :: String -> String
 formatHost master =
-    if elem ':' master then  master
+    if ':' `elem` master then  master
     else "https://" ++ master ++ ":5080"
 
 -- | Parse a instance list in JSON format.
@@ -66,58 +66,81 @@ getInstances :: NameAssoc
              -> String
              -> Result [(String, Instance.Instance)]
 getInstances ktn body =
-    loadJSArray body >>= mapM (parseInstance ktn . fromJSObject)
+    loadJSArray "Parsing instance data" body >>=
+    mapM (parseInstance ktn . fromJSObject)
 
 -- | Parse a node list in JSON format.
 getNodes :: String -> Result [(String, Node.Node)]
-getNodes body = loadJSArray body >>= mapM (parseNode . fromJSObject)
+getNodes body = loadJSArray "Parsing node data" body >>=
+                mapM (parseNode . fromJSObject)
 
 -- | Construct an instance from a JSON object.
 parseInstance :: [(String, Ndx)]
               -> [(String, JSValue)]
               -> Result (String, Instance.Instance)
 parseInstance ktn a = do
-  name <- fromObj "name" a
-  disk <- fromObj "disk_usage" a
-  mem <- fromObj "beparams" a >>= fromObj "memory" . fromJSObject
-  vcpus <- fromObj "beparams" a >>= fromObj "vcpus" . fromJSObject
-  pnode <- fromObj "pnode" a >>= lookupNode ktn name
-  snodes <- fromObj "snodes" a
+  name <- tryFromObj "Parsing new instance" a "name"
+  let owner_name = "Instance '" ++ name ++ "'"
+  let extract s x = tryFromObj owner_name x s
+  disk <- extract "disk_usage" a
+  beparams <- liftM fromJSObject (extract "beparams" a)
+  omem <- extract "oper_ram" a
+  mem <- (case omem of
+            JSRational _ _ -> annotateResult owner_name (fromJVal omem)
+            _ -> extract "memory" beparams)
+  vcpus <- extract "vcpus" beparams
+  pnode <- extract "pnode" a >>= lookupNode ktn name
+  snodes <- extract "snodes" a
   snode <- (if null snodes then return Node.noSecondary
             else readEitherString (head snodes) >>= lookupNode ktn name)
-  running <- fromObj "status" a
-  let inst = Instance.create name mem disk vcpus running pnode snode
+  running <- extract "status" a
+  tags <- extract "tags" a
+  let inst = Instance.create name mem disk vcpus running tags pnode snode
   return (name, inst)
 
 -- | Construct a node from a JSON object.
 parseNode :: [(String, JSValue)] -> Result (String, Node.Node)
 parseNode a = do
-  name <- fromObj "name" a
-  offline <- fromObj "offline" a
-  node <- (if offline
-           then return $ Node.create name 0 0 0 0 0 0 True
+  name <- tryFromObj "Parsing new node" a "name"
+  let extract s = tryFromObj ("Node '" ++ name ++ "'") a s
+  offline <- extract "offline"
+  drained <- extract "drained"
+  guuid   <- extract "group.uuid"
+  node <- (if offline || drained
+           then return $ Node.create name 0 0 0 0 0 0 True guuid
            else do
-             drained <- fromObj "drained" a
-             mtotal  <- fromObj "mtotal"  a
-             mnode   <- fromObj "mnode"   a
-             mfree   <- fromObj "mfree"   a
-             dtotal  <- fromObj "dtotal"  a
-             dfree   <- fromObj "dfree"   a
-             ctotal  <- fromObj "ctotal"  a
+             mtotal  <- extract "mtotal"
+             mnode   <- extract "mnode"
+             mfree   <- extract "mfree"
+             dtotal  <- extract "dtotal"
+             dfree   <- extract "dfree"
+             ctotal  <- extract "ctotal"
              return $ Node.create name mtotal mnode mfree
-                    dtotal dfree ctotal (offline || drained))
+                    dtotal dfree ctotal False guuid)
   return (name, node)
 
--- | Builds the cluster data from an URL.
-loadData :: String -- ^ Cluster or URL to use as source
-         -> IO (Result (Node.AssocList, Instance.AssocList))
-loadData master = do -- IO monad
+-- | Loads the raw cluster data from an URL.
+readData :: String -- ^ Cluster or URL to use as source
+         -> IO (Result String, Result String, Result String)
+readData master = do
   let url = formatHost master
   node_body <- getUrl $ printf "%s/2/nodes?bulk=1" url
   inst_body <- getUrl $ printf "%s/2/instances?bulk=1" url
-  return $ do -- Result monad
-    node_data <- node_body >>= getNodes
-    let (node_names, node_idx) = assignIndices node_data
-    inst_data <- inst_body >>= getInstances node_names
-    let (_, inst_idx) = assignIndices inst_data
-    return (node_idx, inst_idx)
+  tags_body <- getUrl $ printf "%s/2/tags" url
+  return (node_body, inst_body, tags_body)
+
+-- | Builds the cluster data from the raw Rapi content
+parseData :: (Result String, Result String, Result String)
+          -> Result (Node.AssocList, Instance.AssocList, [String])
+parseData (node_body, inst_body, tags_body) = do
+  node_data <- node_body >>= getNodes
+  let (node_names, node_idx) = assignIndices node_data
+  inst_data <- inst_body >>= getInstances node_names
+  let (_, inst_idx) = assignIndices inst_data
+  tags_data <- tags_body >>= (fromJResult "Parsing tags data" . decodeStrict)
+  return (node_idx, inst_idx, tags_data)
+
+-- | Top level function for data loading
+loadData :: String -- ^ Cluster or URL to use as source
+            -> IO (Result (Node.AssocList, Instance.AssocList, [String]))
+loadData master = readData master >>= return . parseData