JournalDataExtractor.cs

Go to the documentation of this file.

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Xml;
using System.Xml.XPath;
using System.Xml.Xsl;
using System.IO;
using System.Text.RegularExpressions;

namespace SeciControls
{
    public class Entry
    {
        public string RunNumber { get; private set; }
        public string Title { get; private set; }
        public string Start { get; private set; }
        public string Duration { get; private set; }
        public string Uamps { get; private set; }
        public string Mev { get; private set; }
        public string Users { get; private set; }
        public string RB { get; private set; }

        public Entry(String run, String title, String start, String duration, String uamps, String mev, String users, String rb)
        {
            RunNumber = run;
            Title = title;
            Start = start;
            Duration = duration;
            Uamps = uamps;
            Mev = mev;
            Users = users;
            RB = rb;
        }
    }

    class JournalDataExtractor
    {
        FileInfo _journal;
        DateTime _lastModified = new DateTime();

        public Boolean GetCurrentCycleData(String journalDir, String mainFileName, out List<Entry> entries)
        {
             entries = new List<Entry>();

            //Get the most recent cycle from journal_main.xml
            XmlDocument mainXml = new XmlDocument();
            mainXml.Load(journalDir + "\\" + mainFileName);

            XmlNodeList nodelist = mainXml.SelectNodes("/journal/file");

            if (nodelist == null)
            {
                return true;
            }

            Double currentCycle = 0;
            String currentCycleFileName = "";

            //The last entry is probably the most recent cycle but we should check
            for (int i = 0; i < nodelist.Count; ++i)
            {
                //filename is formatted like "journal_10_2.xml"
                String filename = nodelist[i].Attributes["name"].Value.ToString();

                //Extract the numbers
                String[] vals = Regex.Split(filename, @"[_\.]");

                if (vals.Length > 3)
                {
                    Double cycleNumber;
                    if (Double.TryParse(vals[1] + "." + vals[2], out cycleNumber) && cycleNumber > currentCycle)
                    {
                        currentCycleFileName = journalDir + "\\" + filename;
                    }
                }
                else
                {
                    if (nodelist.Count == 1)
                    {
                        //Probably on a test machine, so try this file
                        currentCycleFileName = journalDir + "\\" + filename;
                    }
                }
            }

            if (currentCycleFileName != "")
            {
                FileInfo fi = new FileInfo(currentCycleFileName);

                if (!fi.Exists)
                {
                    throw new FileNotFoundException("The cycle journal file does not exist");
                }

                if (_journal == null || fi.FullName != _journal.FullName)
                {
                    //It is a new file
                    _journal = fi;
                    _lastModified = new DateTime();
                }

                if (fi.LastWriteTime != _lastModified)
                {
                    //The file has changed so read it

                    //Load the file
                    XmlDocument cycleXml = new XmlDocument();

                    //Use Western European charset even though the XML claims to be UTF8
                    //as the likes of é causes problems.
                    FileStream inStream = new FileStream(currentCycleFileName, FileMode.Open, FileAccess.Read, FileShare.ReadWrite);
                    StreamReader sr = new StreamReader(inStream, Encoding.GetEncoding("Windows-1252"));
                    cycleXml.Load(sr);

                    _lastModified = fi.LastWriteTime;

                    XmlNamespaceManager nsMgr = new XmlNamespaceManager(cycleXml.NameTable);
                    nsMgr.AddNamespace("nx", "http://definition.nexusformat.org/schema/3.0");

                    //XmlNodeList newnodelist = cycleXml.SelectNodes("nx:nxroot/nx:nxentry", nsMgr);

                    //most recent entry is last
                    for (int i = cycleXml.ChildNodes[1].ChildNodes.Count - 1; i >= 0; --i)
                    {
                        String title = cycleXml.ChildNodes[1].ChildNodes[i].SelectSingleNode("nx:title", nsMgr).InnerText.ToString().Trim();
                        String username = cycleXml.ChildNodes[1].ChildNodes[i].SelectSingleNode("nx:user_name", nsMgr).InnerText.ToString().Trim();
                        String runnumber = cycleXml.ChildNodes[1].ChildNodes[i].SelectSingleNode("nx:run_number", nsMgr).InnerText.ToString().Trim();
                        String start = cycleXml.ChildNodes[1].ChildNodes[i].SelectSingleNode("nx:start_time", nsMgr).InnerText.ToString().Trim().Replace('T', ' ');
                        String duration = cycleXml.ChildNodes[1].ChildNodes[i].SelectSingleNode("nx:duration", nsMgr).InnerText.ToString().Trim();
                        String uamps = cycleXml.ChildNodes[1].ChildNodes[i].SelectSingleNode("nx:proton_charge", nsMgr).InnerText.ToString().Trim();
                        String mev = cycleXml.ChildNodes[1].ChildNodes[i].SelectSingleNode("nx:total_mevents", nsMgr).InnerText.ToString().Trim();
                        String rb = cycleXml.ChildNodes[1].ChildNodes[i].SelectSingleNode("nx:experiment_identifier", nsMgr).InnerText.ToString().Trim();

                        //Make the duration "friendly"
                        int secs;
                        if (Int32.TryParse(duration, out secs))
                        {
                            duration = new TimeSpan(0, 0, secs).ToString();
                        }
                        else
                        {
                            duration = "UNSPECIFIED";
                        }

                        entries.Add(new Entry(runnumber, title, start, duration, uamps, mev, username, rb));
                    }

                    return true;
                }
            }

            return false;
        }
    }
}