mirror of
https://github.com/Abdulazizzn/n8n-enterprise-unlocked.git
synced 2025-12-19 19:11:13 +00:00
refactor(core): Move webhook repository to @n8n/db (#15318)
This commit is contained in:
@@ -31,3 +31,4 @@ export { WorkflowStatisticsRepository } from './workflow-statistics.repository';
|
|||||||
export { WorkflowTagMappingRepository } from './workflow-tag-mapping.repository';
|
export { WorkflowTagMappingRepository } from './workflow-tag-mapping.repository';
|
||||||
export { SharedWorkflowRepository } from './shared-workflow.repository';
|
export { SharedWorkflowRepository } from './shared-workflow.repository';
|
||||||
export { SharedCredentialsRepository } from './shared-credentials.repository';
|
export { SharedCredentialsRepository } from './shared-credentials.repository';
|
||||||
|
export { WebhookRepository } from './webhook.repository';
|
||||||
|
|||||||
@@ -1,7 +1,8 @@
|
|||||||
import { WebhookEntity } from '@n8n/db';
|
|
||||||
import { Service } from '@n8n/di';
|
import { Service } from '@n8n/di';
|
||||||
import { DataSource, Repository } from '@n8n/typeorm';
|
import { DataSource, Repository } from '@n8n/typeorm';
|
||||||
|
|
||||||
|
import { WebhookEntity } from '../entities';
|
||||||
|
|
||||||
@Service()
|
@Service()
|
||||||
export class WebhookRepository extends Repository<WebhookEntity> {
|
export class WebhookRepository extends Repository<WebhookEntity> {
|
||||||
constructor(dataSource: DataSource) {
|
constructor(dataSource: DataSource) {
|
||||||
@@ -1,11 +1,11 @@
|
|||||||
import { WebhookEntity } from '@n8n/db';
|
import { WebhookEntity } from '@n8n/db';
|
||||||
|
import type { WebhookRepository } from '@n8n/db';
|
||||||
import { mock } from 'jest-mock-extended';
|
import { mock } from 'jest-mock-extended';
|
||||||
import type { INode, INodeType, IWebhookData, IWorkflowExecuteAdditionalData } from 'n8n-workflow';
|
import type { INode, INodeType, IWebhookData, IWorkflowExecuteAdditionalData } from 'n8n-workflow';
|
||||||
import { Workflow } from 'n8n-workflow';
|
import { Workflow } from 'n8n-workflow';
|
||||||
import { v4 as uuid } from 'uuid';
|
import { v4 as uuid } from 'uuid';
|
||||||
|
|
||||||
import config from '@/config';
|
import config from '@/config';
|
||||||
import type { WebhookRepository } from '@/databases/repositories/webhook.repository';
|
|
||||||
import type { NodeTypes } from '@/node-types';
|
import type { NodeTypes } from '@/node-types';
|
||||||
import type { CacheService } from '@/services/cache/cache.service';
|
import type { CacheService } from '@/services/cache/cache.service';
|
||||||
import { WebhookService } from '@/webhooks/webhook.service';
|
import { WebhookService } from '@/webhooks/webhook.service';
|
||||||
|
|||||||
@@ -1,4 +1,5 @@
|
|||||||
import type { WebhookEntity } from '@n8n/db';
|
import type { WebhookEntity } from '@n8n/db';
|
||||||
|
import { WebhookRepository } from '@n8n/db';
|
||||||
import { Service } from '@n8n/di';
|
import { Service } from '@n8n/di';
|
||||||
import { HookContext, WebhookContext, Logger } from 'n8n-core';
|
import { HookContext, WebhookContext, Logger } from 'n8n-core';
|
||||||
import { Node, NodeHelpers, UnexpectedError } from 'n8n-workflow';
|
import { Node, NodeHelpers, UnexpectedError } from 'n8n-workflow';
|
||||||
@@ -15,7 +16,6 @@ import type {
|
|||||||
WorkflowExecuteMode,
|
WorkflowExecuteMode,
|
||||||
} from 'n8n-workflow';
|
} from 'n8n-workflow';
|
||||||
|
|
||||||
import { WebhookRepository } from '@/databases/repositories/webhook.repository';
|
|
||||||
import { NodeTypes } from '@/node-types';
|
import { NodeTypes } from '@/node-types';
|
||||||
import { CacheService } from '@/services/cache/cache.service';
|
import { CacheService } from '@/services/cache/cache.service';
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user