construct/modules/client/rooms/rooms.cc

// Matrix Construct
//
// Copyright (C) Matrix Construct Developers, Authors & Contributors
// Copyright (C) 2016-2018 Jason Volk <jason@zemos.net>
//
// Permission to use, copy, modify, and/or distribute this software for any
// purpose with or without fee is hereby granted, provided that the above
// copyright notice and this permission notice is present in all copies. The
// full license for this software is available in the LICENSE file.

#include "rooms.h"

using namespace ircd;

ircd::mapi::header
IRCD_MODULE
{
	"Client 7 :Rooms"
};

m::resource
rooms_resource
{
	"/_matrix/client/r0/rooms/",
	{
		"(7.0) Rooms",
		resource::DIRECTORY,
	}
};

m::resource
rooms_resource_unstable
{
	"/_matrix/client/unstable/rooms/",
	{
		"(10.0) Rooms (unstable)",
		resource::DIRECTORY,
	}
};

m::resource::response
get_rooms(client &client,
          const m::resource::request &request)
{
	if(request.parv.size() < 2)
		throw m::NEED_MORE_PARAMS
		{
			"/rooms command required"
		};

	m::room::id::buf room_id
	{
		url::decode(room_id, request.parv[0])
	};

	const string_view &cmd
	{
		request.parv[1]
	};

	if(cmd == "event")
		return get__event(client, request, room_id);

	if(cmd == "messages")
		return get__messages(client, request, room_id);

	if(cmd == "state")
		return get__state(client, request, room_id);

	if(cmd == "members")
		return get__members(client, request, room_id);

	if(cmd == "joined_members")
		return get__joined_members(client, request, room_id);

	if(cmd == "context")
		return get__context(client, request, room_id);

	if(cmd == "initialSync")
		return get__initialsync(client, request, room_id);

	if(cmd == "relations")
		return get__relations(client, request, room_id);

	throw m::NOT_FOUND
	{
		"/rooms command not found"
	};
}

m::resource::method
method_get
{
	rooms_resource, "GET", get_rooms
};

m::resource::method
method_get_unstable
{
	rooms_resource_unstable, "GET", get_rooms
};

m::resource::response
put_rooms(client &client,
          const m::resource::request &request)
{
	if(request.parv.size() < 2)
		throw m::NEED_MORE_PARAMS
		{
			"/rooms command required"
		};

	m::room::id::buf room_id
	{
		url::decode(room_id, request.parv[0])
	};

	const string_view &cmd
	{
		request.parv[1]
	};

	if(cmd == "send")
		return put__send(client, request, room_id);

	if(cmd == "state")
		return put__state(client, request, room_id);

	if(cmd == "typing")
		return put__typing(client, request, room_id);

	if(cmd == "redact")
		return put__redact(client, request, room_id);

	throw m::NOT_FOUND
	{
		"/rooms command not found"
	};
}

m::resource::method
method_put
{
	rooms_resource, "PUT", put_rooms,
	{
		method_put.REQUIRES_AUTH
	}
};

m::resource::response
post_rooms(client &client,
           const m::resource::request &request)
{
	if(request.parv.size() < 2)
		throw m::NEED_MORE_PARAMS
		{
			"/rooms command required"
		};

	m::room::id::buf room_id
	{
		url::decode(room_id, request.parv[0])
	};

	const string_view &cmd
	{
		request.parv[1]
	};

	if(cmd == "read_markers")
		return post__read_markers(client, request, room_id);

	if(cmd == "receipt")
		return post__receipt(client, request, room_id);

	if(cmd == "join")
		return post__join(client, request, room_id);

	if(cmd == "invite")
		return post__invite(client, request, room_id);

	if(cmd == "leave")
		return post__leave(client, request, room_id);

	if(cmd == "forget")
		return post__forget(client, request, room_id);

	if(cmd == "kick")
		return post__kick(client, request, room_id);

	if(cmd == "ban")
		return post__ban(client, request, room_id);

	if(cmd == "unban")
		return post__unban(client, request, room_id);

	if(cmd == "redact")
		return post__redact(client, request, room_id);

	if(cmd == "report")
		return post__report(client, request, room_id);

	if(cmd == "upgrade")
		return post__upgrade(client, request, room_id);

	throw m::NOT_FOUND
	{
		"/rooms command not found"
	};
}

m::resource::method
method_post
{
	rooms_resource, "POST", post_rooms,
	{
		method_post.REQUIRES_AUTH
	}
};