Main.cpp

#include <stdio.h>
#include <string.h>
#include <windows.h>
#include "ncbind.hpp"
#include <map>

#define BASENAME TJS_W("var")

// 辞書かどうかの判定
static bool isDirectory(tTJSVariant &base) {
	return base.Type() == tvtObject && base.AsObjectNoAddRef() != NULL;
}

// ファイルかどうかの判定
static bool isFile(tTJSVariant &file) {
	return file.Type() == tvtOctet;
}

/**
 * Variant参照型ストリーム
 */
class VariantStream : public IStream {

public:
	/**
	 * コンストラクタ
	 */
	VariantStream(tTJSVariant &parent) : refCount(1), parent(parent), hBuffer(0), stream(0), cur(0) {};

	/**
	 * ファイルを開く
	 */
	bool open(const ttstr &name, tjs_uint32 flags) {
		close();
		this->name = name;

		// 読み込みのみの場合
		if (flags == TJS_BS_READ) {
			parent.AsObjectClosureNoAddRef().PropGet(0, name.c_str(), NULL, &value, NULL);
			return isFile(value);
		}

		// 書き込みが必要な場合
		hBuffer = ::GlobalAlloc(GMEM_MOVEABLE, 0);
		if (FAILED(::CreateStreamOnHGlobal(hBuffer, FALSE, &stream))) {
			::GlobalFree(hBuffer);
			hBuffer = 0;
			return false;
		}

		// オブジェクトの内容を複製
		if (flags == TJS_BS_UPDATE || flags == TJS_BS_APPEND) {
			parent.AsObjectClosureNoAddRef().PropGet(0, name.c_str(), NULL, &value, NULL);
			if (isFile(value)) {
				stream->Write(value.AsOctetNoAddRef()->GetData(), value.AsOctetNoAddRef()->GetLength(), NULL);
				LARGE_INTEGER n;
				n.QuadPart = 0;
				stream->Seek(n, flags == TJS_BS_UPDATE ? STREAM_SEEK_SET : STREAM_SEEK_END, NULL);
			}
		}
		return true;
	}
	
	// IUnknown
	HRESULT STDMETHODCALLTYPE QueryInterface(REFIID riid, void **ppvObject) {
		if (riid == IID_IUnknown || riid == IID_ISequentialStream || riid == IID_IStream) {
			if (ppvObject == NULL)
				return E_POINTER;
			*ppvObject = this;
			AddRef();
			return S_OK;
		} else {
			*ppvObject = 0;
			return E_NOINTERFACE;
		}
	}

	ULONG STDMETHODCALLTYPE AddRef(void) {
		refCount++;
		return refCount;
	}
	
	ULONG STDMETHODCALLTYPE Release(void) {
		int ret = --refCount;
		if (ret <= 0) {
			delete this;
			ret = 0;
		}
		return ret;
	}

	// ISequentialStream
	HRESULT STDMETHODCALLTYPE Read(void *pv, ULONG cb, ULONG *pcbRead) {
		if (stream) {
			return stream->Read(pv, cb, pcbRead);
		} else {
			const tjs_uint8 *base = getBase();
			tTVInteger size = getSize() - cur;
			if (base && cb > 0 && size > 0) {
				if (cb > size) {
					cb = (ULONG)size;
				}
				memcpy(pv, base + cur, cb);
				cur += cb;
				if (pcbRead) {
					*pcbRead = cb;
				}
				return S_OK;
			} else {
				if (pcbRead) {
					*pcbRead = 0;
				}
				return S_FALSE;
			}
		}
	}

	HRESULT STDMETHODCALLTYPE Write(const void *pv, ULONG cb, ULONG *pcbWritten) {
		if (stream) {
			return stream->Write(pv, cb, pcbWritten);
		} else {
			return E_NOTIMPL;
		}
	}

	// IStream
	HRESULT STDMETHODCALLTYPE Seek(LARGE_INTEGER dlibMove,	DWORD dwOrigin, ULARGE_INTEGER *plibNewPosition) {
		if (stream) {
			return stream->Seek(dlibMove, dwOrigin, plibNewPosition);
		} else {
			switch (dwOrigin) {
			case STREAM_SEEK_CUR:
				cur += dlibMove.QuadPart;
				break;
			case STREAM_SEEK_SET:
				cur = dlibMove.QuadPart;
				break;
			case STREAM_SEEK_END:
				cur = getSize();
				cur += dlibMove.QuadPart;
				break;
			}
			if (plibNewPosition) {
				plibNewPosition->QuadPart = cur;
			}
			return S_OK;
		}
	}
	
	HRESULT STDMETHODCALLTYPE SetSize(ULARGE_INTEGER libNewSize) {
		return stream ? stream ->SetSize(libNewSize) : E_NOTIMPL;
	}
	
	HRESULT STDMETHODCALLTYPE CopyTo(IStream *pstm, ULARGE_INTEGER cb, ULARGE_INTEGER *pcbRead, ULARGE_INTEGER *pcbWritten) {
		return stream ? stream->CopyTo(pstm, cb, pcbRead, pcbWritten) : E_NOTIMPL;
	}

