10691727698

Committed 03 Sep 2024 10:37PM UTC coverage: 31.858% (+0.02%) from 31.837%

Build # 10691727698

Build Type

Pull #9698

github

Committed by

web-flow

Commit Message

Merge cd390f20b into a6ff63a86

Pull Request Pull Request #9698: Merge master into lw-deploy

Run Details

5070 of 41258 branches covered (12.29%)

Branch coverage included in aggregate %.

157 of 295 new or added lines in 38 files covered. (53.22%)

60 existing lines in 44 files now uncovered.

29363 of 66824 relevant lines covered (43.94%)

184.72 hits per line

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

20.83

/packages/lesswrong/server/repos/SurveySchedulesRepo.ts

import SurveySchedules from "@/lib/collections/surveySchedules/collection";
import AbstractRepo from "./AbstractRepo";
import { recordPerfMetrics } from "./perfMetricWrapper";

export type SurveyScheduleWithSurvey = DbSurveySchedule & {
  survey: DbSurvey,
};

class SurveySchedulesRepo extends AbstractRepo<"SurveySchedules"> {
  constructor() {
    super(SurveySchedules);
  }

  getCurrentFrontpageSurvey(
    currentUser: DbUser | null,
    clientId: string,
  ): Promise<SurveyScheduleWithSurvey | null> {
    if (!clientId) {
      return Promise.resolve(null);
    }
    const isLoggedIn = !!currentUser;
    const userJoin = isLoggedIn
      ? `LEFT JOIN "Users" u ON u."_id" = $3`
      : "";
    const optOutClause = isLoggedIn
      ? `u."optedOutOfSurveys" IS NOT TRUE AND`
      : "";
    const karmaClause = isLoggedIn
      ? `
        CASE
          WHEN ss."minKarma" IS NULL THEN TRUE
          ELSE ss."minKarma" < COALESCE(u."karma", 0)
        END AND
        CASE
          WHEN ss."maxKarma" IS NULL THEN TRUE
          ELSE ss."maxKarma" > COALESCE(u."karma", 0)
        END AND
      `
      : ""
    return this.getRawDb().oneOrNone(`
      SELECT ss.*, ROW_TO_JSON(s.*) "survey"
      FROM "SurveySchedules" ss
      JOIN "Surveys" s ON
        s."_id" = ss."surveyId"
      LEFT JOIN "SurveyResponses" sr ON
        sr."surveyScheduleId" = ss."_id" AND
        (sr."clientId" = $2 OR (sr."userId" IS NOT NULL AND sr."userId" = $3))
      ${userJoin}
      WHERE
        -- Check the impressions limit hasn't been reached yet
        (
          ss."impressionsLimit" IS NULL OR
          ss."impressionsLimit" > ARRAY_LENGTH(ss."clientIds", 1)
        ) AND
        -- Check the user is in the assigned percentage group
        CASE
          WHEN ss."maxVisitorPercentage" IS NULL THEN TRUE
          ELSE ABS(('x' || SUBSTR(MD5(ss."_id" || COALESCE($3, $2)), 1, 16))::BIT(32)::INTEGER) % 100
            < ss."maxVisitorPercentage"
        END AND
        -- Check the schedule is currently running
        (ss."endDate" IS NULL OR ss."endDate" > CURRENT_TIMESTAMP) AND
        (ss."startDate" IS NULL OR ss."startDate" < CURRENT_TIMESTAMP) AND
        ss."deactivated" IS NOT TRUE AND
        -- Check the user hasn't opted-out of surveys
        ${optOutClause}
        -- Check the user meets karma requirements
        ${karmaClause}
        -- Check the user is in the target group
        CASE ss."target"
          WHEN 'loggedInOnly' THEN $1
          WHEN 'loggedOutOnly' THEN NOT $1
          ELSE TRUE
        END AND
        -- Check the user hasn't already responsed to this schedule
        sr."_id" IS NULL AND
        -- Check the user hasn't responded to any scheduled survey in the last week
        NOT EXISTS (
          SELECT 1
          FROM "SurveyResponses"
          WHERE
            ("clientId" = $2 OR ("userId" IS NOT NULL AND "userId" = $3)) AND
            "createdAt" + '1 week'::INTERVAL > CURRENT_TIMESTAMP AND
            "surveyScheduleId" IS NOT NULL
          LIMIT 1
        )
      ORDER BY
        ss."clientIds" @> ('{' || $2 || '}')::VARCHAR[] DESC,
        "endDate" ASC,
        "_id" DESC
      LIMIT 1
    `, [isLoggedIn, clientId, currentUser?._id]);
  }

  async assignClientToSurveySchedule(
    surveyScheduleId: string,
    clientId: string,
  ): Promise<void> {
    await this.none(`
      UPDATE "SurveySchedules"
      SET "clientIds" = FM_ADD_TO_SET("clientIds", $2)
      WHERE "_id" = $1
    `, [surveyScheduleId, clientId]);
  }
}

