mirror of
				https://github.com/NginxProxyManager/nginx-proxy-manager.git
				synced 2025-11-03 17:13:33 +00:00 
			
		
		
		
	
		
			
				
	
	
		
			126 lines
		
	
	
		
			2.8 KiB
		
	
	
	
		
			JavaScript
		
	
	
	
	
	
			
		
		
	
	
			126 lines
		
	
	
		
			2.8 KiB
		
	
	
	
		
			JavaScript
		
	
	
	
	
	
import fs from "node:fs";
 | 
						|
import errs from "../lib/error.js";
 | 
						|
import settingModel from "../models/setting.js";
 | 
						|
import internalNginx from "./nginx.js";
 | 
						|
 | 
						|
const internalSetting = {
 | 
						|
	/**
 | 
						|
	 * @param  {Access}  access
 | 
						|
	 * @param  {Object}  data
 | 
						|
	 * @param  {String}  data.id
 | 
						|
	 * @return {Promise}
 | 
						|
	 */
 | 
						|
	update: (access, data) => {
 | 
						|
		return access
 | 
						|
			.can("settings:update", data.id)
 | 
						|
			.then((/*access_data*/) => {
 | 
						|
				return internalSetting.get(access, { id: data.id });
 | 
						|
			})
 | 
						|
			.then((row) => {
 | 
						|
				if (row.id !== data.id) {
 | 
						|
					// Sanity check that something crazy hasn't happened
 | 
						|
					throw new errs.InternalValidationError(
 | 
						|
						`Setting could not be updated, IDs do not match: ${row.id} !== ${data.id}`,
 | 
						|
					);
 | 
						|
				}
 | 
						|
 | 
						|
				return settingModel.query().where({ id: data.id }).patch(data);
 | 
						|
			})
 | 
						|
			.then(() => {
 | 
						|
				return internalSetting.get(access, {
 | 
						|
					id: data.id,
 | 
						|
				});
 | 
						|
			})
 | 
						|
			.then((row) => {
 | 
						|
				if (row.id === "default-site") {
 | 
						|
					// write the html if we need to
 | 
						|
					if (row.value === "html") {
 | 
						|
						fs.writeFileSync("/data/nginx/default_www/index.html", row.meta.html, { encoding: "utf8" });
 | 
						|
					}
 | 
						|
 | 
						|
					// Configure nginx
 | 
						|
					return internalNginx
 | 
						|
						.deleteConfig("default")
 | 
						|
						.then(() => {
 | 
						|
							return internalNginx.generateConfig("default", row);
 | 
						|
						})
 | 
						|
						.then(() => {
 | 
						|
							return internalNginx.test();
 | 
						|
						})
 | 
						|
						.then(() => {
 | 
						|
							return internalNginx.reload();
 | 
						|
						})
 | 
						|
						.then(() => {
 | 
						|
							return row;
 | 
						|
						})
 | 
						|
						.catch((/*err*/) => {
 | 
						|
							internalNginx
 | 
						|
								.deleteConfig("default")
 | 
						|
								.then(() => {
 | 
						|
									return internalNginx.test();
 | 
						|
								})
 | 
						|
								.then(() => {
 | 
						|
									return internalNginx.reload();
 | 
						|
								})
 | 
						|
								.then(() => {
 | 
						|
									// I'm being slack here I know..
 | 
						|
									throw new errs.ValidationError("Could not reconfigure Nginx. Please check logs.");
 | 
						|
								});
 | 
						|
						});
 | 
						|
				}
 | 
						|
				return row;
 | 
						|
			});
 | 
						|
	},
 | 
						|
 | 
						|
	/**
 | 
						|
	 * @param  {Access}   access
 | 
						|
	 * @param  {Object}   data
 | 
						|
	 * @param  {String}   data.id
 | 
						|
	 * @return {Promise}
 | 
						|
	 */
 | 
						|
	get: (access, data) => {
 | 
						|
		return access
 | 
						|
			.can("settings:get", data.id)
 | 
						|
			.then(() => {
 | 
						|
				return settingModel.query().where("id", data.id).first();
 | 
						|
			})
 | 
						|
			.then((row) => {
 | 
						|
				if (row) {
 | 
						|
					return row;
 | 
						|
				}
 | 
						|
				throw new errs.ItemNotFoundError(data.id);
 | 
						|
			});
 | 
						|
	},
 | 
						|
 | 
						|
	/**
 | 
						|
	 * This will only count the settings
 | 
						|
	 *
 | 
						|
	 * @param   {Access}  access
 | 
						|
	 * @returns {*}
 | 
						|
	 */
 | 
						|
	getCount: (access) => {
 | 
						|
		return access
 | 
						|
			.can("settings:list")
 | 
						|
			.then(() => {
 | 
						|
				return settingModel.query().count("id as count").first();
 | 
						|
			})
 | 
						|
			.then((row) => {
 | 
						|
				return Number.parseInt(row.count, 10);
 | 
						|
			});
 | 
						|
	},
 | 
						|
 | 
						|
	/**
 | 
						|
	 * All settings
 | 
						|
	 *
 | 
						|
	 * @param   {Access}  access
 | 
						|
	 * @returns {Promise}
 | 
						|
	 */
 | 
						|
	getAll: (access) => {
 | 
						|
		return access.can("settings:list").then(() => {
 | 
						|
			return settingModel.query().orderBy("description", "ASC");
 | 
						|
		});
 | 
						|
	},
 | 
						|
};
 | 
						|
 | 
						|
export default internalSetting;
 |