feat(backend): add updating organizations endpoint

apps/backend/src/modules/api/controllers/organizations.controller.ts

@@ -5,12 +5,14 @@ import {
   type OrganizationsSdk,
   SdkCreateOrganizationInputV,
   SdKSearchOrganizationsInputV,
+  SdkUpdateOrganizationInputV,
 } from '@llm/sdk';
 import { ConfigService } from '~/modules/config';
 import { OrganizationsService } from '~/modules/organizations';
 
 import {
-  rejectUnsafeCreateSdkErrors,
+  mapDbRecordAlreadyExistsToSdkError,
+  mapDbRecordNotFoundToSdkError,
   rejectUnsafeSdkErrors,
   sdkSchemaValidator,
   serializeSdkResponseTE,
@@ -37,15 +39,30 @@ export class OrganizationsController extends AuthorizedController {
         ),
       )
       .post(
-        '/create',
+        '/',
         sdkSchemaValidator('json', SdkCreateOrganizationInputV),
         async context => pipe(
           context.req.valid('json'),
           organizationsService.asUser(context.var.jwt).create,
-          rejectUnsafeCreateSdkErrors,
+          mapDbRecordAlreadyExistsToSdkError,
           rejectUnsafeSdkErrors,
           serializeSdkResponseTE<ReturnType<OrganizationsSdk['create']>>(context),
         ),
+      )
+      .put(
+        '/:id',
+        sdkSchemaValidator('json', SdkUpdateOrganizationInputV),
+        async context => pipe(
+          {
+            id: Number(context.req.param().id),
+            ...context.req.valid('json'),
+          },
+          organizationsService.asUser(context.var.jwt).update,
+          mapDbRecordAlreadyExistsToSdkError,
+          mapDbRecordNotFoundToSdkError,
+          rejectUnsafeSdkErrors,
+          serializeSdkResponseTE<ReturnType<OrganizationsSdk['update']>>(context),
+        ),
       );
   }
 }

apps/backend/src/modules/api/helpers/index.ts

@@ -1,4 +1,4 @@
-export * from './reject-unsafe-create-sdk-errors';
+export * from './map-tag-to-sdk-errors';
 export * from './reject-unsafe-sdk-errors';
 export * from './respond-with-tagged-error';
 export * from './sdk-hono-schema-validator';

apps/backend/src/modules/api/helpers/map-tag-to-sdk-errors.ts

@@ -0,0 +1,44 @@
+import { taskEither as TE } from 'fp-ts';
+import { pipe } from 'fp-ts/function';
+
+import type { TaggedError } from '@llm/commons';
+
+import { isSdkTaggedError, SdkRecordAlreadyExistsError, SdkRecordNotFoundError } from '@llm/sdk';
+import { DatabaseRecordAlreadyExists, DatabaseRecordNotExists } from '~/modules/database';
+import { LoggerService } from '~/modules/logger';
+
+export function mapTagToSdkError<const ET extends string, RET extends TaggedError<`Sdk${string}`>>(
+  catchTag: ET,
+  mapper: (err: TaggedError<string>) => RET,
+) {
+  const logger = LoggerService.of('mapTagToSdkError');
+
+  return <T, E extends TaggedError<string, any>>(task: TE.TaskEither<E, T>) => pipe(
+    task,
+    TE.mapLeft((error) => {
+      if (isSdkTaggedError(error) || error.tag !== catchTag) {
+        return error;
+      }
+
+      const { stack, ...context } = error;
+
+      logger.error(`Mapped creator SDK error - ${error.tag}!`, context);
+
+      if (stack) {
+        console.error(stack);
+      }
+
+      return mapper(error);
+    }),
+  ) as TE.TaskEither<Exclude<E, TaggedError<ET>> | RET, T>;
+}
+
+export const mapDbRecordAlreadyExistsToSdkError = mapTagToSdkError(
+  DatabaseRecordAlreadyExists.tag,
+  () => new SdkRecordAlreadyExistsError({}),
+);
+
+export const mapDbRecordNotFoundToSdkError = mapTagToSdkError(
+  DatabaseRecordNotExists.tag,
+  () => new SdkRecordNotFoundError({}),
+);

apps/backend/src/modules/database/errors/database-record-already-exists.error.ts

@@ -1,3 +1,5 @@
 import { TaggedError } from '@llm/commons';
 
-export class DatabaseRecordAlreadyExists extends TaggedError.ofLiteral()('DatabaseRecordAlreadyExists') {}
+export class DatabaseRecordAlreadyExists extends TaggedError.ofLiteral()('DatabaseRecordAlreadyExists') {
+  readonly httpCode = 403;
+}

apps/backend/src/modules/database/errors/database-record-not-exists.error.ts

@@ -1,3 +1,5 @@
 import { TaggedError } from '@llm/commons';
 
-export class DatabaseRecordNotExists extends TaggedError.ofLiteral()('DatabaseRecordNotExists') {}
+export class DatabaseRecordNotExists extends TaggedError.ofLiteral()('DatabaseRecordNotExists') {
+  readonly httpCode = 404;
+}

apps/backend/src/modules/organizations/organizations.firewall.ts

@@ -14,6 +14,11 @@ export class OrganizationsFirewall extends AuthFirewallService {
     super(jwt);
   }
 
