Spaces:

Benaah
/

MicProtocol

Running

MicProtocol / apps /api /src /integrations /integrations.controller.ts

Upload folder using huggingface_hub

6abfd9d verified about 21 hours ago

4.55 kB

import { Controller, Get, Query, Res, Logger } from "@nestjs/common";
import { Response } from "express";
import { IntegrationsService } from "./integrations.service";

@Controller("api/integrations")
export class IntegrationsController {
    private readonly logger = new Logger(IntegrationsController.name);

    constructor(private readonly integrationsService: IntegrationsService) {}

    @Get("google/callback")
    async googleCallback(
        @Query("code") code: string,
        @Query("state") state: string,
        @Query("error") error: string,
        @Res() res: Response,
    ) {
        if (error) {
            this.logger.warn(`Google OAuth error: ${error}`);
            return res.redirect(`${process.env.WEBAPP_URL || "http://localhost:3000"}/settings?integration=google_calendar&status=error`);
        }

        try {
            const result = await this.integrationsService.handleOAuthCallback(code, state);
            return res.redirect(
                `${process.env.WEBAPP_URL || "http://localhost:3000"}/settings?integration=${result.provider}&status=${result.success ? "connected" : "error"}`,
            );
        } catch (err: any) {
            this.logger.error(`Google OAuth callback failed: ${err.message}`);
            return res.redirect(
                `${process.env.WEBAPP_URL || "http://localhost:3000"}/settings?integration=google_calendar&status=error`,
            );
        }
    }

    @Get("outlook/callback")
    async outlookCallback(
        @Query("code") code: string,
        @Query("state") state: string,
        @Query("error") error: string,
        @Res() res: Response,
    ) {
        if (error) {
            this.logger.warn(`Outlook OAuth error: ${error}`);
            return res.redirect(`${process.env.WEBAPP_URL || "http://localhost:3000"}/settings?integration=outlook&status=error`);
        }

        try {
            const result = await this.integrationsService.handleOAuthCallback(code, state);
            return res.redirect(
                `${process.env.WEBAPP_URL || "http://localhost:3000"}/settings?integration=${result.provider}&status=${result.success ? "connected" : "error"}`,
            );
        } catch (err: any) {
            this.logger.error(`Outlook OAuth callback failed: ${err.message}`);
            return res.redirect(
                `${process.env.WEBAPP_URL || "http://localhost:3000"}/settings?integration=outlook&status=error`,
            );
        }
    }

    @Get("zoom/callback")
    async zoomCallback(
        @Query("code") code: string,
        @Query("state") state: string,
        @Query("error") error: string,
        @Res() res: Response,
    ) {
        if (error) {
            this.logger.warn(`Zoom OAuth error: ${error}`);
            return res.redirect(`${process.env.WEBAPP_URL || "http://localhost:3000"}/settings?integration=zoom&status=error`);
        }

        try {
            const result = await this.integrationsService.handleOAuthCallback(code, state);
            return res.redirect(
                `${process.env.WEBAPP_URL || "http://localhost:3000"}/settings?integration=${result.provider}&status=${result.success ? "connected" : "error"}`,
            );
        } catch (err: any) {
            this.logger.error(`Zoom OAuth callback failed: ${err.message}`);
            return res.redirect(
                `${process.env.WEBAPP_URL || "http://localhost:3000"}/settings?integration=zoom&status=error`,
            );
        }
    }

