Add new user note API endpoint

This commit is contained in:
Jesse Wierzbinski 2023-09-22 15:31:41 -10:00
parent d2d2e576a9
commit ee3d4a386f
3 changed files with 82 additions and 0 deletions

View file

@ -74,6 +74,7 @@ Working endpoints are:
- `/api/v1/accounts/:id/unmute` - `/api/v1/accounts/:id/unmute`
- `/api/v1/accounts/:id/pin` - `/api/v1/accounts/:id/pin`
- `/api/v1/accounts/:id/unpin` - `/api/v1/accounts/:id/unpin`
- `/api/v1/accounts/:id/note`
- `/api/v1/accounts/update_credentials` - `/api/v1/accounts/update_credentials`
- `/api/v1/accounts/verify_credentials` - `/api/v1/accounts/verify_credentials`
- `/api/v1/statuses` - `/api/v1/statuses`

View file

@ -0,0 +1,57 @@
import { getUserByToken } from "@auth";
import { parseRequest } from "@request";
import { errorResponse, jsonResponse } from "@response";
import { MatchedRoute } from "bun";
import { Relationship } from "~database/entities/Relationship";
import { User } from "~database/entities/User";
/**
* Sets a user note
*/
export default async (
req: Request,
matchedRoute: MatchedRoute
): Promise<Response> => {
const id = matchedRoute.params.id;
// Check auth token
const token = req.headers.get("Authorization")?.split(" ")[1] || null;
if (!token)
return errorResponse("This method requires an authenticated user", 422);
const self = await getUserByToken(token);
if (!self) return errorResponse("Unauthorized", 401);
const { comment } = await parseRequest<{
comment: string;
}>(req);
const user = await User.findOneBy({
id,
});
if (!user) return errorResponse("User not found", 404);
// Check if already following
let relationship = await self.getRelationshipToOtherUser(user);
if (!relationship) {
// Create new relationship
const newRelationship = await Relationship.createNew(self, user);
self.relationships.push(newRelationship);
await self.save();
relationship = newRelationship;
}
relationship.note = comment ?? "";
// TODO: Implement duration
await relationship.save();
return jsonResponse(await relationship.toAPI());
};

View file

@ -459,6 +459,30 @@ describe("POST /api/v1/accounts/:id/unpin", () => {
}); });
}); });
describe("POST /api/v1/accounts/:id/note", () => {
test("should update the specified account's note and return the updated account object", async () => {
const response = await fetch(
`${config.http.base_url}/api/v1/accounts/${user2.id}/note`,
{
method: "POST",
headers: {
Authorization: `Bearer ${token.access_token}`,
"Content-Type": "application/json",
},
body: JSON.stringify({ comment: "This is a new note" }),
}
);
expect(response.status).toBe(200);
expect(response.headers.get("content-type")).toBe("application/json");
const account: APIAccount = await response.json();
expect(account.id).toBe(user2.id);
expect(account.note).toBe("This is a new note");
});
});
afterAll(async () => { afterAll(async () => {
const activities = await RawActivity.createQueryBuilder("activity") const activities = await RawActivity.createQueryBuilder("activity")
.where("activity.data->>'actor' = :actor", { .where("activity.data->>'actor' = :actor", {