set up sentry

This commit is contained in:
vergiLgood1 2025-03-16 00:46:37 +07:00
parent 693f5d265e
commit aed9eba5d3
49 changed files with 3074 additions and 232 deletions

View File

@ -39,3 +39,6 @@ yarn-error.log*
# typescript
*.tsbuildinfo
next-env.d.ts
# Sentry Config File
.env.sentry-build-plugin

View File

@ -7,7 +7,7 @@ import { Input } from "@/app/_components/ui/input";
import { SubmitButton } from "@/app/_components/submit-button";
import Link from "next/link";
import { FormField } from "@/app/_components/form-field";
import { useSignInController } from "@/src/interface-adapters/controllers/auth/sign-in-controller";
import { useSignInController } from "@/src/interface-adapters/controllers/auth/sign-in.controller";
import { useState } from "react";
import { signIn } from "../action";

View File

@ -0,0 +1,9 @@
import { NextResponse } from "next/server";
export const dynamic = "force-dynamic";
// A faulty API route to test Sentry's error monitoring
export function GET() {
throw new Error("Sentry Example API Route Error");
return NextResponse.json({ data: "Testing Sentry Error..." });
}

View File

@ -0,0 +1,23 @@
"use client";
import * as Sentry from "@sentry/nextjs";
import NextError from "next/error";
import { useEffect } from "react";
export default function GlobalError({ error }: { error: Error & { digest?: string } }) {
useEffect(() => {
Sentry.captureException(error);
}, [error]);
return (
<html>
<body>
{/* `NextError` is the default Next.js error page component. Its type
definition requires a `statusCode` prop. However, since the App Router
does not expose status codes for errors, we simply pass 0 to render a
generic error message. */}
<NextError statusCode={0} />
</body>
</html>
);
}

View File

@ -0,0 +1,16 @@
export const metadata = {
title: 'Next.js',
description: 'Generated by Next.js',
}
export default function RootLayout({
children,
}: {
children: React.ReactNode
}) {
return (
<html lang="en">
<body>{children}</body>
</html>
)
}

View File

@ -0,0 +1,79 @@
"use client";
import Head from "next/head";
import * as Sentry from "@sentry/nextjs";
export default function Page() {
return (
<div>
<Head>
<title>Sentry Onboarding</title>
<meta name="description" content="Test Sentry for your Next.js app!" />
</Head>
<main
style={{
minHeight: "100vh",
display: "flex",
flexDirection: "column",
justifyContent: "center",
alignItems: "center",
}}
>
<h1 style={{ fontSize: "4rem", margin: "14px 0" }}>
<svg
style={{
height: "1em",
}}
xmlns="http://www.w3.org/2000/svg"
viewBox="0 0 200 44"
>
<path
fill="currentColor"
d="M124.32,28.28,109.56,9.22h-3.68V34.77h3.73V15.19l15.18,19.58h3.26V9.22h-3.73ZM87.15,23.54h13.23V20.22H87.14V12.53h14.93V9.21H83.34V34.77h18.92V31.45H87.14ZM71.59,20.3h0C66.44,19.06,65,18.08,65,15.7c0-2.14,1.89-3.59,4.71-3.59a12.06,12.06,0,0,1,7.07,2.55l2-2.83a14.1,14.1,0,0,0-9-3c-5.06,0-8.59,3-8.59,7.27,0,4.6,3,6.19,8.46,7.52C74.51,24.74,76,25.78,76,28.11s-2,3.77-5.09,3.77a12.34,12.34,0,0,1-8.3-3.26l-2.25,2.69a15.94,15.94,0,0,0,10.42,3.85c5.48,0,9-2.95,9-7.51C79.75,23.79,77.47,21.72,71.59,20.3ZM195.7,9.22l-7.69,12-7.64-12h-4.46L186,24.67V34.78h3.84V24.55L200,9.22Zm-64.63,3.46h8.37v22.1h3.84V12.68h8.37V9.22H131.08ZM169.41,24.8c3.86-1.07,6-3.77,6-7.63,0-4.91-3.59-8-9.38-8H154.67V34.76h3.8V25.58h6.45l6.48,9.2h4.44l-7-9.82Zm-10.95-2.5V12.6h7.17c3.74,0,5.88,1.77,5.88,4.84s-2.29,4.86-5.84,4.86Z M29,2.26a4.67,4.67,0,0,0-8,0L14.42,13.53A32.21,32.21,0,0,1,32.17,40.19H27.55A27.68,27.68,0,0,0,12.09,17.47L6,28a15.92,15.92,0,0,1,9.23,12.17H4.62A.76.76,0,0,1,4,39.06l2.94-5a10.74,10.74,0,0,0-3.36-1.9l-2.91,5a4.54,4.54,0,0,0,1.69,6.24A4.66,4.66,0,0,0,4.62,44H19.15a19.4,19.4,0,0,0-8-17.31l2.31-4A23.87,23.87,0,0,1,23.76,44H36.07a35.88,35.88,0,0,0-16.41-31.8l4.67-8a.77.77,0,0,1,1.05-.27c.53.29,20.29,34.77,20.66,35.17a.76.76,0,0,1-.68,1.13H40.6q.09,1.91,0,3.81h4.78A4.59,4.59,0,0,0,50,39.43a4.49,4.49,0,0,0-.62-2.28Z"
></path>
</svg>
</h1>
<p>Get started by sending us a sample error:</p>
<button
type="button"
style={{
padding: "12px",
cursor: "pointer",
backgroundColor: "#AD6CAA",
borderRadius: "4px",
border: "none",
color: "white",
fontSize: "14px",
margin: "18px",
}}
onClick={async () => {
await Sentry.startSpan({
name: 'Example Frontend Span',
op: 'test'
}, async () => {
const res = await fetch("/api/sentry-example-api");
if (!res.ok) {
throw new Error("Sentry Example Frontend Error");
}
});
}}
>
Throw error!
</button>
<p>
Next, look for the error on the{" "}
<a href="https://politeknik-negeri-jember-hl.sentry.io/issues/?project=4508982535585792">Issues Page</a>.
</p>
<p style={{ marginTop: "24px" }}>
For more information, see{" "}
<a href="https://docs.sentry.io/platforms/javascript/guides/nextjs/">
https://docs.sentry.io/platforms/javascript/guides/nextjs/
</a>
</p>
</main>
</div>
);
}