    @Get("riverside/callback")
    async riversideCallback(
        @Query("code") code: string,
        @Query("state") state: string,
        @Query("error") error: string,
        @Res() res: Response,
    ) {
        if (error) {
            this.logger.warn(`Riverside OAuth error: ${error}`);
            return res.redirect(`${process.env.WEBAPP_URL || "http://localhost:3000"}/settings?integration=riverside&status=error`);
        }

        try {
            const result = await this.integrationsService.handleOAuthCallback(code, state);
            return res.redirect(
                `${process.env.WEBAPP_URL || "http://localhost:3000"}/settings?integration=${result.provider}&status=${result.success ? "connected" : "error"}`,
            );
        } catch (err: any) {
            this.logger.error(`Riverside OAuth callback failed: ${err.message}`);
            return res.redirect(
                `${process.env.WEBAPP_URL || "http://localhost:3000"}/settings?integration=riverside&status=error`,
            );
        }
    }
}

	import { Controller, Get, Query, Res, Logger } from "@nestjs/common";
	import { Response } from "express";
	import { IntegrationsService } from "./integrations.service";

	@Controller("api/integrations")
	export class IntegrationsController {
	private readonly logger = new Logger(IntegrationsController.name);

	constructor(private readonly integrationsService: IntegrationsService) {}

	@Get("google/callback")
	async googleCallback(
	@Query("code") code: string,
	@Query("state") state: string,
	@Query("error") error: string,
	@Res() res: Response,
	) {
	if (error) {
	this.logger.warn(`Google OAuth error: ${error}`);
	return res.redirect(`${process.env.WEBAPP_URL \|\| "http://localhost:3000"}/settings?integration=google_calendar&status=error`);
	}

	try {
	const result = await this.integrationsService.handleOAuthCallback(code, state);
	return res.redirect(
	`${process.env.WEBAPP_URL \|\| "http://localhost:3000"}/settings?integration=${result.provider}&status=${result.success ? "connected" : "error"}`,
	);
	} catch (err: any) {
	this.logger.error(`Google OAuth callback failed: ${err.message}`);
	return res.redirect(
	`${process.env.WEBAPP_URL \|\| "http://localhost:3000"}/settings?integration=google_calendar&status=error`,
	);
	}
	}

	@Get("outlook/callback")
	async outlookCallback(
	@Query("code") code: string,
	@Query("state") state: string,
	@Query("error") error: string,
	@Res() res: Response,
	) {
	if (error) {
	this.logger.warn(`Outlook OAuth error: ${error}`);
	return res.redirect(`${process.env.WEBAPP_URL \|\| "http://localhost:3000"}/settings?integration=outlook&status=error`);
	}

	try {
	const result = await this.integrationsService.handleOAuthCallback(code, state);
	return res.redirect(
	`${process.env.WEBAPP_URL \|\| "http://localhost:3000"}/settings?integration=${result.provider}&status=${result.success ? "connected" : "error"}`,
	);
	} catch (err: any) {
	this.logger.error(`Outlook OAuth callback failed: ${err.message}`);
	return res.redirect(
	`${process.env.WEBAPP_URL \|\| "http://localhost:3000"}/settings?integration=outlook&status=error`,
	);
	}
	}

	@Get("zoom/callback")
	async zoomCallback(
	@Query("code") code: string,
	@Query("state") state: string,
	@Query("error") error: string,
	@Res() res: Response,
	) {
	if (error) {
	this.logger.warn(`Zoom OAuth error: ${error}`);
	return res.redirect(`${process.env.WEBAPP_URL \|\| "http://localhost:3000"}/settings?integration=zoom&status=error`);
	}

	try {
	const result = await this.integrationsService.handleOAuthCallback(code, state);
	return res.redirect(
	`${process.env.WEBAPP_URL \|\| "http://localhost:3000"}/settings?integration=${result.provider}&status=${result.success ? "connected" : "error"}`,
	);
	} catch (err: any) {
	this.logger.error(`Zoom OAuth callback failed: ${err.message}`);
	return res.redirect(
	`${process.env.WEBAPP_URL \|\| "http://localhost:3000"}/settings?integration=zoom&status=error`,
	);
	}
	}

	@Get("riverside/callback")
	async riversideCallback(
	@Query("code") code: string,
	@Query("state") state: string,
	@Query("error") error: string,
	@Res() res: Response,
	) {
	if (error) {
	this.logger.warn(`Riverside OAuth error: ${error}`);
	return res.redirect(`${process.env.WEBAPP_URL \|\| "http://localhost:3000"}/settings?integration=riverside&status=error`);
	}

	try {
	const result = await this.integrationsService.handleOAuthCallback(code, state);
	return res.redirect(
	`${process.env.WEBAPP_URL \|\| "http://localhost:3000"}/settings?integration=${result.provider}&status=${result.success ? "connected" : "error"}`,
	);
	} catch (err: any) {
	this.logger.error(`Riverside OAuth callback failed: ${err.message}`);
	return res.redirect(
	`${process.env.WEBAPP_URL \|\| "http://localhost:3000"}/settings?integration=riverside&status=error`,
	);
	}
	}
	}