89 lines
2.6 KiB
JavaScript
89 lines
2.6 KiB
JavaScript
"use strict";
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
const assert_1 = require("oak-domain/lib/utils/assert");
|
|
const index_backend_1 = require("../utils/cos/index.backend");
|
|
const uuid_1 = require("oak-domain/lib/utils/uuid");
|
|
const lodash_1 = require("oak-domain/lib/utils/lodash");
|
|
async function checkWhetherSuccess(context, applicationId, rows) {
|
|
const successIds = [];
|
|
const failedIds = [];
|
|
await context.setApplication(applicationId);
|
|
for (const d of rows) {
|
|
const { origin } = d;
|
|
const cos = (0, index_backend_1.getCosBackend)(origin);
|
|
(0, assert_1.assert)(cos);
|
|
const success = await cos.checkWhetherSuccess(context.getApplication(), d, context);
|
|
if (success) {
|
|
successIds.push(d.id);
|
|
}
|
|
else {
|
|
failedIds.push(d.id);
|
|
}
|
|
}
|
|
if (successIds.length > 0) {
|
|
await context.operate('extraFile', {
|
|
id: await (0, uuid_1.generateNewIdAsync)(),
|
|
action: 'update',
|
|
data: {
|
|
uploadState: 'success',
|
|
},
|
|
filter: {
|
|
id: {
|
|
$in: successIds,
|
|
}
|
|
}
|
|
}, {});
|
|
}
|
|
if (failedIds.length > 0) {
|
|
await context.operate('extraFile', {
|
|
id: await (0, uuid_1.generateNewIdAsync)(),
|
|
action: 'update',
|
|
data: {
|
|
uploadState: 'failed',
|
|
},
|
|
filter: {
|
|
id: {
|
|
$in: successIds,
|
|
}
|
|
}
|
|
}, {});
|
|
}
|
|
}
|
|
const watchers = [
|
|
{
|
|
name: '确定uploading的文件状态',
|
|
entity: 'extraFile',
|
|
filter: async () => {
|
|
const now = Date.now();
|
|
const deadline = process.env.NODE_ENV === 'production' ? now - 3600 * 1000 : now - 60 * 1000;
|
|
return {
|
|
$$updateAt$$: {
|
|
$lt: deadline,
|
|
},
|
|
uploadState: 'uploading',
|
|
};
|
|
},
|
|
projection: {
|
|
id: 1,
|
|
applicationId: 1,
|
|
origin: 1,
|
|
bucket: 1,
|
|
uploadState: 1,
|
|
objectId: 1,
|
|
extension: 1,
|
|
},
|
|
fn: async (context, data) => {
|
|
const eg = (0, lodash_1.groupBy)(data, 'applicationId');
|
|
for (const appId in eg) {
|
|
await checkWhetherSuccess(context, appId, eg[appId]);
|
|
}
|
|
return {
|
|
extraFile: {
|
|
update: data.length,
|
|
}
|
|
};
|
|
}
|
|
},
|
|
];
|
|
exports.default = watchers;
|