From 5c062d742d846697af1885db78f8279021d80a11 Mon Sep 17 00:00:00 2001 From: Alvin Mites Date: Mon, 5 Jul 2021 21:49:24 -0600 Subject: [PATCH 1/3] grooming --- .../api/resource/issues/_setResolved.ts | 76 +++++++++---------- 1 file changed, 38 insertions(+), 38 deletions(-) diff --git a/packages/server/src/routes/api/resource/issues/_setResolved.ts b/packages/server/src/routes/api/resource/issues/_setResolved.ts index 46307815e..7a29b17ab 100644 --- a/packages/server/src/routes/api/resource/issues/_setResolved.ts +++ b/packages/server/src/routes/api/resource/issues/_setResolved.ts @@ -56,47 +56,47 @@ export async function setResolved(resolved: boolean, req, res, next) { message: `Service Provider issue with _id ${_id} could not be found`, }) ); - } else { + } + + try { + issue.resolved = resolved; + await issue.save(); + // Create Event Log try { - issue.resolved = resolved; - await issue.save(); - // Create Event Log - try { - const resource = await Resource.getByResourceId(issue.resourceId); - const kind: EventLogKind = resolved - ? EventLogKind.ResourceIssueResolved - : EventLogKind.ResourceIssueReopened; - const newDocument = await new EventLog({ - actor: user._id, - detail: { - kind, - resourceId: issue.resourceId.toHexString(), - resourceName: resource.name, - resourceIssueSeverity: issue.severity, - resourceIssueKind: issue.kind, - resourceIssueId: issue._id.toHexString(), - }, + const resource = await Resource.getByResourceId(issue.resourceId); + const kind: EventLogKind = resolved + ? EventLogKind.ResourceIssueResolved + : EventLogKind.ResourceIssueReopened; + const newDocument = await new EventLog({ + actor: user._id, + detail: { kind, - }).save(); - await newDocument.populate("actor").execPopulate(); - await postEventLogMessage(eventLogDocumentToEventLog(newDocument)); - } catch (e) { - console.error(e); - } - res.writeHead(204); - res.end(); + resourceId: issue.resourceId.toHexString(), + resourceName: resource.name, + resourceIssueSeverity: issue.severity, + resourceIssueKind: issue.kind, + resourceIssueId: issue._id.toHexString(), + }, + kind, + }).save(); + await newDocument.populate("actor").execPopulate(); + await postEventLogMessage(eventLogDocumentToEventLog(newDocument)); } catch (e) { - res.writeHead(500, { - "Content-Type": "application/json", - }); - res.end( - JSON.stringify({ - message: `Error setting Service Provider issue with _id ${_id} to ${ - resolved ? "resolved" : "unresolved" - }: ${e.message}`, - }) - ); - return; + console.error(e); } + res.writeHead(204); + res.end(); + } catch (e) { + res.writeHead(500, { + "Content-Type": "application/json", + }); + res.end( + JSON.stringify({ + message: `Error setting Service Provider issue with _id ${_id} to ${ + resolved ? "resolved" : "unresolved" + }: ${e.message}`, + }) + ); + return; } } From 3572bf4d912d30525000ab005cd9418d56741e85 Mon Sep 17 00:00:00 2001 From: Alvin Mites Date: Tue, 13 Jul 2021 21:53:42 -0600 Subject: [PATCH 2/3] grooming async & removing unused --- packages/common/src/ResourceSchedule.ts | 33 ++++++++----------- packages/server/README.md | 2 +- packages/server/src/models/Category.ts | 9 +++-- packages/server/src/models/Resource.ts | 3 +- packages/server/src/models/ResourceIssue.ts | 13 ++++---- packages/server/src/models/User.ts | 6 ++-- .../server/src/routes/api/bot/check-links.ts | 2 +- .../routes/api/bot/destroy-all-sessions.ts | 2 +- .../server/src/routes/api/bot/sync-algolia.ts | 2 +- .../server/src/routes/api/bot/test-job.ts | 7 +++- .../src/routes/provider/alert/create.svelte | 3 +- .../provider/resource/draft/[_id].svelte | 3 +- .../src/utility/handleCommandFromSlack.ts | 2 +- .../server/src/worker/processJobCheckLinks.ts | 6 ++-- .../src/worker/processJobCheckNewAlerts.ts | 4 +-- .../worker/processJobDestroyAllSessions.ts | 2 +- .../src/worker/processJobSyncAlgolia.ts | 6 ++-- packages/server/src/worker/processJobTest.ts | 2 +- packages/server/src/worker/webSocketServer.ts | 2 +- .../web/src/components/SubCategoryButton.tsx | 2 +- 20 files changed, 55 insertions(+), 56 deletions(-) diff --git a/packages/common/src/ResourceSchedule.ts b/packages/common/src/ResourceSchedule.ts index 2bbbbb4a4..fd4921f8f 100644 --- a/packages/common/src/ResourceSchedule.ts +++ b/packages/common/src/ResourceSchedule.ts @@ -1,6 +1,5 @@ import { RRule, RRuleSet } from "rrule"; import { - TResource, TResourceScheduleData, TScheduleItemOpenClose, TTimezoneName, @@ -69,29 +68,29 @@ export function getScheduleItemPeriod( ): TScheduleItemOpenClose { const openTimeValue = item.fromTime.value; const closeTimeValue = item.toTime.value; - const firstOccurenceDate = item.recurrenceRule.all((_, i) => i < 1)[0]; + const firstOccurrenceDate = item.recurrenceRule.all((_, i) => i < 1)[0]; const firstCloseDt = makeSchedulePeriodDate( - firstOccurenceDate, + firstOccurrenceDate, closeTimeValue ); - // rrule doesn't know of the time so its first occurence could be past close + // rrule doesn't know of the time so its first occurrence could be past close if (firstCloseDt.getTime() > dt.getTime()) { - const openDt = makeSchedulePeriodDate(firstOccurenceDate, openTimeValue); + const openDt = makeSchedulePeriodDate(firstOccurrenceDate, openTimeValue); return { open: openDt, close: firstCloseDt, }; } - // the first occurence is past close so retrieve first occurence after the given date - const secondOccurenceDate = item.recurrenceRule.after(dt); + // the first occurrence is past close so retrieve first occurrence after the given date + const secondOccurrenceDate = item.recurrenceRule.after(dt); const secondCloseDt = makeSchedulePeriodDate( - secondOccurenceDate, + secondOccurrenceDate, closeTimeValue ); const secondOpenDt = makeSchedulePeriodDate( - secondOccurenceDate, + secondOccurrenceDate, closeTimeValue ); return { @@ -101,13 +100,13 @@ export function getScheduleItemPeriod( } /** - * Represents the reoccuring schedule of a resource (ex: Mon, Wed, Fri from 8am - 10pm) + * Represents the recurring schedule of a resource (ex: Mon, Wed, Fri from 8am - 10pm) * Based on the iCalendar standard (https://icalendar.org/iCalendar-RFC-5545) * Wraps the rrule library (https://github.com/jakubroztocil/rrule) in order to add * comments for schedule rules (ex: Mon 8am-12pm for residents, 1pm-4pm for non-residents) */ export default class ResourceSchedule { - private _items: TScheduleItem[]; + private readonly _items: TScheduleItem[]; /** * Whether the Resource is always open. */ @@ -214,11 +213,7 @@ export default class ResourceSchedule { return null; } - if (at.getTime() > nextScheduleItemPeriod.open.getTime()) { - return true; - } - - return false; + return at.getTime() > nextScheduleItemPeriod.open.getTime(); } /** @@ -244,10 +239,8 @@ export default class ResourceSchedule { if (!r.toTime || typeof r.toTime !== "string") { return false; } - if (r.comment && typeof r.comment !== "string") { - return false; - } - return true; + + return !(r.comment && typeof r.comment !== "string"); }) ) { throw new Error( diff --git a/packages/server/README.md b/packages/server/README.md index e5e95f842..e2c481558 100644 --- a/packages/server/README.md +++ b/packages/server/README.md @@ -69,7 +69,7 @@ This file contains placeholders for various API keys that you may or may not nee yarn workspace @upswyng/server dev ``` -Runs the server in the development mode. Open [http:/localhost:3000](http:/localhost:3000) to view it in the browser. +Runs the server in the development mode. Open [http://localhost:3000](http://localhost:3000) to view it in the browser. If you want to work on the [provider portal](http://localhost:3000/provider), you can log in with this google user: diff --git a/packages/server/src/models/Category.ts b/packages/server/src/models/Category.ts index c182d2d4d..d2f18d54c 100644 --- a/packages/server/src/models/Category.ts +++ b/packages/server/src/models/Category.ts @@ -1,12 +1,11 @@ +import mongoose, { Document, Schema } from "mongoose"; +import removeUndefinedFields from "../utility/removeUndefinedFields"; import Subcategory, { - TSubcategoryDocument, subcategoryDocumentToSubcategory, + TSubcategoryDocument, } from "./Subcategory"; -import { TCategory, TSubcategory } from "@upswyng/types"; -import mongoose, { Document, Schema } from "mongoose"; - import { ObjectId } from "bson"; -import removeUndefinedFields from "../utility/removeUndefinedFields"; +import { TCategory } from "@upswyng/types"; export interface TCategoryDocument extends Document { _id: ObjectId; diff --git a/packages/server/src/models/Resource.ts b/packages/server/src/models/Resource.ts index 0cdc447f8..20e7e1d70 100644 --- a/packages/server/src/models/Resource.ts +++ b/packages/server/src/models/Resource.ts @@ -4,7 +4,6 @@ import { TLegacyResource, TResource, TResourceScheduleData, - TSubcategory, } from "@upswyng/types"; import { TSubcategoryDocument, @@ -49,7 +48,7 @@ export interface TResourceDocument extends Document { /** * Convert a resource document from the database into our `TResource` type. - * Explicity enumerate keys so we make TypeScript happy. + * Explicitly enumerate keys so we make TypeScript happy. */ export const resourceDocumentToResource = async ( r: TResourceDocument diff --git a/packages/server/src/models/ResourceIssue.ts b/packages/server/src/models/ResourceIssue.ts index 4d5c3f261..b7325d425 100644 --- a/packages/server/src/models/ResourceIssue.ts +++ b/packages/server/src/models/ResourceIssue.ts @@ -104,23 +104,22 @@ ResourceIssueSchema.statics.newWithoutResourceId = function( }) as TResourceIssueDocument; }; +const ResourceIssue = mongoose.model( + "ResourceIssue", + ResourceIssueSchema +); + ResourceIssueSchema.statics.getForResource = async function( resourceId: ObjectId, includeResolved = false ): Promise { // ensure that a resource exists with this ID - // eslint-disable-next-line @typescript-eslint/no-use-before-define - return await ResourceIssue.find({ + return ResourceIssue.find({ resourceId, resolved: { $in: [false, includeResolved] }, }).sort({ createdAt: -1 }); }; -const ResourceIssue = mongoose.model( - "ResourceIssue", - ResourceIssueSchema -); - export default ResourceIssue as typeof ResourceIssue & { /** * Creates a new Resource Issue but __does not__ save it. Does not include a Resource ID; diff --git a/packages/server/src/models/User.ts b/packages/server/src/models/User.ts index 2fea0b308..eb327d5f6 100644 --- a/packages/server/src/models/User.ts +++ b/packages/server/src/models/User.ts @@ -130,8 +130,7 @@ UserSchema.statics.findOrCreateGoogleUser = async function( } else if (!user) { try { const newUser = new self({ google: { sub, email } }); - const result = await newUser.save(); - return result; + return await newUser.save(); } catch (e) { console.error(`Error creating new user:\t${e}`); throw e; @@ -167,8 +166,7 @@ UserSchema.statics.findOrCreateSlackUser = async function( const newUser = new self({ slack: { email, name, userId: slackUserId, teamId }, }); - const result = await newUser.save(); - return result; + return await newUser.save(); } catch (e) { console.error(`Error creating new user:\t${e}`); throw e; diff --git a/packages/server/src/routes/api/bot/check-links.ts b/packages/server/src/routes/api/bot/check-links.ts index f4a5b190a..54922ac21 100644 --- a/packages/server/src/routes/api/bot/check-links.ts +++ b/packages/server/src/routes/api/bot/check-links.ts @@ -5,7 +5,7 @@ import mq from "../../../worker/mq"; async function makeCheckLinksJob(_req, res, _next, user: TUser) { const jobName = getName("-"); - mq.addJobCheckLinks(jobName, user._id); + await mq.addJobCheckLinks(jobName, user._id); const blocks = [ { type: "section", diff --git a/packages/server/src/routes/api/bot/destroy-all-sessions.ts b/packages/server/src/routes/api/bot/destroy-all-sessions.ts index 7f01ef673..15afcbdb2 100644 --- a/packages/server/src/routes/api/bot/destroy-all-sessions.ts +++ b/packages/server/src/routes/api/bot/destroy-all-sessions.ts @@ -5,7 +5,7 @@ import mq from "../../../worker/mq"; async function makeJobDestroyAllSessions(_req, res, _next, user: TUser) { const jobName = getName("-"); - mq.addJobDestroyAllSessions(jobName, user._id); + await mq.addJobDestroyAllSessions(jobName, user._id); const blocks = [ { type: "section", diff --git a/packages/server/src/routes/api/bot/sync-algolia.ts b/packages/server/src/routes/api/bot/sync-algolia.ts index a01c0d0a1..19f702e4e 100644 --- a/packages/server/src/routes/api/bot/sync-algolia.ts +++ b/packages/server/src/routes/api/bot/sync-algolia.ts @@ -5,7 +5,7 @@ import mq from "../../../worker/mq"; async function makeSyncAlgoliaJob(_req, res, _next, user: TUser) { const jobName = getName("-"); - mq.addJobSyncAlgolia(jobName, user._id); + await mq.addJobSyncAlgolia(jobName, user._id); const blocks = [ { type: "section", diff --git a/packages/server/src/routes/api/bot/test-job.ts b/packages/server/src/routes/api/bot/test-job.ts index c572883ca..0fed771ab 100644 --- a/packages/server/src/routes/api/bot/test-job.ts +++ b/packages/server/src/routes/api/bot/test-job.ts @@ -19,7 +19,12 @@ async function makeTestJob(req, res, _next, user: TUser) { } } // TODO: Better Failure handling - mq.addJobTest(jobName, delay ? delay * 1000 : null, undefined, user._id); // this is taking too long, so don't await it. + await mq.addJobTest( + jobName, + delay ? delay * 1000 : null, + undefined, + user._id + ); // this is taking too long, so don't await it. const blocks = [ { type: "section", diff --git a/packages/server/src/routes/provider/alert/create.svelte b/packages/server/src/routes/provider/alert/create.svelte index 8858de108..147606997 100644 --- a/packages/server/src/routes/provider/alert/create.svelte +++ b/packages/server/src/routes/provider/alert/create.svelte @@ -19,6 +19,7 @@ import rgbHex from "rgb-hex"; import TimePicker from "./../../../components/TimePicker.svelte"; import axios from "axios"; + import mq from "../../../worker/mq"; const { tz } = moment; const { session } = stores(); @@ -248,7 +249,7 @@ "success", `Alert "${alertTitle}" was successful created` ); - goto(`/provider/alert?id=${alert._id}`); + await goto(`/provider/alert?id=${alert._id}`); }) .catch(e => (errorMessage = e)) .finally(() => { diff --git a/packages/server/src/routes/provider/resource/draft/[_id].svelte b/packages/server/src/routes/provider/resource/draft/[_id].svelte index 8179e092a..3074bc348 100644 --- a/packages/server/src/routes/provider/resource/draft/[_id].svelte +++ b/packages/server/src/routes/provider/resource/draft/[_id].svelte @@ -66,6 +66,7 @@ import { goto, stores } from "@sapper/app"; import ResourceDiff from "./../../../../components/ResourceDiff.svelte"; import ResourceDisplay from "./../../../../components/ResourceDisplay.svelte"; + import mq from "../../../../worker/mq"; const { session } = stores(); @@ -117,7 +118,7 @@ "success", `The draft of ${draftResource.name} was approved` ); - goto("/provider/resource"); + await goto("/provider/resource"); }) .catch(e => (approveError = e)) .finally(() => (isApproving = false)); diff --git a/packages/server/src/utility/handleCommandFromSlack.ts b/packages/server/src/utility/handleCommandFromSlack.ts index e98e28360..fd2ad6997 100644 --- a/packages/server/src/utility/handleCommandFromSlack.ts +++ b/packages/server/src/utility/handleCommandFromSlack.ts @@ -93,5 +93,5 @@ export default async function handleCommandFromSlack( res.writeHead(200, { "Content-Type": "application/json" }); return res.end(JSON.stringify(slackResponse)); } - return await callback(req, res, next, user); + return callback(req, res, next, user); } diff --git a/packages/server/src/worker/processJobCheckLinks.ts b/packages/server/src/worker/processJobCheckLinks.ts index 277a01b72..f856f4591 100644 --- a/packages/server/src/worker/processJobCheckLinks.ts +++ b/packages/server/src/worker/processJobCheckLinks.ts @@ -85,9 +85,11 @@ export async function processJobCheckLinks( `${job.name}[${job.id}]\tLinks checked count: ${linksCheckedCount}` ); erroredLinks = [...erroredLinks, ...newErroredLinks]; - job.updateProgress((linksCheckedCount / estimatedResourceCount) * 100); // TODO: Persist the resources we have already looked at + await job.updateProgress( + (linksCheckedCount / estimatedResourceCount) * 100 + ); // TODO: Persist the resources we have already looked at } while (resources.length); - job.updateProgress(100); + await job.updateProgress(100); return { erroredLinks, diff --git a/packages/server/src/worker/processJobCheckNewAlerts.ts b/packages/server/src/worker/processJobCheckNewAlerts.ts index 4ef801013..817b5487b 100644 --- a/packages/server/src/worker/processJobCheckNewAlerts.ts +++ b/packages/server/src/worker/processJobCheckNewAlerts.ts @@ -64,13 +64,13 @@ export async function processJobCheckNewAlerts( `Error creating Event Log \`alert_live\` for Alert ${alert._id}: ${e}` ); } - job.updateProgress(((i + 1) / count) * 100); + await job.updateProgress(((i + 1) / count) * 100); } catch (e) { throw e; } }); - job.updateProgress(100); + await job.updateProgress(100); return { alertsProcessed, jobName: job.name, kind: JobKind.CheckNewAlerts }; } diff --git a/packages/server/src/worker/processJobDestroyAllSessions.ts b/packages/server/src/worker/processJobDestroyAllSessions.ts index 700812ab5..3e3a7ad62 100644 --- a/packages/server/src/worker/processJobDestroyAllSessions.ts +++ b/packages/server/src/worker/processJobDestroyAllSessions.ts @@ -16,7 +16,7 @@ export async function processJobDestroyAllSessions( ) { const result = await connection.db.dropCollection("sessions"); if (result) { - job.updateProgress(100); + await job.updateProgress(100); return { kind: JobKind.DestroyAllSessions, }; diff --git a/packages/server/src/worker/processJobSyncAlgolia.ts b/packages/server/src/worker/processJobSyncAlgolia.ts index d73d86e95..4510fbb35 100644 --- a/packages/server/src/worker/processJobSyncAlgolia.ts +++ b/packages/server/src/worker/processJobSyncAlgolia.ts @@ -97,9 +97,11 @@ export async function processJobSyncAlgolia( } processedResourceCount += resources.length; - job.updateProgress((processedResourceCount / estimatedResourceCount) * 100); + await job.updateProgress( + (processedResourceCount / estimatedResourceCount) * 100 + ); } while (resources.length); - job.updateProgress(100); + await job.updateProgress(100); return { kind: JobKind.SyncAlgolia, diff --git a/packages/server/src/worker/processJobTest.ts b/packages/server/src/worker/processJobTest.ts index 2669f8de5..779a4a9ca 100644 --- a/packages/server/src/worker/processJobTest.ts +++ b/packages/server/src/worker/processJobTest.ts @@ -21,7 +21,7 @@ export async function processJobTest( if (progress >= 100 && job.data.shouldFail) { throw new Error(`Forced job to fail at ${progress}%`); } - job.updateProgress(Math.min(progress, 100)); + await job.updateProgress(Math.min(progress, 100)); } // A job can return values that will be stored in Redis as JSON // This return value is unused in this demo application. diff --git a/packages/server/src/worker/webSocketServer.ts b/packages/server/src/worker/webSocketServer.ts index 92f2a4d6b..8f6b49661 100644 --- a/packages/server/src/worker/webSocketServer.ts +++ b/packages/server/src/worker/webSocketServer.ts @@ -262,7 +262,7 @@ export default function(server: Server): void { switch (d.kind) { case "clean_completed_jobs": - queue.clean(0, Infinity, "completed"); + await queue.clean(0, Infinity, "completed"); break; case "remove_job": { diff --git a/packages/web/src/components/SubCategoryButton.tsx b/packages/web/src/components/SubCategoryButton.tsx index f727cb7ae..efdb637d7 100644 --- a/packages/web/src/components/SubCategoryButton.tsx +++ b/packages/web/src/components/SubCategoryButton.tsx @@ -26,7 +26,7 @@ const useStyles = makeStyles((theme: Theme) => ({ })); const SubCategoryButton = (props: Props) => { - const { children, buttonColor, isSelected, ...rest } = props; + const { children, ...rest } = props; const classes = useStyles(props); return ( From 3eae40122bf1a332bedc850c634d5b74783005ea Mon Sep 17 00:00:00 2001 From: Alvin Mites Date: Wed, 21 Jul 2021 20:02:29 -0600 Subject: [PATCH 3/3] cleaning on cr --- packages/server/src/models/Category.ts | 4 ++-- packages/server/src/models/Hotline.ts | 2 +- packages/server/src/models/Resource.ts | 10 +++++----- packages/server/src/models/Subcategory.ts | 4 ++-- packages/server/src/models/User.ts | 8 ++++---- packages/server/src/routes/api/bot/check-links.ts | 2 +- .../server/src/routes/api/bot/destroy-all-sessions.ts | 2 +- packages/server/src/routes/api/bot/sync-algolia.ts | 2 +- .../src/routes/api/resource/issues/resolve/[_id].ts | 2 +- .../src/routes/api/resource/issues/unresolve/[_id].ts | 2 +- .../server/src/routes/provider/alert/create.svelte | 5 ++--- .../src/routes/provider/resource/draft/[_id].svelte | 3 +-- packages/server/src/utility/userMiddleware.ts | 6 +++--- packages/server/src/worker.ts | 10 +++++----- packages/server/src/worker/processJobCheckLinks.ts | 7 +++---- packages/server/src/worker/processJobCheckNewAlerts.ts | 4 ++-- .../server/src/worker/processJobDestroyAllSessions.ts | 2 +- packages/server/src/worker/processJobSyncAlgolia.ts | 6 ++---- packages/server/src/worker/processJobTest.ts | 2 +- packages/server/src/worker/webSocketServer.ts | 4 ++-- 20 files changed, 41 insertions(+), 46 deletions(-) diff --git a/packages/server/src/models/Category.ts b/packages/server/src/models/Category.ts index d2f18d54c..3c4e1a068 100644 --- a/packages/server/src/models/Category.ts +++ b/packages/server/src/models/Category.ts @@ -1,8 +1,8 @@ import mongoose, { Document, Schema } from "mongoose"; import removeUndefinedFields from "../utility/removeUndefinedFields"; import Subcategory, { - subcategoryDocumentToSubcategory, TSubcategoryDocument, + subcategoryDocumentToSubcategory, } from "./Subcategory"; import { ObjectId } from "bson"; import { TCategory } from "@upswyng/types"; @@ -90,7 +90,7 @@ CategorySchema.statics.findOrCreate = async function( CategorySchema.statics.getCategoryList = async function(): Promise< TCategoryDocument[] > { - return await this.find().populate("subcategories"); + return this.find().populate("subcategories"); }; CategorySchema.statics.getByStub = async function( diff --git a/packages/server/src/models/Hotline.ts b/packages/server/src/models/Hotline.ts index a1a55aba9..f94d55496 100644 --- a/packages/server/src/models/Hotline.ts +++ b/packages/server/src/models/Hotline.ts @@ -49,7 +49,7 @@ const HotlineSchema = new Schema( ); HotlineSchema.statics.getAll = async function(): Promise { - return await this.find({}); + return this.find({}); }; const HotlineModel = mongoose.model("Hotline", HotlineSchema); diff --git a/packages/server/src/models/Resource.ts b/packages/server/src/models/Resource.ts index 20e7e1d70..999c61038 100644 --- a/packages/server/src/models/Resource.ts +++ b/packages/server/src/models/Resource.ts @@ -330,7 +330,7 @@ ResourceSchema.statics.getByResourceId = async function( resourceId: ObjectId, includeDeleted: boolean = false ): Promise { - return await this.findOne({ + return this.findOne({ resourceId, deleted: { $in: [false, includeDeleted] }, }) @@ -345,7 +345,7 @@ ResourceSchema.statics.getByResourceId = async function( ResourceSchema.statics.getByRecordId = async function( _id: ObjectId ): Promise { - return await this.findOne({ _id }) + return this.findOne({ _id }) .populate({ path: "subcategories", populate: { path: "parentCategory" } }) .populate("createdBy") .populate("lastModifiedBy"); @@ -357,7 +357,7 @@ ResourceSchema.statics.getByRecordId = async function( ResourceSchema.statics.getByResourceIds = async function( resourceIds: ObjectId[] ): Promise { - return await this.find({ + return this.find({ resourceId: { $in: resourceIds }, }) .populate({ path: "subcategories", populate: { path: "parentCategory" } }) @@ -371,7 +371,7 @@ ResourceSchema.statics.getByResourceIds = async function( ResourceSchema.statics.getAll = async function( includeDeleted: boolean = false ): Promise { - return await this.find({ deleted: { $in: [false, includeDeleted] } }) + return this.find({ deleted: { $in: [false, includeDeleted] } }) .populate({ path: "subcategories", populate: { path: "parentCategory" } }) .populate("createdBy") .populate("lastModifiedBy"); @@ -383,7 +383,7 @@ ResourceSchema.statics.getAll = async function( ResourceSchema.statics.getUncategorized = async function(): Promise< TResourceDocument[] > { - return await this.find({ + return this.find({ "subcategories.0": { $exists: false }, deleted: false, }) diff --git a/packages/server/src/models/Subcategory.ts b/packages/server/src/models/Subcategory.ts index 9617d64bd..732dcde7e 100644 --- a/packages/server/src/models/Subcategory.ts +++ b/packages/server/src/models/Subcategory.ts @@ -112,11 +112,11 @@ SubcategorySchema.statics.getSubcategoryList = async function( includeResources = false ) { if (includeResources) { - return await this.find() + return this.find() .populate("parentCategory") .populate("resources"); } - return await this.find() + return this.find() .populate("parentCategory") .map(r => { delete r.resources; diff --git a/packages/server/src/models/User.ts b/packages/server/src/models/User.ts index eb327d5f6..bf0e2a52e 100644 --- a/packages/server/src/models/User.ts +++ b/packages/server/src/models/User.ts @@ -130,7 +130,7 @@ UserSchema.statics.findOrCreateGoogleUser = async function( } else if (!user) { try { const newUser = new self({ google: { sub, email } }); - return await newUser.save(); + return newUser.save(); } catch (e) { console.error(`Error creating new user:\t${e}`); throw e; @@ -142,7 +142,7 @@ UserSchema.statics.findOrCreateGoogleUser = async function( if (email) { user.google.email = email; } - return await user.save(); + return user.save(); } return user; }; @@ -166,7 +166,7 @@ UserSchema.statics.findOrCreateSlackUser = async function( const newUser = new self({ slack: { email, name, userId: slackUserId, teamId }, }); - return await newUser.save(); + return newUser.save(); } catch (e) { console.error(`Error creating new user:\t${e}`); throw e; @@ -182,7 +182,7 @@ UserSchema.statics.findOrCreateSlackUser = async function( user.slack.email = email; user.slack.teamId = teamId; user.slack.name = name; - return await user.save(); + return user.save(); } return user; }; diff --git a/packages/server/src/routes/api/bot/check-links.ts b/packages/server/src/routes/api/bot/check-links.ts index 54922ac21..f4a5b190a 100644 --- a/packages/server/src/routes/api/bot/check-links.ts +++ b/packages/server/src/routes/api/bot/check-links.ts @@ -5,7 +5,7 @@ import mq from "../../../worker/mq"; async function makeCheckLinksJob(_req, res, _next, user: TUser) { const jobName = getName("-"); - await mq.addJobCheckLinks(jobName, user._id); + mq.addJobCheckLinks(jobName, user._id); const blocks = [ { type: "section", diff --git a/packages/server/src/routes/api/bot/destroy-all-sessions.ts b/packages/server/src/routes/api/bot/destroy-all-sessions.ts index 15afcbdb2..7f01ef673 100644 --- a/packages/server/src/routes/api/bot/destroy-all-sessions.ts +++ b/packages/server/src/routes/api/bot/destroy-all-sessions.ts @@ -5,7 +5,7 @@ import mq from "../../../worker/mq"; async function makeJobDestroyAllSessions(_req, res, _next, user: TUser) { const jobName = getName("-"); - await mq.addJobDestroyAllSessions(jobName, user._id); + mq.addJobDestroyAllSessions(jobName, user._id); const blocks = [ { type: "section", diff --git a/packages/server/src/routes/api/bot/sync-algolia.ts b/packages/server/src/routes/api/bot/sync-algolia.ts index 19f702e4e..a01c0d0a1 100644 --- a/packages/server/src/routes/api/bot/sync-algolia.ts +++ b/packages/server/src/routes/api/bot/sync-algolia.ts @@ -5,7 +5,7 @@ import mq from "../../../worker/mq"; async function makeSyncAlgoliaJob(_req, res, _next, user: TUser) { const jobName = getName("-"); - await mq.addJobSyncAlgolia(jobName, user._id); + mq.addJobSyncAlgolia(jobName, user._id); const blocks = [ { type: "section", diff --git a/packages/server/src/routes/api/resource/issues/resolve/[_id].ts b/packages/server/src/routes/api/resource/issues/resolve/[_id].ts index 56966a723..9dc16d14d 100644 --- a/packages/server/src/routes/api/resource/issues/resolve/[_id].ts +++ b/packages/server/src/routes/api/resource/issues/resolve/[_id].ts @@ -4,5 +4,5 @@ import { setResolved } from "../_setResolved"; * API endpoint to set a `ResourceIssue`'s `resolved` field to `true`. */ export async function post(req, res, next) { - return await setResolved(true, req, res, next); + return setResolved(true, req, res, next); } diff --git a/packages/server/src/routes/api/resource/issues/unresolve/[_id].ts b/packages/server/src/routes/api/resource/issues/unresolve/[_id].ts index 9e09918df..6c2b3269c 100644 --- a/packages/server/src/routes/api/resource/issues/unresolve/[_id].ts +++ b/packages/server/src/routes/api/resource/issues/unresolve/[_id].ts @@ -4,5 +4,5 @@ import { setResolved } from "../_setResolved"; * API endpoint to set a `ResourceIssue`'s `resolved` field to `false`. */ export async function post(req, res, next) { - return await setResolved(false, req, res, next); + return setResolved(false, req, res, next); } diff --git a/packages/server/src/routes/provider/alert/create.svelte b/packages/server/src/routes/provider/alert/create.svelte index 147606997..03f89c420 100644 --- a/packages/server/src/routes/provider/alert/create.svelte +++ b/packages/server/src/routes/provider/alert/create.svelte @@ -7,7 +7,7 @@