13 files changed, 363 insertions, 2 deletions

diff --git a/src/filemgr.cpp b/src/filemgr.cpp
new file mode 100644
index 0000000..00f0410
--- /dev/null
+++ b/src/filemgr.cpp
@@ -0,0 +1,46 @@
+#include "filemgr.h"
+
+FileMgr::FileMgr() :
+        iNextId( 1 )
+{
+}
+
+FileMgr::~FileMgr()
+{
+        for( FileHash::iterator i = hFile.begin(); i; i++ )
+        {
+                delete *i;
+        }
+}
+
+int FileMgr::open( const Bu::String &sPath, int iMode )
+{
+        hFile.insert( iNextId, new Bu::File( sPath, iMode ) );
+        return iNextId++;
+}
+
+Bu::File &FileMgr::get( int iId )
+{
+        try
+        {
+                return *hFile.get( iId );
+        }
+        catch(...)
+        {
+                throw Bu::ExceptionBase("Invalid file handle accessed.");
+        }
+}
+
+void FileMgr::close( int iId )
+{
+        try
+        {
+                delete hFile.get( iId );
+                hFile.erase( iId );
+        }
+        catch(...)
+        {
+                throw Bu::ExceptionBase("Invalid file handle accessed.");
+        }
+}
+
diff --git a/src/filemgr.h b/src/filemgr.h
new file mode 100644
index 0000000..517e784
--- /dev/null
+++ b/src/filemgr.h
@@ -0,0 +1,26 @@
+#ifndef FILE_MGR_H
+#define FILE_MGR_H
+
+#include <bu/singleton.h>
+#include <bu/hash.h>
+#include <bu/file.h>
+
+class FileMgr : public Bu::Singleton<FileMgr>
+{
+friend class Bu::Singleton<FileMgr>;
+private:
+        FileMgr();
+        virtual ~FileMgr();
+
+public:
+        int open( const Bu::String &sPath, int iMode );
+        Bu::File &get( int iId );
+        void close( int iId );
+
+private:
+        typedef Bu::Hash<int, Bu::File *> FileHash;
+        FileHash hFile;
+        int iNextId;
+};
+
+#endif
diff --git a/src/functionclose.cpp b/src/functionclose.cpp
new file mode 100644
index 0000000..ac9c6f6
--- /dev/null
+++ b/src/functionclose.cpp
@@ -0,0 +1,26 @@
+#include "functionclose.h"
+#include "filemgr.h"
+
+#include <bu/plugger.h>
+PluginInterface3( pluginFunctionClose, close, FunctionClose, Function,
+                "Mike Buland", 0, 1 );
+
+FunctionClose::FunctionClose()
+{
+}
+
+FunctionClose::~FunctionClose()
+{
+}
+
+Bu::String FunctionClose::getName() const
+{
+        return "close";
+}
+
+Variable FunctionClose::call( Variable &input, VarList )
+{
+        FileMgr::getInstance().close( (int)input.getOpaque() );
+        return Variable();
+}
+
diff --git a/src/functionclose.h b/src/functionclose.h
new file mode 100644
index 0000000..0a30427
--- /dev/null
+++ b/src/functionclose.h
@@ -0,0 +1,17 @@
+#ifndef FUNCTION_CLOSE_H
+#define FUNCTION_CLOSE_H
+
+#include "function.h"
+
+class FunctionClose : public Function
+{
+public:
+        FunctionClose();
+        virtual ~FunctionClose();
+
+        virtual Bu::String getName() const;
+        virtual Variable call( Variable &input, VarList lParams );
+
+};
+
+#endif
diff --git a/src/functionopen.cpp b/src/functionopen.cpp
new file mode 100644
index 0000000..4026a8c
--- /dev/null
+++ b/src/functionopen.cpp
@@ -0,0 +1,42 @@
+#include "functionopen.h"
+#include "filemgr.h"
+
+#include <bu/plugger.h>
+PluginInterface3( pluginFunctionOpen, open, FunctionOpen, Function,
+                "Mike Buland", 0, 1 );
+
+FunctionOpen::FunctionOpen()
+{
+}
+
+FunctionOpen::~FunctionOpen()
+{
+}
+
+Bu::String FunctionOpen::getName() const
+{
+        return "open";
+}
+
+Variable FunctionOpen::call( Variable &input, VarList lParams )
+{
+        if( lParams.getSize() != 2 )
+        {
+                throw Bu::ExceptionBase(
+                        "open takes two parameters, filename and mode."
+                        );
+        }
+        Bu::String sMode = lParams.last().toString().toLower();
+        int iMode = Bu::File::Create;
+        if( sMode.find('w') )
+                iMode |= Bu::File::Write;
+        if( sMode.find('r') )
+                iMode |= Bu::File::Read;
+        Variable vRet(
+                (void *)FileMgr::getInstance().open(
+                        lParams.first().toString(), iMode
+                        )
+                );
+        return vRet;
+}
+
diff --git a/src/functionopen.h b/src/functionopen.h
new file mode 100644
index 0000000..5ab3cab
--- /dev/null
+++ b/src/functionopen.h
@@ -0,0 +1,17 @@
+#ifndef FUNCTION_OPEN_H
+#define FUNCTION_OPEN_H
+
+#include "function.h"
+
+class FunctionOpen : public Function
+{
+public:
+        FunctionOpen();
+        virtual ~FunctionOpen();
+
+        virtual Bu::String getName() const;
+        virtual Variable call( Variable &input, VarList lParams );
+
+};
+
+#endif
diff --git a/src/functionplugger.cpp b/src/functionplugger.cpp
index c7b270c..a7b4cf5 100644
--- a/src/functionplugger.cpp
+++ b/src/functionplugger.cpp
@@ -17,6 +17,10 @@ extern Bu::PluginInfo pluginFunctionToString;
 extern Bu::PluginInfo pluginFunctionUnlink;
 extern Bu::PluginInfo pluginFunctionRegEx;
 extern Bu::PluginInfo pluginFunctionRange;
