[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[bug-myserver] Preliminary to gopher support :)
|
From: |
Domenico Chierico |
|
Subject: |
[bug-myserver] Preliminary to gopher support :) |
|
Date: |
Thu, 29 Oct 2009 23:50:16 +0100 |
hi all!!
this is perhaps useless .. but it's not my own idea :)
cheers
Domenico
>From a03b043ebf1114db9f3eeeca87dacdc093f1c180 Mon Sep 17 00:00:00 2001
From: Domenico Chierico <address@hidden(none)>
Date: Thu, 29 Oct 2009 22:46:06 +0100
Subject: [PATCH] Add support for gopher protocol
---
myserver/configure.ac | 2 +
myserver/include/protocol/Makefile.am | 2 +-
myserver/include/protocol/gopher/Makefile.am | 4 +
myserver/include/protocol/gopher/engine.h | 64 ++++
myserver/include/protocol/gopher/gopher.h | 101 ++++++
myserver/include/protocol/gopher/gopher_content.h | 268
+++++++++++++++
myserver/src/protocol/Makefile.am | 2 +-
myserver/src/protocol/gopher/Makefile.am | 3 +
myserver/src/protocol/gopher/engine.cpp | 313
++++++++++++++++++
myserver/src/protocol/gopher/gopher.cpp | 119 +++++++
myserver/src/protocol/gopher/gopher_content.cpp | 363
+++++++++++++++++++++
myserver/src/server/server.cpp | 2 +
12 files changed, 1241 insertions(+), 2 deletions(-)
create mode 100644 myserver/include/protocol/gopher/Makefile.am
create mode 100644 myserver/include/protocol/gopher/engine.h
create mode 100644 myserver/include/protocol/gopher/gopher.h
create mode 100644 myserver/include/protocol/gopher/gopher_content.h
create mode 100644 myserver/src/protocol/gopher/Makefile.am
create mode 100644 myserver/src/protocol/gopher/engine.cpp
create mode 100644 myserver/src/protocol/gopher/gopher.cpp
create mode 100644 myserver/src/protocol/gopher/gopher_content.cpp
diff --git a/myserver/configure.ac b/myserver/configure.ac
index 1d5c6af..0e6c6d0 100644
--- a/myserver/configure.ac
+++ b/myserver/configure.ac
@@ -438,6 +438,7 @@ AC_CONFIG_FILES([ po/Makefile.in
include/protocol/https/Makefile
include/protocol/http/Makefile
include/protocol/http/env/Makefile
+ include/protocol/gopher/Makefile
include/filter/Makefile
include/filter/gzip/Makefile
include/plugin/Makefile
@@ -494,6 +495,7 @@ AC_CONFIG_FILES([ po/Makefile.in
src/protocol/https/Makefile
src/protocol/http/Makefile
src/protocol/http/env/Makefile
+ src/protocol/gopher/Makefile
src/filter/Makefile
src/filter/gzip/Makefile
src/plugin/Makefile
diff --git a/myserver/include/protocol/Makefile.am
b/myserver/include/protocol/Makefile.am
index aa23116..41dce02 100644
--- a/myserver/include/protocol/Makefile.am
+++ b/myserver/include/protocol/Makefile.am
@@ -1,3 +1,3 @@
protocolincludedir=$(includedir)/myserver/include/protocol
protocolinclude_HEADERS = protocol_buffer.h protocol.h
protocols_manager.h url.h
-SUBDIRS = control ftp http https
+SUBDIRS = control ftp gopher http https
diff --git a/myserver/include/protocol/gopher/Makefile.am
b/myserver/include/protocol/gopher/Makefile.am
new file mode 100644
index 0000000..1995ecf
--- /dev/null
+++ b/myserver/include/protocol/gopher/Makefile.am
@@ -0,0 +1,4 @@
+gopherincludedir=$(includedir)/myserver/include/protocol/gopher
+gopherinclude_HEADERS = gopher.h gopher_content.h engine.h
+
+
diff --git a/myserver/include/protocol/gopher/engine.h
b/myserver/include/protocol/gopher/engine.h
new file mode 100644
index 0000000..b124079
--- /dev/null
+++ b/myserver/include/protocol/gopher/engine.h
@@ -0,0 +1,64 @@
+/* -*- mode: c++ -*- */
+/*
+MyServer
+Copyright (C) 2002-2009 Free Software Foundation, Inc.
+This program is free software; you can redistribute it and/or modify
+it under the terms of the GNU General Public License as published by
+the Free Software Foundation; either version 3 of the License, or
+(at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+GNU General Public License for more details.
+
+You should have received a copy of the GNU General Public License
+along with this program. If not, see <http://www.gnu.org/licenses/>.
+*/
+
+#ifndef GOPHER_ENGINE_H
+#define GOPHER_ENGINE_H
+
+#include "stdafx.h"
+#include <include/base/hash_map/hash_map.h>
+#include <include/conf/vhost/vhost.h>
+#include <include/base/base64/mime_utils.h>
+
+using namespace std;
+
+class GopherEngine;
+
+typedef void (GopherEngine::* MyMethodPtr)(string, string,
GopherMenu&);
+
+class GopherEngine
+{
+public:
+ GopherEngine ();
+ GopherContent &incoming (GopherRequest, Vhost *tmp);
+
+protected:
+ void dirManagement (string fname, string path, GopherMenu &tmp);
+ void fileManagement (string fname, string path ,GopherMenu &tmp);
+
+ void infoFile (string fname, string path, GopherMenu &tmp);
+ void textFile (string fname, string path, GopherMenu &tmp);
+ void csoFile (string fname, string path, GopherMenu &tmp);
+ void binhexFile (string fname, string path, GopherMenu &tmp);
+ void dosbinFile (string fname, string path, GopherMenu &tmp);
+ void UUencodeFile (string fname, string path, GopherMenu &tmp);
+ void telnetFile (string fname, string path, GopherMenu &tmp);
+ void binFile (string fname, string path, GopherMenu &tmp);
+ void imageFile (string fname, string path, GopherMenu &tmp);
+ void gifFile (string fname, string path, GopherMenu &tmp);
+
+ MimeRecord* getMIME (string &filename);
+
+ string abs_path;
+ string hostname;
+ string port;
+ Vhost *Host;
+ HashMap<string,MyMethodPtr> handlers;
+
+ // Class Const
+};
+#endif
diff --git a/myserver/include/protocol/gopher/gopher.h
b/myserver/include/protocol/gopher/gopher.h
new file mode 100644
index 0000000..a96ecda
--- /dev/null
+++ b/myserver/include/protocol/gopher/gopher.h
@@ -0,0 +1,101 @@
+/* -*- mode: c++ -*- */
+/*
+MyServer
+Copyright (C) 2002-2009 Free Software Foundation, Inc.
+This program is free software; you can redistribute it and/or modify
+it under the terms of the GNU General Public License as published by
+the Free Software Foundation; either version 3 of the License, or
+(at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+GNU General Public License for more details.
+
+You should have received a copy of the GNU General Public License
+along with this program. If not, see <http://www.gnu.org/licenses/>.
+*/
+
+#ifndef GOPHER_H
+# define GOPHER_H
+# include "stdafx.h"
+# include <include/protocol/protocol.h>
+# include <sstream>
+# include <include/protocol/gopher/gopher_content.h>
+
+# include <string>
+# include <vector>
+# include <memory>
+
+class Gopher : public Protocol
+{
+public:
+ Gopher();
+ virtual ~Gopher();
+
+ virtual char* registerName(char* out,int len)
+ {return registerNameImpl(out, len);}
+ static char* registerNameImpl(char*, int len);
+
+ int controlConnection(ConnectionPtr a,
+ char *b1,
+ char *b2,
+ int bs1,
+ int bs2,
+ u_long nbtr,
+ u_long id);
+
+
+ static int loadProtocolStatic();
+ static int unLoadProtocolStatic();
+
+ void Reply(ConnectionPtr a,
+ GopherContent &data);
+};
+
+
+/*!
+ *Adapter class to make Gopher reentrant.
+ */
+class GopherProtocol : public Protocol
+{
+public:
+ GopherProtocol()
+ {
+ protocolOptions = 0;
+ }
+
+ virtual ~GopherProtocol()
+ {
+
+ }
+
+ virtual char* registerName(char* out, int len)
+ {
+ return Gopher::registerNameImpl(out, len);
+ }
+
+ virtual int controlConnection(ConnectionPtr a, char *b1, char *b2,
+ int bs1, int bs2, u_long nbtr, u_long
id)
+ {
+ Gopher Gopher;
+ int ret = 0;
+
+ ret = Gopher.controlConnection(a, b1, b2, bs1, bs2, nbtr, id);
+
+ return ret;
+ }
+
+ virtual int loadProtocol()
+ {
+ return Gopher::loadProtocolStatic ();
+ }
+
+ virtual int unLoadProtocol ()
+ {
+ return Gopher::unLoadProtocolStatic ();
+ }
+
+};
+
+#endif
diff --git a/myserver/include/protocol/gopher/gopher_content.h
b/myserver/include/protocol/gopher/gopher_content.h
new file mode 100644
index 0000000..b1d8621
--- /dev/null
+++ b/myserver/include/protocol/gopher/gopher_content.h
@@ -0,0 +1,268 @@
+/* -*- mode: c++ -*- */
+/*
+MyServer
+Copyright (C) 2002-2009 Free Software Foundation, Inc.
+This program is free software; you can redistribute it and/or modify
+it under the terms of the GNU General Public License as published by
+the Free Software Foundation; either version 3 of the License, or
+(at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+GNU General Public License for more details.
+
+You should have received a copy of the GNU General Public License
+along with this program. If not, see <http://www.gnu.org/licenses/>.
+*/
+
+#ifndef GOPHER_CONTENT_H
+#define GOPHER_CONTENT_H
+
+#include "stdafx.h"
+#include <include/base/socket/socket.h>
+#include <include/base/mem_buff/mem_buff.h>
+#include <include/base/file/file.h>
+#include <include/connection/connection.h>
+#include <vector>
+#include <string>
+
+using namespace std;
+
+class GopherContent
+{
+public:
+ virtual void toProtocol(Socket *s) = 0;
+};
+
+class GopherRequest
+{
+public:
+ GopherRequest();
+ GopherRequest(string s){ data = s; }
+ GopherRequest(string s, ConnectionPtr conn)
+ {
+ data = s;
+ baseReq = conn;
+ }
+ void setConnection(ConnectionPtr conn){ baseReq = conn; }
+ string getRequest(){ return data; }
+ ConnectionPtr getConnection(){ return baseReq; }
+protected:
+ string data;
+ ConnectionPtr baseReq;
+};
+
+class GopherItem: public GopherContent
+{
+ public:
+ GopherItem();
+ GopherItem(char, const char[], const char[], const char[], const
char[]);
+
+ ~GopherItem();
+
+ void Type(char T){ type=T; }
+ char Type(){ return type; }
+ void Desc(string D){ desc=D; }
+ string Desc(){ return desc; }
+ void Rlocation(string R){ rlocation=R; }
+ string Rlocation(){ return rlocation; }
+ void Host(string H){ host = H; }
+ string Host(){ return host; }
+ void Port(string P){ port=P; }
+ string Port(){ return port; }
+
+ void toProtocol(Socket *s);
+
+ protected:
+ char type;
+ string desc;
+ string rlocation;
+ string host;
+ string port;
+
+ void init(char, const char[], const char[], const char[], const
char[]);
+
+};
+
+class GopherMenu: public GopherContent
+{
+public:
+ void addIntro(string tmp, string host, string port);
+ void addItem(GopherItem data);
+
+ void toProtocol(Socket *s);
+
+private:
+ vector<GopherItem> Items;
+
+};
+
+
+class GopherInfo: public GopherItem
+{
+public:
+ GopherInfo();
+ GopherInfo(const char[], const char[], const char[], const char[]);
+ ~GopherInfo();
+
+ void Type(char T){ type='i'; }
+};
+
+class GopherFile: public GopherItem
+{
+public:
+ GopherFile();
+ GopherFile(const char[], const char[], const char[], const char[]);
+ ~GopherFile();
+
+ void Type(char T){ type='0'; }
+};
+
+class GopherDirectory: public GopherItem
+{
+public:
+ GopherDirectory();
+ GopherDirectory(const char[], const char[], const char[], const
char[]);
+ ~GopherDirectory();
+
+ void Type(char T){ type='1'; }
+};
+
+class GopherCSO: public GopherItem
+{
+public:
+ GopherCSO();
+ GopherCSO(const char[], const char[], const char[], const char[]);
+ ~GopherCSO();
+
+ void Type(char T){ type='2'; }
+};
+class GopherError: public GopherItem
+{
+public:
+ GopherError();
+ GopherError(const char[], const char[], const char[], const char[]);
+ ~GopherError();
+
+ void Type(char T){ type='3'; }
+};
+
+class GopherMacBinHex: public GopherItem
+{
+public:
+ GopherMacBinHex();
+ GopherMacBinHex(const char[], const char[], const char[], const
char[]);
+ ~GopherMacBinHex();
+
+ void Type(char T){ type='4'; }
+};
+
+class GopherDosBin: public GopherItem
+{
+public:
+ GopherDosBin();
+ GopherDosBin(const char[], const char[], const char[], const char[]);
+ ~GopherDosBin();
+
+ void Type(char T){ type='5'; }
+};
+
+class GopherUnixUUencode: public GopherItem
+{
+public:
+ GopherUnixUUencode();
+ GopherUnixUUencode(const char[], const char[], const char[], const
char[]);
+ ~GopherUnixUUencode();
+
+ void Type(char T){ type='6'; }
+};
+
+class GopherSearchServer: public GopherItem
+{
+public:
+ GopherSearchServer();
+ GopherSearchServer(const char[], const char[], const char[], const
char[]);
+ ~GopherSearchServer();
+
+ void Type(char T){ type='7'; }
+};
+
+class GopherTelnet: public GopherItem
+{
+public:
+ GopherTelnet();
+ GopherTelnet(const char[], const char[], const char[], const char[]);
+ ~GopherTelnet();
+
+ void Type(char T){ type='8'; }
+};
+
+class GopherBin: public GopherItem
+{
+public:
+ GopherBin();
+ GopherBin(const char[], const char[], const char[], const char[]);
+ ~GopherBin();
+
+ void Type(char T){ type='9'; }
+};
+
+class GopherRendundantServer: public GopherItem
+{
+public:
+ GopherRendundantServer();
+ GopherRendundantServer(const char[], const char[], const char[],
const char[]);
+ ~GopherRendundantServer();
+
+ void Type(char T){ type='+'; }
+};
+
+class GopherGif: public GopherItem
+{
+public:
+ GopherGif();
+ GopherGif(const char[], const char[], const char[], const char[]);
+ ~GopherGif();
+
+ void Type(char T){ type='g'; }
+};
+
+class GopherImage: public GopherItem
+{
+public:
+ GopherImage();
+ GopherImage(const char[], const char[], const char[], const char[]);
+ ~GopherImage();
+
+ void Type(char T){ type='I'; }
+};
+
+class GopherData: public GopherContent
+{
+public:
+ GopherData(string);
+
+ void toProtocol(Socket *s);
+
+private:
+ string buff;
+};
+
+
+class GopherFileContent: public GopherContent
+{
+public:
+ GopherFileContent(string s);
+ ~GopherFileContent();
+
+ void toProtocol(Socket *s);
+
+private:
+ File *sfile;
+ MemBuf buf;
+};
+
+
+
+#endif
diff --git a/myserver/src/protocol/Makefile.am
b/myserver/src/protocol/Makefile.am
index 0917b3b..0f26c60 100644
--- a/myserver/src/protocol/Makefile.am
+++ b/myserver/src/protocol/Makefile.am
@@ -1,7 +1,7 @@
lib_LIBRARIES = libprotocol.a
libprotocol_a_SOURCES = protocol_buffer.cpp protocol.cpp
protocols_manager.cpp \
url.cpp
-SUBDIRS = control ftp http https
+SUBDIRS = control ftp gopher http https
AM_CPPFLAGS = $(all_includes)
install:
diff --git a/myserver/src/protocol/gopher/Makefile.am
b/myserver/src/protocol/gopher/Makefile.am
new file mode 100644
index 0000000..f16f2ee
--- /dev/null
+++ b/myserver/src/protocol/gopher/Makefile.am
@@ -0,0 +1,3 @@
+lib_LIBRARIES = libgopher.a
+libgopher_a_SOURCES = gopher.cpp gopher_content.cpp engine.cpp
+AM_CPPFLAGS = $(all_includes)
\ No newline at end of file
diff --git a/myserver/src/protocol/gopher/engine.cpp
b/myserver/src/protocol/gopher/engine.cpp
new file mode 100644
index 0000000..3761c9d
--- /dev/null
+++ b/myserver/src/protocol/gopher/engine.cpp
@@ -0,0 +1,313 @@
+/* -*- mode: c++ -*- */
+/*
+MyServer
+Copyright (C) 2002-2009 Free Software Foundation, Inc.
+This program is free software; you can redistribute it and/or modify
+it under the terms of the GNU General Public License as published by
+the Free Software Foundation; either version 3 of the License, or
+(at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+GNU General Public License for more details.
+
+You should have received a copy of the GNU General Public License
+along with this program. If not, see <http://www.gnu.org/licenses/>.
+*/
+
+#include <include/protocol/gopher/gopher_content.h>
+#include <include/protocol/gopher/engine.h>
+#include <include/conf/vhost/vhost.h>
+#include <include/server/server.h>
+#include <include/base/read_directory/read_directory.h>
+#include <include/base/file/files_utility.h>
+#include <include/base/file/file.h>
+#include <include/base/mem_buff/mem_buff.h>
+
+
+#include <iostream>
+#include <fstream>
+#include <sstream>
+
+GopherEngine::GopherEngine()
+{
+ string info = "info";
+ string cso = "cso";
+ string binhex = "binhex";
+ string dosbin = "dosbin";
+ string UUencode = "UUencode";
+ string telnet = "telnet";
+ string bin = "bin";
+ string image = "image";
+ string gif = "gif";
+ string text = "text";
+ handlers.put (info, &GopherEngine::infoFile);
+ handlers.put (text, &GopherEngine::textFile);
+ handlers.put (cso, &GopherEngine::csoFile);
+ handlers.put (binhex, &GopherEngine::binhexFile);
+ handlers.put (dosbin, &GopherEngine::dosbinFile);
+ handlers.put (UUencode, &GopherEngine::UUencodeFile);
+ handlers.put (telnet, &GopherEngine::telnetFile);
+ handlers.put (bin, &GopherEngine::binFile);
+ handlers.put (image, &GopherEngine::imageFile);
+ handlers.put (gif, &GopherEngine::gifFile);
+}
+
+GopherContent &GopherEngine::incoming(GopherRequest req, Vhost *host)
+{
+ ReadDirectory fd;
+ GopherContent *Gud;
+ GopherMenu *Gu;
+ stringstream Port;
+ Port << host->getPort ();
+ port = Port.str ();
+ hostname = req.getConnection ()->getLocalIpAddr ();
+ abs_path = host->getDocumentRoot ();
+ Host = host;
+
+ string path = abs_path;
+ path.append ("/");
+ path.append (req.getRequest ());
+ if(! fd.findfirst (path.c_str ()))
+ {
+ Gu = new GopherMenu;
+ if(FilesUtility::getPathRecursionLevel (path)>0)
+ {
+ do {
+ if(fd.name[0]!='.')
+ {
+ cout << fd.name << " : " << fd.attrib << endl;
+ if (fd.attrib & FILE_ATTRIBUTE_DIRECTORY)
+ {
+ dirManagement (fd.name, req.getRequest (), *Gu);
+ }
+ else
+ {
+ fileManagement (fd.name, req.getRequest (), *Gu);
+ }
+ }
+ }while(!fd.findnext ());
+ }
+ else
+ {
+ Gu->addIntro(string("Invalid requested Path\n"), hostname, port);
+ }
+ fd.findclose ();
+ }
+ else
+ {
+ Gud = (GopherContent*)new GopherFileContent (path);
+ return *Gud;
+ }
+ return *Gu;
+}
+
+void GopherEngine::dirManagement (string fname, string path, GopherMenu
&tmp)
+{
+ string file_path = path;
+ file_path.append ("/");
+ file_path.append (fname);
+ tmp.addItem (GopherDirectory (fname.c_str (),
+ file_path.c_str (),
+ hostname.c_str (),
+ port.c_str()));
+}
+
+void GopherEngine::fileManagement (string fname, string path,GopherMenu
&tmp)
+{
+ string ext;
+ string f_path = path;
+ if (f_path != ""){
+ f_path.append ("/");
+ }
+ f_path.append (fname);
+ string abs_name = abs_path;
+ if (abs_name != ""){
+ abs_name.append ("/");
+ }
+ abs_name.append(f_path);
+
+ FilesUtility::getFileExt (ext,fname);
+ if (handlers.containsKey (ext.c_str ()))
+ {
+ (this->*handlers.get(ext.c_str ())) (fname, path, tmp);
+ }
+ else
+ {
+ MimeRecord *mime = getMIME (abs_name);
+ if (mime!=NULL)
+ {
+ string mymime = mime->mimeType;
+ mymime = mymime.substr (0,mymime.find ('/',0));
+ if (handlers.containsKey (mymime.c_str ()))
+ {
+ (this->*handlers.get (mymime.c_str ()))(fname, path, tmp);
+ }
+ }
+ else
+ {
+ tmp.addItem (GopherFile (fname.c_str (),
+ f_path.c_str (),
+ hostname.c_str () ,
+ port.c_str()));
+ }
+ }
+}
+
+/*!
+ * Returns the MIME type passing its extension.
+ * Returns zero if the file is registered.
+ */
+MimeRecord* GopherEngine::getMIME (string &filename)
+{
+ /*const char *handler = td->securityToken.getData ("mime.handler",
+ MYSERVER_VHOST_CONF | MYSERVER_SERVER_CONF, NULL);*/
+ const char *handler = NULL;
+
+ if (Host->isMIME ())
+ return Host->getMIME ()->getMIME (filename);
+
+ return Server::getInstance ()->getMimeManager ()->getMIME (filename,
handler);
+}
+void GopherEngine::textFile(string fname, string path,GopherMenu &tmp)
+{
+ string f_path = path;
+ if (f_path != ""){
+ f_path.append ("/");
+ }
+ f_path.append (fname);
+ tmp.addItem (GopherFile (fname.c_str (),
+ f_path.c_str (),
+ hostname.c_str () ,
+ port.c_str()));
+}
+void GopherEngine::csoFile(string fname, string path,GopherMenu &tmp)
+{
+ string f_path = path;
+ if (f_path != ""){
+ f_path.append ("/");
+ }
+ f_path.append (fname);
+ tmp.addItem (GopherCSO (fname.c_str (),
+ f_path.c_str (),
+ hostname.c_str () ,
+ port.c_str()));
+}
+
+void GopherEngine::binhexFile (string fname, string path, GopherMenu
&tmp)
+{
+ string f_path = path;
+ if (f_path != ""){
+ f_path.append ("/");
+ }
+ f_path.append (fname);
+ tmp.addItem (GopherMacBinHex (fname.c_str (),
+ f_path.c_str (),
+ hostname.c_str () ,
+ port.c_str()));
+}
+
+void GopherEngine::dosbinFile (string fname, string path, GopherMenu
&tmp)
+{
+ string f_path = path;
+ if (f_path != ""){
+ f_path.append ("/");
+ }
+ f_path.append (fname);
+ tmp.addItem (GopherDosBin (fname.c_str (),
+ f_path.c_str (),
+ hostname.c_str () ,
+ port.c_str()));
+}
+
+void GopherEngine::UUencodeFile (string fname, string path, GopherMenu
&tmp)
+{
+ string f_path = path;
+ if (f_path != ""){
+ f_path.append ("/");
+ }
+ f_path.append (fname);
+ tmp.addItem (GopherUnixUUencode (fname.c_str (),
+ f_path.c_str (),
+ hostname.c_str () ,
+ port.c_str()));
+}
+void GopherEngine::telnetFile (string fname, string path, GopherMenu
&tmp)
+{
+ string f_path = path;
+ if (f_path != ""){
+ f_path.append ("/");
+ }
+ f_path.append (fname);
+ tmp.addItem (GopherTelnet (fname.c_str (),
+ f_path.c_str (),
+ hostname.c_str () ,
+ port.c_str()));
+}
+void GopherEngine::binFile (string fname, string path, GopherMenu &tmp)
+{
+ string f_path = path;
+ if (f_path != ""){
+ f_path.append ("/");
+ }
+ f_path.append (fname);
+ tmp.addItem (GopherBin (fname.c_str (),
+ f_path.c_str (),
+ hostname.c_str () ,
+ port.c_str()));
+}
+
+void GopherEngine::imageFile (string fname, string path, GopherMenu
&tmp)
+{
+ string f_path = path;
+ if (f_path != ""){
+ f_path.append ("/");
+ }
+ f_path.append (fname);
+ tmp.addItem (GopherImage (fname.c_str (),
+ f_path.c_str (),
+ hostname.c_str () ,
+ port.c_str()));
+}
+
+void GopherEngine::gifFile (string fname, string path, GopherMenu &tmp)
+{
+ string f_path = path;
+ if (f_path != ""){
+ f_path.append ("/");
+ }
+ f_path.append (fname);
+ tmp.addItem (GopherGif (fname.c_str (),
+ f_path.c_str (),
+ hostname.c_str () ,
+ port.c_str()));
+}
+
+void GopherEngine::infoFile(string fname, string path,GopherMenu &tmp)
+{
+ string file_path;
+ file_path.append (abs_path);
+ file_path.append ("/");
+ file_path.append (path);
+ file_path.append ("/");
+ file_path.append (fname);
+
+ File f;
+ int state;
+ u_long fsize;
+ state = f.openFile (file_path.c_str(), File::READ);
+ if(!state)
+ {
+ MemBuf buff;
+ u_long real;
+ int sts;
+ fsize = f.getFileSize ();
+ buff.setLength (fsize);
+ f.read (buff.getBuffer (), fsize, &real);
+ if(real == fsize){
+ tmp.addIntro (buff.getBuffer (), hostname, port);
+ }
+ f.close();
+ }
+}
diff --git a/myserver/src/protocol/gopher/gopher.cpp
b/myserver/src/protocol/gopher/gopher.cpp
new file mode 100644
index 0000000..1ed8449
--- /dev/null
+++ b/myserver/src/protocol/gopher/gopher.cpp
@@ -0,0 +1,119 @@
+/* -*- mode: c++ -*- */
+/*
+MyServer
+Copyright (C) 2002-2009 Free Software Foundation, Inc.
+This program is free software; you can redistribute it and/or modify
+it under the terms of the GNU General Public License as published by
+the Free Software Foundation; either version 3 of the License, or
+(at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+GNU General Public License for more details.
+
+You should have received a copy of the GNU General Public License
+along with this program. If not, see <http://www.gnu.org/licenses/>.
+*/
+
+
+#include <iostream>
+
+
+#include <include/protocol/gopher/gopher.h>
+#include <include/protocol/gopher/gopher_content.h>
+#include <include/protocol/gopher/engine.h>
+#include <include/server/server.h>
+#include <include/server/clients_thread.h>
+#include <include/base/string/securestr.h>
+
+
+/*!
+ * Constructor for the Gopher class
+ */
+
+Gopher::Gopher (){}
+
+/*!
+ * Destructor for the http class.
+ */
+Gopher::~Gopher ()
+{
+ /* clean (); */
+}
+
+
+/*!
+ * Main Clean method usefull in different env
+ */
+
+/* void Gopher::clean(){} */
+
+/*!
+ * Service method
+ */
+
+char *Gopher::registerNameImpl (char* out, int len)
+{
+ if (out)
+ {
+ myserver_strlcpy (out, "GOPHER", len);
+ }
+ return (char*) "GOPHER";
+}
+
+/*!
+ * The loading unloading routine
+ */
+
+int Gopher::loadProtocolStatic ()
+{
+ /* boh */
+}
+
+int Gopher::unLoadProtocolStatic ()
+{
+ return 1;
+}
+
+/*!
+ * Main protocol implementation stuff
+ */
+
+int Gopher::controlConnection (ConnectionPtr pConnection,
+ char *b1,
+ char *b2,
+ int bs1,
+ int bs2,
+ u_long nbtr,
+ u_long id)
+{
+ char buffer[256];
+ u_long nbr;
+ GopherEngine g;
+
+ if (pConnection == NULL)
+ return ClientsThread::DELETE_CONNECTION;
+ Server *server = Server::getInstance ();
+ if (server == NULL)
+ return ClientsThread::DELETE_CONNECTION;
+ string command (b1);
+ string::size_type loc = command.find ('\n',0);
+ while( loc == string::npos ){
+ pConnection->socket->read (buffer, sizeof (buffer), &nbr);
+ command+=buffer;
+ loc = command.find ('\n',0);
+ }
+ GopherContent &Gu = g.incoming (GopherRequest (command.substr (0,
+ ((int)loc)-1),
+ pConnection)
+ ,pConnection->host);
+ Reply (pConnection,Gu);
+}
+
+void Gopher::Reply(ConnectionPtr pConnection,
+ GopherContent &data)
+{
+ data.toProtocol(pConnection->socket);
+ pConnection->socket->close();
+}
diff --git a/myserver/src/protocol/gopher/gopher_content.cpp
b/myserver/src/protocol/gopher/gopher_content.cpp
new file mode 100644
index 0000000..fb608b1
--- /dev/null
+++ b/myserver/src/protocol/gopher/gopher_content.cpp
@@ -0,0 +1,363 @@
+/* -*- mode: c++ -*- */
+/*
+MyServer
+Copyright (C) 2002-2009 Free Software Foundation, Inc.
+This program is free software; you can redistribute it and/or modify
+it under the terms of the GNU General Public License as published by
+the Free Software Foundation; either version 3 of the License, or
+(at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+GNU General Public License for more details.
+
+You should have received a copy of the GNU General Public License
+along with this program. If not, see <http://www.gnu.org/licenses/>.
+*/
+
+#include <iostream>
+#include <sstream>
+#include <string>
+
+#include <include/protocol/gopher/gopher_content.h>
+#include <include/base/string/stringutils.h>
+
+
+void GopherMenu::addIntro(string freeText, string host, string port)
+{
+ size_t size = freeText.size();
+ char myline[size];
+ vector<GopherItem> tmp;
+ istream *res;
+ istringstream str(freeText);
+ while(!str.getline(myline,size).eof())
+ {
+ tmp.push_back(GopherInfo(myline,
+ "(None)",
+ host.c_str(),
+ port.c_str()));
+ }
+ tmp.push_back(GopherInfo(myline,
+ "(None)",
+ host.c_str(),
+ port.c_str()));
+ Items.insert(Items.begin(),tmp.begin(), tmp.end());
+}
+
+void GopherMenu::addItem(GopherItem i)
+{
+ Items.push_back(i);
+}
+
+void GopherMenu::toProtocol(Socket *s)
+{
+ for(int i=0;i<Items.size();i++)
+ {
+ Items.at(i).toProtocol(s);
+ }
+ s->send(".\n",3,0);
+}
+
+GopherItem::GopherItem(char t,
+ const char d[],
+ const char loc[],
+ const char h[],
+ const char p[])
+{
+ init(t,d,loc,h,p);
+}
+
+GopherItem::GopherItem()
+{
+ init(0,"","","","");
+}
+
+void GopherItem::init(char t,
+ const char d[],
+ const char loc[],
+ const char h[],
+ const char p[])
+{
+ Type(t);
+ Desc(d);
+ Rlocation(loc);
+ Host(h);
+ Port(p);
+}
+GopherItem::~GopherItem()
+{
+ /** clean everithig **/
+}
+
+
+void GopherItem::toProtocol(Socket *s)
+{
+ string res;
+ res = "-";
+ res[0]=type;
+ res.append(desc);
+ res.append("\t");
+ res.append(rlocation);
+ res.append("\t");
+ res.append(host);
+ res.append("\t");
+ res.append(port);
+ res.append("\t\n");
+ s->send(res.c_str(), strlen(res.c_str()),0);
+}
+
+GopherInfo::GopherInfo()
+{
+ init('i',"","","","");
+}
+
+GopherInfo::GopherInfo(const char d[],
+ const char loc[],
+ const char h[],
+ const char p[])
+{
+ init('i',d,loc,h,p);
+}
+
+GopherInfo::~GopherInfo(){}
+
+GopherFile::GopherFile()
+{
+ init('0',"","","","");
+}
+
+GopherFile::GopherFile(const char d[],
+ const char loc[],
+ const char h[],
+ const char p[])
+{
+ init('0',d,loc,h,p);
+}
+
+GopherFile::~GopherFile(){}
+
+
+
+GopherDirectory::GopherDirectory()
+{
+ init('1',"","","","");
+}
+
+GopherDirectory::GopherDirectory(const char d[],
+ const char loc[],
+ const char h[],
+ const char p[])
+{
+ init('1',d,loc,h,p);
+}
+
+GopherDirectory::~GopherDirectory()
+{}
+
+GopherCSO::GopherCSO()
+{
+ init('2',"","","","");
+}
+
+GopherCSO::~GopherCSO()
+{}
+GopherCSO::GopherCSO(const char d[],
+ const char loc[],
+ const char h[],
+ const char p[])
+{
+ init('2',d,loc,h,p);
+}
+
+GopherError::GopherError()
+{
+ init('3',"","","","");
+}
+
+GopherError::~GopherError()
+{}
+
+GopherError::GopherError(const char d[],
+ const char loc[],
+ const char h[],
+ const char p[])
+{
+ init('3',d,loc,h,p);
+}
+
+GopherMacBinHex::GopherMacBinHex()
+{
+ init('4',"","","","");
+}
+
+GopherMacBinHex::~GopherMacBinHex()
+{}
+
+GopherMacBinHex::GopherMacBinHex(const char d[],
+ const char loc[],
+ const char h[],
+ const char p[])
+{
+ init('4',d,loc,h,p);
+}
+
+GopherDosBin::GopherDosBin()
+{
+ init('5',"","","","");
+}
+
+GopherDosBin::~GopherDosBin()
+{}
+
+GopherDosBin::GopherDosBin(const char d[],
+ const char loc[],
+ const char h[],
+ const char p[])
+{
+ init('5',d,loc,h,p);
+}
+
+GopherUnixUUencode::GopherUnixUUencode()
+{
+ init('6',"","","","");
+}
+
+GopherUnixUUencode::~GopherUnixUUencode()
+{}
+
+GopherUnixUUencode::GopherUnixUUencode(const char d[],
+ const char loc[],
+ const char h[],
+ const char p[])
+{
+ init('6',d,loc,h,p);
+}
+
+GopherSearchServer::GopherSearchServer()
+{
+ init('7',"","","","");
+}
+
+GopherSearchServer::~GopherSearchServer()
+{}
+
+GopherSearchServer::GopherSearchServer(const char d[],
+ const char loc[],
+ const char h[],
+ const char p[])
+{
+ init('7',d,loc,h,p);
+}
+
+GopherTelnet::GopherTelnet()
+{
+ init('8',"","","","");
+}
+
+GopherTelnet::~GopherTelnet()
+{}
+
+GopherTelnet::GopherTelnet(const char d[],
+ const char loc[],
+ const char h[],
+ const char p[])
+{
+ init('8',d,loc,h,p);
+}
+
+GopherBin::GopherBin()
+{
+ init('9',"","","","");
+}
+
+GopherBin::~GopherBin()
+{}
+
+GopherBin::GopherBin(const char d[],
+ const char loc[],
+ const char h[],
+ const char p[])
+{
+ init('9',d,loc,h,p);
+}
+
+GopherRendundantServer::GopherRendundantServer()
+{
+ init(0,"","","","");
+}
+
+GopherRendundantServer::~GopherRendundantServer()
+{}
+GopherRendundantServer::GopherRendundantServer(const char d[],
+ const char loc[],
+ const char h[],
+ const char p[])
+{
+ init(0,d,loc,h,p);
+}
+
+GopherGif::GopherGif()
+{
+ init('g',"","","","");
+}
+
+GopherGif::~GopherGif()
+{}
+
+GopherGif::GopherGif(const char d[],
+ const char loc[],
+ const char h[],
+ const char p[])
+{
+ init('g',d,loc,h,p);
+}
+
+GopherImage::GopherImage()
+{
+ init('g',"","","","");
+}
+
+GopherImage::~GopherImage()
+{}
+
+GopherImage::GopherImage(const char d[],
+ const char loc[],
+ const char h[],
+ const char p[])
+{
+ init('I',d,loc,h,p);
+}
+
+
+GopherData::GopherData(string data)
+{
+ buff = data;
+}
+
+void GopherData::toProtocol(Socket *s)
+{
+ string res = buff;
+ res.append("\r\n.\r\n");
+ s->send(res.c_str(), strlen(res.c_str()),0);
+}
+
+
+GopherFileContent::GopherFileContent(string fnome)
+{
+ sfile = new File();
+ sfile->openFile(fnome.c_str(), File::READ);
+ buf.setLength (4096);
+}
+
+GopherFileContent::~GopherFileContent()
+{
+ sfile->close();
+ delete sfile;
+}
+
+void GopherFileContent::toProtocol(Socket *s)
+{
+ u_long tmp;
+ sfile->fastCopyToSocket(s, 0, &buf, &tmp);
+}
diff --git a/myserver/src/server/server.cpp
b/myserver/src/server/server.cpp
index 3b0c29a..6890bfd 100644
--- a/myserver/src/server/server.cpp
+++ b/myserver/src/server/server.cpp
@@ -22,6 +22,7 @@ along with this program. If not, see
<http://www.gnu.org/licenses/>.
#include <include/protocol/http/http.h>
#include <include/protocol/https/https.h>
#include <include/protocol/control/control_protocol.h>
+#include <include/protocol/gopher/gopher.h>
#include <include/protocol/ftp/ftp.h>
#include <include/base/string/stringutils.h>
#include <include/base/socket/socket.h>
@@ -360,6 +361,7 @@ void Server::loadPlugins ()
Protocol *protocolsSet[] = {new HttpProtocol (),
new HttpsProtocol (),
+ new GopherProtocol (),
new FtpProtocol (),
new ControlProtocol (),
NULL};
--
1.6.3.3
- [bug-myserver] Preliminary to gopher support :),
Domenico Chierico <=