@@ -10,17 +10,16 @@ const sqlite3 = sql.verbose();
1010export function createDatabase ( ) {
1111 const dbExists = fs . existsSync ( dbFile ) ;
1212 const db = new sqlite3 . Database ( dbFile ) ;
13- const createSubscriptionStatement =
14- 'CREATE TABLE Subscription (' +
15- 'UserId TEXT NOT NULL, ' +
16- 'SubscriptionId TEXT NOT NULL, ' +
17- 'AccessToken TEXT NOT NULL, ' +
18- 'Resource TEXT NOT NULL, ' +
19- 'ChangeType TEXT NOT NULL, ' +
20- 'ClientState TEXT NOT NULL, ' +
21- 'NotificationUrl TEXT NOT NULL, ' +
22- 'SubscriptionExpirationDateTime TEXT NOT NULL' +
23- ')' ;
13+ const createSubscriptionStatement = 'CREATE TABLE Subscription ('
14+ + 'UserId TEXT NOT NULL, '
15+ + 'SubscriptionId TEXT NOT NULL, '
16+ + 'AccessToken TEXT NOT NULL, '
17+ + 'Resource TEXT NOT NULL, '
18+ + 'ChangeType TEXT NOT NULL, '
19+ + 'ClientState TEXT NOT NULL, '
20+ + 'NotificationUrl TEXT NOT NULL, '
21+ + 'SubscriptionExpirationDateTime TEXT NOT NULL'
22+ + ')' ;
2423
2524 db . serialize ( ( ) => {
2625 if ( ! dbExists ) {
@@ -38,19 +37,18 @@ export function createDatabase() {
3837
3938export function getSubscription ( subscriptionId , callback ) {
4039 const db = new sqlite3 . Database ( dbFile ) ;
41- const getUserDataStatement =
42- 'SELECT ' +
43- 'UserId as userId, ' +
44- 'SubscriptionId as subscriptionId, ' +
45- 'AccessToken as accessToken, ' +
46- 'Resource as resource, ' +
47- 'ChangeType as changeType, ' +
48- 'ClientState as clientState, ' +
49- 'NotificationUrl as notificationUrl, ' +
50- 'SubscriptionExpirationDateTime as subscriptionExpirationDateTime ' +
51- 'FROM Subscription ' +
52- 'WHERE SubscriptionId = $subscriptionId ' +
53- 'AND SubscriptionExpirationDateTime > datetime(\'now\')' ;
40+ const getUserDataStatement = 'SELECT '
41+ + 'UserId as userId, '
42+ + 'SubscriptionId as subscriptionId, '
43+ + 'AccessToken as accessToken, '
44+ + 'Resource as resource, '
45+ + 'ChangeType as changeType, '
46+ + 'ClientState as clientState, '
47+ + 'NotificationUrl as notificationUrl, '
48+ + 'SubscriptionExpirationDateTime as subscriptionExpirationDateTime '
49+ + 'FROM Subscription '
50+ + 'WHERE SubscriptionId = $subscriptionId '
51+ + 'AND SubscriptionExpirationDateTime > datetime(\'now\')' ;
5452
5553 db . serialize ( ( ) => {
5654 db . get (
@@ -65,12 +63,11 @@ export function getSubscription(subscriptionId, callback) {
6563
6664export function saveSubscription ( subscriptionData , callback ) {
6765 const db = new sqlite3 . Database ( dbFile ) ;
68- const insertStatement =
69- 'INSERT INTO Subscription ' +
70- '(UserId, SubscriptionId, AccessToken, Resource, ChangeType, ' +
71- 'ClientState, NotificationUrl, SubscriptionExpirationDateTime) ' +
72- 'VALUES ($userId, $subscriptionId, $accessToken, $resource, $changeType, ' +
73- '$clientState, $notificationUrl, $subscriptionExpirationDateTime)' ;
66+ const insertStatement = 'INSERT INTO Subscription '
67+ + '(UserId, SubscriptionId, AccessToken, Resource, ChangeType, '
68+ + 'ClientState, NotificationUrl, SubscriptionExpirationDateTime) '
69+ + 'VALUES ($userId, $subscriptionId, $accessToken, $resource, $changeType, '
70+ + '$clientState, $notificationUrl, $subscriptionExpirationDateTime)' ;
7471
7572 db . serialize ( ( ) => {
7673 db . run (
@@ -92,9 +89,8 @@ export function saveSubscription(subscriptionData, callback) {
9289
9390export function deleteSubscription ( subscriptionId , callback ) {
9491 const db = new sqlite3 . Database ( dbFile ) ;
95- const deleteStatement =
96- 'DELETE FROM Subscription WHERE ' +
97- 'SubscriptionId = $subscriptionId' ;
92+ const deleteStatement = 'DELETE FROM Subscription WHERE '
93+ + 'SubscriptionId = $subscriptionId' ;
9894
9995 db . serialize ( ( ) => {
10096 db . run (
0 commit comments