trilium/routes/api/sync.js

204 lines
6.6 KiB
JavaScript
Raw Normal View History

2017-10-25 10:58:59 +08:00
"use strict";
const express = require('express');
const router = express.Router();
const auth = require('../../services/auth');
2017-10-27 09:16:21 +08:00
const sync = require('../../services/sync');
2017-11-10 09:52:47 +08:00
const syncUpdate = require('../../services/sync_update');
const sync_table = require('../../services/sync_table');
2017-11-01 07:34:58 +08:00
const sql = require('../../services/sql');
2017-11-03 08:48:02 +08:00
const options = require('../../services/options');
2017-11-22 11:11:27 +08:00
const content_hash = require('../../services/content_hash');
2017-12-24 02:16:18 +08:00
const log = require('../../services/log');
const wrap = require('express-promise-wrap').wrap;
2017-11-22 11:11:27 +08:00
router.get('/check', auth.checkApiAuth, wrap(async (req, res, next) => {
2017-11-22 11:11:27 +08:00
res.send({
'hashes': await content_hash.getHashes(),
'max_sync_id': await sql.getFirstValue('SELECT MAX(id) FROM sync')
2017-11-22 11:11:27 +08:00
});
}));
2017-10-25 10:58:59 +08:00
router.post('/now', auth.checkApiAuth, wrap(async (req, res, next) => {
res.send(await sync.sync());
}));
2017-10-29 23:22:41 +08:00
router.post('/fill-sync-rows', auth.checkApiAuth, wrap(async (req, res, next) => {
await sql.doInTransaction(async () => {
await sync_table.fillAllSyncRows();
});
2017-12-24 02:16:18 +08:00
log.info("Sync rows have been filled.");
res.send({});
}));
router.post('/force-full-sync', auth.checkApiAuth, wrap(async (req, res, next) => {
await sql.doInTransaction(async () => {
await options.setOption('last_synced_pull', 0);
await options.setOption('last_synced_push', 0);
});
2017-12-24 02:16:18 +08:00
log.info("Forcing full sync.");
// not awaiting for the job to finish (will probably take a long time)
sync.sync();
res.send({});
}));
router.post('/force-note-sync/:noteId', auth.checkApiAuth, wrap(async (req, res, next) => {
const noteId = req.params.noteId;
await sql.doInTransaction(async () => {
await sync_table.addNoteSync(noteId);
for (const noteTreeId of await sql.getFirstColumn("SELECT noteTreeId FROM note_tree WHERE isDeleted = 0 AND noteId = ?", [noteId])) {
await sync_table.addNoteTreeSync(noteTreeId);
await sync_table.addRecentNoteSync(noteTreeId);
}
for (const noteRevisionId of await sql.getFirstColumn("SELECT noteRevisionId FROM note_revisions WHERE noteId = ?", [noteId])) {
await sync_table.addNoteHistorySync(noteRevisionId);
}
});
log.info("Forcing note sync for " + noteId);
// not awaiting for the job to finish (will probably take a long time)
sync.sync();
res.send({});
}));
router.get('/changed', auth.checkApiAuth, wrap(async (req, res, next) => {
2017-11-01 07:34:58 +08:00
const lastSyncId = parseInt(req.query.lastSyncId);
2017-10-25 10:58:59 +08:00
res.send(await sql.getAll("SELECT * FROM sync WHERE id > ?", [lastSyncId]));
}));
2017-10-27 09:16:21 +08:00
router.get('/notes/:noteId', auth.checkApiAuth, wrap(async (req, res, next) => {
2017-11-01 07:34:58 +08:00
const noteId = req.params.noteId;
2017-10-27 09:16:21 +08:00
2017-11-01 07:34:58 +08:00
res.send({
2018-01-29 08:30:14 +08:00
entity: await sql.getFirst("SELECT * FROM notes WHERE noteId = ?", [noteId])
2017-11-01 07:34:58 +08:00
});
}));
2017-10-26 10:39:21 +08:00
router.get('/note_tree/:noteTreeId', auth.checkApiAuth, wrap(async (req, res, next) => {
2017-11-24 11:25:39 +08:00
const noteTreeId = req.params.noteTreeId;
2017-10-26 10:39:21 +08:00
res.send(await sql.getFirst("SELECT * FROM note_tree WHERE noteTreeId = ?", [noteTreeId]));
}));
2017-11-01 07:34:58 +08:00
router.get('/note_revisions/:noteRevisionId', auth.checkApiAuth, wrap(async (req, res, next) => {
const noteRevisionId = req.params.noteRevisionId;
2017-11-01 07:34:58 +08:00
res.send(await sql.getFirst("SELECT * FROM note_revisions WHERE noteRevisionId = ?", [noteRevisionId]));
}));
2017-10-27 09:16:21 +08:00
2018-01-29 08:30:14 +08:00
router.get('/options/:name', auth.checkApiAuth, wrap(async (req, res, next) => {
const name = req.params.name;
const opt = await sql.getFirst("SELECT * FROM options WHERE name = ?", [name]);
2017-11-03 08:48:02 +08:00
2018-01-29 08:30:14 +08:00
if (!opt.isSynced) {
2017-11-03 08:48:02 +08:00
res.send("This option can't be synced.");
}
else {
res.send(opt);
2017-11-03 08:48:02 +08:00
}
}));
2017-11-03 08:48:02 +08:00
2018-01-29 08:30:14 +08:00
router.get('/notes_reordering/:parentNoteId', auth.checkApiAuth, wrap(async (req, res, next) => {
const parentNoteId = req.params.parentNoteId;
2017-11-03 10:55:22 +08:00
res.send({
2018-01-29 08:30:14 +08:00
parentNoteId: parentNoteId,
ordering: await sql.getMap("SELECT noteTreeId, notePosition FROM note_tree WHERE parentNoteId = ? AND isDeleted = 0", [parentNoteId])
2017-11-03 10:55:22 +08:00
});
}));
2017-11-03 10:55:22 +08:00
router.get('/recent_notes/:noteTreeId', auth.checkApiAuth, wrap(async (req, res, next) => {
const noteTreeId = req.params.noteTreeId;
2017-11-05 12:16:02 +08:00
2018-01-29 08:30:14 +08:00
res.send(await sql.getFirst("SELECT * FROM recent_notes WHERE noteTreeId = ?", [noteTreeId]));
}));
2017-11-05 12:16:02 +08:00
router.get('/images/:imageId', auth.checkApiAuth, wrap(async (req, res, next) => {
2018-01-07 04:56:00 +08:00
const imageId = req.params.imageId;
2018-01-29 08:30:14 +08:00
const entity = await sql.getFirst("SELECT * FROM images WHERE imageId = ?", [imageId]);
2018-01-07 04:56:00 +08:00
if (entity && entity.data !== null) {
entity.data = entity.data.toString('base64');
}
res.send(entity);
}));
2018-01-07 04:56:00 +08:00
router.get('/note_images/:noteImageId', auth.checkApiAuth, wrap(async (req, res, next) => {
2018-01-07 10:49:02 +08:00
const noteImageId = req.params.noteImageId;
res.send(await sql.getFirst("SELECT * FROM note_images WHERE noteImageId = ?", [noteImageId]));
}));
2018-01-07 10:49:02 +08:00
router.get('/attributes/:attributeId', auth.checkApiAuth, wrap(async (req, res, next) => {
const attributeId = req.params.attributeId;
2018-01-29 08:30:14 +08:00
res.send(await sql.getFirst("SELECT * FROM attributes WHERE attributeId = ?", [attributeId]));
}));
router.put('/notes', auth.checkApiAuth, wrap(async (req, res, next) => {
await syncUpdate.updateNote(req.body.entity, req.body.sourceId);
2017-10-30 10:22:30 +08:00
res.send({});
}));
2017-10-30 10:22:30 +08:00
router.put('/note_tree', auth.checkApiAuth, wrap(async (req, res, next) => {
2017-11-10 09:52:47 +08:00
await syncUpdate.updateNoteTree(req.body.entity, req.body.sourceId);
2017-10-30 10:22:30 +08:00
res.send({});
}));
2017-10-30 10:22:30 +08:00
router.put('/note_revisions', auth.checkApiAuth, wrap(async (req, res, next) => {
2017-11-10 09:52:47 +08:00
await syncUpdate.updateNoteHistory(req.body.entity, req.body.sourceId);
2017-10-26 10:39:21 +08:00
2017-10-27 09:16:21 +08:00
res.send({});
}));
2017-10-25 10:58:59 +08:00
router.put('/notes_reordering', auth.checkApiAuth, wrap(async (req, res, next) => {
2017-11-10 09:52:47 +08:00
await syncUpdate.updateNoteReordering(req.body.entity, req.body.sourceId);
2017-11-03 10:55:22 +08:00
res.send({});
}));
2017-11-03 10:55:22 +08:00
router.put('/options', auth.checkApiAuth, wrap(async (req, res, next) => {
2017-11-10 09:52:47 +08:00
await syncUpdate.updateOptions(req.body.entity, req.body.sourceId);
2017-11-03 08:48:02 +08:00
res.send({});
}));
2017-11-03 08:48:02 +08:00
router.put('/recent_notes', auth.checkApiAuth, wrap(async (req, res, next) => {
2017-11-10 09:52:47 +08:00
await syncUpdate.updateRecentNotes(req.body.entity, req.body.sourceId);
2017-11-05 12:16:02 +08:00
res.send({});
}));
2017-11-05 12:16:02 +08:00
router.put('/images', auth.checkApiAuth, wrap(async (req, res, next) => {
2018-01-07 04:56:00 +08:00
await syncUpdate.updateImage(req.body.entity, req.body.sourceId);
res.send({});
}));
2018-01-07 04:56:00 +08:00
router.put('/note_images', auth.checkApiAuth, wrap(async (req, res, next) => {
2018-01-07 10:49:02 +08:00
await syncUpdate.updateNoteImage(req.body.entity, req.body.sourceId);
res.send({});
}));
2018-01-07 10:49:02 +08:00
router.put('/attributes', auth.checkApiAuth, wrap(async (req, res, next) => {
await syncUpdate.updateAttribute(req.body.entity, req.body.sourceId);
res.send({});
}));
2017-10-25 10:58:59 +08:00
module.exports = router;