10730148275

Committed 06 Sep 2024 12:18AM UTC coverage: 31.837% (-0.02%) from 31.854%

Build # 10730148275

Build Type

Pull #9721

github

Committed by

b0b3rt

Commit Message

missed a bit

Pull Request Pull Request #9721: Llm chat post drafts

Run Details

5025 of 41223 branches covered (12.19%)

Branch coverage included in aggregate %.

25 of 76 new or added lines in 15 files covered. (32.89%)

33 existing lines in 4 files now uncovered.

29359 of 66777 relevant lines covered (43.97%)

187.72 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

28.36

/packages/lesswrong/server/fmCrosspost/requestHandlers.ts

import type { Request } from "express";
import Posts from "../../lib/collections/posts/collection";
import Users from "../../lib/collections/users/collection";
import { getGraphQLSingleQueryFromOptions, getResolverNameFromOptions } from "../../lib/crud/withSingle";
import { Utils } from "../../lib/vulcan-lib";
import { createClient } from "../vulcan-lib/apollo-ssr/apolloClient";
import { createAnonymousContext } from "../vulcan-lib/query";
import { extractDenormalizedData } from "./denormalizedFields";
import { InvalidUserError, UnauthorizedError } from "./errors";
import { validateCrosspostingKarmaThreshold } from "./helpers";
import type { GetRouteOf, PostRouteOf } from "./routes";
import { signToken, verifyToken } from "./tokens";
import { getAllRepos } from "@/server/repos";
import {
  ConnectCrossposterPayload, ConnectCrossposterPayloadValidator, CrosspostPayloadValidator, UnlinkCrossposterPayloadValidator, UpdateCrosspostPayloadValidator
} from "./types";

export const onCrosspostTokenRequest: GetRouteOf<'crosspostToken'> = async (req: Request) => {
  const {user} = req;
  if (!user) {
    throw new UnauthorizedError();
  }

  // Throws an error if user doesn't have enough karma on the source forum (which is the current execution environment)
  validateCrosspostingKarmaThreshold(user);

  const token = await signToken<ConnectCrossposterPayload>({ userId: user._id });
  return {token};
};

export const onConnectCrossposterRequest: PostRouteOf<'connectCrossposter'> = async (req) => {
  const { token, localUserId } = req;
  const payload = await verifyToken(token, ConnectCrossposterPayloadValidator.is);
  const {userId: foreignUserId} = payload;
  await Users.rawUpdateOne({_id: foreignUserId}, {
    $set: {fmCrosspostUserId: localUserId},
  });
  return {
    status: "connected",
    foreignUserId,
    localUserId,
  };
};

export const onUnlinkCrossposterRequest: PostRouteOf<'unlinkCrossposter'> = async (req) => {
  const { token } = req;
  const payload = await verifyToken(token, UnlinkCrossposterPayloadValidator.is);
  const {userId} = payload;
  await Users.rawUpdateOne({_id: userId}, {
    $unset: {fmCrosspostUserId: ""},
  });
  return { status: 'unlinked' };
};

export const onCrosspostRequest: PostRouteOf<'crosspost'> = async (req) => {
  const { token } = req;
  const payload = await verifyToken(token, CrosspostPayloadValidator.is);
  const {localUserId, foreignUserId, postId, ...rest} = payload;
  const denormalizedData = extractDenormalizedData(rest);

  const user = await Users.findOne({_id: foreignUserId});
  if (!user || user.fmCrosspostUserId !== localUserId) {
    throw new InvalidUserError();
  }

  /**
   * TODO: Null is made legal value for fields but database types are incorrectly generated without null. 
   * Hacky fix for now. Search 84b2 to find all instances of this casting.
   */
  const document: Partial<DbPost> = {
    userId: user._id,
    fmCrosspost: {
      isCrosspost: true,
      hostedHere: false,
      foreignPostId: postId,
    },
    ...denormalizedData,
  } as Partial<DbPost>;

  const {data: post} = await Utils.createMutator({
    document,
    collection: Posts,
    validate: false,
    currentUser: user,
    // This is a hack - we have only a fraction of the necessary information for
    // a context. But it appears to be working.
    context: {
      currentUser: user,
      isFMCrosspostRequest: true,
      Users,
      repos: getAllRepos(),
    } as Partial<ResolverContext> as  ResolverContext,
  });

  return {
    status: "posted",
    postId: post._id,
  };
};

//TODO: clean up typecast `as Partial<DbPost>` below, Code: 84b2
export const onUpdateCrosspostRequest: PostRouteOf<'updateCrosspost'> = async (req) => {
  const { token } = req;
  const {postId, ...rest} = await verifyToken(token, UpdateCrosspostPayloadValidator.is);
  const denormalizedData: Partial<DbPost> = extractDenormalizedData(rest) as Partial<DbPost>;
  await Posts.rawUpdateOne({_id: postId}, {$set: denormalizedData});
  return { status: 'updated' };
};

export const onGetCrosspostRequest: PostRouteOf<'getCrosspost'> = async (req) => {
  const { collectionName, extraVariables, extraVariablesValues, fragmentName, documentId } = req;
  const apolloClient = await createClient(createAnonymousContext());
  const query = getGraphQLSingleQueryFromOptions({
    extraVariables,
    collectionName,
    fragmentName,
    fragment: undefined,
  });
  const resolverName = getResolverNameFromOptions(collectionName);

  const { data } = await apolloClient.query({
    query,
    variables: {
      input: {
        selector: { documentId }
      },
      ...extraVariablesValues
    },
  });

  const document = data?.[resolverName]?.result;

  return { document };
};

