1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
import $ from 'cafy';
import Subscription from '../../../../models/sw-subscription';
import { ILocalUser } from '../../../../models/user';
import config from '../../../../config';
export const meta = {
requireCredential: true
};
/**
* subscribe service worker
*/
export default async (params: any, user: ILocalUser) => new Promise(async (res, rej) => {
// Get 'endpoint' parameter
const [endpoint, endpointErr] = $.str.get(params.endpoint);
if (endpointErr) return rej('invalid endpoint param');
// Get 'auth' parameter
const [auth, authErr] = $.str.get(params.auth);
if (authErr) return rej('invalid auth param');
// Get 'publickey' parameter
const [publickey, publickeyErr] = $.str.get(params.publickey);
if (publickeyErr) return rej('invalid publickey param');
// if already subscribed
const exist = await Subscription.findOne({
userId: user._id,
endpoint: endpoint,
auth: auth,
publickey: publickey,
deletedAt: { $exists: false }
});
if (exist != null) {
return res({
state: 'already-subscribed',
key: config.sw.public_key
});
}
await Subscription.insert({
userId: user._id,
endpoint: endpoint,
auth: auth,
publickey: publickey
});
res({
state: 'subscribed',
key: config.sw.public_key
});
});
|
