зеркало из https://github.com/mozilla/pjs.git
adding asynchronous text/plain to text/html stream conversion - NOT PART OF BUILD
This commit is contained in:
valeski%netscape.com
Родитель
374e79203e
Коммит
a9b894bc1c
|
|
@ -0,0 +1,252 @@
|
||||||
|
/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*-
|
||||||
|
*
|
||||||
|
* The contents of this file are subject to the Netscape Public
|
||||||
|
* License Version 1.1 (the "License"); you may not use this file
|
||||||
|
* except in compliance with the License. You may obtain a copy of
|
||||||
|
* the License at http://www.mozilla.org/NPL/
|
||||||
|
*
|
||||||
|
* Software distributed under the License is distributed on an "AS
|
||||||
|
* IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or
|
||||||
|
* implied. See the License for the specific language governing
|
||||||
|
* rights and limitations under the License.
|
||||||
|
*
|
||||||
|
* The Original Code is mozilla.org code.
|
||||||
|
*
|
||||||
|
* The Initial Developer of the Original Code is Netscape
|
||||||
|
* Communications Corporation. Portions created by Netscape are
|
||||||
|
* Copyright (C) 1998 Netscape Communications Corporation. All
|
||||||
|
* Rights Reserved.
|
||||||
|
*
|
||||||
|
* Contributor(s):
|
||||||
|
*/
|
||||||
|
|
||||||
|
#include "nsTXTToHTMLConv.h"
|
||||||
|
#include "nsNetUtil.h"
|
||||||
|
#include "nsIStringStream.h"
|
||||||
|
|
||||||
|
#define TOKEN_DELIMITERS "\t\r\n "
|
||||||
|
|
||||||
|
// nsISupports methods
|
||||||
|
NS_IMPL_THREADSAFE_ISUPPORTS3(nsTXTToHTMLConv,
|
||||||
|
nsIStreamConverter,
|
||||||
|
nsIStreamObserver,
|
||||||
|
nsIStreamListener);
|
||||||
|
|
||||||
|
|
||||||
|
// nsIStreamConverter methods
|
||||||
|
NS_IMETHODIMP
|
||||||
|
nsTXTToHTMLConv::Convert(nsIInputStream *aFromStream,
|
||||||
|
const PRUnichar *aFromType, const PRUnichar *aToType,
|
||||||
|
nsISupports *aCtxt, nsIInputStream * *_retval) {
|
||||||
|
return NS_ERROR_NOT_IMPLEMENTED;
|
||||||
|
}
|
||||||
|
|
||||||
|
NS_IMETHODIMP
|
||||||
|
nsTXTToHTMLConv::AsyncConvertData(const PRUnichar *aFromType,
|
||||||
|
const PRUnichar *aToType,
|
||||||
|
nsIStreamListener *aListener,
|
||||||
|
nsISupports *aCtxt) {
|
||||||
|
NS_ASSERTION(aListener, "null pointer");
|
||||||
|
mListener = aListener;
|
||||||
|
return NS_OK;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
// nsIStreamObserver methods
|
||||||
|
NS_IMETHODIMP
|
||||||
|
nsTXTToHTMLConv::OnStartRequest(nsIChannel *aChannel, nsISupports *aContext) {
|
||||||
|
mBuffer = "<html>\n";
|
||||||
|
return mListener->OnStartRequest(aChannel, aContext);
|
||||||
|
}
|
||||||
|
NS_IMETHODIMP
|
||||||
|
nsTXTToHTMLConv::OnStopRequest(nsIChannel *aChannel, nsISupports *aContext,
|
||||||
|
nsresult aStatus, const PRUnichar *aMsg) {
|
||||||
|
nsresult rv = NS_OK;
|
||||||
|
if (mToken) {
|
||||||
|
// we still have an outstanding token
|
||||||
|
PRInt32 back = mBuffer.FindCharInSet(TOKEN_DELIMITERS);
|
||||||
|
if (back == -1) back = mBuffer.Length();
|
||||||
|
(void)CatHTML(0, mBuffer.Length());
|
||||||
|
}
|
||||||
|
mBuffer += "\n</html>";
|
||||||
|
|
||||||
|
nsCOMPtr<nsIInputStream> inputData;
|
||||||
|
nsCOMPtr<nsISupports> inputDataSup;
|
||||||
|
|
||||||
|
rv = NS_NewStringInputStream(getter_AddRefs(inputDataSup), mBuffer);
|
||||||
|
if (NS_FAILED(rv)) return rv;
|
||||||
|
|
||||||
|
inputData = do_QueryInterface(inputDataSup);
|
||||||
|
|
||||||
|
rv = mListener->OnDataAvailable(aChannel, aContext,
|
||||||
|
inputData, 0, mBuffer.Length());
|
||||||
|
if (NS_FAILED(rv)) return rv;
|
||||||
|
|
||||||
|
return mListener->OnStopRequest(aChannel, aContext, aStatus, aMsg);
|
||||||
|
}
|
||||||
|
|
||||||
|
// nsIStreamListener method
|
||||||
|
NS_IMETHODIMP
|
||||||
|
nsTXTToHTMLConv::OnDataAvailable(nsIChannel *aChannel, nsISupports *aContext,
|
||||||
|
nsIInputStream *aInStream,
|
||||||
|
PRUint32 aOffset, PRUint32 aCount) {
|
||||||
|
nsresult rv = NS_OK;
|
||||||
|
nsString pushBuffer;
|
||||||
|
PRUint32 amtRead = 0;
|
||||||
|
char *buffer = (char*)nsAllocator::Alloc(aCount+1);
|
||||||
|
if (!buffer) return NS_ERROR_OUT_OF_MEMORY;
|
||||||
|
|
||||||
|
do {
|
||||||
|
PRUint32 read = 0;
|
||||||
|
rv = aInStream->Read(buffer, aCount-amtRead, &read);
|
||||||
|
if (NS_FAILED(rv)) return rv;
|
||||||
|
|
||||||
|
buffer[read] = '\0';
|
||||||
|
mBuffer += buffer;
|
||||||
|
amtRead += read;
|
||||||
|
|
||||||
|
PRInt32 front = -1, back = -1, tokenLoc = -1, cursor = 0;
|
||||||
|
|
||||||
|
while ( (tokenLoc = FindToken(cursor, &mToken)) > -1) {
|
||||||
|
front = mBuffer.RFindCharInSet(TOKEN_DELIMITERS, tokenLoc);
|
||||||
|
front++;
|
||||||
|
|
||||||
|
back = mBuffer.FindCharInSet(TOKEN_DELIMITERS, tokenLoc);
|
||||||
|
if (back == -1) {
|
||||||
|
// didn't find an ending, buffer up.
|
||||||
|
mBuffer.Left(pushBuffer, front);
|
||||||
|
cursor = front;
|
||||||
|
break;
|
||||||
|
} else {
|
||||||
|
// found the end of the token.
|
||||||
|
cursor = CatHTML(front, back);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
PRInt32 end = mBuffer.RFind(TOKEN_DELIMITERS,
|
||||||
|
PR_FALSE, mBuffer.Length());
|
||||||
|
mBuffer.Left(pushBuffer, PR_MAX(cursor, end));
|
||||||
|
mBuffer.Cut(0, PR_MAX(cursor, end));
|
||||||
|
cursor = 0;
|
||||||
|
|
||||||
|
if (!pushBuffer.IsEmpty()) {
|
||||||
|
nsCOMPtr<nsIInputStream> inputData;
|
||||||
|
nsCOMPtr<nsISupports> inputDataSup;
|
||||||
|
rv = NS_NewStringInputStream(getter_AddRefs(inputDataSup), pushBuffer);
|
||||||
|
if (NS_FAILED(rv)) {
|
||||||
|
nsAllocator::Free(buffer);
|
||||||
|
return rv;
|
||||||
|
}
|
||||||
|
|
||||||
|
inputData = do_QueryInterface(inputDataSup);
|
||||||
|
|
||||||
|
rv = mListener->OnDataAvailable(aChannel, aContext,
|
||||||
|
inputData, 0, pushBuffer.Length());
|
||||||
|
if (NS_FAILED(rv)) {
|
||||||
|
nsAllocator::Free(buffer);
|
||||||
|
return rv;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} while (amtRead < aCount);
|
||||||
|
|
||||||
|
nsAllocator::Free(buffer);
|
||||||
|
return rv;
|
||||||
|
}
|
||||||
|
// nsTXTToHTMLConv methods
|
||||||
|
nsTXTToHTMLConv::nsTXTToHTMLConv() {
|
||||||
|
NS_INIT_REFCNT();
|
||||||
|
mToken = nsnull;
|
||||||
|
}
|
||||||
|
|
||||||
|
PRBool CleanupTokens(void *aElement, void *aData) {
|
||||||
|
if (aElement) delete (convToken*)aElement;
|
||||||
|
return PR_TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
nsTXTToHTMLConv::~nsTXTToHTMLConv() {
|
||||||
|
mTokens.EnumerateForwards((nsVoidArrayEnumFunc)CleanupTokens, nsnull);
|
||||||
|
}
|
||||||
|
|
||||||
|
nsresult
|
||||||
|
nsTXTToHTMLConv::Init() {
|
||||||
|
nsresult rv = NS_OK;
|
||||||
|
|
||||||
|
// build up the list of tokens to handle
|
||||||
|
convToken *token = new convToken;
|
||||||
|
if (!token) return NS_ERROR_OUT_OF_MEMORY;
|
||||||
|
token->prepend = PR_TRUE;
|
||||||
|
token->token = "http://"; // XXX need to iterate through all protos
|
||||||
|
mTokens.AppendElement(token);
|
||||||
|
|
||||||
|
token = new convToken;
|
||||||
|
if (!token) return NS_ERROR_OUT_OF_MEMORY;
|
||||||
|
token->prepend = PR_TRUE;
|
||||||
|
token->token = '@';
|
||||||
|
token->modText = "mailto:";
|
||||||
|
mTokens.AppendElement(token);
|
||||||
|
|
||||||
|
return rv;
|
||||||
|
}
|
||||||
|
|
||||||
|
PRInt32
|
||||||
|
nsTXTToHTMLConv::FindToken(PRInt32 cursor, convToken* *_retval) {
|
||||||
|
PRInt32 loc = -1, firstToken = mBuffer.Length();
|
||||||
|
PRInt8 token = -1;
|
||||||
|
for (PRInt8 i=0; i < mTokens.Count(); i++) {
|
||||||
|
loc = mBuffer.Find(((convToken*)mTokens[i])->token, PR_FALSE, cursor);
|
||||||
|
if (loc != -1)
|
||||||
|
if (loc < firstToken) {
|
||||||
|
firstToken = loc;
|
||||||
|
token = i;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if (token != -1) {
|
||||||
|
*_retval = (convToken*)mTokens[token];
|
||||||
|
return firstToken;
|
||||||
|
} else {
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
PRInt32
|
||||||
|
nsTXTToHTMLConv::CatHTML(PRInt32 front, PRInt32 back) {
|
||||||
|
PRInt32 cursor = 0;
|
||||||
|
if (!mToken->prepend) {
|
||||||
|
// replace the entire token (from delimiter to delimiter)
|
||||||
|
mBuffer.Cut(front, back);
|
||||||
|
mBuffer.Insert(mToken->modText, front);
|
||||||
|
} else {
|
||||||
|
nsString linkText;
|
||||||
|
// href is implied
|
||||||
|
PRInt32 modLen = mToken->modText.Length();
|
||||||
|
mBuffer.Mid(linkText, front, back-front);
|
||||||
|
mBuffer.Insert("<a href=\"", front);
|
||||||
|
cursor += front+9;
|
||||||
|
if (modLen)
|
||||||
|
mBuffer.Insert(mToken->modText, cursor);
|
||||||
|
cursor += modLen-front+back;
|
||||||
|
mBuffer.Insert("\">", cursor);
|
||||||
|
cursor += 2;
|
||||||
|
mBuffer.Insert(linkText, cursor);
|
||||||
|
cursor += linkText.Length();
|
||||||
|
mBuffer.Insert("</a>", cursor);
|
||||||
|
cursor += 4;
|
||||||
|
}
|
||||||
|
mToken = nsnull; // indicates completeness
|
||||||
|
return cursor;
|
||||||
|
}
|
||||||
|
|
||||||
|
nsresult
|
||||||
|
NS_NewNSTXTToHTMLConv(nsTXTToHTMLConv** aTXTToHTMLConv)
|
||||||
|
{
|
||||||
|
NS_PRECONDITION(aTXTToHTMLConv != nsnull, "null ptr");
|
||||||
|
if (!aTXTToHTMLConv)
|
||||||
|
return NS_ERROR_NULL_POINTER;
|
||||||
|
|
||||||
|
*aTXTToHTMLConv = new nsTXTToHTMLConv();
|
||||||
|
if (!*aTXTToHTMLConv)
|
||||||
|
return NS_ERROR_OUT_OF_MEMORY;
|
||||||
|
|
||||||
|
NS_ADDREF(*aTXTToHTMLConv);
|
||||||
|
return (*aTXTToHTMLConv)->Init();
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,96 @@
|
||||||
|
/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*-
|
||||||
|
*
|
||||||
|
* The contents of this file are subject to the Netscape Public
|
||||||
|
* License Version 1.1 (the "License"); you may not use this file
|
||||||
|
* except in compliance with the License. You may obtain a copy of
|
||||||
|
* the License at http://www.mozilla.org/NPL/
|
||||||
|
*
|
||||||
|
* Software distributed under the License is distributed on an "AS
|
||||||
|
* IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or
|
||||||
|
* implied. See the License for the specific language governing
|
||||||
|
* rights and limitations under the License.
|
||||||
|
*
|
||||||
|
* The Original Code is mozilla.org code.
|
||||||
|
*
|
||||||
|
* The Initial Developer of the Original Code is Netscape
|
||||||
|
* Communications Corporation. Portions created by Netscape are
|
||||||
|
* Copyright (C) 1998 Netscape Communications Corporation. All
|
||||||
|
* Rights Reserved.
|
||||||
|
*
|
||||||
|
* Contributor(s):
|
||||||
|
*/
|
||||||
|
|
||||||
|
#ifndef ____nstxttohtmlconv___h___
|
||||||
|
#define ____nstxttohtmlconv___h___
|
||||||
|
|
||||||
|
#include "nsIStreamConverter.h"
|
||||||
|
#include "nsCOMPtr.h"
|
||||||
|
#include "nsVoidArray.h"
|
||||||
|
#include "nsIFactory.h"
|
||||||
|
#include "nsString.h"
|
||||||
|
|
||||||
|
#define NS_NSTXTTOHTMLCONVERTER_CID \
|
||||||
|
{ /* 9ef9fa14-1dd1-11b2-9d65-d72d6d1f025e */ \
|
||||||
|
0x9ef9fa14, \
|
||||||
|
0x1dd1, \
|
||||||
|
0x11b2, \
|
||||||
|
{0x9d, 0x65, 0xd7, 0x2d, 0x6d, 0x1f, 0x02, 0x5e} \
|
||||||
|
}
|
||||||
|
static NS_DEFINE_CID(kNSTXTTOHTMLCONVCID, NS_NSTXTTOHTMLCONVERTER_CID);
|
||||||
|
|
||||||
|
// Internal representation of a "token"
|
||||||
|
typedef struct convToken {
|
||||||
|
nsString token; // the actual string (i.e. "http://")
|
||||||
|
nsString modText; // replacement text or href prepend text.
|
||||||
|
PRBool prepend; // flag indicating how the modText should be used.
|
||||||
|
} convToken;
|
||||||
|
|
||||||
|
class nsTXTToHTMLConv : public nsIStreamConverter {
|
||||||
|
public:
|
||||||
|
NS_DECL_ISUPPORTS
|
||||||
|
NS_DECL_NSISTREAMCONVERTER
|
||||||
|
NS_DECL_NSISTREAMOBSERVER
|
||||||
|
NS_DECL_NSISTREAMLISTENER
|
||||||
|
|
||||||
|
nsTXTToHTMLConv();
|
||||||
|
virtual ~nsTXTToHTMLConv();
|
||||||
|
nsresult Init();
|
||||||
|
|
||||||
|
// For factory creation.
|
||||||
|
static NS_METHOD
|
||||||
|
Create(nsISupports *aOuter, REFNSIID aIID, void **aResult) {
|
||||||
|
nsresult rv;
|
||||||
|
if (aOuter)
|
||||||
|
return NS_ERROR_NO_AGGREGATION;
|
||||||
|
|
||||||
|
nsTXTToHTMLConv* _s = new nsTXTToHTMLConv();
|
||||||
|
if (_s == nsnull)
|
||||||
|
return NS_ERROR_OUT_OF_MEMORY;
|
||||||
|
NS_ADDREF(_s);
|
||||||
|
rv = _s->Init();
|
||||||
|
if (NS_FAILED(rv)) {
|
||||||
|
delete _s;
|
||||||
|
return rv;
|
||||||
|
}
|
||||||
|
rv = _s->QueryInterface(aIID, aResult);
|
||||||
|
NS_RELEASE(_s);
|
||||||
|
return rv;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
protected:
|
||||||
|
// return the token and it's location in the underlying buffer.
|
||||||
|
PRInt32 FindToken(PRInt32 cursor, convToken* *_retval);
|
||||||
|
|
||||||
|
// return the cursor location after munging HTML into the
|
||||||
|
// underlying buffer.
|
||||||
|
PRInt32 CatHTML(PRInt32 front, PRInt32 back);
|
||||||
|
|
||||||
|
nsCOMPtr<nsIStreamListener> mListener; // final listener (consumer)
|
||||||
|
nsString mBuffer; // any carry over data
|
||||||
|
nsVoidArray mTokens; // list of tokens to search for
|
||||||
|
convToken *mToken; // current token (if any)
|
||||||
|
};
|
||||||
|
|
||||||
|
#endif // ____nstxttohtmlconv___h___
|
||||||
|
|
||||||
Загрузка…
Ссылка в новой задаче