Laushinka/let people unsubscribe 4761

components/server/src/container-module.ts

@@ -80,6 +80,7 @@ import { IAnalyticsWriter } from '@gitpod/gitpod-protocol/lib/analytics';
 import { HeadlessLogServiceClient } from '@gitpod/content-service/lib/headless-log_grpc_pb';
 import { ProjectsService } from './projects/projects-service';
 import { EnvConfig, Config } from './config';
+import { NewsletterSubscriptionController } from './user/newsletter-subscription-controller';
 
 export const productionContainerModule = new ContainerModule((bind, unbind, isBound, rebind) => {
     bind(Env).toSelf().inSingletonScope();
@@ -220,4 +221,6 @@ export const productionContainerModule = new ContainerModule((bind, unbind, isBo
     bind(HeadlessLogController).toSelf().inSingletonScope();
 
     bind(ProjectsService).toSelf().inSingletonScope();
+
+    bind(NewsletterSubscriptionController).toSelf().inSingletonScope();
 });

components/server/src/server.ts

@@ -41,6 +41,7 @@ import { CodeSyncService } from './code-sync/code-sync-service';
 import { increaseHttpRequestCounter, observeHttpRequestDuration } from './prometheus-metrics';
 import { OAuthController } from './oauth-server/oauth-controller';
 import { HeadlessLogController } from './workspace/headless-log-controller';
+import { NewsletterSubscriptionController } from './user/newsletter-subscription-controller';
 import { Config } from './config';
 
 @injectable()
@@ -73,6 +74,7 @@ export class Server<C extends GitpodClient, S extends GitpodServer> {
 
     @inject(HostContextProvider) protected readonly hostCtxProvider: HostContextProvider;
     @inject(OAuthController) protected readonly oauthController: OAuthController;
+    @inject(NewsletterSubscriptionController) protected readonly newsletterSubscriptionController: NewsletterSubscriptionController;
 
     protected readonly eventEmitter = new EventEmitter();
     protected app?: express.Application;
@@ -260,6 +262,7 @@ export class Server<C extends GitpodClient, S extends GitpodServer> {
         app.use('/workspace-download', this.workspaceDownloadService.apiRouter);
         app.use('/code-sync', this.codeSyncService.apiRouter);
         app.use('/headless-logs', this.headlessLogController.apiRouter);
+        app.use(this.newsletterSubscriptionController.apiRouter);
         app.use("/version", (req: express.Request, res: express.Response, next: express.NextFunction) => {
             res.send(this.env.version);
         });

components/server/src/user/newsletter-subscription-controller.ts

@@ -0,0 +1,86 @@
+/**
+ * Copyright (c) 2021 Gitpod GmbH. All rights reserved.
+ * Licensed under the GNU Affero General Public License (AGPL).
+ * See License-AGPL.txt in the project root for license information.
+ */
+
+import * as express from 'express';
+import { inject, injectable } from "inversify";
+import { UserDB } from "@gitpod/gitpod-db/lib";
+import { IAnalyticsWriter } from "@gitpod/gitpod-protocol/lib/analytics";
+
+@injectable()
+export class NewsletterSubscriptionController {
+    @inject(UserDB) protected readonly userDb: UserDB;
+    @inject(IAnalyticsWriter) protected readonly analytics: IAnalyticsWriter;
+
+    get apiRouter(): express.Router {
+        const router = express.Router();
+
+        router.get("/unsubscribe", async (req: express.Request, res: express.Response) => {
+            const email: string = req.query.email;
+            const newsletterType: string = req.query.type;
+            const acceptedNewsletterTypes: string[] = ["changelog", "devx"];
+            const newsletterProperties: {[key:string]: {[key: string]: string}} = {
+                changelog: {
+                    property: "unsubscribed_changelog",
+                    value: "allowsChangelogMail"
+                },
+                devx: {
+                    property: "unsubscribed_devx",
+                    value: "allowsDevXMail"
+                }
+            }
+
+            if (!acceptedNewsletterTypes.includes(newsletterType)) {
+                res.sendStatus(422);
+                return;
+            }
+
+            try {
+                // Not all newsletter subscribers are users,
+                // therefore the email address is our starting point
+                const user = (await this.userDb.findUsersByEmail(email))[0];
+                const successPageUrl: string = 'https://www.gitpod.io/unsubscribe';
+
+                if (user && user.additionalData && user.additionalData.emailNotificationSettings) {
+                    await this.userDb.updateUserPartial({
+                        ...user,
+                        additionalData: {
+                            ...user.additionalData,
+                            emailNotificationSettings: {
+                                ...user.additionalData.emailNotificationSettings,
+                                [newsletterProperties[newsletterType].value]: false
+                            }
+                        }
+                    });
+                    this.analytics.identify({
+                        userId: user.id,
+                        traits: {
+                            [newsletterProperties[newsletterType].property]: true
+                        }
+                    });
+                    res.redirect(successPageUrl);
+                }
+
+                else {
+                    this.analytics.identify({
+                        userId: email,
+                        traits: {
+                            [newsletterProperties[newsletterType].property]: true
+                        }
+                    });
+                    res.redirect(successPageUrl);
+                }
+            } catch (error) {
+                res.send({
+                    err: error.status,
+                    message: error.message
+                });
+                return;
+            }
+        })
+
+        return router;
+    }
+}