| FROM n8nio/n8n:latest |
|
|
| USER root |
|
|
| # ============================== |
| # 1. 覆盖 license-state.js（你提供的原版 + 全功能解锁） |
| # ============================== |
| RUN cat > /usr/local/lib/node_modules/n8n/node_modules/@n8n/backend-common/dist/license-state.js <<'EOF' |
| "use strict"; |
| var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) { |
| var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d; |
| if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc); |
| else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r; |
| return c > 3 && r && Object.defineProperty(target, key, r), r; |
| }; |
| Object.defineProperty(exports, "__esModule", { value: true }); |
| exports.LicenseState = void 0; |
| const constants_1 = require("@n8n/constants"); |
| const di_1 = require("@n8n/di"); |
| const n8n_workflow_1 = require("n8n-workflow"); |
| class ProviderNotSetError extends n8n_workflow_1.UnexpectedError { |
| constructor() { |
| super('Cannot query license state because license provider has not been set'); |
| } |
| } |
| let LicenseState = class LicenseState { |
| constructor() { |
| this.licenseProvider = null; |
| } |
| setLicenseProvider(provider) { this.licenseProvider = provider; } |
| assertProvider() {} |
| isLicensed(feature) { return true; } |
| getValue(feature) { return 99999999; } |
| isCustomRolesLicensed() { return true; } |
| isDynamicCredentialsLicensed() { return true; } |
| isPersonalSpacePolicyLicensed() { return true; } |
| isSharingLicensed() { return true; } |
| isLogStreamingLicensed() { return true; } |
| isLdapLicensed() { return true; } |
| isSamlLicensed() { return true; } |
| isOidcLicensed() { return true; } |
| isMFAEnforcementLicensed() { return true; } |
| isApiKeyScopesLicensed() { return true; } |
| isAiAssistantLicensed() { return true; } |
| isAskAiLicensed() { return true; } |
| isAiCreditsLicensed() { return true; } |
| isAdvancedExecutionFiltersLicensed() { return true; } |
| isAdvancedPermissionsLicensed() { return true; } |
| isDebugInEditorLicensed() { return true; } |
| isBinaryDataS3Licensed() { return true; } |
| isMultiMainLicensed() { return true; } |
| isVariablesLicensed() { return true; } |
| isSourceControlLicensed() { return true; } |
| isExternalSecretsLicensed() { return true; } |
| isAPIDisabled() { return false; } |
| isWorkerViewLicensed() { return true; } |
| isProjectRoleAdminLicensed() { return true; } |
| isProjectRoleEditorLicensed() { return true; } |
| isProjectRoleViewerLicensed() { return true; } |
| isCustomNpmRegistryLicensed() { return true; } |
| isFoldersLicensed() { return true; } |
| isInsightsSummaryLicensed() { return true; } |
| isInsightsDashboardLicensed() { return true; } |
| isInsightsHourlyDataLicensed() { return true; } |
| isWorkflowDiffsLicensed() { return true; } |
| isDataRedactionLicensed() { return true; } |
| isProvisioningLicensed() { return true; } |
| getMaxUsers() { return 99999999; } |
| getMaxActiveWorkflows() { return 99999999; } |
| getMaxVariables() { return 99999999; } |
| getMaxAiCredits() { return 99999999; } |
| getWorkflowHistoryPruneQuota() { return 99999999; } |
| getInsightsMaxHistory() { return 3650; } |
| getInsightsRetentionMaxAge() { return 3650; } |
| getInsightsRetentionPruneInterval() { return 1; } |
| getMaxTeamProjects() { return 99999999; } |
| getMaxWorkflowsWithEvaluations() { return 99999999; } |
| }; |
| exports.LicenseState = LicenseState; |
| exports.LicenseState = LicenseState = __decorate([ |
| (0, di_1.Service)() |
| ], LicenseState); |
| EOF |
|
|
| # ============================== |
| # 2. 覆盖 license.js（你提供的原版 + 只改一行 isLicensed 永久返回 true） |
| # ============================== |
| RUN cat > /usr/local/lib/node_modules/n8n/dist/license.js <<'EOF' |
| "use strict"; |
| var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) { |
| if (k2 === undefined) k2 = k; |
| var desc = Object.getOwnPropertyDescriptor(m, k); |
| if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) { |
| desc = { enumerable: true, get: function() { return m[k]; } }; |
| } |
| Object.defineProperty(o, k2, desc); |
| }) : (function(o, m, k, k2) { |
| if (k2 === undefined) k2 = k; |
| o[k2] = m[k]; |
| })); |
| var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) { |
| Object.defineProperty(o, "default", { enumerable: true, value: v }); |
| }) : function(o, v) { |
| o["default"] = v; |
| }); |
| var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) { |
| var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d; |
| if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc); |
| else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r; |
| return c > 3 && r && Object.defineProperty(target, key, r), r; |
| }; |
| var __importStar = (this && this.__importStar) || (function () { |
| var ownKeys = function(o) { |
| ownKeys = Object.getOwnPropertyNames || function (o) { |
| var ar = []; |
| for (var k in o) if (Object.prototype.hasOwnProperty.call(o, k)) ar[ar.length] = k; |
| return ar; |
| }; |
| return ownKeys(o); |
| }; |
| return function (mod) { |
| if (mod && mod.__esModule) return mod; |
| var result = {}; |
| if (mod != null) for (var k = ownKeys(mod), i = 0; i < k.length; i++) if (k[i] !== "default") __createBinding(result, mod, k[i]); |
| __setModuleDefault(result, mod); |
| return result; |
| }; |
| })(); |
| var __metadata = (this && this.__metadata) || function (k, v) { |
| if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v); |
| }; |
| Object.defineProperty(exports, "__esModule", { value: true }); |
| exports.License = void 0; |
| const backend_common_1 = require("@n8n/backend-common"); |
| const config_1 = require("@n8n/config"); |
| const constants_1 = require("@n8n/constants"); |
| const db_1 = require("@n8n/db"); |
| const decorators_1 = require("@n8n/decorators"); |
| const di_1 = require("@n8n/di"); |
| const license_sdk_1 = require("@n8n_io/license-sdk"); |
| const n8n_core_1 = require("n8n-core"); |
| const license_metrics_service_1 = require("./metrics/license-metrics.service"); |
| const constants_2 = require("./constants"); |
| const LICENSE_RENEWAL_DISABLED_WARNING = 'Automatic license renewal is disabled. The license will not renew automatically, and access to licensed features may be lost!'; |
| let License = class License { |
| constructor(logger, instanceSettings, settingsRepository, licenseMetricsService, globalConfig) { |
| this.logger = logger; |
| this.instanceSettings = instanceSettings; |
| this.settingsRepository = settingsRepository; |
| this.licenseMetricsService = licenseMetricsService; |
| this.globalConfig = globalConfig; |
| this.isShuttingDown = false; |
| this.refreshCallbacks = []; |
| this.logger = this.logger.scoped('license'); |
| } |
| async init({ forceRecreate = false, isCli = false, } = {}) { |
| if (this.manager && !forceRecreate) { |
| this.logger.warn('License manager already initialized or shutting down'); |
| return; |
| } |
| if (this.isShuttingDown) { |
| this.logger.warn('License manager already shutting down'); |
| return; |
| } |
| const { instanceType } = this.instanceSettings; |
| const isMainInstance = instanceType === 'main'; |
| const server = this.globalConfig.license.serverUrl; |
| const offlineMode = !isMainInstance; |
| const autoRenewOffset = 72 * constants_1.Time.hours.toSeconds; |
| const saveCertStr = isMainInstance |
| ? async (value) => await this.saveCertStr(value) |
| : async () => { }; |
| const onFeatureChange = isMainInstance |
| ? async () => await this.onFeatureChange() |
| : async () => { }; |
| const onLicenseRenewed = isMainInstance |
| ? async () => await this.onLicenseRenewed() |
| : async () => { }; |
| const collectUsageMetrics = isMainInstance |
| ? async () => await this.licenseMetricsService.collectUsageMetrics() |
| : async () => []; |
| const collectPassthroughData = isMainInstance |
| ? async () => await this.licenseMetricsService.collectPassthroughData() |
| : async () => ({}); |
| const onExpirySoon = !this.instanceSettings.isLeader ? () => this.onExpirySoon() : undefined; |
| const expirySoonOffsetMins = !this.instanceSettings.isLeader ? 120 : undefined; |
| const { isLeader } = this.instanceSettings; |
| const { autoRenewalEnabled } = this.globalConfig.license; |
| const eligibleToRenew = isCli || isLeader; |
| const shouldRenew = eligibleToRenew && autoRenewalEnabled; |
| if (eligibleToRenew && !autoRenewalEnabled) { |
| this.logger.warn(LICENSE_RENEWAL_DISABLED_WARNING); |
| } |
| try { |
| this.manager = new license_sdk_1.LicenseManager({ |
| server, |
| tenantId: this.globalConfig.license.tenantId, |
| productIdentifier: `n8n-${constants_2.N8N_VERSION}`, |
| autoRenewEnabled: shouldRenew, |
| renewOnInit: shouldRenew, |
| autoRenewOffset, |
| detachFloatingOnShutdown: this.globalConfig.license.detachFloatingOnShutdown, |
| offlineMode, |
| logger: this.logger, |
| loadCertStr: async () => await this.loadCertStr(), |
| saveCertStr, |
| deviceFingerprint: () => this.instanceSettings.instanceId, |
| collectUsageMetrics, |
| collectPassthroughData, |
| onFeatureChange, |
| onLicenseRenewed, |
| onExpirySoon, |
| expirySoonOffsetMins, |
| }); |
| await this.manager.initialize(); |
| this.logger.debug('License initialized'); |
| } |
| catch (error) { |
| if (error instanceof Error) { |
| this.logger.error('Could not initialize license manager sdk', { error }); |
| } |
| } |
| } |
| async loadCertStr() { |
| const ephemeralLicense = this.globalConfig.license.cert; |
| if (ephemeralLicense) { |
| return ephemeralLicense; |
| } |
| const databaseSettings = await this.settingsRepository.findOne({ |
| where: { |
| key: constants_2.SETTINGS_LICENSE_CERT_KEY, |
| }, |
| }); |
| return databaseSettings?.value ?? ''; |
| } |
| async onFeatureChange() { |
| void this.broadcastReloadLicenseCommand(); |
| await this.notifyRefreshCallbacks(); |
| } |
| async onLicenseRenewed() { |
| void this.broadcastReloadLicenseCommand(); |
| await this.notifyRefreshCallbacks(); |
| } |
| async broadcastReloadLicenseCommand() { |
| if (this.globalConfig.executions.mode === 'queue' && this.instanceSettings.isLeader) { |
| const { Publisher } = await Promise.resolve().then(() => __importStar(require('./scaling/pubsub/publisher.service'))); |
| await di_1.Container.get(Publisher).publishCommand({ command: 'reload-license' }); |
| } |
| } |
| async saveCertStr(value) { |
| if (this.globalConfig.license.cert) |
| return; |
| await this.settingsRepository.upsert({ |
| key: constants_2.SETTINGS_LICENSE_CERT_KEY, |
| value, |
| loadOnStartup: false, |
| }, ['key']); |
| } |
| onCertRefresh(refreshCallback) { |
| this.refreshCallbacks.push(refreshCallback); |
| return () => { |
| const index = this.refreshCallbacks.indexOf(refreshCallback); |
| if (index > -1) { |
| this.refreshCallbacks.splice(index, 1); |
| } |
| }; |
| } |
| async notifyRefreshCallbacks() { |
| const cert = await this.loadCertStr(); |
| for (const refreshCallback of this.refreshCallbacks) { |
| try { |
| refreshCallback(cert); |
| } |
| catch (error) { |
| this.logger.error('Error in license refresh callback', { error }); |
| } |
| } |
| } |
| async activate(activationKey, eulaUri, userEmail) { |
| if (!this.manager) { |
| return; |
| } |
| await this.manager.activate(activationKey, { eulaUri, email: userEmail }); |
| this.logger.debug('License activated'); |
| } |
| async reload() { |
| if (!this.manager) { |
| return; |
| } |
| await this.manager.reload(); |
| await this.notifyRefreshCallbacks(); |
| this.logger.debug('License reloaded'); |
| } |
| async renew() { |
| if (!this.manager) { |
| return; |
| } |
| await this.manager.renew(); |
| this.logger.debug('License renewed'); |
| } |
| async clear() { |
| if (!this.manager) { |
| return; |
| } |
| await this.manager.clear(); |
| this.logger.info('License cleared'); |
| } |
| async shutdown() { |
| this.isShuttingDown = true; |
| if (!this.manager) { |
| return; |
| } |
| await this.manager.shutdown(); |
| this.logger.debug('License shut down'); |
| } |
| isLicensed(feature) { return true; } |
| isDynamicCredentialsEnabled() { return true; } |
| isSharingEnabled() { return true; } |
| isLogStreamingEnabled() { return true; } |
| isLdapEnabled() { return true; } |
| isSamlEnabled() { return true; } |
| isAiAssistantEnabled() { return true; } |
| isAskAiEnabled() { return true; } |
| isAiCreditsEnabled() { return true; } |
| isAdvancedExecutionFiltersEnabled() { return true; } |
| isAdvancedPermissionsLicensed() { return true; } |
| isDebugInEditorLicensed() { return true; } |
| isBinaryDataS3Licensed() { return true; } |
| isMultiMainLicensed() { return true; } |
| isVariablesEnabled() { return true; } |
| isSourceControlLicensed() { return true; } |
| isExternalSecretsEnabled() { return true; } |
| isAPIDisabled() { return false; } |
| isWorkerViewLicensed() { return true; } |
| isProjectRoleAdminLicensed() { return true; } |
| isProjectRoleEditorLicensed() { return true; } |
| isProjectRoleViewerLicensed() { return true; } |
| isCustomNpmRegistryEnabled() { return true; } |
| isFoldersEnabled() { return true; } |
| getCurrentEntitlements() { return this.manager?.getCurrentEntitlements() ?? []; } |
| getValue(feature) { return 99999999; } |
| getManagementJwt() { return this.manager?.getManagementJwt() ?? ''; } |
| getMainPlan() { |
| if (!this.manager) return undefined; |
| const entitlements = this.getCurrentEntitlements(); |
| if (!entitlements.length) return undefined; |
| entitlements.sort((a, b) => b.validFrom.getTime() - a.validFrom.getTime()); |
| return entitlements.find((entitlement) => entitlement.productMetadata?.terms?.isMainPlan); |
| } |
| getConsumerId() { return this.manager?.getConsumerId() ?? 'unknown'; } |
| getUsersLimit() { return 99999999; } |
| getTriggerLimit() { return 99999999; } |
| getVariablesLimit() { return 99999999; } |
| getAiCredits() { return 99999999; } |
| getWorkflowHistoryPruneLimit() { return 99999999; } |
| getTeamProjectLimit() { return 99999999; } |
| getPlanName() { return "Enterprise"; } |
| getExpiryDate() { return new Date('3099-12-31'); } |
| getTerminationDate() { return new Date('3099-12-31'); } |
| getExpiringInDays() { return 36500; } |
| getTerminatingInDays() { return 36500; } |
| getInfo() { return 'Enterprise License (Unlimited)'; } |
| isWithinUsersLimit() { return true; } |
| enableAutoRenewals() {} |
| disableAutoRenewals() {} |
| onExpirySoon() {} |
| }; |
| exports.License = License; |
| __decorate([ |
| (0, decorators_1.OnPubSubEvent)('reload-license'), |
| __metadata("design:type", Function), |
| __metadata("design:paramtypes", []), |
| __metadata("design:returntype", Promise) |
| ], License.prototype, "reload", null); |
| __decorate([ |
| (0, decorators_1.OnShutdown)(), |
| __metadata("design:type", Function), |
| __metadata("design:paramtypes", []), |
| __metadata("design:returntype", Promise) |
| ], License.prototype, "shutdown", null); |
| __decorate([ |
| (0, decorators_1.OnLeaderTakeover)(), |
| __metadata("design:type", Function), |
| __metadata("design:paramtypes", []), |
| __metadata("design:returntype", void 0) |
| ], License.prototype, "enableAutoRenewals", null); |
| __decorate([ |
| (0, decorators_1.OnLeaderStepdown)(), |
| __metadata("design:type", Function), |
| __metadata("design:paramtypes", []), |
| __metadata("design:returntype", void 0) |
| ], License.prototype, "disableAutoRenewals", null); |
| exports.License = License = __decorate([ |
| (0, di_1.Service)(), |
| __metadata("design:paramtypes", [backend_common_1.Logger, |
| n8n_core_1.InstanceSettings, |
| db_1.SettingsRepository, |
| license_metrics_service_1.LicenseMetricsService, |
| config_1.GlobalConfig]) |
| ], License); |
| EOF |
|
|
| # ============================== |
| # 启动 n8n |
| # ============================== |
| USER node |
|
|
