Store token, fix binding

Author: jankeromnes

components/gitpod-db/src/typeorm/entity/db-linked-in-token.ts

@@ -4,12 +4,27 @@
  * See License.AGPL.txt in the project root for license information.
  */
 
-import { Entity, PrimaryColumn } from "typeorm";
+import { Column, Entity, PrimaryColumn } from "typeorm";
+import { Transformer } from "../transformer";
 import { TypeORM } from "../typeorm";
+import { encryptionService } from "../user-db-impl";
 
 @Entity()
 // on DB but not Typeorm: @Index("ind_lastModified", ["_lastModified"])   // DBSync
 export class DBLinkedInToken {
     @PrimaryColumn(TypeORM.UUID_COLUMN_TYPE)
     id: string;
+
+    @Column(TypeORM.UUID_COLUMN_TYPE)
+    userId: string;
+
+    @Column({
+        type: "simple-json",
+        transformer: Transformer.compose(
+            Transformer.SIMPLE_JSON([]),
+            // Relies on the initialization of the var in UserDbImpl
+            Transformer.encrypted(() => encryptionService),
+        ),
+    })
+    token: { token: string };
 }

components/gitpod-db/src/typeorm/linked-in-token-db-impl.ts

@@ -21,4 +21,12 @@ export class LinkedInTokenDBImpl implements LinkedInTokenDB {
     protected async getRepo(): Promise<Repository<DBLinkedInToken>> {
         return (await this.getEntityManager()).getRepository<DBLinkedInToken>(DBLinkedInToken);
     }
+
+    public async storeToken(userId: string, token: string): Promise<void> {
+        const repo = await this.getRepo();
+        const dbToken = new DBLinkedInToken();
+        dbToken.userId = userId;
+        dbToken.token = { token };
+        await repo.save(dbToken);
+    }
 }

components/gitpod-db/src/typeorm/migration/1680096507296-LinkedInToken.ts

@@ -12,7 +12,7 @@ const TABLE_NAME = "d_b_linked_in_token";
 export class LinkedInToken1680096507296 implements MigrationInterface {
     public async up(queryRunner: QueryRunner): Promise<void> {
         await queryRunner.query(
-            `CREATE TABLE IF NOT EXISTS ${TABLE_NAME} (id char(36) NOT NULL, _lastModified timestamp(6) NOT NULL DEFAULT CURRENT_TIMESTAMP(6) ON UPDATE CURRENT_TIMESTAMP(6), PRIMARY KEY (id)) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;`,
+            `CREATE TABLE IF NOT EXISTS ${TABLE_NAME} (id char(36) NOT NULL, userId char(36) NOT NULL, token text NOT NULL, _lastModified timestamp(6) NOT NULL DEFAULT CURRENT_TIMESTAMP(6) ON UPDATE CURRENT_TIMESTAMP(6), PRIMARY KEY (id)) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;`,
         );
     }
 

components/server/ee/src/container-module.ts

@@ -62,6 +62,7 @@ import { EntitlementServiceLicense } from "./billing/entitlement-service-license
 import { EntitlementServiceImpl } from "./billing/entitlement-service";
 import { EntitlementServiceUBP } from "./billing/entitlement-service-ubp";
 import { UsageService, UsageServiceImpl, NoOpUsageService } from "../../src/user/usage-service";
+import { LinkedInService } from "./user/linkedin-service";
 
 export const productionEEContainerModule = new ContainerModule((bind, unbind, isBound, rebind) => {
     rebind(Server).to(ServerEE).inSingletonScope();
@@ -135,4 +136,5 @@ export const productionEEContainerModule = new ContainerModule((bind, unbind, is
             return new NoOpUsageService();
         })
         .inSingletonScope();
+    bind(LinkedInService).toSelf().inSingletonScope();
 });