recordPerfMetrics(SurveySchedulesRepo);

export default SurveySchedulesRepo;

1	import SurveySchedules from "@/lib/collections/surveySchedules/collection";	84✔
2	import AbstractRepo from "./AbstractRepo";	21✔
3	import { recordPerfMetrics } from "./perfMetricWrapper";	21✔
4
5	export type SurveyScheduleWithSurvey = DbSurveySchedule & {
6	survey: DbSurvey,
7	};
8
9	class SurveySchedulesRepo extends AbstractRepo<"SurveySchedules"> {
10	constructor() {
UNCOV 11	super(SurveySchedules);	×
12	}
13
14	getCurrentFrontpageSurvey(
15	currentUser: DbUser \| null,
16	clientId: string,
17	): Promise<SurveyScheduleWithSurvey \| null> {
18	if (!clientId) {	×
19	return Promise.resolve(null);	×
20	}
21	const isLoggedIn = !!currentUser;	×
22	const userJoin = isLoggedIn	×
23	? `LEFT JOIN "Users" u ON u."_id" = $3`	×
24	: "";
25	const optOutClause = isLoggedIn	×
26	? `u."optedOutOfSurveys" IS NOT TRUE AND`	×
27	: "";
28	const karmaClause = isLoggedIn	×
29	? `	×
30	CASE
31	WHEN ss."minKarma" IS NULL THEN TRUE
32	ELSE ss."minKarma" < COALESCE(u."karma", 0)
33	END AND
34	CASE
35	WHEN ss."maxKarma" IS NULL THEN TRUE
36	ELSE ss."maxKarma" > COALESCE(u."karma", 0)
37	END AND
38	`
39	: ""
40	return this.getRawDb().oneOrNone(`	×
41	SELECT ss., ROW_TO_JSON(s.) "survey"
42	FROM "SurveySchedules" ss
43	JOIN "Surveys" s ON
44	s."_id" = ss."surveyId"
45	LEFT JOIN "SurveyResponses" sr ON
46	sr."surveyScheduleId" = ss."_id" AND
47	(sr."clientId" = $2 OR (sr."userId" IS NOT NULL AND sr."userId" = $3))
48	${userJoin}
49	WHERE
50	-- Check the impressions limit hasn't been reached yet
51	(
52	ss."impressionsLimit" IS NULL OR
53	ss."impressionsLimit" > ARRAY_LENGTH(ss."clientIds", 1)
54	) AND
55	-- Check the user is in the assigned percentage group
56	CASE
57	WHEN ss."maxVisitorPercentage" IS NULL THEN TRUE
58	ELSE ABS(('x' \|\| SUBSTR(MD5(ss."_id" \|\| COALESCE($3, $2)), 1, 16))::BIT(32)::INTEGER) % 100
59	< ss."maxVisitorPercentage"
60	END AND
61	-- Check the schedule is currently running
62	(ss."endDate" IS NULL OR ss."endDate" > CURRENT_TIMESTAMP) AND
63	(ss."startDate" IS NULL OR ss."startDate" < CURRENT_TIMESTAMP) AND
64	ss."deactivated" IS NOT TRUE AND
65	-- Check the user hasn't opted-out of surveys
66	${optOutClause}
67	-- Check the user meets karma requirements
68	${karmaClause}
69	-- Check the user is in the target group
70	CASE ss."target"
71	WHEN 'loggedInOnly' THEN $1
72	WHEN 'loggedOutOnly' THEN NOT $1
73	ELSE TRUE
74	END AND
75	-- Check the user hasn't already responsed to this schedule
76	sr."_id" IS NULL AND
77	-- Check the user hasn't responded to any scheduled survey in the last week
78	NOT EXISTS (
79	SELECT 1
80	FROM "SurveyResponses"
81	WHERE
82	("clientId" = $2 OR ("userId" IS NOT NULL AND "userId" = $3)) AND
83	"createdAt" + '1 week'::INTERVAL > CURRENT_TIMESTAMP AND
84	"surveyScheduleId" IS NOT NULL
85	LIMIT 1
86	)
87	ORDER BY
88	ss."clientIds" @> ('{' \|\| $2 \|\| '}')::VARCHAR[] DESC,
89	"endDate" ASC,
90	"_id" DESC
91	LIMIT 1
92	`, [isLoggedIn, clientId, currentUser?._id]);	×
93	}
94
95	async assignClientToSurveySchedule(
96	surveyScheduleId: string,
97	clientId: string,
98	): Promise<void> {
99	await this.none(`	×
100	UPDATE "SurveySchedules"
101	SET "clientIds" = FM_ADD_TO_SET("clientIds", $2)
102	WHERE "_id" = $1
103	`, [surveyScheduleId, clientId]);
104	}
105	}	21✔
106
107	recordPerfMetrics(SurveySchedulesRepo);
108
109	export default SurveySchedulesRepo;	21✔

ForumMagnum / ForumMagnum / 10691727698

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