@@ -11,7 +11,6 @@ export function createDatabase() {
1111 const dbExists = fs . existsSync ( dbFile ) ;
1212 const db = new sqlite3 . Database ( dbFile ) ;
1313 const createSubscriptionStatement = 'CREATE TABLE Subscription ('
14- + 'UserId TEXT NOT NULL, '
1514 + 'SubscriptionId TEXT NOT NULL, '
1615 + 'AccessToken TEXT NOT NULL, '
1716 + 'Resource TEXT NOT NULL, '
@@ -38,7 +37,6 @@ export function createDatabase() {
3837export function getSubscription ( subscriptionId , callback ) {
3938 const db = new sqlite3 . Database ( dbFile ) ;
4039 const getUserDataStatement = 'SELECT '
41- + 'UserId as userId, '
4240 + 'SubscriptionId as subscriptionId, '
4341 + 'AccessToken as accessToken, '
4442 + 'Resource as resource, '
@@ -64,16 +62,15 @@ export function getSubscription(subscriptionId, callback) {
6462export function saveSubscription ( subscriptionData , callback ) {
6563 const db = new sqlite3 . Database ( dbFile ) ;
6664 const insertStatement = 'INSERT INTO Subscription '
67- + '(UserId, SubscriptionId, AccessToken, Resource, ChangeType, '
65+ + '(SubscriptionId, AccessToken, Resource, ChangeType, '
6866 + 'ClientState, NotificationUrl, SubscriptionExpirationDateTime) '
69- + 'VALUES ($userId, $ subscriptionId, $accessToken, $resource, $changeType, '
67+ + 'VALUES ($subscriptionId, $accessToken, $resource, $changeType, '
7068 + '$clientState, $notificationUrl, $subscriptionExpirationDateTime)' ;
7169
7270 db . serialize ( ( ) => {
7371 db . run (
7472 insertStatement ,
7573 {
76- $userId : subscriptionData . userId ,
7774 $subscriptionId : subscriptionData . id ,
7875 $accessToken : subscriptionData . accessToken ,
7976 $resource : subscriptionData . resource ,
0 commit comments