3.0.0

.gitlab-ci.yml

@@ -100,10 +100,9 @@ codequality:
   only:
     - tags
   script:
-    - npmci command npm install -g tslint typescript
+    - npmci command npm install -g typescript
     - npmci npm prepare
     - npmci npm install
-    - npmci command "tslint -c tslint.json ./ts/**/*.ts"
   tags:
     - lossless
     - docker

package.json

@@ -1,10 +1,11 @@
 {
   "name": "@mojoio/tink",
-  "version": "1.0.6",
+  "version": "3.0.0",
   "private": false,
   "description": "an unofficial api abstraction for tink.com",
   "main": "dist_ts/index.js",
   "typings": "dist_ts/index.d.ts",
+  "type": "module",
   "author": "Lossless GmbH",
   "license": "MIT",
   "scripts": {
@@ -12,16 +13,17 @@
     "build": "(tsbuild --web)"
   },
   "devDependencies": {
-    "@gitzone/tsbuild": "^2.1.25",
-    "@gitzone/tsbundle": "^1.0.78",
-    "@gitzone/tstest": "^1.0.64",
+    "@gitzone/tsbuild": "^2.1.61",
+    "@gitzone/tsbundle": "^1.0.102",
+    "@gitzone/tstest": "^1.0.70",
     "@pushrocks/qenv": "^4.0.10",
-    "@pushrocks/tapbundle": "^4.0.7",
-    "@types/node": "^17.0.18",
+    "@pushrocks/tapbundle": "^5.0.3",
+    "@types/node": "^17.0.25",
     "tslint": "^6.1.3",
     "tslint-config-prettier": "^1.15.0"
   },
   "dependencies": {
+    "@pushrocks/smartdelay": "^2.0.13",
     "@pushrocks/smartrequest": "^1.1.56"
   },
   "browserslist": [

readme.md

@@ -27,6 +27,30 @@ Platform support | [![Supports Windows 10](https://badgen.net/badge/supports%20W
 
 Use TypeScript for best inclass intellisense
 
+```typescript
+// this example assumes toplevel await
+import * as tink from '@mojoio/tink';
+
+const tinkAccount = new TinkAccount('<clientId>', '<clientSecret>');
+const tinkUser = await tinkAccount.createTinkUser('<YourOwnUniqueUserId/externalUserId>');
+const tinkLinkUrl = await tinkUser.getTinkLink('<marketCode like DE>');
+
+// present the link to your user to connect their bank accounts to the tink platform.
+
+const tinkProviderConsents = await tinkUser.getProviderConsents();
+
+for (const providerConsent of tinkProviderConsents) {
+  const bankAccounts = await providerConsent.getBankAccounts();
+  for (const bankAccount of bankAccounts) {
+    const transactions = bankAccount.getTransactions();
+  }
+}
+
+// additional stuff
+const existingTinkUser = await tinkAccount.getUser('<YourOwnUniqueUserId/externalUserId>');
+await existingTinkuser.delete(); // delete the user on the tink platform
+```
+
 ## Contribution
 
 We are always happy for code contributions. If you are not the code contributing type that is ok. Still, maintaining Open Source repositories takes considerable time and thought. If you like the quality of what we do and our modules are useful to you we would appreciate a little monthly contribution: You can [contribute one time](https://lossless.link/contribute-onetime) or [contribute monthly](https://lossless.link/contribute). :)

test/test.nonci.ts

@@ -3,20 +3,10 @@ import * as qenv from '@pushrocks/qenv';
 
 const testQenv = new qenv.Qenv('./', './.nogit/');
 
-import * as tink from '../ts/index';
+import * as tink from '../ts/index.js';
 
 let tinkTestAccount: tink.TinkAccount;
 
-tap.preTask('should delete existing users', async () => {
-  const preTinkAccount = tinkTestAccount = new tink.TinkAccount(
-    testQenv.getEnvVarOnDemand('TINK_CLIENT_ID'),
-    testQenv.getEnvVarOnDemand('TINK_CLIENT_SECRET')
-  );
-  expect(tinkTestAccount).toBeInstanceOf(tink.TinkAccount);
-  const tinkUser = new tink.TinkUser(preTinkAccount, null, 'user_1234_abc');
-  await tinkUser.delete();
-})
-
 tap.test('should create a valid tink account', async () => {
   tinkTestAccount = new tink.TinkAccount(
     testQenv.getEnvVarOnDemand('TINK_CLIENT_ID'),
@@ -29,8 +19,21 @@ tap.test('should report tink as healthy', async () => {
   await expectAsync(tinkTestAccount.getTinkHealthyBoolean()).toBeTrue();
 });
 
-tap.test('should create a valid request', async () => {
-  await tinkTestAccount.createTinkUser("user_1234_abc");
+tap.test('should create a tink user', async (toolsArg) => {
+  await tinkTestAccount.createTinkUser('user_1234_abc');
 })
 
+tap.test('should create a valid request', async (toolsArg) => {
+  const tinkuser: tink.TinkUser = await tinkTestAccount.getTinkUser('user_1234_abc');
+  console.log(tinkuser);
+  console.log(await tinkuser.getTinkLinkForMarket()); // defaults to 'DE';
+  console.log(await tinkuser.getProviderConsents());
+});
+
+tap.test('should delete existing users', async () => {
+  expect(tinkTestAccount).toBeInstanceOf(tink.TinkAccount);
+  const tinkUser = new tink.TinkUser(tinkTestAccount, null, 'user_1234_abc');
+  await tinkUser.delete();
+});
+
 tap.start();

ts/00_commitinfo_data.ts

@@ -0,0 +1,8 @@
+/**
+ * autocreated commitinfo by @pushrocks/commitinfo
+ */
+export const commitinfo = {
+  name: '@mojoio/tink',
+  version: '3.0.0',
+  description: 'an unofficial api abstraction for tink.com'
+}

ts/index.ts

@@ -1,2 +1,3 @@
-export * from './tink.classes.tinkaccount';
-export * from './tink.classes.tinkuser';
+export * from './tink.classes.tinkaccount.js';
+export * from './tink.classes.tinkuser.js';
+export * from './tink.classes.tinkproviderconsent.js';

ts/tink.classes.tinkaccount.ts

@@ -1,45 +1,35 @@
-import * as plugins from './tink.plugins';
+import * as plugins from './tink.plugins.js';
 
-import { TinkUser } from './tink.classes.tinkuser'
+import { TinkUser } from './tink.classes.tinkuser.js';
 
 export class TinkAccount {
-  private clientId: string;
-  private clientSecret: string;
+  public clientId: string;
+  private _clientSecret: string;
 
-  private apiBaseUrl: string = 'https://api.tink.com';
+  private _apiBaseUrl: string = 'https://api.tink.com';
 
   constructor(clientIdArg: string, clientSecretArg: string) {
     this.clientId = clientIdArg;
-    this.clientSecret = clientSecretArg;
+    this._clientSecret = clientSecretArg;
   }
 
   public async getTinkHealthyBoolean(): Promise<boolean> {
     const response = await plugins.smartrequest.request(
       'https://api.tink.com/api/v1/monitoring/healthy',
-      {}
+      {
+        keepAlive: false,
+      }
     );
     return response.body === 'ok';
   }
 
-  // the request method for tink respecting platform specific stuff
-  // e.g. certain headers if needed
-  public async request(optionsArg: {
-    urlArg: string,
-    methodArg: 'POST' | 'GET',
-    scopeArg: string,
-    payloadArg: any,
-    externalUserId: string
-  }) {
-    // check health
-    if (!(await this.getTinkHealthyBoolean())) {
-      throw new Error('TINK is not healthy right now. Please try again later.');
-    } else {
-      console.log('tink is healthy, continuing...');
-    }
+  public async getClientAccessTokenForScope(scopeArg: string): Promise<string> {
     // lets get an accessToken for the request
     const response = await plugins.smartrequest.postFormDataUrlEncoded(
-      `${this.apiBaseUrl}/api/v1/oauth/token`,
-      {},
+      `${this._apiBaseUrl}/api/v1/oauth/token`,
+      {
+        keepAlive: false,
+      },
       [
         {
           key: 'client_id',
@@ -47,7 +37,7 @@ export class TinkAccount {
         },
         {
           key: 'client_secret',
-          content: this.clientSecret,
+          content: this._clientSecret,
         },
         {
           key: 'grant_type',
@@ -55,28 +45,134 @@ export class TinkAccount {
         },
         {
           key: 'scope',
-          content: optionsArg.scopeArg,
+          content: scopeArg,
         },
       ]
     );
     if (response.statusCode !== 200) {
+      console.log(response.statusCode);
+      console.log(response.body);
       throw new Error('there was an error aquiring an access token.');
     }
-    const accessToken = response.body.access_token;
+    const clientAccessToken = response.body.access_token;
+    return clientAccessToken;
+  }
 
-    const response2 = await plugins.smartrequest.request(`${this.apiBaseUrl}${optionsArg.urlArg}`, {
+  public async getUserAuthorizationCode(
+    externalUserIdArg: string,
+    actorCLientIdArg: string,
+    scopeArg: string
+  ) {
+    const accessToken = await this.getClientAccessTokenForScope('authorization:grant');
+    const response = await plugins.smartrequest.postFormDataUrlEncoded(
+      `${this._apiBaseUrl}/api/v1/oauth/authorization-grant/delegate`,
+      {
+        keepAlive: false,
+        headers: {
+          Authorization: `Bearer ${accessToken}`,
+        },
+      },
+      [
+        {
+          key: 'response_type',
+          content: 'code',
+        },
+        {
+          key: 'actor_client_id',
+          content: actorCLientIdArg,
+        },
+        {
+          key: 'external_user_id',
+          content: externalUserIdArg,
+        },
+        {
+          key: 'id_hint',
+          content: 'Hello there',
+        },
+        {
+          key: 'scope',
+          content: scopeArg,
+        },
+      ]
+    );
+
+    if (response.statusCode !== 200) {
+      console.log(response.body);
+      throw new Error('there was an error aquiring an access token.');
+    }
+    const userAuthorizationCode = response.body.code;
+    return userAuthorizationCode;
+  }
+
+  public async getUserAccessToken(authorizationCode: string): Promise<string> {
+    const accessToken = await this.getClientAccessTokenForScope('authorization:grant');
+    const response = await plugins.smartrequest.postFormDataUrlEncoded(
+      `${this._apiBaseUrl}/api/v1/oauth/token`,
+      {
+        keepAlive: false,
+      },
+      [
+        {
+          key: 'code',
+          content: authorizationCode,
+        },
+        {
+          key: 'client_id',
+          content: this.clientId,
+        },
+        {
+          key: 'client_secret',
+          content: this._clientSecret,
+        },
+        {
+          key: 'grant_type',
+          content: 'authorization_code',
+        },
+      ]
+    );
+
+    if (response.statusCode !== 200) {
+      console.log(response.body);
+      throw new Error('there was an error aquiring an access token.');
+    }
+    const userAccessToken = response.body.access_token;
+    return userAccessToken;
+  }
+
+  // the request method for tink respecting platform specific stuff
+  // e.g. certain headers if needed
+  public async request(optionsArg: {
+    urlArg: string;
+    methodArg: 'POST' | 'GET';
+    accessToken: string;
+    payloadArg: any;
+  }) {
+    // check health
+    if (!(await this.getTinkHealthyBoolean())) {
+      throw new Error('TINK is not healthy right now. Please try again later.');
+    } else {
+      console.log('tink is healthy, continuing...');
+    }
+    const response = await plugins.smartrequest.request(`${this._apiBaseUrl}${optionsArg.urlArg}`, {
+      keepAlive: false,
       headers: {
-        'Authorization': `Bearer ${accessToken}`,
-        'Content-Type': 'application/json'
+        Authorization: `Bearer ${optionsArg.accessToken}`,
+        'Content-Type': 'application/json',
       },
       method: optionsArg.methodArg,
-      requestBody: JSON.stringify(optionsArg.payloadArg)
-    })
-    console.log(response2.statusCode);
-    return response2.body;
+      requestBody: JSON.stringify(optionsArg.payloadArg),
+    });
+    console.log(response.statusCode);
+    return response.body;
+  }
+
+  public async getTinkUser(externalUserIdArg: string) {
+    const tinkuser = await TinkUser.getTinkUser(this, externalUserIdArg);
+    return tinkuser;
   }
 
   public async createTinkUser(externalUserIdArg: string) {
     const tinkuser = await TinkUser.createNewTinkUser(this, externalUserIdArg);
+    return tinkuser;
   }
 }

ts/tink.classes.tinkproviderconsent.ts

@@ -0,0 +1,30 @@
+import * as plugins from './tink.plugins.js';
+
+import { TinkUser } from './tink.classes.tinkuser.js';
+
+/**
+ * a provider consent maps to tinks bank consents
+ */
+export class TinkProviderConsent {
+  // STATIC
+  public static async getProviderConsentsForUser(tinkUserRefArg: TinkUser) {
+    const returnProviderConsents: TinkProviderConsent[] = [];
+    const authorizationCode = await tinkUserRefArg.tinkAccountRef.getUserAuthorizationCode(
+      tinkUserRefArg.externalUserIdArg,
+      tinkUserRefArg.tinkAccountRef.clientId,
+      'accounts:read,balances:read,transactions:read,provider-consents:read'
+    );
+    const accessToken = await tinkUserRefArg.tinkAccountRef.getUserAccessToken(authorizationCode);
+    const responseData = await tinkUserRefArg.tinkAccountRef.request({
+      urlArg: '/api/v1/provider-consents',
+      accessToken,
+      methodArg: 'GET',
+      payloadArg: null,
+    });
+    console.log(responseData);
+    return returnProviderConsents;
+  }
+
+  // INSTANCE
+  constructor(tinkUserRefArg: TinkUser) {}
+}

ts/tink.classes.tinkuser.ts

@@ -1,23 +1,78 @@
-import * as plugins from './tink.plugins';
+import * as plugins from './tink.plugins.js';
 
-import { TinkAccount } from './tink.classes.tinkaccount';
+import { TinkAccount } from './tink.classes.tinkaccount.js';
+import { TinkProviderConsent } from './tink.classes.tinkproviderconsent.js';
 
 export class TinkUser {
   // STATIC
-  public static async createNewTinkUser (tinkaccountArg: TinkAccount, externalUserIdArg: string) {
-    const response = await tinkaccountArg.request({
-      externalUserId: null,
+  public static async createNewTinkUser(tinkAccountArg: TinkAccount, externalUserIdArg: string) {
+    const accessToken = await tinkAccountArg.getClientAccessTokenForScope('user:create');
+    const responseData: {
+      external_user_id: string;
+      user_id: string;
+    } = await tinkAccountArg.request({
       urlArg: '/api/v1/user/create',
+      accessToken,
       methodArg: 'POST',
-      scopeArg: 'user:create',
       payloadArg: {
-        "external_user_id": externalUserIdArg,
-        "market": "GB", 
-        "locale": "en_US"
-      }
+        external_user_id: externalUserIdArg,
+        market: 'DE',
+        locale: 'en_US',
+      },
     });
 
-    console.log(response);
+    const newTinkUser = await TinkUser.getTinkUser(tinkAccountArg, externalUserIdArg);
+    return newTinkUser;
+  }
+
+  public static async getTinkUser(tinkAccountArg: TinkAccount, externalUserIdArg: string) {
+    const authorizationCode = await tinkAccountArg.getUserAuthorizationCode(
+      externalUserIdArg,
+      tinkAccountArg.clientId,
+      'user:read'
+    );
+    const accessToken = await tinkAccountArg.getUserAccessToken(authorizationCode);
+    const responseData: {
+      appId: string;
+      created: string;
+      externalUserId: string;
+      flags: string[];
+      id: string;
+      nationalId: string;
+      profile: {
+        // cashbackEnabled: boolean; // deprecated
+        currency: string;
+        locale: string;
+        market: string;
+        notificationSettings: {
+          balance: boolean;
+          budget: boolean;
+          doubleCharge: boolean;
+          einvoices: boolean;
+          fraud: boolean;
+          income: boolean;
+          largeExpense: boolean;
+          leftToSpend: boolean;
+          loanUpdate: boolean;
+          summaryMonthly: boolean;
+          summaryWeekly: boolean;
+          transaction: boolean;
+          unusualAccount: boolean;
+          unusualCategory: boolean;
+        };
+        periodAdjustedDay: 25;
+        periodMode: 'MONTHLY_ADJUSTED' | 'MONTHLY';
+        timeZone: string;
+      };
+      // username: string; // not relevant
+    } = await tinkAccountArg.request({
+      urlArg: '/api/v1/user',
+      accessToken,
+      methodArg: 'GET',
+      payloadArg: null,
+    });
+    const newTinkUser = new TinkUser(tinkAccountArg, responseData.id, responseData.externalUserId);
+    return newTinkUser;
   }
 
   // INSTANCE
@@ -25,29 +80,59 @@ export class TinkUser {
   public tinkUserId: string;
   public externalUserIdArg: string;
 
-  public authorizationToken: string
-
   constructor(tinkAccountrefArg: TinkAccount, tinkUserIdArg: string, externalUserIdArg: string) {
     this.tinkAccountRef = tinkAccountrefArg;
     this.tinkUserId = tinkUserIdArg;
     this.externalUserIdArg = externalUserIdArg;
   }
 
-  public async authorize() {
-
-  }
-
   /**
    * deletes the user
    */
   public async delete() {
+    const authorizationCode = await this.tinkAccountRef.getUserAuthorizationCode(
+      this.externalUserIdArg,
+      this.tinkAccountRef.clientId,
+      'user:delete'
+    );
+    const accessToken = await this.tinkAccountRef.getUserAccessToken(authorizationCode);
     const response = await this.tinkAccountRef.request({
-      externalUserId: this.externalUserIdArg,
       methodArg: 'POST',
+      accessToken,
       payloadArg: {},
-      scopeArg: 'user:delete',
-      urlArg: '/api/v1/user/delete'
+      urlArg: '/api/v1/user/delete',
     });
-    console.log(response);
+    console.log(`successfully deleted user with externalId ${this.externalUserIdArg}`);
+  }
+
+  /**
+   * gets a tink link that can be used by a user to connect accounts
+   * @returns
+   */
+  public async getTinkLinkForMarket(linkOptionsArg: {
+    countryId: string;
+    redirectUrl: string;
+    testProviderBool?: boolean;
+  } = {
+    countryId: 'DE',
+    redirectUrl: 'https://console.tink.com/callback',
+    testProviderBool: true
+  }): Promise<string> {
+    if (typeof linkOptionsArg.testProviderBool !== 'boolean') {
+      linkOptionsArg.testProviderBool = false;
+    }
+    const authorizationCode = await this.tinkAccountRef.getUserAuthorizationCode(
+      this.externalUserIdArg,
+      'df05e4b379934cd09963197cc855bfe9', // this is a hardcoded app id for tink link, as recommended by tink.com
+      'authorization:read,authorization:grant,credentials:refresh,credentials:read,credentials:write,providers:read,user:read'
+    );
+    const tinkLinkUrl = `https://link.tink.com/1.0/business-transactions/connect-accounts?client_id=${'teststate'}&redirect_uri=${linkOptionsArg.redirectUrl}&authorization_code=${authorizationCode}&market=${linkOptionsArg.countryId}&test=${linkOptionsArg.testProviderBool}`;
+    return tinkLinkUrl;
+  }
+
+  public async getProviderConsents(): Promise<TinkProviderConsent[]> {
+    const providerConsents: TinkProviderConsent[] =
+      await TinkProviderConsent.getProviderConsentsForUser(this);
+    return providerConsents;
   }
 }

ts/tink.plugins.ts

@@ -1,6 +1,6 @@
 // @pushrocks scope
+import * as smartdelay from '@pushrocks/smartdelay';
 import * as smartrequest from '@pushrocks/smartrequest';
+import * as smartpromise from '@pushrocks/smartpromise';
 
-export {
-  smartrequest
-}
+export { smartdelay, smartrequest, smartpromise };