Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

6658 workflows add a first twenty piece email sender #6965

Merged
merged 24 commits into from
Sep 12, 2024
Merged

6658 workflows add a first twenty piece email sender #6965

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
24 commits
Select commit Hold shift + click to select a range
6339a4e
Add system action executor
martmull Sep 9, 2024
e484c60
Add send email step
martmull Sep 9, 2024
4528242
Remove logo from workflow email
martmull Sep 10, 2024
cb33021
Sanitize html
martmull Sep 10, 2024
2e44781
Fix typing
martmull Sep 10, 2024
4978270
Remove front check
martmull Sep 10, 2024
52ac80d
Fix missing data in deleted event
martmull Sep 10, 2024
d030c01
Validate email
martmull Sep 10, 2024
5b50565
Use templating
martmull Sep 10, 2024
77e78a8
Remove useless factory
martmull Sep 11, 2024
2f4a6de
Remove useless changes
martmull Sep 11, 2024
fa03414
Code review return: fix factory naming
martmull Sep 11, 2024
8fca876
Code review return: separate types
martmull Sep 11, 2024
4bcb226
Code review return: update naming
martmull Sep 11, 2024
f99d805
Code review return: reorganize folders
martmull Sep 11, 2024
98fdcfb
Code review return: split workflow/common
martmull Sep 11, 2024
3e74a5d
Simplify folder tree
martmull Sep 11, 2024
5726382
Reorganize workflow-runner
martmull Sep 11, 2024
611b4ca
Reorganize workflow-status
martmull Sep 11, 2024
c8b0b4a
Rename services folders
martmull Sep 11, 2024
b3bde02
Simplify workflow/common
martmull Sep 11, 2024
6ecd69d
Merge integration and core_modules
martmull Sep 11, 2024
d0d9376
Fix lint
martmull Sep 11, 2024
7afe454
WIP: move workflow actions to dedicated modules
martmull Sep 11, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Rename services folders
  • Loading branch information
@martmull
martmull committed Sep 11, 2024
commit c8b0b4a5bb457b7194648a8634e506bc443dc103
2 changes: 1 addition & 1 deletion ...src/engine/core-modules/workflow/filters/workflow-trigger-graphql-api-exception.filter.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ import {
import {
WorkflowTriggerException,
WorkflowTriggerExceptionCode,
} from 'src/modules/workflow/workflow-trigger/workflow-trigger.exception';
} from 'src/modules/workflow/workflow-trigger/exceptions/workflow-trigger.exception';

@Catch(WorkflowTriggerException)
export class WorkflowTriggerGraphqlApiExceptionFilter
Expand Down
2 changes: 1 addition & 1 deletion packages/twenty-server/src/engine/core-modules/workflow/workflow-trigger.resolver.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ import { WorkflowTriggerGraphqlApiExceptionFilter } from 'src/engine/core-module
import { AuthUser } from 'src/engine/decorators/auth/auth-user.decorator';
import { AuthWorkspaceMemberId } from 'src/engine/decorators/auth/auth-workspace-member-id.decorator';
import { JwtAuthGuard } from 'src/engine/guards/jwt.auth.guard';
import { WorkflowTriggerWorkspaceService } from 'src/modules/workflow/workflow-trigger/workflow-trigger.workspace-service';
import { WorkflowTriggerWorkspaceService } from 'src/modules/workflow/workflow-trigger/workspace-services/workflow-trigger.workspace-service';

@Resolver()
@UseGuards(JwtAuthGuard)
Expand Down
2 changes: 1 addition & 1 deletion packages/twenty-server/src/modules/workflow/common/query-hooks/workflow-query-hook.module.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ import { WorkflowCreateManyPreQueryHook } from 'src/modules/workflow/common/quer
import { WorkflowCreateOnePreQueryHook } from 'src/modules/workflow/common/query-hooks/workflow/workflow-create-one.pre-query.hook';
import { WorkflowUpdateManyPreQueryHook } from 'src/modules/workflow/common/query-hooks/workflow/workflow-update-many.pre-query.hook';
import { WorkflowUpdateOnePreQueryHook } from 'src/modules/workflow/common/query-hooks/workflow/workflow-update-one.pre-query.hook';
import { WorkflowCommonWorkspaceService } from 'src/modules/workflow/common/services/workflow-common.workspace-service';
import { WorkflowCommonWorkspaceService } from 'src/modules/workflow/common/workspace-services/workflow-common.workspace-service';