	HRESULT STDMETHODCALLTYPE Commit(DWORD grfCommitFlags) {
		return stream ? stream->Commit(grfCommitFlags) : E_NOTIMPL;
	}

	HRESULT STDMETHODCALLTYPE Revert(void) {
		return stream ? stream->Revert() : E_NOTIMPL;
	}

	HRESULT STDMETHODCALLTYPE LockRegion(ULARGE_INTEGER libOffset, ULARGE_INTEGER cb, DWORD dwLockType) {
		return stream ? stream->LockRegion(libOffset, cb, dwLockType) : E_NOTIMPL;
	}
	
	HRESULT STDMETHODCALLTYPE UnlockRegion(ULARGE_INTEGER libOffset, ULARGE_INTEGER cb, DWORD dwLockType) {
		return stream ? stream->UnlockRegion(libOffset, cb, dwLockType) : E_NOTIMPL;
	}
	
	HRESULT STDMETHODCALLTYPE Stat(STATSTG *pstatstg, DWORD grfStatFlag) {
		return stream ? stream->Stat(pstatstg, grfStatFlag) : E_NOTIMPL;
	}

	HRESULT STDMETHODCALLTYPE Clone(IStream **ppstm) {
		return stream ? stream->Clone(ppstm) : E_NOTIMPL;
	}

protected:

	/**
	 * ファイルを閉じる処理
	 */
	void close() {
		if (stream) {
			stream->Release();
			stream = NULL;
		}
		if (hBuffer) {
			// 書き戻し処理
			if (name != "") {
				unsigned char* pBuffer = (unsigned char*)::GlobalLock(hBuffer);
				if (pBuffer) {
					value = tTJSVariant(pBuffer, GlobalSize(hBuffer));
					parent.AsObjectClosureNoAddRef().PropSet(TJS_MEMBERENSURE, name.c_str(), NULL, &value, NULL);
					::GlobalUnlock(hBuffer);
				}
			}
			::GlobalFree(hBuffer);
			hBuffer = 0;
		}
		value.Clear();
		cur = 0;
	}

    /**
	 * デストラクタ
	 */
	virtual ~VariantStream() {
		close();
	}

	// 読み込み用メモリ領域取得
	const tjs_uint8 *getBase() {
		return isFile(value) ? value.AsOctetNoAddRef()->GetData() : NULL;
	}

	// 読み込み用メモリサイズ取得
	tTVInteger getSize() {
		return isFile(value) ? value.AsOctetNoAddRef()->GetLength() : 0;
	}

private:
	int refCount;
	tTJSVariant parent;
	ttstr name;
	tTJSVariant value;
	HGLOBAL hBuffer;
	IStream *stream;
	tTVInteger cur;
};

/**
 * メンバ登録処理用
 */
class GetLister : public tTJSDispatch /** EnumMembers 用 */
{

public:
	// コンストラクタ
	GetLister(iTVPStorageLister *lister) : lister(lister) {};

	// EnumMember用繰り返し実行部
	// param[0] メンバ名
	// param[1] フラグ
	// param[2] メンバの値
	virtual tjs_error TJS_INTF_METHOD FuncCall( // function invocation
												tjs_uint32 flag,			// calling flag
												const tjs_char * membername,// member name ( NULL for a default member )
												tjs_uint32 *hint,			// hint for the member name (in/out)
												tTJSVariant *result,		// result
												tjs_int numparams,			// number of parameters
												tTJSVariant **param,		// parameters
												iTJSDispatch2 *objthis		// object as "this"
												) {
		if (numparams > 1) {
			tTVInteger flag = param[1]->AsInteger();
			if (!(flag & TJS_HIDDENMEMBER) && isFile(*param[2])) {
				lister->Add(ttstr(param[0]->GetString()));
			}
		}
		if (result) {
			*result = true;
		}
		return TJS_S_OK;
	}

private:
	iTVPStorageLister *lister;
};


/**
 * Varストレージ
 */
class VarStorage : public iTVPStorageMedia
{

public:
	/**
	 * コンストラクタ
	 */
	VarStorage() : refCount(1) {
	}

	// -----------------------------------
	// iTVPStorageMedia Intefaces
	// -----------------------------------

	virtual void TJS_INTF_METHOD AddRef() {
		refCount++;
	};

	virtual void TJS_INTF_METHOD Release() {
		if (refCount == 1) {
			delete this;
		} else {
			refCount--;
		}
	};

	// returns media name like "file", "http" etc.
	virtual void TJS_INTF_METHOD GetName(ttstr &name) {
		name = BASENAME;
	}

	//	virtual ttstr TJS_INTF_METHOD IsCaseSensitive() = 0;
	// returns whether this media is case sensitive or not

	// normalize domain name according with the media's rule
	virtual void TJS_INTF_METHOD NormalizeDomainName(ttstr &name) {
		// nothing to do
	}

	// normalize path name according with the media's rule
	virtual void TJS_INTF_METHOD NormalizePathName(ttstr &name) {
		// nothing to do
	}

