mirror of
https://gitcode.com/gh_mirrors/hy/Hydro.git
synced 2026-10-20 01:38:19 +08:00
core: remove gridfs api
This commit is contained in:
1 parent
67a3f82c6c
commit
54ef77b108
4 files changed
+4
-16
No files matched your search
@@ -95,7 +95,6 @@ export async function load() {
|
|||||||
await lib(pending, fail);
|
await lib(pending, fail);
|
||||||
const systemModel = require('../model/system');
|
const systemModel = require('../model/system');
|
||||||
await systemModel.runConfig();
|
await systemModel.runConfig();
|
||||||
require('../service/gridfs');
|
|
||||||
await service(pending, fail);
|
await service(pending, fail);
|
||||||
for (const i of builtinModel) require(`../model/${i}`);
|
for (const i of builtinModel) require(`../model/${i}`);
|
||||||
await model(pending, fail);
|
await model(pending, fail);
|
||||||
|
|||||||
@@ -50,9 +50,8 @@ export async function load() {
|
|||||||
if (detail) logger.info('finish: lib.builtin');
|
if (detail) logger.info('finish: lib.builtin');
|
||||||
await lib(pending, fail);
|
await lib(pending, fail);
|
||||||
if (detail) logger.info('finish: lib.extra');
|
if (detail) logger.info('finish: lib.extra');
|
||||||
require('../service/gridfs');
|
|
||||||
require('../service/monitor');
|
require('../service/monitor');
|
||||||
if (detail) logger.info('finish: gridfs/monitor');
|
if (detail) logger.info('finish: monitor');
|
||||||
const server = require('../service/server');
|
const server = require('../service/server');
|
||||||
await server.prepare();
|
await server.prepare();
|
||||||
if (detail) logger.info('finish: server');
|
if (detail) logger.info('finish: server');
|
||||||
|
|||||||
@@ -1,10 +0,0 @@
|
|||||||
import { GridFSBucket } from 'mongodb';
|
|
||||||
import db from './db';
|
|
||||||
import { HydroFileSystem } from '../interface';
|
|
||||||
|
|
||||||
const fs = new GridFSBucket(db.db2);
|
|
||||||
|
|
||||||
// @ts-ignore
|
|
||||||
global.Hydro.service.fs = fs;
|
|
||||||
|
|
||||||
export = fs as HydroFileSystem;
|
|
||||||
@@ -1,6 +1,6 @@
|
|||||||
/* eslint-disable @typescript-eslint/no-unused-vars */
|
/* eslint-disable @typescript-eslint/no-unused-vars */
|
||||||
/* eslint-disable no-await-in-loop */
|
/* eslint-disable no-await-in-loop */
|
||||||
import { ObjectID } from 'mongodb';
|
import { ObjectID, GridFSBucket } from 'mongodb';
|
||||||
import AdmZip from 'adm-zip';
|
import AdmZip from 'adm-zip';
|
||||||
import Queue from 'p-queue';
|
import Queue from 'p-queue';
|
||||||
import yaml from 'js-yaml';
|
import yaml from 'js-yaml';
|
||||||
@@ -8,15 +8,14 @@ import { pick } from 'lodash';
|
|||||||
import { convertIniConfig } from '@hydrooj/utils/lib/cases';
|
import { convertIniConfig } from '@hydrooj/utils/lib/cases';
|
||||||
import { BucketItem } from 'minio';
|
import { BucketItem } from 'minio';
|
||||||
import moment from 'moment';
|
import moment from 'moment';
|
||||||
|
import db from './service/db';
|
||||||
import { Progress } from './ui';
|
import { Progress } from './ui';
|
||||||
import { Logger } from './logger';
|
import { Logger } from './logger';
|
||||||
import { streamToBuffer } from './utils';
|
import { streamToBuffer } from './utils';
|
||||||
import {
|
import {
|
||||||
iterateAllDomain, iterateAllProblem, iterateAllPsdoc, iterateAllUser,
|
iterateAllDomain, iterateAllProblem, iterateAllPsdoc, iterateAllUser,
|
||||||
} from './pipelineUtils';
|
} from './pipelineUtils';
|
||||||
import gridfs from './service/gridfs';
|
|
||||||
import storage from './service/storage';
|
import storage from './service/storage';
|
||||||
import db from './service/db';
|
|
||||||
import difficultyAlgorithm from './lib/difficulty';
|
import difficultyAlgorithm from './lib/difficulty';
|
||||||
import problem from './model/problem';
|
import problem from './model/problem';
|
||||||
import user from './model/user';
|
import user from './model/user';
|
||||||
@@ -81,6 +80,7 @@ const scripts: UpgradeScript[] = [
|
|||||||
else savedProgress = { pdocs: [] };
|
else savedProgress = { pdocs: [] };
|
||||||
const ddocs = await domain.getMulti().project({ _id: 1 }).toArray();
|
const ddocs = await domain.getMulti().project({ _id: 1 }).toArray();
|
||||||
logger.info('Found %d domains.', ddocs.length);
|
logger.info('Found %d domains.', ddocs.length);
|
||||||
|
const gridfs = new GridFSBucket(db.db2);
|
||||||
for (let i = 0; i < ddocs.length; i++) {
|
for (let i = 0; i < ddocs.length; i++) {
|
||||||
const ddoc = ddocs[i];
|
const ddoc = ddocs[i];
|
||||||
logger.info('Domain %s (%d/%d)', ddoc._id, i + 1, ddocs.length);
|
logger.info('Domain %s (%d/%d)', ddoc._id, i + 1, ddocs.length);
|
||||||
|
|||||||
Reference in new issue
Block a user