-tryRapi :: String -> String -> IO (Either String String)
-tryRapi url1 url2 =
- do
- body1 <- getUrl url1
- (case body1 of
- Left _ -> getUrl url2
- Right _ -> return body1)
-
-getInstances :: String -> IO (Either String String)
-getInstances master =
- let
- url2 = printf "https://%s:5080/2/instances?bulk=1" master
- url1 = printf "http://%s:5080/instances?bulk=1" master
- in do
- body <- tryRapi url1 url2
- let inst = body `combine` loadJSArray `combine` (parseList parseInstance)
- return inst
-
-getNodes :: String -> IO (Either String String)
-getNodes master =
- let
- url2 = printf "https://%s:5080/2/nodes?bulk=1" master
- url1 = printf "http://%s:5080/nodes?bulk=1" master
- in do
- body <- tryRapi url1 url2
- let inst = body `combine` loadJSArray `combine` (parseList parseNode)
- return inst
-
-parseList :: (JSObject JSValue -> Either String String)
- -> [JSObject JSValue]
- ->Either String String
-parseList fn idata =
- let ml = ensureList $ map fn idata
- in ml `combine` (Right . unlines)
-
-parseInstance :: JSObject JSValue -> Either String String
-parseInstance a =
- let name = getStringElement "name" a
- disk = case getIntElement "disk_usage" a of
- Left _ -> apply2 (+)
- (getIntElement "sda_size" a)
- (getIntElement "sdb_size" a)
- Right x -> Right x
- bep = fromObj "beparams" a
- pnode = getStringElement "pnode" a
- snode = (listHead $ getListElement "snodes" a) `combine` readString
- mem = case bep of
- Left _ -> getIntElement "admin_ram" a
- Right o -> getIntElement "memory" o
- running = getStringElement "status" a
- in
- concatElems name $
- concatElems (show `apply1` mem) $
- concatElems (show `apply1` disk) $
- concatElems running $
- concatElems pnode snode
-
-parseNode :: JSObject JSValue -> Either String String
-parseNode a =
- let name = getStringElement "name" a
- mtotal = getIntElement "mtotal" a
- mnode = getIntElement "mnode" a
- mfree = getIntElement "mfree" a
- dtotal = getIntElement "dtotal" a
- dfree = getIntElement "dfree" a
- in concatElems name $
- concatElems (show `apply1` mtotal) $
- concatElems (show `apply1` mnode) $
- concatElems (show `apply1` mfree) $
- concatElems (show `apply1` dtotal) (show `apply1` dfree)
+-- | Append the default port if not passed in.
+formatHost :: String -> String
+formatHost master =
+ if ':' `elem` master then master
+ else "https://" ++ master ++ ":5080"
+
+-- | Parse a instance list in JSON format.
+getInstances :: NameAssoc
+ -> String
+ -> Result [(String, Instance.Instance)]
+getInstances ktn body =
+ 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 "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 <- 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 <- 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 <- tryFromObj "Parsing new node" a "name"
+ let extract s = tryFromObj ("Node '" ++ name ++ "'") a s
+ offline <- extract "offline"
+ drained <- extract "drained"
+ node <- (if offline || drained
+ then return $ Node.create name 0 0 0 0 0 0 True defaultUUID
+ else do
+ 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 False defaultUUID)
+ return (name, node)
+
+-- | 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
+ 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