+  update = flow(
+    this.organizationsService.update,
+    this.tryTEIfUser.is.root,
+  );
+
   create = flow(
     this.organizationsService.create,
     this.tryTEIfUser.is.root,

apps/backend/src/modules/organizations/organizations.service.ts

@@ -1,11 +1,16 @@
 import { pipe } from 'fp-ts/function';
 import { inject, injectable } from 'tsyringe';
 
-import type { SdkCreateOrganizationInputT, SdkJwtTokenT } from '@llm/sdk';
+import type {
+  SdkCreateOrganizationInputT,
+  SdkJwtTokenT,
+  SdkUpdateOrganizationInputT,
+} from '@llm/sdk';
 
 import { tapTaskEitherTE } from '@llm/commons';
 
 import type { WithAuthFirewall } from '../auth';
+import type { TableRowWithId } from '../database';
 
 import { OrganizationsEsIndexRepo } from './elasticsearch';
 import { OrganizationsEsSearchRepo } from './elasticsearch/organizations-es-search.repo';
@@ -27,5 +32,10 @@ export class OrganizationsService implements WithAuthFirewall<OrganizationsFirew
     tapTaskEitherTE(({ id }) => this.esIndexRepo.findAndIndexDocumentById(id)),
   );
 
+  update = ({ id, ...value }: SdkUpdateOrganizationInputT & TableRowWithId) => pipe(
+    this.repo.update({ id, value }),
+    tapTaskEitherTE(() => this.esIndexRepo.findAndIndexDocumentById(id)),
+  );
+
   asUser = (jwt: SdkJwtTokenT) => new OrganizationsFirewall(jwt, this);
 }

packages/commons/src/errors/tagged-error.ts

@@ -66,6 +66,8 @@ export abstract class TaggedError<
   static ofLiteral<C extends object>() {
     return <const S extends string>(tag: S) =>
       class TaggedLiteralError extends TaggedError<S, C> {
+        static readonly tag = tag;
+
         readonly tag = tag;
       };
   }

packages/sdk/src/modules/dashboard/organizations/dto/index.ts

@@ -3,3 +3,4 @@ export * from './sdk-create-organization-user.dto';
 export * from './sdk-organization.dto';
 export * from './sdk-organization-user.dto';
 export * from './sdk-search-organizations.dto';
+export * from './sdk-update-organization.dto';

packages/sdk/src/modules/dashboard/organizations/dto/sdk-update-organization.dto.ts

@@ -0,0 +1,17 @@
+import type { z } from 'zod';
+
+import { SdkTableRowWithIdV, ZodOmitArchivedFields, ZodOmitDateFields } from '~/shared';
+
+import { SdkOrganizationV } from './sdk-organization.dto';
+
+export const SdkUpdateOrganizationInputV = SdkOrganizationV.omit({
+  ...ZodOmitDateFields,
+  ...ZodOmitArchivedFields,
+  id: true,
+});
+
+export type SdkUpdateOrganizationInputT = z.infer<typeof SdkUpdateOrganizationInputV>;
+
+export const SdkUpdateOrganizationOutputV = SdkTableRowWithIdV;
+
+export type SdkUpdateOrganizationOutputT = z.infer<typeof SdkUpdateOrganizationOutputV>;

packages/sdk/src/modules/dashboard/organizations/organizations.sdk.ts

@@ -3,14 +3,19 @@ import {
   getPayload,
   performApiRequest,
   postPayload,
+  putPayload,
   type SdkRecordAlreadyExistsError,
+  type SdkRecordNotFoundError,
+  type SdkTableRowWithIdT,
 } from '~/shared';
 
 import type {
   SdkCreateOrganizationInputT,
   SdkCreateOrganizationOutputT,
   SdKSearchOrganizationsInputT,
   SdKSearchOrganizationsOutputT,
+  SdkUpdateOrganizationInputT,
+  SdkUpdateOrganizationOutputT,
 } from './dto';
 
 export class OrganizationsSdk extends AbstractNestedSdkWithAuth {
@@ -25,7 +30,16 @@ export class OrganizationsSdk extends AbstractNestedSdkWithAuth {
 
   create = (data: SdkCreateOrganizationInputT) =>
     performApiRequest<SdkCreateOrganizationOutputT, SdkRecordAlreadyExistsError>({
-      url: this.endpoint('/create'),
+      url: this.endpoint('/'),
       options: postPayload(data),
     });
+
+  update = ({ id, ...data }: SdkUpdateOrganizationInputT & SdkTableRowWithIdT) =>
+    performApiRequest<
+      SdkUpdateOrganizationOutputT,
+      SdkRecordAlreadyExistsError | SdkRecordNotFoundError
+    >({
+      url: this.endpoint(`/${id}`),
+      options: putPayload(data),
+    });
 };

packages/sdk/src/shared/errors/index.ts

@@ -1,6 +1,7 @@
 export * from './is-sdk-tagged-error';
 export * from './sdk-payload-validation.error';
 export * from './sdk-record-already-exists.error';
+export * from './sdk-record-not-found.error';
 export * from './sdk-request.error';
 export * from './sdk-server.error';
 export * from './sdk-unauthorized.error';

packages/sdk/src/shared/errors/sdk-record-already-exists.error.ts

@@ -1,3 +1,5 @@
 import { TaggedError } from '@llm/commons';
 
-export class SdkRecordAlreadyExistsError extends TaggedError.ofLiteral()('SdkRecordAlreadyExistsError') {}
+export class SdkRecordAlreadyExistsError extends TaggedError.ofLiteral()('SdkRecordAlreadyExistsError') {
+  static readonly httpCode = 403;
+}

packages/sdk/src/shared/errors/sdk-record-not-found.error.ts

@@ -0,0 +1,5 @@
+import { TaggedError } from '@llm/commons';
+
+export class SdkRecordNotFoundError extends TaggedError.ofLiteral()('SdkRecordNotFoundError') {
+  readonly httpCode = 404;
+}