+extern Bu::PluginInfo pluginFunctionOpen;
+extern Bu::PluginInfo pluginFunctionClose;
+extern Bu::PluginInfo pluginFunctionRead;
+extern Bu::PluginInfo pluginFunctionWrite;
 
 FunctionPlugger::FunctionPlugger()
 {
@@ -33,7 +37,10 @@ FunctionPlugger::FunctionPlugger()
         registerBuiltinPlugin( &pluginFunctionToString );
         registerBuiltinPlugin( &pluginFunctionUnlink );
         registerBuiltinPlugin( &pluginFunctionRegEx );
-        registerBuiltinPlugin( &pluginFunctionRange );
+        registerBuiltinPlugin( &pluginFunctionOpen );
+        registerBuiltinPlugin( &pluginFunctionClose );
+        registerBuiltinPlugin( &pluginFunctionRead );
+        registerBuiltinPlugin( &pluginFunctionWrite );
 
         DIR *dir = opendir("/usr/lib/build");
         if( !dir )
diff --git a/src/functionread.cpp b/src/functionread.cpp
new file mode 100644
index 0000000..789e9e1
--- /dev/null
+++ b/src/functionread.cpp
@@ -0,0 +1,40 @@
+#include "functionread.h"
+#include "filemgr.h"
+
+#include <bu/plugger.h>
+PluginInterface3( pluginFunctionRead, read, FunctionRead, Function,
+                "Mike Buland", 0, 1 );
+
+FunctionRead::FunctionRead()
+{
+}
+
+FunctionRead::~FunctionRead()
+{
+}
+
+Bu::String FunctionRead::getName() const
+{
+        return "read";
+}
+
+Variable FunctionRead::call( Variable &input, VarList lParams )
+{
+        Variable vRet;
+        if( lParams.getSize() == 1 )
+        {
+                int iSize = lParams.first().toInt();
+                Bu::String sBuf( iSize );
+                sBuf.resize(
+                        FileMgr::getInstance().get( (int)input.getOpaque() ).read(
+                                sBuf.getStr(), iSize
+                                )
+                        );
+                vRet = sBuf;
+                return vRet;
+        }
+        throw Bu::ExceptionBase(
+                "read takes zero or one parameters."
+                );
+}
+
diff --git a/src/functionread.h b/src/functionread.h
new file mode 100644
index 0000000..39bf32e
--- /dev/null
+++ b/src/functionread.h
@@ -0,0 +1,17 @@
+#ifndef FUNCTION_READ_H
+#define FUNCTION_READ_H
+
+#include "function.h"
+
+class FunctionRead : public Function
+{
+public:
+        FunctionRead();
+        virtual ~FunctionRead();
+
+        virtual Bu::String getName() const;
+        virtual Variable call( Variable &input, VarList lParams );
+
+};
+
+#endif
diff --git a/src/functionwrite.cpp b/src/functionwrite.cpp
new file mode 100644
index 0000000..7abb661
--- /dev/null
+++ b/src/functionwrite.cpp
@@ -0,0 +1,34 @@
+#include "functionwrite.h"
+#include "filemgr.h"
+
+#include <bu/plugger.h>
+PluginInterface3( pluginFunctionWrite, write, FunctionWrite, Function,
+                "Mike Buland", 0, 1 );
+
+FunctionWrite::FunctionWrite()
+{
+}
+
+FunctionWrite::~FunctionWrite()
+{
+}
+
+Bu::String FunctionWrite::getName() const
+{
+        return "write";
+}
+
+Variable FunctionWrite::call( Variable &input, VarList lParams )
+{
+        if( lParams.getSize() != 1 )
+        {
+                throw Bu::ExceptionBase(
+                        "write takes one parameter, the string to write."
+                        );
+        }
+        FileMgr::getInstance().get( (int)input.getOpaque() ).write(
+                lParams.first().toString()
+                );
+        return Variable();
+}
+
diff --git a/src/functionwrite.h b/src/functionwrite.h
new file mode 100644
index 0000000..75b2283
--- /dev/null
+++ b/src/functionwrite.h
@@ -0,0 +1,17 @@
+#ifndef FUNCTION_WRITE_H
+#define FUNCTION_WRITE_H
+
+#include "function.h"
+
+class FunctionWrite : public Function
+{
+public:
+        FunctionWrite();
+        virtual ~FunctionWrite();
+
+        virtual Bu::String getName() const;
+        virtual Variable call( Variable &input, VarList lParams );
+
+};
+
+#endif
diff --git a/src/variable.cpp b/src/variable.cpp
index 6c9529c..f638dc9 100644
--- a/src/variable.cpp
+++ b/src/variable.cpp
@@ -137,6 +137,13 @@ Variable::Variable( const VarList &lst )
         uVal.lVal = new VarList( lst );
 }
 
