-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'main' into chore-sentence-case
- Loading branch information
Showing
26 changed files
with
388 additions
and
173 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,60 @@ | ||
| name: "Chromatic" | ||
|
|
||
| on: push | ||
|
|
||
| concurrency: | ||
| group: ${{ github.workflow }}-${{ github.ref }}-chromatic | ||
| cancel-in-progress: true | ||
|
|
||
| jobs: | ||
| changed-files: | ||
| runs-on: ubuntu-latest | ||
| name: changed-files | ||
| outputs: | ||
| all_changed_files: ${{ steps.changed-files.outputs.all_changed_files }} | ||
| any_changed: ${{ steps.changed-files.outputs.any_changed }} | ||
| steps: | ||
| - uses: actions/checkout@v4 | ||
| with: | ||
| fetch-depth: 0 | ||
| - name: Get changed files | ||
| id: changed-files | ||
| uses: tj-actions/changed-files@v44 | ||
| with: | ||
| files: | | ||
| apps/nextjs/** | ||
| chromatic: | ||
| name: Run Chromatic | ||
| needs: [changed-files] | ||
| if: ${{ needs.changed-files.outputs.any_changed == 'true' }} | ||
|
|
||
| runs-on: ubuntu-latest | ||
| steps: | ||
| - name: Checkout code | ||
| uses: actions/checkout@v4 | ||
| with: | ||
| fetch-depth: 0 | ||
| - name: Setup pnpm | ||
| uses: pnpm/action-setup@v3 | ||
| with: | ||
| version: 8 | ||
| - uses: actions/setup-node@v4 | ||
| with: | ||
| node-version: 20 | ||
| cache: "pnpm" | ||
| - name: Install dependencies | ||
| run: pnpm install | ||
| - name: Inject Doppler env vars | ||
| uses: dopplerhq/[email protected] | ||
| id: doppler | ||
| with: | ||
| doppler-token: ${{ secrets.DOPPLER_TOKEN }} | ||
| inject-env-vars: true | ||
| - name: Run Chromatic | ||
| uses: chromaui/action@latest | ||
| with: | ||
| workingDir: apps/nextjs | ||
| exitZeroOnChanges: true | ||
| exitOnceUploaded: true | ||
| onlyChanged: true |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,6 @@ | ||
| { | ||
| "onlyChanged": true, | ||
| "projectId": "Project:672908473f629875f0be294f", | ||
| "storybookBaseDir": "apps/nextjs", | ||
| "zip": true | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
140 changes: 140 additions & 0 deletions
140
apps/nextjs/src/app/api/cron-jobs/expired-exports/route.ts
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,140 @@ | ||
| import { prisma } from "@oakai/db"; | ||
| import { googleDrive } from "@oakai/exports/src/gSuite/drive/client"; | ||
| import { aiLogger } from "@oakai/logger"; | ||
| import * as Sentry from "@sentry/node"; | ||
| import type { NextRequest } from "next/server"; | ||
| import { isTruthy } from "remeda"; | ||
|
|
||
| const log = aiLogger("cron"); | ||
|
|
||
| const requiredEnvVars = ["CRON_SECRET", "GOOGLE_DRIVE_OUTPUT_FOLDER_ID"]; | ||
|
|
||
| requiredEnvVars.forEach((envVar) => { | ||
| if (!process.env[envVar]) { | ||
| throw new Error(`Environment variable ${envVar} is not set.`); | ||
| } | ||
| }); | ||
|
|
||
| async function updateExpiredAt(fileIds: string[]) { | ||
| if (fileIds.length === 0) { | ||
| log.info("No file IDs to update."); | ||
| return; | ||
| } | ||
|
|
||
| try { | ||
| const result = await prisma.lessonExport.updateMany({ | ||
| where: { | ||
| gdriveFileId: { | ||
| in: fileIds, | ||
| }, | ||
| }, | ||
| data: { | ||
| expiredAt: new Date(), | ||
| }, | ||
| }); | ||
| log.info(`Updated expiredAt for ${fileIds.length} files.`); | ||
|
|
||
| if (result.count === fileIds.length) { | ||
| log.info("All files updated successfully."); | ||
| } else { | ||
| throw new Error( | ||
| `Expected to update ${fileIds.length} files, but only updated ${result.count}.`, | ||
| ); | ||
| } | ||
| } catch (error) { | ||
| log.error("Error updating expiredAt field in the database:", error); | ||
| throw error; | ||
| } | ||
| } | ||
|
|
||
| async function deleteExpiredExports(fileIds: string[]) { | ||
| try { | ||
| for (const id of fileIds) { | ||
| await googleDrive.files.delete({ fileId: id }); | ||
| log.info("Deleted:", id); | ||
| } | ||
| } catch (error) { | ||
| log.error("Error deleting old files from folder:", error); | ||
| throw error; | ||
| } | ||
| } | ||
|
|
||
| interface FetchExpiredExportsOptions { | ||
| folderId: string; | ||
| daysAgo: number; | ||
| } | ||
|
|
||
| async function fetchExpiredExports({ | ||
| folderId, | ||
| daysAgo, | ||
| }: FetchExpiredExportsOptions) { | ||
| try { | ||
| const currentDate = new Date(); | ||
| const targetDate = new Date( | ||
| currentDate.setDate(currentDate.getDate() - daysAgo), | ||
| ).toISOString(); | ||
|
|
||
| const query = `modifiedTime < '${targetDate}' and '${folderId}' in parents`; | ||
|
|
||
| const res = await googleDrive.files.list({ | ||
| q: query, | ||
| fields: "files(id, name, modifiedTime, ownedByMe )", | ||
| pageSize: 1000, | ||
| }); | ||
|
|
||
| const files = | ||
| res.data.files?.filter((file) => file.ownedByMe === true) || []; | ||
|
|
||
| if (files.length === 0) { | ||
| log.info( | ||
| "No files found that are older than one month in the specified folder.", | ||
| ); | ||
| return null; | ||
| } | ||
|
|
||
| log.info(`Found ${files.length} files older than one month in folder:`); | ||
| return files; | ||
| } catch (error) { | ||
| log.error("Error fetching old files from folder:", error); | ||
| return null; | ||
| } | ||
| } | ||
|
|
||
| export async function GET(request: NextRequest) { | ||
| try { | ||
| const authHeader = request.headers.get("authorization"); | ||
|
|
||
| const cronSecret = process.env.CRON_SECRET; | ||
| const folderId = process.env.GOOGLE_DRIVE_OUTPUT_FOLDER_ID; | ||
|
|
||
| if (!cronSecret) { | ||
| log.error("Missing cron secret"); | ||
| return new Response("Missing cron secret", { status: 500 }); | ||
| } | ||
| if (!folderId) { | ||
| log.error("No folder ID provided."); | ||
| return new Response("No folder ID provided", { status: 500 }); | ||
| } | ||
|
|
||
| if (authHeader !== `Bearer ${cronSecret}`) { | ||
| log.error("Authorization failed. Invalid token."); | ||
| return new Response("Unauthorized", { status: 401 }); | ||
| } | ||
|
|
||
| const files = await fetchExpiredExports({ folderId, daysAgo: 14 }); | ||
|
|
||
| if (!files || files.length === 0) { | ||
| return new Response("No expired files found", { status: 404 }); | ||
| } | ||
|
|
||
| const validFileIds = files.map((file) => file.id).filter(isTruthy); | ||
|
|
||
| await updateExpiredAt(validFileIds); | ||
| await deleteExpiredExports(validFileIds); | ||
| } catch (error) { | ||
| Sentry.captureException(error); | ||
| return new Response("Internal Server Error", { status: 500 }); | ||
| } | ||
|
|
||
| return new Response(JSON.stringify({ success: true }), { status: 200 }); | ||
| } |
26 changes: 0 additions & 26 deletions
26
apps/nextjs/src/components/AppComponents/Chat/Chat/ChatUserAccessCheck.stories.tsx
This file was deleted.
Oops, something went wrong.
Oops, something went wrong.