1	import type { Request } from "express";	54✔
2	import Posts from "../../lib/collections/posts/collection";	18✔
3	import Users from "../../lib/collections/users/collection";	18✔
4	import { getGraphQLSingleQueryFromOptions, getResolverNameFromOptions } from "../../lib/crud/withSingle";	18✔
5	import { Utils } from "../../lib/vulcan-lib";	18✔
6	import { createClient } from "../vulcan-lib/apollo-ssr/apolloClient";	18✔
7	import { createAnonymousContext } from "../vulcan-lib/query";	18✔
8	import { extractDenormalizedData } from "./denormalizedFields";	18✔
9	import { InvalidUserError, UnauthorizedError } from "./errors";	18✔
10	import { validateCrosspostingKarmaThreshold } from "./helpers";	18✔
11	import type { GetRouteOf, PostRouteOf } from "./routes";
12	import { signToken, verifyToken } from "./tokens";	18✔
13	import { getAllRepos } from "@/server/repos";	18✔
14	import {
15	ConnectCrossposterPayload, ConnectCrossposterPayloadValidator, CrosspostPayloadValidator, UnlinkCrossposterPayloadValidator, UpdateCrosspostPayloadValidator
16	} from "./types";	18✔
17
18	export const onCrosspostTokenRequest: GetRouteOf<'crosspostToken'> = async (req: Request) => {	18✔
19	const {user} = req;	×
20	if (!user) {	×
21	throw new UnauthorizedError();	×
22	}
23
24	// Throws an error if user doesn't have enough karma on the source forum (which is the current execution environment)
25	validateCrosspostingKarmaThreshold(user);	×
26
27	const token = await signToken<ConnectCrossposterPayload>({ userId: user._id });	×
28	return {token};	×
29	};
30
31	export const onConnectCrossposterRequest: PostRouteOf<'connectCrossposter'> = async (req) => {	18✔
32	const { token, localUserId } = req;	×
33	const payload = await verifyToken(token, ConnectCrossposterPayloadValidator.is);	×
34	const {userId: foreignUserId} = payload;	×
35	await Users.rawUpdateOne({_id: foreignUserId}, {	×
36	$set: {fmCrosspostUserId: localUserId},
37	});
38	return {	×
39	status: "connected",
40	foreignUserId,
41	localUserId,
42	};
43	};
44
45	export const onUnlinkCrossposterRequest: PostRouteOf<'unlinkCrossposter'> = async (req) => {	18✔
46	const { token } = req;	×
47	const payload = await verifyToken(token, UnlinkCrossposterPayloadValidator.is);	×
48	const {userId} = payload;	×
49	await Users.rawUpdateOne({_id: userId}, {	×
50	$unset: {fmCrosspostUserId: ""},
51	});
52	return { status: 'unlinked' };	×
53	};
54
55	export const onCrosspostRequest: PostRouteOf<'crosspost'> = async (req) => {	18✔
56	const { token } = req;	×
57	const payload = await verifyToken(token, CrosspostPayloadValidator.is);	×
58	const {localUserId, foreignUserId, postId, ...rest} = payload;	×
59	const denormalizedData = extractDenormalizedData(rest);	×
60
61	const user = await Users.findOne({_id: foreignUserId});	×
62	if (!user \|\| user.fmCrosspostUserId !== localUserId) {	×
63	throw new InvalidUserError();	×
64	}
65
66	/**
67	* TODO: Null is made legal value for fields but database types are incorrectly generated without null.
68	* Hacky fix for now. Search 84b2 to find all instances of this casting.
69	*/
70	const document: Partial<DbPost> = {	×
71	userId: user._id,
72	fmCrosspost: {
73	isCrosspost: true,
74	hostedHere: false,
75	foreignPostId: postId,
76	},
77	...denormalizedData,
78	} as Partial<DbPost>;
79
80	const {data: post} = await Utils.createMutator({	×
81	document,
82	collection: Posts,
83	validate: false,
84	currentUser: user,
85	// This is a hack - we have only a fraction of the necessary information for
86	// a context. But it appears to be working.
87	context: {
88	currentUser: user,
89	isFMCrosspostRequest: true,
90	Users,
91	repos: getAllRepos(),
92	} as Partial<ResolverContext> as ResolverContext,
93	});
94
95	return {	×
96	status: "posted",
97	postId: post._id,
98	};
99	};
100
101	//TODO: clean up typecast `as Partial<DbPost>` below, Code: 84b2
102	export const onUpdateCrosspostRequest: PostRouteOf<'updateCrosspost'> = async (req) => {	18✔
103	const { token } = req;	×
104	const {postId, ...rest} = await verifyToken(token, UpdateCrosspostPayloadValidator.is);	×
105	const denormalizedData: Partial<DbPost> = extractDenormalizedData(rest) as Partial<DbPost>;	×
106	await Posts.rawUpdateOne({_id: postId}, {$set: denormalizedData});	×
107	return { status: 'updated' };	×
108	};
109
110	export const onGetCrosspostRequest: PostRouteOf<'getCrosspost'> = async (req) => {	18✔
111	const { collectionName, extraVariables, extraVariablesValues, fragmentName, documentId } = req;	×
112	const apolloClient = await createClient(createAnonymousContext());	×
NEW 113	const query = getGraphQLSingleQueryFromOptions({	×
114	extraVariables,
115	collectionName,
116	fragmentName,
117	fragment: undefined,
118	});
119	const resolverName = getResolverNameFromOptions(collectionName);	×
120
121	const { data } = await apolloClient.query({	×
122	query,
123	variables: {
124	input: {
125	selector: { documentId }
126	},
127	...extraVariablesValues
128	},
129	});
130
131	const document = data?.[resolverName]?.result;	×
132
133	return { document };	×
134	};

ForumMagnum / ForumMagnum / 10730148275

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous