This commit is contained in:
Jordan Bancino 2023-04-14 17:50:14 +00:00
parent 3192063340
commit a90f7c4b9e
6 changed files with 226 additions and 1 deletions

View file

@ -87,7 +87,7 @@ Milestone: v0.3.0
[x] Make sure UserLogin() fails if user is deactivated. [x] Make sure UserLogin() fails if user is deactivated.
[x] Change password [x] Change password
[x] Whoami [x] Whoami
[ ] 9: User Data [~] 9: User Data
[ ] 5: Capabilities negotiation [ ] 5: Capabilities negotiation
[ ] 10: Security (Rate Limiting) [ ] 10: Security (Rate Limiting)

View file

@ -104,6 +104,10 @@ ROUTE_IMPL(RouteMatrix, args)
response = MatrixErrorCreate(M_NOT_FOUND); response = MatrixErrorCreate(M_NOT_FOUND);
} }
} }
else if (MATRIX_PATH_EQUALS(pathPart, "profile"))
{
response = RouteUserProfile(args);
}
else else
{ {
HttpResponseStatus(args->context, HTTP_NOT_FOUND); HttpResponseStatus(args->context, HTTP_NOT_FOUND);

View file

@ -0,0 +1,179 @@
/*
* Copyright (C) 2022-2023 Jordan Bancino <@jordan:bancino.net>
*
* Permission is hereby granted, free of charge, to any person
* obtaining a copy of this software and associated documentation files
* (the "Software"), to deal in the Software without restriction,
* including without limitation the rights to use, copy, modify, merge,
* publish, distribute, sublicense, and/or sell copies of the Software,
* and to permit persons to whom the Software is furnished to do so,
* subject to the following conditions:
*
* The above copyright notice and this permission notice shall be
* included in all copies or portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
* BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
* ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
* SOFTWARE.
*/
#include <Routes.h>
#include <string.h>
#include <HashMap.h>
#include <Memory.h>
#include <User.h>
#include <Json.h>
#include <Str.h>
ROUTE_IMPL(RouteUserProfile, args)
{
Db *db = args->matrixArgs->db;
HashMap *request = NULL;
HashMap *response = NULL;
UserId *userId = NULL;
User *user = NULL;
char *serverName = args->matrixArgs->config->serverName;
char *username = NULL;
char *entry = NULL;
char *token = NULL;
char *value = NULL;
if (MATRIX_PATH_PARTS(args->path) < 1)
{
HttpResponseStatus(args->context, HTTP_BAD_REQUEST);
response = MatrixErrorCreate(M_MISSING_PARAM);
goto finish;
}
username = MATRIX_PATH_POP(args->path);
userId = UserIdParse(username, serverName);
if (!userId)
{
HttpResponseStatus(args->context, HTTP_BAD_REQUEST);
response = MatrixErrorCreate(M_INVALID_PARAM);
goto finish;
}
if (strcmp(userId->server, serverName))
{
/* TODO: Implement lookup over federation. */
HttpResponseStatus(args->context, HTTP_FORBIDDEN);
response = MatrixErrorCreate(M_FORBIDDEN);
goto finish;
}
/* TODO: Actually implement user data */
switch (HttpRequestMethodGet(args->context))
{
case HTTP_GET:
user = UserLock(db, userId->localpart);
if (!user)
{
HttpResponseStatus(args->context, HTTP_NOT_FOUND);
response = MatrixErrorCreate(M_NOT_FOUND);
goto finish;
}
if (MATRIX_PATH_PARTS(args->path) > 1)
{
HttpResponseStatus(args->context, HTTP_BAD_REQUEST);
response = MatrixErrorCreate(M_INVALID_PARAM);
goto finish;
}
else if (MATRIX_PATH_PARTS(args->path) == 1)
{
entry = MATRIX_PATH_POP(args->path);
response = HashMapCreate();
value = UserGetProfile(user, entry);
if (value)
{
HashMapSet(response, entry, JsonValueString(value));
}
goto finish;
}
response = HashMapCreate();
value = UserGetProfile(user, "avatar_url");
if (value)
{
HashMapSet(response, "avatar_url", JsonValueString(value));
}
value = UserGetProfile(user, "displayname");
if (value)
{
HashMapSet(response, "displayname", JsonValueString(value));
}
goto finish;
case HTTP_PUT:
if (MATRIX_PATH_PARTS(args->path) == 1)
{
request = JsonDecode(HttpServerStream(args->context));
if (!request)
{
HttpResponseStatus(args->context, HTTP_BAD_REQUEST);
response = MatrixErrorCreate(M_NOT_JSON);
goto finish;
}
response = MatrixGetAccessToken(args->context, &token);
if (response)
{
goto finish;
}
user = UserAuthenticate(db, token);
if (!user)
{
HttpResponseStatus(args->context, HTTP_BAD_REQUEST);
response = MatrixErrorCreate(M_UNKNOWN_TOKEN);
goto finish;
}
entry = MATRIX_PATH_POP(args->path);
if (strcmp(entry, "displayname") == 0 ||
strcmp(entry, "avatar_url") == 0)
{
/* Check if user has privilege to do that action. */
if (!strcmp(userId->localpart, UserGetName(user)))
{
value = JsonValueAsString(HashMapGet(request, entry));
/* TODO: Make UserSetProfile notify other
* parties of the change */
UserSetProfile(user, entry, value);
response = HashMapCreate();
goto finish;
}
/* User is not allowed to carry-on the action */
HttpResponseStatus(args->context, HTTP_FORBIDDEN);
response = MatrixErrorCreate(M_FORBIDDEN);
goto finish;
}
else
{
HttpResponseStatus(args->context, HTTP_BAD_REQUEST);
response = MatrixErrorCreate(M_UNRECOGNIZED);
goto finish;
}
}
else
{
HttpResponseStatus(args->context, HTTP_BAD_REQUEST);
response = MatrixErrorCreate(M_MISSING_PARAM);
goto finish;
}
default:
HttpResponseStatus(args->context, HTTP_BAD_REQUEST);
response = MatrixErrorCreate(M_UNKNOWN);
break;
}
finish:
Free(username);
Free(entry);
UserIdFree(userId);
UserUnlock(user);
JsonFree(request);
return response;
}

View file

@ -614,6 +614,35 @@ UserDeleteToken(User * user, char *token)
return 1; return 1;
} }
char *
UserGetProfile(User *user, char *name)
{
HashMap *json = NULL;
if (!user || !name)
{
return NULL;
}
json = DbJson(user->ref);
return JsonValueAsString(JsonGet(json, 2, "profile", name));
}
void
UserSetProfile(User *user, char *name, char *val)
{
HashMap *json = NULL;
if (!user || !name || !val)
{
return;
}
json = DbJson(user->ref);
JsonValueFree(JsonSet(json, JsonValueString(val), 2, "profile", name));
}
int int
UserDeleteTokens(User * user, char *exempt) UserDeleteTokens(User * user, char *exempt)
{ {

View file

@ -73,6 +73,11 @@ ROUTE(RouteChangePwd); /* /_matrix/client/(r0|v3)/account/pa
ROUTE(RouteTokenValid); /* /_matrix/client/v1/register/m.logi ROUTE(RouteTokenValid); /* /_matrix/client/v1/register/m.logi
* n.registration_token/validity */ * n.registration_token/validity */
ROUTE(RouteUserProfile); /* This route handles:
/_matrix/client/(r0|v3)/profile/(.*),
/_matrix/client/(r0|v3)/profile/(.*)/avatar_url and
/_matrix/client/(r0|v3)/profile/(.*)/displayname*/
#undef ROUTE #undef ROUTE
#endif #endif

View file

@ -26,6 +26,8 @@
#include <Db.h> #include <Db.h>
#include <Json.h>
typedef struct User User; typedef struct User User;
typedef struct UserAccessToken typedef struct UserAccessToken
@ -102,6 +104,12 @@ extern void
extern int extern int
UserDeleteToken(User *, char *); UserDeleteToken(User *, char *);
extern char *
UserGetProfile(User *, char *);
extern void
UserSetProfile(User *, char *, char *);
extern int extern int
UserDeleteTokens(User *, char *); UserDeleteTokens(User *, char *);