First draft of Mkdir in HTTPFileSystem

src/HTTPCommands.cc

@@ -468,6 +468,15 @@ bool HTTPRequest::SetupHandle(CURL *curl) {
 		}
 	}
 
+	if (httpVerb == "MKCOL") {
+		rv = curl_easy_setopt(curl, CURLOPT_CUSTOMREQUEST, "MKCOL");
+		if (rv != CURLE_OK) {
+			this->errorCode = "E_CURL_LIB";
+			this->errorMessage = "curl_easy_setopt( CURLOPT_MKCOL ) failed.";
+			return false;
+		}
+	}
+
 	if (httpVerb == "POST") {
 		rv = curl_easy_setopt(curl, CURLOPT_POST, 1);
 		if (rv != CURLE_OK) {
@@ -827,3 +836,13 @@ bool HTTPHead::SendRequest() {
 }
 
 // ---------------------------------------------------------------------------
+
+HTTPMkcol::~HTTPMkcol() {}
+
+bool HTTPMkcol::SendRequest() {
+	httpVerb = "MKCOL";
+	expectedResponseCode = 201;
+	std::string noPayloadAllowed;
+	return SendHTTPRequest(noPayloadAllowed);
+}
+

src/HTTPCommands.hh

@@ -336,3 +336,19 @@ class HTTPHead : public HTTPRequest {
   protected:
 	std::string object;
 };
+
+class HTTPMkcol : public HTTPRequest {
+  public:
+	HTTPMkcol(const std::string &h, const std::string &o, XrdSysError &log,
+			 const TokenFile *token)
+		: HTTPRequest(h, log, token), object(o) {
+		hostUrl = hostUrl + "/" + object;
+	}
+
+	virtual ~HTTPMkcol();
+
+	virtual bool SendRequest();
+
+  protected:
+	std::string object;
+};

src/HTTPFileSystem.cc

@@ -18,6 +18,7 @@
 
 #include "HTTPFileSystem.hh"
 #include "HTTPDirectory.hh"
+#include "HTTPCommands.hh"
 #include "HTTPFile.hh"
 #include "logging.hh"
 
@@ -173,3 +174,10 @@ int HTTPFileSystem::Create(const char *tid, const char *path, mode_t mode,
 
 	return 0;
 }
+
+int HTTPFileSystem::Mkdir(const char *path, mode_t mode, int mkpath,
+			  XrdOucEnv *env) {
+	HTTPMkcol mkcol(m_url_base, path, m_log, getToken());
+	mkcol.SendRequest();
+	return 0;
+}

src/HTTPFileSystem.hh

@@ -54,9 +54,7 @@ class HTTPFileSystem : public XrdOss {
 	int Init(XrdSysLogger *lp, const char *cfn) { return 0; }
 	int Init(XrdSysLogger *lp, const char *cfn, XrdOucEnv *en) { return 0; }
 	int Mkdir(const char *path, mode_t mode, int mkpath = 0,
-			  XrdOucEnv *env = 0) {
-		return -ENOSYS;
-	}
+			 XrdOucEnv *env = 0);
 	int Reloc(const char *tident, const char *path, const char *cgName,
 			  const char *anchor = 0) {
 		return -ENOSYS;

test/http_tests.cc

@@ -82,6 +82,15 @@ TEST(TestHTTPFile, TestXfer) {
 	ASSERT_EQ(fh->Close(), 0);
 }
 
+TEST(TestHTTPFile, TestMkdir) {
+	XrdSysLogger log;
+
+	HTTPFileSystem fs(&log, g_config_file.c_str(), nullptr);
+
+	const auto ret = fs.Mkdir("newdir/", 0755);
+	ASSERT_EQ(ret, 0);
+}
+
 class TestHTTPRequest : public HTTPRequest {
   public:
 	XrdSysLogger log{};

test/xrdhttp-setup.sh

@@ -161,7 +161,7 @@ EOF
 
 cat > $XROOTD_CONFIGDIR/authdb <<EOF
 
-u * / lr
+u * / lri
 
 EOF