feat: public api

Author: nevo-david

.github/ISSUE_TEMPLATE/01_installation.prolem.yml

@@ -0,0 +1,19 @@
+name: "🙏🏻 Installation Problem"
+description: "Report an issue with installation"
+title: "Installation Problem"
+labels: ["type: installation"]
+body:
+  - type: markdown
+    attributes:
+      value: For installation issues, please visit our [Discord Support](https://discord.postiz.com) for assistance.
+  - type: textarea
+    id: feature-description
+    validations:
+      required: true
+    attributes:
+      label: For installation issues, please visit our https://discord.postiz.com for assistance.
+      description: For installation issues, please visit our [Discord Support](https://discord.postiz.com) for assistance.
+      placeholder: |
+        For installation issues, please visit our https://discord.postiz.com for assistance.
+        Please do not save this issue - do not submit installation issues on GitHub.
+

.github/ISSUE_TEMPLATE/bug_report.yml .github/ISSUE_TEMPLATE/02_bug_report.yml

@@ -1,8 +1,14 @@
+<p align="center">
+  <a href="https://affiliate.postiz.com">
+    <img src="https://github.com/user-attachments/assets/af9f47b3-e20c-402b-bd11-02f39248d738" />
+  </a>
+</p>
+
 <p align="center">
   <a href="https://postiz.com" target="_blank">
   <picture>
     <source media="(prefers-color-scheme: dark)" srcset="https://github.com/user-attachments/assets/765e9d72-3ee7-4a56-9d59-a2c9befe2311">
-    <img alt="Novu Logo" src="https://github.com/user-attachments/assets/f0d30d70-dddb-4142-8876-e9aa6ed1cb99" width="280"/>
+    <img alt="Postiz Logo" src="https://github.com/user-attachments/assets/f0d30d70-dddb-4142-8876-e9aa6ed1cb99" width="280"/>
   </picture>
   </a>
 </p>
@@ -58,22 +64,6 @@
 
 <br />
 
-
-<p align="center">
-  <br /><br /><br />
-  <h1>We participate in Hacktoberfest 2024! 🎉🎊</h1>
-  <p align="left">We are sending a t-shirt for every merged PR! (max 1 per person)</p>
-  <p align="left"><strong>Rules:</strong></p>
-  <ul align="left">
-    <li>You must create an issue before making a pull request.</li>
-    <li>You can also ask to be assigned to an issue. During Hacktoberfest, each issue can have multiple assignees.</li>
-    <li>We have to approve the issue and add a "hacktoberfest" tag.</li>
-    <li>We encourage everybody to contribute to all types of issues. We will only send swag for issues with features and bug fixes (no typos, sorry).</li>
-  </ul>
-  <p align="center"><img align="center" width="400" src="https://github.com/user-attachments/assets/3ceffccc-e4b3-4098-b9ba-44a94cf01294" /></p>
-  <br /><br /><br />
-</p>
-
 <p align="center">
   <video src="https://github.com/user-attachments/assets/05436a01-19c8-4827-b57f-05a5e7637a67" width="100%" />
 </p>

.github/ISSUE_TEMPLATE/feature_request.yml .github/ISSUE_TEMPLATE/03_feature_request.yml

@@ -1,4 +1,4 @@
-import { Controller, Get, Post, Req, Res } from '@nestjs/common';
+import { Logger, Controller, Get, Post, Req, Res } from '@nestjs/common';
 import {
   CopilotRuntime,
   OpenAIAdapter,
@@ -13,6 +13,11 @@ export class CopilotController {
   constructor(private _subscriptionService: SubscriptionService) {}
   @Post('/chat')
   chat(@Req() req: Request, @Res() res: Response) {
+    if (process.env.OPENAI_API_KEY === undefined || process.env.OPENAI_API_KEY === '') {
+      Logger.warn('OpenAI API key not set, chat functionality will not work');
+      return
+    }
+
     const copilotRuntimeHandler = copilotRuntimeNestEndpoint({
       endpoint: '/copilot/chat',
       runtime: new CopilotRuntime(),

README.md

@@ -1,12 +1,5 @@
 import {
-  Body,
-  Controller,
-  Delete,
-  Get,
-  Param,
-  Post,
-  Query,
-  UseFilters,
+  Body, Controller, Delete, Get, Param, Post, Put, Query, UseFilters
 } from '@nestjs/common';
 import { ioRedis } from '@gitroom/nestjs-libraries/redis/redis.service';
 import { ConnectIntegrationDto } from '@gitroom/nestjs-libraries/dtos/integrations/connect.integration.dto';
@@ -29,6 +22,12 @@ import { PostsService } from '@gitroom/nestjs-libraries/database/prisma/posts/po
 import { IntegrationTimeDto } from '@gitroom/nestjs-libraries/dtos/integrations/integration.time.dto';
 import { AuthService } from '@gitroom/helpers/auth/auth.service';
 import { AuthTokenDetails } from '@gitroom/nestjs-libraries/integrations/social/social.integrations.interface';
+import { PlugDto } from '@gitroom/nestjs-libraries/dtos/plugs/plug.dto';
+import {
+  NotEnoughScopes,
+  RefreshToken,
+} from '@gitroom/nestjs-libraries/integrations/social.abstract';
+import { timer } from '@gitroom/helpers/utils/timer';
 
 @ApiTags('Integrations')
 @Controller('/integrations')
@@ -43,6 +42,37 @@ export class IntegrationsController {
     return this._integrationManager.getAllIntegrations();
   }
 
+  @Get('/customers')
+  getCustomers(@GetOrgFromRequest() org: Organization) {
+    return this._integrationService.customers(org.id);
+  }
+
+  @Put('/:id/group')
+  async updateIntegrationGroup(
+    @GetOrgFromRequest() org: Organization,
+    @Param('id') id: string,
+    @Body() body: { group: string }
+  ) {
+    return this._integrationService.updateIntegrationGroup(
+      org.id,
+      id,
+      body.group
+    );
+  }
+
+  @Put('/:id/customer-name')
+  async updateOnCustomerName(
+    @GetOrgFromRequest() org: Organization,
+    @Param('id') id: string,
+    @Body() body: { name: string }
+  ) {
+    return this._integrationService.updateOnCustomerName(
+      org.id,
+      id,
+      body.name
+    );
+  }
+
   @Get('/list')
   async getIntegrationList(@GetOrgFromRequest() org: Organization) {
     return {
@@ -57,7 +87,7 @@ export class IntegrationsController {
           id: p.id,
           internalId: p.internalId,
           disabled: p.disabled,
-          picture: p.picture,
+          picture: p.picture || '/no-picture.jpg',
           identifier: p.providerIdentifier,
           inBetweenSteps: p.inBetweenSteps,
           refreshNeeded: p.refreshNeeded,
@@ -66,6 +96,7 @@ export class IntegrationsController {
           time: JSON.parse(p.postingTimes),
           changeProfilePicture: !!findIntegration?.changeProfilePicture,
           changeNickName: !!findIntegration?.changeNickname,
+          customer: p.customer,
         };
       }),
     };
@@ -207,11 +238,51 @@ export class IntegrationsController {
       }
 
       if (integrationProvider[body.name]) {
-        return integrationProvider[body.name](
-          getIntegration.token,
-          body.data,
-          getIntegration.internalId
-        );
+        try {
+          const load = await integrationProvider[body.name](
+            getIntegration.token,
+            body.data,
+            getIntegration.internalId
+          );
+
+          return load;
+        } catch (err) {
+          if (err instanceof RefreshToken) {
+            const { accessToken, refreshToken, expiresIn } =
+              await integrationProvider.refreshToken(
+                getIntegration.refreshToken
+              );
+
+            if (accessToken) {
+              await this._integrationService.createOrUpdateIntegration(
+                getIntegration.organizationId,
+                getIntegration.name,
+                getIntegration.picture!,
+                'social',
+                getIntegration.internalId,
+                getIntegration.providerIdentifier,
+                accessToken,
+                refreshToken,
+                expiresIn
+              );
+
+              getIntegration.token = accessToken;
+
+              if (integrationProvider.refreshWait) {
+                await timer(10000);
+              }
+              return this.functionIntegration(org, body);
+            } else {
+              await this._integrationService.disconnectChannel(
+                org.id,
+                getIntegration
+              );
+              return false;
+            }
+          }
+
+          return false;
+        }
       }
       throw new Error('Function not found');
     }
@@ -323,6 +394,7 @@ export class IntegrationsController {
     }
 
     const {
+      error,
       accessToken,
       expiresIn,
       refreshToken,
@@ -341,6 +413,17 @@ export class IntegrationsController {
         details ? JSON.parse(details) : undefined
       );
 
+      if (typeof auth === 'string') {
+        return res({
+          error: auth,
+          accessToken: '',
+          id: '',
+          name: '',
+          picture: '',
+          username: '',
+        });
+      }
+
       if (refresh && integrationProvider.reConnect) {
         const newAuth = await integrationProvider.reConnect(
           auth.id,
@@ -353,13 +436,31 @@ export class IntegrationsController {
       return res(auth);
     });
 
+    if (error) {
+      throw new NotEnoughScopes(error);
+    }
+
     if (!id) {
-      throw new Error('Invalid api key');
+      throw new NotEnoughScopes('Invalid API key');
+    }
+
+    if (refresh && id !== refresh) {
+      throw new NotEnoughScopes(
+        'Please refresh the channel that needs to be refreshed'
+      );
     }
 
+    let validName = name;
+    if (!validName) {
+      if (username) {
+        validName = username.split('.')[0] ?? username;
+      } else {
+        validName = `Channel_${String(id).slice(0, 8)}`;
+      }
+    }
     return this._integrationService.createOrUpdateIntegration(
       org.id,
-      name,
+      validName.trim(),
       picture,
       'social',
       String(id),
@@ -446,4 +547,35 @@ export class IntegrationsController {
 
     return this._integrationService.deleteChannel(org.id, id);
   }
+
+  @Get('/plug/list')
+  async getPlugList() {
+    return { plugs: this._integrationManager.getAllPlugs() };
+  }
+
+  @Get('/:id/plugs')
+  async getPlugsByIntegrationId(
+    @Param('id') id: string,
+    @GetOrgFromRequest() org: Organization
+  ) {
+    return this._integrationService.getPlugsByIntegrationId(org.id, id);
+  }
+
+  @Post('/:id/plugs')
+  async postPlugsByIntegrationId(
+    @Param('id') id: string,
+    @GetOrgFromRequest() org: Organization,
+    @Body() body: PlugDto
+  ) {
+    return this._integrationService.createOrUpdatePlug(org.id, id, body);
+  }
+
+  @Put('/plugs/:id/activate')
+  async changePlugActivation(
+    @Param('id') id: string,
+    @GetOrgFromRequest() org: Organization,
+    @Body('status') status: boolean
+  ) {
+    return this._integrationService.changePlugActivation(org.id, id, status);
+  }
 }

apps/backend/src/api/routes/copilot.controller.ts

@@ -10,7 +10,6 @@ import handleR2Upload from '@gitroom/nestjs-libraries/upload/r2.uploader';
 import { FileInterceptor } from '@nestjs/platform-express';
 import { CustomFileValidationPipe } from '@gitroom/nestjs-libraries/upload/custom.upload.validation';
 import { SubscriptionService } from '@gitroom/nestjs-libraries/database/prisma/subscriptions/subscription.service';
-import { basename } from 'path';
 import { UploadFactory } from '@gitroom/nestjs-libraries/upload/upload.factory';
 
 @ApiTags('Media')

apps/backend/src/api/routes/integrations.controller.ts

@@ -47,7 +47,7 @@ export class UsersController {
     if (!organization) {
       throw new HttpForbiddenException();
     }
-
+    // @ts-ignore
     return {
       ...user,
       orgId: organization.id,
@@ -61,6 +61,8 @@ export class UsersController {
       isLifetime: !!organization?.subscription?.isLifetime,
       admin: !!user.isSuperAdmin,
       impersonate: !!req.cookies.impersonate,
+      // @ts-ignore
+      publicApi: (organization?.users[0]?.role === 'SUPERADMIN' || organization?.users[0]?.role === 'ADMIN') ? organization?.apiKey : '',
     };
   }
 

apps/backend/src/api/routes/media.controller.ts

@@ -6,12 +6,31 @@ import { APP_GUARD } from '@nestjs/core';
 import { PoliciesGuard } from '@gitroom/backend/services/auth/permissions/permissions.guard';
 import { BullMqModule } from '@gitroom/nestjs-libraries/bull-mq-transport-new/bull.mq.module';
 import { PluginModule } from '@gitroom/plugins/plugin.module';
+import { PublicApiModule } from '@gitroom/backend/public-api/public.api.module';
+import { ThrottlerBehindProxyGuard } from '@gitroom/nestjs-libraries/throttler/throttler.provider';
+import { ThrottlerModule } from '@nestjs/throttler';
 
 @Global()
 @Module({
-  imports: [BullMqModule, DatabaseModule, ApiModule, PluginModule],
+  imports: [
+    BullMqModule,
+    DatabaseModule,
+    ApiModule,
+    PluginModule,
+    PublicApiModule,
+    ThrottlerModule.forRoot([
+      {
+        ttl: 3600000,
+        limit: 20,
+      },
+    ]),
+  ],
   controllers: [],
   providers: [
+    {
+      provide: APP_GUARD,
+      useClass: ThrottlerBehindProxyGuard,
+    },
     {
       provide: APP_GUARD,
       useClass: PoliciesGuard,