+Variable::Variable( void *oVal ) :
+        eType( typeOpaque )
+{
+        memset( &uVal, 0, sizeof(uVal) );
+        uVal.oVal = oVal;
+}
+
 Variable::~Variable()
 {
         if( eType == typeString || eType == typeRef )
@@ -191,6 +198,12 @@ const VarList &Variable::getList() const
         return *uVal.lVal;
 }
 
+const void *Variable::getOpaque() const
+{
+        if( eType != typeOpaque ) throw Bu::ExceptionBase("Wrong variable type.");
+        return uVal.oVal;
+}
+
 int Variable::toInt() const
 {
         switch( eType )
@@ -302,6 +315,10 @@ Bu::String Variable::toString() const
 
                 case typeVersion:
                         break;
+
+                case typeOpaque:
+                        sRet = Bu::String("<opaque:%1>").arg( uVal.oVal );
+                        break;
         }
 
         return sRet;
@@ -341,6 +358,9 @@ Variable Variable::toType( Type eNewType ) const
                 
                 case typeRef:
                         return Variable::mkRef( toString() );
+
+                case typeOpaque:
+                        throw Bu::ExceptionBase("Cannot convert opaque types.");
         }
         throw Bu::ExceptionBase("Unhandled case in Variable toType");
 }
@@ -402,6 +422,9 @@ void Variable::doNegate()
                 
                 case typeRef:
                         throw Bu::ExceptionBase("You cannot negate reference values.");
+                
+                case typeOpaque:
+                        throw Bu::ExceptionBase("You cannot negate opaque values.");
         }
 }
 
@@ -463,6 +486,14 @@ const Variable &Variable::operator=( const Bu::String &rhs )
         return *this;
 }
 
+const Variable &Variable::operator=( void *rhs )
+{
+        reset( typeOpaque );
+        uVal.oVal = rhs;
+
+        return *this;
+}
+
 const Variable &Variable::operator+=( const Variable &rhs )
 {
         switch( eType )
@@ -575,6 +606,9 @@ bool Variable::operator==( const Variable &rhs ) const
 
                 case typeVersion:
                         return false;
+
+                case typeOpaque:
+                        return uVal.oVal == rhs.uVal.oVal;
         }
 
         return false;
@@ -613,6 +647,9 @@ bool Variable::operator<( const Variable &rhs ) const
                 
                 case typeRef:
                         throw Bu::ExceptionBase("You cannot < compare reference values.");
+                
+                case typeOpaque:
+                        throw Bu::ExceptionBase("You cannot < compare opaque values.");
         }
         throw Bu::ExceptionBase("Unhandled case in Variable < compare");
 }
@@ -645,6 +682,9 @@ bool Variable::operator>( const Variable &rhs ) const
                 
                 case typeRef:
                         throw Bu::ExceptionBase("You cannot > compare reference values.");
+                
+                case typeOpaque:
+                        throw Bu::ExceptionBase("You cannot > compare opaque values.");
         }
         throw Bu::ExceptionBase("Unhandled case in Variable > compare");
 }
@@ -677,6 +717,9 @@ bool Variable::operator<=( const Variable &rhs ) const
                 
                 case typeRef:
                         throw Bu::ExceptionBase("You cannot <= compare reference values.");
+                
+                case typeOpaque:
+                        throw Bu::ExceptionBase("You cannot <= compare opaque values.");
         }
         throw Bu::ExceptionBase("Unhandled case in Variable <= compare");
 }
@@ -709,6 +752,9 @@ bool Variable::operator>=( const Variable &rhs ) const
                 
                 case typeRef:
                         throw Bu::ExceptionBase("You cannot >= compare reference values.");
