33 * See LICENSE in the project root for license information.
44 */
55
6- var sqlite3 = require ( 'sqlite3' ) . verbose ( ) ;
7- var fs = require ( 'fs' ) ;
8- var dbFile = './helpers/database.sqlite3' ;
6+ import fs from 'fs' ;
7+ import sql from 'sqlite3' ;
98
10- function dbHelper ( ) { }
9+ const dbFile = './helpers/database.sqlite3' ;
10+ const sqlite3 = sql . verbose ( ) ;
1111
1212/**
1313 * Create SQLite3 table Subscription.
1414 */
15- dbHelper . prototype . createDatabase = function createDatabase ( ) {
16- var dbExists = fs . existsSync ( dbFile ) ;
17- var db = new sqlite3 . Database ( dbFile ) ;
18- var createSubscriptionStatement =
15+ export function createDatabase ( ) {
16+ const dbExists = fs . existsSync ( dbFile ) ;
17+ const db = new sqlite3 . Database ( dbFile ) ;
18+ const createSubscriptionStatement =
1919 'CREATE TABLE Subscription (' +
20- 'UserId TEXT NOT NULL, ' +
21- 'SubscriptionId TEXT NOT NULL, ' +
22- 'AccessToken TEXT NOT NULL, ' +
23- 'Resource TEXT NOT NULL, ' +
24- 'ChangeType TEXT NOT NULL, ' +
25- 'ClientState TEXT NOT NULL, ' +
26- 'NotificationUrl TEXT NOT NULL, ' +
27- 'SubscriptionExpirationDateTime TEXT NOT NULL' +
20+ 'UserId TEXT NOT NULL, ' +
21+ 'SubscriptionId TEXT NOT NULL, ' +
22+ 'AccessToken TEXT NOT NULL, ' +
23+ 'Resource TEXT NOT NULL, ' +
24+ 'ChangeType TEXT NOT NULL, ' +
25+ 'ClientState TEXT NOT NULL, ' +
26+ 'NotificationUrl TEXT NOT NULL, ' +
27+ 'SubscriptionExpirationDateTime TEXT NOT NULL' +
2828 ')' ;
2929
3030 db . serialize ( function createTable ( ) {
@@ -41,20 +41,20 @@ dbHelper.prototype.createDatabase = function createDatabase() {
4141 }
4242 } ) ;
4343 db . close ( ) ;
44- } ;
44+ }
4545
46- dbHelper . prototype . getSubscription = function getSubscription ( subscriptionId , callback ) {
47- var db = new sqlite3 . Database ( dbFile ) ;
48- var getUserDataStatement =
46+ export function getSubscription ( subscriptionId , callback ) {
47+ const db = new sqlite3 . Database ( dbFile ) ;
48+ const getUserDataStatement =
4949 'SELECT ' +
50- 'UserId as userId, ' +
51- 'SubscriptionId as subscriptionId, ' +
52- 'AccessToken as accessToken, ' +
53- 'Resource as resource, ' +
54- 'ChangeType as changeType, ' +
55- 'ClientState as clientState, ' +
56- 'NotificationUrl as notificationUrl, ' +
57- 'SubscriptionExpirationDateTime as subscriptionExpirationDateTime ' +
50+ 'UserId as userId, ' +
51+ 'SubscriptionId as subscriptionId, ' +
52+ 'AccessToken as accessToken, ' +
53+ 'Resource as resource, ' +
54+ 'ChangeType as changeType, ' +
55+ 'ClientState as clientState, ' +
56+ 'NotificationUrl as notificationUrl, ' +
57+ 'SubscriptionExpirationDateTime as subscriptionExpirationDateTime ' +
5858 'FROM Subscription ' +
5959 'WHERE SubscriptionId = $subscriptionId ' +
6060 'AND SubscriptionExpirationDateTime > datetime(\'now\')' ;
@@ -68,51 +68,48 @@ dbHelper.prototype.getSubscription = function getSubscription(subscriptionId, ca
6868 callback
6969 ) ;
7070 } ) ;
71- } ;
71+ }
7272
73- dbHelper . prototype . saveSubscription =
74- function saveSubscription ( subscriptionData , callback ) {
75- var db = new sqlite3 . Database ( dbFile ) ;
76- var insertStatement =
77- 'INSERT INTO Subscription ' +
78- '(UserId, SubscriptionId, AccessToken, Resource, ChangeType, ' +
79- 'ClientState, NotificationUrl, SubscriptionExpirationDateTime) ' +
80- 'VALUES ($userId, $subscriptionId, $accessToken, $resource, $changeType, ' +
81- '$clientState, $notificationUrl, $subscriptionExpirationDateTime)' ;
73+ export function saveSubscription ( subscriptionData , callback ) {
74+ const db = new sqlite3 . Database ( dbFile ) ;
75+ const insertStatement =
76+ 'INSERT INTO Subscription ' +
77+ '(UserId, SubscriptionId, AccessToken, Resource, ChangeType, ' +
78+ 'ClientState, NotificationUrl, SubscriptionExpirationDateTime) ' +
79+ 'VALUES ($userId, $subscriptionId, $accessToken, $resource, $changeType, ' +
80+ '$clientState, $notificationUrl, $subscriptionExpirationDateTime)' ;
8281
83- db . serialize ( function executeInsert ( ) {
84- db . run (
85- insertStatement ,
86- {
87- $userId : subscriptionData . userId ,
88- $subscriptionId : subscriptionData . id ,
89- $accessToken : subscriptionData . accessToken ,
90- $resource : subscriptionData . resource ,
91- $clientState : subscriptionData . clientState ,
92- $changeType : subscriptionData . changeType ,
93- $notificationUrl : subscriptionData . notificationUrl ,
94- $subscriptionExpirationDateTime : subscriptionData . expirationDateTime
95- } ,
96- callback
97- ) ;
98- } ) ;
99- } ;
100-
101- dbHelper . prototype . deleteSubscription =
102- function deleteSubscription ( subscriptionId , callback ) {
103- var db = new sqlite3 . Database ( dbFile ) ;
104- var deleteStatement = 'DELETE FROM Subscription WHERE ' +
105- 'SubscriptionId = $subscriptionId' ;
82+ db . serialize ( function executeInsert ( ) {
83+ db . run (
84+ insertStatement ,
85+ {
86+ $userId : subscriptionData . userId ,
87+ $subscriptionId : subscriptionData . id ,
88+ $accessToken : subscriptionData . accessToken ,
89+ $resource : subscriptionData . resource ,
90+ $clientState : subscriptionData . clientState ,
91+ $changeType : subscriptionData . changeType ,
92+ $notificationUrl : subscriptionData . notificationUrl ,
93+ $subscriptionExpirationDateTime : subscriptionData . expirationDateTime
94+ } ,
95+ callback
96+ ) ;
97+ } ) ;
98+ }
10699
107- db . serialize ( function executeDelete ( ) {
108- db . run (
109- deleteStatement ,
110- {
111- $subscriptionId : subscriptionId
112- } ,
113- callback
114- ) ;
115- } ) ;
116- } ;
100+ export function deleteSubscription ( subscriptionId , callback ) {
101+ const db = new sqlite3 . Database ( dbFile ) ;
102+ const deleteStatement =
103+ 'DELETE FROM Subscription WHERE ' +
104+ 'SubscriptionId = $subscriptionId' ;
117105
118- module . exports = dbHelper ;
106+ db . serialize ( function executeDelete ( ) {
107+ db . run (
108+ deleteStatement ,
109+ {
110+ $subscriptionId : subscriptionId
111+ } ,
112+ callback
113+ ) ;
114+ } ) ;
115+ }
0 commit comments