@Module({
providers: [
Expand Down
2 changes: 1 addition & 1 deletion ...on/query-hooks/workflow-version/services/workflow-version-validation.workspace-service.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ import {
WorkflowQueryValidationExceptionCode,
} from 'src/modules/workflow/common/query-hooks/workflow-query-validation.exception';
import { assertWorkflowVersionIsDraft } from 'src/modules/workflow/common/query-hooks/workflow-version/utils/assert-workflow-version-is-draft.util';
import { WorkflowCommonWorkspaceService } from 'src/modules/workflow/common/services/workflow-common.workspace-service';
import { WorkflowCommonWorkspaceService } from 'src/modules/workflow/common/workspace-services/workflow-common.workspace-service';
import {
WorkflowVersionStatus,
WorkflowVersionWorkspaceEntity,
Expand Down
2 changes: 1 addition & 1 deletion packages/twenty-server/src/modules/workflow/common/workflow-common.module.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
import { Module } from '@nestjs/common';

import { WorkflowQueryHookModule } from 'src/modules/workflow/common/query-hooks/workflow-query-hook.module';
import { WorkflowCommonWorkspaceService } from 'src/modules/workflow/common/services/workflow-common.workspace-service';
import { WorkflowCommonWorkspaceService } from 'src/modules/workflow/common/workspace-services/workflow-common.workspace-service';

@Module({
imports: [WorkflowQueryHookModule],
Expand Down
2 changes: 1 addition & 1 deletion ...ices/workflow-common.workspace-service.ts → ...ices/workflow-common.workspace-service.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { WorkflowTrigger } from 'src/modules/workflow/workflow-trigger/types/wor
import {
WorkflowTriggerException,
WorkflowTriggerExceptionCode,
} from 'src/modules/workflow/workflow-trigger/workflow-trigger.exception';
} from 'src/modules/workflow/workflow-trigger/exceptions/workflow-trigger.exception';

@Injectable()
export class WorkflowCommonWorkspaceService {
Expand Down
2 changes: 1 addition & 1 deletion packages/twenty-server/src/modules/workflow/workflow-executor/workflow-executor.module.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
import { Module } from '@nestjs/common';

import { WorkflowCommonModule } from 'src/modules/workflow/common/workflow-common.module';
import { WorkflowExecutorWorkspaceService } from 'src/modules/workflow/workflow-executor/services/workflow-executor.workspace-service';
import { WorkflowExecutorWorkspaceService } from 'src/modules/workflow/workflow-executor/workspace-services/workflow-executor.workspace-service';
import { WorkflowStepExecutorFactory } from 'src/modules/workflow/workflow-executor/factories/workflow-step-executor.factory';
import { CodeWorkflowStepExecutor } from 'src/modules/workflow/workflow-executor/factories/workflow-step-executors/code.workflow-step-executor';
import { SendEmailWorkflowStepExecutor } from 'src/modules/workflow/workflow-executor/factories/workflow-step-executors/send-email.workflow-step-executor';
Expand Down
0 ...es/workflow-executor.workspace-service.ts → ...es/workflow-executor.workspace-service.ts
View file
Open in desktop
File renamed without changes.
6 changes: 3 additions & 3 deletions packages/twenty-server/src/modules/workflow/workflow-runner/jobs/run-workflow.job.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,10 +3,10 @@ import { Scope } from '@nestjs/common';
import { Process } from 'src/engine/integrations/message-queue/decorators/process.decorator';
import { Processor } from 'src/engine/integrations/message-queue/decorators/processor.decorator';
import { MessageQueue } from 'src/engine/integrations/message-queue/message-queue.constants';
import { WorkflowCommonWorkspaceService } from 'src/modules/workflow/common/services/workflow-common.workspace-service';
import { WorkflowCommonWorkspaceService } from 'src/modules/workflow/common/workspace-services/workflow-common.workspace-service';
import { WorkflowRunStatus } from 'src/modules/workflow/common/standard-objects/workflow-run.workspace-entity';
import { WorkflowExecutorWorkspaceService } from 'src/modules/workflow/workflow-executor/services/workflow-executor.workspace-service';
import { WorkflowRunWorkspaceService } from 'src/modules/workflow/workflow-runner/services/workflow-run.workspace-service';
import { WorkflowExecutorWorkspaceService } from 'src/modules/workflow/workflow-executor/workspace-services/workflow-executor.workspace-service';
import { WorkflowRunWorkspaceService } from 'src/modules/workflow/workflow-runner/workspace-services/workflow-run.workspace-service';

export type RunWorkflowJobData = {
workspaceId: string;
Expand Down
4 changes: 2 additions & 2 deletions packages/twenty-server/src/modules/workflow/workflow-runner/workflow-runner.module.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,8 @@ import { Module } from '@nestjs/common';
import { WorkflowCommonModule } from 'src/modules/workflow/common/workflow-common.module';
import { WorkflowExecutorModule } from 'src/modules/workflow/workflow-executor/workflow-executor.module';
import { RunWorkflowJob } from 'src/modules/workflow/workflow-runner/jobs/run-workflow.job';
import { WorkflowRunnerWorkspaceService } from 'src/modules/workflow/workflow-runner/services/workflow-runner.workspace-service';
import { WorkflowRunWorkspaceService } from 'src/modules/workflow/workflow-runner/services/workflow-run.workspace-service';
import { WorkflowRunnerWorkspaceService } from 'src/modules/workflow/workflow-runner/workspace-services/workflow-runner.workspace-service';
import { WorkflowRunWorkspaceService } from 'src/modules/workflow/workflow-runner/workspace-services/workflow-run.workspace-service';

@Module({
imports: [WorkflowCommonModule, WorkflowExecutorModule],
Expand Down
2 changes: 1 addition & 1 deletion ...ervices/workflow-run.workspace-service.ts → ...ervices/workflow-run.workspace-service.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ import { Injectable } from '@nestjs/common';

import { ActorMetadata } from 'src/engine/metadata-modules/field-metadata/composite-types/actor.composite-type';
import { TwentyORMManager } from 'src/engine/twenty-orm/twenty-orm.manager';
import { WorkflowCommonWorkspaceService } from 'src/modules/workflow/common/services/workflow-common.workspace-service';
import { WorkflowCommonWorkspaceService } from 'src/modules/workflow/common/workspace-services/workflow-common.workspace-service';
import {
WorkflowRunStatus,
WorkflowRunWorkspaceEntity,
Expand Down
2 changes: 1 addition & 1 deletion ...ices/workflow-runner.workspace-service.ts → ...ices/workflow-runner.workspace-service.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ import {
RunWorkflowJob,
RunWorkflowJobData,
} from 'src/modules/workflow/workflow-runner/jobs/run-workflow.job';
import { WorkflowRunWorkspaceService } from 'src/modules/workflow/workflow-runner/services/workflow-run.workspace-service';
import { WorkflowRunWorkspaceService } from 'src/modules/workflow/workflow-runner/workspace-services/workflow-run.workspace-service';

@Injectable()
export class WorkflowRunnerWorkspaceService {
Expand Down
0 ...low-trigger/workflow-trigger.exception.ts → .../exceptions/workflow-trigger.exception.ts
View file
Open in desktop
File renamed without changes.
4 changes: 2 additions & 2 deletions ...es/twenty-server/src/modules/workflow/workflow-trigger/jobs/workflow-event-trigger.job.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -10,11 +10,11 @@ import {
WorkflowVersionWorkspaceEntity,
} from 'src/modules/workflow/common/standard-objects/workflow-version.workspace-entity';
import { WorkflowWorkspaceEntity } from 'src/modules/workflow/common/standard-objects/workflow.workspace-entity';
import { WorkflowRunnerWorkspaceService } from 'src/modules/workflow/workflow-runner/services/workflow-runner.workspace-service';
import { WorkflowRunnerWorkspaceService } from 'src/modules/workflow/workflow-runner/workspace-services/workflow-runner.workspace-service';
import {
WorkflowTriggerException,
WorkflowTriggerExceptionCode,
} from 'src/modules/workflow/workflow-trigger/workflow-trigger.exception';
} from 'src/modules/workflow/workflow-trigger/exceptions/workflow-trigger.exception';

export type WorkflowEventTriggerJobData = {
workspaceId: string;
Expand Down
2 changes: 1 addition & 1 deletion ...erver/src/modules/workflow/workflow-trigger/utils/assert-version-can-be-activated.util.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ import {
import {
WorkflowTriggerException,
WorkflowTriggerExceptionCode,
} from 'src/modules/workflow/workflow-trigger/workflow-trigger.exception';
} from 'src/modules/workflow/workflow-trigger/exceptions/workflow-trigger.exception';

export function assertVersionCanBeActivated(
workflowVersion: Omit<WorkflowVersionWorkspaceEntity, 'trigger'> & {
Expand Down
2 changes: 1 addition & 1 deletion packages/twenty-server/src/modules/workflow/workflow-trigger/workflow-trigger.module.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ import { WorkflowCommonModule } from 'src/modules/workflow/common/workflow-commo
import { WorkflowRunnerModule } from 'src/modules/workflow/workflow-runner/workflow-runner.module';
import { DatabaseEventTriggerModule } from 'src/modules/workflow/workflow-trigger/database-event-trigger/database-event-trigger.module';
import { WorkflowEventTriggerJob } from 'src/modules/workflow/workflow-trigger/jobs/workflow-event-trigger.job';
import { WorkflowTriggerWorkspaceService } from 'src/modules/workflow/workflow-trigger/workflow-trigger.workspace-service';
import { WorkflowTriggerWorkspaceService } from 'src/modules/workflow/workflow-trigger/workspace-services/workflow-trigger.workspace-service';

@Module({
imports: [
Expand Down
6 changes: 3 additions & 3 deletions ...ger/workflow-trigger.workspace-service.ts → ...ces/workflow-trigger.workspace-service.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ import { ScopedWorkspaceContextFactory } from 'src/engine/twenty-orm/factories/s
import { WorkspaceRepository } from 'src/engine/twenty-orm/repository/workspace.repository';
import { TwentyORMManager } from 'src/engine/twenty-orm/twenty-orm.manager';
import { WorkspaceEventEmitter } from 'src/engine/workspace-event-emitter/workspace-event-emitter';
import { WorkflowCommonWorkspaceService } from 'src/modules/workflow/common/services/workflow-common.workspace-service';
import { WorkflowCommonWorkspaceService } from 'src/modules/workflow/common/workspace-services/workflow-common.workspace-service';
import {
WorkflowVersionStatus,
WorkflowVersionWorkspaceEntity,
Expand All @@ -18,14 +18,14 @@ import {
WorkflowTrigger,
WorkflowTriggerType,
} from 'src/modules/workflow/workflow-trigger/types/workflow-trigger.type';
import { WorkflowRunnerWorkspaceService } from 'src/modules/workflow/workflow-runner/services/workflow-runner.workspace-service';
import { WorkflowRunnerWorkspaceService } from 'src/modules/workflow/workflow-runner/workspace-services/workflow-runner.workspace-service';
import { WorkflowVersionStatusUpdate } from 'src/modules/workflow/workflow-status/jobs/workflow-statuses-update.job';
import { DatabaseEventTriggerService } from 'src/modules/workflow/workflow-trigger/database-event-trigger/database-event-trigger.service';
import { assertVersionCanBeActivated } from 'src/modules/workflow/workflow-trigger/utils/assert-version-can-be-activated.util';
import {
WorkflowTriggerException,
WorkflowTriggerExceptionCode,
} from 'src/modules/workflow/workflow-trigger/workflow-trigger.exception';
} from 'src/modules/workflow/workflow-trigger/exceptions/workflow-trigger.exception';

@Injectable()
export class WorkflowTriggerWorkspaceService {
Expand Down