+                
+                case typeOpaque:
+                        throw Bu::ExceptionBase("You cannot >= compare opaque values.");
         }
         throw Bu::ExceptionBase("Unhandled case in Variable >= compare");
 }
@@ -741,6 +787,9 @@ Variable Variable::operator+( const Variable &rhs ) const
                 
                 case typeRef:
                         throw Bu::ExceptionBase("You cannot add reference values.");
+                
+                case typeOpaque:
+                        throw Bu::ExceptionBase("You cannot add opaque values.");
         }
         throw Bu::ExceptionBase("Unhandled case in Variable add");
 }
@@ -773,6 +822,9 @@ Variable Variable::operator-( const Variable &rhs ) const
                 
                 case typeRef:
                         throw Bu::ExceptionBase("You cannot subtract reference values.");
+                
+                case typeOpaque:
+                        throw Bu::ExceptionBase("You cannot subtract opaque values.");
         }
         throw Bu::ExceptionBase("Unhandled case in Variable subtract");
 }
@@ -805,6 +857,9 @@ Variable Variable::operator*( const Variable &rhs ) const
                 
                 case typeRef:
                         throw Bu::ExceptionBase("You cannot multiply reference values.");
+                
+                case typeOpaque:
+                        throw Bu::ExceptionBase("You cannot multiply opaque values.");
         }
         throw Bu::ExceptionBase("Unhandled case in Variable multiply");
 }
@@ -837,6 +892,9 @@ Variable Variable::operator/( const Variable &rhs ) const
                 
                 case typeRef:
                         throw Bu::ExceptionBase("You cannot divide reference values.");
+                
+                case typeOpaque:
+                        throw Bu::ExceptionBase("You cannot divide opaque values.");
         }
         throw Bu::ExceptionBase("Unhandled case in Variable divide");
 }
@@ -868,6 +926,7 @@ Bu::Formatter &operator<<( Bu::Formatter &f, const Variable::Type &t )
                 case Variable::typeList:        f << "list";            break;
                 case Variable::typeVersion:     f << "version";         break;
                 case Variable::typeRef:         f << "ref";                     break;
+                case Variable::typeOpaque:      f << "opaque";          break;
         }
         return f;
 }
@@ -885,6 +944,8 @@ Bu::Formatter &operator<<( Bu::Formatter &f, const Variable &v )
                 case Variable::typeList:        f << v.getList();               break;
                 case Variable::typeVersion:/*f << v.getVersion();*/     break;
                 case Variable::typeRef:         f << v.getString();             break;
+                case Variable::typeOpaque:      f << "<opaque:" << v.getOpaque() << ">";
+                                                                        break;
         }
 
         return f;
@@ -924,6 +985,9 @@ Bu::ArchiveBase &operator<<( Bu::ArchiveBase &ar, const Variable &v )
                 case Variable::typeRef:
                         ar << *v.uVal.sVal;
                         break;
+
+                case Variable::typeOpaque:
+                        break;
         }
 
         return ar;
@@ -966,6 +1030,9 @@ Bu::ArchiveBase &operator>>( Bu::ArchiveBase &ar, Variable &v )
                 case Variable::typeRef:
                         ar >> *v.uVal.sVal;
                         break;
+
+                case Variable::typeOpaque:
+                        break;
         }
         
         return ar;
diff --git a/src/variable.h b/src/variable.h
index 260c96a..241393e 100644
--- a/src/variable.h
+++ b/src/variable.h
@@ -21,7 +21,8 @@ public:
                 typeVersion,
                 typeString,
                 typeList,
-                typeRef                 /**< Reference by name, it's just a string. */
+                typeRef,                        /**< Reference by name, it's just a string. */
+                typeOpaque                      /**< Only useful to functions. */
         };
 
 public:
@@ -41,6 +42,7 @@ public:
          */
         Variable( const StrList &lst );
         Variable( const VarList &lst );
+        Variable( void *oVal );
         virtual ~Variable();
 
         static Variable mkRef( const Bu::String &sVal );
@@ -54,6 +56,7 @@ public:
         bool getBool() const;
         const Bu::String &getString() const;
         const VarList &getList() const;
+        const void *getOpaque() const;
 
         // Conversion functions, they'll return the requested type, maybe an error
         // if the source data is really bad
@@ -77,6 +80,7 @@ public:
         const Variable &operator=( const double &rhs );
         const Variable &operator=( const bool &rhs );
         const Variable &operator=( const Bu::String &rhs );
+        const Variable &operator=( void *rhs );
 
         const Variable &operator+=( const Variable &rhs );
         const Variable &operator<<( const Variable &rhs );
@@ -102,6 +106,7 @@ private:
                 bool bVal;
                 Bu::String *sVal;
                 VarList *lVal;
+                void *oVal;
         } uVal;
 
         void reset( Type eType );