Merge branch 'main' into sentry-ai/mcp

Author: egelhaus

.env.example

@@ -50,6 +50,10 @@ GITHUB_CLIENT_ID=""
 GITHUB_CLIENT_SECRET=""
 BEEHIIVE_API_KEY=""
 BEEHIIVE_PUBLICATION_ID=""
+LISTMONK_DOMAIN=""
+LISTMONK_USER=""
+LISTMONK_API_KEY=""
+LISTMONK_LIST_ID=""
 THREADS_APP_ID=""
 THREADS_APP_SECRET=""
 FACEBOOK_APP_ID=""

README.md

@@ -1,6 +1,6 @@
 <p align="center">
-  <a href="https://affiliate.postiz.com">
-    <img src="https://github.com/user-attachments/assets/af9f47b3-e20c-402b-bd11-02f39248d738" />
+  <a href="https://github.com/growchief/growchief">
+    <img alt="automate" src="https://github.com/user-attachments/assets/d760188d-8d56-4b05-a6c1-c57e67ef25cd" />
   </a>
 </p>
 

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

@@ -1,4 +1,14 @@
-import { Body, Controller, Get, Param, Post, Req, Res } from '@nestjs/common';
+import {
+  Body,
+  Controller,
+  Get,
+  Param,
+  Post,
+  Query,
+  Req,
+  Res,
+  StreamableFile,
+} from '@nestjs/common';
 import { ApiTags } from '@nestjs/swagger';
 import { AgenciesService } from '@gitroom/nestjs-libraries/database/prisma/agencies/agencies.service';
 import { PostsService } from '@gitroom/nestjs-libraries/database/prisma/posts/posts.service';
@@ -11,6 +21,10 @@ import { makeId } from '@gitroom/nestjs-libraries/services/make.is';
 import { getCookieUrlFromDomain } from '@gitroom/helpers/subdomain/subdomain.management';
 import { AgentGraphInsertService } from '@gitroom/nestjs-libraries/agent/agent.graph.insert.service';
 import { Nowpayments } from '@gitroom/nestjs-libraries/crypto/nowpayments';
+import { Readable, pipeline } from 'stream';
+import { promisify } from 'util';
+
+const pump = promisify(pipeline);
 
 @ApiTags('Public')
 @Controller('/public')
@@ -136,4 +150,46 @@ export class PublicController {
     console.log('cryptoPost', body, path);
     return this._nowpayments.processPayment(path, body);
   }
+
+  @Get('/stream')
+  async streamFile(
+    @Query('url') url: string,
+    @Res() res: Response,
+    @Req() req: Request
+  ) {
+    if (!url.endsWith('mp4')) {
+      return res.status(400).send('Invalid video URL');
+    }
+
+    const ac = new AbortController();
+    const onClose = () => ac.abort();
+    req.on('aborted', onClose);
+    res.on('close', onClose);
+
+    const r = await fetch(url, { signal: ac.signal });
+
+    if (!r.ok && r.status !== 206) {
+      res.status(r.status);
+      throw new Error(`Upstream error: ${r.statusText}`);
+    }
+
+    const type = r.headers.get('content-type') ?? 'application/octet-stream';
+    res.setHeader('Content-Type', type);
+
+    const contentRange = r.headers.get('content-range');
+    if (contentRange) res.setHeader('Content-Range', contentRange);
+
+    const len = r.headers.get('content-length');
+    if (len) res.setHeader('Content-Length', len);
+
+    const acceptRanges = r.headers.get('accept-ranges') ?? 'bytes';
+    res.setHeader('Accept-Ranges', acceptRanges);
+
+    if (r.status === 206) res.status(206); // Partial Content for range responses
+
+    try {
+      await pump(Readable.fromWeb(r.body as any), res);
+    } catch (err) {
+    }
+  }
 }

apps/backend/src/mcp/main.mcp.ts