View File

@ -2,9 +2,17 @@ import { createContainer } from '@evyweb/ioctopus';
import { DI_RETURN_TYPES, DI_SYMBOLS } from '@/di/types';
import { IInstrumentationService } from '@/src/application/services/instrumentation.service.interface';
import { createAuthenticationModule } from './modules/authentication.module';
import { createMonitoringModule } from './modules/monitoring.module';
import { createTransactionManagerModule } from './modules/database.modul';
import { createUsersModule } from './modules/users.module';
const ApplicationContainer = createContainer();
ApplicationContainer.load(Symbol('MonitoringModule'), createMonitoringModule());
ApplicationContainer.load(Symbol('TransactionManagerModule'), createTransactionManagerModule());
ApplicationContainer.load(Symbol('AuthenticationModule'), createAuthenticationModule());
ApplicationContainer.load(Symbol('UsersModule'), createUsersModule());
export function getInjection<K extends keyof typeof DI_SYMBOLS>(
symbol: K

View File

@ -1,21 +1,57 @@
import { createModule } from '@evyweb/ioctopus';
import { DI_SYMBOLS } from '@/di/types';
import { signInController, signOutController, verifyOtpController } from '@/src/interface-adapters/controllers/auth/authentication-controller';
import { AuthenticationService } from '@/src/infrastructure/services/authentication.service';
import { IInstrumentationServiceImpl } from '@/src/application/services/instrumentation.service.interface';
import { signInUseCase } from '@/src/application/use-cases/auth/sign-in.use-case';
import { signUpUseCase } from '@/src/application/use-cases/auth/sign-up.use-case';
import { signOutUseCase } from '@/src/application/use-cases/auth/sign-out.use-case';
import { DI_SYMBOLS } from '@/di/types';
import { signInController } from '@/src/interface-adapters/controllers/auth/sign-in.controller';
import { signOutController } from '@/src/interface-adapters/controllers/auth/sign-out.controller';
export function createAuthenticationModule() {
const authenticationModule = createModule();
if (process.env.NODE_ENV === 'test') {
// authenticationModule
// .bind(DI_SYMBOLS.IAuthenticationService)
// .toClass(MockAuthenticationService, [DI_SYMBOLS.IUsersRepository]);
} else {
authenticationModule
.bind(DI_SYMBOLS.IAuthenticationService)
.toClass(AuthenticationService, [
DI_SYMBOLS.IUsersRepository,
DI_SYMBOLS.IInstrumentationService,
]);
}
authenticationModule
.bind(DI_SYMBOLS.ISignInUseCase)
.toHigherOrderFunction(signInUseCase, [
DI_SYMBOLS.IInstrumentationService,
DI_SYMBOLS.IUsersRepository,
DI_SYMBOLS.IAuthenticationService,
]);
authenticationModule
.bind(DI_SYMBOLS.ISignOutUseCase)
.toHigherOrderFunction(signOutUseCase, [
DI_SYMBOLS.IInstrumentationService,
DI_SYMBOLS.IAuthenticationService,
]);
authenticationModule
.bind(DI_SYMBOLS.ISignUpUseCase)
.toHigherOrderFunction(signUpUseCase, [
DI_SYMBOLS.IInstrumentationService,
DI_SYMBOLS.IAuthenticationService,
DI_SYMBOLS.IUsersRepository,
]);
// Rest of your bindings remain the same
authenticationModule
.bind(DI_SYMBOLS.ISignInController)
.toHigherOrderFunction(signInController, [
@ -23,19 +59,14 @@ export function createAuthenticationModule() {
DI_SYMBOLS.ISignInUseCase,
]);
authenticationModule
.bind(DI_SYMBOLS.IVerifyOtpController)
.toHigherOrderFunction(verifyOtpController, [
DI_SYMBOLS.IInstrumentationService,
DI_SYMBOLS.IVerifyOtpUseCase,
]);
authenticationModule
.bind(DI_SYMBOLS.ISignOutController)
.toHigherOrderFunction(signOutController, [
DI_SYMBOLS.IInstrumentationService,
DI_SYMBOLS.IAuthenticationService,
DI_SYMBOLS.ISignOutUseCase,
]);
return authenticationModule;
}

View File

@ -0,0 +1,25 @@
// di/modules/transaction-manager.module.ts
import { createModule } from '@evyweb/ioctopus';
import { DI_SYMBOLS } from '@/di/types';
import { TransactionManagerService } from '@/src/infrastructure/services/transaction-manager.service';
import { MockTransactionManagerService } from '@/src/infrastructure/services/transaction-manager.service.mock';
export function createTransactionManagerModule() {
const transactionManagerModule = createModule();
if (process.env.NODE_ENV === 'test') {
// transactionManagerModule
// .bind(DI_SYMBOLS.ITransactionManagerService)
// .toClass(MockTransactionManagerService);
transactionManagerModule
.bind(DI_SYMBOLS.ITransactionManagerService)
.toClass(TransactionManagerService);
} else {
transactionManagerModule
.bind(DI_SYMBOLS.ITransactionManagerService)
.toClass(TransactionManagerService);
}
return transactionManagerModule;
}

View File

@ -1,17 +1,27 @@
import { createModule } from '@evyweb/ioctopus';
import { DI_SYMBOLS } from '@/di/types';
import { InstrumentationService } from '@/src/infrastructure/services/instrumentation.service';
import { CrashReporterService } from '@/src/infrastructure/services/crash-reporter.service';
import { MockInstrumentationService } from '@/src/infrastructure/services/instrumentation.service.mock';
import { MockCrashReporterService } from '@/src/infrastructure/services/crash-reporter.service.mock';
export function createMonitoringModule() {
const monitoringModule = createModule();
if (process.env.NODE_ENV === 'test') {
// monitoringModule
// .bind(DI_SYMBOLS.IInstrumentationService)
// .toClass(MockInstrumentationService);
// monitoringModule
// .bind(DI_SYMBOLS.ICrashReporterService)
// .toClass(MockCrashReporterService);
monitoringModule
.bind(DI_SYMBOLS.IInstrumentationService)
.toClass(MockInstrumentationService);
.toClass(InstrumentationService);
monitoringModule
.bind(DI_SYMBOLS.ICrashReporterService)
.toClass(MockCrashReporterService);
.toClass(CrashReporterService);
} else {
monitoringModule
.bind(DI_SYMBOLS.IInstrumentationService)

View File

@ -0,0 +1,29 @@
import { createModule } from '@evyweb/ioctopus';
import { DI_SYMBOLS } from '@/di/types';
import { UsersRepository } from '@/src/infrastructure/repositories/users.repository.impl';
export function createUsersModule() {
const usersModule = createModule();
if (process.env.NODE_ENV === 'test') {
// usersModule.bind(DI_SYMBOLS.IUsersRepository).toClass(MockUsersRepository);
usersModule
.bind(DI_SYMBOLS.IUsersRepository)
.toClass(UsersRepository, [
DI_SYMBOLS.IInstrumentationService,
DI_SYMBOLS.ICrashReporterService,
]);
} else {
usersModule
.bind(DI_SYMBOLS.IUsersRepository)
.toClass(UsersRepository, [
DI_SYMBOLS.IInstrumentationService,
DI_SYMBOLS.ICrashReporterService
]);
}
return usersModule;
}

View File

@ -6,10 +6,12 @@ import { ICrashReporterService } from '@/src/application/services/crash-reporter
import { ISignInUseCase } from '@/src/application/use-cases/auth/sign-in.use-case';
import { ISignUpUseCase } from '@/src/application/use-cases/auth/sign-up.use-case';
import { ISignOutUseCase } from '@/src/application/use-cases/auth/sign-out.use-case';
import { IUsersRepository } from '@/src/application/repositories/users.repository';
import { ISignInController, ISignOutController, IVerifyOtpController } from '@/src/interface-adapters/controllers/auth/authentication-controller';
import { IUsersRepository } from '@/src/application/repositories/users.repository.interface';
import { IVerifyOtpUseCase } from '@/src/application/use-cases/auth/verify-otp.use-case';
import { IInviteUserUseCase } from '@/src/application/use-cases/users/invite-user.use-case';
import { ISignInController } from '@/src/interface-adapters/controllers/auth/sign-in.controller';
import { ISignOutController } from '@/src/interface-adapters/controllers/auth/sign-out.controller';
import { IVerifyOtpController } from '@/src/interface-adapters/controllers/auth/verify-otp.controller';
export const DI_SYMBOLS = {
// Services
@ -24,6 +26,7 @@ export const DI_SYMBOLS = {
// Use Cases
ISignInUseCase: Symbol.for('ISignInUseCase'),
ISignOutUseCase: Symbol.for('ISignOutUseCase'),
ISignUpUseCase: Symbol.for('ISignUpUseCase'),
IVerifyOtpUseCase: Symbol.for('IVerifyOtpUseCase'),
// Controllers
@ -45,6 +48,7 @@ export interface DI_RETURN_TYPES {
// Use Cases
ISignInUseCase: ISignInUseCase;
ISignOutUseCase: ISignOutUseCase;
ISignUpUseCase: ISignUpUseCase;
IVerifyOtpUseCase: IVerifyOtpUseCase;
// Controllers
@ -52,4 +56,3 @@ export interface DI_RETURN_TYPES {
ISignOutController: ISignOutController;
IVerifyOtpController: IVerifyOtpController;
}

View File

@ -0,0 +1,13 @@
import * as Sentry from '@sentry/nextjs';
export async function register() {
if (process.env.NEXT_RUNTIME === 'nodejs') {
await import('./sentry.server.config');
}
if (process.env.NEXT_RUNTIME === 'edge') {
await import('./sentry.edge.config');
}
}
export const onRequestError = Sentry.captureRequestError;

View File

@ -1,3 +1,4 @@
import { withSentryConfig } from "@sentry/nextjs";
import type { NextConfig } from "next";
const nextConfig: NextConfig = {
@ -23,4 +24,39 @@ const nextConfig: NextConfig = {
},
};
export default nextConfig;
export default withSentryConfig(nextConfig, {
// For all available options, see:
// https://www.npmjs.com/package/@sentry/webpack-plugin#options
org: "politeknik-negeri-jember-hl",
project: "javascript-nextjs",
// Only print logs for uploading source maps in CI
silent: !process.env.CI,
// For all available options, see:
// https://docs.sentry.io/platforms/javascript/guides/nextjs/manual-setup/
// Upload a larger set of source maps for prettier stack traces (increases build time)
widenClientFileUpload: true,
// Automatically annotate React components to show their full name in breadcrumbs and session replay
reactComponentAnnotation: {
enabled: true,
},
// Uncomment to route browser requests to Sentry through a Next.js rewrite to circumvent ad-blockers.
// This can increase your server load as well as your hosting bill.
// Note: Check that the configured route will not match with your Next.js middleware, otherwise reporting of client-
// side errors will fail.
// tunnelRoute: "/monitoring",
// Automatically tree-shake Sentry logger statements to reduce bundle size
disableLogger: true,
// Enables automatic instrumentation of Vercel Cron Monitors. (Does not yet work with App Router route handlers.)
// See the following for more information:
// https://docs.sentry.io/product/crons/
// https://vercel.com/docs/cron-jobs
automaticVercelMonitors: true,
});

File diff suppressed because it is too large Load Diff

View File

@ -28,6 +28,7 @@
"@radix-ui/react-switch": "^1.1.3",
"@radix-ui/react-tabs": "^1.1.3",
"@radix-ui/react-tooltip": "^1.1.8",
"@sentry/nextjs": "^9.5.0",
"@supabase/ssr": "^0.4.1",
"@supabase/supabase-js": "latest",
"@tabler/icons-react": "^3.30.0",

View File

@ -17,7 +17,3 @@ const db = globalThis.prismaGlobal ?? prismaClientSingleton();
export default db;
if (process.env.NODE_ENV !== "production") globalThis.prismaGlobal = db;
export type Transaction = PrismaClient['$transaction'];

View File

@ -0,0 +1,28 @@
// This file configures the initialization of Sentry on the client.
// The config you add here will be used whenever a users loads a page in their browser.
// https://docs.sentry.io/platforms/javascript/guides/nextjs/
import * as Sentry from "@sentry/nextjs";
Sentry.init({
dsn: "https://4dbfb732406eb3962a78693034cd9412@o4508982533160960.ingest.us.sentry.io/4508982736977920",
// Add optional integrations for additional features
integrations: [
Sentry.replayIntegration(),
],
// Define how likely traces are sampled. Adjust this value in production, or use tracesSampler for greater control.
tracesSampleRate: 1,
// Define how likely Replay events are sampled.
// This sets the sample rate to be 10%. You may want this to be 100% while
// in development and sample at a lower rate in production
replaysSessionSampleRate: 0.1,
// Define how likely Replay events are sampled when an error occurs.
replaysOnErrorSampleRate: 1.0,
// Setting this option to true will print useful information to the console while you're setting up Sentry.
debug: false,
});

View File

@ -0,0 +1,16 @@
// This file configures the initialization of Sentry for edge features (middleware, edge routes, and so on).
// The config you add here will be used whenever one of the edge features is loaded.
// Note that this config is unrelated to the Vercel Edge Runtime and is also required when running locally.
// https://docs.sentry.io/platforms/javascript/guides/nextjs/
import * as Sentry from "@sentry/nextjs";
Sentry.init({
dsn: "https://4dbfb732406eb3962a78693034cd9412@o4508982533160960.ingest.us.sentry.io/4508982736977920",
// Define how likely traces are sampled. Adjust this value in production, or use tracesSampler for greater control.
tracesSampleRate: 1,
// Setting this option to true will print useful information to the console while you're setting up Sentry.
debug: false,
});

View File

@ -0,0 +1,15 @@
// This file configures the initialization of Sentry on the server.
// The config you add here will be used whenever the server handles a request.
// https://docs.sentry.io/platforms/javascript/guides/nextjs/
import * as Sentry from "@sentry/nextjs";
Sentry.init({
dsn: "https://4dbfb732406eb3962a78693034cd9412@o4508982533160960.ingest.us.sentry.io/4508982736977920",
// Define how likely traces are sampled. Adjust this value in production, or use tracesSampler for greater control.
tracesSampleRate: 1,
// Setting this option to true will print useful information to the console while you're setting up Sentry.
debug: false,
});

View File

@ -1,5 +1,5 @@
import { AuthenticationError } from "@/src/entities/errors/auth"
import { IUsersRepository } from "../../repositories/users.repository"
import { IUsersRepository } from "../../repositories/users.repository.interface"
import { IAuthenticationService } from "../../services/authentication.service.interface"
import { IInstrumentationService } from "../../services/instrumentation.service.interface"
import { NotFoundError } from "@/src/entities/errors/common"

View File

@ -1,5 +1,5 @@
import { AuthenticationError } from "@/src/entities/errors/auth"
import { IUsersRepository } from "../../repositories/users.repository"
import { IUsersRepository } from "../../repositories/users.repository.interface"
import { IAuthenticationService } from "../../services/authentication.service.interface"
import { IInstrumentationService } from "../../services/instrumentation.service.interface"
import { NotFoundError } from "@/src/entities/errors/common"

View File

@ -5,8 +5,10 @@ import { type SignInFormData, SignInPasswordless, SignInSchema } from "@/src/ent
import { IAuthenticationService } from "@/src/application/services/authentication.service.interface";
import { User } from "@/src/entities/models/users/users.model";
import { Session } from "@/src/entities/models/auth/session.model";
import { IUsersRepository } from "../../repositories/users.repository";
import { IUsersRepository } from "../../repositories/users.repository.interface";
import { AuthResult } from "@/src/entities/models/auth/auth-result.model";
import { UsersRepository } from "@/src/infrastructure/repositories/users.repository.impl";
import { ICrashReporterService } from "../../services/crash-reporter.service.interface";
export type ISignInUseCase = ReturnType<typeof signInUseCase>
@ -14,12 +16,22 @@ export const signInUseCase =
(
instrumentationService: IInstrumentationService,
authenticationService: IAuthenticationService,
crashReporterService: ICrashReporterService,
usersRepository: IUsersRepository
) =>
async (input: SignInPasswordless): Promise<void> => {
return instrumentationService.startSpan({ name: "signIn Use Case", op: "function" },
async () => {
console.log("Injected usersRepository:", usersRepository);
// Create a direct instance as a test
const directRepo = new UsersRepository(
instrumentationService,
crashReporterService
);
console.log("Direct repo methods:", Object.keys(directRepo));
const existingUser = await usersRepository.getUserByEmail(input.email)
if (!existingUser) {

View File

@ -1,5 +1,5 @@
import { CreateUser, User } from "@/src/entities/models/users/users.model"
import { IUsersRepository } from "../../repositories/users.repository"
import { IUsersRepository } from "../../repositories/users.repository.interface"
import { IAuthenticationService } from "../../services/authentication.service.interface"
import { IInstrumentationService } from "../../services/instrumentation.service.interface"
import { AuthenticationError } from "@/src/entities/errors/auth"

View File

@ -1,5 +1,5 @@
import { VerifyOtpFormData } from "@/src/entities/models/auth/verify-otp.model"
import { IUsersRepository } from "../../repositories/users.repository"
import { IUsersRepository } from "../../repositories/users.repository.interface"
import { IAuthenticationService } from "../../services/authentication.service.interface"
import { IInstrumentationService } from "../../services/instrumentation.service.interface"
import { AuthenticationError } from "@/src/entities/errors/auth"

View File

@ -1,5 +1,5 @@
import { User } from "@/src/entities/models/users/users.model"
import { IUsersRepository } from "../../repositories/users.repository"
import { IUsersRepository } from "../../repositories/users.repository.interface"
import { IInstrumentationService } from "../../services/instrumentation.service.interface"
import { NotFoundError } from "@/src/entities/errors/common"

View File

@ -1,5 +1,5 @@
import { AuthenticationError } from "@/src/entities/errors/auth"
import { IUsersRepository } from "../../repositories/users.repository"
import { IUsersRepository } from "../../repositories/users.repository.interface"
import { IAuthenticationService } from "../../services/authentication.service.interface"
import { IInstrumentationService } from "../../services/instrumentation.service.interface"
import { CreateUser, User } from "@/src/entities/models/users/users.model"

View File

@ -1,4 +1,4 @@
import { IUsersRepository } from "../../repositories/users.repository"
import { IUsersRepository } from "../../repositories/users.repository.interface"
import { IInstrumentationService } from "../../services/instrumentation.service.interface"
export type IDeleteUserUseCase = ReturnType<typeof deleteUserUseCase>

View File

@ -1,5 +1,5 @@
import { NotFoundError } from "@/src/entities/errors/common"
import { IUsersRepository } from "../../repositories/users.repository"
import { IUsersRepository } from "../../repositories/users.repository.interface"
import { IInstrumentationService } from "../../services/instrumentation.service.interface"
import { UserResponse } from "@/src/entities/models/users/users.model"

View File

@ -1,5 +1,5 @@
import { User } from "@/src/entities/models/users/users.model"
import { IUsersRepository } from "../../repositories/users.repository"
import { IUsersRepository } from "../../repositories/users.repository.interface"
import { IInstrumentationService } from "../../services/instrumentation.service.interface"
export type IGetListUsersUseCase = ReturnType<typeof getListUsersUseCase>

View File

@ -1,5 +1,5 @@
import { User } from "@/src/entities/models/users/users.model"
import { IUsersRepository } from "../../repositories/users.repository"
import { IUsersRepository } from "../../repositories/users.repository.interface"
import { IInstrumentationService } from "../../services/instrumentation.service.interface"
import { NotFoundError } from "@/src/entities/errors/common"

View File

@ -1,5 +1,5 @@
import { User } from "@/src/entities/models/users/users.model"
import { IUsersRepository } from "../../repositories/users.repository"
import { IUsersRepository } from "../../repositories/users.repository.interface"
import { IInstrumentationService } from "../../services/instrumentation.service.interface"
import { AuthenticationError } from "@/src/entities/errors/auth"
import { NotFoundError } from "@/src/entities/errors/common"

View File

@ -1,6 +1,6 @@
import { NotFoundError } from "@/src/entities/errors/common"
import { IInstrumentationService } from "../../services/instrumentation.service.interface"
import { IUsersRepository } from "../../repositories/users.repository"
import { IUsersRepository } from "../../repositories/users.repository.interface"
import { User } from "@/src/entities/models/users/users.model"
export type IGetUserByUsernameUseCase = ReturnType<typeof getUserByUsernameUseCase>

View File

@ -1,5 +1,5 @@
import { AuthenticationError } from "@/src/entities/errors/auth"
import { IUsersRepository } from "../../repositories/users.repository"
import { IUsersRepository } from "../../repositories/users.repository.interface"
import { IAuthenticationService } from "../../services/authentication.service.interface"
import { IInstrumentationService } from "../../services/instrumentation.service.interface"
import { User } from "@/src/entities/models/users/users.model"

View File

@ -1,5 +1,5 @@
import { UpdateUser, User, UserResponse } from "@/src/entities/models/users/users.model"
import { IUsersRepository } from "../../repositories/users.repository"
import { IUsersRepository } from "../../repositories/users.repository.interface"
import { IInstrumentationService } from "../../services/instrumentation.service.interface"
import { NotFoundError } from "@/src/entities/errors/common"

View File

@ -1,3 +1,4 @@
export interface ITransaction {
rollback: () => void;
prisma: any;
}

View File

@ -1,4 +1,4 @@
import { IUsersRepository } from "@/src/application/repositories/users.repository";
import { IUsersRepository } from "@/src/application/repositories/users.repository.interface";
import { ICrashReporterService } from "@/src/application/services/crash-reporter.service.interface";
import { IInstrumentationService } from "@/src/application/services/instrumentation.service.interface";
import { createAdminClient } from "@/app/_utils/supabase/admin";

View File

@ -1,7 +1,7 @@
import { createAdminClient } from "@/app/_utils/supabase/admin";
import { createClient } from "@/app/_utils/supabase/server";
import db from "@/prisma/db";
import { IUsersRepository } from "@/src/application/repositories/users.repository";
import { IUsersRepository } from "@/src/application/repositories/users.repository.interface";
import { IAuthenticationService } from "@/src/application/services/authentication.service.interface";
import { ICrashReporterService } from "@/src/application/services/crash-reporter.service.interface";
import { IInstrumentationService } from "@/src/application/services/instrumentation.service.interface";

View File

@ -0,0 +1,7 @@
import { ICrashReporterService } from '@/src/application/services/crash-reporter.service.interface';
export class MockCrashReporterService implements ICrashReporterService {
report(_: any): string {
return 'errorId';
}
}

View File

@ -0,0 +1,9 @@
import * as Sentry from '@sentry/nextjs';
import { ICrashReporterService } from '@/src/application/services/crash-reporter.service.interface';
export class CrashReporterService implements ICrashReporterService {
report(error: any): string {
return Sentry.captureException(error);
}
}

View File

@ -0,0 +1,18 @@
import { IInstrumentationService } from '@/src/application/services/instrumentation.service.interface';
export class MockInstrumentationService implements IInstrumentationService {
startSpan<T>(
_: { name: string; op?: string; attributes?: Record<string, any> },
callback: () => T
): T {
return callback();
}
async instrumentServerAction<T>(
_: string,
__: Record<string, any>,
callback: () => T
): Promise<T> {
return callback();
}
}

View File

@ -0,0 +1,20 @@
import * as Sentry from '@sentry/nextjs';
import { IInstrumentationService } from '@/src/application/services/instrumentation.service.interface';
export class InstrumentationService implements IInstrumentationService {
startSpan<T>(
options: { name: string; op?: string; attributes?: Record<string, any> },
callback: () => T
): T {
return Sentry.startSpan(options, callback);
}
instrumentServerAction<T>(
name: string,
options: Record<string, any>,
callback: () => T
): Promise<T> {
return Sentry.withServerActionInstrumentation(name, options, callback);
}
}

View File

@ -0,0 +1,25 @@
import { ITransactionManagerService } from '@/src/application/services/transaction-manager.service.interface';
import { ITransaction } from '@/src/entities/models/transaction.interface';
export class MockTransactionManagerService implements ITransactionManagerService {
public startTransaction<T>(
clb: (tx: ITransaction) => Promise<T>,
parent?: ITransaction
): Promise<T> {
// Create a mock transaction with a prisma property
const mockTransaction: ITransaction = {
rollback: () => { console.log('Mock transaction rolled back'); },
prisma: {
$connect: () => { console.log('Mock transaction connected'); },
$disconnect: () => { console.log('Mock transaction disconnected'); },
$transaction: async (callback: () => any) => {
return await callback();
}
}
};
// Use the parent transaction if provided
const txToUse = parent || mockTransaction;
return clb(txToUse);
}
}

View File

@ -0,0 +1,33 @@
import { PrismaClient, Prisma } from '@prisma/client';
import { ITransactionManagerService } from '@/src/application/services/transaction-manager.service.interface';
import { ITransaction } from '@/src/entities/models/transaction.interface';
import db from '@/prisma/db';
export class TransactionManagerService implements ITransactionManagerService {
public async startTransaction<T>(
clb: (tx: ITransaction) => Promise<T>,
parent?: ITransaction
): Promise<T> {
// If a parent transaction is provided, use it
if (parent) {
return clb(parent);
}
// Otherwise start a new transaction
return await db.$transaction(async (prismaTransaction) => {
// Create a transaction wrapper that implements ITransaction
const txWrapper: ITransaction = {
rollback: () => {
throw new Prisma.PrismaClientKnownRequestError(
'Transaction has been rolled back.',
{ clientVersion: Prisma.prismaVersion.client, code: 'P2034' }
);
},
prisma: prismaTransaction
};
return await clb(txWrapper);
});
}
}

View File

@ -1,78 +0,0 @@
import { z } from "zod"
import type { IInstrumentationService } from "@/src/application/services/instrumentation.service.interface"
import { InputParseError } from "@/src/entities/errors/common"
import { ISignInUseCase } from "@/src/application/use-cases/auth/sign-in.use-case"
import { IAuthenticationService } from "@/src/application/services/authentication.service.interface"
import { ISignUpUseCase } from "@/src/application/use-cases/auth/sign-up.use-case"
import { IVerifyOtpUseCase } from "@/src/application/use-cases/auth/verify-otp.use-case"
// Sign In Controller
const signInInputSchema = z.object({
email: z.string().email("Please enter a valid email address"),
})
export type ISignInController = ReturnType<typeof signInController>
export const signInController =
(
instrumentationService: IInstrumentationService,
signInUseCase: ISignInUseCase
) =>
async (input: Partial<z.infer<typeof signInInputSchema>>) => {
return await instrumentationService.startSpan({ name: "signIn Controller" }, async () => {
const { data, error: inputParseError } = signInInputSchema.safeParse(input)
if (inputParseError) {
throw new InputParseError("Invalid data", { cause: inputParseError })
}
return await signInUseCase({
email: data.email
})
})
}
// Verify OTP Controller
const verifyOtpInputSchema = z.object({
email: z.string().email("Please enter a valid email address"),
token: z.string().min(6, "Please enter a valid OTP")
})
export type IVerifyOtpController = ReturnType<typeof verifyOtpController>
export const verifyOtpController =
(
instrumentationService: IInstrumentationService,
verifyOtpUseCase: IVerifyOtpUseCase
) =>
async (input: Partial<z.infer<typeof verifyOtpInputSchema>>) => {
return await instrumentationService.startSpan({ name: "verifyOtp Controller" }, async () => {
const { data, error: inputParseError } = verifyOtpInputSchema.safeParse(input)
if (inputParseError) {
throw new InputParseError("Invalid data", { cause: inputParseError })
}
return await verifyOtpUseCase({
email: data.email,
token: data.token
})
})
}
// Sign Out Controller
export type ISignOutController = ReturnType<typeof signOutController>
export const signOutController =
(
instrumentationService: IInstrumentationService,
authenticationService: IAuthenticationService
) =>
async () => {
return await instrumentationService.startSpan({
name: "signOut Controller"
}, async () => {
return await authenticationService.signOut()
})
}

View File

@ -1,4 +1,4 @@
"use client";
// "use client";
import { useRouter } from "next/navigation";
import {
@ -14,6 +14,9 @@ import { useAuthMutation } from "./auth-controller";
import { zodResolver } from "@hookform/resolvers/zod";
import { useForm } from "react-hook-form";
import { AuthenticationError } from "@/src/entities/errors/auth";
import { ISignInUseCase } from "@/src/application/use-cases/auth/sign-in.use-case";
import { IInstrumentationService } from "@/src/application/services/instrumentation.service.interface";
import { InputParseError } from "@/src/entities/errors/common";
type SignInFormErrors = Partial<Record<keyof SignInFormData, string>>;
@ -163,32 +166,58 @@ type SignInFormErrors = Partial<Record<keyof SignInFormData, string>>;
// };
// }
export function useSignInController() {
const { signIn } = useAuthMutation();
// export function useSignInController() {
// const { signIn } = useAuthMutation();
// Gunakan react-hook-form untuk mengelola form state & error handling
const {
register,
handleSubmit,
formState: { errors },
} = useForm<SignInFormData>({
resolver: zodResolver(SignInSchema),
defaultValues: defaultSignInPasswordlessValues,
});
// // Gunakan react-hook-form untuk mengelola form state & error handling
// const {
// register,
// handleSubmit,
// formState: { errors },
// } = useForm<SignInFormData>({
// resolver: zodResolver(SignInSchema),
// defaultValues: defaultSignInPasswordlessValues,
// });
// Handler untuk submit form
const onSubmit = handleSubmit(async (data) => {
try {
signIn.mutate(data);
} catch (error) {
console.error("Sign-in submission error:", error);
// // Handler untuk submit form
// const onSubmit = handleSubmit(async (data) => {
// try {
// signIn.mutate(data);
// } catch (error) {
// console.error("Sign-in submission error:", error);
// }
// });
// return {
// register,
// handleSubmit: onSubmit,
// errors,
// isPending: signIn.isPending,
// };
// }
// Sign In Controller
const signInInputSchema = z.object({
email: z.string().email("Please enter a valid email address"),
})
export type ISignInController = ReturnType<typeof signInController>
export const signInController =
(
instrumentationService: IInstrumentationService,
signInUseCase: ISignInUseCase
) =>
async (input: Partial<z.infer<typeof signInInputSchema>>) => {
return await instrumentationService.startSpan({ name: "signIn Controller" }, async () => {
const { data, error: inputParseError } = signInInputSchema.safeParse(input)
if (inputParseError) {
throw new InputParseError("Invalid data", { cause: inputParseError })
}
});
return {
register,
handleSubmit: onSubmit,
errors,
isPending: signIn.isPending,
};
return await signInUseCase({
email: data.email
})
})
}

View File

@ -0,0 +1,18 @@
import { IAuthenticationService } from "@/src/application/services/authentication.service.interface"
import { IInstrumentationService } from "@/src/application/services/instrumentation.service.interface"
// Sign Out Controller
export type ISignOutController = ReturnType<typeof signOutController>
export const signOutController =
(
instrumentationService: IInstrumentationService,
authenticationService: IAuthenticationService
) =>
async () => {
return await instrumentationService.startSpan({
name: "signOut Controller"
}, async () => {
return await authenticationService.signOut()
})
}

View File

@ -14,6 +14,10 @@ import {
import { useNavigations } from "@/app/_hooks/use-navigations";
import { toast } from "sonner";
import { useAuthMutation } from "./auth-controller";
import { IInstrumentationService } from "@/src/application/services/instrumentation.service.interface";
import { IVerifyOtpUseCase } from "@/src/application/use-cases/auth/verify-otp.use-case";
import { z } from "zod";
import { InputParseError } from "@/src/entities/errors/common";
// export function useVerifyOtpForm(email: string) {
// const [isSubmitting, setIsSubmitting] = useState(false);
@ -114,3 +118,30 @@ export const useVerifyOtpController = (email: string) => {
}
}
// Verify OTP Controller
const verifyOtpInputSchema = z.object({
email: z.string().email("Please enter a valid email address"),
token: z.string().min(6, "Please enter a valid OTP")
})
export type IVerifyOtpController = ReturnType<typeof verifyOtpController>
export const verifyOtpController =
(
instrumentationService: IInstrumentationService,
verifyOtpUseCase: IVerifyOtpUseCase
) =>
async (input: Partial<z.infer<typeof verifyOtpInputSchema>>) => {
return await instrumentationService.startSpan({ name: "verifyOtp Controller" }, async () => {
const { data, error: inputParseError } = verifyOtpInputSchema.safeParse(input)
if (inputParseError) {
throw new InputParseError("Invalid data", { cause: inputParseError })
}
return await verifyOtpUseCase({
email: data.email,
token: data.token
})
})
}