/*
 * Copyright 2004-2010, Jérôme Duval. All rights reserved.
 * Distributed under the terms of the MIT License.
 * Original code from ZipOMatic by jonas.sundstrom@kirilla.com
 */
#ifndef _EXPANDER_THREAD_H
#define _EXPANDER_THREAD_H


#include <Message.h>
#include <Volume.h>
#include <String.h>
#include <OS.h>
#include <FindDirectory.h>

#include "GenericThread.h"
#include <stdio.h>
#include <stdlib.h>


extern const char* ExpanderThreadName;


class ExpanderThread : public GenericThread {
public:
                                                                ExpanderThread(BMessage* refs_message,
                                                                        BMessenger* messenger);
                                                                ~ExpanderThread();

                        status_t                        SuspendExternalExpander();
                        status_t                        ResumeExternalExpander();
                        status_t                        InterruptExternalExpander();
                        status_t                        WaitOnExternalExpander();

                        void                            PushInput(BString text);

private:
        virtual status_t                        ThreadStartup();
        virtual status_t                        ExecuteUnit();
        virtual status_t                        ThreadShutdown();

        virtual void                            ThreadStartupFailed(status_t a_status);
        virtual void                            ExecuteUnitFailed(status_t a_status);
        virtual void                            ThreadShutdownFailed(status_t a_status);

                        status_t                        ProcessRefs(BMessage* message);

                        thread_id                       PipeCommand(int argc, const char** argv,
                                                                        int& in, int& out, int& err,
                                                                        const char** envp = (const char**)environ);

                        BMessenger*                     fWindowMessenger;

                        thread_id                       fThreadId;
                        int                                     fStdIn;
                        int                                     fStdOut;
                        int                                     fStdErr;
                        FILE*                           fExpanderOutput;
                        FILE*                           fExpanderError;
                        char                            fExpanderOutputBuffer[LINE_MAX];
};


#endif  // _EXPANDER_THREAD_H