@@ -50,7 +50,7 @@ export class MainMcp {
   @McpTool({
     toolName: 'POSTIZ_SCHEDULE_POST',
     zod: {
-      type: eenum(['draft', 'scheduled']),
+      type: eenum(['draft', 'schedule']),
       configId: string(),
       generatePictures: boolean(),
       date: string().describe('UTC TIME'),

apps/backend/src/public-api/public.api.module.ts

@@ -34,3 +34,4 @@ export class PublicApiModule implements NestModule {
     consumer.apply(PublicAuthMiddleware).forRoutes(...authenticatedController);
   }
 }
+

apps/backend/src/services/auth/auth.service.ts

@@ -7,10 +7,10 @@ import { OrganizationService } from '@gitroom/nestjs-libraries/database/prisma/o
 import { AuthService as AuthChecker } from '@gitroom/helpers/auth/auth.service';
 import { ProvidersFactory } from '@gitroom/backend/services/auth/providers/providers.factory';
 import dayjs from 'dayjs';
-import { NewsletterService } from '@gitroom/nestjs-libraries/services/newsletter.service';
 import { NotificationService } from '@gitroom/nestjs-libraries/database/prisma/notifications/notification.service';
 import { ForgotReturnPasswordDto } from '@gitroom/nestjs-libraries/dtos/auth/forgot-return.password.dto';
 import { EmailService } from '@gitroom/nestjs-libraries/services/email.service';
+import { NewsletterService } from '@gitroom/nestjs-libraries/newsletter/newsletter.service';
 
 @Injectable()
 export class AuthService {

apps/cron/src/tasks/check.missing.queues.ts

@@ -28,6 +28,7 @@ export class CheckMissingQueues {
       )
     ).filter((p) => !p.isJob);
 
+
     for (const job of notExists) {
       this._workerServiceProducer.emit('post', {
         id: job.id,

apps/frontend/next.config.js

@@ -6,6 +6,16 @@ const nextConfig = {
   experimental: {
     proxyTimeout: 90_000,
   },
+  // Document-Policy header for browser profiling
+  async headers() {
+    return [{
+      source: "/:path*",
+      headers: [{
+        key: "Document-Policy",
+        value: "js-profiling",
+      }, ],
+    }, ];
+  },
   reactStrictMode: false,
   transpilePackages: ['crypto-hash'],
   // Enable production sourcemaps for Sentry
@@ -60,15 +70,15 @@ export default withSentryConfig(nextConfig, {
   org: process.env.SENTRY_ORG,
   project: process.env.SENTRY_PROJECT,
   authToken: process.env.SENTRY_AUTH_TOKEN,
-  
+
   // Sourcemap configuration optimized for monorepo
   sourcemaps: {
     disable: false,
     // More comprehensive asset patterns for monorepo
     assets: [
       ".next/static/**/*.js",
       ".next/static/**/*.js.map",
-      ".next/server/**/*.js", 
+      ".next/server/**/*.js",
       ".next/server/**/*.js.map",
     ],
     ignore: [
@@ -97,7 +107,7 @@ export default withSentryConfig(nextConfig, {
   telemetry: false,
   silent: process.env.NODE_ENV === 'production',
   debug: process.env.NODE_ENV === 'development',
-  
+
   // Error handling for CI/CD
   errorHandler: (error) => {
     console.warn("Sentry build error occurred:", error.message);

apps/frontend/public/icons/platforms/listmonk.png

@@ -10,6 +10,16 @@ import utc from 'dayjs/plugin/utc';
 import { VideoOrImage } from '@gitroom/react/helpers/video.or.image';
 import { CopyClient } from '@gitroom/frontend/components/preview/copy.client';
 import { getT } from '@gitroom/react/translation/get.translation.service.backend';
+import dynamicLoad from 'next/dynamic';
+
+const RenderPreviewDate = dynamicLoad(
+  () =>
+    import('@gitroom/frontend/components/preview/render.preview.date').then(
+      (mod) => mod.RenderPreviewDate
+    ),
+  { ssr: false }
+);
+
 dayjs.extend(utc);
 export const metadata: Metadata = {
   title: `${isGeneralServerSide() ? 'Postiz' : 'Gitroom'} Preview`,
@@ -91,11 +101,8 @@ export default async function Auth({
               </div>
             )}
             <div className="flex-1">
-              {t('publication_date', 'Publication Date:')}
-              {dayjs
-                .utc(post[0].publishDate)
-                .local()
-                .format('MMMM D, YYYY h:mm A')}
+              {t('publication_date', 'Publication Date:')}{' '}
+              <RenderPreviewDate date={post[0].publishDate} />
             </div>
           </div>
         </div>