aboutsummaryrefslogtreecommitdiff
path: root/src/server/index.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/server/index.ts')
-rw-r--r--src/server/index.ts10
1 files changed, 3 insertions, 7 deletions
diff --git a/src/server/index.ts b/src/server/index.ts
index e3e4221cf..e03079d66 100644
--- a/src/server/index.ts
+++ b/src/server/index.ts
@@ -47,9 +47,7 @@ const mongoose = require('mongoose');
const probe = require("probe-image-size");
import * as qs from 'query-string';
import { Opt } from '../new_fields/Doc';
-const Extensions = require("../extensions/Extensions");
-const ArrayExtensions = require("../extensions/ArrayExtensions");
-
+import { batchedMapInterval, TimeUnit } from "array-batcher";
const download = (url: string, dest: fs.PathLike) => request.get(url).pipe(fs.createWriteStream(dest));
let youtubeApiKey: string;
@@ -101,8 +99,6 @@ enum Method {
POST
}
-Extensions.AssignExtensions();
-
/**
* Please invoke this function when adding a new route to Dash's server.
* It ensures that any requests leading to or containing user-sensitive information
@@ -861,9 +857,9 @@ app.post(RouteStore.googlePhotosMediaUpload, async (req, res) => {
return newMediaItems;
};
const batcher = { batchSize: 25 };
- const interval = { magnitude: 100, unit: ArrayExtensions.TimeUnit.Milliseconds };
+ const interval = { magnitude: 100, unit: TimeUnit.Milliseconds };
- const newMediaItems = await mediaInput.batchedMapInterval(batcher, dispatchUpload, interval);
+ const newMediaItems = await batchedMapInterval(mediaInput, batcher, dispatchUpload, interval);
if (failed) {
return _error(res, tokenError);