InfluxReader.cs

Go to the documentation of this file.

using System;
using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using System.Linq;
using ARDesign.Serialize;
using ARDesign.Influx;

namespace ARDesign
{
    namespace Widgets
    {
        public abstract class InfluxType<T> : InfluxReader
        {
            protected T dataVals;

            protected abstract void CastWidget();

            #region UNITY_MONOBEHAVIOUR_METHODS
            // Use this for initialization
            void Awake()
            {
                widget = this.GetComponent<WidgetHandler>();
                //Debug.Log("Start called on " + widget.name);
                CastWidget();
            }
            #endregion //UNITY_MONOBEHAVIOUR_METHODS

            #region PUBLIC_METHODS
            public T GetData()
            {
                return dataVals;
            }
            #endregion //PUBLIC_METHODS
        }

        public abstract class InfluxReader : MonoBehaviour
        {
            //determines if widget needs to be updated or is static
            public bool toUpdate = false;
            [NonSerialized]
            public bool isDataBuilt = false;
            [NonSerialized]
            public bool isSetup = false;

            #region PRIVATE_MEMBER_VARIABLES
            protected string measure;
            protected string building;
            protected string room;
            private InfluxSetup parent = null;

            private string urlToQuery;
            private string urlToUpdate;

            protected WidgetHandler widget;
            #endregion //PRIVATE_MEMBER_VARIABLES

            #region PUBLIC_METHODS
            public void SetDBVals(string m, string b, string r)
            {
                parent = gameObject.GetComponentInParent<InfluxSetup>();
                measure = m;
                building = b;
                room = r;

                urlToQuery = SetQueryUrl();
                urlToUpdate = SetQueryUrl();
            }

            public void UpdateVals()
            {
                StartCoroutine(RefreshCurVals());
            }

            public void SetVals()
            {
                StartCoroutine(BuildValues());
                isSetup = true;
            }
            #endregion //PUBLIC_METHODS

            #region ABSTRACT_METHODS
            protected abstract string SetQueryUrl();

            protected abstract string SetUpdateUrl();

            protected abstract void ParseSetUpText(string webReturn);

            protected abstract void ParseUpdateText(string webReturn);

            #endregion //ABSTRACT_METHODS

            #region PRIVATE_METHODS
            private IEnumerator RefreshCurVals()
            {
                WWW web = new WWW(urlToUpdate);
                yield return web;

                if (web.error != null)
                {
                    Debug.Log(web.error);
                }
                else
                {
                    ParseUpdateText(web.text);
                }

            }

            private IEnumerator BuildValues()
            {
                WWW web = new WWW(urlToQuery);
                yield return web;
                if (web.error != null)
                {
                    Debug.Log(web.error);
                }
                else
                {
                    ParseSetUpText(web.text);
                }
            }
            #endregion //PRIVATE_METHODS

            #region QUERY_HELPER_FUNCTIONS

            protected string BuildUrl(string query)
            {
                return parent.BuildUrlWithQuery(query);
            }

            public string BuildUrlWithLimit(int limit)
            {
                return BuildUrl("SELECT type,value FROM " + measure + " WHERE \"building\"=\'" + building + "\' AND \"room\"=\'" + room + "\' ORDER BY DESC LIMIT " + limit);

            }


            public string BuildUrlWithoutLimit()
            {

                return BuildUrl("SELECT type,value FROM " + measure + " WHERE \"building\"=\'" + building + "\' AND \"room\"=\'" + room + "\' ORDER BY DESC");

            }

            public string BuildUrlWithLimitSetType(string type, int limit)
            {
                return BuildUrl("SELECT value FROM " + measure + " WHERE \"building\"=\'" + building + "\' AND \"room\"=\'" + room + "\' AND \"type\"=\'" + type + "\' ORDER BY DESC LIMIT " + limit);

            }

            public string BuildUrlWithoutLimitSetType(string type)
            {

                return BuildUrl("SELECT value FROM " + measure + " WHERE \"building\"=\'" + building + "\' AND \"room\"=\'" + room + "\' AND \"type\"=\'" + type + "\' ORDER BY DESC");

            }

            public string BuildUrlTagList(string keyName)
            {
                return BuildUrl("SHOW TAG VALUES FROM " + measure + " WITH KEY = \"" + keyName + "\"");
            }
            #endregion //QUERY_HELPER_FUNCTIONS
        }
    }
}