	// check file existence
	virtual bool TJS_INTF_METHOD CheckExistentStorage(const ttstr &name) {
		tTJSVariant f = getFile(name);
		return isFile(f);
	}

	// open a storage and return a tTJSBinaryStream instance.
	// name does not contain in-archive storage name but
	// is normalized.
	virtual iTJSBinaryStream * TJS_INTF_METHOD Open(const ttstr & name, tjs_uint32 flags) {
		iTJSBinaryStream *ret = NULL;
		ttstr fname;
		tTJSVariant parent = getParentName(name, fname);
		if (isDirectory(parent) && fname.length() > 0) {
			VariantStream *stream = new VariantStream(parent);
			if (stream) {
				if (stream->open(fname, flags)) {
					ret = TVPCreateBinaryStreamAdapter(stream);
				}
				stream->Release();
			}
		}
		if (!ret) {
			TVPThrowExceptionMessage(TJS_W("cannot open memfile:%1"), name);
		}
		return ret;
	}

	// list files at given place
	virtual void TJS_INTF_METHOD GetListAt(const ttstr &name, iTVPStorageLister * lister) {
		tTJSVariant base = getFile(name);
		if (isDirectory(base)) {
			tTJSVariantClosure closure(new GetLister(lister));
			base.AsObjectClosureNoAddRef().EnumMembers(TJS_IGNOREPROP, &closure, NULL);
			closure.Release();
		}
	}

	// basically the same as above,
	// check wether given name is easily accessible from local OS filesystem.
	// if true, returns local OS native name. otherwise returns an empty string.
	virtual void TJS_INTF_METHOD GetLocallyAccessibleName(ttstr &name) {
		name = "";
	}

protected:

	/**
	 * デストラクタ
	 */
	virtual ~VarStorage() {
	}
	
	/*
	 * 親フォルダとパスを返す
	 * @param name ファイル名
	 * @param fname ファイル名を返す
	 * @return 親フォルダ
	 */
	tTJSVariant getParentName(const ttstr &name, ttstr &fname) {
		// ドメイン部を分離
		const tjs_char *p = name.c_str();
		const tjs_char *q;
		if ((q = TJS_strchr(p, '/'))) {
			ttstr dname = ttstr(p, q-p);
			if (dname != TJS_W(".")) {
				TVPThrowExceptionMessage(TJS_W("no such domain:%1"), dname);
			}
		} else {
			TVPThrowExceptionMessage(TJS_W("invalid path:%1"), name);
		}
		// パス名
		ttstr path = ttstr(q+1);
		iTJSDispatch2 *global = TVPGetScriptDispatch();
		tTJSVariant base(global, global);
		while (path.length() > 0) {
			p = path.c_str();
			q = TJS_strchr(p, '/');
			if (q == NULL) {
				// ファイル
				break;
			} else if (q == p) {
				// フォルダ名が空
				base.Clear();
				break;
			} else {
				// フォルダ
				ttstr member = ttstr(p, q-p);
				tTJSVariant value;
				tTJSVariantClosure &o = base.AsObjectClosureNoAddRef();
				if (((o.IsInstanceOf(0, NULL, NULL, TJS_W("Array"), NULL) == TJS_S_TRUE &&
					  TJS_SUCCEEDED(o.PropGetByNum(0, (tjs_int)TJSStringToInteger(member.c_str()), &value, NULL))) ||
					 (TJS_SUCCEEDED(o.PropGet(0, member.c_str(), NULL, &value, NULL)))) && isDirectory(value)) {
					base = value;
					path = ttstr(q+1);
				} else {
					base.Clear();
					break;
				}
			}
		}
		fname = path;
		return base;
	}
	
	/*
	 * ファイル名に合致する変数を探して返す
	 * @param name ファイル名
	 * @return 発見したファイルまたはフォルダ。見つからない場合は tvtVoid
	 */
	tTJSVariant getFile(const ttstr &name) {
		ttstr fname;
		tTJSVariant base = getParentName(name, fname);
		if (isDirectory(base) && fname.length() > 0) {
			// ファイル
			tTJSVariant value;
			if (TJS_SUCCEEDED(base.AsObjectClosureNoAddRef().PropGet(0, fname.c_str(), NULL, &value, NULL))) {
				base = value;
			} else {
				base.Clear();
			}
		}
		return base;
	}

private:
	tjs_uint refCount; //< リファレンスカウント
};

VarStorage *var = NULL;

/**
 * 開放処理後
 */
static void PreRegistCallback()
{
	if (var == NULL) {
		var = new VarStorage();
		TVPRegisterStorageMedia(var);
	}
}

/**
 * 開放処理後
 */
static void PostUnregistCallback()
{
	if (var != NULL) {
		TVPUnregisterStorageMedia(var);
		var->Release();
		var = NULL;
	}
}

NCB_PRE_REGIST_CALLBACK(PreRegistCallback);
NCB_POST_UNREGIST_CALLBACK(PostUnregistCallback);